Debug

SessionMessagingKit/Open Groups/V2/OpenGroupAPIV2.swift

@@ -128,37 +128,41 @@ public final class OpenGroupAPIV2 : NSObject {
     }
     
     public static func compactPoll(_ server: String) -> Promise<[CompactPollResponseBody]> {
-        #if DEBUG
-        dispatchPrecondition(condition: .onQueue(.main))
-        #endif
         let storage = SNMessagingKitConfiguration.shared.storage
         let rooms = storage.getAllV2OpenGroups().values.filter { $0.server == server }.map { $0.room }
         var body: [JSON] = []
+        var authTokenPromises: [String:Promise<String>] = [:]
         for room in rooms {
-            // It's okay for this to be blocking. This call happens on a background thread
+            authTokenPromises[room] = getAuthToken(for: room, on: server)
-            // plus we'll almost always have the auth token in storage anyway.
+            var json: JSON = [ "room_id" : room ]
-            guard let authToken = try? getAuthToken(for: room, on: server).wait() else { continue }
-            var json: JSON = [ "room_id" : room, "auth_token" : authToken ]
             if let lastMessageServerID = storage.getLastMessageServerID(for: room, on: server) {
-                json["from_message_server_id"] = String(lastMessageServerID)
+                json["from_message_server_id"] = lastMessageServerID
             }
             if let lastDeletionServerID = storage.getLastDeletionServerID(for: room, on: server) {
-                json["from_deletion_server_id"] = String(lastDeletionServerID)
+                json["from_deletion_server_id"] = lastDeletionServerID
             }
             body.append(json)
         }
-        let request = Request(verb: .post, room: nil, server: server, endpoint: "compact_poll", parameters: [ "requests" : body ], isAuthRequired: false)
+        return when(fulfilled: [Promise<String>](authTokenPromises.values)).then(on: DispatchQueue.global(qos: .userInitiated)) { _ -> Promise<[CompactPollResponseBody]> in
-        return send(request).then(on: DispatchQueue.global(qos: .userInitiated)) { json -> Promise<[CompactPollResponseBody]> in
+            let bodyWithAuthTokens = body.compactMap { json -> JSON? in
-            guard let results = json["results"] as? [JSON] else { throw Error.parsingFailed }
+                guard let roomID = json["room_id"] as? String, let authToken = authTokenPromises[roomID]?.value else { return nil }
-            let promises = results.compactMap { json -> Promise<CompactPollResponseBody>? in
+                var json = json
-                guard let room = json["room_id"] as? String else { return nil }
+                json["auth_token"] = authToken
-                let deletions = json["deletions"] as? [Int64] ?? []
+                return json
-                let moderators = json["moderators"] as? [String] ?? []
+            }
-                return try? parseMessages(from: json, for: room, on: server).map { messages in
+            let request = Request(verb: .post, room: nil, server: server, endpoint: "compact_poll", parameters: [ "requests" : bodyWithAuthTokens ], isAuthRequired: false)
-                    return CompactPollResponseBody(room: room, messages: messages, deletions: deletions, moderators: moderators)
+            return send(request).then(on: DispatchQueue.global(qos: .userInitiated)) { json -> Promise<[CompactPollResponseBody]> in
+                guard let results = json["results"] as? [JSON] else { throw Error.parsingFailed }
+                let promises = results.compactMap { json -> Promise<CompactPollResponseBody>? in
+                    guard let room = json["room_id"] as? String else { return nil }
+                    let deletions = json["deletions"] as? [Int64] ?? []
+                    let moderators = json["moderators"] as? [String] ?? []
+                    return try? parseMessages(from: json, for: room, on: server).map { messages in
+                        return CompactPollResponseBody(room: room, messages: messages, deletions: deletions, moderators: moderators)
+                    }
                 }
+                return when(fulfilled: promises)
             }
-            return when(fulfilled: promises)
         }
     }
     

SessionMessagingKit/Sending & Receiving/Pollers/OpenGroupPollerV2.swift

@@ -58,7 +58,9 @@ public final class OpenGroupPollerV2 : NSObject {
             self.isPolling = false
             bodies.forEach { self.handleCompactPollBody($0, isBackgroundPoll: isBackgroundPoll) }
             seal.fulfill(())
-        }.catch(on: DispatchQueue.global(qos: .userInitiated)) { _ in
+        }.catch(on: DispatchQueue.global(qos: .userInitiated)) { error in
+            SNLog("Open group polling failed due to error: \(error).")
+            self.isPolling = false
             seal.fulfill(()) // The promise is just used to keep track of when we're done
         }
         return promise