deps: CliDeps;

startChannels: () => Promise<void>;

prewarmPrimaryModel?: typeof prewarmConfiguredPrimaryModel;

onPluginServices?: (pluginServices: PluginServicesHandle | null) => void;

log: { warn: (msg: string) => void };

logHooks: {

info: (msg: string) => void;

}

});

const pluginServicesPromise = measureStartup(

params.startupTrace,

"sidecars.plugin-services",

async () => {

try {

const { startPluginServices } = await import("../plugins/services.js");

return await startPluginServices({

registry: params.pluginRegistry,

config: params.cfg,

workspaceDir: params.defaultWorkspaceDir,

startupTrace: params.startupTrace,

});

} catch (err) {

params.log.warn(`plugin services failed to start: ${String(err)}`);

return null;

}

},

);

const pluginServicesReportPromise = params.onPluginServices

? pluginServicesPromise.then((pluginServices) => {

params.onPluginServices?.(pluginServices);

return pluginServices;

})

: pluginServicesPromise;

const skipChannels =

isTruthyEnvValue(process.env.OPENCLAW_SKIP_CHANNELS) ||

isTruthyEnvValue(process.env.OPENCLAW_SKIP_PROVIDERS);

}, 250);

}

let pluginServices: PluginServicesHandle | null = null;

await measureStartup(params.startupTrace, "sidecars.plugin-services", async () => {

try {

const { startPluginServices } = await import("../plugins/services.js");

pluginServices = await startPluginServices({

registry: params.pluginRegistry,

config: params.cfg,

workspaceDir: params.defaultWorkspaceDir,

startupTrace: params.startupTrace,

});

} catch (err) {

params.log.warn(`plugin services failed to start: ${String(err)}`);

}

});

const pluginServices = await pluginServicesReportPromise;

if (params.cfg.acp?.enabled) {

void (async () => {

await params.onStartupPluginsLoaded?.(loaded);

}

await measureStartup(params.startupTrace, "post-attach.log", () =>

const startupLogPromise = measureStartup(params.startupTrace, "post-attach.log", () =>

runtimeDeps.logGatewayStartup({

cfg: params.cfgAtStart,

bindHost: params.bindHost,

}),

);

let pluginServicesReported = false;

const reportPluginServices = (pluginServices: PluginServicesHandle | null) => {

pluginServicesReported = true;

params.onPluginServices?.(pluginServices);

};

const sidecarsPromise = params.minimalTestGateway

? Promise.resolve({ pluginServices: null, pluginRegistry, postReadySidecars: [] })

: new Promise<void>((resolve) => setImmediate(resolve)).then(async () => {

logHooks: params.logHooks,

logChannels: params.logChannels,

startupTrace: params.startupTrace,

onPluginServices: reportPluginServices,

}),

);

const loaderStatsAfter = getPluginModuleLoaderStats();

for (const method of STARTUP_UNAVAILABLE_GATEWAY_METHODS) {

params.unavailableGatewayMethods.delete(method);

}

params.onPluginServices?.(result.pluginServices);

if (!pluginServicesReported) {

reportPluginServices(result.pluginServices);

}

params.onPostReadySidecars?.(result.postReadySidecars);

params.onSidecarsReady?.();

params.startupTrace?.detail("sidecars.ready", [

});

if (params.deferSidecars !== true) {

const [stopGatewayUpdateCheck, tailscaleCleanup, sidecarsResult] = await Promise.all([

const [, stopGatewayUpdateCheck, tailscaleCleanup, sidecarsResult] = await Promise.all([

startupLogPromise,

stopGatewayUpdateCheckPromise,

tailscaleCleanupPromise,

sidecarsPromise,

};

}

const [stopGatewayUpdateCheck, tailscaleCleanup] = await Promise.all([

const [, stopGatewayUpdateCheck, tailscaleCleanup] = await Promise.all([

startupLogPromise,

stopGatewayUpdateCheckPromise,

tailscaleCleanupPromise,

]);