Mirroristas/orbitdb
2
0
Fork 0
mirror of https://github.com/orbitdb/orbitdb.git synced 2025-03-30 15:08:28 +00:00
Code Issues Packages Projects Releases Wiki Activity

Update sync.test.js

Browse Source
This commit is contained in:
Julien Malard-Adam 2025-02-16 16:47:06 +01:00 committed by julienmalard
parent 2d9c6c8962
commit b92847f255
1 changed files with 61 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

85
test/sync.test.js
View File

@ -661,6 +661,67 @@ describe('Sync protocol', function () {
})
})
describe('Events - error listener', () => {
let sync1, sync2
let log1, log2
const timeoutTime = 1 // 1 millisecond
before(async () => {
[ipfs1, ipfs2] = await Promise.all([createHelia(), createHelia()])
peerId1 = ipfs1.libp2p.peerId
peerId2 = ipfs2.libp2p.peerId
await connectPeers(ipfs1, ipfs2)
log1 = await Log(testIdentity1, { logId: 'synclog6' })
log2 = await Log(testIdentity2, { logId: 'synclog6' })
})
after(async () => {
if (sync1) {
await sync1.stop()
}
if (sync2) {
await sync2.stop()
}
if (log1) {
await log1.close()
}
if (log2) {
await log2.close()
}
await ipfs1.stop()
await ipfs2.stop()
})
it('does not crash when no listeners are attached to the `error` event on `Sync.events`', async () => {
let err = null
const onError = (error) => {
(!err) && (err = error)
}
sync1 = await Sync({ ipfs: ipfs1, log: log1, timeout: timeoutTime })
sync2 = await Sync({ ipfs: ipfs2, log: log2, start: false, timeout: timeoutTime })
// `sync1.events` has no listener on `error`
sync2.events.on('error', onError)
await log1.append('hello1')
await sync2.start()
await waitFor(() => err !== null, () => true)
notStrictEqual(err, null)
strictEqual(err.type, 'aborted')
strictEqual(err.message, 'Read aborted')
})
})
describe('Timeouts', () => {
let sync1, sync2
let log1, log2
@ -720,29 +781,5 @@ describe('Sync protocol', function () {
strictEqual(err.type, 'aborted')
strictEqual(err.message, 'Read aborted')
})
it('does not crash when no listeners are attached to the `error` event on `Sync.events`', async () => {
let err = null
const onError = (error) => {
(!err) && (err = error)
}
sync1 = await Sync({ ipfs: ipfs1, log: log1, timeout: timeoutTime })
sync2 = await Sync({ ipfs: ipfs2, log: log2, start: false, timeout: timeoutTime })
// `sync1.events` has no listener on `error`
sync2.events.on('error', onError)
await log1.append('hello1')
await sync2.start()
await waitFor(() => err !== null, () => true)
notStrictEqual(err, null)
strictEqual(err.type, 'aborted')
strictEqual(err.message, 'Read aborted')
})
})
})