chore: sync tool contracts (#144)

Author: leo-paz

.changeset/hosted-churn-tool-contracts.md

@@ -0,0 +1,7 @@
+---
+"@outlit/tools": patch
+"@outlit/cli": patch
+"@outlit/pi": patch
+---
+
+Sync notification tool contracts with hosted churn agent destination IDs.

packages/cli/src/commands/notify.ts

@@ -1,24 +1,15 @@
 import { readFileSync } from "node:fs"
-import {
-  customerToolContracts,
-  notificationProviderValues,
-  notificationSeverityValues,
-} from "@outlit/tools"
+import { customerToolContracts, notificationSeverityValues } from "@outlit/tools"
 import { defineCommand } from "citty"
 import { authArgs } from "../args/auth"
 import { AGENT_JSON_HINT, outputArgs } from "../args/output"
 import { getClientOrExit, runTool } from "../lib/api"
 import { errorMessage, outputError } from "../lib/output"
 
 type NotificationSeverity = (typeof notificationSeverityValues)[number]
-type NotificationProvider = (typeof notificationProviderValues)[number]
-type NotificationDestination = {
-  provider: NotificationProvider
-  channelId?: string
-}
 
-const MAX_DESTINATION_COUNT = 10
-const MAX_DESTINATION_CHANNEL_ID_LENGTH = 240
+const MAX_DESTINATION_ID_COUNT = 10
+const UUID_PATTERN = /^[0-9a-f]{8}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{4}-[0-9a-f]{12}$/i
 
 function parsePayload(raw: string): unknown {
   try {
@@ -56,40 +47,20 @@ function payloadSizeIsValid(payload: unknown): boolean {
   return typeof serialized === "string" && serialized.length <= 100000
 }
 
-function parseDestinations(raw: string | undefined): NotificationDestination[] | null | undefined {
+function parseDestinationIds(raw: string | undefined): string[] | null | undefined {
   if (raw === undefined) {
     return undefined
   }
 
-  const destinations = raw.split(",").map((entry) => entry.trim())
+  const destinationIds = raw.split(",").map((entry) => entry.trim())
   if (
-    destinations.length > MAX_DESTINATION_COUNT ||
-    destinations.some((entry) => entry.length === 0)
+    destinationIds.length > MAX_DESTINATION_ID_COUNT ||
+    destinationIds.some((entry) => entry.length === 0 || !UUID_PATTERN.test(entry))
   ) {
     return null
   }
 
-  const parsed: NotificationDestination[] = []
-  for (const destination of destinations) {
-    const [providerInput, ...channelParts] = destination.split(":")
-    const provider = providerInput?.trim().toLowerCase()
-    const channelId = channelParts.join(":").trim()
-
-    if (!notificationProviderValues.includes(provider as NotificationProvider)) {
-      return null
-    }
-
-    if (channelId.length > MAX_DESTINATION_CHANNEL_ID_LENGTH) {
-      return null
-    }
-
-    parsed.push({
-      provider: provider as NotificationProvider,
-      ...(channelId.length > 0 ? { channelId } : {}),
-    })
-  }
-
-  return parsed
+  return destinationIds
 }
 
 export default defineCommand({
@@ -99,13 +70,13 @@ export default defineCommand({
       "Send a notification through Outlit to the organization's configured notifier.",
       "",
       "Use --markdown or --markdown-file for the human-readable body; Outlit renders it for the destination platform.",
-      "Add a JSON or raw payload when useful for structured context. When --destination is omitted, Outlit uses the default notifier.",
+      "Add a JSON or raw payload when useful for structured context. When --destination-id is omitted, Outlit uses the default notifier.",
       "",
       "Examples:",
       "  outlit notify --title 'Risk found' --markdown '**Risk found**\\n\\n- Customer: acme.com'",
       "  outlit notify --title 'Risk found' '{\"customer\":\"acme.com\"}'",
       "  outlit notify --title 'Risk found' --payload-file ./payload.json",
-      "  outlit notify --title 'Escalation' --markdown '**Check this account**' --destination slack:C123",
+      "  outlit notify --title 'Escalation' --markdown '**Check this account**' --destination-id 00000000-0000-4000-8000-000000000001",
       "  outlit notify --title 'Escalation' --severity HIGH --message 'Check this account' '{\"customer\":\"acme.com\"}'",
       "",
       AGENT_JSON_HINT,
@@ -152,10 +123,10 @@ export default defineCommand({
       type: "string",
       description: "Optional subject line",
     },
-    destination: {
+    "destination-id": {
       type: "string",
       description:
-        "Optional comma-separated destinations in provider[:channelId] form. Supported provider: slack",
+        "Optional comma-separated notification destination IDs. Omit to use the default notifier.",
     },
   },
   async run({ args }) {
@@ -250,11 +221,11 @@ export default defineCommand({
       severity = normalized
     }
 
-    const destinations = parseDestinations(args.destination)
-    if (destinations === null) {
+    const destinationIds = parseDestinationIds(args["destination-id"])
+    if (destinationIds === null) {
       return outputError(
         {
-          message: `--destination must use provider[:channelId] with provider one of: ${notificationProviderValues.join(", ")}`,
+          message: "--destination-id must be one or more comma-separated UUIDs",
           code: "invalid_input",
         },
         json,
@@ -329,8 +300,8 @@ export default defineCommand({
       params.subject = subject
     }
 
-    if (destinations !== undefined) {
-      params.destinations = destinations
+    if (destinationIds !== undefined) {
+      params.destinationIds = destinationIds
     }
 
     return runTool(client, customerToolContracts.outlit_send_notification.toolName, params, json)

packages/cli/tests/commands/notify.test.ts

@@ -100,16 +100,17 @@ describe("notify", () => {
     }
   })
 
-  test("sends markdown without a payload and forwards explicit destinations", async () => {
+  test("sends markdown without a payload and forwards explicit destination IDs", async () => {
     const { default: notifyCmd } = await import("../../src/commands/notify")
     const writeSpy = spyOn(process.stdout, "write").mockImplementation(() => true)
+    const destinationId = "00000000-0000-4000-8000-000000000001"
 
     try {
       await notifyCmd.run!({
         args: {
           title: "Risk found",
           markdown: "  **Risk found**\n\n- Customer: Acme  ",
-          destination: "slack:C456",
+          "destination-id": destinationId,
           json: true,
         },
       } as Parameters<NonNullable<typeof notifyCmd.run>>[0])
@@ -119,7 +120,7 @@ describe("notify", () => {
         expect.objectContaining({
           title: "Risk found",
           markdown: "**Risk found**\n\n- Customer: Acme",
-          destinations: [{ provider: "slack", channelId: "C456" }],
+          destinationIds: [destinationId],
         }),
       )
     } finally {
@@ -341,7 +342,7 @@ describe("notify", () => {
     }
   })
 
-  test("invalid destination returns invalid_input", async () => {
+  test("invalid destination ID returns invalid_input", async () => {
     const { default: notifyCmd } = await import("../../src/commands/notify")
     const exitSpy = mockExitThrow()
     const stderrSpy = spyOn(process.stderr, "write").mockImplementation(() => true)
@@ -352,7 +353,7 @@ describe("notify", () => {
         args: {
           title: "Risk found",
           markdown: "**Risk found**",
-          destination: "teams:C123",
+          "destination-id": "not-a-uuid",
           json: true,
         },
       } as Parameters<NonNullable<typeof notifyCmd.run>>[0])
@@ -372,14 +373,18 @@ describe("notify", () => {
     const { default: notifyCmd } = await import("../../src/commands/notify")
     const exitSpy = mockExitThrow()
     const stderrSpy = spyOn(process.stderr, "write").mockImplementation(() => true)
+    const destinationIds = Array.from(
+      { length: 11 },
+      (_, index) => `00000000-0000-4000-8000-${String(index).padStart(12, "0")}`,
+    ).join(",")
 
     let thrown: unknown
     try {
       await notifyCmd.run!({
         args: {
           title: "Risk found",
           markdown: "**Risk found**",
-          destination: Array.from({ length: 11 }, (_, index) => `slack:C${index}`).join(","),
+          "destination-id": destinationIds,
           json: true,
         },
       } as Parameters<NonNullable<typeof notifyCmd.run>>[0])
@@ -395,7 +400,7 @@ describe("notify", () => {
     }
   })
 
-  test("destination channelId over 240 characters returns invalid_input", async () => {
+  test("mixed valid and invalid destination IDs return invalid_input", async () => {
     const { default: notifyCmd } = await import("../../src/commands/notify")
     const exitSpy = mockExitThrow()
     const stderrSpy = spyOn(process.stderr, "write").mockImplementation(() => true)
@@ -406,7 +411,7 @@ describe("notify", () => {
         args: {
           title: "Risk found",
           markdown: "**Risk found**",
-          destination: `slack:${"C".repeat(241)}`,
+          "destination-id": "00000000-0000-4000-8000-000000000001,not-a-uuid",
           json: true,
         },
       } as Parameters<NonNullable<typeof notifyCmd.run>>[0])

packages/pi/tests/extension.test.ts

@@ -176,7 +176,7 @@ describe("createOutlitPiExtension", () => {
     ) {
       expect(tool.parameters.required).toEqual(["title"])
       expect(Object.keys(tool.parameters.properties ?? {})).toEqual(
-        expect.arrayContaining(["title", "markdown", "payload", "destinations"]),
+        expect.arrayContaining(["title", "markdown", "payload", "destinationIds"]),
       )
     } else {
       throw new Error("Expected notification tool parameters to expose required fields")

packages/tools/src/contracts.ts

@@ -744,35 +744,16 @@ export const customerToolContracts = {
           minLength: 1,
           maxLength: 240,
         },
-        destinations: {
-          description:
-            "Optional explicit notification destinations. Omit to use the default notifier.",
+        destinationIds: {
+          description: "Optional NotificationDestination ids. Omit to use the default notifier.",
           minItems: 1,
           maxItems: 10,
           type: "array",
           items: {
-            type: "object",
-            properties: {
-              provider: {
-                description: "Notification provider",
-                type: "string",
-                enum: ["slack"],
-              },
-              channelId: {
-                description: "Provider-specific destination channel ID",
-                type: "string",
-                minLength: 1,
-                maxLength: 240,
-              },
-              label: {
-                description: "Optional destination label",
-                type: "string",
-                minLength: 1,
-                maxLength: 120,
-              },
-            },
-            required: ["provider"],
-            additionalProperties: false,
+            type: "string",
+            format: "uuid",
+            pattern:
+              "^([0-9a-fA-F]{8}-[0-9a-fA-F]{4}-[1-8][0-9a-fA-F]{3}-[89abAB][0-9a-fA-F]{3}-[0-9a-fA-F]{12}|00000000-0000-0000-0000-000000000000|ffffffff-ffff-ffff-ffff-ffffffffffff)$",
           },
         },
       },
@@ -919,7 +900,7 @@ export const workspaceUserListOrderFields = ["name", "email", "owned_customer_co
 export const schemaTables = ["activity", "customers", "users", "revenue"] as const
 
 export const customerToolContractHash =
-  "2dde2d1482c1e2c81bfd57e48e2f8d5e32d1a8f482fa8fd062708884833fa07a" as const
+  "c483d23afc5530cdfae07e5e806b092ce0fb73baec919ef7f2b68afd03252844" as const
 
 export type CustomerToolName = (typeof customerToolNames)[number]
 export type CustomerSourceType = (typeof customerSourceTypes)[number]

packages/tools/tests/client.test.ts

@@ -161,7 +161,7 @@ describe("tool contracts", () => {
       {
         enum?: string[]
         type?: string
-        items?: { properties?: Record<string, { enum?: string[] }> }
+        items?: { format?: string; type?: string }
       }
     >
 
@@ -172,7 +172,15 @@ describe("tool contracts", () => {
         type: "string",
       }),
     )
-    expect(properties.destinations?.items?.properties?.provider?.enum).toEqual(["slack"])
+    expect(properties.destinationIds).toEqual(
+      expect.objectContaining({
+        type: "array",
+        items: expect.objectContaining({
+          type: "string",
+          format: "uuid",
+        }),
+      }),
+    )
     expect(properties.severity).toEqual(
       expect.objectContaining({
         enum: ["low", "medium", "high"],
@@ -245,7 +253,7 @@ describe("createOutlitClient", () => {
       title: "Reminder",
       markdown: "**Reminder**\n\n- Customer: Acme",
       severity: "low",
-      destinations: [{ provider: "slack", channelId: "C123" }],
+      destinationIds: ["00000000-0000-4000-8000-000000000001"],
     })
 
     expect(fetchMock).toHaveBeenCalledWith("https://example.outlit.test/api/tools/call", {
@@ -260,7 +268,7 @@ describe("createOutlitClient", () => {
           title: "Reminder",
           markdown: "**Reminder**\n\n- Customer: Acme",
           severity: "low",
-          destinations: [{ provider: "slack", channelId: "C123" }],
+          destinationIds: ["00000000-0000-4000-8000-000000000001"],
         },
       }),
     })