fix: clean up v2 projection and cold history output

- skip empty thinking parts in the agent loop (live stream, interrupted
  drain, cold history) so no empty thinking shells are emitted
- emit the steered prompt's user message when submission races with
  turn completion, assigning it to the new turn exactly once
- emit goal system entries only on goal status transitions, and mirror
  that in cold history (goal.create produces the active entry,
  goal.update/clear produce none)
- let before_turn history paging reach past the compaction floor so
  loading earlier messages keeps returning pages
- refresh the v2 example fixtures and add a steer-race projection case

Author: liruifengv

.changeset/fix-empty-thinking-parts.md

@@ -0,0 +1,5 @@
+---
+"@moonshot-ai/kimi-code": patch
+---
+
+Fix empty thinking entries recorded for steps without reasoning content.

.changeset/fix-history-paging-past-compaction.md

@@ -0,0 +1,5 @@
+---
+"@moonshot-ai/kimi-code": patch
+---
+
+Fix earlier-message history paging returning empty pages before compaction points.

.changeset/goal-status-transitions-only.md

@@ -0,0 +1,5 @@
+---
+"@moonshot-ai/kimi-code": patch
+---
+
+Emit goal status stream entries only when the goal status actually changes.

packages/agent-core-v2/src/agent/loop/loopService.ts

@@ -932,6 +932,7 @@ export class AgentLoopService extends Disposable implements IAgentLoopService {
     response: AgentLLMRequestFinish,
   ): void {
     for (const part of response.message.content) {
+      if (part.type === 'think' && part.think === '' && (part as { encrypted?: string }).encrypted === undefined) continue;
       this.context.appendLoopEvent({
         type: 'content.part',
         uuid: randomUUID(),
@@ -950,6 +951,7 @@ export class AgentLoopService extends Disposable implements IAgentLoopService {
     streamParts: StreamPartCollector,
   ): void {
     for (const part of streamParts.drainInterruptedContent()) {
+      if (part.type === 'think' && part.think === '' && (part as { encrypted?: string }).encrypted === undefined) continue;
       this.context.appendLoopEvent({
         type: 'content.part',
         uuid: randomUUID(),
@@ -1144,13 +1146,19 @@ export class AgentLoopService extends Disposable implements IAgentLoopService {
               new AssistantDelta({ agentId: this.scopeContext.agentId, turnId, delta: part.text }),
             );
             return;
-          case 'think':
+          case 'think': {
+            const hasPayload =
+              part.think !== '' || (part as { encrypted?: string }).encrypted !== undefined;
+            if (!hasPayload) return;
             onResponseEvent();
             accumulate(part);
-            void this.dispatcher.dispatch(
-              new ThinkingDelta({ agentId: this.scopeContext.agentId, turnId, delta: part.think }),
-            );
+            if (part.think !== '') {
+              void this.dispatcher.dispatch(
+                new ThinkingDelta({ agentId: this.scopeContext.agentId, turnId, delta: part.think }),
+              );
+            }
             return;
+          }
           case 'image_url':
           case 'audio_url':
           case 'video_url':

packages/kap-server/src/services/v2Projection/agentProjector.ts

@@ -587,6 +587,7 @@ export class AgentV2Projector {
     const acc = this.prompts.get(event.promptId as string);
     if (!acc || acc.status === 'completed') return;
     acc.status = 'completed';
+    if (!acc.emitted) this.assignHeld(acc, this.maxTurnId + 1);
     out.push(this.userMessage(acc, event.time, (event.finishedAt as string) ?? iso(event.time)));
   }
 
@@ -597,6 +598,7 @@ export class AgentV2Projector {
     if (qi >= 0) this.queue.splice(qi, 1);
     if (acc.status !== 'completed') {
       acc.status = 'completed';
+      if (!acc.emitted) this.assignHeld(acc, this.maxTurnId + 1);
       out.push(this.userMessage(acc, event.time, (event.abortedAt as string) ?? iso(event.time)));
     }
     out.push({
@@ -608,6 +610,14 @@ export class AgentV2Projector {
     });
   }
 
+  private assignHeld(acc: PromptAcc, engineTurnId: number): void {
+    const turnId = this.protocolTurnId(engineTurnId);
+    const seq = this.nextUserSeq(engineTurnId);
+    acc.messageId = `${turnId}.u${seq}`;
+    acc.turnId = turnId;
+    acc.emitted = true;
+  }
+
   private onTurnStarted(event: ProjectionEvent, out: ServerMessage[]): void {
     const engineTurnId = event.turnId as number;
     this.maxTurnId = Math.max(this.maxTurnId, engineTurnId);
@@ -629,14 +639,20 @@ export class AgentV2Projector {
     }
     turn.userSeq = maxSeq;
     const promptId = event.promptId as string | undefined;
+    let heldAcc: PromptAcc | undefined;
     if (promptId) {
       const acc = this.prompts.get(promptId);
+      if (acc && !acc.emitted) {
+        this.assignHeld(acc, engineTurnId);
+        heldAcc = acc;
+      }
       turn.userMessageId = acc?.messageId ?? promptId;
       turn.promptIds.push(promptId);
       turn.attachmentIds = acc?.attachmentIds;
     }
     this.turns.set(engineTurnId, turn);
     out.push(this.turnMessage(turn, event.time));
+    if (heldAcc) out.push(this.userMessage(heldAcc, event.time));
   }
 
   private onTurnEnded(event: ProjectionEvent, out: ServerMessage[]): void {
@@ -762,6 +778,7 @@ export class AgentV2Projector {
     const step = this.currentStep;
     if (!step) return;
     let acc = kind === 'assistant' ? this.openAssistant : this.openThinking;
+    if (!acc && delta.length === 0) return;
     if (!acc || acc.stepKey !== step.stepId) {
       this.closeOpenTexts(event.time, out);
       const seq = kind === 'assistant' ? step.textSeq.a++ : step.textSeq.h++;
@@ -1025,8 +1042,13 @@ export class AgentV2Projector {
     });
   }
 
+  private lastGoalStatus?: string;
+
   private onGoalUpdated(event: ProjectionEvent, out: ServerMessage[]): void {
     const snapshot = event.snapshot as { status?: string; objective?: string } | null | undefined;
+    const status = snapshot?.status;
+    if (status === this.lastGoalStatus) return;
+    this.lastGoalStatus = status;
     if (!snapshot) return;
     out.push({
       type: 'system',

packages/kap-server/src/services/v2Projection/coldHistory.ts

@@ -105,7 +105,7 @@ interface InteractionAcc {
 }
 
 interface SystemAcc {
-  subtype: 'interruption' | 'undo';
+  subtype: 'interruption' | 'undo' | 'goal';
   payload: Record<string, unknown>;
   time?: number;
   recordIndex: number;
@@ -381,6 +381,7 @@ export function buildColdHistory(
           const kind = partType === 'think' ? 'thinking' : partType === 'text' ? 'assistant' : undefined;
           if (!kind) break;
           const text = kind === 'thinking' ? asText(part?.['think']) ?? '' : asText(part?.['text']) ?? '';
+          if (text.length === 0) break;
           if (!step.openText || step.openText.kind !== kind) {
             sealOpenText(step);
             const seq = kind === 'assistant' ? step.textSeq.a++ : step.textSeq.h++;
@@ -507,6 +508,19 @@ export function buildColdHistory(
         });
         break;
       }
+      case 'goal.create': {
+        looseSystems.push({
+          subtype: 'goal',
+          payload: { status: 'active', objective: asText(record['objective']) },
+          time,
+          recordIndex,
+        });
+        break;
+      }
+      case 'goal.update':
+      case 'goal.clear': {
+        break;
+      }
       case 'context.apply_compaction': {
         floorIndex = recordIndex;
         floorTime = time;
@@ -544,7 +558,7 @@ export function buildColdHistory(
     }
   }
 
-  const keptTurns = turns.filter((turn) => turn.lastRecordIndex > floorIndex);
+  const keptTurns = query.beforeTurn !== undefined ? turns : turns.filter((turn) => turn.lastRecordIndex > floorIndex);
 
   interface FlatUnit {
     pos: number;
@@ -775,7 +789,7 @@ export function buildColdHistory(
 
   for (const task of tasks.values()) {
     const lastTime = task.terminatedTime ?? task.lastTime ?? task.startedTime;
-    if (lastTime !== undefined && floorTime !== undefined && lastTime <= floorTime) continue;
+    if (query.beforeTurn === undefined && lastTime !== undefined && floorTime !== undefined && lastTime <= floorTime) continue;
     const startedInfo = task.startedInfo;
     const terminatedInfo = task.terminatedInfo;
     units.push({