import { parseRegexp } from '@vitest/utils';
const REGEXP_WRAP_PREFIX = "$$vitest:";
const processSend = process.send?.bind(process);
const processOn = process.on?.bind(process);
const processOff = process.off?.bind(process);
const dispose = [];
function createThreadsRpcOptions({
port
}) {
return {
post: (v) => {
port.postMessage(v);
},
on: (fn) => {
port.addListener("message", fn);
}
};
}
function disposeInternalListeners() {
for (const fn of dispose) {
try {
fn();
} catch {
}
}
dispose.length = 0;
}
function createForksRpcOptions(nodeV8) {
return {
serialize: nodeV8.serialize,
deserialize: (v) => nodeV8.deserialize(Buffer.from(v)),
post(v) {
processSend(v);
},
on(fn) {
const handler = (message, ...extras) => {
if (message?.__tinypool_worker_message__) {
return;
}
return fn(message, ...extras);
};
processOn("message", handler);
dispose.push(() => processOff("message", handler));
}
};
}
function unwrapSerializableConfig(config) {
if (config.testNamePattern && typeof config.testNamePattern === "string") {
const testNamePattern = config.testNamePattern;
if (testNamePattern.startsWith(REGEXP_WRAP_PREFIX)) {
config.testNamePattern = parseRegexp(
testNamePattern.slice(REGEXP_WRAP_PREFIX.length)
);
}
}
if (config.defines && Array.isArray(config.defines.keys) && config.defines.original) {
const { keys, original } = config.defines;
const defines = {};
for (const key of keys) {
defines[key] = original[key];
}
config.defines = defines;
}
return config;
}
export { createThreadsRpcOptions as a, createForksRpcOptions as c, disposeInternalListeners as d, unwrapSerializableConfig as u };
