Remove default Mship execution cutoff and expose Slack agent prerequisites

Author: Sg312

apps/sim/app/api/copilot/chat/stream/route.test.ts

@@ -141,33 +141,43 @@ describe('copilot chat stream replay route', () => {
     })
   })
 
-  it('stops replay polling when run becomes cancelled', async () => {
-    getLatestRunForStream
-      .mockResolvedValueOnce({
-        status: 'active',
-        executionId: 'exec-1',
-        id: 'run-1',
-      })
-      .mockResolvedValueOnce({
-        status: 'cancelled',
-        executionId: 'exec-1',
-        id: 'run-1',
+  it.each([0, 2 * 60 * 60_000])(
+    'delivers cancellation after %i ms of replay',
+    async (elapsedMs) => {
+      const now = Date.now()
+      const clock = vi.spyOn(Date, 'now').mockReturnValue(now)
+      readEvents.mockImplementationOnce(async () => {
+        clock.mockReturnValue(now + elapsedMs)
+        return []
       })
+      getLatestRunForStream
+        .mockResolvedValueOnce({
+          status: 'active',
+          executionId: 'exec-1',
+          id: 'run-1',
+        })
+        .mockResolvedValueOnce({
+          status: 'cancelled',
+          executionId: 'exec-1',
+          id: 'run-1',
+        })
 
-    const response = await GET(
-      new NextRequest('http://localhost:3000/api/copilot/chat/stream?streamId=stream-1&after=0')
-    )
+      const response = await GET(
+        new NextRequest('http://localhost:3000/api/copilot/chat/stream?streamId=stream-1&after=0')
+      )
 
-    const chunks = await readAllChunks(response)
-    expect(chunks[0]).toBe(': accepted\n\n')
-    expect(chunks.join('')).toContain(
-      JSON.stringify({
-        status: MothershipStreamV1CompletionStatus.cancelled,
-        reason: 'terminal_status',
-      })
-    )
-    expect(getLatestRunForStream).toHaveBeenCalledTimes(2)
-  })
+      const chunks = await readAllChunks(response)
+      expect(chunks[0]).toBe(': accepted\n\n')
+      expect(chunks.join('')).toContain(
+        JSON.stringify({
+          status: MothershipStreamV1CompletionStatus.cancelled,
+          reason: 'terminal_status',
+        })
+      )
+      expect(getLatestRunForStream).toHaveBeenCalledTimes(2)
+      clock.mockRestore()
+    }
+  )
 
   it('emits structured terminal replay error when run metadata disappears', async () => {
     getLatestRunForStream

apps/sim/app/api/mothership/chat/stream/route.ts

@@ -1,9 +1,7 @@
 import type { NextRequest } from 'next/server'
 import { mothershipChatStreamQuerySchema } from '@/lib/api/contracts/mothership-chats'
 import { validationErrorResponse } from '@/lib/api/server'
-import { GET as copilotStreamGet, maxDuration } from '@/app/api/copilot/chat/stream/route'
-
-export { maxDuration }
+import { GET as copilotStreamGet } from '@/app/api/copilot/chat/stream/route'
 
 export function GET(request: NextRequest) {
   const validation = mothershipChatStreamQuerySchema.safeParse(

apps/sim/blocks/blocks/slack.ts

@@ -19,6 +19,7 @@ import {
   parseOptionalNumberInput,
 } from '@/blocks/utils'
 import { getTrigger } from '@/triggers'
+import { SLACK_AGENT_SCOPES } from '@/triggers/slack/capabilities'
 
 /**
  * Canonical basic/advanced pair for the channel target, shared by the card
@@ -3503,6 +3504,11 @@ export const SlackV2Block: BlockConfig = {
   description: 'Manage Slack messages, channels, users, files, Lists, canvases, and Agent Sessions',
   longDescription:
     'Build Slack workflows with messages, conversations, files, reactions, pins, bookmarks, user groups, profiles, Lists, canvases, and Agent Sessions. Operations that need additional app scopes use custom Slack bots. Lists require lists:read/lists:write and a paid Slack plan. Native Sim connections retain their existing permissions. Page through list outputs explicitly.',
+  bestPractices: `${SlackBlock.bestPractices}
+Native agent-session streaming uses a custom Slack bot and a supported trigger event. Enable streamResponse and select the intended outputs in streamOutputs; Sim Chat (mothership) streams its content output. The trigger owns the streamed reply, so another send needs a separate purpose.
+The custom-bot manifest's baseline agent scopes are ${SLACK_AGENT_SCOPES.join(', ')}. Selected capabilities add their required scopes and event subscriptions. Verify the installed app's grants, resource access and event configuration; a saved credential or edited manifest alone does not prove access.
+streamIncludeToolCalls displays tool activity; it does not authorize tool execution. Configure Sim Chat's selected operations and their credentials separately. Choose streamIncludeThinking deliberately for the destination audience.
+Block Kit messages can contain buttons, selects and forms, but interactions require the app's interactivity request URL and the corresponding interaction trigger. Treat message events, button/select callbacks and modal submissions as separate paths. A control's action_id/value correlates work; runtime actor and state checks authorize it.`,
   hideFromToolbar: false,
   sunset: undefined,
   canvasPresentation: {

apps/sim/lib/mothership/request/types.ts

@@ -249,6 +249,7 @@ export interface OrchestratorOptions {
   /** Checks the server controller, independently of user cancellation. */
   assertControllerOwnership?: () => Promise<void>
   autoExecuteTools?: boolean
+  /** Optional caller-requested deadline; healthy runs have no default wall-clock limit. */
   timeout?: number
   onEvent?: (event: StreamEvent) => void | Promise<void>
   /**