fixed saga handler base

README.md

@@ -88,9 +88,16 @@ It can be very useful as domain and eventdenormalizer component if you work with
 
 See [tests](https://github.com/adrai/node-cqs/tree/master/test) for detailed information...
 
+# Release Notes
+
+## v0.3.6
+
+- fixed saga handler base
+
+
 # License
 
-Copyright (c) 2012 Adriano Raiano
+Copyright (c) 2013 Adriano Raiano
 
 Permission is hereby granted, free of charge, to any person obtaining a copy
 of this software and associated documentation files (the "Software"), to deal

lib/domain/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);
                 }
             }
         });
@@ -45,7 +45,7 @@ SagaHandler.prototype = {
                 callback(null, saga);
             },
 
-            // commit
+            // commit the uncommittedEvents
             function(saga, callback) {
                 self.commit(saga, callback);
             }
@@ -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 {

package.json

@@ -1,7 +1,7 @@
 {
   "author": "adrai",
   "name": "node-cqs",
-  "version": "0.3.5",
+  "version": "0.3.6",
   "private": false,
   "main": "index.js",
   "engines": {