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

Move load status to init

Browse Source
This commit is contained in:
haad 2016-03-22 17:59:55 +01:00
parent 76a0ad5d52
commit 0509b6ee5d
1 changed files with 13 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
src/OrbitDB.js
View File

@ -22,28 +22,26 @@ class OrbitDB {
this._logs[channel] = await(Log.create(this._ipfs, this.user.username));
this.events[channel] = new EventEmitter();
this.events[channel].emit('load', channel);
Cache.loadCache();
this.sync(channel, Cache.get(channel));
this.events[channel].emit('loaded', channel);
}
sync(channel, hash) {
this.events[channel].emit('load', channel, hash);
// setTimeout(async(() => {
// console.log("--> Head:", hash)
if(hash && this._logs[channel]) {
const oldCount = this._logs[channel].items.length;
const other = await(Log.fromIpfsHash(this._ipfs, hash));
await(this._logs[channel].join(other));
// console.log("--> Head:", hash)
if(hash && this._logs[channel]) {
const oldCount = this._logs[channel].items.length;
const other = await(Log.fromIpfsHash(this._ipfs, hash));
await(this._logs[channel].join(other));
// Only emit the event if something was added
const joinedCount = (this._logs[channel].items.length - oldCount);
if(joinedCount > 0) {
this.events[channel].emit('sync', channel, hash);
Cache.set(channel, hash);
}
// Only emit the event if something was added
const joinedCount = (this._logs[channel].items.length - oldCount);
if(joinedCount > 0) {
this.events[channel].emit('sync', channel, hash);
Cache.set(channel, hash);
}
this.events[channel].emit('loaded', channel, hash);
// }), 3000);
}
}
/* DB Operations */