Function expectWebSocketOriginCase

src/node/orpc/server.test.ts:273–297

(input: {
  headers?: OriginHeaders;
  accepted: boolean;
  allowHttpOrigin?: boolean;
})

}

async function expectWebSocketOriginCase(input: {
  headers?: OriginHeaders;
  accepted: boolean;
  allowHttpOrigin?: boolean;
}): Promise<void> {
  await withTestOrpcServer(
    async (server) => {
      const ws = new WebSocket(server.wsUrl, {
        headers: resolveOriginHeaders(input.headers, server),
      });

      try {
        if (input.accepted) {
          await waitForWebSocketOpen(ws);
          await closeWebSocket(ws);
        } else {
          await waitForWebSocketRejection(ws);
        }
      } finally {
        ws.terminate();
      }
    },
    input.allowHttpOrigin ? { allowHttpOrigin: true } : {}
  );
}

describe("createOrpcServer", () => {
  test("serveStatic fallback does not swallow /api routes", async () => {