1.0.4

README.md

@@ -1,9 +1,37 @@
 # smartstream
 simplifies access to node streams, TypeScript ready!
 
-## Status
+## Availabililty
+[![npm](https://push.rocks/assets/repo-button-npm.svg)](https://www.npmjs.com/package/smartstream)
+[![git](https://push.rocks/assets/repo-button-git.svg)](https://gitlab.com/pushrocks/smartstream)
+[![git](https://push.rocks/assets/repo-button-mirror.svg)](https://github.com/pushrocks/smartstream)
+[![docs](https://push.rocks/assets/repo-button-docs.svg)](https://pushrocks.gitlab.io/smartstream/gitbook)
+
+## Status for master
 [![build status](https://gitlab.com/pushrocks/smartstream/badges/master/build.svg)](https://gitlab.com/pushrocks/smartstream/commits/master)
+[![coverage report](https://gitlab.com/pushrocks/smartstream/badges/master/coverage.svg)](https://gitlab.com/pushrocks/smartstream/commits/master)
+[![Dependency Status](https://david-dm.org/pushrocks/smartstream.svg)](https://david-dm.org/pushrocks/smartstream)
+[![bitHound Dependencies](https://www.bithound.io/github/pushrocks/smartstream/badges/dependencies.svg)](https://www.bithound.io/github/pushrocks/smartstream/master/dependencies/npm)
+[![bitHound Code](https://www.bithound.io/github/pushrocks/smartstream/badges/code.svg)](https://www.bithound.io/github/pushrocks/smartstream)
+[![TypeScript](https://img.shields.io/badge/TypeScript-2.x-blue.svg)](https://nodejs.org/dist/latest-v6.x/docs/api/)
+[![node](https://img.shields.io/badge/node->=%206.x.x-blue.svg)](https://nodejs.org/dist/latest-v6.x/docs/api/)
+[![JavaScript Style Guide](https://img.shields.io/badge/code%20style-standard-brightgreen.svg)](http://standardjs.com/)
 
 ## Usage
 We recommend the use of TypeScript for best in class intellisense support.
 
+```typescript
+import { Smartstream } from 'smartstream'
+import * as gUglify from 'gulp-uglify'
+
+let mySmartstream = new Smartstream([
+    gulp.src(['./file1.js','./file2.js']),
+    gUglify(),
+    gulp.dest('./some/output/path')
+])
+
+mySmartstream.onError((err) => { /* handle error */ }) // handles all errors in stream
+myStream.onCustomEvent('myeventname', (args...) => { /* Do something */ }) // emit an custom event anywhere in your stream
+mySmartstream.run().then(() => {/* do something when stream is finished */})
+```
+

dist/index.d.ts

@@ -1,10 +1,42 @@
+/// <reference types="q" />
+import * as plugins from './smartstream.plugins';
 export interface IErrorFunction {
-    (err: any): number;
+    (err: any): any;
 }
+export interface ICustomEventFunction {
+    (): any;
+}
+export interface ICustomEventObject {
+    eventName: string;
+    eventFunction: ICustomEventFunction;
+}
+/**
+ * class Smartstream handles
+ */
 export declare class Smartstream {
-    streamArray: any[];
+    private streamArray;
-    errorFunction: IErrorFunction;
+    private errorFunction;
+    private customEventObjectArray;
+    private streamStartedDeferred;
+    /**
+     * constructor
+     */
     constructor(streamArrayArg: any[]);
+    /**
+     * attach an error handler to the stream to prevent throwing
+     */
     onError(errorFunctionArg: IErrorFunction): void;
-    run(): any;
+    /**
+     * make something with the stream itself
+     */
+    streamStarted(): plugins.q.Promise<any>;
+    /**
+     * attach listener to custom event
+     */
+    onCustomEvent(eventNameArg: string, eventFunctionArg: ICustomEventFunction): void;
+    /**
+     * run the stream
+     * @returns Promise
+     */
+    run(): plugins.q.Promise<void>;
 }

dist/index.js

@@ -1,21 +1,81 @@
 "use strict";
 const plugins = require("./smartstream.plugins");
+/**
+ * class Smartstream handles
+ */
 class Smartstream {
+    /**
+     * constructor
+     */
     constructor(streamArrayArg) {
         this.streamArray = [];
         this.errorFunction = null;
+        this.customEventObjectArray = [];
+        this.streamStartedDeferred = plugins.q.defer();
         this.streamArray = streamArrayArg;
     }
+    /**
+     * attach an error handler to the stream to prevent throwing
+     */
     onError(errorFunctionArg) {
         this.errorFunction = errorFunctionArg;
     }
-    run() {
+    /**
-        let combinedStream = plugins.streamCombiner2.obj(this.streamArray);
+     * make something with the stream itself
-        if (this.errorFunction !== null) {
+     */
-            combinedStream.on('error', this.errorFunction);
+    streamStarted() {
+        return this.streamStartedDeferred.promise;
     }
-        return combinedStream;
+    /**
+     * attach listener to custom event
+     */
+    onCustomEvent(eventNameArg, eventFunctionArg) {
+        this.customEventObjectArray.push({
+            eventName: eventNameArg,
+            eventFunction: eventFunctionArg
+        });
+    }
+    /**
+     * run the stream
+     * @returns Promise
+     */
+    run() {
+        let done = plugins.q.defer();
+        // clone Array
+        let streamExecutionArray = [];
+        for (let streamItem of this.streamArray) {
+            streamExecutionArray.push(streamItem);
+        }
+        // combine the stream
+        let finalStream = null;
+        let firstIteration = true;
+        for (let stream of streamExecutionArray) {
+            if (firstIteration === true) {
+                finalStream = stream;
+            }
+            if (this.errorFunction !== null) {
+                stream.on('error', this.errorFunction);
+            }
+            for (let customEventObject of this.customEventObjectArray) {
+                stream.on(customEventObject.eventName, customEventObject.eventFunction);
+            }
+            if (!firstIteration) {
+                finalStream = finalStream.pipe(stream);
+            }
+            firstIteration = false;
+        }
+        this.streamStartedDeferred.resolve();
+        finalStream.on('end', function () {
+            done.resolve();
+        });
+        finalStream.on('close', function () {
+            done.resolve();
+        });
+        finalStream.on('finish', function () {
+            done.resolve();
+        });
+        return done.promise;
     }
 }
 exports.Smartstream = Smartstream;
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiaW5kZXguanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi90cy9pbmRleC50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiO0FBQUEsaURBQWdEO0FBTWhEO0lBR0ksWUFBWSxjQUFxQjtRQUZqQyxnQkFBVyxHQUFHLEVBQUUsQ0FBQTtRQUNoQixrQkFBYSxHQUFtQixJQUFJLENBQUE7UUFFaEMsSUFBSSxDQUFDLFdBQVcsR0FBRyxjQUFjLENBQUE7SUFDckMsQ0FBQztJQUNELE9BQU8sQ0FBQyxnQkFBZ0M7UUFDcEMsSUFBSSxDQUFDLGFBQWEsR0FBRyxnQkFBZ0IsQ0FBQTtJQUN6QyxDQUFDO0lBQ0QsR0FBRztRQUNDLElBQUksY0FBYyxHQUFHLE9BQU8sQ0FBQyxlQUFlLENBQUMsR0FBRyxDQUFDLElBQUksQ0FBQyxXQUFXLENBQUMsQ0FBQTtRQUNsRSxFQUFFLENBQUMsQ0FBQyxJQUFJLENBQUMsYUFBYSxLQUFLLElBQUksQ0FBQyxDQUFDLENBQUM7WUFDOUIsY0FBYyxDQUFDLEVBQUUsQ0FBQyxPQUFPLEVBQUUsSUFBSSxDQUFDLGFBQWEsQ0FBQyxDQUFBO1FBQ2xELENBQUM7UUFDRCxNQUFNLENBQUMsY0FBYyxDQUFBO0lBQ3pCLENBQUM7Q0FDSjtBQWhCRCxrQ0FnQkMifQ==
+//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiaW5kZXguanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi90cy9pbmRleC50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiO0FBQUEsaURBQWdEO0FBZWhEOztHQUVHO0FBQ0g7SUFNSTs7T0FFRztJQUNILFlBQVksY0FBcUI7UUFSekIsZ0JBQVcsR0FBRyxFQUFFLENBQUE7UUFDaEIsa0JBQWEsR0FBbUIsSUFBSSxDQUFBO1FBQ3BDLDJCQUFzQixHQUF5QixFQUFFLENBQUE7UUFDakQsMEJBQXFCLEdBQUcsT0FBTyxDQUFDLENBQUMsQ0FBQyxLQUFLLEVBQUUsQ0FBQTtRQU03QyxJQUFJLENBQUMsV0FBVyxHQUFHLGNBQWMsQ0FBQTtJQUNyQyxDQUFDO0lBRUQ7O09BRUc7SUFDSCxPQUFPLENBQUMsZ0JBQWdDO1FBQ3BDLElBQUksQ0FBQyxhQUFhLEdBQUcsZ0JBQWdCLENBQUE7SUFDekMsQ0FBQztJQUVEOztPQUVHO0lBQ0gsYUFBYTtRQUNULE1BQU0sQ0FBQyxJQUFJLENBQUMscUJBQXFCLENBQUMsT0FBTyxDQUFBO0lBQzdDLENBQUM7SUFFRDs7T0FFRztJQUNILGFBQWEsQ0FBQyxZQUFvQixFQUFFLGdCQUFzQztRQUN0RSxJQUFJLENBQUMsc0JBQXNCLENBQUMsSUFBSSxDQUFDO1lBQzdCLFNBQVMsRUFBRSxZQUFZO1lBQ3ZCLGFBQWEsRUFBRSxnQkFBZ0I7U0FDbEMsQ0FBQyxDQUFBO0lBQ04sQ0FBQztJQUVEOzs7T0FHRztJQUNILEdBQUc7UUFDQyxJQUFJLElBQUksR0FBRyxPQUFPLENBQUMsQ0FBQyxDQUFDLEtBQUssRUFBUSxDQUFBO1FBRWxDLGNBQWM7UUFDZCxJQUFJLG9CQUFvQixHQUFHLEVBQUUsQ0FBQTtRQUM3QixHQUFHLENBQUMsQ0FBQyxJQUFJLFVBQVUsSUFBSSxJQUFJLENBQUMsV0FBVyxDQUFDLENBQUMsQ0FBQztZQUFDLG9CQUFvQixDQUFDLElBQUksQ0FBQyxVQUFVLENBQUMsQ0FBQTtRQUFDLENBQUM7UUFFbEYscUJBQXFCO1FBQ3JCLElBQUksV0FBVyxHQUFHLElBQUksQ0FBQTtRQUN0QixJQUFJLGNBQWMsR0FBWSxJQUFJLENBQUE7UUFDbEMsR0FBRyxDQUFDLENBQUMsSUFBSSxNQUFNLElBQUksb0JBQW9CLENBQUMsQ0FBQyxDQUFDO1lBQ3RDLEVBQUUsQ0FBQyxDQUFDLGNBQWMsS0FBSyxJQUFJLENBQUMsQ0FBQyxDQUFDO2dCQUMxQixXQUFXLEdBQUcsTUFBTSxDQUFBO1lBQ3hCLENBQUM7WUFDRCxFQUFFLENBQUMsQ0FBQyxJQUFJLENBQUMsYUFBYSxLQUFLLElBQUksQ0FBQyxDQUFDLENBQUM7Z0JBQzlCLE1BQU0sQ0FBQyxFQUFFLENBQUMsT0FBTyxFQUFFLElBQUksQ0FBQyxhQUFhLENBQUMsQ0FBQTtZQUMxQyxDQUFDO1lBQ0QsR0FBRyxDQUFDLENBQUMsSUFBSSxpQkFBaUIsSUFBSSxJQUFJLENBQUMsc0JBQXNCLENBQUMsQ0FBQyxDQUFDO2dCQUN4RCxNQUFNLENBQUMsRUFBRSxDQUFDLGlCQUFpQixDQUFDLFNBQVMsRUFBRSxpQkFBaUIsQ0FBQyxhQUFhLENBQUMsQ0FBQTtZQUMzRSxDQUFDO1lBQ0QsRUFBRSxDQUFDLENBQUMsQ0FBQyxjQUFjLENBQUMsQ0FBQyxDQUFDO2dCQUNsQixXQUFXLEdBQUcsV0FBVyxDQUFDLElBQUksQ0FBQyxNQUFNLENBQUMsQ0FBQTtZQUMxQyxDQUFDO1lBQ0QsY0FBYyxHQUFHLEtBQUssQ0FBQTtRQUMxQixDQUFDO1FBRUQsSUFBSSxDQUFDLHFCQUFxQixDQUFDLE9BQU8sRUFBRSxDQUFBO1FBRXBDLFdBQVcsQ0FBQyxFQUFFLENBQUMsS0FBSyxFQUFDO1lBQ2pCLElBQUksQ0FBQyxPQUFPLEVBQUUsQ0FBQTtRQUNsQixDQUFDLENBQUMsQ0FBQTtRQUNGLFdBQVcsQ0FBQyxFQUFFLENBQUMsT0FBTyxFQUFDO1lBQ25CLElBQUksQ0FBQyxPQUFPLEVBQUUsQ0FBQTtRQUNsQixDQUFDLENBQUMsQ0FBQTtRQUNGLFdBQVcsQ0FBQyxFQUFFLENBQUMsUUFBUSxFQUFDO1lBQ3BCLElBQUksQ0FBQyxPQUFPLEVBQUUsQ0FBQTtRQUNsQixDQUFDLENBQUMsQ0FBQTtRQUNGLE1BQU0sQ0FBQyxJQUFJLENBQUMsT0FBTyxDQUFBO0lBQ3ZCLENBQUM7Q0FDSjtBQWhGRCxrQ0FnRkMifQ==

dist/smartstream.plugins.d.ts

@@ -1,3 +1,2 @@
 import 'typings-global';
 export import q = require('q');
-export declare let streamCombiner2: any;

dist/smartstream.plugins.js

@@ -1,5 +1,4 @@
 "use strict";
 require("typings-global");
 exports.q = require("q");
-exports.streamCombiner2 = require('stream-combiner2');
+//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoic21hcnRzdHJlYW0ucGx1Z2lucy5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uL3RzL3NtYXJ0c3RyZWFtLnBsdWdpbnMudHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6IjtBQUFBLDBCQUF1QjtBQUN2Qix5QkFBOEIifQ==
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoic21hcnRzdHJlYW0ucGx1Z2lucy5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uL3RzL3NtYXJ0c3RyZWFtLnBsdWdpbnMudHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6IjtBQUFBLDBCQUF1QjtBQUN2Qix5QkFBOEI7QUFDbkIsUUFBQSxlQUFlLEdBQUcsT0FBTyxDQUFDLGtCQUFrQixDQUFDLENBQUEifQ==

package.json

@@ -1,6 +1,6 @@
 {
   "name": "smartstream",
-  "version": "1.0.1",
+  "version": "1.0.4",
   "description": "simplifies access to node streams, TypeScript ready!",
   "main": "dist/index.js",
   "typings": "dist/index.d.ts",
@@ -26,7 +26,6 @@
   "dependencies": {
     "@types/q": "0.x.x",
     "q": "^1.4.1",
-    "stream-combiner2": "^1.1.1",
     "typings-global": "^1.0.14"
   }
 }

test/test.js

@@ -4,12 +4,15 @@ const fs = require("fs");
 const smartstream = require("../dist/index");
 let testSmartstream;
 describe('smartstream', function () {
-    it('should combine a stream', function () {
+    it('should combine a stream', function (done) {
+        this.timeout(5000);
         testSmartstream = new smartstream.Smartstream([
             fs.createReadStream('./test/assets/test.md'),
             fs.createWriteStream('./test/assets/testCopy.md')
         ]);
-        testSmartstream.run();
+        testSmartstream.run().then(() => {
+            done();
         });
     });
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoidGVzdC5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbInRlc3QudHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6IjtBQUFBLHdCQUFxQjtBQUNyQix5QkFBeUI7QUFHekIsNkNBQTRDO0FBRTVDLElBQUksZUFBd0MsQ0FBQTtBQUU1QyxRQUFRLENBQUMsYUFBYSxFQUFFO0lBQ3BCLEVBQUUsQ0FBQyx5QkFBeUIsRUFBRTtRQUMxQixlQUFlLEdBQUcsSUFBSSxXQUFXLENBQUMsV0FBVyxDQUFDO1lBQzFDLEVBQUUsQ0FBQyxnQkFBZ0IsQ0FBQyx1QkFBdUIsQ0FBQztZQUM1QyxFQUFFLENBQUMsaUJBQWlCLENBQUMsMkJBQTJCLENBQUM7U0FDcEQsQ0FBQyxDQUFBO1FBQ0YsZUFBZSxDQUFDLEdBQUcsRUFBRSxDQUFBO0lBQ3pCLENBQUMsQ0FBQyxDQUFBO0FBQ04sQ0FBQyxDQUFDLENBQUEifQ==
+});
+//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoidGVzdC5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbInRlc3QudHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6IjtBQUFBLHdCQUFxQjtBQUNyQix5QkFBeUI7QUFHekIsNkNBQTRDO0FBRTVDLElBQUksZUFBd0MsQ0FBQTtBQUU1QyxRQUFRLENBQUMsYUFBYSxFQUFFO0lBQ3BCLEVBQUUsQ0FBQyx5QkFBeUIsRUFBRSxVQUFTLElBQUk7UUFDdkMsSUFBSSxDQUFDLE9BQU8sQ0FBQyxJQUFJLENBQUMsQ0FBQTtRQUNsQixlQUFlLEdBQUcsSUFBSSxXQUFXLENBQUMsV0FBVyxDQUFDO1lBQzFDLEVBQUUsQ0FBQyxnQkFBZ0IsQ0FBQyx1QkFBdUIsQ0FBQztZQUM1QyxFQUFFLENBQUMsaUJBQWlCLENBQUMsMkJBQTJCLENBQUM7U0FDcEQsQ0FBQyxDQUFBO1FBQ0YsZUFBZSxDQUFDLEdBQUcsRUFBRSxDQUFDLElBQUksQ0FBQztZQUN2QixJQUFJLEVBQUUsQ0FBQTtRQUNWLENBQUMsQ0FBQyxDQUFBO0lBQ04sQ0FBQyxDQUFDLENBQUE7QUFDTixDQUFDLENBQUMsQ0FBQSJ9

test/test.ts

@@ -7,11 +7,14 @@ import * as smartstream from '../dist/index'
 let testSmartstream: smartstream.Smartstream
 
 describe('smartstream', function() {
-    it('should combine a stream', function(){
+    it('should combine a stream', function(done){
+        this.timeout(5000)
         testSmartstream = new smartstream.Smartstream([
             fs.createReadStream('./test/assets/test.md'),
             fs.createWriteStream('./test/assets/testCopy.md')
         ])
-        testSmartstream.run()
+        testSmartstream.run().then(() => {
+            done()
+        })
     })
 })

ts/index.ts

@@ -1,23 +1,99 @@
 import * as plugins from './smartstream.plugins'
 
 export interface IErrorFunction {
-    (err): number
+    (err): any
 }
 
+export interface ICustomEventFunction {
+    (): any
+}
+
+export interface ICustomEventObject {
+    eventName: string
+    eventFunction: ICustomEventFunction
+}
+
+/**
+ * class Smartstream handles 
+ */
 export class Smartstream {
-    streamArray = []
+    private streamArray = []
-    errorFunction: IErrorFunction = null
+    private errorFunction: IErrorFunction = null
+    private customEventObjectArray: ICustomEventObject[] = []
+    private streamStartedDeferred = plugins.q.defer()
+
+    /**
+     * constructor
+     */
     constructor(streamArrayArg: any[]) {
         this.streamArray = streamArrayArg
     }
+
+    /**
+     * attach an error handler to the stream to prevent throwing
+     */
     onError(errorFunctionArg: IErrorFunction) {
         this.errorFunction = errorFunctionArg
     }
-    run() {
+
-        let combinedStream = plugins.streamCombiner2.obj(this.streamArray)
+    /**
+     * make something with the stream itself
+     */
+    streamStarted(): plugins.q.Promise<any> {
+        return this.streamStartedDeferred.promise
+    }
+
+    /**
+     * attach listener to custom event
+     */
+    onCustomEvent(eventNameArg: string, eventFunctionArg: ICustomEventFunction) {
+        this.customEventObjectArray.push({
+            eventName: eventNameArg,
+            eventFunction: eventFunctionArg
+        })
+    }
+
+    /**
+     * run the stream
+     * @returns Promise
+     */
+    run(): plugins.q.Promise<void> {
+        let done = plugins.q.defer<void>()
+
+        // clone Array
+        let streamExecutionArray = []
+        for (let streamItem of this.streamArray) { streamExecutionArray.push(streamItem) }
+
+        // combine the stream
+        let finalStream = null
+        let firstIteration: boolean = true
+        for (let stream of streamExecutionArray) {
+            if (firstIteration === true) {
+                finalStream = stream
+            }
             if (this.errorFunction !== null) {
-            combinedStream.on('error', this.errorFunction)
+                stream.on('error', this.errorFunction)
             }
-        return combinedStream
+            for (let customEventObject of this.customEventObjectArray) {
+                stream.on(customEventObject.eventName, customEventObject.eventFunction)
+            }
+            if (!firstIteration) {
+                finalStream = finalStream.pipe(stream)
+            }
+            firstIteration = false
+        }
+    
+        this.streamStartedDeferred.resolve()
+
+        finalStream.on('end',function(){
+            done.resolve()
+        })
+        finalStream.on('close',function(){
+            done.resolve()
+        })
+        finalStream.on('finish',function(){
+            done.resolve()
+        })
+        return done.promise
     }
 }

ts/smartstream.plugins.ts

@@ -1,3 +1,2 @@
 import 'typings-global'
 export import q = require('q')
-export let streamCombiner2 = require('stream-combiner2')