Add MessengerRegisterGroupChatProcessor

Sources/XXMessengerClient/Messenger/Functions/MessengerRegisterGroupChatProcessor.swift

+import XCTestDynamicOverlay
+import XXClient
+
+public struct MessengerRegisterGroupChatProcessor {
+  public var run: (GroupChatProcessor) -> Cancellable
+
+  public func callAsFunction(_ processor: GroupChatProcessor) -> Cancellable {
+    run(processor)
+  }
+}
+
+extension MessengerRegisterGroupChatProcessor {
+  public static func live(_ env: MessengerEnvironment) -> MessengerRegisterGroupChatProcessor {
+    MessengerRegisterGroupChatProcessor { processor in
+      env.groupChatProcessors.register(processor)
+    }
+  }
+}
+
+extension MessengerRegisterGroupChatProcessor {
+  public static let unimplemented = MessengerRegisterGroupChatProcessor(
+    run: XCTUnimplemented("\(Self.self)", placeholder: Cancellable {})
+  )
+}

Sources/XXMessengerClient/Messenger/Messenger.swift

@@ -50,6 +50,7 @@ public struct Messenger {
   public var trackServices: MessengerTrackServices
   public var getNotificationReports: MessengerGetNotificationReports
   public var registerGroupRequestHandler: MessengerRegisterGroupRequestHandler
+  public var registerGroupChatProcessor: MessengerRegisterGroupChatProcessor
   public var startGroupChat: MessengerStartGroupChat
 }
 
@@ -105,6 +106,7 @@ extension Messenger {
       trackServices: .live(env),
       getNotificationReports: .live(env),
       registerGroupRequestHandler: .live(env),
+      registerGroupChatProcessor: .live(env),
       startGroupChat: .live(env)
     )
   }
@@ -161,6 +163,7 @@ extension Messenger {
     trackServices: .unimplemented,
     getNotificationReports: .unimplemented,
     registerGroupRequestHandler: .unimplemented,
+    registerGroupChatProcessor: .unimplemented,
     startGroupChat: .unimplemented
   )
 }

Tests/XXMessengerClientTests/Messenger/Functions/MessengerRegisterGroupChatProcessorTests.swift

+import XCTest
+import XXClient
+@testable import XXMessengerClient
+
+final class MessengerRegisterGroupChatProcessorTests: XCTestCase {
+  func testRegister() {
+    var registered: [GroupChatProcessor] = []
+    var didHandle: [GroupChatProcessor.Result] = []
+    var didCancel = 0
+
+    var env: MessengerEnvironment = .unimplemented
+    env.groupChatProcessors.register = { processor in
+      registered.append(processor)
+      return Cancellable { didCancel += 1 }
+    }
+    let register: MessengerRegisterGroupChatProcessor = .live(env)
+    let cancellable = register(.init { result in
+      didHandle.append(result)
+    })
+
+    XCTAssertEqual(registered.count, 1)
+
+    let result = GroupChatProcessor.Result.success(.stub())
+    registered.forEach { processor in
+      processor.handle(result)
+    }
+
+    XCTAssertEqual(didHandle, [result])
+
+    cancellable.cancel()
+
+    XCTAssertEqual(didCancel, 1)
+  }
+}