Vercel sync env vars extension

packages/build/src/extensions/vercelSyncEnvVars.ts

@@ -0,0 +1,78 @@
+import { BuildExtension } from "@trigger.dev/core/v3/build";
+import { syncEnvVars } from "./core.js";
+
+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",
+      dev: "development",
+    } as const;
+
+    const vercelEnvironment =
+      environmentMap[ctx.environment as keyof typeof environmentMap];
+
+    const vercelApiUrl =
+      `https://api.vercel.com/v8/projects/${projectId}/env?decrypt=true`;
+
+    try {
+      const response = await fetch(vercelApiUrl, {
+        headers: {
+          Authorization: `Bearer ${vercelAccessToken}`,
+        },
+      });
+
+      if (!response.ok) {
+        throw new Error(`HTTP error! status: ${response.status}`);
+      }
+
+      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,
+        }));
+
+      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 {
+    name: "SyncVercelEnvVarsExtension",
+    async onBuildComplete(context, manifest) {
+      await sync.onBuildComplete?.(context, manifest);
+    },
+  };
+}