Mirroristas/orbitdb
2
0
Fork 0
mirror of https://github.com/orbitdb/orbitdb.git synced 2025-06-27 16:32:30 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix peer sending messages to themselves

Browse Source
This commit is contained in:
haad 2023-02-16 12:32:31 +02:00
parent 967abafb8d
commit 96f07d6e2b
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/db/interface.js
View File

@ -28,8 +28,7 @@ const Database = async ({ OpLog, ipfs, identity, databaseId, accessController, s
const messageIsNotFromMe = (message) => String(peerId) !== String(message.from) const messageIsNotFromMe = (message) => String(peerId) !== String(message.from)
const messageHasData = (message) => message.data !== undefined const messageHasData = (message) => message.data !== undefined
try { try {
// if (messageIsNotFromMe(message) && messageHasData(message)) { if (messageIsNotFromMe(message) && messageHasData(message)) {
if (messageHasData(message)) {
await sync(message.data) await sync(message.data)
} }
} catch (e) { } catch (e) {
@ -50,8 +49,8 @@ const Database = async ({ OpLog, ipfs, identity, databaseId, accessController, s
} }
const close = async () => { const close = async () => {
await log.close()
await ipfs.pubsub.unsubscribe(log.id, handleMessage) await ipfs.pubsub.unsubscribe(log.id, handleMessage)
await log.close()
events.emit('close') events.emit('close')
} }