Mirroristas/orbitdb
2
0
Fork 0
mirror of https://github.com/orbitdb/orbitdb.git synced 2025-06-27 16:32:30 +00:00
Code Issues Packages Projects Releases Wiki Activity

Cleanup

Browse Source
This commit is contained in:
haad 2016-02-26 14:06:47 +01:00
parent 7f34829645
commit 471b189cbb
4 changed files with 10 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
examples/benchmark.js
View File

@ -5,8 +5,7 @@ var OrbitClient = require('../src/OrbitClient');
var Timer = require('./Timer'); var Timer = require('./Timer');
// orbit-server // orbit-server
// const host = 'localhost'; const host = 'localhost';
const host = '178.62.241.75';
const port = 3333; const port = 3333;
var username = 'testrunner'; var username = 'testrunner';
@ -17,8 +16,8 @@ let run = (async(() => {
// Connect // Connect
var orbit = OrbitClient.connect(host, port, username, password); var orbit = OrbitClient.connect(host, port, username, password);
const id = process.argv[2] ? process.argv[2] : 'a'; const id = process.argv[3] ? process.argv[3] : 'a';
const channelName = 'c1'; const channelName = process.argv[2] ? process.argv[2] : 'c1';
const db = orbit.channel(channelName); const db = orbit.channel(channelName);
// Metrics // Metrics

6
examples/keyvalue.js
View File

@ -23,14 +23,14 @@ let run = (async(() => {
while(true) { while(true) {
const key = process.argv[4] ? process.argv[4] : 'greeting'; const key = process.argv[4] ? process.argv[4] : 'greeting';
const value = process.argv[5] ? process.argv[5] : 'Hello world'; const value = process.argv[5] ? process.argv[5] : 'Hello world';
let timer = new Timer(true); const timer = new Timer(true);
db.put(key, value + " " + count); db.put(key, value + " " + count);
let v = db.get(key); const result = db.get(key);
console.log("---------------------------------------------------") console.log("---------------------------------------------------")
console.log("Key | Value") console.log("Key | Value")
console.log("---------------------------------------------------") console.log("---------------------------------------------------")
console.log(`${key} | ${v}`); console.log(`${key} | ${result}`);
console.log("---------------------------------------------------") console.log("---------------------------------------------------")
console.log(`Query #${count} took ${timer.stop(true)} ms\n`); console.log(`Query #${count} took ${timer.stop(true)} ms\n`);

4
examples/keyvalueReader.js
View File

@ -23,12 +23,12 @@ let run = (async(() => {
setInterval(async(() => { setInterval(async(() => {
const key = process.argv[4] ? process.argv[4] : 'greeting'; const key = process.argv[4] ? process.argv[4] : 'greeting';
let timer = new Timer(true); let timer = new Timer(true);
let v = db.get(key); const result = db.get(key);
console.log("---------------------------------------------------") console.log("---------------------------------------------------")
console.log("Key | Value") console.log("Key | Value")
console.log("---------------------------------------------------") console.log("---------------------------------------------------")
console.log(`${key} | ${v}`); console.log(`${key} | ${result}`);
console.log("---------------------------------------------------") console.log("---------------------------------------------------")
console.log(`Query #${count} took ${timer.stop(true)} ms\n`); console.log(`Query #${count} took ${timer.stop(true)} ms\n`);

4
src/OrbitClient.js
View File

@ -27,7 +27,7 @@ class OrbitClient {
channel(hash, password) { channel(hash, password) {
if(password === undefined) password = ''; if(password === undefined) password = '';
const processMsg = async((hash, message) => { const onMessage = async((hash, message) => {
const other = await(List.fromIpfsHash(this._ipfs, message)); const other = await(List.fromIpfsHash(this._ipfs, message));
if(other.id !== this.user.username) { if(other.id !== this.user.username) {
this._store.join(other); this._store.join(other);
@ -42,7 +42,7 @@ class OrbitClient {
} }
}); });
this._pubsub.subscribe(hash, password, processMsg, onLatest); this._pubsub.subscribe(hash, password, onMessage, onLatest);
return { return {
iterator: (options) => this._iterator(hash, password, options), iterator: (options) => this._iterator(hash, password, options),