Mirroristas/orbitdb
2
0
Fork 0
mirror of https://github.com/orbitdb/orbitdb.git synced 2025-05-22 06:46:38 +00:00
Code Issues Packages Projects Releases Wiki Activity

Refactor state broadcast events

Browse Source
This commit is contained in:
haad 2016-03-23 10:32:54 +01:00
parent e93507f68a
commit 5baf2600b9
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/OrbitDB.js
View File

@ -23,15 +23,14 @@ class OrbitDB {
this._logs[channel] = await(Log.create(this._ipfs, this.user.username)); this._logs[channel] = await(Log.create(this._ipfs, this.user.username));
this.events[channel] = new EventEmitter(); this.events[channel] = new EventEmitter();
this.events[channel].emit('load', channel);
Cache.loadCache(this.options.cacheFile); Cache.loadCache(this.options.cacheFile);
this.sync(channel, Cache.get(channel)); this.sync(channel, Cache.get(channel));
this.events[channel].emit('loaded', channel);
} }
sync(channel, hash) { sync(channel, hash) {
// console.log("--> Head:", hash) // console.log("--> Head:", hash)
if(hash && this._logs[channel]) { if(hash && this._logs[channel]) {
this.events[channel].emit('load', 'sync', channel);
const oldCount = this._logs[channel].items.length; const oldCount = this._logs[channel].items.length;
const other = await(Log.fromIpfsHash(this._ipfs, hash)); const other = await(Log.fromIpfsHash(this._ipfs, hash));
await(this._logs[channel].join(other)); await(this._logs[channel].join(other));
@ -43,12 +42,14 @@ class OrbitDB {
Cache.set(channel, hash); Cache.set(channel, hash);
} }
} }
this.events[channel].emit('loaded', 'sync', channel);
} }
/* DB Operations */ /* DB Operations */
// Get items from the db // Get items from the db
query(channel, password, opts) { query(channel, password, opts) {
this.events[channel].emit('load', 'query', channel);
// console.log("--> Query:", channel, opts); // console.log("--> Query:", channel, opts);
if(!opts) opts = {}; if(!opts) opts = {};
@ -71,6 +72,7 @@ class OrbitDB {
if(opts.reverse) result.reverse(); if(opts.reverse) result.reverse();
const res = result.toArray(); const res = result.toArray();
// console.log("--> Found", res.length, "items"); // console.log("--> Found", res.length, "items");
this.events[channel].emit('loaded', 'query', channel);
return res; return res;
} }
@ -116,7 +118,7 @@ class OrbitDB {
.map(_createLWWSet) // Return items as LWW (ignore values after the first found) .map(_createLWWSet) // Return items as LWW (ignore values after the first found)
.compact() // Remove nulls .compact() // Remove nulls
.drop(inclusive ? 0 : 1) // Drop the 'gt/lt' item, include 'gte/lte' item .drop(inclusive ? 0 : 1) // Drop the 'gt/lt' item, include 'gte/lte' item
.take(amount) .take(amount);
} }
// Write an op to the db // Write an op to the db