v1.0.7

.babelrc

@@ -0,0 +1,8 @@
+{
+  "presets": [
+    "es2015"
+  ],
+  "plugins": [
+    "add-module-exports"
+  ]
+}

.eslintrc.yml

@@ -0,0 +1,6 @@
+extends: eslint:recommended
+parserOptions:
+  ecmaVersion: 6
+  sourceType: module
+env:
+  node: true

.gitignore

@@ -1,11 +1,4 @@
-.DS_Store
-logs
-*.log
-pids
-*.pid
-*.seed
-lib-cov
-coverage
-.lock-wscript
-npm-debug.log*
-node_modules
+/coverage/
+/lib/
+/node_modules/
+/npm-debug.log

.npmignore

@@ -0,0 +1,7 @@
+/coverage/
+/src/
+/.babelrc
+/.editorconfig
+/.eslintrc.yml
+/.gitignore
+/.travis.yml

.travis.yml

@@ -1,12 +1,23 @@
 language: node_js
 node_js:
-  - "stable"
-  - "5.0"
-  - "4.0"
+  - "6"
+  - "4"
   - "0.12"
   - "0.10"
-after_script:
+after_success:
   - npm run coveralls
-branches:
-  only:
-    - master
+before_deploy:
+  - npm run build
+deploy:
+  provider: npm
+  api_key:
+    secure: iZZgNpXKoBt+O/xjmh9bhoxKV0Yth8LuxpDCE0ULD4kGlx/yMyGsSllLu1RHPKJKu4e/hB4svq9Qk8SJLH+q7drld1JzwkT9YPgYNKx4YyHzvi79sI7SQa+yS2wrgaKPxErBgi2FX5Dssy9Mw+bkTAsPpHrc+l8ElxCcpllJKJr6kuk1IhWlt406ZColZE0jYX1GLgLed/VLVPr95tx/bZJEAfo7zNMn3kjGOG5GR5tid2i9CLLrPf6VcjWzoLzuqlE4NRrfD1lf+poOnH6URp89Wq0Ar8lWtBPpwaE5FDgMg2K3HlErdYt0DNRkC/hwxtYYNBrzeSHdFHwV5lOKODKZVIVTQ6b4mMzC1JCThxQy2Ayci3bnzMW3ZiE0xr8h+zDWiZWQa38PLCZfdfVv+15jqa/Bx2kKU3Utkua/Fk83O9tVvFoDcBvepY23zhoyJquB3xQ5v+xzDexLFU0gLgLAc+d4nP84AzJgKQYO94KnV96UkrSWQeavck87BcxZKhXLTqqIzuqGv5Ep32WjCOVcxyG4hcN+rAArKyI1YwfDAA/rcN1xj5KVzoTnoBppqTXczhumqsp8zcu9q0CPvbXCTeo4QE6bV1LadStLzer5B3NnTid0WFJ1tvInKFQf92diNZTfb6znbc53ZGDfRuVE97v66iaph7BtVfqsqfU=
+  email:
+    secure: ABRzp+20NrgciL4tdftlCINA9MHp2Ldd8R3k+v2ekILOR/n3Vomxd5qbmHhP/AiFWYEUZw1fU7zg6NNaxmtXRKvnLrpkA0aDeFBIphJ/wN/RSyR0hHO4VChf7bQYZnjpw8hJQy3Q3q41McKdTAc0MyoBELLcBh7bODgLzla1YqZRSb95XFJgK1g8umcKQ3HURkBLGSNimyXYqrukRAr7IIp7PYmovQzyEMNTmsSHJiE005/gHWv14ly+MGcRl27HlrDa0WWZMn5oRXUyiLgR7yhmmZOCK2VzC4nhm5J39j0vexY8YuxXyyd7NlUipcwIP9XiMeqX7t6w+DPCskYh4xq7iqV+jC2PRYaL+fKVXvJAJCDFgrSi3pJAtge7EFdcfqLZrdaekmHt9O9BLXKXd0QTEX+snaSW5nc1EwdoRHibUnybRIl5aZnrr88FK8EhtAvkJdhlqb1Ij98+/KHhEvlzgOJIMewykZv8Aa7QqDlBw9zAHJH4ZAxQfPa72lo9gIoc/1I18pUDHbXtzJL+dVEfk/zjrtGnZ7Ag1wJX6pGaNhndhTTIaFhAaDUojQAkeee5WmUTTgTHmjPjiCryXiKfbLhdXL3c3lXD4EnbBP5Gzv2Yu4YQMTVg1OcDi4zduussmN0uf+Ahm9dNIKkvrcTvAwPJ1tOqnbGH6SX75Zs=
+  skip_cleanup: true
+  on:
+    repo: akim-mcmath/gulp-transform
+    node: "4"
+    tags: true
+after_deploy:
+  - npm run unbuild

README.md

@@ -127,7 +127,7 @@ Copyright © 2016 Akim McMath. Licensed under the [MIT License][License link
 [NPM link]: https://npmjs.org/package/gulp-transform
 [Version badge]: https://img.shields.io/npm/v/gulp-transform.svg?style=flat-square
 [License badge]: https://img.shields.io/npm/l/gulp-transform.svg?style=flat-square
-[License link]: LICENSE.txt
+[License link]: LICENSE
 [Build badge]: https://img.shields.io/travis/akim-mcmath/gulp-transform/master.svg?style=flat-square
 [Build link]: https://travis-ci.org/akim-mcmath/gulp-transform
 [Coverage badge]: https://img.shields.io/coveralls/akim-mcmath/gulp-transform/master.svg?style=flat-square&service=github

package.json

@@ -1,22 +1,17 @@
 {
   "name": "gulp-transform",
-  "version": "1.0.6",
-  "description": "Gulp plugin for performing arbitrary transformations on the contents of files.",
-  "main": "index.js",
-  "files": [
-    "index.js",
-    "LICENSE.txt",
-    "README.md"
-  ],
+  "version": "1.0.7",
+  "description": "Perform arbitrary transformations on files",
+  "main": "lib/index.js",
   "scripts": {
-    "test": "npm run jshint && npm run jscs && npm run mocha",
-    "jshint": "jshint . --exclude-path .gitignore",
-    "jscs": "jscs .",
-    "mocha": "istanbul cover _mocha",
+    "build": "npm run unbuild && babel src -d lib",
+    "unbuild": "rimraf lib",
+    "test:lint": "eslint src",
+    "test:unit": "istanbul cover _mocha",
+    "test:report": "npm run test:unit && open coverage/lcov-report/index.html",
+    "test": "npm run test:lint && npm run test:unit",
     "coverage": "npm test && open ./coverage/lcov-report/index.html",
-    "clean": "rm -rf ./node_modules ./coverage",
-    "coveralls": "cat ./coverage/lcov.info | coveralls",
-    "preversion": "npm run test"
+    "coveralls": "cat coverage/lcov.info | coveralls"
   },
   "engines": {
     "node": ">=0.10"
@@ -40,23 +35,26 @@
   },
   "homepage": "https://github.com/akim-mcmath/gulp-transform#readme",
   "peerDependencies": {
-    "gulp": "^3.0.0"
+    "gulp": "3.x"
   },
   "dependencies": {
-    "gulp-util": "^3.0.7"
+    "gulp-util": "^3.0.7",
+    "lodash": "^4.13.1"
   },
   "devDependencies": {
+    "babel-cli": "^6.9.0",
+    "babel-plugin-add-module-exports": "^0.2.1",
+    "babel-preset-es2015": "^6.9.0",
+    "babel-register": "^6.9.0",
     "chai": "^3.5.0",
-    "cheerio": "^0.20.0",
-    "coveralls": "^2.11.6",
+    "coffee-script": "^1.10.0",
+    "coveralls": "^2.11.9",
+    "eslint": "^2.11.1",
     "event-stream": "^3.3.2",
-    "gulp": "^3.9.1",
-    "istanbul": "^0.4.2",
-    "jscs": "^2.9.0",
-    "jshint": "^2.9.1",
-    "mocha": "^2.4.5",
-    "rimraf": "^2.5.1",
-    "sinon": "^1.17.3",
+    "istanbul": "1.0.0-alpha.2",
+    "mocha": "^2.5.3",
+    "rimraf": "^2.5.2",
+    "sinon": "^1.17.4",
     "sinon-chai": "^2.8.0"
   }
 }

src/err.js

@@ -0,0 +1,5 @@
+import {PluginError} from 'gulp-util';
+
+export function err(msg) {
+  throw new PluginError('gulp-transform', msg);
+}

src/file-stream.js

@@ -0,0 +1,27 @@
+import {Transform} from 'stream';
+import {transform} from './transform';
+
+export class FileStream extends Transform {
+
+  constructor(transformFn, file, options) {
+    super();
+
+    this.fn = transformFn;
+    this.file = file;
+    this.opts = options;
+    this.data = [];
+  }
+
+  _transform(chunk, encoding, next) {
+    this.data.push(chunk);
+    next();
+  }
+
+  _flush(done) {
+    let contents = Buffer.concat(this.data);
+    this.push(transform(this.fn, contents, this.file, this.opts));
+
+    done();
+  }
+
+}

src/index.js

@@ -0,0 +1,18 @@
+import {isNil, isFunction, isObject} from 'lodash';
+import {PluginStream} from './plugin-stream';
+import {err} from './err';
+
+export default function gulpTransform(transformFn, options) {
+  if (isNil(transformFn)) {
+    err('transformFn must be defined');
+
+  } else if (!isFunction(transformFn)) {
+    err('transformFn must be a function');
+
+  } else if (!isNil(options) && !isObject(options)) {
+    err('options must be an object');
+
+  } else {
+    return new PluginStream(transformFn, options);
+  }
+}

src/plugin-stream.js

@@ -0,0 +1,28 @@
+import {Transform} from 'stream';
+import {FileStream} from './file-stream';
+import {transform} from './transform';
+
+export class PluginStream extends Transform {
+
+  constructor(transformFn, options={}) {
+    super({objectMode: true});
+
+    this.fn = transformFn;
+    this.opts = options;
+  }
+
+  _transform(file, encoding, next) {
+    let {fn, opts} = this;
+
+    if (file.isBuffer()) {
+      file.contents = transform(fn, file.contents, file, opts);
+    }
+
+    if (file.isStream()) {
+      file.contents = file.contents.pipe(new FileStream(fn, file, opts));
+    }
+
+    next(null, file);
+  }
+
+}

src/transform.js

@@ -0,0 +1,11 @@
+import {isBuffer, isString} from 'lodash';
+import {err} from './err';
+
+export function transform(fn, contents, file, opts) {
+  let encoded = opts.encoding ? contents.toString(opts.encoding) : contents;
+  let transformed = fn.call(opts.thisArg, encoded, file);
+
+  return isBuffer(transformed) ? transformed :
+    isString(transformed) ? new Buffer(transformed) :
+    err('transformFn must return a string or a Buffer');
+}