757
*/
758
private _runTurnCompleteSideEffects(sessionKey: ProtocolURI, turnId: string | undefined): void {
760
>
// scoped to the owning session's working tree, which peer chats
761
>
// share. Normalize an additional-chat channel to its session for
762
>
// those, while keeping the original channel for per-chat queued
763
>
// message consumption (queues live on the chat state). For the
764
>
// default chat / single-chat case `sessionKey` is already the
765
>
// session URI, so this is a no-op.
766
>
const sessionUri = isAhpChatChannel(sessionKey) ? parseRequiredSessionUriFromChatUri(sessionKey) : sessionKey;
767
>
// Capture the end-of-turn git checkpoint BEFORE notifying the
768
>
// changeset service so the per-turn changeset recompute can take
769
>
// the authoritative git-diff fast path (which includes terminal-tool
770
>
// edits the FileEditTracker misses). The capture is best-effort —
771
>
// any failure logs and the changeset pipeline falls back to the
772
>
// `file_edits`-based path. We don't block subsequent side effects
773
>
// (queued message drain, host notification) on the changeset
774
>
// completion since those have always been fire-and-forget; the
775
>
// ordering guarantee we care about is checkpoint-then-changeset.
776
>
if (turnId !== undefined) {
777
>
this._checkpointService.captureTurnCheckpoint(URI.parse(sessionUri), turnId).then(() => {
778
>
this._changesets.onTurnComplete(sessionUri, turnId);
779
>
}, err => {
780
this._logService.warn(`[AgentSideEffects] Turn checkpoint capture failed for ${sessionUri}/${turnId}: ${err instanceof Error ? err.message : String(err)}`);
781
this._changesets.onTurnComplete(sessionUri, turnId);
783
>
} else {
784
this._changesets.onTurnComplete(sessionUri, turnId);
785
}
787
>
this._options.onTurnComplete(sessionUri);
788
>
789
>
// After the first turn completes, refine the auto-generated title using
790
>
// the full first-turn context (request + response). No-op for later
791
>
// turns or when the title has since been changed. `sessionKey` may be an
792
>
// additional chat channel; route it as `chatChannel` so the refinement
793
>
// targets that chat's title, mirroring `seedTitleFromFirstMessage`.
794
>
const titleChatChannel = isAhpChatChannel(sessionKey) && !isDefaultChatUri(sessionKey) ? sessionKey : undefined;
795
>
this._titleController.refineTitleFromFirstTurn(sessionUri, titleChatChannel);
796
>
797
>
// A completed turn produces new output the user may not have seen. Route
798
>
// subagent turns to their owning session too (a background subagent can
799
>
// complete after the parent turn). Each client keeps its active session
800
>
// read; `_markSessionUnread` is idempotent.
801
>
this._markSessionUnread(sessionUri);
802
>
}
803
804
private _markSessionUnread(session: ProtocolURI): void {