feat(Cloud Databases): In place upgrade (IBM-Cloud#6275)

* In place upgrade

* Check if task is running

* Update isMatchingTask function

* Make UTC

* Check task is running in update function

* Add location

* Update expiration to strfmt datetime type and enable new version endpoint

* PR fixes

* Updates, remove existing task logic

* Add acceptance test

* Update capability call

* Bump go-sdk version

---------

Co-authored-by: Lorna-Kelly <[email protected]>

Author: lornakelly

go.mod

@@ -8,7 +8,7 @@ require (
 	github.com/IBM-Cloud/power-go-client v1.11.0
 	github.com/IBM/appconfiguration-go-admin-sdk v0.4.4
 	github.com/IBM/appid-management-go-sdk v0.0.0-20210908164609-dd0e0eaf732f
-	github.com/IBM/cloud-databases-go-sdk v0.7.1
+	github.com/IBM/cloud-databases-go-sdk v0.8.0
 	github.com/IBM/cloud-db2-go-sdk v0.2.3
 	github.com/IBM/cloudant-go-sdk v0.8.0
 	github.com/IBM/code-engine-go-sdk v0.0.0-20241217191651-e1821f8c58c3

go.sum

@@ -102,8 +102,8 @@ github.com/IBM/appconfiguration-go-admin-sdk v0.4.4 h1:VQ+mVavoo3/xrBaVSyxE+B6Ue
 github.com/IBM/appconfiguration-go-admin-sdk v0.4.4/go.mod h1:E9cXu9w0EClhZq+E9wBw8QzNLKZd2bNdMrTXwVSWJ1s=
 github.com/IBM/appid-management-go-sdk v0.0.0-20210908164609-dd0e0eaf732f h1:4c1kqY4GqmkQ+tO03rneDb74Tv7BhTj8jDiDB1p8mdM=
 github.com/IBM/appid-management-go-sdk v0.0.0-20210908164609-dd0e0eaf732f/go.mod h1:d22kTYY7RYBWcQlZpqrSdshpB/lJ16viWS5Sbjtlc8s=
-github.com/IBM/cloud-databases-go-sdk v0.7.1 h1:5kK4/3NUsGxZzmuUe+1ftajpOQbeDVh5VeemrPgROP4=
-github.com/IBM/cloud-databases-go-sdk v0.7.1/go.mod h1:JYucI1PdwqbAd8XGdDAchxzxRP7bxOh1zUnseovHKsc=
+github.com/IBM/cloud-databases-go-sdk v0.8.0 h1:uMFqhnc/roVTzfCaUsJ23eaHKjChhGpM1F7Mpxik0bo=
+github.com/IBM/cloud-databases-go-sdk v0.8.0/go.mod h1:JYucI1PdwqbAd8XGdDAchxzxRP7bxOh1zUnseovHKsc=
 github.com/IBM/cloud-db2-go-sdk v0.2.3 h1:R+8uFXSZFOsBDC7nKqW9DgyGgT9Pop589ziUIaw2Tek=
 github.com/IBM/cloud-db2-go-sdk v0.2.3/go.mod h1:jEJMNXX2KOE+Hhk3M8CBq0qi9CZ0eRK36xmhuBPSiNA=
 github.com/IBM/cloudant-go-sdk v0.8.0 h1:XzaqZFy5fm1Q9+iK52X5zRW39SHaahT9pf5SRgVTsTY=

ibm/service/database/deployment.go

@@ -0,0 +1,37 @@
+// Copyright IBM Corp. 2017, 2022 All Rights Reserved.
+// Licensed under the Mozilla Public License v2.0
+
+package database
+
+import (
+	"fmt"
+
+	"github.com/IBM-Cloud/terraform-provider-ibm/ibm/conns"
+	"github.com/IBM/cloud-databases-go-sdk/clouddatabasesv5"
+	"github.com/IBM/go-sdk-core/v5/core"
+)
+
+/* Deployment api calls
+   TODO Move other deployment api endpoints in here
+*/
+
+func getDeploymentCapability(capabilityId string, deploymentId string, platform string, location string, meta interface{}) (*clouddatabasesv5.Capability, error) {
+	cloudDatabasesClient, err := meta.(conns.ClientSession).CloudDatabasesV5()
+	if err != nil {
+		return nil, err
+	}
+
+	getDeploymentCapabilityOptions := &clouddatabasesv5.GetDeploymentCapabilityOptions{
+		ID:             core.StringPtr(deploymentId),
+		CapabilityID:   core.StringPtr(capabilityId),
+		TargetPlatform: core.StringPtr(fmt.Sprintf("target_platform=%s", platform)),
+		TargetLocation: core.StringPtr(fmt.Sprintf("target_location=%s", location)),
+	}
+	getDeploymentCapabilityResponse, response, err := cloudDatabasesClient.GetDeploymentCapability(getDeploymentCapabilityOptions)
+
+	if getDeploymentCapabilityResponse == nil || getDeploymentCapabilityResponse.Capability == nil {
+		return nil, fmt.Errorf("capability '%s' field is nil in response %s", capabilityId, response)
+	}
+
+	return getDeploymentCapabilityResponse.Capability, nil
+}

ibm/service/database/helpers.go

@@ -0,0 +1,82 @@
+// Copyright IBM Corp. 2017, 2022 All Rights Reserved.
+// Licensed under the Mozilla Public License v2.0
+
+package database
+
+import (
+	"fmt"
+	"log"
+	"time"
+
+	"github.com/IBM/cloud-databases-go-sdk/clouddatabasesv5"
+	"github.com/IBM/go-sdk-core/v5/core"
+	"github.com/go-openapi/strfmt"
+)
+
+/*  TODO Move other helper functions here */
+type TimeoutHelper struct {
+	Now time.Time
+}
+
+// Allows mocking
+type DeploymentTaskFetcher interface {
+	ListDeploymentTasks(opts *clouddatabasesv5.ListDeploymentTasksOptions) (*clouddatabasesv5.Tasks, *core.DetailedResponse, error)
+}
+type TaskManager struct {
+	Client     DeploymentTaskFetcher
+	InstanceID string
+}
+
+func (t *TimeoutHelper) isMoreThan24Hours(duration time.Duration) bool {
+	return duration > 24*time.Hour
+}
+
+func (t *TimeoutHelper) futureTimeToISO(duration time.Duration) strfmt.DateTime {
+	utcTime := t.Now.Add(duration).UTC()
+	return strfmt.DateTime(utcTime)
+}
+
+func (t *TimeoutHelper) calculateExpirationDatetime(timeoutDuration time.Duration) strfmt.DateTime {
+	if t.isMoreThan24Hours(timeoutDuration) {
+		return t.futureTimeToISO(24 * time.Hour)
+	}
+
+	return t.futureTimeToISO(timeoutDuration)
+}
+
+func (tm *TaskManager) matchingTaskInProgress(taskType string) (bool, *clouddatabasesv5.Task, error) {
+	opts := &clouddatabasesv5.ListDeploymentTasksOptions{
+		ID: core.StringPtr(tm.InstanceID),
+	}
+
+	resp, _, err := tm.Client.ListDeploymentTasks(opts)
+	if err != nil {
+		return false, nil, fmt.Errorf("failed to list tasks for instance: %w", err)
+	}
+
+	for _, task := range resp.Tasks {
+		if task.Status == nil || task.ResourceType == nil {
+			continue
+		}
+		id := *task.ID
+		createdAt := *task.CreatedAt
+		status := *task.Status
+		progress := *task.ProgressPercent
+		description := *task.Description
+		resourceType := *task.ResourceType
+
+		if (status == databaseTaskRunningStatus || status == databaseTaskQueuedStatus) && resourceType == taskType {
+			log.Printf("[INFO] Found matching task in progress:\n"+
+				"  Type: %s\n"+
+				"  Created at: %s\n"+
+				"  Status: %s\n"+
+				"  Current progress percent: %d\n"+
+				"  Description: %s\n"+
+				"  ID: %s\n",
+				resourceType, createdAt, status, progress, description, id)
+			return true, &task, nil
+		}
+	}
+
+	return false, nil, nil
+}