fix(mothership): reconcile staging contracts and consolidate migrations

Author: Sg312

apps/docs/openapi-v2-knowledge.json

@@ -5942,7 +5942,7 @@
           },
           "rankScore": {
             "type": "number",
-            "description": "The score results are ordered by, descending. In `vector` mode it equals `similarity`; in `hybrid` mode it is the reciprocal-rank-fusion score (a sum of 1/(60 + rank) over the lexical and vector legs, so a chunk both legs ranked first scores 2/61); when a reranker ordered the results it is `rerankerScore`.",
+            "description": "Retrieval score before optional recency boosting. In `vector` mode it equals `similarity`; in `hybrid` mode it is the reciprocal-rank-fusion score (a sum of 1/(60 + rank) over the lexical and vector legs). When a reranker orders the results it is `rerankerScore`. Use `rank` for the final order.",
             "examples": [0.0328]
           },
           "rank": {

apps/docs/openapi-v2-tables.json

@@ -5658,16 +5658,7 @@
                 },
                 "type": {
                   "type": "string",
-                  "enum": [
-                    "string",
-                    "number",
-                    "currency",
-                    "boolean",
-                    "date",
-                    "ttl",
-                    "json",
-                    "select"
-                  ],
+                  "enum": ["string", "number", "currency", "boolean", "date", "json", "select"],
                   "description": "Data type of values stored in the column."
                 },
                 "required": {

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

@@ -2,6 +2,7 @@
  * @vitest-environment node
  */
 import { createMockRequest } from '@sim/testing'
+import { sleep } from '@sim/utils/helpers'
 import { beforeEach, describe, expect, it, vi } from 'vitest'
 
 const {
@@ -198,7 +199,7 @@ describe('POST /api/copilot/chat/abort', () => {
       const controller = new AbortController()
       const timeout = vi.spyOn(AbortSignal, 'timeout').mockReturnValue(controller.signal)
       mockWaitForPendingChatStream.mockImplementationOnce(async () => {
-        await new Promise((resolve) => setTimeout(resolve, 8000))
+        await sleep(8000)
         return false
       })
       const response = POST(abortRequest())

apps/sim/app/api/copilot/tool-permission/route.ts

@@ -29,8 +29,6 @@ import {
   createUnauthorizedResponse,
 } from '@/lib/mothership/request/http'
 import { withIncomingGoSpan } from '@/lib/mothership/request/otel'
-import { isCopilotToolPermissionsEnabled } from '@/lib/core/config/env-flags'
-import { withRouteHandler } from '@/lib/core/utils/with-route-handler'
 import { isWorkspaceCapabilityWithheld } from '@/lib/permission-groups/capability-assertions'
 
 const logger = createLogger('CopilotToolPermissionAPI')

apps/sim/app/api/files/serve/[...path]/route.ts

@@ -9,8 +9,6 @@ import {
   InternalUnauthenticatedError,
 } from '@/lib/api/server/routes'
 import { AuthType, checkSessionOrInternalAuth } from '@/lib/auth/hybrid'
-import { resolveServableDocBytes } from '@/lib/mothership/tools/server/files/doc-compile'
-import { DocCompileUserError } from '@/lib/mothership/tools/server/files/doc-compile-error'
 import { asOrchestrationError } from '@/lib/core/orchestration/types'
 import { assertKnownSizeWithinLimit, isPayloadSizeLimitError } from '@/lib/core/utils/stream-limits'
 import { withRouteHandler } from '@/lib/core/utils/with-route-handler'

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

@@ -125,7 +125,7 @@ vi.mock('@/lib/permission-groups/config-scope.server', () => permissionGroupScop
 const mockResolvePermissionGroupConfig =
   permissionGroupScopeMockFns.mockResolvePermissionGroupConfig
 
-import { chatOperations } from '@/lib/copilot/application/operations'
+import { chatOperations } from '@/lib/mothership/application/operations'
 import { CAPABILITY_RULES } from '@/lib/permission-groups/capabilities'
 import { DEFAULT_PERMISSION_GROUP_CONFIG } from '@/lib/permission-groups/fields'
 import { POST } from '@/app/api/v2/chat/route'

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

@@ -13,6 +13,12 @@ import {
   v2RateLimits,
 } from '@/lib/api/server/routes'
 import { resolveBillingAttribution } from '@/lib/billing/core/billing-attribution'
+import {
+  forbiddenErrorDetails,
+  PersonalApiKeysDisabledError,
+  requirePersonalApiKeysAllowed,
+  type WorkspaceAuthorizationContext,
+} from '@/lib/core/application'
 import { withRouteHandler } from '@/lib/core/utils/with-route-handler'
 import { getPersonalAndWorkspaceEnv } from '@/lib/environment/utils'
 import { chatOperations } from '@/lib/mothership/application/operations'
@@ -32,25 +38,16 @@ import {
   MothershipStreamV1EventType,
   MothershipStreamV1TextChannel,
 } from '@/lib/mothership/generated/mothership-stream-v1'
+import { PROTOCOL_VERSION } from '@/lib/mothership/generated/protocol'
 import { runHeadlessCopilotLifecycle } from '@/lib/mothership/request/lifecycle/headless'
 import { requestExplicitStreamAbort } from '@/lib/mothership/request/session/explicit-abort'
 import type { OrchestratorResult, StreamEvent } from '@/lib/mothership/request/types'
 import { normalizeSecretMountPolicy } from '@/lib/mothership/secret-mount-policy'
-import {
-  forbiddenErrorDetails,
-  PersonalApiKeysDisabledError,
-  requirePersonalApiKeysAllowed,
-  type WorkspaceAuthorizationContext,
-} from '@/lib/core/application'
-import { isDocSandboxEnabled } from '@/lib/core/config/env-flags'
-import { withRouteHandler } from '@/lib/core/utils/with-route-handler'
-import { getPersonalAndWorkspaceEnv } from '@/lib/environment/utils'
 import { CAPABILITY_RULES } from '@/lib/permission-groups/capabilities'
 import {
   capabilityRefusal,
   isWorkspaceCapabilityWithheld,
 } from '@/lib/permission-groups/capability-assertions'
-import { PROTOCOL_VERSION } from '@/lib/mothership/generated/protocol'
 import {
   assertActiveWorkspaceAccess,
   isWorkspaceAccessDeniedError,

apps/sim/app/workspace/[workspaceId]/components/message-actions/message-actions.tsx

@@ -19,7 +19,7 @@ import {
   useCopyToClipboard,
 } from '@sim/emcn'
 import { useParams, useRouter } from 'next/navigation'
-import { isLiveAssistantMessageId } from '@/lib/mothership/chat/effective-transcript'
+import { isLiveAssistantMessageId } from '@/lib/mothership/chat/live-message-id'
 import { useChatSurface } from '@/app/workspace/[workspaceId]/home/components/chat-surface-context'
 import { useSubmitCopilotFeedback } from '@/hooks/queries/copilot-feedback'
 import { useForkMothershipChat } from '@/hooks/queries/mothership-chats'

apps/sim/app/workspace/[workspaceId]/home/components/user-input/components/plus-menu-dropdown/plus-menu-dropdown.test.tsx

@@ -48,11 +48,11 @@ vi.mock('@/blocks/integration-matcher', () => ({
 vi.mock('@/stores/browser-session/store', () => ({ useBrowserSessionStore: () => fixtures.tabs }))
 vi.mock('@/stores/copilot-terminal/store', () => ({ useCopilotTerminalStore: () => fixtures.tabs }))
 
+import { setDesktopPreferencesSnapshot } from '@/lib/desktop'
 import {
   BROWSER_SESSION_RESOURCE_ID,
   TERMINAL_SESSION_RESOURCE_ID,
-} from '@/lib/copilot/resources/types'
-import { setDesktopPreferencesSnapshot } from '@/lib/desktop'
+} from '@/lib/mothership/resources/types'
 import {
   mapResourceToContext,
   type PlusMenuHandle,

apps/sim/app/workspace/[workspaceId]/home/hooks/send-handoff.ts

@@ -7,6 +7,7 @@
 import { generateId } from '@sim/utils/id'
 import { isRecordLike } from '@sim/utils/object'
 import { STREAM_STORAGE_KEY } from '@/lib/mothership/constants'
+import type { ChatRequestMode } from '@/app/workspace/[workspaceId]/home/types'
 import type { QueuedSendHandoffSeed } from '@/stores/mothership-queue/types'
 import type { ChatContext } from '@/stores/panel'
 import type { FileAttachmentForApi } from '../types'
@@ -24,6 +25,7 @@ export interface QueuedSendHandoffState extends QueuedSendHandoffSeed {
   message: string
   fileAttachments?: FileAttachmentForApi[]
   contexts?: ChatContext[]
+  requestMode?: ChatRequestMode
   requestedAt: number
   resolveAttempts?: number
 }
@@ -167,6 +169,7 @@ export function readQueuedSendHandoffState(): QueuedSendHandoffState | null {
       ...(Array.isArray(parsed.contexts)
         ? { contexts: parsed.contexts.filter(isChatContext) }
         : {}),
+      ...(parsed.requestMode === 'ask' ? { requestMode: parsed.requestMode } : {}),
       requestedAt: parsed.requestedAt,
       ...(typeof parsed.resolveAttempts === 'number' &&
       Number.isFinite(parsed.resolveAttempts) &&