Initial Commit; shell utils: exec/spawn

.gitignore

@@ -0,0 +1,2 @@
+node_modules
+package-lock.json

.prettierrc.js

@@ -0,0 +1,7 @@
+module.exports = {
+  jsxSingleQuote: true,
+  singleQuote: true,
+  printWidth: 150,
+  tabWidth: 2,
+  trailingComma: 'none'
+};

.vscode/settings.json

@@ -0,0 +1,4 @@
+{
+    "editor.formatOnSave": true,
+    "editor.defaultFormatter": "esbenp.prettier-vscode"
+}

index.d.ts

@@ -0,0 +1,3 @@
+export declare namespace NodeUtils {
+}
+//# sourceMappingURL=index.d.ts.map

index.d.ts.map

@@ -0,0 +1 @@
+{"version":3,"file":"index.d.ts","sourceRoot":"","sources":["index.ts"],"names":[],"mappings":"AAEA,yBAAiB,SAAS,CAAC;CAG1B"}

index.js

@@ -0,0 +1,10 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.NodeUtils = void 0;
+var shell_1 = require("./shell");
+var NodeUtils;
+(function (NodeUtils) {
+    shell_1.exec;
+    shell_1.spawn;
+})(NodeUtils = exports.NodeUtils || (exports.NodeUtils = {}));
+//# sourceMappingURL=index.js.map

index.js.map

@@ -0,0 +1 @@
+{"version":3,"file":"index.js","sourceRoot":"","sources":["index.ts"],"names":[],"mappings":";;;AAAA,iCAAsC;AAEtC,IAAiB,SAAS,CAGzB;AAHD,WAAiB,SAAS;IACtB,YAAI,CAAC;IACL,aAAK,CAAC;AACV,CAAC,EAHgB,SAAS,GAAT,iBAAS,KAAT,iBAAS,QAGzB"}

index.ts

@@ -0,0 +1,6 @@
+import { exec, spawn } from './shell';
+
+export namespace NodeUtils {
+    exec;
+    spawn;
+}

package.json

@@ -0,0 +1,19 @@
+{
+  "name": "node-utils",
+  "version": "1.0.0",
+  "description": "Shared common library for JavaScript in NodeJS",
+  "repository": {
+    "type": "git",
+    "url": "https://bitbucket.siriusonline.de/scm/npm/node-utils.git"
+  },
+  "main": "index.js",
+  "scripts": {
+    "build": "tsc"
+  },
+  "author": "Christian Kahlau, sirius-net GmbH",
+  "license": "ISC",
+  "devDependencies": {
+    "@types/node": "^14.14.31",
+    "typescript": "^4.2.2"
+  }
+}

shell/index.d.ts

@@ -0,0 +1,4 @@
+/// <reference types="node" />
+export declare function exec(command: string, stdout: (...args: any[]) => void | NodeJS.WriteStream, stderr: (...args: any[]) => void | NodeJS.WriteStream): Promise<string>;
+export declare function spawn(command: any, args: any, stdout: any, stderr: any): Promise<void>;
+//# sourceMappingURL=index.d.ts.map

shell/index.d.ts.map

@@ -0,0 +1 @@
+{"version":3,"file":"index.d.ts","sourceRoot":"","sources":["index.ts"],"names":[],"mappings":";AAKA,wBAAgB,IAAI,CAAC,OAAO,EAAE,MAAM,EAAE,MAAM,EAAE,CAAC,GAAG,IAAI,OAAA,KAAK,IAAI,GAAG,MAAM,CAAC,WAAW,EAAE,MAAM,EAAE,CAAC,GAAG,IAAI,OAAA,KAAK,IAAI,GAAG,MAAM,CAAC,WAAW,mBAiDnI;AAED,wBAAgB,KAAK,CAAC,OAAO,KAAA,EAAE,IAAI,KAAA,EAAE,MAAM,KAAA,EAAE,MAAM,KAAA,iBAoBlD"}

shell/index.js

@@ -0,0 +1,84 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.spawn = exports.exec = void 0;
+var child_process_1 = require("child_process");
+var child_process_2 = require("child_process");
+var MAX_BUFFER = 10 * Math.pow(2, 20);
+function exec(command, stdout, stderr) {
+    return new Promise(function (resolve, reject) {
+        var stdoutbuf = "";
+        var stderrbuf = "";
+        // EXEC CHILD PROCESS
+        var p = child_process_1.exec(command, { maxBuffer: MAX_BUFFER }, function (err, out) {
+            if (err)
+                return reject(err);
+            if (stdoutbuf.length > 0 && typeof stdout === 'function')
+                stdout(stdoutbuf);
+            if (stderrbuf.length > 0 && typeof stderr === 'function')
+                stderr(stderrbuf);
+            resolve(out);
+        });
+        // PIPE STDOUT
+        if (typeof stdout === 'function') {
+            p.stdout.on("data", function (chunk) {
+                stdoutbuf += chunk;
+                var i = -1;
+                while ((i = stdoutbuf.indexOf('\n')) >= 0) {
+                    var line = stdoutbuf.substring(0, i);
+                    stdoutbuf = stdoutbuf.substring(i + 1);
+                    if (typeof stdout === 'function') {
+                        stdout(line);
+                    }
+                }
+            });
+        }
+        else if (typeof stdout !== 'undefined') {
+            p.stdout.pipe(stdout);
+        }
+        // PIPE STDERR
+        if (typeof stderr === 'function') {
+            p.stderr.on("data", function (chunk) {
+                stderrbuf += chunk;
+                var i = -1;
+                while ((i = stderrbuf.indexOf('\n')) >= 0) {
+                    var line = stderrbuf.substring(0, i);
+                    stderrbuf = stderrbuf.substring(i + 1);
+                    if (typeof stderr === 'function') {
+                        stderr(line);
+                    }
+                }
+            });
+        }
+        else if (typeof stderr !== 'undefined') {
+            p.stderr.pipe(stderr);
+        }
+    });
+}
+exports.exec = exec;
+function spawn(command, args, stdout, stderr) {
+    return new Promise(function (resolve, reject) {
+        try {
+            var p = child_process_2.spawn(command, args);
+            p.stdout.pipe(stdout);
+            p.stderr.pipe(stderr);
+            p.on('close', function (code, sig) {
+                if (!code)
+                    resolve();
+                else
+                    reject();
+            });
+            p.on('error', reject);
+            p.on('exit', function (code, sig) {
+                if (!code)
+                    resolve();
+                else
+                    reject();
+            });
+        }
+        catch (err) {
+            console.error(err);
+        }
+    });
+}
+exports.spawn = spawn;
+//# sourceMappingURL=index.js.map

shell/index.ts

@@ -0,0 +1,77 @@
+import { ChildProcessWithoutNullStreams, exec as shell_exec } from 'child_process';
+import { spawn as shell_spawn } from 'child_process';
+
+const MAX_BUFFER = 10 * Math.pow(2, 20);
+
+export function exec(command: string, stdout: (...args) => void | NodeJS.WriteStream, stderr: (...args) => void | NodeJS.WriteStream) {
+    return new Promise<string>((resolve, reject) => {
+        let stdoutbuf = "";
+        let stderrbuf = "";
+
+        // EXEC CHILD PROCESS
+        const p = shell_exec(command, { maxBuffer: MAX_BUFFER }, (err, out) => {
+            if (err) return reject(err);
+
+            if (stdoutbuf.length > 0 && typeof stdout === 'function') stdout(stdoutbuf);
+            if (stderrbuf.length > 0 && typeof stderr === 'function') stderr(stderrbuf);
+
+            resolve(out);
+        });
+
+        // PIPE STDOUT
+        if (typeof stdout === 'function') {
+            p.stdout.on("data", chunk => {
+                stdoutbuf += chunk;
+                let i = -1;
+                while ((i = stdoutbuf.indexOf('\n')) >= 0) {
+                    const line = stdoutbuf.substring(0, i);
+                    stdoutbuf = stdoutbuf.substring(i + 1);
+                    if (typeof stdout === 'function') {
+                        stdout(line);
+                    }
+                }
+            });
+        } else if (typeof stdout !== 'undefined') {
+            p.stdout.pipe(stdout);
+        }
+
+        // PIPE STDERR
+        if (typeof stderr === 'function') {
+            p.stderr.on("data", chunk => {
+                stderrbuf += chunk;
+                let i = -1;
+                while ((i = stderrbuf.indexOf('\n')) >= 0) {
+                    const line = stderrbuf.substring(0, i);
+                    stderrbuf = stderrbuf.substring(i + 1);
+                    if (typeof stderr === 'function') {
+                        stderr(line);
+                    }
+                }
+            });
+        } else if (typeof stderr !== 'undefined') {
+            p.stderr.pipe(stderr);
+        }
+    });
+}
+
+export function spawn(command, args, stdout, stderr) {
+    return new Promise<void>((resolve, reject) => {
+        try {
+            const p = shell_spawn(command, args);
+
+            p.stdout.pipe(stdout);
+            p.stderr.pipe(stderr);
+            p.on('close', (code, sig) => {
+                if (!code) resolve();
+                else reject();
+            });
+            p.on('error', reject);
+            p.on('exit', (code, sig) => {
+                if (!code) resolve();
+                else reject();
+            });
+        } catch (err) {
+            console.error(err);
+        }
+    });
+}

tsconfig.json

@@ -0,0 +1,15 @@
+{
+  "compilerOptions": {
+    "lib": ["ES2020"],
+    "target": "es5",
+    "module": "commonjs",
+    "declaration": true,
+    "declarationMap": true,
+    "sourceMap": true,
+    "rootDir": "./",
+    "strict": false,
+    "esModuleInterop": true,
+    "skipLibCheck": true,
+    "forceConsistentCasingInFileNames": true
+  }
+}