Mirroristas/orbitdb
2
0
Fork 0
mirror of https://github.com/orbitdb/orbitdb.git synced 2025-10-07 22:57:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

Decrease network info read timeout. Fix events.

Browse Source
This commit is contained in:
haad
2016-05-30 15:56:26 +02:00
parent c4cef9914c
commit 2ef28e2380
1 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/OrbitDB.js
View File

@@ -82,13 +82,15 @@ class OrbitDB {
}
_onMessage(dbname, hash) {
// console.log(".MESSAGE", dbname, message);
// console.log(".MESSAGE", dbname, hash, this.user.username);
const store = this.stores[dbname];
this.events.emit('message', dbname, hash);
// console.log("sync", store !== null, this.user.username)
store.sync(hash).catch((e) => logger.error(e.stack));
}
_onWrite(dbname, hash) {
// console.log(".WRITE", dbname);
// console.log(".WRITE", dbname, hash, this.user.username);
if(!hash) throw new Error("Hash can't be null!");
if(this._pubsub) this._pubsub.publish(dbname, hash);
this.events.emit('data', dbname, hash);
@@ -100,7 +102,7 @@ class OrbitDB {
}
_onSynced(dbname, items) {
// console.log(".SYNCED", dbname);
// console.log(".SYNCED", dbname, items.length);
this.events.emit('synced', dbname, items);
}
@@ -145,7 +147,7 @@ class OrbitDB {
return new Promise((resolve, reject) => {
if(this._ipfs.files.cat) {
logger.debug(".cat with js-ipfs");
setTimeout(reject, 10000);
setTimeout(reject, 5000);
this._ipfs.files.cat(hash, (err, res) => {
if(err) return reject(err);
let buf = '';