add basic engine version check via current deploy

Author: nicktrn

apps/webapp/app/v3/engineVersion.server.ts

@@ -1,5 +1,6 @@
 import { RunEngineVersion, RuntimeEnvironmentType } from "@trigger.dev/database";
 import { AuthenticatedEnvironment } from "~/services/apiAuth.server";
+import { findCurrentWorkerDeploymentWithoutTasks } from "./models/workerDeployment.server";
 
 export async function determineEngineVersion({
   environment,
@@ -8,7 +9,9 @@ export async function determineEngineVersion({
   environment: AuthenticatedEnvironment;
   version?: RunEngineVersion;
 }): Promise<RunEngineVersion> {
-  if (version) return version;
+  if (version) {
+    return version;
+  }
 
   // If the project is V1, then none of the background workers are running V2
   if (environment.project.engine === RunEngineVersion.V1) {
@@ -20,6 +23,16 @@ export async function determineEngineVersion({
     return "V1";
   }
 
+  /**
+   * The project has V2 enabled and this isn't dev
+   */
+
+  // Check the current deployment for this environment
+  const currentDeployment = await findCurrentWorkerDeploymentWithoutTasks(environment.id);
+  if (currentDeployment?.type === "V1") {
+    return "V1";
+  }
+
   //todo we need to determine the version using the BackgroundWorker
   //- triggerAndWait we can lookup the BackgroundWorker easily, and get the engine.
   //- No locked version: lookup the BackgroundWorker via the Deployment/latest dev BW

apps/webapp/app/v3/models/workerDeployment.server.ts

@@ -1,5 +1,5 @@
 import type { Prettify } from "@trigger.dev/core";
-import { BackgroundWorker } from "@trigger.dev/database";
+import { BackgroundWorker, WorkerDeployment } from "@trigger.dev/database";
 import { CURRENT_DEPLOYMENT_LABEL, CURRENT_UNMANAGED_DEPLOYMENT_LABEL } from "~/consts";
 import { Prisma, prisma } from "~/db.server";
 import { AuthenticatedEnvironment } from "~/services/apiAuth.server";
@@ -45,6 +45,25 @@ export async function findCurrentWorkerDeployment(
   return promotion?.deployment;
 }
 
+export async function findCurrentWorkerDeploymentWithoutTasks(
+  environmentId: string,
+  label = CURRENT_DEPLOYMENT_LABEL
+): Promise<WorkerDeployment | undefined> {
+  const promotion = await prisma.workerDeploymentPromotion.findUnique({
+    where: {
+      environmentId_label: {
+        environmentId,
+        label,
+      },
+    },
+    include: {
+      deployment: true,
+    },
+  });
+
+  return promotion?.deployment;
+}
+
 export async function findCurrentUnmanagedWorkerDeployment(
   environmentId: string
 ): Promise<WorkerDeploymentWithWorkerTasks | undefined> {