#11

thenativeweb · Jul 11, 2013 · 4c075ca · 4c075ca
1 parent a2f35e0
commit 4c075ca
Show file tree

Hide file tree

Showing 5 changed files with 13 additions and 3 deletions.
diff --git a/README.md b/README.md
@@ -76,6 +76,10 @@ See [tests](https://github.com/adrai/node-cqrs-domain/tree/master/test) for deta
 
 # Release Notes
 
+## v0.4.1
+
+- added optional snapshotThreshold on aggregate
+
 ## v0.4.0
 
 - asynchronous api for saga

diff --git a/lib/bases/commandHandlerBase.js b/lib/bases/commandHandlerBase.js
@@ -88,7 +88,9 @@ CommandHandler.prototype = {
             if (!err) {
                 stream.commit(function(err) {
                     // Check if snapshotting is needed.
-                    if (stream.events.length >= self.options.snapshotThreshold) {
+                    if (aggregate.snapshotThreshold && ((_.isFunction(aggregate.snapshotThreshold) && stream.events.length >= aggregate.snapshotThreshold()) ||
+                                                        (_.isNumber(aggregate.snapshotThreshold) && stream.events.length >= aggregate.snapshotThreshold)) ||
+                        stream.events.length >= self.options.snapshotThreshold) {
                         self.eventStore.createSnapshot(stream.streamId, stream.currentRevision(), aggregate.toJSON());
                     }
                 });

diff --git a/licence b/licence
@@ -1,4 +1,4 @@
-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

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

diff --git a/test/integration/aggregates/dummyAggregate.js b/test/integration/aggregates/dummyAggregate.js
@@ -2,6 +2,10 @@ var base = require('../../../index').aggregateBase;
 
 module.exports = base.extend({
 
+    // snapshotThreshold: 20, 
+    // or
+    // snapshotThreshold: function() { return 12 + 10; },
+
     changeDummy: function(data, callback) {
         this.apply(this.toEvent('dummyChanged', data));