Initial version.

Author: mitar

.gitignore

@@ -0,0 +1,3 @@
+.*
+.build*
+smart.lock

package.js

@@ -0,0 +1,48 @@
+Package.describe({
+  summary: "Reactive server-side MongoDB queries",
+  version: '0.1.0',
+  name: 'peerlibrary:reactive-publish',
+  git: 'https://github.com/peerlibrary/meteor-reactive-publish.git'
+});
+
+Package.onUse(function (api) {
+  api.versionsFrom('[email protected]');
+
+  // Core dependencies.
+  api.use([
+    'coffeescript',
+    'underscore',
+    'mongo'
+  ], 'server');
+
+  // 3rd party dependencies.
+  api.use([
+    'peerlibrary:[email protected]',
+    'peerlibrary:[email protected]'
+  ], 'server');
+
+  api.addFiles([
+    'server.coffee'
+  ], 'server');
+});
+
+Package.onTest(function (api) {
+  // Core dependencies.
+  api.use([
+    'tinytest',
+    'test-helpers',
+    'coffeescript',
+    'insecure',
+    'random',
+    'underscore'
+  ]);
+
+  // Internal dependencies.
+  api.use([
+    'peerlibrary:reactive-publish'
+  ]);
+
+  api.add_files([
+    'tests.coffee'
+  ]);
+});

server.coffee

@@ -0,0 +1,83 @@
+originalPublish = Meteor.publish
+
+Meteor.publish = (name, publishFunction) ->
+  originalPublish name, (args...) ->
+    publish = @
+
+    relatedPublish = null
+    ready = false
+
+    publishDocuments = ->
+      oldRelatedPublish = relatedPublish
+
+      Tracker.nonreactive =>
+        relatedPublish = publish._recreate()
+
+        # We copy overridden methods if they exist
+        for own key, value of publish when key in ['added', 'changed', 'removed', 'ready', 'stop', 'error']
+          relatedPublish[key] = value
+
+        # If there are any extra fields which do not exist in recreated related publish
+        # (because they were added by some other code), copy them over
+        # TODO: This copies also @related, test how recursive @related works
+        for own key, value of publish when key not of relatedPublish
+          relatedPublish[key] = value
+
+        relatedPublishAdded = relatedPublish.added
+        relatedPublish.added = (collectionName, id, fields) ->
+          stringId = @_idFilter.idStringify id
+          # If document as already present in oldRelatedPublish then we just set
+          # relatedPublish's _documents and call changed to send updated fields
+          # (Meteor sends only a diff).
+          if oldRelatedPublish?._documents[collectionName]?[stringId]
+            Meteor._ensure(@_documents, collectionName)[stringId] = true
+            @changed collectionName, id, fields
+          else
+            relatedPublishAdded.call @, collectionName, id, fields
+
+        relatedPublish.ready = ->
+          # Mark it as ready only the first time
+          publish.ready() unless ready
+          ready = true
+          # To return nothing.
+          return
+
+        relatedPublish.stop = (relatedChange) ->
+          if relatedChange
+            # We only deactivate (which calls stop callbacks as well) because we
+            # have manually removed only documents which are not published again.
+            @_deactivate()
+          else
+            # We do manually what would _stopSubscription do, but without
+            # subscription handling. This should be done by the parent publish.
+            @_removeAllDocuments()
+            @_deactivate()
+            publish.stop()
+          # To return nothing.
+          return
+
+      relatedPublish._handler = publishFunction
+      relatedPublish._runHandler()
+
+      return unless oldRelatedPublish
+
+      Tracker.nonreactive =>
+        # We remove those which are not published anymore
+        for collectionName in _.keys(oldRelatedPublish._documents)
+          for id in _.difference _.keys(oldRelatedPublish._documents[collectionName] or {}), _.keys(relatedPublish._documents[collectionName] or {})
+            oldRelatedPublish.removed collectionName, id
+
+        oldRelatedPublish.stop true
+        oldRelatedPublish = null
+
+    handle = Tracker.autorun (computation) =>
+      publishDocuments()
+
+    publish.onStop ->
+      handle?.stop()
+      handle = null
+      relatedPublish?.stop()
+      relatedPublish = null
+
+    # To return nothing.
+    return