Format routine target discovery sources

Author: TheGreatAxios

packages/routines/README.md

@@ -93,12 +93,12 @@ otherwise) only groups the picker.
   then applies the product filter (`@corbits/workflow-catalog`'s
   `isAutomatableWorkflowName` or `isConversationalWorkflowName`, never a
   workbench-host anchor name) and orders by `(name asc, definitionAssetId
-  asc)`. Pagination is an opaque cursor over that key; `limit` defaults to
+asc)`. Pagination is an opaque cursor over that key; `limit` defaults to
   50 and caps at 200. A principal holding no definition grant gets an empty
   page, not a 403.
 - Wire shape (`@corbits/routines/client`): `RoutineTarget`
   `{ definitionAssetId, definitionId, assetName, name, description, kind,
-  wireHash }`, `RoutineTargetsResponse` `{ items, nextCursor }`, and
+wireHash }`, `RoutineTargetsResponse` `{ items, nextCursor }`, and
   `routineTargetsPath(tenantId, { limit?, cursor? })`.
   `definitionAssetId` is the identity a routine stores; `definitionId` /
   `wireHash` name what would run right now.

packages/routines/src/targets-route.ts

@@ -21,13 +21,17 @@ const LimitParam = type("string.integer.parse").narrow(
   (limit) => limit >= 1 && limit <= ROUTINE_TARGETS_MAX_LIMIT,
 );
 
-export function createRoutineTargetRoutes(deps: RoutineTargetsDeps): Hono<TenantEnv> {
+export function createRoutineTargetRoutes(
+  deps: RoutineTargetsDeps,
+): Hono<TenantEnv> {
   const app = new Hono<TenantEnv>();
 
   app.get("/", async (c) => {
     const rawLimit = c.req.query("limit");
     const limit =
-      rawLimit === undefined ? ROUTINE_TARGETS_DEFAULT_LIMIT : LimitParam(rawLimit);
+      rawLimit === undefined
+        ? ROUTINE_TARGETS_DEFAULT_LIMIT
+        : LimitParam(rawLimit);
     if (limit instanceof type.errors) {
       return c.json(
         makeErrorEnvelope({
@@ -49,7 +53,10 @@ export function createRoutineTargetRoutes(deps: RoutineTargetsDeps): Hono<Tenant
     } catch (error) {
       if (error instanceof InvalidRoutineTargetCursorError) {
         return c.json(
-          makeErrorEnvelope({ code: "bad_request", userMessage: error.message }),
+          makeErrorEnvelope({
+            code: "bad_request",
+            userMessage: error.message,
+          }),
           400,
         );
       }

packages/routines/src/targets.ts

@@ -57,7 +57,10 @@ export async function listLaunchableDefinitions(
       workflowDefinitionVersion,
       and(
         eq(workflowDefinitionVersion.definitionId, workflowDefinition.id),
-        eq(workflowDefinitionVersion.version, workflowDefinition.currentVersion),
+        eq(
+          workflowDefinitionVersion.version,
+          workflowDefinition.currentVersion,
+        ),
       ),
     )
     .where(
@@ -79,7 +82,13 @@ export async function listLaunchableDefinitions(
   return rows.flatMap((row) =>
     row.definitionAssetId === null || row.wireHash === null
       ? []
-      : [{ ...row, definitionAssetId: row.definitionAssetId, wireHash: row.wireHash }],
+      : [
+          {
+            ...row,
+            definitionAssetId: row.definitionAssetId,
+            wireHash: row.wireHash,
+          },
+        ],
   );
 }
 
@@ -213,7 +222,10 @@ export async function listRoutineTargets(
   const last = items.at(-1);
   const nextCursor =
     remaining.length > items.length && last !== undefined
-      ? encodeCursor({ name: last.name, definitionAssetId: last.definitionAssetId })
+      ? encodeCursor({
+          name: last.name,
+          definitionAssetId: last.definitionAssetId,
+        })
       : null;
   return { items, nextCursor };
 }

packages/routines/test/targets.drizzle.test.ts

@@ -9,7 +9,13 @@ import { type } from "arktype";
 import { Hono } from "hono";
 import type { MiddlewareHandler } from "hono";
 
-import { createDB, createGrantStore, dropSchema, runMigrations, schema } from "@intx/db";
+import {
+  createDB,
+  createGrantStore,
+  dropSchema,
+  runMigrations,
+  schema,
+} from "@intx/db";
 import type { TenantEnv } from "@intx/hub-api";
 
 import { dbTargetFromUrl } from "../../../scripts/db-setup";
@@ -46,8 +52,14 @@ const WORKFLOW_PROJECTION = {
   triggers: [],
   stepOrder: ["gather", "write"],
   steps: {
-    gather: { kind: "step", agent: { systemPrompt: "Gather.", modelSources: [] } },
-    write: { kind: "step", agent: { systemPrompt: "Write.", modelSources: [] } },
+    gather: {
+      kind: "step",
+      agent: { systemPrompt: "Gather.", modelSources: [] },
+    },
+    write: {
+      kind: "step",
+      agent: { systemPrompt: "Write.", modelSources: [] },
+    },
   },
 };
 
@@ -141,8 +153,20 @@ describeIfDb("routine target discovery", () => {
         },
       ]);
       await db.insert(schema.principal).values([
-        { id: READER, tenantId: TENANT, kind: "user", refId: "reader", status: "active" },
-        { id: STRANGER, tenantId: TENANT, kind: "user", refId: "stranger", status: "active" },
+        {
+          id: READER,
+          tenantId: TENANT,
+          kind: "user",
+          refId: "reader",
+          status: "active",
+        },
+        {
+          id: STRANGER,
+          tenantId: TENANT,
+          kind: "user",
+          refId: "stranger",
+          status: "active",
+        },
         {
           id: OTHER_TENANT_READER,
           tenantId: OTHER_TENANT,
@@ -335,7 +359,9 @@ describeIfDb("routine target discovery", () => {
         principalId: READER,
         limit: 1,
       });
-      expect(first.items.map((item) => item.definitionId)).toEqual(["wfd_agent"]);
+      expect(first.items.map((item) => item.definitionId)).toEqual([
+        "wfd_agent",
+      ]);
       expect(first.nextCursor).not.toBeNull();
       const second = await listRoutineTargets(targetsFor(db), {
         tenantId: TENANT,
@@ -359,7 +385,10 @@ describeIfDb("routine target discovery", () => {
       };
       const app = new Hono<TenantEnv>();
       app.use("*", asReader);
-      app.route("/workflows/targets", createRoutineTargetRoutes(targetsFor(db)));
+      app.route(
+        "/workflows/targets",
+        createRoutineTargetRoutes(targetsFor(db)),
+      );
 
       const res = await app.request("/workflows/targets?limit=1");
       expect(res.status).toBe(200);