/
feed-holes.test.js
76 lines (62 loc) · 2.14 KB
/
feed-holes.test.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
const test = require('node:test')
const assert = require('node:assert')
const p = require('node:util').promisify
const { createPeer } = require('./util')
function getTexts(msgs) {
return msgs.filter((msg) => msg.data?.text).map((msg) => msg.data.text)
}
test('Feed holes', async (t) => {
const alice = createPeer({ name: 'alice' })
await alice.db.loaded()
// Alice creates her own account
const aliceID = await p(alice.db.account.create)({
subdomain: 'account',
_nonce: 'alice',
})
const posts = []
for (let i = 0; i < 10; i++) {
const rec = await p(alice.db.feed.publish)({
account: aliceID,
domain: 'post',
data: { text: 'A' + i },
})
posts.push(rec.id)
}
assert.deepEqual(
getTexts([...alice.db.msgs()]),
['A0', 'A1', 'A2', 'A3', 'A4', 'A5', 'A6', 'A7', 'A8', 'A9'],
'alice has the whole feed'
)
await p(alice.db.del)(posts[3])
await p(alice.db.del)(posts[4])
await p(alice.db.del)(posts[5])
await p(alice.db.erase)(posts[6]) // vital as trail from A7
assert('alice deleted the middle part of the feed')
assert.deepEqual(
getTexts([...alice.db.msgs()]),
['A0', 'A1', 'A2', /* */ 'A7', 'A8', 'A9'],
'alice has the beginning and the end of the feed'
)
alice.goals.set(aliceID, 'all') // alice wants her account tangle
const postFeedID = alice.db.feed.getID(aliceID, 'post')
// notice 4 on purpose, because we want to make sure A2 is deleted
alice.goals.set(postFeedID, 'newest-4')
assert('alice set a goal for newest-4 of post feed')
// Mock db.erase so we can inspect how many times it was called
const prevErase = alice.db.erase
const calledErase = []
alice.db.erase = (msgID, cb) => {
calledErase.push(msgID)
prevErase(msgID, cb)
}
await p(alice.gc.forceImmediately)()
assert.deepEqual(calledErase, [posts[2]], 'erased A2')
assert.deepEqual(
getTexts([...alice.db.msgs()]),
[/* */ 'A7', 'A8', 'A9'],
'alice has only the end of the feed'
)
await p(alice.gc.forceImmediately)()
assert.deepEqual(calledErase, [posts[2]], 'no double erasing')
await p(alice.close)(true)
})