From 33c0a580c8f4842bcf1e022c93ec8bef78f81e30 Mon Sep 17 00:00:00 2001
From: "Friedrich W. H. Kossebau" <friedrich@kogmbh.com>
Date: Mon, 19 Aug 2013 17:21:45 +0200
Subject: [PATCH] Add
 OperationRouter.getHasLocalUnsyncedOpsAndUpdates/OperationRouter.unsubscribeHasLocalUnsyncedOpsUpdates

---
 .../editor/server/nowjs/OperationRouter.js    |  9 ++++
 .../editor/server/pullbox/OperationRouter.js  | 43 ++++++++++++++++++-
 webodf/lib/ops/OperationRouter.js             | 17 ++++++++
 webodf/lib/ops/TrivialOperationRouter.js      |  9 ++++
 4 files changed, 77 insertions(+), 1 deletion(-)

diff --git a/programs/editor/server/nowjs/OperationRouter.js b/programs/editor/server/nowjs/OperationRouter.js
index f2860d51..b7a46ed6 100644
--- a/programs/editor/server/nowjs/OperationRouter.js
+++ b/programs/editor/server/nowjs/OperationRouter.js
@@ -177,5 +177,14 @@ define("webodf/editor/server/nowjs/OperationRouter", [], function () {
             cb();
         };
         /*jslint emptyblock: false, unparam: false*/
+
+        this.getHasLocalUnsyncedOpsAndUpdates = function (subscriber) {
+            subscriber(false);
+        };
+
+        /*jslint emptyblock: true, unparam: true*/
+        this.unsubscribeHasLocalUnsyncedOpsUpdates = function (subscriber) {
+        };
+        /*jslint emptyblock: false, unparam: false*/
     };
 });
diff --git a/programs/editor/server/pullbox/OperationRouter.js b/programs/editor/server/pullbox/OperationRouter.js
index a24744a5..a3d99427 100644
--- a/programs/editor/server/pullbox/OperationRouter.js
+++ b/programs/editor/server/pullbox/OperationRouter.js
@@ -71,6 +71,8 @@ define("webodf/editor/server/pullbox/OperationRouter", [], function () {
             unplayedServerOpspecQueue = [],
             /** @type {!Array.<!Function>} sync request callbacks which should be called after the received ops have been applied server */
             uncalledSyncRequestCallbacksQueue = [],
+            /** @type {!Array.<!function(!boolean):undefined>} ops created since the last sync call to the server */
+            hasLocalUnsyncedOpsStateSubscribers = [],
             /**@type{!boolean}*/
             hasLocalUnsyncedOps = false,
             /**@type{!boolean} tells if any local ops have been modifying ops */
@@ -84,7 +86,8 @@ define("webodf/editor/server/pullbox/OperationRouter", [], function () {
          * @return {undefined}
          */
         function updateHasLocalUnsyncedOpsState() {
-            var hasLocalUnsyncedOpsNow = (unsyncedClientOpspecQueue.length > 0);
+            var i,
+                hasLocalUnsyncedOpsNow = (unsyncedClientOpspecQueue.length > 0);
 
             // no change?
             if (hasLocalUnsyncedOps === hasLocalUnsyncedOpsNow) {
@@ -92,6 +95,9 @@ define("webodf/editor/server/pullbox/OperationRouter", [], function () {
             }
 
             hasLocalUnsyncedOps = hasLocalUnsyncedOpsNow;
+            for (i=0; i<hasLocalUnsyncedOpsStateSubscribers.length; i+=1) {
+                hasLocalUnsyncedOpsStateSubscribers[i](hasLocalUnsyncedOps);
+            }
         }
 
         /**
@@ -454,5 +460,40 @@ runtime.log("OperationRouter: instant opsSync requested");
             }
         };
 
+        this.getHasLocalUnsyncedOpsAndUpdates = function (subscriber) {
+            var i;
+
+            // detect double subscription
+            for (i=0; i<hasLocalUnsyncedOpsStateSubscribers.length; i+=1) {
+                if (subscribers[i] === subscriber) {
+                    break;
+                }
+            }
+            if (i < hasLocalUnsyncedOpsStateSubscribers.length) {
+                // already subscribed
+                runtime.log("double subscription request in PullBoxMemberModel::getHasLocalUnsyncedOpsAndUpdates");
+            } else {
+                // subscribe
+                hasLocalUnsyncedOpsStateSubscribers.push(subscriber);
+            }
+
+            subscriber(hasLocalUnsyncedOps);
+        };
+
+        /*jslint emptyblock: true, unparam: true*/
+        this.unsubscribeHasLocalUnsyncedOpsUpdates = function (subscriber) {
+            var i;
+
+            for (i=0; i<hasLocalUnsyncedOpsStateSubscribers.length; i+=1) {
+                if (hasLocalUnsyncedOpsStateSubscribers[i] === subscriber) {
+                    break;
+                }
+            }
+
+            runtime.assert((i < hasLocalUnsyncedOpsStateSubscribers.length),
+                            "tried to unsubscribe when not subscribed in PullBoxMemberModel::getHasLocalUnsyncedOpsAndUpdates");
+
+            hasLocalUnsyncedOpsStateSubscribers.splice(i,1);
+        };
     };
 });
diff --git a/webodf/lib/ops/OperationRouter.js b/webodf/lib/ops/OperationRouter.js
index 3bb6b594..6d210d8a 100644
--- a/webodf/lib/ops/OperationRouter.js
+++ b/webodf/lib/ops/OperationRouter.js
@@ -82,3 +82,20 @@ ops.OperationRouter.prototype.push = function (operations) {"use strict"; };
  * @return {undefined}
  */
 ops.OperationRouter.prototype.close = function (callback) {"use strict"; };
+
+/**
+ * subscriber is called with the current state and after that
+ * on every state change.
+ *
+ * @param {function(!boolean)} subscriber
+ * @return {undefined}
+ */
+ops.OperationRouter.prototype.getHasLocalUnsyncedOpsAndUpdates = function (subscriber) {"use strict"; };
+
+/**
+ * Undoes the subscription done with getHasLocalUnsyncedOpsAndUpdates
+ *
+ * @param {function(!boolean)} subscriber
+ * @return {undefined}
+ */
+ops.OperationRouter.prototype.unsubscribeHasLocalUnsyncedOpsUpdates = function (subscriber) {"use strict"; };
diff --git a/webodf/lib/ops/TrivialOperationRouter.js b/webodf/lib/ops/TrivialOperationRouter.js
index 163817a1..f50f054e 100644
--- a/webodf/lib/ops/TrivialOperationRouter.js
+++ b/webodf/lib/ops/TrivialOperationRouter.js
@@ -96,4 +96,13 @@ ops.TrivialOperationRouter = function TrivialOperationRouter() {
     this.close = function (cb) {
         cb();
     };
+
+    this.getHasLocalUnsyncedOpsAndUpdates = function (subscriber) {
+        subscriber(false);
+    };
+
+    /*jslint emptyblock: true, unparam: true*/
+    this.unsubscribeHasLocalUnsyncedOpsUpdates = function (subscriber) {
+    };
+    /*jslint emptyblock: false, unparam: false*/
 };