Introduce waiters for Intake Runner, Intake and Intake User

Author: Yago Carlos Fernandez Gou

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(20 * 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(20 * 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(10 * 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(10 * time.Minute)
+	return handler
+}