1.0.4

dist/index.d.ts

@@ -1,8 +1,2 @@
-export interface IExecResult {
-    exitCode: number;
-    stdout: string;
-}
-export declare let exec: (commandStringArg: string) => Promise<IExecResult>;
-export declare let execSilent: (commandStringArg: string) => Promise<IExecResult>;
-export declare let execSync: () => void;
-export declare let execSyncSilent: () => void;
+export * from './smartshell.wrap';
+export * from './smartshell.classes.smartshell';

dist/index.js

@@ -1,24 +1,8 @@
 "use strict";
+function __export(m) {
+    for (var p in m) if (!exports.hasOwnProperty(p)) exports[p] = m[p];
+}
 Object.defineProperty(exports, "__esModule", { value: true });
-const plugins = require("./smartshell.plugins");
-exports.exec = (commandStringArg) => {
-    let done = plugins.smartq.defer();
-    plugins.shelljs.exec(commandStringArg, { async: true }, (code, stdout, stderr) => {
-        done.resolve({
-            exitCode: code,
-            stdout: stdout
-        });
-    });
-    return done.promise;
-};
-exports.execSilent = (commandStringArg) => {
-    let done = plugins.smartq.defer();
-    plugins.shelljs.exec(commandStringArg, {}, () => {
-    });
-    return done.promise;
-};
-exports.execSync = () => {
-};
-exports.execSyncSilent = () => {
-};
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiaW5kZXguanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi90cy9pbmRleC50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiOztBQUFBLGdEQUErQztBQVNwQyxRQUFBLElBQUksR0FBRyxDQUFDLGdCQUF3QjtJQUN6QyxJQUFJLElBQUksR0FBRyxPQUFPLENBQUMsTUFBTSxDQUFDLEtBQUssRUFBZSxDQUFBO0lBQzlDLE9BQU8sQ0FBQyxPQUFPLENBQUMsSUFBSSxDQUFDLGdCQUFnQixFQUFDLEVBQUMsS0FBSyxFQUFFLElBQUksRUFBQyxFQUFFLENBQUMsSUFBSSxFQUFFLE1BQU0sRUFBRSxNQUFNO1FBQ3hFLElBQUksQ0FBQyxPQUFPLENBQUM7WUFDWCxRQUFRLEVBQUUsSUFBSTtZQUNkLE1BQU0sRUFBRSxNQUFNO1NBQ2YsQ0FBQyxDQUFBO0lBQ0osQ0FBQyxDQUFDLENBQUE7SUFDRixNQUFNLENBQUMsSUFBSSxDQUFDLE9BQU8sQ0FBQTtBQUNyQixDQUFDLENBQUE7QUFFVSxRQUFBLFVBQVUsR0FBRyxDQUFDLGdCQUF3QjtJQUMvQyxJQUFJLElBQUksR0FBRyxPQUFPLENBQUMsTUFBTSxDQUFDLEtBQUssRUFBZSxDQUFBO0lBQzlDLE9BQU8sQ0FBQyxPQUFPLENBQUMsSUFBSSxDQUFDLGdCQUFnQixFQUFDLEVBQUUsRUFBRTtJQUUxQyxDQUFDLENBQUMsQ0FBQTtJQUNGLE1BQU0sQ0FBQyxJQUFJLENBQUMsT0FBTyxDQUFBO0FBQ3JCLENBQUMsQ0FBQTtBQUVVLFFBQUEsUUFBUSxHQUFHO0FBRXRCLENBQUMsQ0FBQTtBQUVVLFFBQUEsY0FBYyxHQUFHO0FBRTVCLENBQUMsQ0FBQSJ9
+__export(require("./smartshell.wrap"));
+__export(require("./smartshell.classes.smartshell"));
+//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiaW5kZXguanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi90cy9pbmRleC50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiOzs7OztBQUFBLHVDQUFpQztBQUNqQyxxREFBK0MifQ==

dist/smartshell.classes.smartshell.d.ts

@@ -0,0 +1,28 @@
+import * as smartshellWrap from './smartshell.wrap';
+export declare type TExecutor = 'sh' | 'bash';
+export interface ISmartshellContructorOptions {
+    executor: TExecutor;
+    sourceFilePaths: string[];
+}
+export declare class Smartshell {
+    executor: TExecutor;
+    sourceFileArray: string[];
+    constructor(optionsArg: ISmartshellContructorOptions);
+    addSourceFiles(sourceFilePathsArray: string[]): void;
+    cleanSourceFiles(): void;
+    /**
+     * executes silently and returns IExecResult
+     * @param commandArg
+     */
+    execSilent(commandArg: string): Promise<smartshellWrap.IExecResult>;
+    /**
+     * executes and returns IExecResult
+     * @param commandArg
+     */
+    exec(commandArg: string): Promise<smartshellWrap.IExecResult>;
+    /**
+     * creates the final sourcing string
+     * @param commandArg
+     */
+    private createExecString(commandArg);
+}

dist/smartshell.classes.smartshell.js

@@ -0,0 +1,66 @@
+"use strict";
+var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
+    return new (P || (P = Promise))(function (resolve, reject) {
+        function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
+        function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
+        function step(result) { result.done ? resolve(result.value) : new P(function (resolve) { resolve(result.value); }).then(fulfilled, rejected); }
+        step((generator = generator.apply(thisArg, _arguments || [])).next());
+    });
+};
+Object.defineProperty(exports, "__esModule", { value: true });
+const smartshellWrap = require("./smartshell.wrap");
+class Smartshell {
+    constructor(optionsArg) {
+        this.sourceFileArray = [];
+        this.executor = optionsArg.executor;
+        for (let sourceFilePath of optionsArg.sourceFilePaths) {
+            this.sourceFileArray.push(sourceFilePath);
+        }
+    }
+    addSourceFiles(sourceFilePathsArray) {
+        for (let sourceFilePath of sourceFilePathsArray) {
+            this.sourceFileArray.push(sourceFilePath);
+        }
+    }
+    cleanSourceFiles() {
+        this.sourceFileArray = [];
+    }
+    /**
+     * executes silently and returns IExecResult
+     * @param commandArg
+     */
+    execSilent(commandArg) {
+        return __awaiter(this, void 0, void 0, function* () {
+            let execCommand = this.createExecString(commandArg);
+            return yield smartshellWrap.execSilent(commandArg);
+        });
+    }
+    /**
+     * executes and returns IExecResult
+     * @param commandArg
+     */
+    exec(commandArg) {
+        return __awaiter(this, void 0, void 0, function* () {
+            let execCommand = this.createExecString(commandArg);
+            return yield smartshellWrap.exec(commandArg);
+        });
+    }
+    /**
+     * creates the final sourcing string
+     * @param commandArg
+     */
+    createExecString(commandArg) {
+        if (this.executor === 'bash') {
+            let sourceString = '';
+            for (let sourceFilePath of this.sourceFileArray) {
+                sourceString = sourceString + `source ${sourceFilePath} && `;
+            }
+            return `bash -c '${sourceString} ${commandArg}'`;
+        }
+        else {
+            return commandArg;
+        }
+    }
+}
+exports.Smartshell = Smartshell;
+//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoic21hcnRzaGVsbC5jbGFzc2VzLnNtYXJ0c2hlbGwuanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi90cy9zbWFydHNoZWxsLmNsYXNzZXMuc21hcnRzaGVsbC50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiOzs7Ozs7Ozs7O0FBQ0Esb0RBQW1EO0FBVW5EO0lBR0UsWUFBYSxVQUF3QztRQURyRCxvQkFBZSxHQUFhLEVBQUUsQ0FBQTtRQUU1QixJQUFJLENBQUMsUUFBUSxHQUFHLFVBQVUsQ0FBQyxRQUFRLENBQUE7UUFDbkMsR0FBRyxDQUFDLENBQUMsSUFBSSxjQUFjLElBQUksVUFBVSxDQUFDLGVBQWUsQ0FBQyxDQUFDLENBQUM7WUFDdEQsSUFBSSxDQUFDLGVBQWUsQ0FBQyxJQUFJLENBQUMsY0FBYyxDQUFDLENBQUE7UUFDM0MsQ0FBQztJQUNILENBQUM7SUFFRCxjQUFjLENBQUMsb0JBQThCO1FBQzNDLEdBQUcsQ0FBQSxDQUFDLElBQUksY0FBYyxJQUFJLG9CQUFvQixDQUFDLENBQUMsQ0FBQztZQUMvQyxJQUFJLENBQUMsZUFBZSxDQUFDLElBQUksQ0FBQyxjQUFjLENBQUMsQ0FBQTtRQUMzQyxDQUFDO0lBQ0gsQ0FBQztJQUVELGdCQUFnQjtRQUNkLElBQUksQ0FBQyxlQUFlLEdBQUcsRUFBRSxDQUFBO0lBQzNCLENBQUM7SUFFRDs7O09BR0c7SUFDRyxVQUFVLENBQUUsVUFBa0I7O1lBQ2xDLElBQUksV0FBVyxHQUFHLElBQUksQ0FBQyxnQkFBZ0IsQ0FBQyxVQUFVLENBQUMsQ0FBQTtZQUNuRCxNQUFNLENBQUMsTUFBTSxjQUFjLENBQUMsVUFBVSxDQUFDLFVBQVUsQ0FBQyxDQUFBO1FBQ3BELENBQUM7S0FBQTtJQUVEOzs7T0FHRztJQUNHLElBQUksQ0FBRSxVQUFrQjs7WUFDNUIsSUFBSSxXQUFXLEdBQUcsSUFBSSxDQUFDLGdCQUFnQixDQUFDLFVBQVUsQ0FBQyxDQUFBO1lBQ25ELE1BQU0sQ0FBQyxNQUFNLGNBQWMsQ0FBQyxJQUFJLENBQUMsVUFBVSxDQUFDLENBQUE7UUFDOUMsQ0FBQztLQUFBO0lBRUQ7OztPQUdHO0lBQ0ssZ0JBQWdCLENBQUUsVUFBVTtRQUNsQyxFQUFFLENBQUMsQ0FBQyxJQUFJLENBQUMsUUFBUSxLQUFLLE1BQU0sQ0FBQyxDQUFDLENBQUM7WUFDN0IsSUFBSSxZQUFZLEdBQUcsRUFBRSxDQUFBO1lBQ3JCLEdBQUcsQ0FBQyxDQUFDLElBQUksY0FBYyxJQUFJLElBQUksQ0FBQyxlQUFlLENBQUMsQ0FBQyxDQUFDO2dCQUNoRCxZQUFZLEdBQUcsWUFBWSxHQUFHLFVBQVUsY0FBYyxNQUFNLENBQUE7WUFDOUQsQ0FBQztZQUNELE1BQU0sQ0FBQyxZQUFZLFlBQVksSUFBSSxVQUFVLEdBQUcsQ0FBQTtRQUNsRCxDQUFDO1FBQUMsSUFBSSxDQUFDLENBQUM7WUFDTixNQUFNLENBQUMsVUFBVSxDQUFBO1FBQ25CLENBQUM7SUFDSCxDQUFDO0NBQ0Y7QUFyREQsZ0NBcURDIn0=

dist/smartshell.wrap.d.ts

@@ -0,0 +1,27 @@
+/// <reference types="node" />
+import { ChildProcess } from 'child_process';
+export interface IExecResult {
+    exitCode: number;
+    stdout: string;
+}
+export interface IExecResultStreaming {
+    childProcess: ChildProcess;
+    finalPromise: Promise<IExecResult>;
+}
+/**
+ * executes a given command async
+ * @param commandStringArg
+ */
+export declare let exec: (commandStringArg: string) => Promise<IExecResult>;
+/**
+ * executes a given command async and silent
+ * @param commandStringArg
+ */
+export declare let execSilent: (commandStringArg: string) => Promise<IExecResult>;
+/**
+ * executes a command and allws you to stream output
+ */
+export declare let execStreaming: (commandStringArg: string) => {
+    childProcess: ChildProcess;
+    finalPromise: Promise<IExecResult>;
+};

dist/smartshell.wrap.js

@@ -0,0 +1,48 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+const plugins = require("./smartshell.plugins");
+/**
+ * executes a given command async
+ * @param commandStringArg
+ */
+exports.exec = (commandStringArg) => {
+    let done = plugins.smartq.defer();
+    plugins.shelljs.exec(commandStringArg, { async: true }, (code, stdout, stderr) => {
+        done.resolve({
+            exitCode: code,
+            stdout: stdout
+        });
+    });
+    return done.promise;
+};
+/**
+ * executes a given command async and silent
+ * @param commandStringArg
+ */
+exports.execSilent = (commandStringArg) => {
+    let done = plugins.smartq.defer();
+    plugins.shelljs.exec(commandStringArg, { async: true, silent: true }, (code, stdout, stderr) => {
+        done.resolve({
+            exitCode: code,
+            stdout: stdout
+        });
+    });
+    return done.promise;
+};
+/**
+ * executes a command and allws you to stream output
+ */
+exports.execStreaming = (commandStringArg) => {
+    let childProcessEnded = plugins.smartq.defer();
+    let execChildProcess = plugins.shelljs.exec(commandStringArg, { async: true, silent: true }, (code, stdout, stderr) => {
+        childProcessEnded.resolve({
+            exitCode: code,
+            stdout: stdout
+        });
+    });
+    return {
+        childProcess: execChildProcess,
+        finalPromise: childProcessEnded.promise
+    };
+};
+//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoic21hcnRzaGVsbC53cmFwLmpzIiwic291cmNlUm9vdCI6IiIsInNvdXJjZXMiOlsiLi4vdHMvc21hcnRzaGVsbC53cmFwLnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiI7O0FBQUEsZ0RBQStDO0FBZ0IvQzs7O0dBR0c7QUFDUSxRQUFBLElBQUksR0FBRyxDQUFDLGdCQUF3QjtJQUN6QyxJQUFJLElBQUksR0FBRyxPQUFPLENBQUMsTUFBTSxDQUFDLEtBQUssRUFBZSxDQUFBO0lBQzlDLE9BQU8sQ0FBQyxPQUFPLENBQUMsSUFBSSxDQUFDLGdCQUFnQixFQUFFLEVBQUUsS0FBSyxFQUFFLElBQUksRUFBRSxFQUFFLENBQUMsSUFBSSxFQUFFLE1BQU0sRUFBRSxNQUFNO1FBQzNFLElBQUksQ0FBQyxPQUFPLENBQUM7WUFDWCxRQUFRLEVBQUUsSUFBSTtZQUNkLE1BQU0sRUFBRSxNQUFNO1NBQ2YsQ0FBQyxDQUFBO0lBQ0osQ0FBQyxDQUFDLENBQUE7SUFDRixNQUFNLENBQUMsSUFBSSxDQUFDLE9BQU8sQ0FBQTtBQUNyQixDQUFDLENBQUE7QUFFRDs7O0dBR0c7QUFDUSxRQUFBLFVBQVUsR0FBRyxDQUFDLGdCQUF3QjtJQUMvQyxJQUFJLElBQUksR0FBRyxPQUFPLENBQUMsTUFBTSxDQUFDLEtBQUssRUFBZSxDQUFBO0lBQzlDLE9BQU8sQ0FBQyxPQUFPLENBQUMsSUFBSSxDQUFDLGdCQUFnQixFQUFFLEVBQUUsS0FBSyxFQUFFLElBQUksRUFBRSxNQUFNLEVBQUUsSUFBSSxFQUFFLEVBQUUsQ0FBQyxJQUFJLEVBQUUsTUFBTSxFQUFFLE1BQU07UUFDekYsSUFBSSxDQUFDLE9BQU8sQ0FBQztZQUNYLFFBQVEsRUFBRSxJQUFJO1lBQ2QsTUFBTSxFQUFFLE1BQU07U0FDZixDQUFDLENBQUE7SUFDSixDQUFDLENBQUMsQ0FBQTtJQUNGLE1BQU0sQ0FBQyxJQUFJLENBQUMsT0FBTyxDQUFBO0FBQ3JCLENBQUMsQ0FBQTtBQUVEOztHQUVHO0FBQ1EsUUFBQSxhQUFhLEdBQUcsQ0FBQyxnQkFBd0I7SUFDbEQsSUFBSSxpQkFBaUIsR0FBRyxPQUFPLENBQUMsTUFBTSxDQUFDLEtBQUssRUFBZSxDQUFBO0lBQzNELElBQUksZ0JBQWdCLEdBQUcsT0FBTyxDQUFDLE9BQU8sQ0FBQyxJQUFJLENBQUMsZ0JBQWdCLEVBQUUsRUFBQyxLQUFLLEVBQUUsSUFBSSxFQUFFLE1BQU0sRUFBRSxJQUFJLEVBQUMsRUFBRSxDQUFDLElBQUksRUFBRSxNQUFNLEVBQUUsTUFBTTtRQUM5RyxpQkFBaUIsQ0FBQyxPQUFPLENBQUM7WUFDeEIsUUFBUSxFQUFFLElBQUk7WUFDZCxNQUFNLEVBQUUsTUFBTTtTQUNmLENBQUMsQ0FBQTtJQUNKLENBQUMsQ0FBQyxDQUFBO0lBQ0YsTUFBTSxDQUFDO1FBQ0wsWUFBWSxFQUFFLGdCQUFnQjtRQUM5QixZQUFZLEVBQUUsaUJBQWlCLENBQUMsT0FBTztLQUN4QyxDQUFBO0FBQ0gsQ0FBQyxDQUFBIn0=

package.json

@@ -1,6 +1,6 @@
 {
   "name": "smartshell",
-  "version": "1.0.1",
+  "version": "1.0.4",
   "description": "shell actions designed as promises",
   "main": "dist/index.js",
   "typings": "dist/index.d.ts",

test/test.js

@@ -1,13 +1,47 @@
 "use strict";
+var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
+    return new (P || (P = Promise))(function (resolve, reject) {
+        function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
+        function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
+        function step(result) { result.done ? resolve(result.value) : new P(function (resolve) { resolve(result.value); }).then(fulfilled, rejected); }
+        step((generator = generator.apply(thisArg, _arguments || [])).next());
+    });
+};
 Object.defineProperty(exports, "__esModule", { value: true });
 require("typings-test");
+const smartchai_1 = require("smartchai");
 const smartshell = require("../dist/index");
+let testSmartshell;
 describe('smartshell', function () {
     it('it should run async', function () {
         this.timeout(1000000);
-        return smartshell.exec('npmdocker speedtest').then((execResult) => {
-            console.log(execResult.stdout);
+        return smartshell.exec('npm -v').then((execResult) => {
+            smartchai_1.expect(execResult.stdout).to.match(/[0-9\.]*/);
         });
     });
+    it('should run async and silent', function () {
+        return smartshell.execSilent('npm -v').then((execResult) => {
+            smartchai_1.expect(execResult.stdout).to.match(/[0-9\.]*/);
+        });
+    });
+    it('should stream a shell execution', function () {
+        let execStreamingResponse = smartshell.execStreaming('npm -v');
+        execStreamingResponse.childProcess.stdout.on('data', (data) => {
+            console.log('Received ' + data);
+        });
+        return execStreamingResponse.finalPromise;
+    });
+    it('should create a Smartshell instance', function () {
+        testSmartshell = new smartshell.Smartshell({
+            executor: 'bash',
+            sourceFilePaths: []
+        });
+        smartchai_1.expect(testSmartshell).to.be.instanceof(smartshell.Smartshell);
+    });
+    it('should run async', function () {
+        return testSmartshell.execSilent('sleep 1 && npm -v').then((execResult) => __awaiter(this, void 0, void 0, function* () {
+            console.log(execResult.stdout);
+        }));
+    });
 });
-//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoidGVzdC5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbInRlc3QudHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6Ijs7QUFBQSx3QkFBcUI7QUFHckIsNENBQTJDO0FBRTNDLFFBQVEsQ0FBQyxZQUFZLEVBQUU7SUFDbkIsRUFBRSxDQUFDLHFCQUFxQixFQUFFO1FBQ3RCLElBQUksQ0FBQyxPQUFPLENBQUMsT0FBTyxDQUFDLENBQUE7UUFDckIsTUFBTSxDQUFDLFVBQVUsQ0FBQyxJQUFJLENBQUMscUJBQXFCLENBQUMsQ0FBQyxJQUFJLENBQUMsQ0FBQyxVQUFVO1lBQzFELE9BQU8sQ0FBQyxHQUFHLENBQUMsVUFBVSxDQUFDLE1BQU0sQ0FBQyxDQUFBO1FBQ2xDLENBQUMsQ0FBQyxDQUFBO0lBQ04sQ0FBQyxDQUFDLENBQUE7QUFDTixDQUFDLENBQUMsQ0FBQSJ9
+//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoidGVzdC5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbInRlc3QudHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6Ijs7Ozs7Ozs7OztBQUFBLHdCQUFxQjtBQUNyQix5Q0FBa0M7QUFFbEMsNENBQTJDO0FBRTNDLElBQUksY0FBcUMsQ0FBQTtBQUV6QyxRQUFRLENBQUMsWUFBWSxFQUFFO0lBQ3JCLEVBQUUsQ0FBQyxxQkFBcUIsRUFBRTtRQUN4QixJQUFJLENBQUMsT0FBTyxDQUFDLE9BQU8sQ0FBQyxDQUFBO1FBQ3JCLE1BQU0sQ0FBQyxVQUFVLENBQUMsSUFBSSxDQUFDLFFBQVEsQ0FBQyxDQUFDLElBQUksQ0FBQyxDQUFDLFVBQVU7WUFDL0Msa0JBQU0sQ0FBQyxVQUFVLENBQUMsTUFBTSxDQUFDLENBQUMsRUFBRSxDQUFDLEtBQUssQ0FBQyxVQUFVLENBQUMsQ0FBQTtRQUNoRCxDQUFDLENBQUMsQ0FBQTtJQUNKLENBQUMsQ0FBQyxDQUFBO0lBQ0YsRUFBRSxDQUFDLDZCQUE2QixFQUFFO1FBQ2hDLE1BQU0sQ0FBQyxVQUFVLENBQUMsVUFBVSxDQUFDLFFBQVEsQ0FBQyxDQUFDLElBQUksQ0FBQyxDQUFDLFVBQVU7WUFDckQsa0JBQU0sQ0FBQyxVQUFVLENBQUMsTUFBTSxDQUFDLENBQUMsRUFBRSxDQUFDLEtBQUssQ0FBQyxVQUFVLENBQUMsQ0FBQTtRQUNoRCxDQUFDLENBQUMsQ0FBQTtJQUNKLENBQUMsQ0FBQyxDQUFBO0lBQ0YsRUFBRSxDQUFDLGlDQUFpQyxFQUFFO1FBQ3BDLElBQUkscUJBQXFCLEdBQUcsVUFBVSxDQUFDLGFBQWEsQ0FBQyxRQUFRLENBQUMsQ0FBQTtRQUM5RCxxQkFBcUIsQ0FBQyxZQUFZLENBQUMsTUFBTSxDQUFDLEVBQUUsQ0FBQyxNQUFNLEVBQUUsQ0FBQyxJQUFJO1lBQ3hELE9BQU8sQ0FBQyxHQUFHLENBQUMsV0FBVyxHQUFHLElBQUksQ0FBQyxDQUFBO1FBQ2pDLENBQUMsQ0FBQyxDQUFBO1FBQ0YsTUFBTSxDQUFDLHFCQUFxQixDQUFDLFlBQVksQ0FBQTtJQUMzQyxDQUFDLENBQUMsQ0FBQTtJQUNGLEVBQUUsQ0FBQyxxQ0FBcUMsRUFBRTtRQUN4QyxjQUFjLEdBQUcsSUFBSSxVQUFVLENBQUMsVUFBVSxDQUFDO1lBQ3pDLFFBQVEsRUFBRSxNQUFNO1lBQ2hCLGVBQWUsRUFBRSxFQUFFO1NBQ3BCLENBQUMsQ0FBQTtRQUNGLGtCQUFNLENBQUMsY0FBYyxDQUFDLENBQUMsRUFBRSxDQUFDLEVBQUUsQ0FBQyxVQUFVLENBQUMsVUFBVSxDQUFDLFVBQVUsQ0FBQyxDQUFBO0lBQ2hFLENBQUMsQ0FBQyxDQUFBO0lBRUYsRUFBRSxDQUFDLGtCQUFrQixFQUFFO1FBQ3JCLE1BQU0sQ0FBQyxjQUFjLENBQUMsVUFBVSxDQUFDLG1CQUFtQixDQUFDLENBQUMsSUFBSSxDQUFDLENBQU8sVUFBVTtZQUMxRSxPQUFPLENBQUMsR0FBRyxDQUFDLFVBQVUsQ0FBQyxNQUFNLENBQUMsQ0FBQTtRQUNoQyxDQUFDLENBQUEsQ0FBQyxDQUFBO0lBQ0osQ0FBQyxDQUFDLENBQUE7QUFDSixDQUFDLENBQUMsQ0FBQSJ9

test/test.ts

@@ -3,11 +3,38 @@ import { expect } from 'smartchai'
 
 import * as smartshell from '../dist/index'
 
-describe('smartshell', function() {
-    it('it should run async', function() {
-        this.timeout(1000000)
-        return smartshell.exec('npmdocker speedtest').then((execResult) => {
-            console.log(execResult.stdout)
-        })
+let testSmartshell: smartshell.Smartshell
+
+describe('smartshell', function () {
+  it('it should run async', function () {
+    this.timeout(1000000)
+    return smartshell.exec('npm -v').then((execResult) => {
+      expect(execResult.stdout).to.match(/[0-9\.]*/)
     })
-})
+  })
+  it('should run async and silent', function () {
+    return smartshell.execSilent('npm -v').then((execResult) => {
+      expect(execResult.stdout).to.match(/[0-9\.]*/)
+    })
+  })
+  it('should stream a shell execution', function () {
+    let execStreamingResponse = smartshell.execStreaming('npm -v')
+    execStreamingResponse.childProcess.stdout.on('data', (data) => {
+      console.log('Received ' + data)
+    })
+    return execStreamingResponse.finalPromise
+  })
+  it('should create a Smartshell instance', function () {
+    testSmartshell = new smartshell.Smartshell({
+      executor: 'bash',
+      sourceFilePaths: []
+    })
+    expect(testSmartshell).to.be.instanceof(smartshell.Smartshell)
+  })
+
+  it('should run async', function () {
+    return testSmartshell.execSilent('sleep 1 && npm -v').then(async (execResult) => {
+      console.log(execResult.stdout)
+    })
+  })
+})

ts/index.ts

@@ -1 +1,2 @@
 export * from './smartshell.wrap'
+export * from './smartshell.classes.smartshell'

ts/smartshell.classes.smartshell.ts

@@ -4,13 +4,62 @@ import * as smartshellWrap from './smartshell.wrap'
 export type TExecutor = 'sh' | 'bash'
 
 export interface ISmartshellContructorOptions {
-    executor: TExecutor
-    sourceFiles: string[]
+  executor: TExecutor
+  sourceFilePaths: string[]
 
 }
 
 export class Smartshell {
-    constructor() {
-        
+  executor: TExecutor
+  sourceFileArray: string[] = []
+  constructor (optionsArg: ISmartshellContructorOptions) {
+    this.executor = optionsArg.executor
+    for (let sourceFilePath of optionsArg.sourceFilePaths) {
+      this.sourceFileArray.push(sourceFilePath)
     }
-}
+  }
+
+  addSourceFiles(sourceFilePathsArray: string[]) {
+    for(let sourceFilePath of sourceFilePathsArray) {
+      this.sourceFileArray.push(sourceFilePath)
+    }
+  }
+
+  cleanSourceFiles () {
+    this.sourceFileArray = []
+  }
+
+  /**
+   * executes silently and returns IExecResult
+   * @param commandArg
+   */
+  async execSilent (commandArg: string) {
+    let execCommand = this.createExecString(commandArg)
+    return await smartshellWrap.execSilent(commandArg)
+  }
+
+  /**
+   * executes and returns IExecResult
+   * @param commandArg
+   */
+  async exec (commandArg: string) {
+    let execCommand = this.createExecString(commandArg)
+    return await smartshellWrap.exec(commandArg)
+  }
+
+  /**
+   * creates the final sourcing string
+   * @param commandArg
+   */
+  private createExecString (commandArg): string {
+    if (this.executor === 'bash') {
+      let sourceString = ''
+      for (let sourceFilePath of this.sourceFileArray) {
+        sourceString = sourceString + `source ${sourceFilePath} && `
+      }
+      return `bash -c '${sourceString} ${commandArg}'`
+    } else {
+      return commandArg
+    }
+  }
+}

ts/smartshell.wrap.ts

@@ -1,13 +1,26 @@
 import * as plugins from './smartshell.plugins'
 
+// interfaces
+import { ChildProcess } from 'child_process'
+import { Deferred } from 'smartq'
+
 export interface IExecResult {
   exitCode: number,
   stdout: string
 }
 
+export interface IExecResultStreaming {
+  childProcess: ChildProcess,
+  finalPromise: Promise<IExecResult>
+}
+
+/**
+ * executes a given command async
+ * @param commandStringArg
+ */
 export let exec = (commandStringArg: string): Promise<IExecResult> => {
   let done = plugins.smartq.defer<IExecResult>()
-  plugins.shelljs.exec(commandStringArg,{async: true}, (code, stdout, stderr) => {
+  plugins.shelljs.exec(commandStringArg, { async: true }, (code, stdout, stderr) => {
     done.resolve({
       exitCode: code,
       stdout: stdout
@@ -16,9 +29,13 @@ export let exec = (commandStringArg: string): Promise<IExecResult> => {
   return done.promise
 }
 
+/**
+ * executes a given command async and silent
+ * @param commandStringArg
+ */
 export let execSilent = (commandStringArg: string) => {
   let done = plugins.smartq.defer<IExecResult>()
-  plugins.shelljs.exec(commandStringArg,{async: true, silent: true}, (code, stdout, stderr) => {
+  plugins.shelljs.exec(commandStringArg, { async: true, silent: true }, (code, stdout, stderr) => {
     done.resolve({
       exitCode: code,
       stdout: stdout
@@ -26,3 +43,20 @@ export let execSilent = (commandStringArg: string) => {
   })
   return done.promise
 }
+
+/**
+ * executes a command and allws you to stream output
+ */
+export let execStreaming = (commandStringArg: string) => {
+  let childProcessEnded = plugins.smartq.defer<IExecResult>()
+  let execChildProcess = plugins.shelljs.exec(commandStringArg, {async: true, silent: true}, (code, stdout, stderr) => {
+    childProcessEnded.resolve({
+      exitCode: code,
+      stdout: stdout
+    })
+  })
+  return {
+    childProcess: execChildProcess,
+    finalPromise: childProcessEnded.promise
+  }
+}

tslint.json

@@ -0,0 +1,3 @@
+{
+    "extends": "tslint-config-standard"
+}