type ConsoleLogFn = (...args: unknown[]) => void;

type UncaughtExceptionHandler = (error: unknown) => boolean;

type UnhandledRejectionHandler = (reason: unknown) => boolean;

type ProcessUnhandledRejectionListener = (reason: unknown, promise: Promise<unknown>) => void;

type ExecBridge = (command: string, options?: unknown, callback?: unknown) => ChildProcess;

type ExecOptionsRecord = Record<string, unknown> & { windowsHide?: boolean };

};

}

function installCiaoUnhandledRejectionListener(handler: UnhandledRejectionHandler): () => void {

const hadOtherListeners = process.listenerCount("unhandledRejection") > 0;

const listener: ProcessUnhandledRejectionListener = (reason) => {

if (handler(reason)) {

return;

}

if (hadOtherListeners) {

return;

}

queueMicrotask(() => {

throw reason instanceof Error ? reason : new Error(String(reason));

});

};

process.on("unhandledRejection", listener);

return () => {

process.off("unhandledRejection", listener);

};

}

export async function startGatewayBonjourAdvertiser(

opts: GatewayBonjourAdvertiseOpts,

deps: BonjourAdvertiserDeps = {},

let restoreConsoleLog: () => void = () => {};

let requestCiaoRecovery: ((classification: CiaoProcessErrorClassification) => void) | undefined;

let cleanupUnhandledRejection: (() => void) | undefined;

let cleanupDirectUnhandledRejection: (() => void) | undefined;

let cleanupUncaughtException: (() => void) | undefined;

let processHandlersCleaned = false;

return;

}

processHandlersCleaned = true;

cleanupDirectUnhandledRejection?.();

cleanupUncaughtException?.();

cleanupUnhandledRejection?.();

}

}

return true;

};

cleanupDirectUnhandledRejection = installCiaoUnhandledRejectionListener(handleCiaoProcessError);

cleanupUnhandledRejection = deps.registerUnhandledRejectionHandler?.(handleCiaoProcessError);

cleanupUncaughtException = deps.registerUncaughtExceptionHandler?.(handleCiaoProcessError);