chore: init force deploy

Author: adityachoudhari26

apps/workspace-engine/oapi/openapi.json

@@ -1172,6 +1172,21 @@
             ],
             "type": "object"
          },
+         "ReleaseTargetForceDeployEvent": {
+            "properties": {
+               "releaseTarget": {
+                  "$ref": "#/components/schemas/ReleaseTarget"
+               },
+               "version": {
+                  "$ref": "#/components/schemas/DeploymentVersion"
+               }
+            },
+            "required": [
+               "releaseTarget",
+               "version"
+            ],
+            "type": "object"
+         },
          "ReleaseTargetState": {
             "properties": {
                "currentRelease": {

apps/workspace-engine/oapi/spec/main.jsonnet

@@ -37,6 +37,7 @@
       (import 'schemas/relationship.jsonnet') +
       (import 'schemas/jobs.jsonnet') +
       (import 'schemas/deployments.jsonnet') +
-      (import 'schemas/verification.jsonnet'),
+      (import 'schemas/verification.jsonnet') +
+      (import 'schemas/release-targets.jsonnet'),
   },
 }

apps/workspace-engine/oapi/spec/schemas/release-targets.jsonnet

@@ -0,0 +1,12 @@
+local openapi = import '../lib/openapi.libsonnet';
+
+{
+  ReleaseTargetForceDeployEvent: {
+    type: 'object',
+    required: ['releaseTarget', 'version'],
+    properties: {
+      releaseTarget: openapi.schemaRef('ReleaseTarget'),
+      version: openapi.schemaRef('DeploymentVersion'),
+    },
+  },
+}

apps/workspace-engine/pkg/events/handler/redeploy/redeploy.go

@@ -27,3 +27,12 @@ func HandleReleaseTargetDeploy(ctx context.Context, ws *workspace.Workspace, eve
 
 	return nil
 }
+
+func HandleReleaseTargetForceDeploy(ctx context.Context, ws *workspace.Workspace, event handler.RawEvent) error {
+	releaseTargetForceDeployEvent := &oapi.ReleaseTargetForceDeployEvent{}
+	if err := json.Unmarshal(event.Data, releaseTargetForceDeployEvent); err != nil {
+		return err
+	}
+
+	return ws.ReleaseManager().ForceDeploy(ctx, &releaseTargetForceDeployEvent.ReleaseTarget, &releaseTargetForceDeployEvent.Version)
+}

apps/workspace-engine/pkg/oapi/oapi.gen.go

@@ -58,6 +58,7 @@ type planDeploymentConfig struct {
 	resourceRelatedEntities      map[string][]*oapi.EntityRelation
 	recorder                     *trace.ReconcileTarget
 	earliestVersionForEvaluation *oapi.DeploymentVersion
+	forceDeployVersion           *oapi.DeploymentVersion
 }
 
 func WithResourceRelatedEntities(entities map[string][]*oapi.EntityRelation) planDeploymentOptions {
@@ -78,6 +79,12 @@ func WithVersionAndNewer(version *oapi.DeploymentVersion) planDeploymentOptions
 	}
 }
 
+func WithForceDeployVersion(version *oapi.DeploymentVersion) planDeploymentOptions {
+	return func(cfg *planDeploymentConfig) {
+		cfg.forceDeployVersion = version
+	}
+}
+
 // Returns:
 //   - *oapi.Release: The desired release to deploy
 //   - nil: No deployable release (no versions or all blocked by policies)
@@ -126,9 +133,14 @@ func (p *Planner) PlanDeployment(ctx context.Context, releaseTarget *oapi.Releas
 		return nil, nil
 	}
 
+	deployableVersion := cfg.forceDeployVersion
+
 	// Step 2: Find first version that passes user-defined policies
-	span.AddEvent("Step 2: Finding deployable version")
-	deployableVersion := p.findDeployableVersion(ctx, candidateVersions, releaseTarget, planning)
+	if deployableVersion == nil {
+		span.AddEvent("Step 2: Finding deployable version")
+		deployableVersion = p.findDeployableVersion(ctx, candidateVersions, releaseTarget, planning)
+	}
+
 	if deployableVersion == nil {
 		span.AddEvent("No deployable version found (blocked by policies)")
 		span.SetAttributes(

apps/workspace-engine/pkg/workspace/releasemanager/deployment/planner.go

@@ -94,6 +94,7 @@ func (o *DeploymentOrchestrator) Reconcile(
 		deployment.WithResourceRelatedEntities(options.resourceRelationships),
 		deployment.WithTraceRecorder(recorder),
 		deployment.WithVersionAndNewer(options.earliestVersionForEvaluation),
+		deployment.WithForceDeployVersion(options.forceDeployVersion),
 	)
 	if err != nil {
 		span.RecordError(err)

apps/workspace-engine/pkg/workspace/releasemanager/deployment_orchestrator.go

@@ -285,6 +285,16 @@ func (m *Manager) Redeploy(ctx context.Context, releaseTarget *oapi.ReleaseTarge
 		WithTrigger(trace.TriggerManual))
 }
 
+func (m *Manager) ForceDeploy(ctx context.Context, releaseTarget *oapi.ReleaseTarget, version *oapi.DeploymentVersion) error {
+	ctx, span := tracer.Start(ctx, "ForceDeploy")
+	defer span.End()
+
+	return m.ReconcileTarget(ctx, releaseTarget,
+		WithSkipEligibilityCheck(true),
+		WithTrigger(trace.TriggerManual),
+		WithForceDeployVersion(version))
+}
+
 // reconcileTargetWithRelationships is like ReconcileTarget but accepts pre-computed resource relationships.
 // This is an optimization to avoid recomputing relationships for multiple release targets that share the same resource.
 // After reconciliation completes, it caches the computed state for use by other APIs.

apps/workspace-engine/pkg/workspace/releasemanager/manager.go

@@ -12,6 +12,7 @@ type options struct {
 	trigger                      trace.TriggerReason
 	resourceRelationships        map[string][]*oapi.EntityRelation
 	earliestVersionForEvaluation *oapi.DeploymentVersion
+	forceDeployVersion           *oapi.DeploymentVersion
 
 	// StateCache options
 	bypassCache    bool
@@ -42,6 +43,12 @@ func WithVersionAndNewer(version *oapi.DeploymentVersion) Option {
 	}
 }
 
+func WithForceDeployVersion(version *oapi.DeploymentVersion) Option {
+	return func(opts *options) {
+		opts.forceDeployVersion = version
+	}
+}
+
 // StateCache options
 
 func WithResourceRelationships(relationships map[string][]*oapi.EntityRelation) Option {