- monitor ops state and disconnect if submitop fails

 - bump version

Author: zbryikt

CHANGELOG.md

@@ -1,5 +1,10 @@
 # Change Logs
 
+## v0.5.6
+
+ - monitor ops state and disconnect if submitop fails
+
+
 ## v0.5.5
 
  - sharehub: fix bug: error should be thrown if no handler registered.

dist/sharehub.js

@@ -2,7 +2,7 @@
   var hub, sharehub;
   hub = typeof module != 'undefined' && module !== null ? require("./datahub") : datahub;
   sharehub = function(o){
-    var this$ = this;
+    var watchdog, this$ = this;
     o == null && (o = {});
     this.evthdr = {};
     this.data = {};
@@ -11,11 +11,78 @@
     this._create = o.create || null;
     this._watch = o.watch || null;
     this.ews = o.ews;
+    watchdog = {
+      timeout: 20000,
+      count: 0,
+      hash: {},
+      hdr: null,
+      fire: function(){
+        if (watchdog.hdr) {
+          clearTimeout(watchdog.hdr);
+          watchdog.hdr = null;
+        }
+        if (this$.ews && this$.ews.disconnect && this$.ews.status && this$.ews.status() === 2) {
+          this$.ews.disconnect();
+        }
+        return watchdog.hash = {};
+      },
+      check: function(){
+        var ref$, now, min, k, v, ref1$;
+        ref$ = [Date.now(), -1], now = ref$[0], min = ref$[1];
+        for (k in ref$ = this.hash) {
+          v = ref$[k];
+          if (now - v >= this.timeout) {
+            return this.fire();
+          }
+          if (min < 0 || this.timeout - (now - v) < min) {
+            min = (ref1$ = this.timeout - (now - v)) > 0 ? ref1$ : 0;
+          }
+        }
+        if (this.hdr) {
+          clearTimeout(this.hdr);
+          this.hdr = null;
+        }
+        if (min >= 0) {
+          return this.hdr = setTimeout(function(){
+            return this.check();
+          }, min);
+        }
+      },
+      track: function(){
+        var tid;
+        if (this$.ews && this$.ews.status && this$.ews.status() !== 2) {
+          return 0;
+        }
+        tid = ++watchdog.count;
+        watchdog.hash[tid] = Date.now();
+        if (!watchdog.hdr) {
+          watchdog.hdr = setTimeout(function(){
+            return watchdog.check();
+          }, watchdog.timeout);
+        }
+        return tid;
+      },
+      untrack: function(tid){
+        var this$ = this;
+        if (!tid) {
+          return function(){};
+        }
+        return function(e){
+          var ref$, ref1$;
+          if (e) {
+            return this$.fire();
+          } else {
+            return ref1$ = (ref$ = this$.hash)[tid], delete ref$[tid], ref1$;
+          }
+        };
+      }
+    };
     hub.src.call(this, import$(import$({}, o), {
       opsOut: function(ops){
-        var _id;
+        var _id, tid;
         _id = ops._id;
-        this$.doc.submitOp(JSON.parse(JSON.stringify(ops)));
+        tid = watchdog.track();
+        this$.doc.submitOp(JSON.parse(JSON.stringify(ops)), watchdog.untrack(tid));
         return this$.opsIn(ops);
       },
       get: function(){

dist/sharehub.min.js

@@ -8,7 +8,7 @@
     "dist/**/*"
   ],
   "description": "access scoped data via piped operational transformation",
-  "version": "0.5.5",
+  "version": "0.5.6",
   "homepage": "https://github.com/plotdb/datahub",
   "repository": {
     "type": "git",

package.json

@@ -8,12 +8,42 @@ sharehub = (o={}) ->
   @_create = o.create or null
   @_watch = o.watch or null
   @ews = o.ews
+
+  watchdog =
+    timeout: 20000
+    count: 0, hash: {}, hdr: null
+    fire: ~>
+      if watchdog.hdr =>
+        clearTimeout watchdog.hdr
+        watchdog.hdr = null
+      if @ews and @ews.disconnect and @ews.status and @ews.status! == 2 => @ews.disconnect!
+      watchdog.hash = {}
+    check: ->
+      [now, min] = [Date.now!, -1]
+      for k,v of @hash =>
+        if (now - v) >= @timeout => return @fire!
+        if min < 0 or (@timeout - (now - v)) < min => min = ((@timeout - (now - v)) >? 0)
+      if @hdr =>
+        clearTimeout @hdr
+        @hdr = null
+      if min >= 0 => @hdr = setTimeout (->@check!), min
+    track: ~>
+      if @ews and @ews.status and @ews.status! != 2 => return 0
+      tid = ++watchdog.count
+      watchdog.hash[tid] = Date.now!
+      if !watchdog.hdr => watchdog.hdr = setTimeout((~>watchdog.check!), watchdog.timeout)
+      return tid
+    untrack: (tid) ->
+      if !tid => return (->)
+      (e) ~> if e => @fire! else delete @hash[tid]
+
   hub.src.call @, {} <<< o <<< do
     ops-out: (ops) ~>
       _id = ops._id
       # DATA: we only have to apply if we decide to make a clone of remote obj when init
       #@data = json0.type.apply @data, ops
-      @doc.submitOp JSON.parse(JSON.stringify(ops))
+      tid = watchdog.track!
+      @doc.submitOp JSON.parse(JSON.stringify(ops)), watchdog.untrack(tid)
       # reflect to other subtree in hub
       @ops-in ops
     get: ~> @data