Skip to content

Commit

Permalink
skip transformations for partial diffs
Browse files Browse the repository at this point in the history
  • Loading branch information
pemrouz committed Mar 6, 2016
1 parent 4140214 commit 10381a7
Show file tree
Hide file tree
Showing 2 changed files with 19 additions and 26 deletions.
26 changes: 10 additions & 16 deletions dist/index.js
Original file line number Diff line number Diff line change
Expand Up @@ -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);
Expand Down Expand Up @@ -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);
Expand Down Expand Up @@ -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',
Expand Down
19 changes: 9 additions & 10 deletions src/index.js
Original file line number Diff line number Diff line change
Expand Up @@ -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
}
Expand Down Expand Up @@ -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'
Expand All @@ -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'
Expand Down

0 comments on commit 10381a7

Please sign in to comment.