Method markStaleSingle

coderd/x/gitsync/worker.go:327–355

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

(
	ctx context.Context,
	chatID uuid.UUID,
	branch, origin string,
)

// markStaleSingle upserts the git ref for a single chat and
// publishes a diff-status change event.
func (w *Worker) markStaleSingle(
	ctx context.Context,
	chatID uuid.UUID,
	branch, origin string,
) {
	_, err := w.store.UpsertChatDiffStatusReference(ctx,
		database.UpsertChatDiffStatusReferenceParams{
			ChatID:          chatID,
			GitBranch:       branch,
			GitRemoteOrigin: origin,
			StaleAt:         w.clock.Now().Add(-time.Second),
			Url:             sql.NullString{},
		},
	)
	if err != nil {
		w.logger.Warn(ctx, "store git ref on chat diff status",
			slog.F("chat_id", chatID),
			slog.Error(err))
		return
	}
	// Notify the frontend immediately so the UI shows the
	// branch info even before the worker refreshes PR data.
	if w.publishDiffStatusChangeFn != nil {
		if pubErr := w.publishDiffStatusChangeFn(ctx, chatID); pubErr != nil {
			w.logger.Debug(ctx, "publish diff status after mark stale",
				slog.F("chat_id", chatID), slog.Error(pubErr))
		}
	}
}

// RefreshChat synchronously refreshes a single chat's diff
// status using the same Refresher pipeline as the background