Introduce waiters for Intake Runner, Intake and Intake User

CHANGELOG.md

@@ -1,3 +1,4 @@
+
 ## Release (2025-xx-xx)
 - `core`: [v0.18.0](core/CHANGELOG.md#v0180)
   - **New:** Added duration utils
@@ -14,6 +15,10 @@
 - `postgresflex`: [v1.3.0](services/postgresflex/CHANGELOG.md#v130)
   - **Breaking Change:** The attribute type for `PartialUpdateInstancePayload` and `UpdateInstancePayload` changed from `Storage` to `StorageUpdate`.
   - **Deprecation:** `StorageUpdate`: updating the performance class field is not possible.
+- `intake`: [v0.3.0](services/intake/CHANGELOG.md#v030)
+  - **Feature:** Add wait handlers for `Intake`, `IntakeRunner`, and `IntakeUser` resources.
+  - **Improvement:** Add usage examples for the `intake` service.
+
 - `iaas`: 
   - [v1.0.1](services/iaas/CHANGELOG.md#v101)
     - Bump STACKIT resourcemanager SDK module from `v0.17.1` to `v0.18.0`

services/intake/CHANGELOG.md

@@ -1,3 +1,7 @@
+## v0.3.0
+- **Feature:** Add wait handlers for `Intake`, `IntakeRunner`, and `IntakeUser` resources.
+- **Improvement:** Add usage examples for the `intake` service.
+
 ## v0.2.0
 - **Feature:** Add response `IntakeRunnerResponse` to `UpdateIntakeRunnerExecute` request
 - **Feature:** Add response `IntakeUserResponse` to `UpdateIntakeUserExecute` request

services/intake/VERSION

@@ -1 +1 @@
-v0.2.0
+v0.3.0

services/intake/go.mod

@@ -3,6 +3,7 @@ module github.com/stackitcloud/stackit-sdk-go/services/intake
 go 1.21
 
 require (
+	github.com/google/go-cmp v0.7.0
 	github.com/google/uuid v1.6.0
 	github.com/stackitcloud/stackit-sdk-go/core v0.17.3
 )

services/intake/wait/wait.go

@@ -0,0 +1,162 @@
+package wait
+
+import (
+	"context"
+	"errors"
+	"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/intake"
+)
+
+type APIClientInterface interface {
+	GetIntakeRunnerExecute(ctx context.Context, projectId, region, intakeRunnerId string) (*intake.IntakeRunnerResponse, error)
+	GetIntakeExecute(ctx context.Context, projectId, region, intakeId string) (*intake.IntakeResponse, error)
+	GetIntakeUserExecute(ctx context.Context, projectId, region, intakeId, intakeUserId string) (*intake.IntakeUserResponse, error)
+}
+
+func CreateOrUpdateIntakeRunnerWaitHandler(ctx context.Context, a APIClientInterface, projectId, region, intakeRunnerId string) *wait.AsyncActionHandler[intake.IntakeRunnerResponse] {
+	handler := wait.New(func() (waitFinished bool, response *intake.IntakeRunnerResponse, err error) {
+		runner, err := a.GetIntakeRunnerExecute(ctx, projectId, region, intakeRunnerId)
+		if err != nil {
+			return false, nil, err
+		}
+
+		if runner == nil {
+			return false, nil, fmt.Errorf("API returned a nil response for Intake Runner %s", intakeRunnerId)
+		}
+
+		if runner.Id == nil || runner.State == nil {
+			return false, nil, fmt.Errorf("could not get ID or State from response for Intake Runner %s", intakeRunnerId)
+		}
+
+		if *runner.Id == intakeRunnerId && *runner.State == intake.INTAKERUNNERRESPONSESTATE_ACTIVE {
+			return true, runner, nil
+		}
+
+		// The API does not have a dedicated failure state for this resource,
+		// so we rely on the timeout for cases where it never becomes active.
+		return false, nil, nil
+	})
+	handler.SetTimeout(15 * time.Minute)
+	return handler
+}
+
+func DeleteIntakeRunnerWaitHandler(ctx context.Context, a APIClientInterface, projectId, region, intakeRunnerId string) *wait.AsyncActionHandler[intake.IntakeRunnerResponse] {
+	handler := wait.New(func() (waitFinished bool, response *intake.IntakeRunnerResponse, err error) {
+		_, err = a.GetIntakeRunnerExecute(ctx, projectId, region, intakeRunnerId)
+		if err == nil {
+			// Resource still exists
+			return false, nil, nil
+		}
+
+		var oapiError *oapierror.GenericOpenAPIError
+		if errors.As(err, &oapiError) {
+			if oapiError.StatusCode == http.StatusNotFound {
+				// Success: Resource is gone
+				return true, nil, nil
+			}
+		}
+		// An unexpected error occurred
+		return false, nil, err
+	})
+	handler.SetTimeout(15 * time.Minute)
+	return handler
+}
+
+func CreateOrUpdateIntakeWaitHandler(ctx context.Context, a APIClientInterface, projectId, region, intakeId string) *wait.AsyncActionHandler[intake.IntakeResponse] {
+	handler := wait.New(func() (waitFinished bool, response *intake.IntakeResponse, err error) {
+		ik, err := a.GetIntakeExecute(ctx, projectId, region, intakeId)
+		if err != nil {
+			return false, nil, err
+		}
+
+		if ik == nil {
+			return false, nil, fmt.Errorf("API returned a nil response for Intake %s", intakeId)
+		}
+
+		if ik.Id == nil || ik.State == nil {
+			return false, nil, fmt.Errorf("could not get ID or State from response for Intake %s", intakeId)
+		}
+
+		if *ik.Id == intakeId && *ik.State == intake.INTAKERESPONSESTATE_ACTIVE {
+			return true, ik, nil
+		}
+
+		if *ik.Id == intakeId && *ik.State == intake.INTAKERESPONSESTATE_FAILED {
+			return true, ik, fmt.Errorf("create/update failed for Intake %s", intakeId)
+		}
+
+		return false, nil, nil
+	})
+	handler.SetTimeout(10 * time.Minute)
+	return handler
+}
+
+func DeleteIntakeWaitHandler(ctx context.Context, a APIClientInterface, projectId, region, intakeId string) *wait.AsyncActionHandler[intake.IntakeResponse] {
+	handler := wait.New(func() (waitFinished bool, response *intake.IntakeResponse, err error) {
+		_, err = a.GetIntakeExecute(ctx, projectId, region, intakeId)
+		if err == nil {
+			return false, nil, nil
+		}
+
+		var oapiError *oapierror.GenericOpenAPIError
+		if errors.As(err, &oapiError) {
+			if oapiError.StatusCode == http.StatusNotFound {
+				return true, nil, nil
+			}
+		}
+		return false, nil, err
+	})
+	handler.SetTimeout(10 * time.Minute)
+	return handler
+}
+
+func CreateOrUpdateIntakeUserWaitHandler(ctx context.Context, a APIClientInterface, projectId, region, intakeId, intakeUserId string) *wait.AsyncActionHandler[intake.IntakeUserResponse] {
+	handler := wait.New(func() (waitFinished bool, response *intake.IntakeUserResponse, err error) {
+		user, err := a.GetIntakeUserExecute(ctx, projectId, region, intakeId, intakeUserId)
+		if err != nil {
+			return false, nil, err
+		}
+
+		if user == nil {
+			return false, nil, fmt.Errorf("API returned a nil response for Intake User %s", intakeUserId)
+		}
+
+		if user.Id == nil || user.State == nil {
+			return false, nil, fmt.Errorf("could not get ID or State from response for Intake User %s", intakeUserId)
+		}
+
+		if *user.Id == intakeUserId && *user.State == intake.INTAKEUSERRESPONSESTATE_ACTIVE {
+			return true, user, nil
+		}
+
+		// The API does not have a dedicated failure state for this resource, we rely on the timeout for cases where
+		// it never becomes active.
+		return false, nil, nil
+	})
+	handler.SetTimeout(5 * time.Minute)
+	return handler
+}
+
+func DeleteIntakeUserWaitHandler(ctx context.Context, a APIClientInterface, projectId, region, intakeId, intakeUserId string) *wait.AsyncActionHandler[intake.IntakeUserResponse] {
+	handler := wait.New(func() (waitFinished bool, response *intake.IntakeUserResponse, err error) {
+		_, err = a.GetIntakeUserExecute(ctx, projectId, region, intakeId, intakeUserId)
+		if err == nil {
+			return false, nil, nil
+		}
+
+		var oapiError *oapierror.GenericOpenAPIError
+		if errors.As(err, &oapiError) {
+			if oapiError.StatusCode == http.StatusNotFound {
+				return true, nil, nil
+			}
+		}
+		return false, nil, err
+	})
+	handler.SetTimeout(5 * time.Minute)
+	return handler
+}