getActiveTaskCount = earlyRuntime.getActiveTaskCount;

runtimeState.skillsChangeUnsub = earlyRuntime.skillsChangeUnsub;

const [{ startGatewayEventSubscriptions }, gatewayRuntimeServices] = await startupTrace.measure(

"runtime.post-early-imports",

() =>

const [{ startGatewayEventSubscriptions }, { startGatewayRuntimeServices }] =

await startupTrace.measure("runtime.post-early-imports", () =>

Promise.all([

import("./server-runtime-subscriptions.js"),

import("./server-runtime-services.js"),

import("./server-runtime-startup-services.js"),

]),

);

);

const runtimeSubscriptions = await startupTrace.measure("runtime.subscriptions", () =>

startGatewayEventSubscriptions({

broadcast,

Object.assign(runtimeState, runtimeSubscriptions);

const runtimeServices = await startupTrace.measure("runtime.services", () =>

gatewayRuntimeServices.startGatewayRuntimeServices({

startGatewayRuntimeServices({

minimalTestGateway,

cfgAtStart,

channelManager,

const sessionDeliveryRecoveryMaxEnqueuedAt = Date.now();

let postAttachRuntimeReturned = false;

let scheduledServicesActivated = false;

let scheduledServicesModulePromise: Promise<

typeof import("./server-runtime-services.js")

> | null = null;

const loadScheduledServicesModule = () => {

scheduledServicesModulePromise ??= import("./server-runtime-services.js");

return scheduledServicesModulePromise;

};

const activateScheduledServicesWhenReady = () => {

if (

closePreludeStarted ||

) {

return;

}

const activated = gatewayRuntimeServices.activateGatewayScheduledServices({

minimalTestGateway,

cfgAtStart,

deps,

sessionDeliveryRecoveryMaxEnqueuedAt,

cron: runtimeState.cronState.cron,

startCron: false,

logCron,

log,

pluginLookUpTable,

});

scheduledServicesActivated = true;

runtimeState.heartbeatRunner = activated.heartbeatRunner;

runtimeState.stopModelPricingRefresh = activated.stopModelPricingRefresh;

void loadScheduledServicesModule().then((gatewayRuntimeServices) => {

if (closePreludeStarted) {

return;

}

const activated = gatewayRuntimeServices.activateGatewayScheduledServices({

minimalTestGateway,

cfgAtStart,

deps,

sessionDeliveryRecoveryMaxEnqueuedAt,

cron: runtimeState.cronState.cron,

startCron: false,

logCron,

log,

pluginLookUpTable,

});

runtimeState.heartbeatRunner = activated.heartbeatRunner;

runtimeState.stopModelPricingRefresh = activated.stopModelPricingRefresh;

});

};

({

stopGatewayUpdateCheck: runtimeState.stopGatewayUpdateCheck,

log.warn(`gateway: failed to promote config last-known-good backup: ${String(err)}`);

});

if (!minimalTestGateway) {

const gatewayRuntimeServices = await loadScheduledServicesModule();

postReadyMaintenanceTimer = gatewayRuntimeServices.scheduleGatewayPostReadyMaintenance({

delayMs: POST_READY_MAINTENANCE_DELAY_MS,

isClosing: () => closePreludeStarted,