use env lib

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({});