bunch of fixes in apps/web and apps/bot

Author: yujonglee

apps/bot/Dockerfile

@@ -22,4 +22,5 @@ FROM node:22-slim AS runtime
 WORKDIR /app
 ENV NODE_ENV="production"
 COPY --from=build /runtime ./
+COPY --from=build /repo/apps/bot/lib ./lib
 CMD ["node", "./lib/server.js"]

apps/bot/app.yml

@@ -9,9 +9,6 @@ primary_region = 'sjc'
 [build]
 dockerfile = "Dockerfile"
 
-[processes]
-app = "node ./lib/server.js"
-
 [deploy]
 strategy = 'bluegreen'
 

apps/bot/fly.toml

@@ -10,15 +10,15 @@
   },
   "dependencies": {
     "@t3-oss/env-core": "^0.13.8",
-    "probot": "^13.4.5",
+    "probot": "^13.4.7",
     "zod": "^4.1.13"
   },
   "devDependencies": {
-    "@types/node": "^20.0.0",
-    "nock": "^14.0.5",
-    "smee-client": "^2.0.0",
-    "typescript": "^5.8.3",
-    "vitest": "^2.0.0"
+    "@types/node": "^20.19.25",
+    "nock": "^14.0.10",
+    "smee-client": "^2.0.4",
+    "typescript": "^5.9.3",
+    "vitest": "^2.1.9"
   },
   "overrides": {
     "@types/pg": "8.15.1"

apps/bot/package.json

@@ -0,0 +1,4 @@
+export * from "./list";
+export * from "./send";
+export * from "./shared";
+export * from "./terminate";

apps/bot/src/devin/index.ts

@@ -0,0 +1,81 @@
+// https://docs.devin.ai/api-reference/sessions/list-sessions.
+import { DEVIN_API_BASE_URL, fetchFromDevin } from "./shared";
+
+const DEFAULT_PAGE_SIZE = 100;
+const MAX_PAGES = 50;
+
+export interface DevinSession {
+  session_id: string;
+  status: string;
+  created_at: string;
+  updated_at: string;
+  title?: string;
+  pull_request: {
+    url: string;
+  } | null;
+}
+
+interface ListSessionsResponse {
+  sessions: DevinSession[];
+}
+
+interface ListSessionsOptions {
+  limit?: number;
+  offset?: number;
+  status?: string;
+}
+
+export async function listDevinSessions(
+  options: ListSessionsOptions = {},
+): Promise<ListSessionsResponse> {
+  const url = new URL(`${DEVIN_API_BASE_URL}/sessions`);
+  const limit = options.limit ?? DEFAULT_PAGE_SIZE;
+  const offset = options.offset ?? 0;
+
+  url.searchParams.set("limit", limit.toString());
+  url.searchParams.set("offset", offset.toString());
+
+  if (options.status) {
+    url.searchParams.set("status", options.status);
+  }
+
+  const response = await fetchFromDevin(url.toString(), {
+    method: "GET",
+  });
+
+  return (await response.json()) as ListSessionsResponse;
+}
+
+export async function findRunningSessionForPR(
+  prUrl: string,
+): Promise<DevinSession | null> {
+  let offset = 0;
+  const limit = DEFAULT_PAGE_SIZE;
+
+  for (let i = 0; i < MAX_PAGES; i++) {
+    const { sessions } = await listDevinSessions({
+      limit,
+      offset,
+      status: "running",
+    });
+
+    if (sessions.length === 0) {
+      break;
+    }
+
+    const match = sessions.find(
+      (session) => session.pull_request?.url === prUrl,
+    );
+    if (match) {
+      return match;
+    }
+
+    if (sessions.length < limit) {
+      break;
+    }
+
+    offset += limit;
+  }
+
+  return null;
+}

apps/bot/src/devin/list.ts

@@ -0,0 +1,15 @@
+// https://docs.devin.ai/api-reference/sessions/send-a-message-to-an-existing-devin-session
+import { DEVIN_API_BASE_URL, fetchFromDevin } from "./shared";
+
+export async function sendMessageToDevinSession(
+  sessionId: string,
+  message: string,
+): Promise<void> {
+  await fetchFromDevin(`${DEVIN_API_BASE_URL}/sessions/${sessionId}/message`, {
+    method: "POST",
+    headers: {
+      "Content-Type": "application/json",
+    },
+    body: JSON.stringify({ message }),
+  });
+}

apps/bot/src/devin/send.ts

@@ -0,0 +1,25 @@
+import { env } from "../env";
+
+export const DEVIN_API_BASE_URL = "https://api.devin.ai/v1";
+
+export async function fetchFromDevin(
+  input: string | URL,
+  init?: RequestInit,
+): Promise<Response> {
+  const response = await fetch(input, {
+    ...init,
+    headers: {
+      Authorization: `Bearer ${env.DEVIN_API_KEY}`,
+      ...(init?.headers ?? {}),
+    },
+  });
+
+  if (!response.ok) {
+    const body = await response.text();
+    throw new Error(
+      `Devin API request failed: ${response.status} ${response.statusText} - ${body}`,
+    );
+  }
+
+  return response;
+}

apps/bot/src/devin/shared.ts

@@ -0,0 +1,8 @@
+// https://docs.devin.ai/api-reference/sessions/terminate-a-session.
+import { DEVIN_API_BASE_URL, fetchFromDevin } from "./shared";
+
+export async function terminateDevinSession(sessionId: string): Promise<void> {
+  await fetchFromDevin(`${DEVIN_API_BASE_URL}/sessions/${sessionId}`, {
+    method: "DELETE",
+  });
+}

apps/bot/src/devin/terminate.ts

@@ -8,6 +8,7 @@ export const env = createEnv({
     GITHUB_BOT_WEBHOOK_SECRET: z.string().min(1),
     GITHUB_BOT_CLIENT_ID: z.string().min(1).optional(),
     GITHUB_BOT_CLIENT_SECRET: z.string().min(1).optional(),
+    DEVIN_API_KEY: z.string().min(1).optional(),
   },
   runtimeEnv: process.env,
   emptyStringAsUndefined: true,