import { initTRPC, TRPCError } from "@trpc/server";

import superjson from "superjson";

import type { Context } from "./context";

const t = initTRPC.context<Context>().create({

  transformer: superjson,

});

export const router = t.router;

export const publicProcedure = t.procedure;

export const protectedProcedure = t.procedure.use(({ ctx, next }) => {

  if (!ctx.user) {

    throw new TRPCError({ code: "UNAUTHORIZED", message: "Sign in to post." });

  }

  return next({ ctx: { ...ctx, user: ctx.user } });

});

export const adminProcedure = t.procedure.use(({ ctx, next }) => {

  if (!ctx.user) throw new TRPCError({ code: "UNAUTHORIZED" });

  if (ctx.user.role !== "admin" && ctx.user.role !== "moderator") {

    throw new TRPCError({ code: "FORBIDDEN", message: "Admins only." });

  }

  return next({ ctx: { ...ctx, user: ctx.user } });

});