Live query support

autorun.js

@@ -0,0 +1,37 @@
+import { Tracker } from 'meteor/tracker';
+import { autorun } from 'mobx';
+
+export default (trackerMobxAutorun) => {
+  let mobxDisposer = null;
+  let computation = null;
+  let hasBeenStarted;
+  let subscriptionHandle;
+  return {
+    start() {
+      let isFirstRun = true;
+      computation = Tracker.autorun(() => {
+        if (mobxDisposer) {
+          mobxDisposer();
+          isFirstRun = true;
+        }
+        mobxDisposer = autorun(() => {
+          if (isFirstRun) {
+            subscriptionHandle = trackerMobxAutorun();
+          } else {
+            computation.invalidate();
+            subscriptionHandle && subscriptionHandle.stop();
+          }
+          isFirstRun = false;
+        });
+      });
+      hasBeenStarted = true;
+    },
+    stop() {
+      if (hasBeenStarted) {
+        computation.stop();
+        mobxDisposer();
+        subscriptionHandle && subscriptionHandle.stop();
+      }
+    }
+  };
+};

index.js

@@ -1,40 +1,10 @@
-import { Tracker } from 'meteor/tracker';
 import { checkNpmVersions } from 'meteor/tmeasday:check-npm-versions';
+import observeCursor from './observe-cursor';
+import autorun from './autorun';
 
 checkNpmVersions({
   'mobx': '2.x'
 }, 'space:tracker-mobx-autorun');
 
-const { autorun } = require('mobx');
-
-export default (trackerMobxAutorun) => {
-  let mobxDisposer = null;
-  let computation = null;
-  let hasBeenStarted;
-  return {
-    start() {
-      let isFirstRun = true;
-      computation = Tracker.autorun(() => {
-        if (mobxDisposer) {
-          mobxDisposer();
-          isFirstRun = true;
-        }
-        mobxDisposer = autorun(() => {
-          if (isFirstRun) {
-            trackerMobxAutorun();
-          } else {
-            computation.invalidate();
-          }
-          isFirstRun = false;
-        });
-      });
-      hasBeenStarted = true;
-    },
-    stop() {
-      if (hasBeenStarted) {
-        computation.stop();
-        mobxDisposer();
-      }
-    }
-  };
-};
+export default autorun;
+export const observe = observeCursor;

observe-cursor.js

@@ -0,0 +1,38 @@
+import { Tracker } from 'meteor/tracker';
+import { action } from 'mobx';
+
+export default (actionPrefix = '', storeAttribute, handle, cursor) => {
+
+  if (handle.ready()) {
+    // initial fetch...
+    Tracker.nonreactive(() => {
+      action(`${actionPrefix}: initial fetch`, (comments) => {
+        storeAttribute.replace(comments);
+      })(cursor.fetch());
+    });
+
+    // ...and then observe
+    cursor.observe({
+      // we don't want that the addedAt function is triggered x times at the beginning
+      // just fetch them once (see above)
+      _suppress_initial: true,
+      addedAt: action(`${actionPrefix}: document added`, (document, atIndex) => {
+        storeAttribute.splice(atIndex, 0, document);
+      }),
+      changedAt: action(`${actionPrefix}: document changed`, (newDocument, oldDocument, atIndex) => {
+        storeAttribute.splice(atIndex, 1, newDocument);
+      }),
+      removedAt: action(`${actionPrefix}: document removed`, (oldDocument, atIndex) => {
+        storeAttribute.splice(atIndex, 1);
+      }),
+      movedTo: action(`${actionPrefix}: document moved`, (document, fromIndex, toIndex) => {
+        storeAttribute.splice(fromIndex, 1);
+        storeAttribute.splice(toIndex, 0, document);
+      }),
+    });
+  } else {
+    action(`${actionPrefix}: initialized`, () => {
+      storeAttribute.replace([]);
+    })();
+  }
+};