Method MarkStale

coderd/x/gitsync/worker.go:292–323

MarkStale persists the git ref for a chat (or all chats on a workspace when no ChatID is provided), setting stale_at to the past so the next tick picks them up. Publishes a diff status event for each affected chat. Called from workspaceagents handlers. No goroutines spawned.

(ctx context.Context, p MarkStaleParams)

// event for each affected chat.
// Called from workspaceagents handlers. No goroutines spawned.
func (w *Worker) MarkStale(ctx context.Context, p MarkStaleParams) {
	if p.Branch == "" || p.Origin == "" {
		return
	}

	// When a specific chat is identified, target it directly
	// instead of broadcasting to every chat on the workspace.
	// Note: this path does not verify that the chat belongs to
	// WorkspaceID. This is safe because ChatID originates from
	// chatd via the agent (trusted data flow), but differs from
	// the broadcast path which filters by workspace.
	if p.ChatID != uuid.Nil {
		w.markStaleSingle(ctx, p.ChatID, p.Branch, p.Origin)
		return
	}

	// Broadcast path: scope by workspace. GetChatsByWorkspaceIDs
	// filters archived=false, which is intentional: archived
	// chats aren't in the active sidebar and don't need refreshed
	// git refs.
	chats, err := w.store.GetChatsByWorkspaceIDs(ctx, []uuid.UUID{p.WorkspaceID})
	if err != nil {
		w.logger.Warn(ctx, "list chats for git ref storage",
			slog.F("workspace_id", p.WorkspaceID),
			slog.Error(err))
		return
	}

	for _, chat := range chats {
		w.markStaleSingle(ctx, chat.ID, p.Branch, p.Origin)
	}
}

// markStaleSingle upserts the git ref for a single chat and
// publishes a diff-status change event.