Merge pull request digitalocean#407 from kamaln7/apps-create-deployment

apps: add the option to force build a new deployment
dmartzol · Nov 5, 2020 · f3e2fed · f3e2fed
2 parents 4120ba2 + a96b6ff
commit f3e2fed
Show file tree

Hide file tree

Showing 2 changed files with 39 additions and 17 deletions.
diff --git a/apps.go b/apps.go
@@ -33,7 +33,7 @@ type AppsService interface {
 
 	GetDeployment(ctx context.Context, appID, deploymentID string) (*Deployment, *Response, error)
 	ListDeployments(ctx context.Context, appID string, opts *ListOptions) ([]*Deployment, *Response, error)
-	CreateDeployment(ctx context.Context, appID string) (*Deployment, *Response, error)
+	CreateDeployment(ctx context.Context, appID string, create ...*DeploymentCreateRequest) (*Deployment, *Response, error)
 
 	GetLogs(ctx context.Context, appID, deploymentID, component string, logType AppLogType, follow bool) (*AppLogs, *Response, error)
 
@@ -62,6 +62,11 @@ type AppUpdateRequest struct {
 	Spec *AppSpec `json:"spec"`
 }
 
+// DeploymentCreateRequest represents a request to create a deployment.
+type DeploymentCreateRequest struct {
+	ForceBuild bool `json:"force_build"`
+}
+
 type appRoot struct {
 	App *App `json:"app"`
 }
@@ -210,9 +215,15 @@ func (s *AppsServiceOp) ListDeployments(ctx context.Context, appID string, opts
 }
 
 // CreateDeployment creates an app deployment.
-func (s *AppsServiceOp) CreateDeployment(ctx context.Context, appID string) (*Deployment, *Response, error) {
+func (s *AppsServiceOp) CreateDeployment(ctx context.Context, appID string, create ...*DeploymentCreateRequest) (*Deployment, *Response, error) {
 	path := fmt.Sprintf("%s/%s/deployments", appsBasePath, appID)
-	req, err := s.client.NewRequest(ctx, http.MethodPost, path, nil)
+
+	var createReq *DeploymentCreateRequest
+	for _, c := range create {
+		createReq = c
+	}
+
+	req, err := s.client.NewRequest(ctx, http.MethodPost, path, createReq)
 	if err != nil {
 		return nil, nil, err
 	}

diff --git a/apps_test.go b/apps_test.go
@@ -265,20 +265,31 @@ func TestApps_DeleteApp(t *testing.T) {
 }
 
 func TestApps_CreateDeployment(t *testing.T) {
-	setup()
-	defer teardown()
-
-	ctx := context.Background()
-
-	mux.HandleFunc(fmt.Sprintf("/v2/apps/%s/deployments", testApp.ID), func(w http.ResponseWriter, r *http.Request) {
-		testMethod(t, r, http.MethodPost)
-
-		json.NewEncoder(w).Encode(&deploymentRoot{Deployment: &testDeployment})
-	})
-
-	deployment, _, err := client.Apps.CreateDeployment(ctx, testApp.ID)
-	require.NoError(t, err)
-	assert.Equal(t, &testDeployment, deployment)
+	for _, forceBuild := range []bool{true, false} {
+		t.Run(fmt.Sprintf("ForceBuild_%t", forceBuild), func(t *testing.T) {
+			setup()
+			defer teardown()
+
+			ctx := context.Background()
+
+			mux.HandleFunc(fmt.Sprintf("/v2/apps/%s/deployments", testApp.ID), func(w http.ResponseWriter, r *http.Request) {
+				testMethod(t, r, http.MethodPost)
+
+				var req DeploymentCreateRequest
+				err := json.NewDecoder(r.Body).Decode(&req)
+				require.NoError(t, err)
+				assert.Equal(t, forceBuild, req.ForceBuild)
+
+				json.NewEncoder(w).Encode(&deploymentRoot{Deployment: &testDeployment})
+			})
+
+			deployment, _, err := client.Apps.CreateDeployment(ctx, testApp.ID, &DeploymentCreateRequest{
+				ForceBuild: forceBuild,
+			})
+			require.NoError(t, err)
+			assert.Equal(t, &testDeployment, deployment)
+		})
+	}
 }
 
 func TestApps_GetDeployment(t *testing.T) {