mirror of
https://github.com/orbitdb/orbitdb.git
synced 2025-03-30 15:08:28 +00:00
a063b3fb4a
Fix sync Fix linter Fix tests Clean up Set default references count to 0 Fix sync Use address instead of databaseId Sync protocol Keep references to open databases in OrbitDB Fix append benchmark Initial version of heads exchange Remove Feed Fix KeyValuePersisted iterator Refactor OrbitDBAddress a bit more Add rest of the database types Refactor OrbitDB addresses Initial version for the full circle Initial structure and tests for new OrbitDB Make sure KeyStore is open when a Database is created Re-organize OrbitDB Use new databases and Log More clean up Add 'drop' event to Database Clean up OrbitDB Remove id from OrbitDB Use new KeyStore and Identities Remove storage from OrbitDB Remove migrations from OrbitDB Remove caches from OrbitDB Remove pubsub from OrbitDB
102 lines
2.5 KiB
JavaScript
102 lines
2.5 KiB
JavaScript
// import assert from 'assert'
|
|
// import OrbitDB from '../src/OrbitDB.js'
|
|
// import rmrf from 'rimraf'
|
|
// import path from 'path'
|
|
|
|
// // Include test utilities
|
|
// import {
|
|
// config,
|
|
// startIpfs,
|
|
// stopIpfs,
|
|
// testAPIs,
|
|
// } from 'orbit-db-test-utils'
|
|
|
|
// const last = arr => arr[arr.length - 1]
|
|
|
|
// const dbPath = './orbitdb/tests/feed-load'
|
|
|
|
// Object.keys(testAPIs).forEach(API => {
|
|
// describe(`orbit-db - Feed Load Amount (${API})`, function() {
|
|
// this.timeout(config.timeout)
|
|
|
|
// let ipfsd, ipfs, orbitdb1, db, address
|
|
|
|
// before(async () => {
|
|
// rmrf.sync(dbPath)
|
|
// ipfsd = await startIpfs(API, config.daemon1)
|
|
// ipfs = ipfsd.api
|
|
// orbitdb1 = await OrbitDB.createInstance(ipfs, { directory: path.join(dbPath, '1') })
|
|
// })
|
|
|
|
// after(async () => {
|
|
// if(orbitdb1)
|
|
// await orbitdb1.stop()
|
|
|
|
// if (ipfsd)
|
|
// await stopIpfs(ipfsd)
|
|
// })
|
|
|
|
// describe('Feed Load Amount', function() {
|
|
|
|
// it('add 10 items and verify they are in the index', async () => {
|
|
// db = await orbitdb1.feed('feed database')
|
|
|
|
// //All tests should retrieve these 10 items.
|
|
// for (var i=0; i < 10; i++) {
|
|
// await db.add({content: (i + 10).toString()})
|
|
// }
|
|
|
|
// assert.equal(Object.keys(db.index).length, 10)
|
|
// })
|
|
|
|
// it('reopen store and load 10 items', async () => {
|
|
|
|
// address = db.address.toString()
|
|
// await db.close()
|
|
// db = await orbitdb1.open(address)
|
|
|
|
// //Load 10 items
|
|
// await db.load(10)
|
|
|
|
// assert.equal(Object.keys(db.index).length, 10)
|
|
|
|
// })
|
|
|
|
// it('reopen store and load 1 item more than exists', async () => {
|
|
// await db.close()
|
|
// db = await orbitdb1.open(address)
|
|
|
|
// //Load 11 items
|
|
// await db.load(11)
|
|
|
|
// assert.equal(Object.keys(db.index).length, 10)
|
|
|
|
// })
|
|
|
|
// it('reopen store and load 5 item more than exists', async () => {
|
|
|
|
// await db.close()
|
|
// db = await orbitdb1.open(address)
|
|
|
|
// //Load 15 items
|
|
// await db.load(15)
|
|
|
|
// assert.equal(Object.keys(db.index).length, 10)
|
|
// })
|
|
|
|
// it('reopen store and load 20 items more than exists', async () => {
|
|
|
|
// await db.close()
|
|
// db = await orbitdb1.open(address)
|
|
|
|
// //Load 30 items
|
|
// await db.load(30)
|
|
|
|
// assert.equal(Object.keys(db.index).length, 10)
|
|
// })
|
|
|
|
// })
|
|
|
|
// })
|
|
// })
|