Mirroristas/orbitdb
2
0
Fork 0
mirror of https://github.com/orbitdb/orbitdb.git synced 2025-10-07 22:57:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

test: Create a Level db if directory is specified.

Browse Source
This commit is contained in:
Hayden Young
2024-01-16 21:46:04 +00:00
parent 3cca7779a8
commit 973cc7aa20
2 changed files with 11 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
test/orbitdb-replication.test.js
View File

@@ -4,20 +4,16 @@ import { createOrbitDB } from '../src/index.js'
import connectPeers from './utils/connect-nodes.js'
import waitFor from './utils/wait-for.js'
import createHelia from './utils/create-helia.js'
import { LevelBlockstore } from 'blockstore-level'
describe('Replicating databases', function () {
this.timeout(10000)
let blockstore1, blockstore2
let ipfs1, ipfs2
let orbitdb1, orbitdb2
before(async () => {
blockstore1 = new LevelBlockstore('./ipfs1')
blockstore2 = new LevelBlockstore('./ipfs2')
ipfs1 = await createHelia({ blockstore: blockstore1 })
ipfs2 = await createHelia({ blockstore: blockstore2 })
ipfs1 = await createHelia({ directory: './ipfs1' })
ipfs2 = await createHelia({ directory: './ipfs2' })
await connectPeers(ipfs1, ipfs2)
orbitdb1 = await createOrbitDB({ ipfs: ipfs1, id: 'user1', directory: './orbitdb1' })
@@ -27,8 +23,8 @@ describe('Replicating databases', function () {
after(async () => {
await orbitdb1.stop()
await orbitdb2.stop()
await blockstore1.close()
await blockstore2.close()
await ipfs1.blockstore.child.child.close()
await ipfs2.blockstore.child.child.close()
await ipfs1.stop()
await ipfs2.stop()
@@ -140,11 +136,13 @@ describe('Replicating databases', function () {
await orbitdb1.stop()
await orbitdb2.stop()
await ipfs1.blockstore.child.child.close()
await ipfs2.blockstore.child.child.close()
await ipfs1.stop()
await ipfs2.stop()
ipfs1 = await createHelia({ blockstore: blockstore1 })
ipfs2 = await createHelia({ blockstore: blockstore2 })
ipfs1 = await createHelia({ directory: './ipfs1' })
ipfs2 = await createHelia({ directory: './ipfs2' })
await connectPeers(ipfs1, ipfs2)