Allow job retries to successfully send notifications

regalijan · Feb 6, 2025 · 0c0655a · 0c0655a
1 parent c47812c
commit 0c0655a
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/functions/api/coconut.ts b/functions/api/coconut.ts
@@ -18,14 +18,12 @@ export async function onRequestPost(context: RequestContext) {
 
   if (coconutToken !== token) return jsonError("Forbidden", 403);
 
-  await context.env.DATA.delete(`coconutjob_${attachment}`);
-
   const aws = new AwsClient({
     accessKeyId: context.env.R2_ACCESS_KEY,
     secretAccessKey: context.env.R2_SECRET_KEY,
   });
 
-  const { event } = await context.request.json() as { event: string };
+  const { event } = (await context.request.json()) as { event: string };
 
   if (event === "job.failed") {
     await fetch(context.env.REPORTS_WEBHOOK, {
@@ -53,6 +51,7 @@ export async function onRequestPost(context: RequestContext) {
       method: "PUT",
     });
 
+    await context.env.DATA.delete(`coconutjob_${attachment}`);
     await context.env.R2.delete(`${attachment}.mp4`);
 
     if (!copyResp.ok)