		@@ -1,1 +0,1 @@
		{"version":3,"names":["pirates","require","sourceMapSupport","piratesRevert","maps","Object","create","installSourceMapSupport","install","handleUncaughtExceptions","environment","retrieveSourceMap","filename","map","url","compile","client","inputCode","result","transform","code","register","opts","addHook","bind","exts","extensions","getDefaultExtensions","ignoreNodeModules","setOptions","revert","module","exports"],"sources":["../src/hook.cts"],"sourcesContent":["import type { IClient, Options } from \"./types.cts\";\n\nimport pirates = require(\"pirates\");\nconst sourceMapSupport: typeof import(\"@cspotcode/source-map-support\") = require(\"@cspotcode/source-map-support\");\nlet piratesRevert: () => void;\nconst maps = Object.create(null);\n\nfunction installSourceMapSupport() {\n // @ts-expect-error assign to function\n installSourceMapSupport = () => {};\n\n sourceMapSupport.install({\n handleUncaughtExceptions: false,\n environment: \"node\",\n retrieveSourceMap(filename: string) {\n const map = maps?.[filename];\n if (map) {\n return { url: null, map: map };\n } else {\n return null;\n }\n },\n });\n}\n\nfunction compile(client: IClient, inputCode: string, filename: string) {\n const result = client.transform(inputCode, filename);\n\n if (result == null) return inputCode;\n\n const { code, map } = result;\n if (map) {\n maps[filename] = map;\n installSourceMapSupport();\n }\n return code;\n}\n\nfunction register(client: IClient, opts: Options = {}) {\n if (piratesRevert) piratesRevert();\n\n piratesRevert = pirates.addHook(compile.bind(null, client), {\n exts: opts.extensions ?? client.getDefaultExtensions(),\n ignoreNodeModules: false,\n });\n\n client.setOptions(opts);\n}\n\nfunction revert() {\n if (piratesRevert) piratesRevert();\n}\n\nexport = { register, revert };\n"],"mappings":";;MAEOA,OAAO,GAAAC,OAAA,CAAW,SAAS;AAClC,MAAMC,gBAAgE,GAAGD,OAAO,CAAC,+BAA+B,CAAC;AACjH,IAAIE,aAAyB;AAC7B,MAAMC,IAAI,GAAGC,MAAM,CAACC,MAAM,CAAC,IAAI,CAAC;AAEhC,SAASC,uBAAuBA,CAAA,EAAG;EAEjCA,uBAAuB,GAAGA,CAAA,KAAM,CAAC,CAAC;EAElCL,gBAAgB,CAACM,OAAO,CAAC;IACvBC,wBAAwB,EAAE,KAAK;IAC/BC,WAAW,EAAE,MAAM;IACnBC,iBAAiBA,CAACC,QAAgB,EAAE;MAClC,MAAMC,GAAG,GAAGT,IAAI,GAAGQ,QAAQ,CAAC;MAC5B,IAAIC,GAAG,EAAE;QACP,OAAO;UAAEC,GAAG,EAAE,IAAI;UAAED,GAAG,EAAEA;QAAI,CAAC;MAChC,CAAC,MAAM;QACL,OAAO,IAAI;MACb;IACF;EACF,CAAC,CAAC;AACJ;AAEA,SAASE,OAAOA,CAACC,MAAe,EAAEC,SAAiB,EAAEL,QAAgB,EAAE;EACrE,MAAMM,MAAM,GAAGF,MAAM,CAACG,SAAS,CAACF,SAAS,EAAEL,QAAQ,CAAC;EAEpD,IAAIM,MAAM,IAAI,IAAI,EAAE,OAAOD,SAAS;EAEpC,MAAM;IAAEG,IAAI;IAAEP;EAAI,CAAC,GAAGK,MAAM;EAC5B,IAAIL,GAAG,EAAE;IACPT,IAAI,CAACQ,QAAQ,CAAC,GAAGC,GAAG;IACpBN,uBAAuB,CAAC,CAAC;EAC3B;EACA,OAAOa,IAAI;AACb;AAEA,SAASC,QAAQA,CAACL,MAAe,EAAEM,IAAa,GAAG,CAAC,CAAC,EAAE;EACrD,IAAInB,aAAa,EAAEA,aAAa,CAAC,CAAC;EAElCA,aAAa,GAAGH,OAAO,CAACuB,OAAO,CAACR,OAAO,CAACS,IAAI,CAAC,IAAI,EAAER,MAAM,CAAC,EAAE;IAC1DS,IAAI,EAAEH,IAAI,CAACI,UAAU,IAAIV,MAAM,CAACW,oBAAoB,CAAC,CAAC;IACtDC,iBAAiB,EAAE;EACrB,CAAC,CAAC;EAEFZ,MAAM,CAACa,UAAU,CAACP,IAAI,CAAC;AACzB;AAEA,SAASQ,MAAMA,CAAA,EAAG;EAChB,IAAI3B,aAAa,EAAEA,aAAa,CAAC,CAAC;AACpC;AAAC4B,MAAA,CAAAC,OAAA,GAEQ;EAAEX,QAAQ;EAAES;AAAO,CAAC","ignoreList":[]}
		{"version":3,"names":["pirates","require","sourceMapSupport","piratesRevert","maps","Object","create","installSourceMapSupport","install","handleUncaughtExceptions","environment","retrieveSourceMap","filename","map","url","compile","client","inputCode","result","transform","code","register","opts","addHook","bind","exts","extensions","getDefaultExtensions","ignoreNodeModules","setOptions","revert","module","exports"],"sources":["../src/hook.cts"],"sourcesContent":["import type { IClient, Options } from \"./types.cts\";\n\nimport pirates = require(\"pirates\");\nconst sourceMapSupport: typeof import(\"@cspotcode/source-map-support\") = require(\"@cspotcode/source-map-support\");\nlet piratesRevert: () => void;\nconst maps = Object.create(null);\n\nfunction installSourceMapSupport() {\n // @ts-expect-error assign to function\n installSourceMapSupport = () => {};\n\n sourceMapSupport.install({\n handleUncaughtExceptions: false,\n environment: \"node\",\n // @ts-expect-error FIXME: url can be null?\n retrieveSourceMap(filename: string) {\n const map = maps?.[filename];\n if (map) {\n return { url: null, map: map };\n } else {\n return null;\n }\n },\n });\n}\n\nfunction compile(client: IClient, inputCode: string, filename: string) {\n const result = client.transform(inputCode, filename);\n\n if (result == null) return inputCode;\n\n const { code, map } = result;\n if (map) {\n maps[filename] = map;\n installSourceMapSupport();\n }\n return code;\n}\n\nfunction register(client: IClient, opts: Options = {}) {\n if (piratesRevert) piratesRevert();\n\n piratesRevert = pirates.addHook(compile.bind(null, client), {\n exts: opts.extensions ?? client.getDefaultExtensions(),\n ignoreNodeModules: false,\n });\n\n client.setOptions(opts);\n}\n\nfunction revert() {\n if (piratesRevert) piratesRevert();\n}\n\nexport = { register, revert };\n"],"mappings":";;MAEOA,OAAO,GAAAC,OAAA,CAAW,SAAS;AAClC,MAAMC,gBAAgE,GAAGD,OAAO,CAAC,+BAA+B,CAAC;AACjH,IAAIE,aAAyB;AAC7B,MAAMC,IAAI,GAAGC,MAAM,CAACC,MAAM,CAAC,IAAI,CAAC;AAEhC,SAASC,uBAAuBA,CAAA,EAAG;EAEjCA,uBAAuB,GAAGA,CAAA,KAAM,CAAC,CAAC;EAElCL,gBAAgB,CAACM,OAAO,CAAC;IACvBC,wBAAwB,EAAE,KAAK;IAC/BC,WAAW,EAAE,MAAM;IAEnBC,iBAAiBA,CAACC,QAAgB,EAAE;MAClC,MAAMC,GAAG,GAAGT,IAAI,GAAGQ,QAAQ,CAAC;MAC5B,IAAIC,GAAG,EAAE;QACP,OAAO;UAAEC,GAAG,EAAE,IAAI;UAAED,GAAG,EAAEA;QAAI,CAAC;MAChC,CAAC,MAAM;QACL,OAAO,IAAI;MACb;IACF;EACF,CAAC,CAAC;AACJ;AAEA,SAASE,OAAOA,CAACC,MAAe,EAAEC,SAAiB,EAAEL,QAAgB,EAAE;EACrE,MAAMM,MAAM,GAAGF,MAAM,CAACG,SAAS,CAACF,SAAS,EAAEL,QAAQ,CAAC;EAEpD,IAAIM,MAAM,IAAI,IAAI,EAAE,OAAOD,SAAS;EAEpC,MAAM;IAAEG,IAAI;IAAEP;EAAI,CAAC,GAAGK,MAAM;EAC5B,IAAIL,GAAG,EAAE;IACPT,IAAI,CAACQ,QAAQ,CAAC,GAAGC,GAAG;IACpBN,uBAAuB,CAAC,CAAC;EAC3B;EACA,OAAOa,IAAI;AACb;AAEA,SAASC,QAAQA,CAACL,MAAe,EAAEM,IAAa,GAAG,CAAC,CAAC,EAAE;EACrD,IAAInB,aAAa,EAAEA,aAAa,CAAC,CAAC;EAElCA,aAAa,GAAGH,OAAO,CAACuB,OAAO,CAACR,OAAO,CAACS,IAAI,CAAC,IAAI,EAAER,MAAM,CAAC,EAAE;IAC1DS,IAAI,EAAEH,IAAI,CAACI,UAAU,IAAIV,MAAM,CAACW,oBAAoB,CAAC,CAAC;IACtDC,iBAAiB,EAAE;EACrB,CAAC,CAAC;EAEFZ,MAAM,CAACa,UAAU,CAACP,IAAI,CAAC;AACzB;AAEA,SAASQ,MAAMA,CAAA,EAAG;EAChB,IAAI3B,aAAa,EAAEA,aAAa,CAAC,CAAC;AACpC;AAAC4B,MAAA,CAAAC,OAAA,GAEQ;EAAEX,QAAQ;EAAES;AAAO,CAAC","ignoreList":[]}

+1

-1

lib/worker-client.cjs.map

		@@ -1,1 +0,1 @@
		{"version":3,"names":["types","require","ACTIONS","worker_threads","path","markInRegisterWorker","Client","send","constructor","eCache","getDefaultExtensions","GET_DEFAULT_EXTENSIONS","undefined","setOptions","options","SET_OPTIONS","transform","code","filename","TRANSFORM","close","CLOSE","WorkerClient","worker","Worker","resolve","__dirname","env","process","signal","Int32Array","SharedArrayBuffer","action","payload","subChannel","MessageChannel","postMessage","port","port1","Atomics","wait","message","receiveMessageOnPort","port2","error","Object","assign","errorData","result","unref","module","exports"],"sources":["../src/worker-client.cts"],"sourcesContent":["import type { IClient, Options } from \"./types.cts\";\nimport types = require(\"./types.cts\");\nimport ACTIONS = types.ACTIONS;\n\nimport worker_threads = require(\"node:worker_threads\");\nimport path = require(\"node:path\");\n\nconst { markInRegisterWorker } = require(\"./is-in-register-worker.cjs\");\n\nclass Client implements IClient {\n #send;\n\n constructor(send: (action: ACTIONS, payload: any) => any) {\n this.#send = send;\n }\n\n #eCache: string[];\n getDefaultExtensions(): string[] {\n return (this.#eCache ??= this.#send(\n ACTIONS.GET_DEFAULT_EXTENSIONS,\n undefined,\n ));\n }\n\n setOptions(options: Options): void {\n return this.#send(ACTIONS.SET_OPTIONS, options);\n }\n\n transform(\n code: string,\n filename: string,\n ): { code: string; map: object } \| null {\n return this.#send(ACTIONS.TRANSFORM, { code, filename });\n }\n\n close() {\n this.#send(ACTIONS.CLOSE, undefined);\n }\n}\n\n// We need to run Babel in a worker because require hooks must\n// run synchronously, but many steps of Babel's config loading\n// (which is done for each file) can be asynchronous\nclass WorkerClient extends Client {\n #worker = new worker_threads.Worker(\n path.resolve(__dirname, \"./worker/index.mjs\"),\n { env: markInRegisterWorker(process.env) },\n );\n\n #signal = new Int32Array(new SharedArrayBuffer(4));\n\n constructor() {\n super((action, payload) => {\n this.#signal[0] = 0;\n const subChannel = new worker_threads.MessageChannel();\n\n this.#worker.postMessage(\n { signal: this.#signal, port: subChannel.port1, action, payload },\n [subChannel.port1],\n );\n\n Atomics.wait(this.#signal, 0, 0);\n const { message } = worker_threads.receiveMessageOnPort(subChannel.port2);\n\n if (message.error) throw Object.assign(message.error, message.errorData);\n else return message.result;\n });\n\n // The worker will never exit by itself. Prevent it from keeping\n // the main process alive.\n this.#worker.unref();\n }\n}\n\nexport = { WorkerClient };\n"],"mappings":";;MACOA,KAAK,GAAAC,OAAA,CAAW,aAAa;AAAA,IAC7BC,OAAO,GAAGF,KAAK,CAACE,OAAO;AAAA,MAEvBC,cAAc,GAAAF,OAAA,CAAW,qBAAqB;AAAA,MAC9CG,IAAI,GAAAH,OAAA,CAAW,WAAW;AAEjC,MAAM;EAAEI;AAAqB,CAAC,GAAGJ,OAAO,CAAC,6BAA6B,CAAC;AAEvE,MAAMK,MAAM,CAAoB;EAC9B,CAACC,IAAI;EAELC,WAAWA,CAACD,IAA4C,EAAE;IACxD,IAAI,CAAC,CAACA,IAAI,GAAGA,IAAI;EACnB;EAEA,CAACE,MAAM;EACPC,oBAAoBA,CAAA,EAAa;IAC/B,OAAQ,IAAI,CAAC,CAACD,MAAM,KAAK,IAAI,CAAC,CAACF,IAAI,CACjCL,OAAO,CAACS,sBAAsB,EAC9BC,SACF,CAAC;EACH;EAEAC,UAAUA,CAACC,OAAgB,EAAQ;IACjC,OAAO,IAAI,CAAC,CAACP,IAAI,CAACL,OAAO,CAACa,WAAW,EAAED,OAAO,CAAC;EACjD;EAEAE,SAASA,CACPC,IAAY,EACZC,QAAgB,EACsB;IACtC,OAAO,IAAI,CAAC,CAACX,IAAI,CAACL,OAAO,CAACiB,SAAS,EAAE;MAAEF,IAAI;MAAEC;IAAS,CAAC,CAAC;EAC1D;EAEAE,KAAKA,CAAA,EAAG;IACN,IAAI,CAAC,CAACb,IAAI,CAACL,OAAO,CAACmB,KAAK,EAAET,SAAS,CAAC;EACtC;AACF;AAKA,MAAMU,YAAY,SAAShB,MAAM,CAAC;EAChC,CAACiB,MAAM,GAAG,IAAIpB,cAAc,CAACqB,MAAM,CACjCpB,IAAI,CAACqB,OAAO,CAACC,SAAS,EAAE,oBAAoB,CAAC,EAC7C;IAAEC,GAAG,EAAEtB,oBAAoB,CAACuB,OAAO,CAACD,GAAG;EAAE,CAC3C,CAAC;EAED,CAACE,MAAM,GAAG,IAAIC,UAAU,CAAC,IAAIC,iBAAiB,CAAC,CAAC,CAAC,CAAC;EAElDvB,WAAWA,CAAA,EAAG;IACZ,KAAK,CAAC,CAACwB,MAAM,EAAEC,OAAO,KAAK;MACzB,IAAI,CAAC,CAACJ,MAAM,CAAC,CAAC,CAAC,GAAG,CAAC;MACnB,MAAMK,UAAU,GAAG,IAAI/B,cAAc,CAACgC,cAAc,CAAC,CAAC;MAEtD,IAAI,CAAC,CAACZ,MAAM,CAACa,WAAW,CACtB;QAAEP,MAAM,EAAE,IAAI,CAAC,CAACA,MAAM;QAAEQ,IAAI,EAAEH,UAAU,CAACI,KAAK;QAAEN,MAAM;QAAEC;MAAQ,CAAC,EACjE,CAACC,UAAU,CAACI,KAAK,CACnB,CAAC;MAEDC,OAAO,CAACC,IAAI,CAAC,IAAI,CAAC,CAACX,MAAM,EAAE,CAAC,EAAE,CAAC,CAAC;MAChC,MAAM;QAAEY;MAAQ,CAAC,GAAGtC,cAAc,CAACuC,oBAAoB,CAACR,UAAU,CAACS,KAAK,CAAC;MAEzE,IAAIF,OAAO,CAACG,KAAK,EAAE,MAAMC,MAAM,CAACC,MAAM,CAACL,OAAO,CAACG,KAAK,EAAEH,OAAO,CAACM,SAAS,CAAC,CAAC,KACpE,OAAON,OAAO,CAACO,MAAM;IAC5B,CAAC,CAAC;IAIF,IAAI,CAAC,CAACzB,MAAM,CAAC0B,KAAK,CAAC,CAAC;EACtB;AACF;AAACC,MAAA,CAAAC,OAAA,GAEQ;EAAE7B;AAAa,CAAC","ignoreList":[]}
		{"version":3,"names":["types","require","ACTIONS","worker_threads","path","markInRegisterWorker","Client","send","constructor","eCache","getDefaultExtensions","GET_DEFAULT_EXTENSIONS","undefined","setOptions","options","SET_OPTIONS","transform","code","filename","TRANSFORM","close","CLOSE","WorkerClient","worker","Worker","resolve","__dirname","env","process","signal","Int32Array","SharedArrayBuffer","action","payload","subChannel","MessageChannel","postMessage","port","port1","Atomics","wait","message","receiveMessageOnPort","port2","error","Object","assign","errorData","result","unref","module","exports"],"sources":["../src/worker-client.cts"],"sourcesContent":["import type { IClient, Options } from \"./types.cts\";\nimport types = require(\"./types.cts\");\nimport ACTIONS = types.ACTIONS;\n\nimport worker_threads = require(\"node:worker_threads\");\nimport path = require(\"node:path\");\n\nconst { markInRegisterWorker } = require(\"./is-in-register-worker.cjs\");\n\nclass Client implements IClient {\n #send;\n\n constructor(send: (action: ACTIONS, payload: any) => any) {\n this.#send = send;\n }\n\n #eCache: string[] \| undefined;\n getDefaultExtensions(): string[] {\n return (this.#eCache ??= this.#send(\n ACTIONS.GET_DEFAULT_EXTENSIONS,\n undefined,\n ));\n }\n\n setOptions(options: Options): void {\n return this.#send(ACTIONS.SET_OPTIONS, options);\n }\n\n transform(\n code: string,\n filename: string,\n ): { code: string; map: object } \| null {\n return this.#send(ACTIONS.TRANSFORM, { code, filename });\n }\n\n close() {\n this.#send(ACTIONS.CLOSE, undefined);\n }\n}\n\n// We need to run Babel in a worker because require hooks must\n// run synchronously, but many steps of Babel's config loading\n// (which is done for each file) can be asynchronous\nclass WorkerClient extends Client {\n #worker = new worker_threads.Worker(\n path.resolve(__dirname, \"./worker/index.mjs\"),\n { env: markInRegisterWorker(process.env) },\n );\n\n #signal = new Int32Array(new SharedArrayBuffer(4));\n\n constructor() {\n super((action, payload) => {\n this.#signal[0] = 0;\n const subChannel = new worker_threads.MessageChannel();\n\n this.#worker.postMessage(\n { signal: this.#signal, port: subChannel.port1, action, payload },\n [subChannel.port1],\n );\n\n Atomics.wait(this.#signal, 0, 0);\n const { message } = worker_threads.receiveMessageOnPort(\n subChannel.port2,\n )!;\n\n if (message.error) throw Object.assign(message.error, message.errorData);\n else return message.result;\n });\n\n // The worker will never exit by itself. Prevent it from keeping\n // the main process alive.\n this.#worker.unref();\n }\n}\n\nexport = { WorkerClient };\n"],"mappings":";;MACOA,KAAK,GAAAC,OAAA,CAAW,aAAa;AAAA,IAC7BC,OAAO,GAAGF,KAAK,CAACE,OAAO;AAAA,MAEvBC,cAAc,GAAAF,OAAA,CAAW,qBAAqB;AAAA,MAC9CG,IAAI,GAAAH,OAAA,CAAW,WAAW;AAEjC,MAAM;EAAEI;AAAqB,CAAC,GAAGJ,OAAO,CAAC,6BAA6B,CAAC;AAEvE,MAAMK,MAAM,CAAoB;EAC9B,CAACC,IAAI;EAELC,WAAWA,CAACD,IAA4C,EAAE;IACxD,IAAI,CAAC,CAACA,IAAI,GAAGA,IAAI;EACnB;EAEA,CAACE,MAAM;EACPC,oBAAoBA,CAAA,EAAa;IAC/B,OAAQ,IAAI,CAAC,CAACD,MAAM,KAAK,IAAI,CAAC,CAACF,IAAI,CACjCL,OAAO,CAACS,sBAAsB,EAC9BC,SACF,CAAC;EACH;EAEAC,UAAUA,CAACC,OAAgB,EAAQ;IACjC,OAAO,IAAI,CAAC,CAACP,IAAI,CAACL,OAAO,CAACa,WAAW,EAAED,OAAO,CAAC;EACjD;EAEAE,SAASA,CACPC,IAAY,EACZC,QAAgB,EACsB;IACtC,OAAO,IAAI,CAAC,CAACX,IAAI,CAACL,OAAO,CAACiB,SAAS,EAAE;MAAEF,IAAI;MAAEC;IAAS,CAAC,CAAC;EAC1D;EAEAE,KAAKA,CAAA,EAAG;IACN,IAAI,CAAC,CAACb,IAAI,CAACL,OAAO,CAACmB,KAAK,EAAET,SAAS,CAAC;EACtC;AACF;AAKA,MAAMU,YAAY,SAAShB,MAAM,CAAC;EAChC,CAACiB,MAAM,GAAG,IAAIpB,cAAc,CAACqB,MAAM,CACjCpB,IAAI,CAACqB,OAAO,CAACC,SAAS,EAAE,oBAAoB,CAAC,EAC7C;IAAEC,GAAG,EAAEtB,oBAAoB,CAACuB,OAAO,CAACD,GAAG;EAAE,CAC3C,CAAC;EAED,CAACE,MAAM,GAAG,IAAIC,UAAU,CAAC,IAAIC,iBAAiB,CAAC,CAAC,CAAC,CAAC;EAElDvB,WAAWA,CAAA,EAAG;IACZ,KAAK,CAAC,CAACwB,MAAM,EAAEC,OAAO,KAAK;MACzB,IAAI,CAAC,CAACJ,MAAM,CAAC,CAAC,CAAC,GAAG,CAAC;MACnB,MAAMK,UAAU,GAAG,IAAI/B,cAAc,CAACgC,cAAc,CAAC,CAAC;MAEtD,IAAI,CAAC,CAACZ,MAAM,CAACa,WAAW,CACtB;QAAEP,MAAM,EAAE,IAAI,CAAC,CAACA,MAAM;QAAEQ,IAAI,EAAEH,UAAU,CAACI,KAAK;QAAEN,MAAM;QAAEC;MAAQ,CAAC,EACjE,CAACC,UAAU,CAACI,KAAK,CACnB,CAAC;MAEDC,OAAO,CAACC,IAAI,CAAC,IAAI,CAAC,CAACX,MAAM,EAAE,CAAC,EAAE,CAAC,CAAC;MAChC,MAAM;QAAEY;MAAQ,CAAC,GAAGtC,cAAc,CAACuC,oBAAoB,CACrDR,UAAU,CAACS,KACb,CAAE;MAEF,IAAIF,OAAO,CAACG,KAAK,EAAE,MAAMC,MAAM,CAACC,MAAM,CAACL,OAAO,CAACG,KAAK,EAAEH,OAAO,CAACM,SAAS,CAAC,CAAC,KACpE,OAAON,OAAO,CAACO,MAAM;IAC5B,CAAC,CAAC;IAIF,IAAI,CAAC,CAACzB,MAAM,CAAC0B,KAAK,CAAC,CAAC;EACtB;AACF;AAACC,MAAA,CAAAC,OAAA,GAEQ;EAAE7B;AAAa,CAAC","ignoreList":[]}

+1

-1

lib/worker/index.mjs.map

		@@ -1,1 +0,1 @@
		{"version":3,"names":["handleMessage","parentPort","addListener","signal","port","action","payload","response","result","error","errorData","postMessage","Error","close","Atomics","store","notify"],"sources":["../../src/worker/index.mts"],"sourcesContent":["import type { ACTIONS } from \"../types.cts\";\n\nimport handleMessage from \"./handle-message.mts\";\n\nimport { parentPort, type MessagePort } from \"node:worker_threads\";\n\nparentPort.addListener(\n \"message\",\n\n // eslint-disable-next-line @typescript-eslint/no-misused-promises\n async ({\n signal,\n port,\n action,\n payload,\n }: {\n signal: Int32Array;\n port: MessagePort;\n action: ACTIONS;\n payload: any;\n }) => {\n let response;\n\n try {\n response = { result: await handleMessage(action, payload) };\n } catch (error) {\n response = { error, errorData: { ...error } };\n }\n\n try {\n port.postMessage(response);\n } catch {\n port.postMessage({\n error: new Error(\"Cannot serialize worker response\"),\n });\n } finally {\n port.close();\n Atomics.store(signal, 0, 1);\n Atomics.notify(signal, 0);\n }\n },\n);\n"],"mappings":"AAEA,OAAOA,aAAa,MAAM,sBAAsB;AAEhD,SAASC,UAAU,QAA0B,qBAAqB;AAElEA,UAAU,CAACC,WAAW,CACpB,SAAS,EAGT,OAAO;EACLC,MAAM;EACNC,IAAI;EACJC,MAAM;EACNC;AAMF,CAAC,KAAK;EACJ,IAAIC,QAAQ;EAEZ,IAAI;IACFA,QAAQ,GAAG;MAAEC,MAAM,EAAE,MAAMR,aAAa,CAACK,MAAM,EAAEC,OAAO;IAAE,CAAC;EAC7D,CAAC,CAAC,OAAOG,KAAK,EAAE;IACdF,QAAQ,GAAG;MAAEE,KAAK;MAAEC,SAAS,EAAE;QAAE,GAAGD;MAAM;IAAE,CAAC;EAC/C;EAEA,IAAI;IACFL,IAAI,CAACO,WAAW,CAACJ,QAAQ,CAAC;EAC5B,CAAC,CAAC,MAAM;IACNH,IAAI,CAACO,WAAW,CAAC;MACfF,KAAK,EAAE,IAAIG,KAAK,CAAC,kCAAkC;IACrD,CAAC,CAAC;EACJ,CAAC,SAAS;IACRR,IAAI,CAACS,KAAK,CAAC,CAAC;IACZC,OAAO,CAACC,KAAK,CAACZ,MAAM,EAAE,CAAC,EAAE,CAAC,CAAC;IAC3BW,OAAO,CAACE,MAAM,CAACb,MAAM,EAAE,CAAC,CAAC;EAC3B;AACF,CACF,CAAC","ignoreList":[]}
		{"version":3,"names":["handleMessage","parentPort","addListener","signal","port","action","payload","response","result","error","errorData","postMessage","Error","close","Atomics","store","notify"],"sources":["../../src/worker/index.mts"],"sourcesContent":["import type { ACTIONS } from \"../types.cts\";\n\nimport handleMessage from \"./handle-message.mts\";\n\nimport { parentPort, type MessagePort } from \"node:worker_threads\";\n\nparentPort!.addListener(\n \"message\",\n\n // eslint-disable-next-line @typescript-eslint/no-misused-promises\n async ({\n signal,\n port,\n action,\n payload,\n }: {\n signal: Int32Array;\n port: MessagePort;\n action: ACTIONS;\n payload: any;\n }) => {\n let response;\n\n try {\n response = { result: await handleMessage(action, payload) };\n } catch (error) {\n response = { error, errorData: { ...error } };\n }\n\n try {\n port.postMessage(response);\n } catch {\n port.postMessage({\n error: new Error(\"Cannot serialize worker response\"),\n });\n } finally {\n port.close();\n Atomics.store(signal, 0, 1);\n Atomics.notify(signal, 0);\n }\n },\n);\n"],"mappings":"AAEA,OAAOA,aAAa,MAAM,sBAAsB;AAEhD,SAASC,UAAU,QAA0B,qBAAqB;AAElEA,UAAU,CAAEC,WAAW,CACrB,SAAS,EAGT,OAAO;EACLC,MAAM;EACNC,IAAI;EACJC,MAAM;EACNC;AAMF,CAAC,KAAK;EACJ,IAAIC,QAAQ;EAEZ,IAAI;IACFA,QAAQ,GAAG;MAAEC,MAAM,EAAE,MAAMR,aAAa,CAACK,MAAM,EAAEC,OAAO;IAAE,CAAC;EAC7D,CAAC,CAAC,OAAOG,KAAK,EAAE;IACdF,QAAQ,GAAG;MAAEE,KAAK;MAAEC,SAAS,EAAE;QAAE,GAAGD;MAAM;IAAE,CAAC;EAC/C;EAEA,IAAI;IACFL,IAAI,CAACO,WAAW,CAACJ,QAAQ,CAAC;EAC5B,CAAC,CAAC,MAAM;IACNH,IAAI,CAACO,WAAW,CAAC;MACfF,KAAK,EAAE,IAAIG,KAAK,CAAC,kCAAkC;IACrD,CAAC,CAAC;EACJ,CAAC,SAAS;IACRR,IAAI,CAACS,KAAK,CAAC,CAAC;IACZC,OAAO,CAACC,KAAK,CAACZ,MAAM,EAAE,CAAC,EAAE,CAAC,CAAC;IAC3BW,OAAO,CAACE,MAAM,CAACb,MAAM,EAAE,CAAC,CAAC;EAC3B;AACF,CACF,CAAC","ignoreList":[]}

+5

-6

package.json

		{
		"name": "@babel/register",
		"version": "8.0.0-rc.2",
		"version": "8.0.0-rc.3",
		"description": "babel require hook",
		@@ -25,8 +25,8 @@ "license": "MIT",
		"peerDependencies": {
		"@babel/core": "^8.0.0-rc.2"
		"@babel/core": "^8.0.0-rc.3"
		},
		"devDependencies": {
		"@babel/core": "^8.0.0-rc.2",
		"@babel/plugin-transform-arrow-functions": "^8.0.0-rc.2",
		"@babel/plugin-transform-modules-commonjs": "^8.0.0-rc.2",
		"@babel/core": "^8.0.0-rc.3",
		"@babel/plugin-transform-arrow-functions": "^8.0.0-rc.3",
		"@babel/plugin-transform-modules-commonjs": "^8.0.0-rc.3",
		"@types/cacache": "^20.0.0"
		@@ -41,3 +41,2 @@ },
		".": {
		"types": "./lib/index.d.ts",
		"default": "./lib/index.cjs"
		@@ -44,0 +43,0 @@ },

@babel/register - npm Package Compare versions

New alerts

Fixed alerts

Improved metrics