refac(tests): Use Ginkgo/Gomega for workspace tests

.mockery.yml

@@ -21,3 +21,7 @@ packages:
     config:
       all: true
     interfaces:
+  github.com/codesphere-cloud/cs-go/api:
+    config:
+      all: true
+    interfaces:

Makefile

@@ -10,6 +10,7 @@ lint: install-build-deps
 	golangci-lint run
 
 test:
+	# -count=1 to disable caching test results
 	go test ./... -count=1
 
 generate:

api/api_suite_test.go

@@ -0,0 +1,13 @@
+package api_test
+
+import (
+	"testing"
+
+	. "github.com/onsi/ginkgo/v2"
+	. "github.com/onsi/gomega"
+)
+
+func TestApi(t *testing.T) {
+	RegisterFailHandler(Fail)
+	RunSpecs(t, "Api Suite")
+}

api/client.go

@@ -11,8 +11,9 @@ import (
 )
 
 type Client struct {
-	ctx context.Context
-	api *openapi_client.APIClient
+	ctx  context.Context
+	api  *openapi_client.APIClient
+	time Time
 }
 
 type Configuration struct {
@@ -35,10 +36,11 @@ func (c Configuration) GetApiUrl() *url.URL {
 }
 
 // For use in tests
-func NewClientWithCustomApi(ctx context.Context, opts Configuration, api *openapi_client.APIClient) *Client {
+func NewClientWithCustomDeps(ctx context.Context, opts Configuration, api *openapi_client.APIClient, time Time) *Client {
 	return &Client{
-		ctx: context.WithValue(ctx, openapi_client.ContextAccessToken, opts.Token),
-		api: api,
+		ctx:  context.WithValue(ctx, openapi_client.ContextAccessToken, opts.Token),
+		api:  api,
+		time: time,
 	}
 }
 
@@ -47,7 +49,7 @@ func NewClient(ctx context.Context, opts Configuration) *Client {
 	cfg.Servers = []openapi_client.ServerConfiguration{{
 		URL: opts.BaseUrl.String(),
 	}}
-	return NewClientWithCustomApi(ctx, opts, openapi_client.NewAPIClient(cfg))
+	return NewClientWithCustomDeps(ctx, opts, openapi_client.NewAPIClient(cfg), &RealTime{})
 }
 
 func (c *Client) ListDataCenters() ([]DataCenter, error) {

api/types.go

@@ -5,6 +5,7 @@ package api
 
 import (
 	openapi "github.com/codesphere-cloud/cs-go/api/openapi_client"
+	"time"
 )
 
 type DataCenter = openapi.MetadataGetDatacenters200ResponseInner
@@ -33,3 +34,18 @@ func ConvertToTeam(t *openapi.TeamsGetTeam200Response) *Team {
 		Role: 0,
 	}
 }
+
+type Time interface {
+	Sleep(time.Duration)
+	Now() time.Time
+}
+
+type RealTime struct{}
+
+func (r *RealTime) Now() time.Time {
+	return time.Now()
+}
+
+func (r *RealTime) Sleep(time.Duration) {
+
+}

api/workspace.go

@@ -44,7 +44,7 @@ func (c *Client) SetEnvVarOnWorkspace(workspaceId int, envVars map[string]string
 func (client *Client) WaitForWorkspaceRunning(workspace *Workspace, timeout time.Duration) error {
 	delay := 5 * time.Second
 
-	maxWaitTime := time.Now().Add(timeout)
+	maxWaitTime := client.time.Now().Add(timeout)
 	for {
 		status, err := client.WorkspaceStatus(workspace.Id)
 
@@ -55,10 +55,10 @@ func (client *Client) WaitForWorkspaceRunning(workspace *Workspace, timeout time
 		if status.IsRunning {
 			return nil
 		}
-		if time.Now().After(maxWaitTime) {
+		if client.time.Now().After(maxWaitTime) {
 			break
 		}
-		time.Sleep(delay)
+		client.time.Sleep(delay)
 	}
 
 	return errors.TimedOut(