@node-minify/run
Advanced tools
+8
-2
@@ -12,2 +12,3 @@ //#region src/index.d.ts | ||
| timeout?: number; | ||
| silence?: boolean; | ||
| }; | ||
@@ -20,2 +21,3 @@ /** | ||
| * @param timeout - Optional timeout in milliseconds. Process will be killed if it exceeds this limit. | ||
| * @param silence - Optional boolean to suppress console logging. | ||
| * @returns Promise with minified content from stdout | ||
@@ -27,3 +29,4 @@ */ | ||
| maxBuffer, | ||
| timeout | ||
| timeout, | ||
| silence | ||
| }: RunCommandLineParams): Promise<string>; | ||
@@ -35,2 +38,3 @@ type RunParams = { | ||
| timeout?: number; | ||
| silence?: boolean; | ||
| }; | ||
@@ -43,2 +47,3 @@ /** | ||
| * @param timeout - Optional timeout in milliseconds. Process will be killed if it exceeds this limit. | ||
| * @param silence - Optional boolean to suppress console logging. | ||
| * @returns Promise with minified content from stdout | ||
@@ -50,3 +55,4 @@ */ | ||
| maxBuffer, | ||
| timeout | ||
| timeout, | ||
| silence | ||
| }: RunParams): Promise<string>; | ||
@@ -53,0 +59,0 @@ //#endregion |
@@ -1,1 +0,1 @@ | ||
| {"version":3,"file":"index.d.ts","names":[],"sources":["../src/index.ts"],"sourcesContent":[],"mappings":";;AAQA;AAeA;;;AAGI,KAlBQ,oBAAA,GAkBR;EACA,IAAA,EAAA,MAAA,EAAA;EACD,IAAA,EAAA,MAAA;EAAuB,SAAA,CAAA,EAAA,MAAA;EAAO,OAAA,CAAA,EAAA,MAAA;AAEhC,CAAA;AAiBD;;;;;;;;iBAxBsB,cAAA;;;;;GAKnB,uBAAuB;KAIrB,SAAA;;;;;;;;;;;;;;iBAeiB,GAAA;;;;;GAKnB,YAAY"} | ||
| {"version":3,"file":"index.d.ts","names":[],"sources":["../src/index.ts"],"sourcesContent":[],"mappings":";;AAQA;AAiBA;;;AAGI,KApBQ,oBAAA,GAoBR;EACA,IAAA,EAAA,MAAA,EAAA;EACA,IAAA,EAAA,MAAA;EACD,SAAA,CAAA,EAAA,MAAA;EAAuB,OAAA,CAAA,EAAA,MAAA;EAAO,OAAA,CAAA,EAAA,OAAA;AAEhC,CAAA;AAmBD;;;;;;;;;iBA3BsB,cAAA;;;;;;GAMnB,uBAAuB;KAIrB,SAAA;;;;;;;;;;;;;;;;iBAiBiB,GAAA;;;;;;GAMnB,YAAY"} |
+7
-4
@@ -15,5 +15,6 @@ import childProcess from "node:child_process"; | ||
| * @param timeout - Optional timeout in milliseconds. Process will be killed if it exceeds this limit. | ||
| * @param silence - Optional boolean to suppress console logging. | ||
| * @returns Promise with minified content from stdout | ||
| */ | ||
| async function runCommandLine({ args, data, maxBuffer, timeout }) { | ||
| async function runCommandLine({ args, data, maxBuffer, timeout, silence }) { | ||
| return run({ | ||
@@ -23,3 +24,4 @@ data, | ||
| maxBuffer, | ||
| timeout | ||
| timeout, | ||
| silence | ||
| }); | ||
@@ -33,5 +35,6 @@ } | ||
| * @param timeout - Optional timeout in milliseconds. Process will be killed if it exceeds this limit. | ||
| * @param silence - Optional boolean to suppress console logging. | ||
| * @returns Promise with minified content from stdout | ||
| */ | ||
| async function run({ data, args, maxBuffer = 1024 * 1024, timeout }) { | ||
| async function run({ data, args, maxBuffer = 1024 * 1024, timeout, silence = false }) { | ||
| return new Promise((resolve, reject) => { | ||
@@ -52,3 +55,3 @@ const stdoutChunks = []; | ||
| const handleError = (source) => (error) => { | ||
| console.error(`Error in ${source}:`, error); | ||
| if (!silence) console.error(`Error in ${source}:`, error); | ||
| }; | ||
@@ -55,0 +58,0 @@ child.on("error", (error) => { |
@@ -1,1 +0,1 @@ | ||
| {"version":3,"file":"index.js","names":["stdoutChunks: Buffer[]","stderrChunks: Buffer[]","timeoutId: NodeJS.Timeout | undefined"],"sources":["../src/index.ts"],"sourcesContent":["/*!\n * node-minify\n * Copyright (c) 2011-2026 Rodolphe Stoclin\n * MIT Licensed\n */\n\nimport childProcess from \"node:child_process\";\n\nexport type RunCommandLineParams = {\n args: string[];\n data: string;\n maxBuffer?: number;\n timeout?: number;\n};\n\n/**\n * Run the command line with spawn.\n * @param args - Command line arguments for the Java process\n * @param data - Data to minify (piped to stdin)\n * @param maxBuffer - Optional buffer limit in bytes. Defaults to 1024 * 1024 (1MB).\n * @param timeout - Optional timeout in milliseconds. Process will be killed if it exceeds this limit.\n * @returns Promise with minified content from stdout\n */\nexport async function runCommandLine({\n args,\n data,\n maxBuffer,\n timeout,\n}: RunCommandLineParams): Promise<string> {\n return run({ data, args, maxBuffer, timeout });\n}\n\ntype RunParams = {\n data: string;\n args: string[];\n maxBuffer?: number;\n timeout?: number;\n};\n\n/**\n * Execute command with Java process.\n * @param data - Data to minify (piped to stdin)\n * @param args - Command line arguments\n * @param maxBuffer - Optional buffer limit in bytes. Defaults to 1024 * 1024 (1MB).\n * @param timeout - Optional timeout in milliseconds. Process will be killed if it exceeds this limit.\n * @returns Promise with minified content from stdout\n */\nexport async function run({\n data,\n args,\n maxBuffer = 1024 * 1024,\n timeout,\n}: RunParams): Promise<string> {\n return new Promise((resolve, reject) => {\n const stdoutChunks: Buffer[] = [];\n const stderrChunks: Buffer[] = [];\n let stdoutLength = 0;\n let stderrLength = 0;\n let timeoutId: NodeJS.Timeout | undefined;\n let settled = false;\n\n const child = childProcess.spawn(\"java\", args, {\n stdio: \"pipe\",\n });\n\n if (timeout) {\n timeoutId = setTimeout(() => {\n if (settled || child.killed) return;\n settled = true;\n child.kill();\n reject(new Error(`Process timed out after ${timeout}ms`));\n }, timeout);\n }\n\n const handleError = (source: string) => (error: Error) => {\n console.error(`Error in ${source}:`, error);\n };\n\n child.on(\"error\", (error) => {\n if (settled) return;\n settled = true;\n if (timeoutId) clearTimeout(timeoutId);\n handleError(\"child\")(error);\n reject(new Error(`Process error: ${error.message}`));\n });\n\n child.stdin?.on(\"error\", handleError(\"child.stdin\"));\n child.stdout?.on(\"error\", handleError(\"child.stdout\"));\n child.stderr?.on(\"error\", handleError(\"child.stderr\"));\n\n child.on(\"exit\", (code: number | null) => {\n if (settled) return;\n settled = true;\n if (timeoutId) clearTimeout(timeoutId);\n const stderr = Buffer.concat(stderrChunks).toString(\"utf8\");\n if (code !== 0) {\n reject(new Error(stderr || `Process exited with code ${code}`));\n return;\n }\n\n resolve(Buffer.concat(stdoutChunks).toString(\"utf8\"));\n });\n\n child.stdout?.on(\"data\", (chunk: Buffer) => {\n stdoutChunks.push(chunk);\n stdoutLength += chunk.length;\n\n if (maxBuffer > 0 && stdoutLength > maxBuffer) {\n if (settled) return;\n settled = true;\n if (timeoutId) clearTimeout(timeoutId);\n child.kill();\n reject(new Error(\"stdout maxBuffer exceeded\"));\n return;\n }\n });\n\n child.stderr?.on(\"data\", (chunk: Buffer) => {\n stderrChunks.push(chunk);\n stderrLength += chunk.length;\n\n if (maxBuffer > 0 && stderrLength > maxBuffer) {\n if (settled) return;\n settled = true;\n if (timeoutId) clearTimeout(timeoutId);\n child.kill();\n reject(new Error(\"stderr maxBuffer exceeded\"));\n return;\n }\n });\n\n child.stdin?.end(data);\n });\n}\n"],"mappings":";;;;;;;;;;;;;;;;AAuBA,eAAsB,eAAe,EACjC,MACA,MACA,WACA,WACsC;AACtC,QAAO,IAAI;EAAE;EAAM;EAAM;EAAW;EAAS,CAAC;;;;;;;;;;AAkBlD,eAAsB,IAAI,EACtB,MACA,MACA,YAAY,OAAO,MACnB,WAC2B;AAC3B,QAAO,IAAI,SAAS,SAAS,WAAW;EACpC,MAAMA,eAAyB,EAAE;EACjC,MAAMC,eAAyB,EAAE;EACjC,IAAI,eAAe;EACnB,IAAI,eAAe;EACnB,IAAIC;EACJ,IAAI,UAAU;EAEd,MAAM,QAAQ,aAAa,MAAM,QAAQ,MAAM,EAC3C,OAAO,QACV,CAAC;AAEF,MAAI,QACA,aAAY,iBAAiB;AACzB,OAAI,WAAW,MAAM,OAAQ;AAC7B,aAAU;AACV,SAAM,MAAM;AACZ,0BAAO,IAAI,MAAM,2BAA2B,QAAQ,IAAI,CAAC;KAC1D,QAAQ;EAGf,MAAM,eAAe,YAAoB,UAAiB;AACtD,WAAQ,MAAM,YAAY,OAAO,IAAI,MAAM;;AAG/C,QAAM,GAAG,UAAU,UAAU;AACzB,OAAI,QAAS;AACb,aAAU;AACV,OAAI,UAAW,cAAa,UAAU;AACtC,eAAY,QAAQ,CAAC,MAAM;AAC3B,0BAAO,IAAI,MAAM,kBAAkB,MAAM,UAAU,CAAC;IACtD;AAEF,QAAM,OAAO,GAAG,SAAS,YAAY,cAAc,CAAC;AACpD,QAAM,QAAQ,GAAG,SAAS,YAAY,eAAe,CAAC;AACtD,QAAM,QAAQ,GAAG,SAAS,YAAY,eAAe,CAAC;AAEtD,QAAM,GAAG,SAAS,SAAwB;AACtC,OAAI,QAAS;AACb,aAAU;AACV,OAAI,UAAW,cAAa,UAAU;GACtC,MAAM,SAAS,OAAO,OAAO,aAAa,CAAC,SAAS,OAAO;AAC3D,OAAI,SAAS,GAAG;AACZ,WAAO,IAAI,MAAM,UAAU,4BAA4B,OAAO,CAAC;AAC/D;;AAGJ,WAAQ,OAAO,OAAO,aAAa,CAAC,SAAS,OAAO,CAAC;IACvD;AAEF,QAAM,QAAQ,GAAG,SAAS,UAAkB;AACxC,gBAAa,KAAK,MAAM;AACxB,mBAAgB,MAAM;AAEtB,OAAI,YAAY,KAAK,eAAe,WAAW;AAC3C,QAAI,QAAS;AACb,cAAU;AACV,QAAI,UAAW,cAAa,UAAU;AACtC,UAAM,MAAM;AACZ,2BAAO,IAAI,MAAM,4BAA4B,CAAC;AAC9C;;IAEN;AAEF,QAAM,QAAQ,GAAG,SAAS,UAAkB;AACxC,gBAAa,KAAK,MAAM;AACxB,mBAAgB,MAAM;AAEtB,OAAI,YAAY,KAAK,eAAe,WAAW;AAC3C,QAAI,QAAS;AACb,cAAU;AACV,QAAI,UAAW,cAAa,UAAU;AACtC,UAAM,MAAM;AACZ,2BAAO,IAAI,MAAM,4BAA4B,CAAC;AAC9C;;IAEN;AAEF,QAAM,OAAO,IAAI,KAAK;GACxB"} | ||
| {"version":3,"file":"index.js","names":[],"sources":["../src/index.ts"],"sourcesContent":["/*!\n * node-minify\n * Copyright (c) 2011-2026 Rodolphe Stoclin\n * MIT Licensed\n */\n\nimport childProcess from \"node:child_process\";\n\nexport type RunCommandLineParams = {\n args: string[];\n data: string;\n maxBuffer?: number;\n timeout?: number;\n silence?: boolean;\n};\n\n/**\n * Run the command line with spawn.\n * @param args - Command line arguments for the Java process\n * @param data - Data to minify (piped to stdin)\n * @param maxBuffer - Optional buffer limit in bytes. Defaults to 1024 * 1024 (1MB).\n * @param timeout - Optional timeout in milliseconds. Process will be killed if it exceeds this limit.\n * @param silence - Optional boolean to suppress console logging.\n * @returns Promise with minified content from stdout\n */\nexport async function runCommandLine({\n args,\n data,\n maxBuffer,\n timeout,\n silence,\n}: RunCommandLineParams): Promise<string> {\n return run({ data, args, maxBuffer, timeout, silence });\n}\n\ntype RunParams = {\n data: string;\n args: string[];\n maxBuffer?: number;\n timeout?: number;\n silence?: boolean;\n};\n\n/**\n * Execute command with Java process.\n * @param data - Data to minify (piped to stdin)\n * @param args - Command line arguments\n * @param maxBuffer - Optional buffer limit in bytes. Defaults to 1024 * 1024 (1MB).\n * @param timeout - Optional timeout in milliseconds. Process will be killed if it exceeds this limit.\n * @param silence - Optional boolean to suppress console logging.\n * @returns Promise with minified content from stdout\n */\nexport async function run({\n data,\n args,\n maxBuffer = 1024 * 1024,\n timeout,\n silence = false,\n}: RunParams): Promise<string> {\n return new Promise((resolve, reject) => {\n const stdoutChunks: Buffer[] = [];\n const stderrChunks: Buffer[] = [];\n let stdoutLength = 0;\n let stderrLength = 0;\n let timeoutId: NodeJS.Timeout | undefined;\n let settled = false;\n\n const child = childProcess.spawn(\"java\", args, {\n stdio: \"pipe\",\n });\n\n if (timeout) {\n timeoutId = setTimeout(() => {\n if (settled || child.killed) return;\n settled = true;\n child.kill();\n reject(new Error(`Process timed out after ${timeout}ms`));\n }, timeout);\n }\n\n const handleError = (source: string) => (error: Error) => {\n if (!silence) {\n console.error(`Error in ${source}:`, error);\n }\n };\n\n child.on(\"error\", (error) => {\n if (settled) return;\n settled = true;\n if (timeoutId) clearTimeout(timeoutId);\n handleError(\"child\")(error);\n reject(new Error(`Process error: ${error.message}`));\n });\n\n child.stdin?.on(\"error\", handleError(\"child.stdin\"));\n child.stdout?.on(\"error\", handleError(\"child.stdout\"));\n child.stderr?.on(\"error\", handleError(\"child.stderr\"));\n\n child.on(\"exit\", (code: number | null) => {\n if (settled) return;\n settled = true;\n if (timeoutId) clearTimeout(timeoutId);\n const stderr = Buffer.concat(stderrChunks).toString(\"utf8\");\n if (code !== 0) {\n reject(new Error(stderr || `Process exited with code ${code}`));\n return;\n }\n\n resolve(Buffer.concat(stdoutChunks).toString(\"utf8\"));\n });\n\n child.stdout?.on(\"data\", (chunk: Buffer) => {\n stdoutChunks.push(chunk);\n stdoutLength += chunk.length;\n\n if (maxBuffer > 0 && stdoutLength > maxBuffer) {\n if (settled) return;\n settled = true;\n if (timeoutId) clearTimeout(timeoutId);\n child.kill();\n reject(new Error(\"stdout maxBuffer exceeded\"));\n return;\n }\n });\n\n child.stderr?.on(\"data\", (chunk: Buffer) => {\n stderrChunks.push(chunk);\n stderrLength += chunk.length;\n\n if (maxBuffer > 0 && stderrLength > maxBuffer) {\n if (settled) return;\n settled = true;\n if (timeoutId) clearTimeout(timeoutId);\n child.kill();\n reject(new Error(\"stderr maxBuffer exceeded\"));\n return;\n }\n });\n\n child.stdin?.end(data);\n });\n}\n"],"mappings":";;;;;;;;;;;;;;;;;AAyBA,eAAsB,eAAe,EACjC,MACA,MACA,WACA,SACA,WACsC;AACtC,QAAO,IAAI;EAAE;EAAM;EAAM;EAAW;EAAS;EAAS,CAAC;;;;;;;;;;;AAoB3D,eAAsB,IAAI,EACtB,MACA,MACA,YAAY,OAAO,MACnB,SACA,UAAU,SACiB;AAC3B,QAAO,IAAI,SAAS,SAAS,WAAW;EACpC,MAAM,eAAyB,EAAE;EACjC,MAAM,eAAyB,EAAE;EACjC,IAAI,eAAe;EACnB,IAAI,eAAe;EACnB,IAAI;EACJ,IAAI,UAAU;EAEd,MAAM,QAAQ,aAAa,MAAM,QAAQ,MAAM,EAC3C,OAAO,QACV,CAAC;AAEF,MAAI,QACA,aAAY,iBAAiB;AACzB,OAAI,WAAW,MAAM,OAAQ;AAC7B,aAAU;AACV,SAAM,MAAM;AACZ,0BAAO,IAAI,MAAM,2BAA2B,QAAQ,IAAI,CAAC;KAC1D,QAAQ;EAGf,MAAM,eAAe,YAAoB,UAAiB;AACtD,OAAI,CAAC,QACD,SAAQ,MAAM,YAAY,OAAO,IAAI,MAAM;;AAInD,QAAM,GAAG,UAAU,UAAU;AACzB,OAAI,QAAS;AACb,aAAU;AACV,OAAI,UAAW,cAAa,UAAU;AACtC,eAAY,QAAQ,CAAC,MAAM;AAC3B,0BAAO,IAAI,MAAM,kBAAkB,MAAM,UAAU,CAAC;IACtD;AAEF,QAAM,OAAO,GAAG,SAAS,YAAY,cAAc,CAAC;AACpD,QAAM,QAAQ,GAAG,SAAS,YAAY,eAAe,CAAC;AACtD,QAAM,QAAQ,GAAG,SAAS,YAAY,eAAe,CAAC;AAEtD,QAAM,GAAG,SAAS,SAAwB;AACtC,OAAI,QAAS;AACb,aAAU;AACV,OAAI,UAAW,cAAa,UAAU;GACtC,MAAM,SAAS,OAAO,OAAO,aAAa,CAAC,SAAS,OAAO;AAC3D,OAAI,SAAS,GAAG;AACZ,WAAO,IAAI,MAAM,UAAU,4BAA4B,OAAO,CAAC;AAC/D;;AAGJ,WAAQ,OAAO,OAAO,aAAa,CAAC,SAAS,OAAO,CAAC;IACvD;AAEF,QAAM,QAAQ,GAAG,SAAS,UAAkB;AACxC,gBAAa,KAAK,MAAM;AACxB,mBAAgB,MAAM;AAEtB,OAAI,YAAY,KAAK,eAAe,WAAW;AAC3C,QAAI,QAAS;AACb,cAAU;AACV,QAAI,UAAW,cAAa,UAAU;AACtC,UAAM,MAAM;AACZ,2BAAO,IAAI,MAAM,4BAA4B,CAAC;AAC9C;;IAEN;AAEF,QAAM,QAAQ,GAAG,SAAS,UAAkB;AACxC,gBAAa,KAAK,MAAM;AACxB,mBAAgB,MAAM;AAEtB,OAAI,YAAY,KAAK,eAAe,WAAW;AAC3C,QAAI,QAAS;AACb,cAAU;AACV,QAAI,UAAW,cAAa,UAAU;AACtC,UAAM,MAAM;AACZ,2BAAO,IAAI,MAAM,4BAA4B,CAAC;AAC9C;;IAEN;AAEF,QAAM,OAAO,IAAI,KAAK;GACxB"} |
+2
-2
| { | ||
| "name": "@node-minify/run", | ||
| "version": "10.3.0", | ||
| "version": "10.4.0", | ||
| "description": "exec commands for @node-minify", | ||
@@ -55,4 +55,4 @@ "keywords": [ | ||
| "devDependencies": { | ||
| "@node-minify/types": "10.3.0" | ||
| "@node-minify/types": "10.4.0" | ||
| } | ||
| } |
16221
4.03%156
6.12%