feat: route k8s requests with enqueueOne strategy to /pipelines endpo…

…int (#195)

* feat: route k8s requests with enqueueOne strategy to /pipelines endpoint

* added cue property for extra deploymentConfig fields

cmd/validate/resources/pipelineRequest.cue

@@ -35,6 +35,11 @@ import "struct"
 #DeploymentConfig: {
   timeout?: #Timeout
   keepDeploymentObject?: bool
+  ifDeploymentInProgress?: #IfDeploymentInProgress
+}
+
+#IfDeploymentInProgress: {
+	strategy: "reject" | "enqueueOne"
 }
 
 #Timeout: {

pkg/deploy/deploy.go

@@ -24,6 +24,7 @@ type (
 
 const (
 	mediaTypeKubernetesPipelineV2 = "application/vnd.start.kubernetes.pipeline.v2+json"
+	kubernetesKind                = "kubernetes"
 )
 
 func NewClient(configuration *config.Configuration) *Client {
@@ -173,7 +174,13 @@ func getPipelinePathAndHeaders(options StartPipelineOptions) (string, map[string
 	if err != nil {
 		return "", nil, err
 	}
-	if structured.Kind == "kubernetes" || structured.Kind == "" {
+	if structured.Kind == kubernetesKind &&
+	  structured.DeploymentConfig != nil &&
+	  structured.DeploymentConfig.IfDeploymentInProgress != nil &&
+	  structured.DeploymentConfig.IfDeploymentInProgress.Strategy == enqueueOne {
+		return "/pipelines", nil, nil
+	}
+	if structured.Kind == kubernetesKind || structured.Kind == "" {
 		return "/pipelines/kubernetes", map[string]string{
 			"Content-Type": mediaTypeKubernetesPipelineV2,
 			"Accept":       mediaTypeKubernetesPipelineV2,

pkg/deploy/deploy_test.go

@@ -108,6 +108,20 @@ application: lambda-application
 			yaml: `
 kind: banana cloud
 application: lambda-application
+`,
+			expectedPath: "/pipelines",
+			expectedHeaders: map[string]string{
+				"Content-Type": "application/json",
+			},
+		},
+		{
+			name: "k8s with enqueueOne strategy",
+			yaml: `
+kind: kubernetes
+application: classic-k8s-app
+deploymentConfig:
+  ifDeploymentInProgress:
+    strategy: enqueueOne
 `,
 			expectedPath: "/pipelines",
 			expectedHeaders: map[string]string{

pkg/deploy/request.go

@@ -23,16 +23,27 @@ type (
 	}
 
 	structuredConfig struct {
-		Kind        string     `yaml:"kind"`
-		Application string     `yaml:"application"`
-		Manifests   []manifest `yaml:"manifests"`
+		Kind             string            `yaml:"kind"`
+		Application      string            `yaml:"application"`
+		Manifests        []manifest        `yaml:"manifests"`
+		DeploymentConfig *deploymentConfig `yaml:"deploymentConfig"`
 	}
 
 	manifest struct {
 		Path    string   `yaml:"path"`
 		Targets []string `yaml:"targets"`
 		Inline  string   `yaml:"inline"`
 	}
+
+	deploymentConfig struct {
+		IfDeploymentInProgress *ifDeploymentInProgress `yaml:"ifDeploymentInProgress"`
+	}
+
+	ifDeploymentInProgress struct {
+		Strategy strategy `yaml:"strategy"`
+	}
+
+	strategy string
 )
 
 const (
@@ -41,6 +52,9 @@ const (
 	contextKey            = "context"
 	scmcKey               = "sourceControl"
 	envVarGithubWorkspace = "GITHUB_WORKSPACE"
+
+	enqueueOne strategy = "enqueueOne"
+	reject     strategy = "reject"
 )
 
 func (s *StartPipelineOptions) structuredConfig() (*structuredConfig, error) {