diff --git a/lib/tunnelbroker/peer-to-peer-message-handler.js b/lib/tunnelbroker/peer-to-peer-message-handler.js --- a/lib/tunnelbroker/peer-to-peer-message-handler.js +++ b/lib/tunnelbroker/peer-to-peer-message-handler.js @@ -74,7 +74,7 @@ return; } try { - await peerToPeerMessageHandler(peerToPeerMessage, message.messageID); + await peerToPeerMessageHandler(peerToPeerMessage); } catch (e) { console.log(e.message); } finally { diff --git a/lib/tunnelbroker/use-peer-to-peer-message-handler.js b/lib/tunnelbroker/use-peer-to-peer-message-handler.js --- a/lib/tunnelbroker/use-peer-to-peer-message-handler.js +++ b/lib/tunnelbroker/use-peer-to-peer-message-handler.js @@ -103,7 +103,6 @@ function usePeerToPeerMessageHandler(): ( message: PeerToPeerMessage, - messageID: string, ) => Promise { const { olmAPI, sqliteAPI } = getConfig(); @@ -118,7 +117,7 @@ const handleOlmMessageToDevice = useHandleOlmMessageToDevice(); return React.useCallback( - async (message: PeerToPeerMessage, messageID: string) => { + async (message: PeerToPeerMessage) => { if (message.type === peerToPeerMessageTypes.OUTBOUND_SESSION_CREATION) { const { senderInfo, encryptedData, sessionVersion } = message; const { userID: senderUserID, deviceID: senderDeviceID } = senderInfo; @@ -194,10 +193,9 @@ } else if (message.type === peerToPeerMessageTypes.ENCRYPTED_MESSAGE) { try { await olmAPI.initializeCryptoAccount(); - const decrypted = await olmAPI.decryptSequentialAndPersist( + const decrypted = await olmAPI.decrypt( message.encryptedData, message.senderInfo.deviceID, - messageID, ); console.log( 'Decrypted message from device ' +