|
|
@ -87,7 +87,10 @@ public final class ClosedGroupPoller : NSObject {
|
|
|
|
timers[groupPublicKey] = Timer.scheduledTimerOnMainThread(withTimeInterval: nextPollInterval, repeats: false) { [weak self] timer in
|
|
|
|
timers[groupPublicKey] = Timer.scheduledTimerOnMainThread(withTimeInterval: nextPollInterval, repeats: false) { [weak self] timer in
|
|
|
|
timer.invalidate()
|
|
|
|
timer.invalidate()
|
|
|
|
Threading.pollerQueue.async {
|
|
|
|
Threading.pollerQueue.async {
|
|
|
|
self?.poll(groupPublicKey).done(on: Threading.pollerQueue) { _ in
|
|
|
|
var promises: [Promise<Void>] = []
|
|
|
|
|
|
|
|
if let promise = self?.poll(groupPublicKey) { promises.append(promise) }
|
|
|
|
|
|
|
|
if SnodeAPI.inHardfork, let promise = self?.poll(groupPublicKey, defaultInbox: true) { promises.append(promise) }
|
|
|
|
|
|
|
|
when(resolved: promises).done(on: Threading.pollerQueue) { _ in
|
|
|
|
self?.pollRecursively(groupPublicKey)
|
|
|
|
self?.pollRecursively(groupPublicKey)
|
|
|
|
}.catch(on: Threading.pollerQueue) { error in
|
|
|
|
}.catch(on: Threading.pollerQueue) { error in
|
|
|
|
// The error is logged in poll(_:)
|
|
|
|
// The error is logged in poll(_:)
|
|
|
@ -97,13 +100,14 @@ public final class ClosedGroupPoller : NSObject {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
private func poll(_ groupPublicKey: String) -> Promise<Void> {
|
|
|
|
private func poll(_ groupPublicKey: String, defaultInbox: Bool = false) -> Promise<Void> {
|
|
|
|
guard isPolling(for: groupPublicKey) else { return Promise.value(()) }
|
|
|
|
guard isPolling(for: groupPublicKey) else { return Promise.value(()) }
|
|
|
|
let promise = SnodeAPI.getSwarm(for: groupPublicKey).then2 { [weak self] swarm -> Promise<(Snode, [JSON], JSON?)> in
|
|
|
|
let promise = SnodeAPI.getSwarm(for: groupPublicKey).then2 { [weak self] swarm -> Promise<(Snode, [JSON], JSON?)> in
|
|
|
|
// randomElement() uses the system's default random generator, which is cryptographically secure
|
|
|
|
// randomElement() uses the system's default random generator, which is cryptographically secure
|
|
|
|
guard let snode = swarm.randomElement() else { return Promise(error: Error.insufficientSnodes) }
|
|
|
|
guard let snode = swarm.randomElement() else { return Promise(error: Error.insufficientSnodes) }
|
|
|
|
guard let self = self, self.isPolling(for: groupPublicKey) else { return Promise(error: Error.pollingCanceled) }
|
|
|
|
guard let self = self, self.isPolling(for: groupPublicKey) else { return Promise(error: Error.pollingCanceled) }
|
|
|
|
return SnodeAPI.getRawMessages(from: snode, associatedWith: groupPublicKey, authenticated: false).map2 {
|
|
|
|
let getRawMessagesPromise = defaultInbox ? SnodeAPI.getRawClosedGroupMessagesFromDefaultNamespace(from: snode, associatedWith: groupPublicKey) : SnodeAPI.getRawMessages(from: snode, associatedWith: groupPublicKey, authenticated: false)
|
|
|
|
|
|
|
|
return getRawMessagesPromise.map2 {
|
|
|
|
let (rawMessages, lastRawMessage) = SnodeAPI.parseRawMessagesResponse($0, from: snode, associatedWith: groupPublicKey)
|
|
|
|
let (rawMessages, lastRawMessage) = SnodeAPI.parseRawMessagesResponse($0, from: snode, associatedWith: groupPublicKey)
|
|
|
|
|
|
|
|
|
|
|
|
return (snode, rawMessages, lastRawMessage)
|
|
|
|
return (snode, rawMessages, lastRawMessage)
|
|
|
|