34 lines
975 B
TypeScript
34 lines
975 B
TypeScript
import superjson from "superjson";
|
|
|
|
import { initTRPC, TRPCError } from "@trpc/server";
|
|
|
|
import { Context } from "./createContext";
|
|
|
|
export const t = initTRPC.context<Context>().create({
|
|
transformer: superjson,
|
|
});
|
|
|
|
const perfMiddleware = t.middleware(async ({ path, type, next }) => {
|
|
performance.mark("Start");
|
|
const result = await next();
|
|
performance.mark("End");
|
|
performance.measure(`[${result.ok ? "OK" : "ERROR"}][$1] ${type} '${path}'`, "Start", "End");
|
|
return result;
|
|
});
|
|
|
|
const isAuthedMiddleware = t.middleware(({ ctx, next }) => {
|
|
if (!ctx.user || !ctx.session) {
|
|
throw new TRPCError({ code: "UNAUTHORIZED" });
|
|
}
|
|
return next({
|
|
ctx: {
|
|
// infers that `user` and `session` are non-nullable to downstream procedures
|
|
session: ctx.session,
|
|
user: ctx.user,
|
|
},
|
|
});
|
|
});
|
|
|
|
export const publicProcedure = t.procedure.use(perfMiddleware);
|
|
export const authedProcedure = t.procedure.use(perfMiddleware).use(isAuthedMiddleware);
|