Updated extension and added try catch

Author: D-K-P

packages/build/src/extensions/vercelSyncEnvVars.ts

@@ -1,8 +1,28 @@
 import { BuildExtension } from "@trigger.dev/core/v3/build";
 import { syncEnvVars } from "./core.js";
 
-export function vercelSyncEnvVars(): BuildExtension {
+export function syncVercelEnvVars(
+  options?: { projectId?: string; vercelAccessToken?: string },
+): BuildExtension {
   const sync = syncEnvVars(async (ctx) => {
+    const projectId = options?.projectId ?? process.env.VERCEL_PROJECT_ID ??
+      ctx.env.VERCEL_PROJECT_ID;
+    const vercelAccessToken = options?.vercelAccessToken ??
+      process.env.VERCEL_ACCESS_TOKEN ??
+      ctx.env.VERCEL_ACCESS_TOKEN;
+
+    if (!projectId) {
+      throw new Error(
+        "vercelSyncEnvVars: you did not pass in a projectId or set the VERCEL_PROJECT_ID env var.",
+      );
+    }
+
+    if (!vercelAccessToken) {
+      throw new Error(
+        "vercelSyncEnvVars: you did not pass in a vercelAccessToken or set the VERCEL_ACCESS_TOKEN env var.",
+      );
+    }
+
     const environmentMap = {
       prod: "production",
       staging: "preview",
@@ -13,32 +33,40 @@ export function vercelSyncEnvVars(): BuildExtension {
       environmentMap[ctx.environment as keyof typeof environmentMap];
 
     const vercelApiUrl =
-      `https://api.vercel.com/v8/projects/${process.env.VERCEL_PROJECT_ID}/env?decrypt=true`;
+      `https://api.vercel.com/v8/projects/${projectId}/env?decrypt=true`;
 
-    const response = await fetch(vercelApiUrl, {
-      headers: {
-        Authorization: `Bearer ${process.env.VERCEL_ACCESS_TOKEN}`,
-      },
-    });
+    try {
+      const response = await fetch(vercelApiUrl, {
+        headers: {
+          Authorization: `Bearer ${vercelAccessToken}`,
+        },
+      });
 
-    if (!response.ok) {
-      throw new Error(`HTTP error! status: ${response.status}`);
-    }
+      if (!response.ok) {
+        throw new Error(`HTTP error! status: ${response.status}`);
+      }
 
-    const data = await response.json();
+      const data = await response.json();
 
-    const filteredEnvs = data.envs
-      .filter(
-        (env: { type: string; value: string; target: string[] }) =>
-          env.type === "encrypted" && env.value &&
-          env.target.includes(vercelEnvironment),
-      )
-      .map((env: { key: string; value: string }) => ({
-        name: env.key,
-        value: env.value,
-      }));
+      const filteredEnvs = data.envs
+        .filter(
+          (env: { type: string; value: string; target: string[] }) =>
+            env.type === "encrypted" && env.value &&
+            env.target.includes(vercelEnvironment),
+        )
+        .map((env: { key: string; value: string }) => ({
+          name: env.key,
+          value: env.value,
+        }));
 
-    return filteredEnvs;
+      return filteredEnvs;
+    } catch (error) {
+      console.error(
+        "Error fetching or processing Vercel environment variables:",
+        error,
+      );
+      throw error; // Re-throw the error to be handled by the caller
+    }
   });
 
   return {