From f3603a7240fd1c68fda3321481ee818c7945fd3b Mon Sep 17 00:00:00 2001 From: MarconLP <13001502+MarconLP@users.noreply.github.com> Date: Sun, 23 Apr 2023 14:36:02 +0200 Subject: [PATCH] add delete video event --- src/server/api/routers/video.ts | 23 ++++++++++++++++------- 1 file changed, 16 insertions(+), 7 deletions(-) diff --git a/src/server/api/routers/video.ts b/src/server/api/routers/video.ts index 0b56a73..18f260b 100644 --- a/src/server/api/routers/video.ts +++ b/src/server/api/routers/video.ts @@ -311,11 +311,11 @@ export const videoRouter = createTRPCRouter({ videoId: z.string(), }) ) - .mutation(async ({ ctx, input }) => { - const deleteVideo = await ctx.prisma.video.deleteMany({ + .mutation(async ({ ctx: { prisma, session, s3, posthog }, input }) => { + const deleteVideo = await prisma.video.deleteMany({ where: { id: input.videoId, - userId: ctx.session.user.id, + userId: session.user.id, }, }); @@ -323,17 +323,26 @@ export const videoRouter = createTRPCRouter({ throw new TRPCError({ code: "FORBIDDEN" }); } - const deleteVideoObject = await ctx.s3.send( + posthog.capture({ + distinctId: session.user.id, + event: "video delete", + properties: { + videoId: input.videoId, + }, + }); + void posthog.shutdownAsync(); + + const deleteVideoObject = await s3.send( new DeleteObjectCommand({ Bucket: env.AWS_BUCKET_NAME, - Key: ctx.session.user.id + "/" + input.videoId, + Key: session.user.id + "/" + input.videoId, }) ); - const deleteThumbnailObject = await ctx.s3.send( + const deleteThumbnailObject = await s3.send( new DeleteObjectCommand({ Bucket: env.AWS_BUCKET_NAME, - Key: ctx.session.user.id + "/" + input.videoId + "-thumbnail", + Key: session.user.id + "/" + input.videoId + "-thumbnail", }) );