From abd94a7f5a50f43c797a11b53549ae48fff667c3 Mon Sep 17 00:00:00 2001 From: Florian Dold Date: Mon, 10 Oct 2016 03:43:44 +0200 Subject: add node_modules to address #4364 --- node_modules/gulp-json-transform/index.js | 59 +++++++++++++++++++++++++++++++ 1 file changed, 59 insertions(+) create mode 100644 node_modules/gulp-json-transform/index.js (limited to 'node_modules/gulp-json-transform/index.js') diff --git a/node_modules/gulp-json-transform/index.js b/node_modules/gulp-json-transform/index.js new file mode 100644 index 000000000..a42f4239c --- /dev/null +++ b/node_modules/gulp-json-transform/index.js @@ -0,0 +1,59 @@ +var Promise = require('promise'); +var through = require('through2'); +var gutil = require('gulp-util'); +var PluginError = gutil.PluginError; + +const PLUGIN_NAME = 'gulp-json-transform'; + +function jsonPromiseParse(rawStr) { + return new Promise(function(resolve, reject) { + var json; + try { + json = JSON.parse(rawStr); + } catch (e) { + return reject(new Error('Invalid JSON: ' + e.message)); + } + resolve(json); + }); +} + +module.exports = function(transformFn, jsonSpace) { + if (!transformFn) { + throw new PluginError(PLUGIN_NAME, 'Missing transform function!'); + } + + return through.obj(function(file, enc, cb) { + var self = this; + + if (file.isStream()) { + return self.emit('error', new PluginError(PLUGIN_NAME, 'Streaming not supported')); + } + + if (file.isBuffer()) { + var fileContent = file.contents.toString(enc); + + jsonPromiseParse(fileContent) + .then(function(data){ + return transformFn(data, { + path: file.path, + relative: file.relative, + base: file.base + }); + }) + .then(function(output) { + var isString = (typeof output === 'string'); + file.contents = new Buffer(isString ? output : JSON.stringify(output, null, jsonSpace)); + self.push(file); + cb(); + }) + .catch(function(e) { + gutil.log(PLUGIN_NAME + ':', gutil.colors.red(e.message)); + self.emit('error', new PluginError(PLUGIN_NAME, e)); + self.emit('end'); + }); + + } + + }); + +}; -- cgit v1.2.3