add delete video event
This commit is contained in:
parent
2fe910feec
commit
f3603a7240
1 changed files with 16 additions and 7 deletions
|
|
@ -311,11 +311,11 @@ export const videoRouter = createTRPCRouter({
|
||||||
videoId: z.string(),
|
videoId: z.string(),
|
||||||
})
|
})
|
||||||
)
|
)
|
||||||
.mutation(async ({ ctx, input }) => {
|
.mutation(async ({ ctx: { prisma, session, s3, posthog }, input }) => {
|
||||||
const deleteVideo = await ctx.prisma.video.deleteMany({
|
const deleteVideo = await prisma.video.deleteMany({
|
||||||
where: {
|
where: {
|
||||||
id: input.videoId,
|
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" });
|
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({
|
new DeleteObjectCommand({
|
||||||
Bucket: env.AWS_BUCKET_NAME,
|
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({
|
new DeleteObjectCommand({
|
||||||
Bucket: env.AWS_BUCKET_NAME,
|
Bucket: env.AWS_BUCKET_NAME,
|
||||||
Key: ctx.session.user.id + "/" + input.videoId + "-thumbnail",
|
Key: session.user.id + "/" + input.videoId + "-thumbnail",
|
||||||
})
|
})
|
||||||
);
|
);
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue