bind: "loopback",

auth: { mode: "token", token },

controlUiEnabled: false,

awaitStartupSidecars: true,

});

logLiveStep("gateway startup returned");

await waitForGatewayPort({ host: "127.0.0.1", port, timeoutMs: CONNECT_TIMEOUT_MS });

bind: "loopback",

auth: { mode: "token", token },

controlUiEnabled: false,

awaitStartupSidecars: true,

});

const client = await connectTestGatewayClient({

url: `ws://127.0.0.1:${port}`,

});

});

it("waits for sidecars by default before returning", async () => {

let resumeSidecars!: () => void;

const sidecarsReady = new Promise<{ pluginServices: null }>((resolve) => {

resumeSidecars = () => resolve({ pluginServices: null });

});

const startGatewaySidecars = vi.fn(async () => {

return await sidecarsReady;

});

let returned = false;

const runtimePromise = startGatewayPostAttachRuntime(

createPostAttachParams(),

createPostAttachRuntimeDeps({ startGatewaySidecars }),

).then(() => {

returned = true;

});

await vi.waitFor(() => {

expect(startGatewaySidecars).toHaveBeenCalledTimes(1);

});

await Promise.resolve();

expect(returned).toBe(false);

resumeSidecars();

await runtimePromise;

expect(returned).toBe(true);

});

it("keeps startup-gated methods unavailable while sidecars are still resuming", async () => {

let resumeSidecars!: () => void;

const sidecarsReady = new Promise<{ pluginServices: null }>((resolve) => {

{

...createPostAttachParams(),

unavailableGatewayMethods,

awaitSidecars: false,

deferSidecars: true,

},

createPostAttachRuntimeDeps({ startGatewaySidecars }),

);

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

onSidecarsReady?: () => void;

startupTrace?: GatewayStartupTrace;

awaitSidecars?: boolean;

deferSidecars?: boolean;

},

runtimeDeps: GatewayPostAttachRuntimeDeps = defaultGatewayPostAttachRuntimeDeps,

) {

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

});

if (params.awaitSidecars !== false) {

if (params.deferSidecars !== true) {

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

stopGatewayUpdateCheckPromise,

tailscaleCleanupPromise,

prompter: import("../wizard/prompts.js").WizardPrompter,

) => Promise<void>;

/**

* Whether to wait for post-listen sidecars (channels, plugin services) to finish

* starting before marking the gateway as ready. Defaults to true; pass false to

* let sidecars start in the background.

* Let post-listen sidecars (channels, plugin services) finish in the background.

* Defaults to false so gateway startup waits until sidecars are ready.

*/

awaitStartupSidecars?: boolean;

deferStartupSidecars?: boolean;

/**

* Optional startup timestamp used for concise readiness logging.

*/

startupSidecarsReady = true;

},

startupTrace,

awaitSidecars: opts.awaitStartupSidecars,

deferSidecars: opts.deferStartupSidecars === true,

}),

));

startupTrace.mark("ready");