Function openSession

e2e/cloud/mcp-sse-replay.test.ts:56–68

(mcpUrl: string, bearer: string)

  });

const openSession = async (mcpUrl: string, bearer: string): Promise<string> => {
  const initialized = await postJson(mcpUrl, bearer, initializeBody);
  const sessionId = initialized.headers.get("mcp-session-id");
  await initialized.text();
  if (initialized.status !== 200 || !sessionId) {
    throw new Error(`openSession: initialize failed (${initialized.status})`);
  }

  const notification = await postJson(mcpUrl, bearer, initializedNotification, sessionId);
  await notification.text();
  expect(notification.status, "notifications/initialized is accepted").toBe(202);
  return sessionId;
};

type JsonRpcMessage = {
  readonly id?: unknown;