spawn-streaming - npm Package Compare versions

Comparing version 1.1.10 to 1.1.11

dist/cjs/lib/concatWritable.js

@@ -11,3 +11,2 @@ "use strict";
 });
-var _readablestream = /*#__PURE__*/ _interop_require_default(require("readable-stream"));
 var _stream = /*#__PURE__*/ _interop_require_default(require("stream"));
@@ -20,3 +19,8 @@ function _interop_require_default(obj) {
 var major = +process.versions.node.split('.')[0];
-var Writable = major > 0 ? _stream.default.Writable : _readablestream.default.Writable;
+var Writable;
+if (major > 0) {
+    Writable = _stream.default.Writable;
+} else {
+    Writable = require('readable-stream').Writable;
+}
 function concatWritable(callback) {
@@ -23,0 +27,0 @@ var chunks = [];

dist/cjs/lib/concatWritable.js.map

@@ -1,1 +0,1 @@
-{"version":3,"sources":["/Users/kevin/Dev/OpenSource/node/spawn-streaming/src/lib/concatWritable.ts"],"sourcesContent":["import StreamCompat from 'readable-stream';\nimport Stream from 'stream';\n\nconst major = +process.versions.node.split('.')[0];\nconst Writable = major > 0 ? Stream.Writable : (StreamCompat.Writable as typeof Stream.Writable);\n\nexport type Callback = (lines: Buffer) => undefined;\n\nexport default function concatWritable(callback: Callback): NodeJS.WritableStream {\n  const chunks = [];\n  const stream = new Writable({\n    write: (chunk, _encoding, next) => {\n      chunks.push(chunk);\n      next();\n    },\n  });\n  stream.on('finish', () => callback(Buffer.concat(chunks.splice(0))));\n  return stream;\n}\n"],"names":["concatWritable","major","process","versions","node","split","Writable","Stream","StreamCompat","callback","chunks","stream","write","chunk","_encoding","next","push","on","Buffer","concat","splice"],"mappings":";;;;+BAQA;;;eAAwBA;;;qEARC;6DACN;;;;;;AAEnB,IAAMC,QAAQ,CAACC,QAAQC,QAAQ,CAACC,IAAI,CAACC,KAAK,CAAC,IAAI,CAAC,EAAE;AAClD,IAAMC,WAAWL,QAAQ,IAAIM,eAAM,CAACD,QAAQ,GAAIE,uBAAY,CAACF,QAAQ;AAItD,SAASN,eAAeS,QAAkB;IACvD,IAAMC,SAAS,EAAE;IACjB,IAAMC,SAAS,IAAIL,SAAS;QAC1BM,OAAO,SAACC,OAAOC,WAAWC;YACxBL,OAAOM,IAAI,CAACH;YACZE;QACF;IACF;IACAJ,OAAOM,EAAE,CAAC,UAAU;eAAMR,SAASS,OAAOC,MAAM,CAACT,OAAOU,MAAM,CAAC;;IAC/D,OAAOT;AACT"}
+{"version":3,"sources":["/Users/kevin/Dev/OpenSource/node/spawn-streaming/src/lib/concatWritable.ts"],"sourcesContent":["import Stream from 'stream';\n\nconst major = +process.versions.node.split('.')[0];\nlet Writable: typeof Stream.Writable;\nif (major > 0) {\n  Writable = Stream.Writable;\n} else {\n  Writable = require('readable-stream').Writable;\n}\n\nexport type Callback = (lines: Buffer) => undefined;\n\nexport default function concatWritable(callback: Callback): NodeJS.WritableStream {\n  const chunks = [];\n  const stream = new Writable({\n    write: (chunk, _encoding, next) => {\n      chunks.push(chunk);\n      next();\n    },\n  });\n  stream.on('finish', () => callback(Buffer.concat(chunks.splice(0))));\n  return stream;\n}\n"],"names":["concatWritable","major","process","versions","node","split","Writable","Stream","require","callback","chunks","stream","write","chunk","_encoding","next","push","on","Buffer","concat","splice"],"mappings":";;;;+BAYA;;;eAAwBA;;;6DAZL;;;;;;AAEnB,IAAMC,QAAQ,CAACC,QAAQC,QAAQ,CAACC,IAAI,CAACC,KAAK,CAAC,IAAI,CAAC,EAAE;AAClD,IAAIC;AACJ,IAAIL,QAAQ,GAAG;IACbK,WAAWC,eAAM,CAACD,QAAQ;AAC5B,OAAO;IACLA,WAAWE,QAAQ,mBAAmBF,QAAQ;AAChD;AAIe,SAASN,eAAeS,QAAkB;IACvD,IAAMC,SAAS,EAAE;IACjB,IAAMC,SAAS,IAAIL,SAAS;QAC1BM,OAAO,SAACC,OAAOC,WAAWC;YACxBL,OAAOM,IAAI,CAACH;YACZE;QACF;IACF;IACAJ,OAAOM,EAAE,CAAC,UAAU;eAAMR,SAASS,OAAOC,MAAM,CAACT,OAAOU,MAAM,CAAC;;IAC/D,OAAOT;AACT"}

dist/cjs/lib/prefixTransform.js

@@ -11,3 +11,2 @@ "use strict";
 });
-var _readablestream = /*#__PURE__*/ _interop_require_default(require("readable-stream"));
 var _stream = /*#__PURE__*/ _interop_require_default(require("stream"));
@@ -22,3 +21,8 @@ var _colors = /*#__PURE__*/ _interop_require_default(require("colors"));
 var major = +process.versions.node.split('.')[0];
-var Transform = major > 0 ? _stream.default.Transform : _readablestream.default.Transform;
+var Transform;
+if (major > 0) {
+    Transform = _stream.default.Transform;
+} else {
+    Transform = require('readable-stream').Transform;
+}
 function prefixTransform(prefix, color) {
@@ -25,0 +29,0 @@ var createLine = function(line) {

dist/cjs/lib/prefixTransform.js.map

@@ -1,1 +0,1 @@
-{"version":3,"sources":["/Users/kevin/Dev/OpenSource/node/spawn-streaming/src/lib/prefixTransform.ts"],"sourcesContent":["import StreamCompat from 'readable-stream';\nimport Stream from 'stream';\n\nconst major = +process.versions.node.split('.')[0];\nconst Transform = major > 0 ? Stream.Transform : (StreamCompat.Transform as typeof Stream.Transform);\n\nimport c from 'colors';\nimport type { ColorFunction } from '../types.ts';\nimport LineBuffer from './LineBuffer.ts';\n\nexport default function prefixTransform(prefix: string, color: ColorFunction): NodeJS.ReadableStream {\n  const createLine = (line: string) => `${c.bold(color(prefix))}: ${line}\\n`;\n\n  let transform: InstanceType<typeof Transform>;\n  const lineBuffer = new LineBuffer((line) => {\n    transform.push(createLine(line));\n  });\n\n  transform = new Transform({\n    transform(chunk, _enc, callback) {\n      lineBuffer.write(chunk);\n      callback();\n    },\n    flush() {\n      lineBuffer.flush();\n      lineBuffer.dispose();\n      this.push(null);\n    },\n  });\n\n  return transform;\n}\n"],"names":["prefixTransform","major","process","versions","node","split","Transform","Stream","StreamCompat","prefix","color","createLine","line","c","bold","transform","lineBuffer","LineBuffer","push","chunk","_enc","callback","write","flush","dispose"],"mappings":";;;;+BAUA;;;eAAwBA;;;qEAVC;6DACN;6DAKL;mEAES;;;;;;AALvB,IAAMC,QAAQ,CAACC,QAAQC,QAAQ,CAACC,IAAI,CAACC,KAAK,CAAC,IAAI,CAAC,EAAE;AAClD,IAAMC,YAAYL,QAAQ,IAAIM,eAAM,CAACD,SAAS,GAAIE,uBAAY,CAACF,SAAS;AAMzD,SAASN,gBAAgBS,MAAc,EAAEC,KAAoB;IAC1E,IAAMC,aAAa,SAACC;eAAiB,AAAC,GAA4BA,OAA1BC,eAAC,CAACC,IAAI,CAACJ,MAAMD,UAAS,MAAS,OAALG,MAAK;;IAEvE,IAAIG;IACJ,IAAMC,aAAa,IAAIC,qBAAU,CAAC,SAACL;QACjCG,UAAUG,IAAI,CAACP,WAAWC;IAC5B;IAEAG,YAAY,IAAIT,UAAU;QACxBS,WAAAA,SAAAA,UAAUI,KAAK,EAAEC,IAAI,EAAEC,QAAQ;YAC7BL,WAAWM,KAAK,CAACH;YACjBE;QACF;QACAE,OAAAA,SAAAA;YACEP,WAAWO,KAAK;YAChBP,WAAWQ,OAAO;YAClB,IAAI,CAACN,IAAI,CAAC;QACZ;IACF;IAEA,OAAOH;AACT"}
+{"version":3,"sources":["/Users/kevin/Dev/OpenSource/node/spawn-streaming/src/lib/prefixTransform.ts"],"sourcesContent":["import Stream from 'stream';\n\nconst major = +process.versions.node.split('.')[0];\nlet Transform: typeof Stream.Transform;\nif (major > 0) {\n  Transform = Stream.Transform;\n} else {\n  Transform = require('readable-stream').Transform;\n}\n\nimport c from 'colors';\nimport type { ColorFunction } from '../types.ts';\nimport LineBuffer from './LineBuffer.ts';\n\nexport default function prefixTransform(prefix: string, color: ColorFunction): NodeJS.ReadableStream {\n  const createLine = (line: string) => `${c.bold(color(prefix))}: ${line}\\n`;\n\n  let transform: InstanceType<typeof Transform>;\n  const lineBuffer = new LineBuffer((line) => {\n    transform.push(createLine(line));\n  });\n\n  transform = new Transform({\n    transform(chunk, _enc, callback) {\n      lineBuffer.write(chunk);\n      callback();\n    },\n    flush() {\n      lineBuffer.flush();\n      lineBuffer.dispose();\n      this.push(null);\n    },\n  });\n\n  return transform;\n}\n"],"names":["prefixTransform","major","process","versions","node","split","Transform","Stream","require","prefix","color","createLine","line","c","bold","transform","lineBuffer","LineBuffer","push","chunk","_enc","callback","write","flush","dispose"],"mappings":";;;;+BAcA;;;eAAwBA;;;6DAdL;6DAUL;mEAES;;;;;;AAVvB,IAAMC,QAAQ,CAACC,QAAQC,QAAQ,CAACC,IAAI,CAACC,KAAK,CAAC,IAAI,CAAC,EAAE;AAClD,IAAIC;AACJ,IAAIL,QAAQ,GAAG;IACbK,YAAYC,eAAM,CAACD,SAAS;AAC9B,OAAO;IACLA,YAAYE,QAAQ,mBAAmBF,SAAS;AAClD;AAMe,SAASN,gBAAgBS,MAAc,EAAEC,KAAoB;IAC1E,IAAMC,aAAa,SAACC;eAAiB,AAAC,GAA4BA,OAA1BC,eAAC,CAACC,IAAI,CAACJ,MAAMD,UAAS,MAAS,OAALG,MAAK;;IAEvE,IAAIG;IACJ,IAAMC,aAAa,IAAIC,qBAAU,CAAC,SAACL;QACjCG,UAAUG,IAAI,CAACP,WAAWC;IAC5B;IAEAG,YAAY,IAAIT,UAAU;QACxBS,WAAAA,SAAAA,UAAUI,KAAK,EAAEC,IAAI,EAAEC,QAAQ;YAC7BL,WAAWM,KAAK,CAACH;YACjBE;QACF;QACAE,OAAAA,SAAAA;YACEP,WAAWO,KAAK;YAChBP,WAAWQ,OAAO;YAClB,IAAI,CAACN,IAAI,CAAC;QACZ;IACF;IAEA,OAAOH;AACT"}

dist/esm/lib/concatWritable.js

@@ -1,5 +0,9 @@
-import StreamCompat from 'readable-stream';
 import Stream from 'stream';
 const major = +process.versions.node.split('.')[0];
-const Writable = major > 0 ? Stream.Writable : StreamCompat.Writable;
+let Writable;
+if (major > 0) {
+    Writable = Stream.Writable;
+} else {
+    Writable = require('readable-stream').Writable;
+}
 export default function concatWritable(callback) {
@@ -6,0 +10,0 @@ const chunks = [];

dist/esm/lib/concatWritable.js.map

@@ -1,1 +0,1 @@
-{"version":3,"sources":["/Users/kevin/Dev/OpenSource/node/spawn-streaming/src/lib/concatWritable.ts"],"sourcesContent":["import StreamCompat from 'readable-stream';\nimport Stream from 'stream';\n\nconst major = +process.versions.node.split('.')[0];\nconst Writable = major > 0 ? Stream.Writable : (StreamCompat.Writable as typeof Stream.Writable);\n\nexport type Callback = (lines: Buffer) => undefined;\n\nexport default function concatWritable(callback: Callback): NodeJS.WritableStream {\n  const chunks = [];\n  const stream = new Writable({\n    write: (chunk, _encoding, next) => {\n      chunks.push(chunk);\n      next();\n    },\n  });\n  stream.on('finish', () => callback(Buffer.concat(chunks.splice(0))));\n  return stream;\n}\n"],"names":["StreamCompat","Stream","major","process","versions","node","split","Writable","concatWritable","callback","chunks","stream","write","chunk","_encoding","next","push","on","Buffer","concat","splice"],"mappings":"AAAA,OAAOA,kBAAkB,kBAAkB;AAC3C,OAAOC,YAAY,SAAS;AAE5B,MAAMC,QAAQ,CAACC,QAAQC,QAAQ,CAACC,IAAI,CAACC,KAAK,CAAC,IAAI,CAAC,EAAE;AAClD,MAAMC,WAAWL,QAAQ,IAAID,OAAOM,QAAQ,GAAIP,aAAaO,QAAQ;AAIrE,eAAe,SAASC,eAAeC,QAAkB;IACvD,MAAMC,SAAS,EAAE;IACjB,MAAMC,SAAS,IAAIJ,SAAS;QAC1BK,OAAO,CAACC,OAAOC,WAAWC;YACxBL,OAAOM,IAAI,CAACH;YACZE;QACF;IACF;IACAJ,OAAOM,EAAE,CAAC,UAAU,IAAMR,SAASS,OAAOC,MAAM,CAACT,OAAOU,MAAM,CAAC;IAC/D,OAAOT;AACT"}
+{"version":3,"sources":["/Users/kevin/Dev/OpenSource/node/spawn-streaming/src/lib/concatWritable.ts"],"sourcesContent":["import Stream from 'stream';\n\nconst major = +process.versions.node.split('.')[0];\nlet Writable: typeof Stream.Writable;\nif (major > 0) {\n  Writable = Stream.Writable;\n} else {\n  Writable = require('readable-stream').Writable;\n}\n\nexport type Callback = (lines: Buffer) => undefined;\n\nexport default function concatWritable(callback: Callback): NodeJS.WritableStream {\n  const chunks = [];\n  const stream = new Writable({\n    write: (chunk, _encoding, next) => {\n      chunks.push(chunk);\n      next();\n    },\n  });\n  stream.on('finish', () => callback(Buffer.concat(chunks.splice(0))));\n  return stream;\n}\n"],"names":["Stream","major","process","versions","node","split","Writable","require","concatWritable","callback","chunks","stream","write","chunk","_encoding","next","push","on","Buffer","concat","splice"],"mappings":"AAAA,OAAOA,YAAY,SAAS;AAE5B,MAAMC,QAAQ,CAACC,QAAQC,QAAQ,CAACC,IAAI,CAACC,KAAK,CAAC,IAAI,CAAC,EAAE;AAClD,IAAIC;AACJ,IAAIL,QAAQ,GAAG;IACbK,WAAWN,OAAOM,QAAQ;AAC5B,OAAO;IACLA,WAAWC,QAAQ,mBAAmBD,QAAQ;AAChD;AAIA,eAAe,SAASE,eAAeC,QAAkB;IACvD,MAAMC,SAAS,EAAE;IACjB,MAAMC,SAAS,IAAIL,SAAS;QAC1BM,OAAO,CAACC,OAAOC,WAAWC;YACxBL,OAAOM,IAAI,CAACH;YACZE;QACF;IACF;IACAJ,OAAOM,EAAE,CAAC,UAAU,IAAMR,SAASS,OAAOC,MAAM,CAACT,OAAOU,MAAM,CAAC;IAC/D,OAAOT;AACT"}

dist/esm/lib/prefixTransform.js

@@ -1,5 +0,9 @@
-import StreamCompat from 'readable-stream';
 import Stream from 'stream';
 const major = +process.versions.node.split('.')[0];
-const Transform = major > 0 ? Stream.Transform : StreamCompat.Transform;
+let Transform;
+if (major > 0) {
+    Transform = Stream.Transform;
+} else {
+    Transform = require('readable-stream').Transform;
+}
 import c from 'colors';
@@ -6,0 +10,0 @@ import LineBuffer from './LineBuffer.js';

dist/esm/lib/prefixTransform.js.map

@@ -1,1 +0,1 @@
-{"version":3,"sources":["/Users/kevin/Dev/OpenSource/node/spawn-streaming/src/lib/prefixTransform.ts"],"sourcesContent":["import StreamCompat from 'readable-stream';\nimport Stream from 'stream';\n\nconst major = +process.versions.node.split('.')[0];\nconst Transform = major > 0 ? Stream.Transform : (StreamCompat.Transform as typeof Stream.Transform);\n\nimport c from 'colors';\nimport type { ColorFunction } from '../types.ts';\nimport LineBuffer from './LineBuffer.ts';\n\nexport default function prefixTransform(prefix: string, color: ColorFunction): NodeJS.ReadableStream {\n  const createLine = (line: string) => `${c.bold(color(prefix))}: ${line}\\n`;\n\n  let transform: InstanceType<typeof Transform>;\n  const lineBuffer = new LineBuffer((line) => {\n    transform.push(createLine(line));\n  });\n\n  transform = new Transform({\n    transform(chunk, _enc, callback) {\n      lineBuffer.write(chunk);\n      callback();\n    },\n    flush() {\n      lineBuffer.flush();\n      lineBuffer.dispose();\n      this.push(null);\n    },\n  });\n\n  return transform;\n}\n"],"names":["StreamCompat","Stream","major","process","versions","node","split","Transform","c","LineBuffer","prefixTransform","prefix","color","createLine","line","bold","transform","lineBuffer","push","chunk","_enc","callback","write","flush","dispose"],"mappings":"AAAA,OAAOA,kBAAkB,kBAAkB;AAC3C,OAAOC,YAAY,SAAS;AAE5B,MAAMC,QAAQ,CAACC,QAAQC,QAAQ,CAACC,IAAI,CAACC,KAAK,CAAC,IAAI,CAAC,EAAE;AAClD,MAAMC,YAAYL,QAAQ,IAAID,OAAOM,SAAS,GAAIP,aAAaO,SAAS;AAExE,OAAOC,OAAO,SAAS;AAEvB,OAAOC,gBAAgB,kBAAkB;AAEzC,eAAe,SAASC,gBAAgBC,MAAc,EAAEC,KAAoB;IAC1E,MAAMC,aAAa,CAACC,OAAiB,GAAGN,EAAEO,IAAI,CAACH,MAAMD,SAAS,EAAE,EAAEG,KAAK,EAAE,CAAC;IAE1E,IAAIE;IACJ,MAAMC,aAAa,IAAIR,WAAW,CAACK;QACjCE,UAAUE,IAAI,CAACL,WAAWC;IAC5B;IAEAE,YAAY,IAAIT,UAAU;QACxBS,WAAUG,KAAK,EAAEC,IAAI,EAAEC,QAAQ;YAC7BJ,WAAWK,KAAK,CAACH;YACjBE;QACF;QACAE;YACEN,WAAWM,KAAK;YAChBN,WAAWO,OAAO;YAClB,IAAI,CAACN,IAAI,CAAC;QACZ;IACF;IAEA,OAAOF;AACT"}
+{"version":3,"sources":["/Users/kevin/Dev/OpenSource/node/spawn-streaming/src/lib/prefixTransform.ts"],"sourcesContent":["import Stream from 'stream';\n\nconst major = +process.versions.node.split('.')[0];\nlet Transform: typeof Stream.Transform;\nif (major > 0) {\n  Transform = Stream.Transform;\n} else {\n  Transform = require('readable-stream').Transform;\n}\n\nimport c from 'colors';\nimport type { ColorFunction } from '../types.ts';\nimport LineBuffer from './LineBuffer.ts';\n\nexport default function prefixTransform(prefix: string, color: ColorFunction): NodeJS.ReadableStream {\n  const createLine = (line: string) => `${c.bold(color(prefix))}: ${line}\\n`;\n\n  let transform: InstanceType<typeof Transform>;\n  const lineBuffer = new LineBuffer((line) => {\n    transform.push(createLine(line));\n  });\n\n  transform = new Transform({\n    transform(chunk, _enc, callback) {\n      lineBuffer.write(chunk);\n      callback();\n    },\n    flush() {\n      lineBuffer.flush();\n      lineBuffer.dispose();\n      this.push(null);\n    },\n  });\n\n  return transform;\n}\n"],"names":["Stream","major","process","versions","node","split","Transform","require","c","LineBuffer","prefixTransform","prefix","color","createLine","line","bold","transform","lineBuffer","push","chunk","_enc","callback","write","flush","dispose"],"mappings":"AAAA,OAAOA,YAAY,SAAS;AAE5B,MAAMC,QAAQ,CAACC,QAAQC,QAAQ,CAACC,IAAI,CAACC,KAAK,CAAC,IAAI,CAAC,EAAE;AAClD,IAAIC;AACJ,IAAIL,QAAQ,GAAG;IACbK,YAAYN,OAAOM,SAAS;AAC9B,OAAO;IACLA,YAAYC,QAAQ,mBAAmBD,SAAS;AAClD;AAEA,OAAOE,OAAO,SAAS;AAEvB,OAAOC,gBAAgB,kBAAkB;AAEzC,eAAe,SAASC,gBAAgBC,MAAc,EAAEC,KAAoB;IAC1E,MAAMC,aAAa,CAACC,OAAiB,GAAGN,EAAEO,IAAI,CAACH,MAAMD,SAAS,EAAE,EAAEG,KAAK,EAAE,CAAC;IAE1E,IAAIE;IACJ,MAAMC,aAAa,IAAIR,WAAW,CAACK;QACjCE,UAAUE,IAAI,CAACL,WAAWC;IAC5B;IAEAE,YAAY,IAAIV,UAAU;QACxBU,WAAUG,KAAK,EAAEC,IAAI,EAAEC,QAAQ;YAC7BJ,WAAWK,KAAK,CAACH;YACjBE;QACF;QACAE;YACEN,WAAWM,KAAK;YAChBN,WAAWO,OAAO;YAClB,IAAI,CAACN,IAAI,CAAC;QACZ;IACF;IAEA,OAAOF;AACT"}

package.json

 {
   "name": "spawn-streaming",
-  "version": "1.1.10",
+  "version": "1.1.11",
   "description": "Formats spawn with prefix and colors",
@@ -5,0 +5,0 @@ "keywords": [

New alerts

Long strings

Supply chain risk

Contains long string literals, which may be a sign of obfuscated or packed code.

Found 1 instance in 1 package

Fixed alerts

Long strings

Supply chain risk

Contains long string literals, which may be a sign of obfuscated or packed code.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

94236

0.07%

Lines of code

1090

1.49%

No dependency changes