oops (#7)

Author: BetrixDev

app/lib/env.ts

@@ -22,6 +22,7 @@ export const env = createEnv({
     UPLOADTHING_TOKEN: z.string(),
     UPLOADTHING_APP_ID: z.string(),
     POLAR_ACCESS_TOKEN: z.string(),
+    POLAR_WEBHOOK_SECRET: z.string(),
   },
   clientPrefix: "VITE_",
   client: {},

app/routes/api/wh/polar.ts

@@ -7,23 +7,30 @@ import {
 import { getHeaders } from "@tanstack/start/server";
 import { tasks } from "@trigger.dev/sdk/v3";
 import type { handlePolarEventTask } from "@/trigger/handle-polar-event";
+import { env } from "@/lib/env";
 
 export const APIRoute = createAPIFileRoute("/api/wh/polar")({
-  POST: async ({ request, params }) => {
+  POST: async ({ request }) => {
     try {
       const event = validateEvent(
         await request.json(),
         getHeaders() as Record<string, string>,
-        process.env.POLAR_WEBHOOK_SECRET ?? ""
+        env.POLAR_WEBHOOK_SECRET
       );
 
       if (
         event.type === "subscription.active" ||
         event.type === "subscription.revoked"
       ) {
-        await tasks.trigger<typeof handlePolarEventTask>("handle-polar-event", {
-          event,
-        });
+        await tasks.trigger<typeof handlePolarEventTask>(
+          "handle-polar-event",
+          {
+            event,
+          },
+          {
+            tags: [`user_${event.data.customer.metadata.userId}`],
+          }
+        );
       }
 
       return json({ message: "Webhook received" });

app/trigger/handle-polar-event.ts

@@ -24,6 +24,9 @@ export const handlePolarEventTask = schemaTask({
       .unknown()
       .transform((val) => val as ReturnType<typeof validateEvent>),
   }),
+  machine: {
+    preset: "micro",
+  },
   run: async ({ event }) => {
     const clerk = clerkClient({});
 

app/trigger/video-processing.ts

@@ -234,6 +234,8 @@ export const videoProcessingTask = schemaTask({
                     Bucket: env.THUMBS_BUCKET_NAME,
                     Key: `${videoData.id}-large.webp`,
                     Body: buffer,
+                    CacheControl: "public, max-age=31536000",
+                    ContentType: "image/webp",
                   },
                   abortController,
                 }).done()
@@ -262,6 +264,8 @@ export const videoProcessingTask = schemaTask({
                     Bucket: env.THUMBS_BUCKET_NAME,
                     Key: `${videoData.id}-small.webp`,
                     Body: buffer,
+                    CacheControl: "public, max-age=31536000",
+                    ContentType: "image/webp",
                   },
                   abortController,
                 }).done()