55 lines
1.4 KiB
JavaScript
55 lines
1.4 KiB
JavaScript
'use strict'
|
|
|
|
const IPFS = require('ipfs')
|
|
const IPFSRepo = require('ipfs-repo')
|
|
const DatastoreLevel = require('datastore-level')
|
|
const OrbitDB = require('../src/OrbitDB')
|
|
|
|
console.log("Starting IPFS...")
|
|
|
|
const repoConf = {
|
|
storageBackends: {
|
|
blocks: DatastoreLevel
|
|
}
|
|
}
|
|
|
|
const ipfs = new IPFS({
|
|
repo: new IPFSRepo('./orbitdb/benchmarks/load/ipfs', repoConf),
|
|
start: false
|
|
})
|
|
|
|
ipfs.on('error', (err) => console.error(err))
|
|
|
|
ipfs.on('ready', async () => {
|
|
const run = async () => {
|
|
try {
|
|
const orbit = await OrbitDB.createInstance(ipfs, { directory: './orbitdb/benchmarks' })
|
|
const db = await orbit.eventlog('orbit-db.benchmark', { replicate: false })
|
|
|
|
const amount = 1000
|
|
console.log('DB entries:', amount)
|
|
|
|
console.log('Writing DB...')
|
|
const st1 = new Date().getTime()
|
|
for (let i = 0; i < amount; i++) {
|
|
await db.add('a' + i)
|
|
}
|
|
const et1 = new Date().getTime()
|
|
console.log('writing took', (et1 - st1), 'ms')
|
|
await db.close()
|
|
|
|
const db2 = await orbit.eventlog('orbit-db.benchmark', { replicate: false })
|
|
console.log('Loading DB...')
|
|
const st2 = new Date().getTime()
|
|
await db2.load()
|
|
const et2 = new Date().getTime()
|
|
console.log('load took', (et2 - st2), 'ms')
|
|
process.exit(0)
|
|
} catch (e) {
|
|
console.log(e)
|
|
process.exit(1)
|
|
}
|
|
}
|
|
run()
|
|
})
|