always create new diff object

Author: pemrouz

dist/index.js

@@ -29,9 +29,9 @@ var _values = require('utilise/values');
 
 var _values2 = _interopRequireDefault(_values);
 
-var _last = require('utilise/last');
+var _key = require('utilise/key');
 
-var _last2 = _interopRequireDefault(_last);
+var _key2 = _interopRequireDefault(_key);
 
 var _is = require('utilise/is');
 
@@ -92,7 +92,11 @@ var register = function register(ripple) {
 
     if (!res) return err('failed to register', name), false;
     ripple.resources[name] = res;
-    ripple.emit('change', [name, res.body.log ? (0, _last2.default)(res.body.log) : { type: 'update', value: res.body }]);
+    ripple.emit('change', [name, {
+      type: 'update',
+      value: res.body,
+      time: now(res)
+    }]);
     return ripple.resources[name].body;
   };
 };
@@ -124,4 +128,7 @@ var types = function types() {
 };
 
 var err = require('utilise/err')('[ri/core]'),
-    log = require('utilise/log')('[ri/core]');
+    log = require('utilise/log')('[ri/core]'),
+    now = function now(d, t) {
+  return t = (0, _key2.default)('body.log.length')(d), _is2.default.num(t) ? t - 1 : t;
+};

src/index.js

@@ -40,10 +40,11 @@ const register = ripple => ({name, body, headers = {}}) => {
 
   if (!res) return err('failed to register', name), false
   ripple.resources[name] = res
-  ripple.emit('change', [name, res.body.log
-    ? last(res.body.log)
-    : { type: 'update', value: res.body }
-  ])
+  ripple.emit('change', [name, { 
+    type: 'update'
+  , value: res.body
+  , time: now(res)
+  }])
   return ripple.resources[name].body
 }
 
@@ -69,10 +70,11 @@ import chainable  from 'utilise/chainable'
 import identity   from 'utilise/identity'
 import header     from 'utilise/header'
 import values     from 'utilise/values'
-import last       from 'utilise/last'
+import key        from 'utilise/key'
 import is         from 'utilise/is'
 import to         from 'utilise/to'
 import za         from 'utilise/za'
 import text       from './types/text'
 const err = require('utilise/err')('[ri/core]')
-    , log = require('utilise/log')('[ri/core]')
+    , log = require('utilise/log')('[ri/core]')
+    , now = (d, t) => (t = key('body.log.length')(d), is.num(t) ? t - 1 : t)

test.js

@@ -137,21 +137,21 @@ describe('Core', function() {
 
     ripple.on('change', fn)
     ripple('foo', 'bar')
-    expect(params).to.eql(['foo', { type: 'update', value: 'bar' }])
+    expect(params).to.eql(['foo', { type: 'update', value: 'bar', time: undefined }])
 
     ripple.types['data'] = { header: 'data', check: String }
     ripple('boo', { log: ['baz'] })
-    expect(params).to.eql(['boo', 'baz'])
+    expect(params).to.eql(['boo', { type: 'update', value: { log: ['baz'] }, time: 0 }])
   })
 
   it('should indicate if new resource', function(done){
     var ripple = core()
     ripple.once('change', function(d, change){
       expect(d).to.eql('foo')
-      expect(change).to.eql({ type: 'update', value: 'foo' })
+      expect(change).to.eql({ type: 'update', value: 'foo', time: undefined })
       ripple.once('change', function(d, change){
         expect(d).to.eql('foo')
-        expect(change).to.eql({ type: 'update', value: 'bar' })
+        expect(change).to.eql({ type: 'update', value: 'bar', time: undefined })
         done()
       })
       ripple('foo', 'bar')