feat(mothership): per-turn effort dial — composer dropdown, request pass-through

The composer gains an effort dropdown (low..max, default high,
persisted preference); the selection rides the chat POST and the v2
chat API (new optional effort field) through to the worker, which
applies it per turn and keeps it across continuations.

Claude-Session: https://claude.ai/code/session_01CgaxNAaeD3taGdghbXn17w

Author: Sg312

apps/sim/app/api/v2/chat/route.ts

@@ -195,7 +195,7 @@ export const POST = withRouteHandler(
 
     const parsed = await parseRequest(v2ChatContract, req, {}, { ...V2_PARSE_DEFAULTS })
     if (!parsed.success) return parsed.response
-    const { workspaceId, message, conversationId } = parsed.data.body
+    const { workspaceId, message, conversationId, effort } = parsed.data.body
 
     const messageId = generateId()
     const requestId = generateId()
@@ -346,6 +346,7 @@ export const POST = withRouteHandler(
         chatId,
         messageId,
         ...(integrationTools.length > 0 ? { integrationTools } : {}),
+        ...(effort ? { effort } : {}),
       }
 
       let allowExplicitAbort = true

apps/sim/app/workspace/[workspaceId]/home/components/user-input/user-input.tsx

@@ -10,7 +10,7 @@ import {
   useRef,
   useState,
 } from 'react'
-import { Button, cn, Paperclip, Plus, Slash, Tooltip, toast } from '@sim/emcn'
+import { Button, ChipDropdown, cn, Paperclip, Plus, Slash, Tooltip, toast } from '@sim/emcn'
 import { createLogger } from '@sim/logger'
 import { useParams } from 'next/navigation'
 import { getDesktopBridge } from '@/lib/desktop'
@@ -42,6 +42,11 @@ import { mentionifyIntegrations } from '@/blocks/integration-matcher'
 import { useSettingsNavigation } from '@/hooks/use-settings-navigation'
 import { type SpeechToTextError, useSpeechToText } from '@/hooks/use-speech-to-text'
 import { type DraftPayload, useMothershipDraftsStore } from '@/stores/mothership-drafts/store'
+import {
+  MOTHERSHIP_EFFORT_OPTIONS,
+  type MothershipEffort,
+  useMothershipEffortStore,
+} from '@/stores/mothership-effort/store'
 import type { ChatContext } from '@/stores/panel'
 
 export type { FileAttachmentForApi } from '@/app/workspace/[workspaceId]/home/types'
@@ -649,6 +654,9 @@ const UserInputImpl = forwardRef<UserInputHandle, UserInputProps>(function UserI
     editorRef.current.openResourceMenu({ left: rect.left, top: rect.top })
   }, [])
 
+  const effort = useMothershipEffortStore((state) => state.effort)
+  const setEffort = useMothershipEffortStore((state) => state.setEffort)
+
   const handleSlashTriggerClick = useCallback(() => {
     editorRef.current.insertSlashTrigger()
   }, [])
@@ -733,6 +741,12 @@ const UserInputImpl = forwardRef<UserInputHandle, UserInputProps>(function UserI
             </Tooltip.Trigger>
             <Tooltip.Content side='top'>Skills</Tooltip.Content>
           </Tooltip.Root>
+          <ChipDropdown
+            options={MOTHERSHIP_EFFORT_OPTIONS}
+            value={effort}
+            placeholder='Effort'
+            onChange={(value) => setEffort(value as MothershipEffort)}
+          />
         </div>
         <div className='flex items-center gap-1.5'>
           {canSearch && <ModeSwitcher onLeaveSearch={handleLeaveSearch} />}

apps/sim/app/workspace/[workspaceId]/home/hooks/use-chat.ts

@@ -119,6 +119,7 @@ import { workflowKeys } from '@/hooks/queries/workflows'
 import { useExecutionStream } from '@/hooks/use-execution-stream'
 import { snapAllSmoothText } from '@/hooks/use-smooth-text'
 import { useExecutionStore } from '@/stores/execution/store'
+import { useMothershipEffortStore } from '@/stores/mothership-effort/store'
 import { useMothershipQueueStore } from '@/stores/mothership-queue/store'
 import type {
   QueuedMothershipMessage,
@@ -3401,6 +3402,7 @@ export function useChat(
             // subagent) — the server gates the features on these flags.
             ...desktopChatCapabilities,
             userTimezone: Intl.DateTimeFormat().resolvedOptions().timeZone,
+            effort: useMothershipEffortStore.getState().effort,
           }),
           signal: abortController.signal,
         })

apps/sim/lib/api/contracts/v2/chat.ts

@@ -27,6 +27,10 @@ export const v2ChatBodySchema = z.object({
     .uuid('conversationId must be a valid conversation id')
     .optional()
     .describe('Conversation to continue; a new one starts when omitted.'),
+  effort: z
+    .enum(['low', 'medium', 'high', 'xhigh', 'max'])
+    .optional()
+    .describe('Model effort for this turn; defaults to the deployment default (high).'),
 })
 
 const v2ChatTokensSchema = z.object({

apps/sim/lib/mothership/chat/payload.ts

@@ -55,6 +55,8 @@ interface BuildPayloadParams {
   userPermission?: string
   /** Plan/flag-gated org capabilities (e.g. "custom-blocks") the mothership gates tools/prompts on. */
   userTimezone?: string
+  /** Per-turn model effort dial (user-selected in the composer). */
+  effort?: 'low' | 'medium' | 'high' | 'xhigh' | 'max'
   desktopLocalFilesystem?: boolean
   browser?: boolean
   terminalCapable?: boolean
@@ -428,6 +430,7 @@ export async function buildCopilotRequestPayload(
     ...(integrationTools.length > 0 ? { integrationTools } : {}),
     ...(mothershipTools.length > 0 ? { mothershipTools } : {}),
     ...(params.userTimezone ? { userTimezone: params.userTimezone } : {}),
+    ...(params.effort ? { effort: params.effort } : {}),
     // The mounted chat view executes client-routed workflow tools (run panel UX), so the
     // UI declares that capability explicitly; headless callers omit or send [] and the
     // server runs those tools immediately instead of waiting out the pickup grace.

apps/sim/lib/mothership/chat/post.ts

@@ -287,6 +287,8 @@ const ChatMessageSchema = z.object({
   contexts: z.array(ChatContextSchema).optional(),
   commands: z.array(z.string()).optional(),
   userTimezone: z.string().optional(),
+  /** Per-turn model effort dial; forwarded verbatim to the worker. */
+  effort: z.enum(['low', 'medium', 'high', 'xhigh', 'max']).optional(),
   /**
    * Contract ChatRequest.clientCapabilities: what this caller can execute client-side.
    * PRESENT = explicit declaration (empty array → no client pickup, dispatch runs
@@ -354,6 +356,7 @@ type UnifiedChatBranch =
         fileAttachments?: UnifiedChatRequest['fileAttachments']
         userPermission?: string
         userTimezone?: string
+        effort?: 'low' | 'medium' | 'high' | 'xhigh' | 'max'
         workflowId: string
         workflowName?: string
         workspaceId?: string
@@ -394,6 +397,7 @@ type UnifiedChatBranch =
         fileAttachments?: UnifiedChatRequest['fileAttachments']
         userPermission?: string
         userTimezone?: string
+        effort?: 'low' | 'medium' | 'high' | 'xhigh' | 'max'
         desktopLocalFilesystem?: boolean
         browser?: boolean
         terminalCapable?: boolean
@@ -878,6 +882,7 @@ async function resolveBranch(params: {
             implicitFeedback: payloadParams.implicitFeedback,
             userPermission: payloadParams.userPermission,
             userTimezone: payloadParams.userTimezone,
+            effort: payloadParams.effort,
             desktopLocalFilesystem: payloadParams.desktopLocalFilesystem,
             browser: payloadParams.browser,
             terminalCapable: payloadParams.terminalCapable,
@@ -936,6 +941,7 @@ async function resolveBranch(params: {
           chatId: payloadParams.chatId,
           userPermission: payloadParams.userPermission,
           userTimezone: payloadParams.userTimezone,
+          effort: payloadParams.effort,
           desktopLocalFilesystem: payloadParams.desktopLocalFilesystem,
           browser: payloadParams.browser,
           terminalCapable: payloadParams.terminalCapable,
@@ -1372,6 +1378,7 @@ export async function handleUnifiedChatPost(req: NextRequest) {
                 fileAttachments: body.fileAttachments,
                 userPermission: userPermission ?? undefined,
                 userTimezone: body.userTimezone,
+                effort: body.effort,
                 workflowId: branch.workflowId,
                 workflowName: branch.workflowName,
                 workspaceId: branch.workspaceId,
@@ -1396,6 +1403,7 @@ export async function handleUnifiedChatPost(req: NextRequest) {
                 fileAttachments: body.fileAttachments,
                 userPermission: userPermission ?? undefined,
                 userTimezone: body.userTimezone,
+                effort: body.effort,
                 desktopLocalFilesystem: body.desktopCapabilities?.localFilesystem === true,
                 browser: body.desktopCapabilities?.browser === true,
                 terminalCapable: body.desktopCapabilities?.terminal === true,

apps/sim/stores/mothership-effort/store.ts

@@ -0,0 +1,31 @@
+import { create } from 'zustand'
+import { devtools, persist } from 'zustand/middleware'
+
+/** The composer's model-effort dial, forwarded per request to the mothership. */
+export type MothershipEffort = 'low' | 'medium' | 'high' | 'xhigh' | 'max'
+
+export const MOTHERSHIP_EFFORT_OPTIONS: Array<{ value: MothershipEffort; label: string }> = [
+  { value: 'low', label: 'Low effort' },
+  { value: 'medium', label: 'Medium effort' },
+  { value: 'high', label: 'High effort' },
+  { value: 'xhigh', label: 'X-high effort' },
+  { value: 'max', label: 'Max effort' },
+]
+
+interface MothershipEffortState {
+  effort: MothershipEffort
+  setEffort: (effort: MothershipEffort) => void
+}
+
+export const useMothershipEffortStore = create<MothershipEffortState>()(
+  devtools(
+    persist(
+      (set) => ({
+        effort: 'high',
+        setEffort: (effort) => set({ effort }),
+      }),
+      { name: 'mothership-effort' }
+    ),
+    { name: 'mothership-effort-store' }
+  )
+)