coder · evgeniy-scherbina · Apr 17, 2025 · Mar 12, 2025 · Mar 13, 2025 · Mar 13, 2025
diff --git a/coderd/database/lock.go b/coderd/database/lock.go
@@ -12,8 +12,7 @@ const (
 	LockIDDBPurge
 	LockIDNotificationsReportGenerator
 	LockIDCryptoKeyRotation
-	LockIDReconcileTemplatePrebuilds
-	LockIDDeterminePrebuildsState
+	LockIDReconcilePrebuilds
 )
 
 // GenLockID generates a unique and consistent lock ID from a given string.

diff --git a/coderd/database/querier.go b/coderd/database/querier.go
diff --git a/coderd/database/queries.sql.go b/coderd/database/queries.sql.go
diff --git a/coderd/database/queries/prebuilds.sql b/coderd/database/queries/prebuilds.sql
@@ -57,9 +57,9 @@ WHERE (b.transition = 'start'::workspace_transition
 	AND b.job_status = 'succeeded'::provisioner_job_status);
 
 -- name: CountInProgressPrebuilds :many
--- CountInProgressPrebuilds returns the number of in-progress prebuilds, grouped by template version ID and transition.
+-- CountInProgressPrebuilds returns the number of in-progress prebuilds, grouped by preset ID and transition.
 -- Prebuild considered in-progress if it's in the "starting", "stopping", or "deleting" state.
-SELECT t.id AS template_id, wpb.template_version_id, wpb.transition, COUNT(wpb.transition)::int AS count
+SELECT t.id AS template_id, wpb.template_version_id, wpb.transition, COUNT(wpb.transition)::int AS count, wlb.template_version_preset_id as preset_id
 FROM workspace_latest_builds wlb
 		INNER JOIN workspace_prebuild_builds wpb ON wpb.id = wlb.id
 		-- We only need these counts for active template versions.
@@ -70,7 +70,7 @@ FROM workspace_latest_builds wlb
 		-- prebuilds that are still building.
 		INNER JOIN templates t ON t.active_version_id = wlb.template_version_id
 WHERE wlb.job_status IN ('pending'::provisioner_job_status, 'running'::provisioner_job_status)
-GROUP BY t.id, wpb.template_version_id, wpb.transition;
+GROUP BY t.id, wpb.template_version_id, wpb.transition, wlb.template_version_preset_id;
 
 -- GetPresetsBackoff groups workspace builds by preset ID.
 -- Each preset is associated with exactly one template version ID.

diff --git a/coderd/prebuilds/api.go b/coderd/prebuilds/api.go
@@ -0,0 +1,27 @@
+package prebuilds
+
+import (
+	"context"
+)
+
+// ReconciliationOrchestrator manages the lifecycle of prebuild reconciliation.
+// It runs a continuous loop to check and reconcile prebuild states, and can be stopped gracefully.
+type ReconciliationOrchestrator interface {
+	Reconciler
+
+	// RunLoop starts a continuous reconciliation loop that periodically calls ReconcileAll
+	// to ensure all prebuilds are in their desired states. The loop runs until the context
+	// is canceled or Stop is called.
+	RunLoop(ctx context.Context)
+
+	// Stop gracefully shuts down the orchestrator with the given cause.
+	// The cause is used for logging and error reporting.
+	Stop(ctx context.Context, cause error)
+}
+
+type Reconciler interface {
+	// ReconcileAll orchestrates the reconciliation of all prebuilds across all templates.
+	// It takes a global snapshot of the system state and then reconciles each preset
+	// in parallel, creating or deleting prebuilds as needed to reach their desired states.
+	ReconcileAll(ctx context.Context) error
+}
diff --git a/coderd/prebuilds/global_snapshot.go b/coderd/prebuilds/global_snapshot.go
@@ -0,0 +1,66 @@
+package prebuilds
+
+import (
+	"github.com/google/uuid"
+	"golang.org/x/xerrors"
+
+	"github.com/coder/coder/v2/coderd/database"
+	"github.com/coder/coder/v2/coderd/util/slice"
+)
+
+// GlobalSnapshot represents a full point-in-time snapshot of state relating to prebuilds across all templates.
+type GlobalSnapshot struct {
+	Presets             []database.GetTemplatePresetsWithPrebuildsRow
+	RunningPrebuilds    []database.GetRunningPrebuiltWorkspacesRow
+	PrebuildsInProgress []database.CountInProgressPrebuildsRow
+	Backoffs            []database.GetPresetsBackoffRow
+}
+
+func NewGlobalSnapshot(
+	presets []database.GetTemplatePresetsWithPrebuildsRow,
+	runningPrebuilds []database.GetRunningPrebuiltWorkspacesRow,
+	prebuildsInProgress []database.CountInProgressPrebuildsRow,
+	backoffs []database.GetPresetsBackoffRow,
+) GlobalSnapshot {
+	return GlobalSnapshot{
+		Presets:             presets,
+		RunningPrebuilds:    runningPrebuilds,
+		PrebuildsInProgress: prebuildsInProgress,
+		Backoffs:            backoffs,
+	}
+}
+
+func (s GlobalSnapshot) FilterByPreset(presetID uuid.UUID) (*PresetSnapshot, error) {
+	preset, found := slice.Find(s.Presets, func(preset database.GetTemplatePresetsWithPrebuildsRow) bool {
+		return preset.ID == presetID
+	})
+	if !found {
+		return nil, xerrors.Errorf("no preset found with ID %q", presetID)
+	}
+
+	running := slice.Filter(s.RunningPrebuilds, func(prebuild database.GetRunningPrebuiltWorkspacesRow) bool {
+		if !prebuild.CurrentPresetID.Valid {
+			return false
+		}
+		return prebuild.CurrentPresetID.UUID == preset.ID
+	})
+
+	inProgress := slice.Filter(s.PrebuildsInProgress, func(prebuild database.CountInProgressPrebuildsRow) bool {
+		return prebuild.PresetID.UUID == preset.ID
+	})
+
+	var backoffPtr *database.GetPresetsBackoffRow
+	backoff, found := slice.Find(s.Backoffs, func(row database.GetPresetsBackoffRow) bool {
+		return row.PresetID == preset.ID
+	})
+	if found {
+		backoffPtr = &backoff
+	}
+
+	return &PresetSnapshot{
+		Preset:     preset,
+		Running:    running,
+		InProgress: inProgress,
+		Backoff:    backoffPtr,
+	}, nil
+}
diff --git a/coderd/prebuilds/noop.go b/coderd/prebuilds/noop.go
@@ -0,0 +1,35 @@
+package prebuilds
+
+import (
+	"context"
+
+	"github.com/coder/coder/v2/coderd/database"
+)
+
+type NoopReconciler struct{}
+
+func NewNoopReconciler() *NoopReconciler {
+	return &NoopReconciler{}
+}
+
+func (NoopReconciler) RunLoop(context.Context) {}
+
+func (NoopReconciler) Stop(context.Context, error) {}
+
+func (NoopReconciler) ReconcileAll(context.Context) error {
+	return nil
+}
+
+func (NoopReconciler) SnapshotState(context.Context, database.Store) (*GlobalSnapshot, error) {
+	return &GlobalSnapshot{}, nil
+}
+
+func (NoopReconciler) ReconcilePreset(context.Context, PresetSnapshot) error {
+	return nil
+}
+
+func (NoopReconciler) CalculateActions(context.Context, PresetSnapshot) (*ReconciliationActions, error) {
+	return &ReconciliationActions{}, nil
+}
+
+var _ ReconciliationOrchestrator = NoopReconciler{}