Check pipeline status after deploy

Author: Fabio Stabile

internal/cmd/deploy/trigger.go

@@ -93,6 +93,10 @@ func runDeployTrigger(ctx context.Context, environmentName string, options *clio
 		return fmt.Errorf("error retrieving the pipeline status: %w", err)
 	}
 
+	if status == "failed" {
+		return fmt.Errorf("Pipeline failed")
+	}
+
 	fmt.Printf("Pipeline ended with %s\n", status)
 	return nil
 }

internal/cmd/deploy/trigger_test.go

@@ -41,6 +41,11 @@ func TestDeploy(t *testing.T) {
 			server:    testTriggerServer(t),
 			projectID: "correct",
 		},
+		"pipeline failed": {
+			server:    testTriggerServer(t),
+			projectID: "failed",
+			expectErr: true,
+		},
 		"pipeline fails": {
 			server:    testTriggerServer(t),
 			projectID: "fails-bad-request",
@@ -82,7 +87,7 @@ func testTriggerServer(t *testing.T) *httptest.Server {
 	server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
 		t.Helper()
 		switch {
-		case r.Method == http.MethodPost && (r.URL.Path == fmt.Sprintf(deployProjectEndpointTemplate, "correct") || r.URL.Path == fmt.Sprintf(deployProjectEndpointTemplate, "fails-wait-status")):
+		case r.Method == http.MethodPost && (r.URL.Path == fmt.Sprintf(deployProjectEndpointTemplate, "correct") || r.URL.Path == fmt.Sprintf(deployProjectEndpointTemplate, "fails-wait-status") || r.URL.Path == fmt.Sprintf(deployProjectEndpointTemplate, "failed")):
 			data, err := resources.EncodeResourceToJSON(&resources.DeployProject{
 				ID:  1,
 				URL: "http://example.com",
@@ -97,6 +102,13 @@ func testTriggerServer(t *testing.T) *httptest.Server {
 			})
 			require.NoError(t, err)
 			w.Write(data)
+		case r.Method == http.MethodGet && r.URL.Path == fmt.Sprintf(pipelineStatusEndpointTemplate, "failed", 1) && r.URL.Query().Get("environment") == "environmentName":
+			data, err := resources.EncodeResourceToJSON(&resources.PipelineStatus{
+				ID:     1,
+				Status: "failed",
+			})
+			require.NoError(t, err)
+			w.Write(data)
 		case r.Method == http.MethodPost && r.URL.Path == fmt.Sprintf(deployProjectEndpointTemplate, "fails-bad-request"):
 			respBody := `{"error": "Bad Request","message":"some bad request"}`