Function openSession

apps/cloud/src/mcp-session.e2e.node.test.ts:133–172

(
  organizationId: string,
  options: BuildOptions & { readonly caps?: ClientCapabilities } = {},
)

// them connected to an in-memory MCP client. Shaped as an acquireRelease so
// the transport teardown is guaranteed when the test scope closes.
const openSession = (
  organizationId: string,
  options: BuildOptions & { readonly caps?: ClientCapabilities } = {},
) =>
  Effect.acquireRelease(
    Effect.gen(function* () {
      const executor = yield* buildScopedExecutor(organizationId, `Org ${organizationId}`, options);
      const engine = createExecutionEngine({ executor, codeExecutor: makeQuickJsExecutor() });
      const mcpServer = yield* buildMcpServer({
        engine,
        appsEnabled: false,
        requestStateSigningKey: new Uint8Array(32).fill(23),
        requestStatePrincipal: `cloud-mcp-test:${organizationId}`,
        sessionful: true,
        elicitationMode: options.elicitationMode ? { mode: options.elicitationMode } : undefined,
      });
      const [clientTransport, serverTransport] = InMemoryTransport.createLinkedPair();
      const client = new Client(
        { name: "cloud-e2e-test", version: "1.0.0" },
        { capabilities: options.caps ?? ELICITATION_CAPS },
      );
      yield* Effect.promise(() => mcpServer.connect(serverTransport));
      yield* Effect.promise(() => client.connect(clientTransport));
      return { client, clientTransport, serverTransport };
    }),
    ({ clientTransport, serverTransport }) =>
      Effect.all(
        [
          Effect.tryPromise({
            try: () => clientTransport.close(),
            catch: (cause) => cause,
          }).pipe(Effect.ignore),
          Effect.tryPromise({
            try: () => serverTransport.close(),
            catch: (cause) => cause,
          }).pipe(Effect.ignore),
        ],
        { discard: true },
      ),
  ).pipe(Effect.map(({ client }) => ({ client })));

const nextOrgId = (() => {
  let seq = 0;