}

if (classification.kind === "cancellation") {

logger.debug(`bonjour: ignoring unhandled ciao rejection: ${classification.formatted}`);

logger.warn(`bonjour: suppressing ciao cancellation: ${classification.formatted}`);

requestCiaoRecovery?.(classification);

} else if (classification.kind === "interface-enumeration-failure") {

// Restricted sandboxes can refuse os.networkInterfaces(); mDNS cannot

// function without it, so surface a single warning and skip recovery.

}

}

function handleAdvertiseFailure(

label: string,

svc: BonjourService,

err: unknown,

action: "failed" | "threw",

) {

const classification = classifyCiaoProcessError(err);

if (classification) {

logger.warn(

`bonjour: advertise ${action} with ciao ${classification.kind} (${serviceSummary(

label,

svc,

)}): ${classification.formatted}`,

);

requestCiaoRecovery?.(classification);

return;

}

logger.warn(

`bonjour: advertise ${action} (${serviceSummary(label, svc)}): ${formatBonjourError(err)}`,

);

}

function startAdvertising(services: Array<{ label: string; svc: BonjourService }>) {

for (const { label, svc } of services) {

try {

logger.info(`bonjour: advertised ${serviceSummary(label, svc)}`);

})

.catch((err) => {

logger.warn(

`bonjour: advertise failed (${serviceSummary(label, svc)}): ${formatBonjourError(err)}`,

);

handleAdvertiseFailure(label, svc, err, "failed");

});

} catch (err) {

logger.warn(

`bonjour: advertise threw (${serviceSummary(label, svc)}): ${formatBonjourError(err)}`,

);

handleAdvertiseFailure(label, svc, err, "threw");

}

}

}

let consecutiveRestarts = 0;

let cycle: BonjourCycle | null = createCycle();

const stateTracker = new Map<string, ServiceStateTracker>();

attachConflictListeners(cycle.services);

startAdvertising(cycle.services);

const updateStateTrackers = (services: Array<{ label: string; svc: BonjourService }>) => {

const now = Date.now();

requestCiaoRecovery = (classification) => {

void recreateAdvertiser(`ciao ${classification.kind}: ${classification.formatted}`);

};

attachConflictListeners(cycle.services);

startAdvertising(cycle.services);

const lastRepairAttempt = new Map<string, number>();

const watchdog = setInterval(() => {