Add dev connection message

Author: ericallam

apps/webapp/app/routes/api.v1.projects.$projectRef.dev-status.ts

@@ -0,0 +1,61 @@
+import { json, type LoaderFunctionArgs } from "@remix-run/server-runtime";
+import { z } from "zod";
+import { prisma } from "~/db.server";
+import { devPresence } from "~/presenters/v3/DevPresence.server";
+import { authenticateApiRequestWithPersonalAccessToken } from "~/services/personalAccessToken.server";
+import { getEnvironmentFromEnv } from "./api.v1.projects.$projectRef.$env";
+
+const ParamsSchema = z.object({
+  projectRef: z.string(),
+});
+
+type ParamsSchema = z.infer<typeof ParamsSchema>;
+
+export async function loader({ request, params }: LoaderFunctionArgs) {
+  const authenticationResult = await authenticateApiRequestWithPersonalAccessToken(request);
+
+  if (!authenticationResult) {
+    return json({ error: "Invalid or Missing Access Token" }, { status: 401 });
+  }
+
+  const parsedParams = ParamsSchema.safeParse(params);
+
+  if (!parsedParams.success) {
+    return json({ error: "Invalid Params" }, { status: 400 });
+  }
+
+  const { projectRef } = parsedParams.data;
+
+  const project = await prisma.project.findFirst({
+    where: {
+      externalRef: projectRef,
+      organization: {
+        members: {
+          some: {
+            userId: authenticationResult.userId,
+          },
+        },
+      },
+    },
+  });
+
+  if (!project) {
+    return json({ error: "Project not found" }, { status: 404 });
+  }
+
+  const envResult = await getEnvironmentFromEnv({
+    projectId: project.id,
+    userId: authenticationResult.userId,
+    env: "dev",
+  });
+
+  if (!envResult.success) {
+    return json({ error: envResult.error }, { status: 404 });
+  }
+
+  const runtimeEnv = envResult.environment;
+
+  const isConnected = await devPresence.isConnected(runtimeEnv.id);
+
+  return json({ isConnected });
+}

packages/cli-v3/src/apiClient.ts

@@ -196,6 +196,20 @@ export class CliApiClient {
     );
   }
 
+  async getDevStatus(projectRef: string) {
+    if (!this.accessToken) {
+      throw new Error("getJWT: No access token");
+    }
+
+    return wrapZodFetch(
+      z.object({ isConnected: z.boolean() }),
+      `${this.apiURL}/api/v1/projects/${projectRef}/dev-status`,
+      {
+        headers: this.getHeaders(),
+      }
+    );
+  }
+
   async createBackgroundWorker(projectRef: string, body: CreateBackgroundWorkerRequestBody) {
     if (!this.accessToken) {
       throw new Error("createBackgroundWorker: No access token");

packages/cli-v3/src/mcp/tools.ts

@@ -478,9 +478,32 @@ export function registerTriggerTaskTool(context: McpContext) {
 
       const taskRunUrl = `${auth.dashboardUrl}/projects/v3/${$projectRef}/runs/${result.id}`;
 
-      return {
-        content: [{ type: "text", text: JSON.stringify({ ...result, taskRunUrl }, null, 2) }],
-      };
+      if (environment === "dev") {
+        const cliApiClient = new CliApiClient(auth.auth.apiUrl, auth.auth.accessToken);
+
+        const devStatus = await cliApiClient.getDevStatus($projectRef);
+        const isConnected = devStatus.success ? devStatus.data.isConnected : false;
+        const connectionMessage = isConnected
+          ? undefined
+          : "The dev CLI is not connected to this project, because it is not currently running. Make sure to run the dev command to execute triggered tasks.";
+
+        if (connectionMessage) {
+          return {
+            content: [
+              { type: "text", text: JSON.stringify({ ...result, taskRunUrl }, null, 2) },
+              { type: "text", text: connectionMessage },
+            ],
+          };
+        } else {
+          return {
+            content: [{ type: "text", text: JSON.stringify({ ...result, taskRunUrl }, null, 2) }],
+          };
+        }
+      } else {
+        return {
+          content: [{ type: "text", text: JSON.stringify({ ...result, taskRunUrl }, null, 2) }],
+        };
+      }
     }
   );
 }