// See https://github.com/openclaw/openclaw/issues/72481

const STUCK_ANNOUNCING_MS = 20_000;

const MAX_CONSECUTIVE_RESTARTS = 3;

const MAX_CONSECUTIVE_STUCK_STATE_RESTARTS = 1;

// A flapping advertiser can briefly reach "announced" between probing

// failures, which resets the consecutive counter. Bound total restarts too.

const RESTART_WINDOW_MS = 30 * 60_000;

let recreatePromise: Promise<void> | null = null;

let disabled = false;

let consecutiveRestarts = 0;

let consecutiveStuckStateRestarts = 0;

const restartTimestamps: number[] = [];

let cycle: BonjourCycle | null = createCycle();

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

}

};

const recreateAdvertiser = async (reason: string) => {

const recreateAdvertiser = async (reason: string, opts?: { stuckState?: boolean }) => {

if (stopped || disabled) {

return;

}

}

recreatePromise = (async () => {

consecutiveRestarts += 1;

consecutiveStuckStateRestarts = opts?.stuckState ? consecutiveStuckStateRestarts + 1 : 0;

const now = Date.now();

while (

restartTimestamps.length > 0 &&

}

restartTimestamps.push(now);

const tooManyConsecutive = consecutiveRestarts > MAX_CONSECUTIVE_RESTARTS;

const tooManyStuckStates =

consecutiveStuckStateRestarts > MAX_CONSECUTIVE_STUCK_STATE_RESTARTS;

const tooManyInWindow = restartTimestamps.length >= MAX_RESTARTS_IN_WINDOW;

if (tooManyConsecutive || tooManyInWindow) {

if (tooManyConsecutive || tooManyStuckStates || tooManyInWindow) {

disabled = true;

const detail = tooManyConsecutive

? `${MAX_CONSECUTIVE_RESTARTS} failed restarts`

: `${MAX_RESTARTS_IN_WINDOW} restarts within ${Math.round(

RESTART_WINDOW_MS / 60_000,

)} minutes`;

: tooManyStuckStates

? `${MAX_CONSECUTIVE_STUCK_STATE_RESTARTS} stuck-state restart`

: `${MAX_RESTARTS_IN_WINDOW} restarts within ${Math.round(

RESTART_WINDOW_MS / 60_000,

)} minutes`;

logger.warn(

`bonjour: disabling advertiser after ${detail} (${reason}); set discovery.mdns.mode="off" or OPENCLAW_DISABLE_BONJOUR=1 to disable mDNS discovery`,

);

}

if (stateUnknown === "announced") {

consecutiveRestarts = 0;

consecutiveStuckStateRestarts = 0;

}

const tracked = stateTracker.get(label);

if (

label,

svc,

)})`,

{ stuckState: true },

);

return;

}