From 96f07d6e2be16a9012a149aadba4974ee558c6f0 Mon Sep 17 00:00:00 2001 From: haad Date: Thu, 16 Feb 2023 12:32:31 +0200 Subject: [PATCH] Fix peer sending messages to themselves --- src/db/interface.js | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/src/db/interface.js b/src/db/interface.js index 85c92e7..65ab7e6 100644 --- a/src/db/interface.js +++ b/src/db/interface.js @@ -28,8 +28,7 @@ const Database = async ({ OpLog, ipfs, identity, databaseId, accessController, s const messageIsNotFromMe = (message) => String(peerId) !== String(message.from) const messageHasData = (message) => message.data !== undefined try { - // if (messageIsNotFromMe(message) && messageHasData(message)) { - if (messageHasData(message)) { + if (messageIsNotFromMe(message) && messageHasData(message)) { await sync(message.data) } } catch (e) { @@ -50,8 +49,8 @@ const Database = async ({ OpLog, ipfs, identity, databaseId, accessController, s } const close = async () => { - await log.close() await ipfs.pubsub.unsubscribe(log.id, handleMessage) + await log.close() events.emit('close') }