Add waiters for IaaS network and network area operations

services/iaas/NOTICE.txt

@@ -1,2 +1,2 @@
 STACKIT IaaS SDK for Go
-Copyright 2024 Schwarz IT KG
+Copyright 2024 Schwarz IT KG

services/iaas/go.mod

@@ -2,7 +2,10 @@ module github.com/stackitcloud/stackit-sdk-go/services/iaas
 
 go 1.18
 
-require github.com/stackitcloud/stackit-sdk-go/core v0.12.0
+require (
+	github.com/google/go-cmp v0.6.0
+	github.com/stackitcloud/stackit-sdk-go/core v0.12.0
+)
 
 require (
 	github.com/golang-jwt/jwt/v5 v5.2.1 // indirect

services/iaas/go.sum

@@ -1,6 +1,7 @@
 github.com/golang-jwt/jwt/v5 v5.2.1 h1:OuVbFODueb089Lh128TAcimifWaLhJwVflnrgM17wHk=
 github.com/golang-jwt/jwt/v5 v5.2.1/go.mod h1:pqrtFR0X4osieyHYxtmOUWsAWrfe1Q5UVIyoH402zdk=
 github.com/google/go-cmp v0.6.0 h1:ofyhxvXcZhMsU5ulbFiLKl/XBFqE1GSq7atu8tAmTRI=
+github.com/google/go-cmp v0.6.0/go.mod h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeNGIjoY=
 github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0=
 github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
 github.com/stackitcloud/stackit-sdk-go/core v0.12.0 h1:auIzUUNRuydKOScvpICP4MifGgvOajiDQd+ncGmBL0U=

services/iaas/wait/wait.go

@@ -0,0 +1,152 @@
+package wait
+
+import (
+	"context"
+	"fmt"
+	"net/http"
+	"time"
+
+	"github.com/stackitcloud/stackit-sdk-go/core/oapierror"
+	"github.com/stackitcloud/stackit-sdk-go/core/wait"
+	"github.com/stackitcloud/stackit-sdk-go/services/iaas"
+)
+
+const (
+	CreateSuccess = "CREATED"
+)
+
+// Interfaces needed for tests
+type APIClientInterface interface {
+	GetNetworkAreaExecute(ctx context.Context, organizationId, areaId string) (*iaas.NetworkArea, error)
+	GetProjectRequestExecute(ctx context.Context, projectId string, requestId string) (*iaas.Request, error)
+	GetNetworkExecute(ctx context.Context, projectId, networkId string) (*iaas.Network, error)
+}
+
+// CreateNetworkAreaWaitHandler will wait for network area creation
+func CreateNetworkAreaWaitHandler(ctx context.Context, a APIClientInterface, organizationId, areaId string) *wait.AsyncActionHandler[iaas.NetworkArea] {
+	handler := wait.New(func() (waitFinished bool, response *iaas.NetworkArea, err error) {
+		area, err := a.GetNetworkAreaExecute(ctx, organizationId, areaId)
+		if err != nil {
+			return false, area, err
+		}
+		if area.AreaId == nil || area.State == nil {
+			return false, area, fmt.Errorf("create failed for network area with id %s, the response is not valid: the id or the state are missing", areaId)
+		}
+		if *area.AreaId == areaId && *area.State == CreateSuccess {
+			return true, area, nil
+		}
+		return false, area, nil
+	})
+	handler.SetTimeout(10 * time.Minute)
+	return handler
+}
+
+// UpdateNetworkAreaWaitHandler will wait for network area update
+func UpdateNetworkAreaWaitHandler(ctx context.Context, a APIClientInterface, organizationId, areaId string) *wait.AsyncActionHandler[iaas.NetworkArea] {
+	handler := wait.New(func() (waitFinished bool, response *iaas.NetworkArea, err error) {
+		area, err := a.GetNetworkAreaExecute(ctx, organizationId, areaId)
+		if err != nil {
+			return false, area, err
+		}
+		if area.AreaId == nil || area.State == nil {
+			return false, nil, fmt.Errorf("update failed for network area with id %s, the response is not valid: the id or the state are missing", areaId)
+		}
+		// The state returns to "CREATED" after a successful update is completed
+		if *area.AreaId == areaId && *area.State == CreateSuccess {
+			return true, area, nil
+		}
+		return false, area, nil
+	})
+	handler.SetSleepBeforeWait(2 * time.Second)
+	handler.SetTimeout(10 * time.Minute)
+	return handler
+}
+
+// DeleteNetworkAreaWaitHandler will wait for network area deletion
+func DeleteNetworkAreaWaitHandler(ctx context.Context, a APIClientInterface, organizationId, areaId string) *wait.AsyncActionHandler[iaas.NetworkArea] {
+	handler := wait.New(func() (waitFinished bool, response *iaas.NetworkArea, err error) {
+		area, err := a.GetNetworkAreaExecute(ctx, organizationId, areaId)
+		if err == nil {
+			return false, nil, nil
+		}
+		oapiErr, ok := err.(*oapierror.GenericOpenAPIError) //nolint:errorlint //complaining that error.As should be used to catch wrapped errors, but this error should not be wrapped
+		if !ok {
+			return false, area, fmt.Errorf("could not convert error to oapierror.GenericOpenAPIError: %w", err)
+		}
+		if oapiErr.StatusCode != http.StatusNotFound {
+			return false, area, err
+		}
+		return true, nil, nil
+	})
+	handler.SetTimeout(10 * time.Minute)
+	return handler
+}
+
+// CreateNetworkWaitHandler will wait for network creation
+func CreateNetworkWaitHandler(ctx context.Context, a APIClientInterface, projectId, requestId string) *wait.AsyncActionHandler[iaas.Network] {
+	handler := wait.New(func() (waitFinished bool, response *iaas.Network, err error) {
+		request, err := a.GetProjectRequestExecute(ctx, projectId, requestId)
+		if err != nil {
+			return false, nil, err
+		}
+		if request == nil || request.Resources == nil || len(*request.Resources) == 0 || (*request.Resources)[0].Id == nil {
+			return false, nil, fmt.Errorf("no resources found for request with id %s", requestId)
+		}
+		networkId := *(*request.Resources)[0].Id
+		network, err := a.GetNetworkExecute(ctx, projectId, networkId)
+		if err != nil {
+			return false, network, err
+		}
+		if network.NetworkId == nil || network.State == nil {
+			return false, network, fmt.Errorf("create failed for network with id %s, the response is not valid: the id or the state are missing", networkId)
+		}
+		if *network.NetworkId == networkId && *network.State == CreateSuccess {
+			return true, network, nil
+		}
+		return false, network, nil
+	})
+	handler.SetSleepBeforeWait(2 * time.Second)
+	handler.SetTimeout(10 * time.Minute)
+	return handler
+}
+
+// UpdateNetworkWaitHandler will wait for network update
+func UpdateNetworkWaitHandler(ctx context.Context, a APIClientInterface, projectId, networkId string) *wait.AsyncActionHandler[iaas.Network] {
+	handler := wait.New(func() (waitFinished bool, response *iaas.Network, err error) {
+		network, err := a.GetNetworkExecute(ctx, projectId, networkId)
+		if err != nil {
+			return false, network, err
+		}
+		if network.NetworkId == nil || network.State == nil {
+			return false, network, fmt.Errorf("update failed for network area with id %s, the response is not valid: the id or the state are missing", networkId)
+		}
+		// The state returns to "CREATED" after a successful update is completed
+		if *network.NetworkId == networkId && *network.State == CreateSuccess {
+			return true, network, nil
+		}
+		return false, network, nil
+	})
+	handler.SetSleepBeforeWait(2 * time.Second)
+	handler.SetTimeout(10 * time.Minute)
+	return handler
+}
+
+// DeleteNetworkWaitHandler will wait for network deletion
+func DeleteNetworkWaitHandler(ctx context.Context, a APIClientInterface, projectId, networkId string) *wait.AsyncActionHandler[iaas.Network] {
+	handler := wait.New(func() (waitFinished bool, response *iaas.Network, err error) {
+		network, err := a.GetNetworkExecute(ctx, projectId, networkId)
+		if err == nil {
+			return false, nil, nil
+		}
+		oapiErr, ok := err.(*oapierror.GenericOpenAPIError) //nolint:errorlint //complaining that error.As should be used to catch wrapped errors, but this error should not be wrapped
+		if !ok {
+			return false, network, fmt.Errorf("could not convert error to oapierror.GenericOpenAPIError: %w", err)
+		}
+		if oapiErr.StatusCode != http.StatusNotFound {
+			return false, network, err
+		}
+		return true, nil, nil
+	})
+	handler.SetTimeout(10 * time.Minute)
+	return handler
+}