fixed sagahandler

thenativeweb · Feb 20, 2013 · 1c79f41 · 1c79f41
1 parent e01651e
commit 1c79f41
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 3 deletions.
diff --git a/lib/bases/sagaHandlerBase.js b/lib/bases/sagaHandlerBase.js
@@ -12,7 +12,7 @@ SagaHandler.prototype = {
         var self = this;
 
         function initSaga(id, data) {
-            var saga = new this.Saga(id);
+            var saga = new self.Saga(id);
             saga.load(data);
             self.sagas[id] = saga;
         }
@@ -21,7 +21,7 @@ SagaHandler.prototype = {
             if (!err) {
                 for(var i = 0, len = sagas.length; i < len; i++) {
                     var saga = sagas[i];
-                    initSaga(stream.id, saga);
+                    initSaga(saga.id, saga);
                 }
             }
         });
@@ -62,6 +62,7 @@ SagaHandler.prototype = {
     commit: function(saga, callback) {
         var self = this;
         this.repository.get(saga.id, function(err, vm) {
+            vm.set('type', self.saga);
             if (saga.get('destroyed')) {
                 vm.destroy();
             } else {

diff --git a/lib/domain.js b/lib/domain.js
@@ -69,6 +69,9 @@ module.exports = domain = _.extend(new EventEmitter2({
 
         _.defaults(options, defaults);
 
+        options.commandQueue.collectionName = options.commandQueue.collectionName || defaults.commandQueue.collectionName;
+        options.repository.collectionName = options.repository.collectionName || defaults.repository.collectionName;
+
         // initialize the hub by passing the function that gets the command id from the event
         hub.init(newGetCommandId || getCommandId);
 

diff --git a/package.json b/package.json
@@ -1,7 +1,7 @@
 {
   "author": "adrai",
   "name": "cqrs-domain",
-  "version": "0.3.5",
+  "version": "0.3.6",
   "private": false,
   "main": "index.js",
   "engines": {