fix(mothership): expose canonical model hints in internal discovery

Author: Sg312

apps/docs/content/docs/integrations/slack.mdx

@@ -15,7 +15,7 @@ Use [Slack](https://www.slack.com/) to send and manage messages, work with canva
 
 ## Stream Trigger Responses
 
-Custom-bot Slack triggers can stream workflow outputs directly back into the conversation that started a run. Enable **Stream response to Slack** on a Message, App Mention, or Assistant Thread Started trigger, then select the outputs to deliver.
+Custom-bot Slack triggers can stream workflow outputs directly back into the conversation that started a run. Turn on **Enable agent session** (`streamResponse`) on a Message, App Mention, or Assistant Thread Started trigger, then select the outputs to deliver in **Outputs to stream** (`streamOutputs`).
 
 - A selected Agent output streams immediately as it is generated. If the Agent later calls a tool, any pre-tool commentary already streamed remains visible.
 - A selected non-streaming block output is sent when that block invocation completes.
@@ -24,7 +24,11 @@ Custom-bot Slack triggers can stream workflow outputs directly back into the con
 - Optional thinking and tool-call updates appear as Slack tasks in a timeline or plan.
 - Slack Agent Sessions remain in processing state for the run, return to active when it finishes, and the native Slack stop button cancels active workflow executions.
 
-Automatic trigger responses require a custom bot created by the Slack setup wizard. They are not available with the shared Sim Slack app.
+Automatic trigger responses require a custom bot created by the Slack setup wizard. They are not available with the shared Sim Slack app. Where the deployment enables shared-app triggers, the Sim app can receive its subscribed event subset without automatic streaming.
+
+The **Set Assistant Status** (`set_status`) action changes the assistant-thread indicator; it does not enable agent-session streaming. A separate Send Message action for an output already selected on the trigger sends an additional message.
+
+Testing a block with sample input verifies its logic. To verify a Slack integration, check the real event's deployed workflow run and any execution or delivery errors, then confirm the reply in the originating conversation or thread.
 
 ## AI-Generated Content
 

apps/sim/lib/api/contracts/mothership-catalog.ts

@@ -0,0 +1,21 @@
+import { z } from 'zod'
+import { v2BlockDetailSchema, v2BlockFieldSchema } from '@/lib/api/contracts/v2/catalog'
+
+/** Internal discovery adds compact catalog hints without changing the public v2 response. */
+const mothershipBlockFieldSchema = v2BlockFieldSchema.extend({
+  optionsAvailability: z.string().optional(),
+  options: z
+    .array(
+      v2BlockFieldSchema.shape.options.unwrap().element.extend({
+        recommended: z.literal(true).optional(),
+        speedOptimized: z.literal(true).optional(),
+        sunset: z.object({ status: z.enum(['legacy', 'deprecated']) }).optional(),
+      })
+    )
+    .optional(),
+})
+
+export const mothershipBlockDetailSchema = v2BlockDetailSchema.extend({
+  inputSchema: z.array(mothershipBlockFieldSchema),
+})
+export type MothershipBlockDetail = z.infer<typeof mothershipBlockDetailSchema>

apps/sim/lib/mothership/agent-cli/curation.test.ts

@@ -1,6 +1,8 @@
 import { beforeEach, describe, expect, it, vi } from 'vitest'
-import type { V2BlockDetail } from '@/lib/api/contracts/v2/catalog'
+import { mothershipBlockDetailSchema } from '@/lib/api/contracts/mothership-catalog'
+import { type V2BlockDetail, v2BlockDetailSchema } from '@/lib/api/contracts/v2/catalog'
 import { curateBlockDetail } from '@/lib/mothership/agent-cli/curation'
+import { PROVIDER_DEFINITIONS } from '@/providers/models'
 
 const { permissionConfig, denied } = vi.hoisted(() => ({
   permissionConfig: { current: null as { deniedTools?: string[] } | null },
@@ -96,6 +98,61 @@ describe('curateBlockDetail', () => {
     expect(curated.toolIds).toEqual(['slack_send'])
   })
 
+  it('adds canonical model hints only on the internal curated response', async () => {
+    const models = Object.values(PROVIDER_DEFINITIONS)
+      .flatMap((provider) => provider.models)
+      .filter((model) => model.sunset?.status !== 'deprecated')
+    const original = {
+      ...blockDetail(),
+      inputSchema: [
+        {
+          id: 'model',
+          type: 'combobox',
+          options: [...models.map((model) => ({ id: model.id })), { id: 'private-local-model' }],
+        },
+      ],
+    }
+    const publicShape = v2BlockDetailSchema.parse(original)
+    expect(publicShape).toEqual(original)
+    const result = await curateBlockDetail(ok(JSON.stringify(original)), viewer)
+    const detail = mothershipBlockDetailSchema.parse(JSON.parse(result.stdout))
+    const field = detail.inputSchema[0]!
+    expect(field.optionsAvailability).toContain(
+      'deployment, provider credentials and model permissions'
+    )
+    expect(field.options).toHaveLength(original.inputSchema[0]!.options.length)
+    for (const model of models) {
+      const option = field.options!.find((option) => option.id === model.id)!
+      expect(option.recommended).toBe(model.recommended || undefined)
+      expect(option.speedOptimized).toBe(model.speedOptimized || undefined)
+      expect(option.sunset).toEqual(model.sunset)
+      expect(option).not.toHaveProperty('runnable')
+      expect(option).not.toHaveProperty('pricing')
+    }
+    expect(field.options!.at(-1)).toEqual({ id: 'private-local-model' })
+    expect(v2BlockDetailSchema.parse(detail)).toEqual(original)
+  })
+
+  it('applies denied operation projection before adding model hints', async () => {
+    permissionConfig.current = { deniedTools: ['slack_canvas'] }
+    denied.current.needsProjection.set('slack', new Set(['canvas']))
+    const original = blockDetail()
+    original.inputSchema.push({
+      id: 'model',
+      type: 'combobox',
+      options: [{ id: 'claude-sonnet-5' }],
+    })
+    const result = await curateBlockDetail(ok(JSON.stringify(original)), viewer)
+    const detail = mothershipBlockDetailSchema.parse(JSON.parse(result.stdout))
+    expect(Object.keys(detail.operations)).toEqual(['send'])
+    expect(detail.inputSchema[0]!.options).toEqual([{ id: 'send' }])
+    expect(detail.inputSchema[1]!.optionsAvailability).toBeDefined()
+    denied.current.fullyDenied.add('slack')
+    const blocked = await curateBlockDetail(ok(JSON.stringify(original)), viewer)
+    expect(blocked.exitCode).toBe(1)
+    expect(blocked.stdout).not.toContain('recommended')
+  })
+
   it('refuses a fully denied block', async () => {
     permissionConfig.current = { deniedTools: ['slack_send', 'slack_canvas'] }
     denied.current = { needsProjection: new Map(), fullyDenied: new Set(['slack']) }

apps/sim/lib/mothership/agent-cli/curation.ts

@@ -6,7 +6,9 @@
  */
 
 import { omit } from '@sim/utils/object'
+import { mothershipBlockDetailSchema } from '@/lib/api/contracts/mothership-catalog'
 import { type V2BlockDetail, v2BlockDetailSchema } from '@/lib/api/contracts/v2/catalog'
+import { withModelHints } from '@/lib/mothership/agent-cli/model-hints'
 import { agentCliFail } from '@/lib/mothership/agent-cli/types'
 import type { AgentCliRawResult } from '@/lib/mothership/generated/agent-cli'
 import { resolveDeniedBlockOperations } from '@/lib/mothership/integration-tool-projection'
@@ -27,7 +29,7 @@ function parseBlockDetail(stdout: string): V2BlockDetail | null {
   }
 }
 
-export async function curateBlockDetail(
+async function curatePermittedBlockDetail(
   result: AgentCliRawResult,
   viewer: CurationViewer
 ): Promise<AgentCliRawResult> {
@@ -63,3 +65,17 @@ export async function curateBlockDetail(
     }),
   }
 }
+
+/** Static hints follow the existing authorized read and per-viewer operation projection. */
+export async function curateBlockDetail(
+  result: AgentCliRawResult,
+  viewer: CurationViewer
+): Promise<AgentCliRawResult> {
+  const permitted = await curatePermittedBlockDetail(result, viewer)
+  if (permitted.exitCode !== 0) return permitted
+  const detail = parseBlockDetail(permitted.stdout)
+  if (!detail) return permitted
+  const enriched = withModelHints(detail)
+  if (enriched === detail) return permitted
+  return { ...permitted, stdout: JSON.stringify(mothershipBlockDetailSchema.parse(enriched)) }
+}

apps/sim/lib/mothership/agent-cli/model-hints.ts

@@ -0,0 +1,37 @@
+import type { MothershipBlockDetail } from '@/lib/api/contracts/mothership-catalog'
+import { PROVIDER_DEFINITIONS } from '@/providers/models'
+
+/** Enrich only authorized, already-published options; these facts never grant model access. */
+export function withModelHints(detail: MothershipBlockDetail): MothershipBlockDetail {
+  if (
+    !detail.inputSchema.some(
+      (field) => field.id === 'model' && field.type === 'combobox' && field.options?.length
+    )
+  )
+    return detail
+  const models = new Map(
+    Object.values(PROVIDER_DEFINITIONS).flatMap((provider) =>
+      provider.models.map((model) => [model.id.toLowerCase(), model] as const)
+    )
+  )
+  return {
+    ...detail,
+    inputSchema: detail.inputSchema.map((field) => {
+      if (field.id !== 'model' || field.type !== 'combobox' || !field.options?.length) return field
+      return {
+        ...field,
+        optionsAvailability:
+          'Model availability depends on deployment, provider credentials and model permissions; catalog options do not establish access.',
+        options: field.options.map((option) => {
+          const model = models.get(option.id.toLowerCase())
+          return {
+            ...option,
+            ...(model?.recommended ? { recommended: true as const } : {}),
+            ...(model?.speedOptimized ? { speedOptimized: true as const } : {}),
+            ...(model?.sunset ? { sunset: { ...model.sunset } } : {}),
+          }
+        }),
+      }
+    }),
+  }
+}