remove messages duplicates after app relaunch

Sources/Chat/NetworkingInteractor.swift

@@ -8,6 +8,7 @@ protocol NetworkInteracting {
     var socketConnectionStatusPublisher: AnyPublisher<SocketConnectionStatus, Never> { get }
     var requestPublisher: AnyPublisher<RequestSubscriptionPayload, Never> {get}
     var responsePublisher: AnyPublisher<ChatResponse, Never> {get}
+    func respondSuccess(payload: RequestSubscriptionPayload) async throws
     func subscribe(topic: String) async throws
     func request(_ request: JSONRPCRequest<ChatRequestParams>, topic: String, envelopeType: Envelope.EnvelopeType) async throws
     func respond(topic: String, response: JsonRpcResult) async throws
@@ -59,7 +60,13 @@ class NetworkingInteractor: NetworkInteracting {
         try await relayClient.publish(topic: topic, payload: message, tag: .chat)
     }
 
+    func respondSuccess(payload: RequestSubscriptionPayload) async throws {
+        let response = JSONRPCResponse<AnyCodable>(id: payload.request.id, result: AnyCodable(true))
+        try await respond(topic: payload.topic, response: JsonRpcResult.response(response))
+    }
+
     func respond(topic: String, response: JsonRpcResult) async throws {
+        _ = try jsonRpcHistory.resolve(response: response)
         let message = try serializer.serialize(topic: topic, encodable: response.value)
         try await relayClient.publish(topic: topic, payload: message, tag: .chat, prompt: false)
     }
@@ -81,8 +88,13 @@ class NetworkingInteractor: NetworkInteracting {
     }
 
     private func handleChatRequest(topic: String, request: JSONRPCRequest<ChatRequestParams>) {
-        let payload = RequestSubscriptionPayload(topic: topic, request: request)
-        requestPublisherSubject.send(payload)
+        do {
+            try jsonRpcHistory.set(topic: topic, request: request)
+            let payload = RequestSubscriptionPayload(topic: topic, request: request)
+            requestPublisherSubject.send(payload)
+        } catch {
+            logger.debug(error)
+        }
     }
 
     private func handleJsonRpcResponse(response: JSONRPCResponse<AnyCodable>) {

Sources/Chat/ProtocolServices/Common/MessagingService.swift

@@ -56,15 +56,16 @@ class MessagingService {
             switch subscriptionPayload.request.params {
             case .message(var message):
                 message.topic = subscriptionPayload.topic
-                handleMessage(message)
+                handleMessage(message, subscriptionPayload)
             default:
                 return
             }
         }.store(in: &publishers)
     }
 
-    private func handleMessage(_ message: Message) {
+    private func handleMessage(_ message: Message, _ payload: RequestSubscriptionPayload) {
         Task(priority: .background) {
+            try await networkingInteractor.respondSuccess(payload: payload)
             await messagesStore.add(message)
             logger.debug("Received message")
             onMessage?(message)

Sources/WalletConnectSign/NetworkInteractor/NetworkInteractor.swift

@@ -226,7 +226,7 @@ class NetworkInteractor: NetworkInteracting {
             logger.info("Info: \(error.localizedDescription)")
         }
     }
-
+    
     private func handleJsonRpcErrorResponse(response: JSONRPCErrorResponse) {
         do {
             let record = try jsonRpcHistory.resolve(response: JsonRpcResult.error(response))

Tests/ChatTests/Mocks/NetworkingInteractorMock.swift

@@ -5,6 +5,7 @@ import WalletConnectUtils
 import WalletConnectRelay
 
 class NetworkingInteractorMock: NetworkInteracting {
+
     var socketConnectionStatusPublisher: AnyPublisher<SocketConnectionStatus, Never> {
         socketConnectionStatusPublisherSubject.eraseToAnyPublisher()
     }
@@ -34,6 +35,10 @@ class NetworkingInteractorMock: NetworkInteracting {
 
     }
 
+    func respondSuccess(payload: RequestSubscriptionPayload) async throws {
+
+    }
+
     private(set) var subscriptions: [String] = []
 
     func subscribe(topic: String) async throws {