fix(mothership): streaming invariant projection enforcement

Author: icecrasher321

apps/docs/components/icons.tsx

@@ -1958,6 +1958,24 @@ export function WhatsAppIcon(props: SVGProps<SVGSVGElement>) {
   )
 }
 
+export function SportmonksIcon(props: SVGProps<SVGSVGElement>) {
+  return (
+    <svg
+      {...props}
+      viewBox='0 0 25 24'
+      fill='none'
+      fillRule='evenodd'
+      xmlns='http://www.w3.org/2000/svg'
+    >
+      <path
+        d='M11.857 8.546c1.893 0 3.517.678 4.872 2.033 1.355 1.336 2.032 2.96 2.032 4.872 0 1.91-.677 3.535-2.032 4.871-1.355 1.355-2.979 2.032-4.872 2.032H1V17.093h10.857c.446 0 .825-.157 1.142-.473.334-.334.5-.724.5-1.17 0-.445-.166-.835-.5-1.17a1.558 1.558 0 00-1.142-.472H7.905c-1.912 0-3.537-.677-4.873-2.032C1.678 10.421 1 8.796 1 6.903 1 4.993 1.678 3.368 3.033 2.032 4.368.678 5.992 0 7.905 0h10.188V5.263H7.904a1.65 1.65 0 00-1.17.473 1.586 1.586 0 00-.472 1.169c0 .445.157.835.473 1.17.334.315.724.472 1.17.472h3.952z'
+        fill='currentColor'
+      />
+      <circle cx='21.27' cy='20.123' r='2.732' fill='#FF0F50' />
+    </svg>
+  )
+}
+
 export function SquareIcon(props: SVGProps<SVGSVGElement>) {
   return (
     <svg {...props} viewBox='0 0 501.42 501.42' xmlns='http://www.w3.org/2000/svg'>

apps/docs/components/ui/icon-mapping.ts

@@ -190,6 +190,7 @@ import {
   SixtyfourIcon,
   SlackIcon,
   SmtpIcon,
+  SportmonksIcon,
   SQSIcon,
   SquareIcon,
   SshIcon,
@@ -439,6 +440,7 @@ export const blockTypeToIconMap: Record<string, IconComponent> = {
   sixtyfour: SixtyfourIcon,
   slack: SlackIcon,
   smtp: SmtpIcon,
+  sportmonks: SportmonksIcon,
   sqs: SQSIcon,
   square: SquareIcon,
   ssh: SshIcon,

apps/docs/content/docs/en/integrations/meta.json

@@ -191,6 +191,7 @@
     "sixtyfour",
     "slack",
     "smtp",
+    "sportmonks",
     "sqs",
     "square",
     "ssh",

apps/docs/content/docs/en/integrations/sportmonks.mdx

@@ -381,6 +381,24 @@ describe('reduceEvent — edit_content row merge', () => {
     expect(tool(m, 'wf-1').result?.success).toBe(true)
     expect(m.bufferedResults.has('ec-1')).toBe(false)
   })
+
+  it('finalizes a stale running section row when the next section opens', () => {
+    const sub: Scope = { lane: 'subagent', spanId: 'S1' }
+    const m = apply([
+      spanStart(1, 'S1', 'file', 'tc-file'),
+      // Section 1: the workspace_file row is reopened by its edit_content, but the
+      // edit's closing result is reordered/dropped — wf-1 is left running.
+      toolCall(2, 'wf-1', 'workspace_file', sub),
+      toolResult(3, 'wf-1', true, undefined, sub),
+      toolCall(4, 'ec-1', 'edit_content', sub),
+      // Section 2 opens before section 1's edit result lands.
+      toolCall(5, 'wf-2', 'workspace_file', sub),
+    ])
+    // The previous section settles instead of spinning until the turn terminal...
+    expect(tool(m, 'wf-1').status).toBe('success')
+    // ...and the new section's row is the live write.
+    expect(tool(m, 'wf-2').status).toBe('running')
+  })
 })
 
 describe('reduceEvent — error tag + compaction coverage', () => {

apps/sim/app/workspace/[workspaceId]/home/hooks/stream/turn-model.test.ts

@@ -150,6 +150,31 @@ function findWorkspaceFileNodeInSpan(model: TurnModel, spanId: string): ToolNode
   return undefined
 }
 
+/**
+ * The file agent writes a file as strictly sequential `workspace_file` +
+ * `edit_content` section pairs, waiting for each to finish before the next. So
+ * when a new section's `workspace_file` opens, any earlier `workspace_file` row
+ * still `running` in the same span is a completed section whose closing
+ * `edit_content` result was reordered or dropped — finalize it as success so its
+ * "writing" spinner resolves when the next section starts, instead of lingering
+ * until the turn-terminal sweep. A no-op on the happy path (prior rows already
+ * settled on their own result).
+ */
+function finalizeStaleWorkspaceFiles(model: TurnModel, spanId: string): void {
+  for (const id of model.order) {
+    const node = model.nodes.get(id)
+    if (
+      node?.kind === 'tool' &&
+      node.spanId === spanId &&
+      node.name === WORKSPACE_FILE_TOOL &&
+      node.status === 'running'
+    ) {
+      node.status = 'success'
+      node.streamingArgs = undefined
+    }
+  }
+}
+
 function isRecord(value: unknown): value is Record<string, unknown> {
   return typeof value === 'object' && value !== null && !Array.isArray(value)
 }
@@ -438,6 +463,11 @@ export function reduceEvent(model: TurnModel, envelope: PersistedStreamEventEnve
             break
           }
         }
+        // A new file section opening settles any earlier still-running section row
+        // in this span (the file agent writes sections sequentially).
+        if (toolName === WORKSPACE_FILE_TOOL && !model.nodes.has(rawToolCallId)) {
+          finalizeStaleWorkspaceFiles(model, spanId)
+        }
         const node = upsertToolNode(
           model,
           resolveToolId(model, rawToolCallId),