Add MessengerRegisterGroupRequestHandler

Sources/XXMessengerClient/Messenger/Functions/MessengerRegisterGroupRequestHandler.swift

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

Sources/XXMessengerClient/Messenger/Messenger.swift

@@ -49,6 +49,7 @@ public struct Messenger {
   public var receiveFile: MessengerReceiveFile
   public var trackServices: MessengerTrackServices
   public var getNotificationReports: MessengerGetNotificationReports
+  public var registerGroupRequestHandler: MessengerRegisterGroupRequestHandler
   public var startGroupChat: MessengerStartGroupChat
 }
 
@@ -103,6 +104,7 @@ extension Messenger {
       receiveFile: .live(env),
       trackServices: .live(env),
       getNotificationReports: .live(env),
+      registerGroupRequestHandler: .live(env),
       startGroupChat: .live(env)
     )
   }
@@ -158,6 +160,7 @@ extension Messenger {
     receiveFile: .unimplemented,
     trackServices: .unimplemented,
     getNotificationReports: .unimplemented,
+    registerGroupRequestHandler: .unimplemented,
     startGroupChat: .unimplemented
   )
 }

Tests/XXMessengerClientTests/Messenger/Functions/MessengerRegisterGroupRequestHandlerTests.swift

+import XCTest
+import XXClient
+@testable import XXMessengerClient
+
+final class MessengerRegisterGroupRequestHandlerTests: XCTestCase {
+  func testRegister() {
+    var registered: [GroupRequest] = []
+    var didHandle: [Group] = []
+    var didCancel = 0
+
+    var env: MessengerEnvironment = .unimplemented
+    env.groupRequests.register = { handler in
+      registered.append(handler)
+      return Cancellable { didCancel += 1 }
+    }
+    let register: MessengerRegisterGroupRequestHandler = .live(env)
+    let cancellable = register(.init { group in
+      didHandle.append(group)
+    })
+
+    XCTAssertEqual(registered.count, 1)
+
+    let group = Group.stub(1)
+    registered.forEach { handler in
+      handler.handle(group)
+    }
+
+    XCTAssertEqual(didHandle.map { $0.getId() }, [group.getId()])
+
+    cancellable.cancel()
+
+    XCTAssertEqual(didCancel, 1)
+  }
+}