Hono

import { OpenAPIHandler } from "@orpc/openapi/fetch";
import { RPCHandler } from "@orpc/server/fetch";

import { router } from "./router";

export const rpcHandler = new RPCHandler(router);
export const openAPIHandler = new OpenAPIHandler(router);

import { Hono } from "hono";

import { openAPIHandler, rpcHandler } from "./orpc";

const app = new Hono();

app.use("/rpc/*", async (c, next) => {
  const result = await rpcHandler.handle(c.req.raw, {
    prefix: "/rpc",
    context: {
      requestId: c.req.header("x-request-id") ?? crypto.randomUUID(),
    },
  });

  if (result.matched) return result.response;
  return next();
});

app.use("/api/*", async (c, next) => {
  const result = await openAPIHandler.handle(c.req.raw, {
    prefix: "/api",
    context: {
      requestId: c.req.header("x-request-id") ?? crypto.randomUUID(),
    },
  });

  if (result.matched) return result.response;
  return next();
});

export default app;

type RequestContext = {
  requestId: string;
  role: "viewer" | "operator" | "admin";
};

const procedure = makeEffectORPC(runtime).$context<RequestContext>();

import { Effect } from "effect";
import { withFiberContext } from "effect-orpc/node";

app.use("*", async (_c, next) => {
  await Effect.runPromise(
    Effect.gen(function* () {
      yield* Effect.annotateLogsScoped({ requestId: crypto.randomUUID() });
      yield* withFiberContext(() => next());
    }),
  );
});

cd examples/hono
bun install
bun start