118 lines
3.5 KiB
JavaScript
118 lines
3.5 KiB
JavaScript
'use strict';
|
|
|
|
// const ipfsd = require('ipfsd-ctl');
|
|
const IPFS = require('ipfs')
|
|
const OrbitDB = require('../src/OrbitDB');
|
|
const Timer = require('./Timer');
|
|
|
|
// usage: benchmark.js <network hash> <username> <channel>;
|
|
|
|
// orbit-server
|
|
// const network = 'QmRB8x6aErtKTFHDNRiViixSKYwW1DbfcvJHaZy1hnRzLM'; // dev server
|
|
const network = 'QmaAHGFm78eupEaDFzBfhUL5xn32dbeqn8oU2XCZJTQGBj'; // 'localhost:3333'
|
|
const username = process.argv[2] ? process.argv[2] : 'testrunner';
|
|
const password = '';
|
|
const channelName = process.argv[3] ? process.argv[3] : 'c1';
|
|
|
|
const startIpfs = () => {
|
|
return new Promise((resolve, reject) => {
|
|
// ipfsd.disposableApi((err, ipfs) => {
|
|
// if(err) console.error(err);
|
|
// resolve(ipfs);
|
|
// });
|
|
// ipfsd.local((err, node) => {
|
|
// if(err) reject(err);
|
|
// node.startDaemon((err, ipfs) => {
|
|
// if(err) reject(err);
|
|
// resolve(ipfs);
|
|
// });
|
|
// });
|
|
const ipfs = new IPFS('/tmp/benchmark')
|
|
ipfs.goOnline(() => {
|
|
resolve(ipfs)
|
|
})
|
|
});
|
|
};
|
|
|
|
const util = require('util');
|
|
|
|
// Metrics
|
|
let totalQueries = 0;
|
|
let seconds = 0;
|
|
let queriesPerSecond = 0;
|
|
let lastTenSeconds = 0;
|
|
let store;
|
|
|
|
const queryLoop = (db) => {
|
|
// const queryLoop = (ipfs) => {
|
|
// const data = new Buffer(JSON.stringify({ Data: JSON.stringify({ hello: "world" }) }));
|
|
// ipfs.object.put(data).then(() => {
|
|
// totalQueries ++;
|
|
// lastTenSeconds ++;
|
|
// queriesPerSecond ++;
|
|
// process.nextTick(() => queryLoop(ipfs));
|
|
// })
|
|
// let timer = new Timer();
|
|
// timer.start();
|
|
store.add(username + totalQueries).then(() => {
|
|
// console.log(`${timer.stop(true)} ms - ${process._getActiveRequests().length} ${process._getActiveHandles().length}`);
|
|
// console.log(util.inspect(process.memoryUsage()));
|
|
totalQueries ++;
|
|
lastTenSeconds ++;
|
|
queriesPerSecond ++;
|
|
process.nextTick(queryLoop);
|
|
});
|
|
};
|
|
|
|
let run = (() => {
|
|
// Connect
|
|
console.log(`Connecting...`)
|
|
startIpfs()
|
|
// .then((ipfs) => queryLoop(ipfs))
|
|
.then((ipfs) => OrbitDB.connect(network, username, password, ipfs))
|
|
.then((orbit) => {
|
|
console.log("OrbitDB")
|
|
orbit.events.on('load', () => console.log("loading log"))
|
|
orbit.events.on('ready', (db) => {
|
|
console.log("log fetched from history for", db.dbname);
|
|
store = db;
|
|
queryLoop();
|
|
});
|
|
return orbit;
|
|
})
|
|
.then((orbit) => orbit.eventlog(channelName))
|
|
// .then((db) => {
|
|
// console.log("OrbitDB")
|
|
// return new Promise((resolve, reject) => {
|
|
// db.events.on('load', () => console.log("loading log from history"))
|
|
// db.events.on('ready', (dbname) => {
|
|
// console.log("log fetched from history for", dbname);
|
|
// queryLoop(db);
|
|
// resolve();
|
|
// });
|
|
// });
|
|
// })
|
|
.then(() => {
|
|
console.log("++")
|
|
// 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);
|
|
})
|
|
.catch((e) => {
|
|
console.error("error:", e);
|
|
console.error(e.stack);
|
|
process.exit(1);
|
|
})
|
|
})();
|
|
|
|
module.exports = run;
|