function recoverPendingSessionDeliveries(params: {

deps: import("../cli/deps.types.js").CliDeps;

log: GatewayRuntimeServiceLogger;

maxEnqueuedAt: number;

}): void {

const maxEnqueuedAt = Date.now();

const timer = setTimeout(() => {

void (async () => {

const { recoverPendingRestartContinuationDeliveries } =

await recoverPendingRestartContinuationDeliveries({

deps: params.deps,

log: logRecovery,

maxEnqueuedAt,

maxEnqueuedAt: params.maxEnqueuedAt,

});

})().catch((err) => params.log.error(`Session delivery recovery failed: ${String(err)}`));

}, 1_250);

channelHealthMonitor: ChannelHealthMonitor | null;

stopModelPricingRefresh: () => void;

} {

// Keep scheduled work inert until post-attach sidecars finish.

const channelHealthMonitor = startGatewayChannelHealthMonitor({

cfg: params.cfgAtStart,

channelManager: params.channelManager,

};

}

/**

* Activate cron scheduler, heartbeat runner, and pending delivery recovery

* after gateway sidecars are fully started and chat.history is available.

*/

export function activateGatewayScheduledServices(params: {

minimalTestGateway: boolean;

cfgAtStart: OpenClawConfig;

deps: import("../cli/deps.types.js").CliDeps;

sessionDeliveryRecoveryMaxEnqueuedAt: number;

cron: { start: () => Promise<void> };

logCron: { error: (message: string) => void };

log: GatewayRuntimeServiceLogger;

recoverPendingSessionDeliveries({

deps: params.deps,

log: params.log,

maxEnqueuedAt: params.sessionDeliveryRecoveryMaxEnqueuedAt,

});

return { heartbeatRunner };

}