{"version":3,"names":["path","require","types","ACTIONS","_send","WeakMap","_eCache","Client","constructor","send","_classPrivateFieldInitSpec","_classPrivateFieldSet","getDefaultExtensions","_classPrivateFieldGet2","_classPrivateFieldGet","call","GET_DEFAULT_EXTENSIONS","undefined","setOptions","options","SET_OPTIONS","transform","code","filename","TRANSFORM","_worker","_signal","WorkerClient","action","payload","subChannel","_get_worker_threads","MessageChannel","postMessage","signal","port","port1","Atomics","wait","message","receiveMessageOnPort","port2","error","Object","assign","errorData","result","Worker","resolve","__dirname","env","_get_markInRegisterWorker","process","Int32Array","SharedArrayBuffer","unref","_this","_this2","markInRegisterWorker","module","exports","LocalClient","_LocalClient","_assertClassBrand$_","_assertClassBrand","_handleMessage","_","TRANSFORM_SYNC","isLocalClient"],"sources":["../src/worker-client.cts"],"sourcesContent":["import type { IClient, Options } from \"./types.cts\";\n\nimport path = require(\"node:path\");\nimport types = require(\"./types.cts\");\n\nimport ACTIONS = types.ACTIONS;\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\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  // These two require() calls are in deferred so that they are not imported in\n  // older Node.js versions (which don't support workers).\n  // TODO: Hoist them in Babel 8.\n\n  static get #worker_threads() {\n    return require(\"node:worker_threads\") as typeof import(\"worker_threads\");\n  }\n\n  static get #markInRegisterWorker() {\n    return require(\"./is-in-register-worker.cjs\").markInRegisterWorker;\n  }\n\n  #worker = new WorkerClient.#worker_threads.Worker(\n    path.resolve(__dirname, \"./worker/index.cjs\"),\n    { env: WorkerClient.#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 WorkerClient.#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 } = WorkerClient.#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\nif (!process.env.BABEL_8_BREAKING) {\n  module.exports.LocalClient = class LocalClient extends Client {\n    isLocalClient = true;\n\n    static #handleMessage: (action: ACTIONS, payload: any) => any;\n\n    constructor() {\n      LocalClient.#handleMessage ??= require(\"./worker/handle-message.cjs\");\n\n      super((action, payload) => {\n        return LocalClient.#handleMessage(\n          action === ACTIONS.TRANSFORM ? ACTIONS.TRANSFORM_SYNC : action,\n          payload,\n        );\n      });\n    }\n  };\n}\n"],"mappings":";;;;;;;;MAEOA,IAAI,GAAAC,OAAA,CAAW,MAAW;AAAA,MAC1BC,KAAK,GAAAD,OAAA,CAAW,aAAa;AAAA,IAE7BE,OAAO,GAAGD,KAAK,CAACC,OAAO;AAAA,IAAAC,KAAA,OAAAC,OAAA;AAAA,IAAAC,OAAA,OAAAD,OAAA;AAE9B,MAAME,MAAM,CAAoB;EAG9BC,WAAWA,CAACC,IAA4C,EAAE;IAF1DC,0BAAA,OAAAN,KAAK;IAMLM,0BAAA,OAAAJ,OAAO;IAHLK,qBAAA,CAAKP,KAAK,EAAV,IAAI,EAASK,IAAJ,CAAC;EACZ;EAGAG,oBAAoBA,CAAA,EAAa;IAAA,IAAAC,sBAAA;IAC/B,QAAAA,sBAAA,GAAQC,qBAAA,CAAKR,OAAO,EAAZ,IAAW,CAAC,YAAAO,sBAAA,GAAZF,qBAAA,CAAKL,OAAO,EAAZ,IAAI,EAAaQ,qBAAA,CAAKV,KAAK,EAAV,IAAS,CAAC,CAAAW,IAAA,CAAV,IAAI,EAC3BZ,OAAO,CAACa,sBAAsB,EAC9BC,SAAS,CAFQ,CAAC;EAItB;EAEAC,UAAUA,CAACC,OAAgB,EAAQ;IACjC,OAAOL,qBAAA,CAAKV,KAAK,EAAV,IAAS,CAAC,CAAAW,IAAA,CAAV,IAAI,EAAOZ,OAAO,CAACiB,WAAW,EAAED,OAAO;EAChD;EAEAE,SAASA,CACPC,IAAY,EACZC,QAAgB,EACsB;IACtC,OAAOT,qBAAA,CAAKV,KAAK,EAAV,IAAS,CAAC,CAAAW,IAAA,CAAV,IAAI,EAAOZ,OAAO,CAACqB,SAAS,EAAE;MAAEF,IAAI;MAAEC;IAAS,CAAC;EACzD;AACF;AAAC,IAAAE,OAAA,OAAApB,OAAA;AAAA,IAAAqB,OAAA,OAAArB,OAAA;AAKD,MAAMsB,YAAY,SAASpB,MAAM,CAAC;EAoBhCC,WAAWA,CAAA,EAAG;IACZ,KAAK,CAAC,CAACoB,MAAM,EAAEC,OAAO,KAAK;MACzBf,qBAAA,CAAKY,OAAO,EAAZ,IAAW,CAAC,CAAC,CAAC,CAAC,GAAG,CAAC;MACnB,MAAMI,UAAU,GAAG,KAAiBC,mBAAe,CAA5BJ,YAA2B,CAAC,CAACK,cAAc,EAAC,CAAC;MAEpElB,qBAAA,CAAKW,OAAO,EAAZ,IAAW,CAAC,CAACQ,WAAW,CACtB;QAAEC,MAAM,EAAEpB,qBAAA,CAAKY,OAAO,EAAZ,IAAW,CAAC;QAAES,IAAI,EAAEL,UAAU,CAACM,KAAK;QAAER,MAAM;QAAEC;MAAQ,CAAC,EACjE,CAACC,UAAU,CAACM,KAAK,CACnB,CAAC;MAEDC,OAAO,CAACC,IAAI,CAACxB,qBAAA,CAAKY,OAAO,EAAZ,IAAW,CAAC,EAAE,CAAC,EAAE,CAAC,CAAC;MAChC,MAAM;QAAEa;MAAQ,CAAC,GAAgBR,mBAAe,CAA5BJ,YAA2B,CAAC,CAACa,oBAAoB,CACnEV,UAAU,CAACW,KACb,CAAC;MAED,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;IAxBJpC,0BAAA,OAAAe,OAAO,EAAG,KAAiBM,mBAAe,CAA5BJ,YAA2B,CAAC,CAACoB,MAAM,EAC/C/C,IAAI,CAACgD,OAAO,CAACC,SAAS,EAAE,oBAAoB,CAAC,EAC7C;MAAEC,GAAG,EAAeC,yBAAqB,CAAlCxB,YAAiC,CAAC,CAAAZ,IAAA,CAAlCY,YAAY,EAAuByB,OAAO,CAACF,GAAG;IAAE,CACzD,CAAC;IAEDxC,0BAAA,OAAAgB,OAAO,EAAG,IAAI2B,UAAU,CAAC,IAAIC,iBAAiB,CAAC,CAAC,CAAC,CAAC;IAuBhDxC,qBAAA,CAAKW,OAAO,EAAZ,IAAW,CAAC,CAAC8B,KAAK,CAAC,CAAC;EACtB;AACF;AAAC,SAAAxB,oBAAAyB,KAAA,EAtC8B;EAC3B,OAAOvD,OAAO,CAAC,gBAAqB,CAAC;AACvC;AAAC,SAAAkD,0BAAAM,MAAA,EAEkC;EACjC,OAAOxD,OAAO,CAAC,6BAA6B,CAAC,CAACyD,oBAAoB;AACpE;AAACC,MAAA,CAAAC,OAAA,GAkCM;EAAEjC;AAAa,CAAC;AAGvBgC,MAAM,CAACC,OAAO,CAACC,WAAW,IAAAC,YAAA,GAAG,MAAMD,WAAW,SAAStD,MAAM,CAAC;EAK5DC,WAAWA,CAAA,EAAG;IAAA,IAAAuD,mBAAA;IACZ,CAAAA,mBAAA,GAAAC,iBAAA,CAAAF,YAAA,EAAAD,WAAW,EAACI,cAAc,EAAAC,CAAA,YAAAH,mBAAA,GAAdE,cAAc,CAAAC,CAAA,GAAAF,iBAAA,CAAAF,YAAA,EAA1BD,WAAW,EAAoB5D,OAAO,CAAC,6BAA6B,CAAC,CAA3C;IAE1B,KAAK,CAAC,CAAC2B,MAAM,EAAEC,OAAO,KAAK;MACzB,OAAOmC,iBAAA,CAAAF,YAAA,EAAAD,WAAW,EAACI,cAAc,EAAAC,CAAA,CAAAnD,IAAA,CAA1B8C,WAAW,EAChBjC,MAAM,KAAKzB,OAAO,CAACqB,SAAS,GAAGrB,OAAO,CAACgE,cAAc,GAAGvC,MAAM,EAC9DC,OAAO;IAEX,CAAC,CAAC;IAAC,KAZLuC,aAAa,GAAG,IAAI;EAapB;AACF,CAAC,EAAAH,cAAA;EAAAC,CAAA;AAAA,GAAAJ,YAAA","ignoreList":[]}