it should respond via ack if available

Author: pemrouz

dist/index.js

@@ -63,7 +63,7 @@ var _is2 = _interopRequireDefault(_is);
 function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
 
 // -------------------------------------------
-// API: Synchronises resources between server/client
+// Synchronises resources between server/client
 // -------------------------------------------
 function sync(ripple, server) {
   log('creating');
@@ -168,7 +168,7 @@ var to = function to(ripple, res, change) {
 
 // incoming transforms
 var consume = function consume(ripple) {
-  return function (_ref3) {
+  return function (_ref3, ack) {
 /* istanbul ignore next */
     var _ref4 = _slicedToArray(_ref3, 3);
 
@@ -186,7 +186,7 @@ var consume = function consume(ripple) {
         xres = (0, _header2.default)('from')(res),
         next = (0, _set2.default)(change),
         silent = silence(this),
-        respond = ripple.respond(this, name, change.time);
+        respond = ack || ripple.respond(this, name, change.time);
 
     return xall && !xall.call(this, req, change, respond) ? debug('skip all', name) // rejected - by xall
     : xtype && !xtype.call(this, req, change, respond) ? debug('skip type', name) // rejected - by xtype

src/index.js

@@ -22,10 +22,10 @@ export default function sync(ripple, server){
 }
 
 const respond = ripple => (socket, name, time) => reply => {
-  socket.emit('response', [ name, time, reply ])
+  socket.emit('response', [name, time, reply])
 }
 
-const response = ripple => function([ name, time, reply ]) {
+const response = ripple => function([name, time, reply]) {
   ripple.resources[name].body.emit('response._' + time, reply)
 }
 
@@ -78,7 +78,7 @@ const to = (ripple, res, change) => socket => {
 }
 
 // incoming transforms
-const consume = ripple => function([name, change, req = {}]) {
+const consume = ripple => function([name, change, req = {}], ack) {
   log('receiving', name)
 
   const res     = ripple.resources[name]
@@ -87,7 +87,7 @@ const consume = ripple => function([name, change, req = {}]) {
       , xres    = header('from')(res)
       , next    = set(change)
       , silent  = silence(this)
-      , respond = ripple.respond(this, name, change.time)
+      , respond = ack || ripple.respond(this, name, change.time)
 
   return xall  &&  !xall.call(this, req, change, respond) ? debug('skip all' , name) // rejected - by xall
        : xtype && !xtype.call(this, req, change, respond) ? debug('skip type', name) // rejected - by xtype