mirror of
https://github.com/orbitdb/orbitdb.git
synced 2025-03-30 15:08:28 +00:00
8f990e0ccc
Use immutable ipfs-log. Simplify internals. Remove obsolete dependencies. Update dependencies. Use @dignifiedquire's mapSeries for Promises. Split tests to individual stores. Improve tests. Fix build process. Build size down to 121kb. Fix benchmarks and examples. Move Cache to Stores (and to its own module).
51 lines
1.2 KiB
JavaScript
51 lines
1.2 KiB
JavaScript
'use strict'
|
|
|
|
const IpfsDaemon = require('ipfs-daemon/src/ipfs-node-daemon')
|
|
const OrbitDB = require('../src/OrbitDB')
|
|
|
|
// Metrics
|
|
let totalQueries = 0
|
|
let seconds = 0
|
|
let queriesPerSecond = 0
|
|
let lastTenSeconds = 0
|
|
|
|
// Main loop
|
|
const queryLoop = (db) => {
|
|
db.add(totalQueries)
|
|
.then(() => {
|
|
totalQueries ++
|
|
lastTenSeconds ++
|
|
queriesPerSecond ++
|
|
setImmediate(() => queryLoop(db))
|
|
})
|
|
.catch((e) => console.error(e))
|
|
}
|
|
|
|
// Start
|
|
console.log("Starting IPFS daemon...")
|
|
|
|
const ipfs = new IpfsDaemon()
|
|
|
|
ipfs.on('error', (err) => console.error(err))
|
|
|
|
ipfs.on('ready', () => {
|
|
const orbit = new OrbitDB(ipfs, 'benchmark')
|
|
const db = orbit.eventlog('orbit-db.benchmark', { maxHistory: 100 })
|
|
|
|
// Metrics output
|
|
setInterval(() => {
|
|
seconds ++
|
|
if(seconds % 10 === 0) {
|
|
console.log(`--> Average of ${lastTenSeconds/10} q/s in the last 10 seconds`)
|
|
if(lastTenSeconds === 0)
|
|
throw new Error("Problems!")
|
|
lastTenSeconds = 0
|
|
}
|
|
console.log(`${queriesPerSecond} queries per second, ${totalQueries} queries in ${seconds} seconds`)
|
|
queriesPerSecond = 0
|
|
}, 1000)
|
|
|
|
// Start the main loop
|
|
queryLoop(db)
|
|
})
|