update devin status handler and types

Author: yujonglee

apps/bot/package.json

@@ -14,6 +14,7 @@
     "zod": "^4.1.13"
   },
   "devDependencies": {
+    "@octokit/plugin-rest-endpoint-methods": "^17.0.0",
     "@types/node": "^20.19.25",
     "nock": "^14.0.10",
     "smee-client": "^2.0.4",

apps/bot/src/devin/detail.ts

@@ -0,0 +1,47 @@
+// https://docs.devin.ai/api-reference/sessions/retrieve-details-about-an-existing-session
+import { DEVIN_API_BASE_URL, fetchFromDevin } from "./shared.js";
+
+export const DevinSessionStatus = {
+  Working: "working",
+  Blocked: "blocked",
+  Expired: "expired",
+  Finished: "finished",
+  SuspendRequested: "suspend_requested",
+  SuspendRequestedFrontend: "suspend_requested_frontend",
+  ResumeRequested: "resume_requested",
+  ResumeRequestedFrontend: "resume_requested_frontend",
+  Resumed: "resumed",
+} as const;
+
+export type DevinSessionStatus =
+  (typeof DevinSessionStatus)[keyof typeof DevinSessionStatus];
+
+export interface DevinSessionDetail {
+  session_id: string;
+  status: string;
+  title: string | null;
+  created_at: string;
+  updated_at: string;
+  snapshot_id: string | null;
+  playbook_id: string | null;
+  tags: string[] | null;
+  pull_request: { url: string } | null;
+  structured_output: Record<string, unknown> | null;
+  status_enum: DevinSessionStatus | null;
+}
+
+export async function getDevinSessionDetail(
+  sessionId: string,
+): Promise<DevinSessionDetail> {
+  const url = `${DEVIN_API_BASE_URL}/sessions/${sessionId}`;
+
+  const response = await fetchFromDevin(url, {
+    method: "GET",
+  });
+
+  return (await response.json()) as DevinSessionDetail;
+}
+
+export function isDevinSessionWorking(detail: DevinSessionDetail): boolean {
+  return detail.status_enum === DevinSessionStatus.Working;
+}

apps/bot/src/devin/index.ts

@@ -1,3 +1,4 @@
+export * from "./detail.js";
 export * from "./list.js";
 export * from "./send.js";
 export * from "./shared.js";

apps/bot/src/features/devin-status.ts

@@ -0,0 +1,67 @@
+import { Probot } from "probot";
+
+import {
+  findRunningSessionForPR,
+  getDevinSessionDetail,
+  isDevinSessionWorking,
+} from "../devin/index.js";
+import { createOrUpdateCheck, ProbotContext } from "../lib/github-checks.js";
+
+const CHECK_NAME = "Devin";
+
+export function registerDevinStatusHandler(app: Probot): void {
+  app.on(
+    [
+      "pull_request.opened",
+      "pull_request.synchronize",
+      "pull_request.reopened",
+    ],
+    async (context) => {
+      const pr = context.payload.pull_request;
+      const owner = context.payload.repository.owner.login;
+      const repo = context.payload.repository.name;
+      const headSha = pr.head.sha;
+      const prUrl = pr.html_url;
+
+      context.log.info(
+        `[Devin] PR ${context.payload.action} for ${owner}/${repo}#${pr.number}`,
+      );
+
+      try {
+        await checkDevinSession(context, owner, repo, headSha, prUrl);
+      } catch (error) {
+        context.log.error(`[Devin] Failed to check Devin session: ${error}`);
+      }
+    },
+  );
+}
+
+async function checkDevinSession(
+  context: ProbotContext,
+  owner: string,
+  repo: string,
+  headSha: string,
+  prUrl: string,
+): Promise<void> {
+  const session = await findRunningSessionForPR(prUrl);
+  if (!session) {
+    return;
+  }
+
+  const detail = await getDevinSessionDetail(session.session_id);
+  if (!isDevinSessionWorking(detail)) {
+    return;
+  }
+
+  await createOrUpdateCheck(context, {
+    owner,
+    repo,
+    name: CHECK_NAME,
+    head_sha: headSha,
+    status: "in_progress",
+    output: {
+      title: "Devin is working",
+      summary: `Devin session ${session.session_id} is currently working on this PR.`,
+    },
+  });
+}

apps/bot/src/features/index.ts

@@ -1,3 +1,3 @@
+export * from "./devin-status.js";
 export * from "./fix-merge-conflict.js";
-export * from "./mergeable.js";
 export * from "./pr-closed.js";

apps/bot/src/features/mergeable.ts

@@ -1,6 +1,7 @@
 import { ApplicationFunctionOptions, Probot } from "probot";
 
 import {
+  registerDevinStatusHandler,
   registerFixMergeConflictHandler,
   registerPrClosedHandler,
 } from "./features/index.js";
@@ -14,6 +15,7 @@ export default (app: Probot, { getRouter }: ApplicationFunctionOptions) => {
     });
   }
 
+  registerDevinStatusHandler(app);
   registerFixMergeConflictHandler(app);
   registerPrClosedHandler(app);
 };