expect mongoose connection to be injected

Author: tbarbugli

src/FeedManager.js

@@ -69,11 +69,12 @@ FeedManager.prototype = {
   },
 
   activityCreated: function(instance) {
-    if (this.trackingEnabled(instance)){
+    if (this.trackingEnabled(instance)) {
       var activity = instance.createActivity();
-      instance.getStreamBackend().serializeActivities([activity]);
+      var backend = instance.getStreamBackend();
+      backend.serializeActivities([activity]);
       var feedType = instance.activityActorFeed() || this.settings.userFeed;
-      var userId = instance.activityActorId();
+      var userId = backend.getIdFromRef(activity.actor);
       feed = this.getFeed(feedType, userId);
       feed.addActivity(activity, function(err, response, body) {
         if (err) console.log('err: ', err);
@@ -82,7 +83,7 @@ FeedManager.prototype = {
   },
 
   activityDeleted: function(instance) {
-    if (this.trackingEnabled(instance)){
+    if (this.trackingEnabled(instance)) {
       var activity = instance.createActivity();
       feed = this.getFeed(this.settings.userFeed, activity.actor);
       feed.removeActivity({'foreignId': activity.foreign_id}, function(err, response, body) {

src/backends/activity.js

@@ -22,15 +22,6 @@ BaseActivity.methods.activityActor = function() {
     return actor;
 };
 
-BaseActivity.methods.activityActorId = function() {
-    var actor = this.activityGetActor();
-    if (typeof(actor.activityInstanceReference) === 'function') {
-        return actor.activityInstanceReference(actor);
-    } else {
-        return actor;
-    }
-};
-
 BaseActivity.methods.activityObject = function() {
     return this;
 };

src/backends/mongoose.js

@@ -1,12 +1,14 @@
 var BaseActivity = require('./activity.js');
 var util = require("util");
-var mongoose = require('mongoose');
 var stream = require('../index.js');
 
 function Backend() {}
 
-util.inherits(Backend, stream.BaseBackend);
+function setupMongoose(m) {
+  Backend.prototype.getMongoose = function () { return m };
+}
 
+util.inherits(Backend, stream.BaseBackend);
 
 Backend.prototype.serializeValue = function(value) {
   if (typeof(value._id) != "undefined") {
@@ -31,9 +33,14 @@ Backend.prototype.loadFromStorage = function(modelClass, objectsIds, callback) {
 };
 
 Backend.prototype.getClassFromRef = function(ref) {
+  var mongoose = this.getMongoose();
   return mongoose.model(ref);
 }
 
+Backend.prototype.getIdFromRef = function(ref) {
+  return ref.split(':')[1];
+}
+
 function extendSchema(base, mixin) {
   if (typeof base.methods === 'undefined') {
     base.methods = {};
@@ -93,3 +100,4 @@ var activitySchema = function(Schema) {
 
 module.exports.activitySchema = activitySchema;
 module.exports.Backend = Backend;
+module.exports.setupMongoose = setupMongoose;

src/index.js

@@ -3,8 +3,7 @@ var config = require('./config.js');
 var settings = config();
 var BaseBackend = require('./backends/base.js');
 
-// TODO: make sure this happens only once!
-// appears to be happening once only : )
 module.exports.FeedManager = new FeedManager(settings);
 module.exports.BaseBackend = BaseBackend;
 module.exports.mongoose = require('./backends/mongoose.js');
+module.exports.settings = settings;