sofa/apps/server/src/orpc/middleware.ts

import { oo } from "@orpc/openapi";
import { os as baseOs, ORPCError } from "@orpc/server";

import { auth } from "@sofa/auth/server";

const base = baseOs.$context<{ headers: Headers }>();

export const authed = oo.spec(
  base.middleware(async ({ context, next }) => {
    const sessionData = await auth.api.getSession({
      headers: context.headers,
    });
    if (!sessionData?.session || !sessionData?.user) {
      throw new ORPCError("UNAUTHORIZED");
    }
    return next({
      context: {
        user: sessionData.user,
        session: sessionData.session,
      },
    });
  }),
  { security: [{ session: [] }] },
);

export const admin = oo.spec(
  base.middleware(async ({ context, next }) => {
    const sessionData = await auth.api.getSession({
      headers: context.headers,
    });
    if (!sessionData?.session || !sessionData?.user) {
      throw new ORPCError("UNAUTHORIZED");
    }
    if (sessionData.user.role !== "admin") {
      throw new ORPCError("FORBIDDEN");
    }
    return next({
      context: {
        user: sessionData.user,
        session: sessionData.session,
      },
    });
  }),
  { security: [{ session: [] }] },
);