From 2ef28e2380d3138a5e2ae7972771f5c6e226ff29 Mon Sep 17 00:00:00 2001
From: haad <haad@headbanggames.com>
Date: Mon, 30 May 2016 15:56:26 +0200
Subject: [PATCH] Decrease network info read timeout. Fix events.

---
 src/OrbitDB.js | 10 ++++++----
 1 file changed, 6 insertions(+), 4 deletions(-)

diff --git a/src/OrbitDB.js b/src/OrbitDB.js
index eb4249a..43dc3f0 100644
--- a/src/OrbitDB.js
+++ b/src/OrbitDB.js
@@ -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 = '';