49 lines
1.6 KiB
TypeScript
49 lines
1.6 KiB
TypeScript
import { publicProcedure, router } from "~/server/trpc";
|
|
import { db } from "~/server/db";
|
|
import { music } from "~/server/dbschema/schema";
|
|
import { eq } from "drizzle-orm";
|
|
import { isAdmin } from "~/app/actions";
|
|
import { TRPCError } from "@trpc/server";
|
|
import { z } from "zod";
|
|
import { createMusicInputSchema, updateMusicInputSchema } from "~/lib/trpc/music/schemas";
|
|
import { utapi } from "../uploadthing";
|
|
export const musicRouter = router({
|
|
list: publicProcedure.query(async () => {
|
|
let res = await db.select().from(music).orderBy(music.createdAt);
|
|
console.log(res);
|
|
return res;
|
|
}),
|
|
create: publicProcedure
|
|
.input(
|
|
createMusicInputSchema
|
|
)
|
|
.mutation(async ({ input }) => {
|
|
const admin = await isAdmin();
|
|
if (!admin) throw new TRPCError({ code: "FORBIDDEN", message: "Access denied" });
|
|
let res = await db.insert(music).values(input).returning();
|
|
return res.at(0);
|
|
}),
|
|
update: publicProcedure
|
|
.input(
|
|
updateMusicInputSchema
|
|
)
|
|
.mutation(async ({ input }) => {
|
|
const admin = await isAdmin();
|
|
if (!admin) throw new TRPCError({ code: "FORBIDDEN", message: "Access denied" });
|
|
const { id, ...data } = input;
|
|
return db.update(music).set(data).where(eq(music.id, id)).returning();
|
|
}),
|
|
delete: publicProcedure
|
|
.input(z.object({id:z.string().uuid()}))
|
|
.mutation(async ({ input }) => {
|
|
const admin = await isAdmin();
|
|
if (!admin) throw new TRPCError({ code: "FORBIDDEN", message: "Access denied" });
|
|
let res = await db.delete(music).where(eq(music.id, input.id)).returning();
|
|
let ret = res.at(0)
|
|
if (ret) {
|
|
utapi.deleteFiles(ret.fileKey)
|
|
}
|
|
return ret;
|
|
}),
|
|
});
|