Reactive search results. Performance is not considered while implemen…

…ting this.

README.md

@@ -100,6 +100,40 @@ Template.searchResult.helpers({
 });
 ```
 
+### Use reactive data in search results
+
+By default, the contents returned by `getData()` is not reactive in the sense of it reflecting the current state of the mongo database. To use reactive content, do the following when creating a SearchSource object on the client
+
+```js
+var options = {
+  keepHistory: 1000 * 60 * 5,
+  localSearch: true,
+  collection: Documents, // Collection to reflect on the client
+  subscriptionName: 'documents.byIds' // Use subscription by this name
+};
+
+// Some fields
+const fields = [ 'name', 'description' ];
+
+const DocumentSearch = new SearchSource('docs', fields, options);
+```
+
+and on the server, publish the documents by ids
+
+```js
+Meteor.publish('documents.byIds', function (ids) {
+  check(ids, [ String ]);
+
+  return Documents.find({
+    _id: {
+      $in: ids
+    }
+  });
+});
+```
+
+and the rest is as usual. One thing to notice is that `getData()` cannot return a cursor if reactive items are used. This is because we sort documents on a score field that is not attached to the documents itself, so mongo cannot take care of the ordering.
+
 ### Searching
 
 Finally we can invoke search queries by invoking following API.

lib/client.js

@@ -19,6 +19,7 @@ SearchSource.prototype._loadData = function(query, options) {
   var self = this;
   var version = 0;
   var historyKey = query + EJSON.stringify(options);
+
   if(this._canUseHistory(historyKey)) {
     this._updateStore(this.history[historyKey].data);
     this.metaData.set(this.history[historyKey].metadata);
@@ -149,6 +150,31 @@ SearchSource.prototype.getData = function(options, getCursor) {
     transform: transform
   });
 
+  var collection = this.options.collection;
+
+  if(collection) {
+    var ids = _.pluck(cursor.fetch(), '_id');
+
+    if (this.options.subscriptionName) {
+        Meteor.subscribe(this.options.subscriptionName, ids);
+    }
+
+    var docs = collection.find({
+      _id: {
+        $in: ids
+      }
+    }, {
+      transform: transform
+    }).fetch();
+
+    var sortIds = _.invert(_.object(_.pairs(ids)));
+    var sorted = _.sortBy(docs, function(x) {
+        return sortIds[x._id];
+    });
+
+    return sorted;
+  }
+
   if(getCursor) {
     return cursor;
   }
@@ -234,4 +260,4 @@ SearchSource.prototype._getRegExpFilterRegExp = _.once(function() {
     return "\\" + c;
   }).join("|");
   return new RegExp("(" + regExpCharsReplace + ")", "g");
-});
+});