chore: format integration routes

Shaw · Shaw · commit cdadbdc884cd · 2026-05-16T03:56:45.000-07:00
diff --git a/packages/cloud-api/compat/agents/[id]/logs/route.ts b/packages/cloud-api/compat/agents/[id]/logs/route.ts
@@ -1,12 +1,12 @@
 import { Hono } from "hono";
-import type { RouteContext } from "@/lib/api/hono-next-style-params";
 /**
  * GET /api/compat/agents/[id]/logs — container logs for thin clients
  *
  * Fetches logs from the bridge URL if the agent is running,
  * or returns a descriptive status message otherwise.
  */
 import { envelope, errorEnvelope } from "@/lib/api/compat-envelope";
+import type { RouteContext } from "@/lib/api/hono-next-style-params";
 import { assertSafeOutboundUrl } from "@/lib/security/outbound-url";
 import { elizaSandboxService } from "@/lib/services/eliza-sandbox";
 import { logger } from "@/lib/utils/logger";
@@ -17,12 +17,18 @@ import { handleCompatError } from "../../../_lib/error-handler";
 
 const CORS_METHODS = "GET, OPTIONS";
 
-async function __hono_GET(request: Request, { params }: RouteContext<{ id: string }>) {
+async function __hono_GET(
+  request: Request,
+  { params }: RouteContext<{ id: string }>,
+) {
   try {
     const { user } = await requireCompatAuth(request);
     const { id: agentId } = await params;
 
-    const agent = await elizaSandboxService.getAgent(agentId, user.organization_id);
+    const agent = await elizaSandboxService.getAgent(
+      agentId,
+      user.organization_id,
+    );
     if (!agent) {
       return withCompatCors(
         Response.json(errorEnvelope("Agent not found"), { status: 404 }),
@@ -32,7 +38,10 @@ async function __hono_GET(request: Request, { params }: RouteContext<{ id: strin
 
     const url = new URL(request.url);
     const rawTail = parseInt(url.searchParams.get("tail") ?? "100", 10);
-    const tail = Math.max(1, Math.min(Number.isFinite(rawTail) ? rawTail : 100, 5000));
+    const tail = Math.max(
+      1,
+      Math.min(Number.isFinite(rawTail) ? rawTail : 100, 5000),
+    );
 
     // Try bridge logs if agent is running
     if (agent.bridge_url && agent.status === "running") {
@@ -50,7 +59,8 @@ async function __hono_GET(request: Request, { params }: RouteContext<{ id: strin
       } catch (fetchErr) {
         logger.warn("[compat] Failed to fetch logs from bridge", {
           agentId,
-          error: fetchErr instanceof Error ? fetchErr.message : String(fetchErr),
+          error:
+            fetchErr instanceof Error ? fetchErr.message : String(fetchErr),
         });
       }
     }
@@ -66,7 +76,9 @@ async function __hono_GET(request: Request, { params }: RouteContext<{ id: strin
     };
 
     return withCompatCors(
-      Response.json(envelope(statusMsg[agent.status] ?? `Agent status: ${agent.status}`)),
+      Response.json(
+        envelope(statusMsg[agent.status] ?? `Agent status: ${agent.status}`),
+      ),
       CORS_METHODS,
     );
   } catch (err) {
@@ -77,6 +89,8 @@ async function __hono_GET(request: Request, { params }: RouteContext<{ id: strin
 const __hono_app = new Hono<AppEnv>();
 __hono_app.options("/", () => handleCompatCorsOptions(CORS_METHODS));
 __hono_app.get("/", async (c) =>
-  __hono_GET(c.req.raw, { params: Promise.resolve({ id: c.req.param("id")! }) }),
+  __hono_GET(c.req.raw, {
+    params: Promise.resolve({ id: c.req.param("id")! }),
+  }),
 );
 export default __hono_app;
diff --git a/packages/cloud-api/v1/agents/[agentId]/logs/route.ts b/packages/cloud-api/v1/agents/[agentId]/logs/route.ts
@@ -22,28 +22,37 @@ app.get("/", async (c) => {
   try {
     const identity = await requireServiceKey(c);
     const agentId = c.req.param("agentId") ?? "";
-    const agent = await elizaSandboxService.getAgent(agentId, identity.organizationId);
+    const agent = await elizaSandboxService.getAgent(
+      agentId,
+      identity.organizationId,
+    );
 
     if (!agent) {
       return c.json({ error: "Agent not found" }, 404);
     }
 
     const rawTail = parseInt(c.req.query("tail") ?? "100", 10);
-    const tail = Math.max(1, Math.min(Number.isFinite(rawTail) ? rawTail : 100, 5000));
+    const tail = Math.max(
+      1,
+      Math.min(Number.isFinite(rawTail) ? rawTail : 100, 5000),
+    );
 
     if (agent.bridge_url && agent.status === "running") {
       try {
         const logsUrl = `${agent.bridge_url}/logs?tail=${tail}`;
         await assertSafeOutboundUrl(logsUrl);
-        const res = await fetch(logsUrl, { signal: AbortSignal.timeout(10_000) });
+        const res = await fetch(logsUrl, {
+          signal: AbortSignal.timeout(10_000),
+        });
         if (res.ok) {
           const logs = await res.text();
           return c.json({ logs, status: agent.status });
         }
       } catch (fetchErr) {
         logger.warn("[service-api] Failed to fetch logs from bridge", {
           agentId,
-          error: fetchErr instanceof Error ? fetchErr.message : String(fetchErr),
+          error:
+            fetchErr instanceof Error ? fetchErr.message : String(fetchErr),
         });
       }
     }
diff --git a/packages/cloud-api/v1/containers/[id]/logs/route.ts b/packages/cloud-api/v1/containers/[id]/logs/route.ts
@@ -7,12 +7,11 @@
  */
 
 import { Hono } from "hono";
-
-import { forwardToContainerControlPlane } from "../../../_container-control-plane-forward";
 import { failureResponse } from "@/lib/api/cloud-worker-errors";
 import { requireUserOrApiKeyWithOrg } from "@/lib/auth/workers-hono-auth";
 import { logger } from "@/lib/utils/logger";
 import type { AppEnv } from "@/types/cloud-worker-env";
+import { forwardToContainerControlPlane } from "../../../_container-control-plane-forward";
 
 const app = new Hono<AppEnv>();
 
diff --git a/packages/cloud-api/v1/containers/[id]/logs/stream/route.ts b/packages/cloud-api/v1/containers/[id]/logs/stream/route.ts
@@ -34,19 +34,28 @@ import { logger } from "@/lib/utils/logger";
 
 const HEARTBEAT_INTERVAL_MS = 25_000;
 
-async function __hono_GET(request: Request, { params }: { params: Promise<{ id: string }> }) {
+async function __hono_GET(
+  request: Request,
+  { params }: { params: Promise<{ id: string }> },
+) {
   let user: { organization_id: string | null };
   try {
     ({ user } = await requireAuthOrApiKeyWithOrg(request));
   } catch (err) {
     return Response.json(
-      { success: false, error: err instanceof Error ? err.message : "Unauthorized" },
+      {
+        success: false,
+        error: err instanceof Error ? err.message : "Unauthorized",
+      },
       { status: 401 },
     );
   }
   if (!user.organization_id) {
     return Response.json(
-      { success: false, error: "Caller is not associated with an organization" },
+      {
+        success: false,
+        error: "Caller is not associated with an organization",
+      },
       { status: 403 },
     );
   }
@@ -68,15 +77,21 @@ async function __hono_GET(request: Request, { params }: { params: Promise<{ id:
     if (request.signal.aborted) {
       ac.abort();
     } else {
-      request.signal.addEventListener("abort", () => ac.abort(), { once: true });
+      request.signal.addEventListener("abort", () => ac.abort(), {
+        once: true,
+      });
     }
   }
 
   const stream = new ReadableStream<Uint8Array>({
     async start(controller) {
       const send = (event: string, data: unknown) => {
         try {
-          controller.enqueue(encoder.encode(`event: ${event}\ndata: ${JSON.stringify(data)}\n\n`));
+          controller.enqueue(
+            encoder.encode(
+              `event: ${event}\ndata: ${JSON.stringify(data)}\n\n`,
+            ),
+          );
         } catch {
           // Controller already closed — ignore.
         }
@@ -91,15 +106,22 @@ async function __hono_GET(request: Request, { params }: { params: Promise<{ id:
 
       send("open", { containerId, tailLines });
 
-      const heartbeat = setInterval(() => sendComment("keep-alive"), HEARTBEAT_INTERVAL_MS);
+      const heartbeat = setInterval(
+        () => sendComment("keep-alive"),
+        HEARTBEAT_INTERVAL_MS,
+      );
 
       try {
-        await getHetznerContainersClient().streamLogs(containerId, user.organization_id!, {
-          tailLines,
-          signal: ac.signal,
-          onStdout: (chunk) => send("log", { chunk, stream: "stdout" }),
-          onStderr: (chunk) => send("log", { chunk, stream: "stderr" }),
-        });
+        await getHetznerContainersClient().streamLogs(
+          containerId,
+          user.organization_id!,
+          {
+            tailLines,
+            signal: ac.signal,
+            onStdout: (chunk) => send("log", { chunk, stream: "stdout" }),
+            onStderr: (chunk) => send("log", { chunk, stream: "stderr" }),
+          },
+        );
         send("close", { reason: "remote_exit" });
       } catch (err) {
         if (err instanceof HetznerClientError) {
@@ -141,6 +163,8 @@ async function __hono_GET(request: Request, { params }: { params: Promise<{ id:
 
 const __hono_app = new Hono<AppEnv>();
 __hono_app.get("/", async (c) =>
-  __hono_GET(c.req.raw, { params: Promise.resolve({ id: c.req.param("id")! }) }),
+  __hono_GET(c.req.raw, {
+    params: Promise.resolve({ id: c.req.param("id")! }),
+  }),
 );
 export default __hono_app;
diff --git a/packages/cloud-api/v1/reports/bug/route.ts b/packages/cloud-api/v1/reports/bug/route.ts
@@ -7,7 +7,10 @@
 import { Hono } from "hono";
 import { z } from "zod";
 import { failureResponse } from "@/lib/api/cloud-worker-errors";
-import { RateLimitPresets, rateLimit } from "@/lib/middleware/rate-limit-hono-cloudflare";
+import {
+  RateLimitPresets,
+  rateLimit,
+} from "@/lib/middleware/rate-limit-hono-cloudflare";
 import { emailService } from "@/lib/services/email";
 import { logger } from "@/lib/utils/logger";
 import type { AppEnv } from "@/types/cloud-worker-env";
@@ -67,8 +70,12 @@ app.post("/", async (c) => {
 
     const reportId = `rpt_${crypto.randomUUID()}`;
     const receivedAt = new Date().toISOString();
-    const env = c.env as { BUG_REPORT_EMAIL_TO?: string; SUPPORT_EMAIL?: string };
-    const recipient = env.BUG_REPORT_EMAIL_TO ?? env.SUPPORT_EMAIL ?? "developer@elizalabs.ai";
+    const env = c.env as {
+      BUG_REPORT_EMAIL_TO?: string;
+      SUPPORT_EMAIL?: string;
+    };
+    const recipient =
+      env.BUG_REPORT_EMAIL_TO ?? env.SUPPORT_EMAIL ?? "developer@elizalabs.ai";
 
     const startupSummary = validated.startup
       ? JSON.stringify(validated.startup, null, 2)
@@ -120,8 +127,12 @@ app.post("/", async (c) => {
       "",
       "Steps to Reproduce:",
       validated.stepsToReproduce,
-      validated.expectedBehavior ? `\nExpected Behavior:\n${validated.expectedBehavior}` : "",
-      validated.actualBehavior ? `\nActual Behavior:\n${validated.actualBehavior}` : "",
+      validated.expectedBehavior
+        ? `\nExpected Behavior:\n${validated.expectedBehavior}`
+        : "",
+      validated.actualBehavior
+        ? `\nActual Behavior:\n${validated.actualBehavior}`
+        : "",
       startupSummary ? `\nStartup Context:\n${startupSummary}` : "",
       validated.logs ? `\nLogs:\n${validated.logs}` : "",
     ]
@@ -141,7 +152,10 @@ app.post("/", async (c) => {
         source: validated.source,
         category: validated.category,
       });
-      return c.json({ accepted: false, error: "Email service unavailable" }, 503);
+      return c.json(
+        { accepted: false, error: "Email service unavailable" },
+        503,
+      );
     }
 
     logger.info("[BugReport] Structured bug report accepted", {
diff --git a/plugins/plugin-local-inference/src/services/dflash-catalog-disable.test.ts b/plugins/plugin-local-inference/src/services/dflash-catalog-disable.test.ts
@@ -175,7 +175,9 @@ describe("DflashLlamaServer catalog disable reason", () => {
 	});
 
 	it("omits drafter startup flags when launched target-only", async () => {
-		const root = fs.mkdtempSync(path.join(os.tmpdir(), "eliza-dflash-disable-"));
+		const root = fs.mkdtempSync(
+			path.join(os.tmpdir(), "eliza-dflash-disable-"),
+		);
 		const binary = path.join(root, "llama-server");
 		const argsFile = path.join(root, "args.txt");
 		fs.writeFileSync(
