send chat messages between the clients

WalletConnect · Jul 5, 2022 · 235fdb9 · 235fdb9
1 parent e238566
commit 235fdb9
Show file tree

Hide file tree

Showing 3 changed files with 14 additions and 4 deletions.
diff --git a/Sources/Chat/ProtocolServices/Common/MessagingService.swift b/Sources/Chat/ProtocolServices/Common/MessagingService.swift
@@ -13,6 +13,7 @@ class MessagingService {
         self.networkingInteractor = networkingInteractor
         self.logger = logger
         setUpResponseHandling()
+        setUpRequestHandling()
     }
 
     func send(topic: String, messageString: String) async throws {

diff --git a/Sources/Chat/ProtocolServices/Invitee/InvitationHandlingService.swift b/Sources/Chat/ProtocolServices/Invitee/InvitationHandlingService.swift
@@ -74,8 +74,8 @@ class InvitationHandlingService {
                 } catch {
                     logger.debug("Did not handle invite, error: \(error)")
                 }
-            case .message(let message):
-                print("received message: \(message)")
+            default:
+                return
             }
         }.store(in: &publishers)
     }

diff --git a/Tests/ChatTests/EndToEndTests.swift b/Tests/ChatTests/EndToEndTests.swift
@@ -86,6 +86,7 @@ final class ChatTests: XCTestCase {
     func testMessage() async {
         await waitClientsConnected()
         let messageExpectation = expectation(description: "message received")
+        messageExpectation.expectedFulfillmentCount = 2
         let message = "message"
 
         let account = Account(chainIdentifier: "eip155:1", address: "0x3627523167367216556273151")!
@@ -100,9 +101,17 @@ final class ChatTests: XCTestCase {
             Task {try! await invitee.message(topic: thread.topic, message: message)}
         }.store(in: &publishers)
 
-        inviter.messagePublisher.sink { [unowned self] message in
+        inviter.newThreadPublisher.sink { [unowned self] thread in
+            Task {try! await inviter.message(topic: thread.topic, message: message)}
+        }.store(in: &publishers)
+
+        inviter.messagePublisher.sink { message in
+            messageExpectation.fulfill()
+        }.store(in: &publishers)
+
+        invitee.messagePublisher.sink { message in
             messageExpectation.fulfill()
-        }
+        }.store(in: &publishers)
 
         wait(for: [messageExpectation], timeout: 4)
     }