Function connectToInProcessServer

src/node/acp/serverConnection.ts:152–216

(requestedAuthToken?: string)

}

async function connectToInProcessServer(requestedAuthToken?: string): Promise<ServerConnection> {
  const authToken = requestedAuthToken ?? crypto.randomUUID();
  const config = new Config();
  const serviceContainer = new ServiceContainer(config);

  let initialized = false;
  let inProcessServer: InProcessOrpcServer | undefined;

  try {
    await serviceContainer.initialize();
    initialized = true;

    const context = serviceContainer.toORPCContext();
    inProcessServer = await createOrpcServer({
      host: "127.0.0.1",
      port: 0,
      authToken,
      context,
    });

    const activeServer = inProcessServer;
    assert(
      activeServer != null,
      "connectToInProcessServer: expected createOrpcServer to return a server instance"
    );

    const connection = await connectViaWebSocket(activeServer.baseUrl, authToken);

    return {
      client: connection.client,
      inProcessServer: activeServer,
      baseUrl: connection.baseUrl,
      close: async () => {
        let firstError: Error | undefined;

        const captureError = (error: unknown) => {
          firstError ??=
            error instanceof Error
              ? error
              : new Error("connectToInProcessServer: failed to close resources", {
                  cause: error,
                });
        };

        await closeWebSocket(connection.websocket).catch(captureError);
        await activeServer.close().catch(captureError);
        await serviceContainer.dispose().catch(captureError);

        if (firstError !== undefined) {
          throw firstError;
        }
      },
    };
  } catch (error) {
    if (inProcessServer) {
      await inProcessServer.close().catch(() => undefined);
    }