import { parentPort } from 'node:worker_threads';

if (!parentPort) throw new Error('generation worker node wrapper requires parentPort');
const pending = [];
globalThis.self = {
  postMessage(data, transfer = []) {
    parentPort.postMessage(data, transfer);
  },
};
parentPort.on('message', (data) => {
  if (typeof globalThis.self.onmessage === 'function') globalThis.self.onmessage({ data });
  else pending.push(data);
});
await import('../src/generationWorker.js');
while (pending.length) globalThis.self.onmessage({ data: pending.shift() });