@polarity-dev/lambda-local-runner - npm Package Compare versions

Comparing version 0.0.6 to 0.0.7

dist/worker-wrap.js

@@ -11,3 +11,3 @@ 'use strict';
 // src/worker-wrap.js
-var { workerData, isMainThread } = __require("worker_threads");
+var { workerData, isMainThread, parentPort } = __require("worker_threads");
 var { existsSync } = __require("fs");
@@ -19,6 +19,6 @@ var { join, isAbsolute } = __require("path");
 }
-var { id, payload, lambdaPath: inputLambdaPath } = workerData;
+var { payload, lambdaPath: inputLambdaPath } = workerData;
 var lambdaPath = isAbsolute(inputLambdaPath) ? inputLambdaPath : join(__dirname, "..", inputLambdaPath);
 if (!existsSync(lambdaPath)) {
-  console.log(`[${id}] File ${lambdaPath} not found`);
+  parentPort.postMessage({ error: `File ${lambdaPath} not found` });
   process.exit(1);
@@ -29,3 +29,3 @@ }
 if (!handler) {
-  console.log(`[${id}] Handler function in ${lambdaPath} not found`);
+  parentPort.postMessage({ error: `Handler function in ${lambdaPath} not found` });
   process.exit(1);
@@ -37,10 +37,10 @@ }
   result.then((data) => {
-    console.log(`[${id}] Worker finished with result ${JSON.stringify(data)}`);
+    parentPort.postMessage({ data });
   }).catch((error) => {
-    console.error(`[${id}] Worker finished with error ${JSON.stringify(error)}`);
+    parentPort.postMessage({ error });
   });
 } else {
-  console.log(`[${id}] Worker finished with result ${JSON.stringify(result)}`);
+  parentPort.postMessage({ data: result });
 }
 //# sourceMappingURL=worker-wrap.js.map
 //# sourceMappingURL=worker-wrap.js.map

dist/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,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"]}
+{"version":3,"sources":["../src/worker-wrap.js"],"names":[],"mappings":";;;;;;;;;;AAAA,IAAM,EAAE,UAAY,EAAA,YAAA,EAAc,UAAW,EAAA,GAAI,UAAQ,gBAAgB,CAAA;AACzE,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,OAAA,EAAS,UAAY,EAAA,eAAA,EAAoB,GAAA,UAAA;AACjD,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,UAAA,CAAW,YAAY,EAAE,KAAA,EAAO,CAAQ,KAAA,EAAA,UAAU,cAAc,CAAA;AAChE,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,UAAA,CAAW,YAAY,EAAE,KAAA,EAAO,CAAuB,oBAAA,EAAA,UAAU,cAAc,CAAA;AAC/E,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,IAAW,UAAA,CAAA,WAAA,CAAY,EAAE,IAAA,EAAM,CAAA;AAAA,GAClC,CAAA,CAAE,KAAM,CAAA,CAAC,KAAU,KAAA;AAChB,IAAW,UAAA,CAAA,WAAA,CAAY,EAAE,KAAA,EAAO,CAAA;AAAA,GACnC,CAAA;AACL,CAAO,MAAA;AACH,EAAA,UAAA,CAAW,WAAY,CAAA,EAAE,IAAM,EAAA,MAAA,EAAQ,CAAA;AAC3C","file":"worker-wrap.js","sourcesContent":["const { workerData, isMainThread, parentPort } = 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 { payload, lambdaPath: inputLambdaPath } = workerData\nconst lambdaPath = isAbsolute(inputLambdaPath) ? inputLambdaPath : join(__dirname, \"..\", inputLambdaPath)\n\nif (!existsSync(lambdaPath)) {\n    parentPort.postMessage({ error: `File ${lambdaPath} not found` })\n    process.exit(1)\n}\n\nconst lambda = require(lambdaPath)\nconst { handler } = lambda\n\nif (!handler) {\n    parentPort.postMessage({ error: `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        parentPort.postMessage({ data })\n    }).catch((error) => {\n        parentPort.postMessage({ error })\n    })\n} else {\n    parentPort.postMessage({ data: result })\n}\n"]}

dist/worker-wrap.mjs

@@ -9,3 +9,3 @@ var __require = /* @__PURE__ */ ((x) => typeof require !== "undefined" ? require : typeof Proxy !== "undefined" ? new Proxy(x, {
 // src/worker-wrap.js
-var { workerData, isMainThread } = __require("worker_threads");
+var { workerData, isMainThread, parentPort } = __require("worker_threads");
 var { existsSync } = __require("fs");
@@ -17,6 +17,6 @@ var { join, isAbsolute } = __require("path");
 }
-var { id, payload, lambdaPath: inputLambdaPath } = workerData;
+var { payload, lambdaPath: inputLambdaPath } = workerData;
 var lambdaPath = isAbsolute(inputLambdaPath) ? inputLambdaPath : join(__dirname, "..", inputLambdaPath);
 if (!existsSync(lambdaPath)) {
-  console.log(`[${id}] File ${lambdaPath} not found`);
+  parentPort.postMessage({ error: `File ${lambdaPath} not found` });
   process.exit(1);
@@ -27,3 +27,3 @@ }
 if (!handler) {
-  console.log(`[${id}] Handler function in ${lambdaPath} not found`);
+  parentPort.postMessage({ error: `Handler function in ${lambdaPath} not found` });
   process.exit(1);
@@ -35,10 +35,10 @@ }
   result.then((data) => {
-    console.log(`[${id}] Worker finished with result ${JSON.stringify(data)}`);
+    parentPort.postMessage({ data });
   }).catch((error) => {
-    console.error(`[${id}] Worker finished with error ${JSON.stringify(error)}`);
+    parentPort.postMessage({ error });
   });
 } else {
-  console.log(`[${id}] Worker finished with result ${JSON.stringify(result)}`);
+  parentPort.postMessage({ data: result });
 }
 //# sourceMappingURL=worker-wrap.mjs.map
 //# sourceMappingURL=worker-wrap.mjs.map

dist/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,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"]}
+{"version":3,"sources":["../src/worker-wrap.js"],"names":[],"mappings":";;;;;;;;AAAA,IAAM,EAAE,UAAY,EAAA,YAAA,EAAc,UAAW,EAAA,GAAI,UAAQ,gBAAgB,CAAA;AACzE,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,OAAA,EAAS,UAAY,EAAA,eAAA,EAAoB,GAAA,UAAA;AACjD,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,UAAA,CAAW,YAAY,EAAE,KAAA,EAAO,CAAQ,KAAA,EAAA,UAAU,cAAc,CAAA;AAChE,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,UAAA,CAAW,YAAY,EAAE,KAAA,EAAO,CAAuB,oBAAA,EAAA,UAAU,cAAc,CAAA;AAC/E,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,IAAW,UAAA,CAAA,WAAA,CAAY,EAAE,IAAA,EAAM,CAAA;AAAA,GAClC,CAAA,CAAE,KAAM,CAAA,CAAC,KAAU,KAAA;AAChB,IAAW,UAAA,CAAA,WAAA,CAAY,EAAE,KAAA,EAAO,CAAA;AAAA,GACnC,CAAA;AACL,CAAO,MAAA;AACH,EAAA,UAAA,CAAW,WAAY,CAAA,EAAE,IAAM,EAAA,MAAA,EAAQ,CAAA;AAC3C","file":"worker-wrap.mjs","sourcesContent":["const { workerData, isMainThread, parentPort } = 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 { payload, lambdaPath: inputLambdaPath } = workerData\nconst lambdaPath = isAbsolute(inputLambdaPath) ? inputLambdaPath : join(__dirname, \"..\", inputLambdaPath)\n\nif (!existsSync(lambdaPath)) {\n    parentPort.postMessage({ error: `File ${lambdaPath} not found` })\n    process.exit(1)\n}\n\nconst lambda = require(lambdaPath)\nconst { handler } = lambda\n\nif (!handler) {\n    parentPort.postMessage({ error: `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        parentPort.postMessage({ data })\n    }).catch((error) => {\n        parentPort.postMessage({ error })\n    })\n} else {\n    parentPort.postMessage({ data: result })\n}\n"]}

package.json

 {
   "name": "@polarity-dev/lambda-local-runner",
-  "version": "0.0.6",
+  "version": "0.0.7",
   "bin": {
@@ -41,3 +41,3 @@ "local-lambda": "./dist/cli.js"
     "build": "rm -rf dist && tsup ",
-    "start": "node --import tsx .",
+    "start": "node --import tsx tests/index.ts",
     "dev": "nodemon",
@@ -44,0 +44,0 @@ "typecheck": "tsc --noEmit",

New alerts

AI-detected potential malware

Supply chain risk

AI has identified this package as malware. This is a strong signal that the package may be malicious.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

14815657

0.09%

Lines of code

136851

0.08%

Worsened metrics

Number of high supply chain risk alerts

1

Infinity%

No dependency changes