From 10381a7abeda230be662345c27f0f081c824d8c1 Mon Sep 17 00:00:00 2001
From: pemrouz <p3pedram@hotmail.com>
Date: Sun, 6 Mar 2016 21:27:57 +0000
Subject: [PATCH] skip transformations for partial diffs

---
 dist/index.js | 26 ++++++++++----------------
 src/index.js  | 19 +++++++++----------
 2 files changed, 19 insertions(+), 26 deletions(-)

diff --git a/dist/index.js b/dist/index.js
index 218bc7b..a9adbea 100644
--- a/dist/index.js
+++ b/dist/index.js
@@ -29,10 +29,6 @@ var _client = require('utilise/client');
 
 var _client2 = _interopRequireDefault(_client);
 
-var _proxy = require('utilise/proxy');
-
-var _proxy2 = _interopRequireDefault(_proxy);
-
 var _keys = require('utilise/keys');
 
 var _keys2 = _interopRequireDefault(_keys);
@@ -61,7 +57,8 @@ function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { de
 // -------------------------------------------
 function mysql(ripple) {
   log('creating');
-  strip(ripple.types['application/data']);
+  var type = ripple.types['application/data'];
+  type.to = strip(type.to);
   (0, _key2.default)('adaptors.mysql', function (d) {
     return init(ripple);
   })(ripple);
@@ -158,20 +155,17 @@ var kvpair = function kvpair(arr) {
   };
 };
 
-var strip = function strip(type) {
-  type.to = (0, _proxy2.default)(type.to, function (_ref) {
-    var name = _ref.name;
-    var body = _ref.body;
-    var headers = _ref.headers;
+var strip = function strip(next) {
+  return function (res, change) {
+    if (change) return next ? next.call(this, res, change) : true;
+    var rep = { name: res.name, body: res.body, headers: {} };
 
-    var stripped = {};
-
-    (0, _keys2.default)(headers).filter((0, _not2.default)((0, _is2.default)('mysql'))).map(function (header) {
-      return stripped[header] = headers[header];
+    (0, _keys2.default)(res.headers).filter((0, _not2.default)((0, _is2.default)('mysql'))).map(function (header) {
+      return rep.headers[header] = res.headers[header];
     });
 
-    return { name: name, body: body, headers: stripped };
-  });
+    return next ? next.call(this, rep, change) : rep;
+  };
 };
 
 var loaded = 'headers.mysql.loaded',
diff --git a/src/index.js b/src/index.js
index 633fb7c..7ec3d63 100644
--- a/src/index.js
+++ b/src/index.js
@@ -3,7 +3,8 @@
 // -------------------------------------------
 export default function mysql(ripple){
   log('creating')
-  strip(ripple.types['application/data'])
+  var type = ripple.types['application/data']
+  type.to = strip(type.to)
   key('adaptors.mysql', d => init(ripple))(ripple)
   return ripple
 }
@@ -109,16 +110,15 @@ const sqls = {
 
 const kvpair = arr => key => '`' + key + "`=" + escape(arr[key])
 
-const strip = type => {
-  type.to = proxy(type.to, ({ name, body, headers }) => { 
-    const stripped = {}
+const strip = next => function (res, change) {
+  if (change) return next ? next.call(this, res, change) : true
+  const rep = { name: res.name, body: res.body, headers: {} }
 
-    keys(headers)
-      .filter(not(is('mysql')))
-      .map(header => stripped[header] = headers[header])
+  keys(res.headers)
+    .filter(not(is('mysql')))
+    .map(header => rep.headers[header] = res.headers[header])
 
-    return { name, body, headers: stripped } 
-  })
+  return next ? next.call(this, rep, change) : rep
 }
 
 import { default as from } from 'utilise/from'
@@ -127,7 +127,6 @@ import prepend from 'utilise/prepend'
 import append from 'utilise/append'
 import header from 'utilise/header'
 import client from 'utilise/client'
-import proxy from 'utilise/proxy'
 import keys from 'utilise/keys'
 import key from 'utilise/key'
 import not from 'utilise/not'