@polarity-dev/lambda-local-runner
Advanced tools
@@ -34,10 +34,10 @@ 'use strict'; | ||
| result.then((data) => { | ||
| console.log(`[${id}] Worker finished with result ${data}`); | ||
| console.log(`[${id}] Worker finished with result ${JSON.stringify(data)}`); | ||
| }).catch((error) => { | ||
| console.error(`[${id}] Worker finished with error ${error}`); | ||
| console.error(`[${id}] Worker finished with error ${JSON.stringify(error)}`); | ||
| }); | ||
| } else { | ||
| console.log(`[${id}] Worker finished with result ${result}`); | ||
| console.log(`[${id}] Worker finished with result ${JSON.stringify(result)}`); | ||
| } | ||
| //# sourceMappingURL=worker-wrap.js.map | ||
| //# sourceMappingURL=worker-wrap.js.map |
@@ -1,1 +0,1 @@ | ||
| {"version":3,"sources":["../src/worker-wrap.js"],"names":[],"mappings":";;;;;;;;;;AAAA,IAAM,EAAE,UAAA,EAAY,YAAa,EAAA,GAAI,UAAQ,gBAAgB,CAAA;AAC7D,IAAM,EAAE,UAAA,EAAe,GAAA,SAAA,CAAQ,IAAI,CAAA;AACnC,IAAM,EAAE,IAAA,EAAM,UAAW,EAAA,GAAI,UAAQ,MAAM,CAAA;AAG3C,IAAI,YAAc,EAAA;AACd,EAAA,OAAA,CAAQ,IAAI,uCAAuC,CAAA;AACnD,EAAA,OAAA,CAAQ,KAAK,CAAC,CAAA;AAClB;AAEA,IAAM,EAAE,EAAA,EAAI,OAAS,EAAA,UAAA,EAAY,iBAAoB,GAAA,UAAA;AACrD,IAAM,UAAA,GAAa,WAAW,eAAe,CAAA,GAAI,kBAAkB,IAAK,CAAA,SAAA,EAAW,MAAM,eAAe,CAAA;AAExG,IAAI,CAAC,UAAW,CAAA,UAAU,CAAG,EAAA;AACzB,EAAA,OAAA,CAAQ,GAAI,CAAA,CAAA,CAAA,EAAI,EAAE,CAAA,OAAA,EAAU,UAAU,CAAY,UAAA,CAAA,CAAA;AAClD,EAAA,OAAA,CAAQ,KAAK,CAAC,CAAA;AAClB;AAEA,IAAM,MAAA,GAAS,UAAQ,UAAU,CAAA;AACjC,IAAM,EAAE,SAAY,GAAA,MAAA;AAEpB,IAAI,CAAC,OAAS,EAAA;AACV,EAAA,OAAA,CAAQ,GAAI,CAAA,CAAA,CAAA,EAAI,EAAE,CAAA,sBAAA,EAAyB,UAAU,CAAY,UAAA,CAAA,CAAA;AACjE,EAAA,OAAA,CAAQ,KAAK,CAAC,CAAA;AAClB;AAEA,IAAM,MAAS,GAAA,OAAA,CAAQ,OAAS,EAAA,IAAA,EAAM,MAAM;AAAE,CAAC,CAAA;AAE/C,IAAI,kBAAkB,OAAS,EAAA;AAC3B,EAAO,MAAA,CAAA,IAAA,CAAK,CAAC,IAAS,KAAA;AAClB,IAAA,OAAA,CAAQ,GAAI,CAAA,CAAA,CAAA,EAAI,EAAE,CAAA,8BAAA,EAAiC,IAAI,CAAE,CAAA,CAAA;AAAA,GAC5D,CAAA,CAAE,KAAM,CAAA,CAAC,KAAU,KAAA;AAChB,IAAA,OAAA,CAAQ,KAAM,CAAA,CAAA,CAAA,EAAI,EAAE,CAAA,6BAAA,EAAgC,KAAK,CAAE,CAAA,CAAA;AAAA,GAC9D,CAAA;AACL,CAAO,MAAA;AACH,EAAA,OAAA,CAAQ,GAAI,CAAA,CAAA,CAAA,EAAI,EAAE,CAAA,8BAAA,EAAiC,MAAM,CAAE,CAAA,CAAA;AAC/D","file":"worker-wrap.js","sourcesContent":["const { workerData, isMainThread } = require(\"worker_threads\")\nconst { existsSync } = require(\"fs\")\nconst { join, isAbsolute } = require(\"path\")\n\n\nif (isMainThread) {\n console.log(\"This script should be run as a worker\")\n process.exit(0)\n}\n\nconst { id, payload, lambdaPath: inputLambdaPath } = workerData\nconst lambdaPath = isAbsolute(inputLambdaPath) ? inputLambdaPath : join(__dirname, \"..\", inputLambdaPath)\n\nif (!existsSync(lambdaPath)) {\n console.log(`[${id}] File ${lambdaPath} not found`)\n process.exit(1)\n}\n\nconst lambda = require(lambdaPath)\nconst { handler } = lambda\n\nif (!handler) {\n console.log(`[${id}] Handler function in ${lambdaPath} not found`)\n process.exit(1)\n}\n\nconst result = handler(payload, null, () => { })\n\nif (result instanceof Promise) {\n result.then((data) => {\n console.log(`[${id}] Worker finished with result ${data}`)\n }).catch((error) => {\n console.error(`[${id}] Worker finished with error ${error}`)\n })\n} else {\n console.log(`[${id}] Worker finished with result ${result}`)\n}\n"]} | ||
| {"version":3,"sources":["../src/worker-wrap.js"],"names":[],"mappings":";;;;;;;;;;AAAA,IAAM,EAAE,UAAA,EAAY,YAAa,EAAA,GAAI,UAAQ,gBAAgB,CAAA;AAC7D,IAAM,EAAE,UAAA,EAAe,GAAA,SAAA,CAAQ,IAAI,CAAA;AACnC,IAAM,EAAE,IAAA,EAAM,UAAW,EAAA,GAAI,UAAQ,MAAM,CAAA;AAG3C,IAAI,YAAc,EAAA;AACd,EAAA,OAAA,CAAQ,IAAI,uCAAuC,CAAA;AACnD,EAAA,OAAA,CAAQ,KAAK,CAAC,CAAA;AAClB;AAEA,IAAM,EAAE,EAAA,EAAI,OAAS,EAAA,UAAA,EAAY,iBAAoB,GAAA,UAAA;AACrD,IAAM,UAAA,GAAa,WAAW,eAAe,CAAA,GAAI,kBAAkB,IAAK,CAAA,SAAA,EAAW,MAAM,eAAe,CAAA;AAExG,IAAI,CAAC,UAAW,CAAA,UAAU,CAAG,EAAA;AACzB,EAAA,OAAA,CAAQ,GAAI,CAAA,CAAA,CAAA,EAAI,EAAE,CAAA,OAAA,EAAU,UAAU,CAAY,UAAA,CAAA,CAAA;AAClD,EAAA,OAAA,CAAQ,KAAK,CAAC,CAAA;AAClB;AAEA,IAAM,MAAA,GAAS,UAAQ,UAAU,CAAA;AACjC,IAAM,EAAE,SAAY,GAAA,MAAA;AAEpB,IAAI,CAAC,OAAS,EAAA;AACV,EAAA,OAAA,CAAQ,GAAI,CAAA,CAAA,CAAA,EAAI,EAAE,CAAA,sBAAA,EAAyB,UAAU,CAAY,UAAA,CAAA,CAAA;AACjE,EAAA,OAAA,CAAQ,KAAK,CAAC,CAAA;AAClB;AAEA,IAAM,MAAS,GAAA,OAAA,CAAQ,OAAS,EAAA,IAAA,EAAM,MAAM;AAAE,CAAC,CAAA;AAE/C,IAAI,kBAAkB,OAAS,EAAA;AAC3B,EAAO,MAAA,CAAA,IAAA,CAAK,CAAC,IAAS,KAAA;AAClB,IAAQ,OAAA,CAAA,GAAA,CAAI,IAAI,EAAE,CAAA,8BAAA,EAAiC,KAAK,SAAU,CAAA,IAAI,CAAC,CAAE,CAAA,CAAA;AAAA,GAC5E,CAAA,CAAE,KAAM,CAAA,CAAC,KAAU,KAAA;AAChB,IAAQ,OAAA,CAAA,KAAA,CAAM,IAAI,EAAE,CAAA,6BAAA,EAAgC,KAAK,SAAU,CAAA,KAAK,CAAC,CAAE,CAAA,CAAA;AAAA,GAC9E,CAAA;AACL,CAAO,MAAA;AACH,EAAQ,OAAA,CAAA,GAAA,CAAI,IAAI,EAAE,CAAA,8BAAA,EAAiC,KAAK,SAAU,CAAA,MAAM,CAAC,CAAE,CAAA,CAAA;AAC/E","file":"worker-wrap.js","sourcesContent":["const { workerData, isMainThread } = require(\"worker_threads\")\nconst { existsSync } = require(\"fs\")\nconst { join, isAbsolute } = require(\"path\")\n\n\nif (isMainThread) {\n console.log(\"This script should be run as a worker\")\n process.exit(0)\n}\n\nconst { id, payload, lambdaPath: inputLambdaPath } = workerData\nconst lambdaPath = isAbsolute(inputLambdaPath) ? inputLambdaPath : join(__dirname, \"..\", inputLambdaPath)\n\nif (!existsSync(lambdaPath)) {\n console.log(`[${id}] File ${lambdaPath} not found`)\n process.exit(1)\n}\n\nconst lambda = require(lambdaPath)\nconst { handler } = lambda\n\nif (!handler) {\n console.log(`[${id}] Handler function in ${lambdaPath} not found`)\n process.exit(1)\n}\n\nconst result = handler(payload, null, () => { })\n\nif (result instanceof Promise) {\n result.then((data) => {\n console.log(`[${id}] Worker finished with result ${JSON.stringify(data)}`)\n }).catch((error) => {\n console.error(`[${id}] Worker finished with error ${JSON.stringify(error)}`)\n })\n} else {\n console.log(`[${id}] Worker finished with result ${JSON.stringify(result)}`)\n}\n"]} |
@@ -32,10 +32,10 @@ var __require = /* @__PURE__ */ ((x) => typeof require !== "undefined" ? require : typeof Proxy !== "undefined" ? new Proxy(x, { | ||
| result.then((data) => { | ||
| console.log(`[${id}] Worker finished with result ${data}`); | ||
| console.log(`[${id}] Worker finished with result ${JSON.stringify(data)}`); | ||
| }).catch((error) => { | ||
| console.error(`[${id}] Worker finished with error ${error}`); | ||
| console.error(`[${id}] Worker finished with error ${JSON.stringify(error)}`); | ||
| }); | ||
| } else { | ||
| console.log(`[${id}] Worker finished with result ${result}`); | ||
| console.log(`[${id}] Worker finished with result ${JSON.stringify(result)}`); | ||
| } | ||
| //# sourceMappingURL=worker-wrap.mjs.map | ||
| //# sourceMappingURL=worker-wrap.mjs.map |
@@ -1,1 +0,1 @@ | ||
| {"version":3,"sources":["../src/worker-wrap.js"],"names":[],"mappings":";;;;;;;;AAAA,IAAM,EAAE,UAAA,EAAY,YAAa,EAAA,GAAI,UAAQ,gBAAgB,CAAA;AAC7D,IAAM,EAAE,UAAA,EAAe,GAAA,SAAA,CAAQ,IAAI,CAAA;AACnC,IAAM,EAAE,IAAA,EAAM,UAAW,EAAA,GAAI,UAAQ,MAAM,CAAA;AAG3C,IAAI,YAAc,EAAA;AACd,EAAA,OAAA,CAAQ,IAAI,uCAAuC,CAAA;AACnD,EAAA,OAAA,CAAQ,KAAK,CAAC,CAAA;AAClB;AAEA,IAAM,EAAE,EAAA,EAAI,OAAS,EAAA,UAAA,EAAY,iBAAoB,GAAA,UAAA;AACrD,IAAM,UAAA,GAAa,WAAW,eAAe,CAAA,GAAI,kBAAkB,IAAK,CAAA,SAAA,EAAW,MAAM,eAAe,CAAA;AAExG,IAAI,CAAC,UAAW,CAAA,UAAU,CAAG,EAAA;AACzB,EAAA,OAAA,CAAQ,GAAI,CAAA,CAAA,CAAA,EAAI,EAAE,CAAA,OAAA,EAAU,UAAU,CAAY,UAAA,CAAA,CAAA;AAClD,EAAA,OAAA,CAAQ,KAAK,CAAC,CAAA;AAClB;AAEA,IAAM,MAAA,GAAS,UAAQ,UAAU,CAAA;AACjC,IAAM,EAAE,SAAY,GAAA,MAAA;AAEpB,IAAI,CAAC,OAAS,EAAA;AACV,EAAA,OAAA,CAAQ,GAAI,CAAA,CAAA,CAAA,EAAI,EAAE,CAAA,sBAAA,EAAyB,UAAU,CAAY,UAAA,CAAA,CAAA;AACjE,EAAA,OAAA,CAAQ,KAAK,CAAC,CAAA;AAClB;AAEA,IAAM,MAAS,GAAA,OAAA,CAAQ,OAAS,EAAA,IAAA,EAAM,MAAM;AAAE,CAAC,CAAA;AAE/C,IAAI,kBAAkB,OAAS,EAAA;AAC3B,EAAO,MAAA,CAAA,IAAA,CAAK,CAAC,IAAS,KAAA;AAClB,IAAA,OAAA,CAAQ,GAAI,CAAA,CAAA,CAAA,EAAI,EAAE,CAAA,8BAAA,EAAiC,IAAI,CAAE,CAAA,CAAA;AAAA,GAC5D,CAAA,CAAE,KAAM,CAAA,CAAC,KAAU,KAAA;AAChB,IAAA,OAAA,CAAQ,KAAM,CAAA,CAAA,CAAA,EAAI,EAAE,CAAA,6BAAA,EAAgC,KAAK,CAAE,CAAA,CAAA;AAAA,GAC9D,CAAA;AACL,CAAO,MAAA;AACH,EAAA,OAAA,CAAQ,GAAI,CAAA,CAAA,CAAA,EAAI,EAAE,CAAA,8BAAA,EAAiC,MAAM,CAAE,CAAA,CAAA;AAC/D","file":"worker-wrap.mjs","sourcesContent":["const { workerData, isMainThread } = require(\"worker_threads\")\nconst { existsSync } = require(\"fs\")\nconst { join, isAbsolute } = require(\"path\")\n\n\nif (isMainThread) {\n console.log(\"This script should be run as a worker\")\n process.exit(0)\n}\n\nconst { id, payload, lambdaPath: inputLambdaPath } = workerData\nconst lambdaPath = isAbsolute(inputLambdaPath) ? inputLambdaPath : join(__dirname, \"..\", inputLambdaPath)\n\nif (!existsSync(lambdaPath)) {\n console.log(`[${id}] File ${lambdaPath} not found`)\n process.exit(1)\n}\n\nconst lambda = require(lambdaPath)\nconst { handler } = lambda\n\nif (!handler) {\n console.log(`[${id}] Handler function in ${lambdaPath} not found`)\n process.exit(1)\n}\n\nconst result = handler(payload, null, () => { })\n\nif (result instanceof Promise) {\n result.then((data) => {\n console.log(`[${id}] Worker finished with result ${data}`)\n }).catch((error) => {\n console.error(`[${id}] Worker finished with error ${error}`)\n })\n} else {\n console.log(`[${id}] Worker finished with result ${result}`)\n}\n"]} | ||
| {"version":3,"sources":["../src/worker-wrap.js"],"names":[],"mappings":";;;;;;;;AAAA,IAAM,EAAE,UAAA,EAAY,YAAa,EAAA,GAAI,UAAQ,gBAAgB,CAAA;AAC7D,IAAM,EAAE,UAAA,EAAe,GAAA,SAAA,CAAQ,IAAI,CAAA;AACnC,IAAM,EAAE,IAAA,EAAM,UAAW,EAAA,GAAI,UAAQ,MAAM,CAAA;AAG3C,IAAI,YAAc,EAAA;AACd,EAAA,OAAA,CAAQ,IAAI,uCAAuC,CAAA;AACnD,EAAA,OAAA,CAAQ,KAAK,CAAC,CAAA;AAClB;AAEA,IAAM,EAAE,EAAA,EAAI,OAAS,EAAA,UAAA,EAAY,iBAAoB,GAAA,UAAA;AACrD,IAAM,UAAA,GAAa,WAAW,eAAe,CAAA,GAAI,kBAAkB,IAAK,CAAA,SAAA,EAAW,MAAM,eAAe,CAAA;AAExG,IAAI,CAAC,UAAW,CAAA,UAAU,CAAG,EAAA;AACzB,EAAA,OAAA,CAAQ,GAAI,CAAA,CAAA,CAAA,EAAI,EAAE,CAAA,OAAA,EAAU,UAAU,CAAY,UAAA,CAAA,CAAA;AAClD,EAAA,OAAA,CAAQ,KAAK,CAAC,CAAA;AAClB;AAEA,IAAM,MAAA,GAAS,UAAQ,UAAU,CAAA;AACjC,IAAM,EAAE,SAAY,GAAA,MAAA;AAEpB,IAAI,CAAC,OAAS,EAAA;AACV,EAAA,OAAA,CAAQ,GAAI,CAAA,CAAA,CAAA,EAAI,EAAE,CAAA,sBAAA,EAAyB,UAAU,CAAY,UAAA,CAAA,CAAA;AACjE,EAAA,OAAA,CAAQ,KAAK,CAAC,CAAA;AAClB;AAEA,IAAM,MAAS,GAAA,OAAA,CAAQ,OAAS,EAAA,IAAA,EAAM,MAAM;AAAE,CAAC,CAAA;AAE/C,IAAI,kBAAkB,OAAS,EAAA;AAC3B,EAAO,MAAA,CAAA,IAAA,CAAK,CAAC,IAAS,KAAA;AAClB,IAAQ,OAAA,CAAA,GAAA,CAAI,IAAI,EAAE,CAAA,8BAAA,EAAiC,KAAK,SAAU,CAAA,IAAI,CAAC,CAAE,CAAA,CAAA;AAAA,GAC5E,CAAA,CAAE,KAAM,CAAA,CAAC,KAAU,KAAA;AAChB,IAAQ,OAAA,CAAA,KAAA,CAAM,IAAI,EAAE,CAAA,6BAAA,EAAgC,KAAK,SAAU,CAAA,KAAK,CAAC,CAAE,CAAA,CAAA;AAAA,GAC9E,CAAA;AACL,CAAO,MAAA;AACH,EAAQ,OAAA,CAAA,GAAA,CAAI,IAAI,EAAE,CAAA,8BAAA,EAAiC,KAAK,SAAU,CAAA,MAAM,CAAC,CAAE,CAAA,CAAA;AAC/E","file":"worker-wrap.mjs","sourcesContent":["const { workerData, isMainThread } = require(\"worker_threads\")\nconst { existsSync } = require(\"fs\")\nconst { join, isAbsolute } = require(\"path\")\n\n\nif (isMainThread) {\n console.log(\"This script should be run as a worker\")\n process.exit(0)\n}\n\nconst { id, payload, lambdaPath: inputLambdaPath } = workerData\nconst lambdaPath = isAbsolute(inputLambdaPath) ? inputLambdaPath : join(__dirname, \"..\", inputLambdaPath)\n\nif (!existsSync(lambdaPath)) {\n console.log(`[${id}] File ${lambdaPath} not found`)\n process.exit(1)\n}\n\nconst lambda = require(lambdaPath)\nconst { handler } = lambda\n\nif (!handler) {\n console.log(`[${id}] Handler function in ${lambdaPath} not found`)\n process.exit(1)\n}\n\nconst result = handler(payload, null, () => { })\n\nif (result instanceof Promise) {\n result.then((data) => {\n console.log(`[${id}] Worker finished with result ${JSON.stringify(data)}`)\n }).catch((error) => {\n console.error(`[${id}] Worker finished with error ${JSON.stringify(error)}`)\n })\n} else {\n console.log(`[${id}] Worker finished with result ${JSON.stringify(result)}`)\n}\n"]} |
+1
-1
| { | ||
| "name": "@polarity-dev/lambda-local-runner", | ||
| "version": "0.0.5", | ||
| "version": "0.0.6", | ||
| "bin": { | ||
@@ -5,0 +5,0 @@ "local-lambda": "./dist/cli.js" |
14803006
0