pzp
/
pzp-db
mirror of https://codeberg.org/pzp/pzp-db.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix microqueue tests

This commit is contained in:
Andre Staltz 2023-12-21 11:29:32 +02:00
parent f38a62e006
commit fd2e50438a
No known key found for this signature in database
GPG Key ID: 9EDE23EA7E8A4890
1 changed files with 13 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
test/on-record-added.test.js
View File

@ -30,17 +30,24 @@ test('onRecordAdded', async (t) => {
var remove = peer.db.onRecordAdded((rec) => { var remove = peer.db.onRecordAdded((rec) => {
listenedRecs.push(rec) listenedRecs.push(rec)
if (rec.msg.data?.text === 'I am hungry') { if (rec.msg.data?.text === 'I am hungry') {
console.log(rec);
assert.equal(publishedRec1, true, 'onRecordAdded triggered after publish') assert.equal(publishedRec1, true, 'onRecordAdded triggered after publish')
} }
}) })
const rec1 = await p(peer.db.feed.publish)({ const rec1 = await new Promise((resolve, reject) => {
account, peer.db.feed.publish(
domain: 'post', {
data: { text: 'I am hungry' }, account,
domain: 'post',
data: { text: 'I am hungry' },
},
(err, rec) => {
publishedRec1 = true
if (err) reject(err)
else resolve(rec)
}
)
}) })
publishedRec1 = true
assert.equal(rec1.msg.data.text, 'I am hungry', 'msg1 text correct') assert.equal(rec1.msg.data.text, 'I am hungry', 'msg1 text correct')
await p(setTimeout)(500) await p(setTimeout)(500)