mirror of https://codeberg.org/pzp/pzp-sync.git
74 lines
1.9 KiB
JavaScript
74 lines
1.9 KiB
JavaScript
const test = require('node:test')
|
|
const assert = require('node:assert')
|
|
const p = require('util').promisify
|
|
const Keypair = require('ppppp-keypair')
|
|
const { createPeer } = require('./util')
|
|
|
|
const aliceKeypair = Keypair.generate('ed25519', 'alice')
|
|
const bobKeys = Keypair.generate('ed25519', 'bob')
|
|
|
|
function getAccount(iter) {
|
|
return [...iter]
|
|
.filter((msg) => msg.metadata.account === 'self' && msg.data)
|
|
.map((msg) => msg.data.add.key.bytes)
|
|
}
|
|
|
|
test('sync an account tangle', async (t) => {
|
|
const alice = createPeer({ name: 'alice', keypair: aliceKeypair })
|
|
const bob = createPeer({ name: 'bob', keypair: bobKeys })
|
|
|
|
await alice.db.loaded()
|
|
await bob.db.loaded()
|
|
|
|
// Alice's account tangle
|
|
await alice.db.loaded()
|
|
const aliceID = await p(alice.db.account.create)({
|
|
domain: 'account',
|
|
_nonce: 'alice',
|
|
})
|
|
|
|
const aliceKeypair1 = Keypair.generate('ed25519', 'alice1')
|
|
await p(alice.db.account.add)({
|
|
account: aliceID,
|
|
keypair: aliceKeypair1,
|
|
})
|
|
|
|
const aliceKeypair2 = Keypair.generate('ed25519', 'alice2')
|
|
await p(alice.db.account.add)({
|
|
account: aliceID,
|
|
keypair: aliceKeypair2,
|
|
})
|
|
|
|
assert.deepEqual(
|
|
getAccount(alice.db.msgs()),
|
|
[aliceKeypair.public, aliceKeypair1.public, aliceKeypair2.public],
|
|
'alice has her account tangle'
|
|
)
|
|
|
|
assert.deepEqual(
|
|
getAccount(bob.db.msgs()),
|
|
[],
|
|
"bob doesn't have alice's account tangle"
|
|
)
|
|
|
|
bob.tangleSync.setGoal(aliceID, 'all')
|
|
alice.tangleSync.setGoal(aliceID, 'all')
|
|
|
|
const remoteAlice = await p(bob.connect)(alice.getAddress())
|
|
assert('bob connected to alice')
|
|
|
|
bob.tangleSync.initiate()
|
|
await p(setTimeout)(1000)
|
|
assert('tangleSync!')
|
|
|
|
assert.deepEqual(
|
|
getAccount(bob.db.msgs()),
|
|
[aliceKeypair.public, aliceKeypair1.public, aliceKeypair2.public],
|
|
"bob has alice's account tangle"
|
|
)
|
|
|
|
await p(remoteAlice.close)(true)
|
|
await p(alice.close)(true)
|
|
await p(bob.close)(true)
|
|
})
|