Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
23 changes: 11 additions & 12 deletions internal/cmd/ske/cluster/create/create.go
Original file line number Diff line number Diff line change
Expand Up @@ -95,21 +95,20 @@ func NewCmd(params *types.CmdParams) *cobra.Command {
return err
}

// Check if the project is enabled before trying to create
enabled, err := serviceEnablementUtils.ProjectEnabled(ctx, serviceEnablementApiClient, model.ProjectId, model.Region)
if err != nil {
return err
}
if !enabled {
return &errors.ServiceDisabledError{
Service: "ske",
}
}

// Check if cluster exists
exists, err := skeUtils.ClusterExists(ctx, apiClient.DefaultAPI, model.ProjectId, model.Region, model.ClusterName)
if err != nil {
return err
// Check if the project is enabled
enabled, enabledErr := serviceEnablementUtils.ProjectEnabled(ctx, serviceEnablementApiClient, model.ProjectId, model.Region)
if enabledErr != nil {
return fmt.Errorf("check if project is enabled failed: %w", enabledErr)
}
if !enabled {
return &errors.ServiceDisabledError{
Service: "ske",
}
}
return fmt.Errorf("cluster exists check failed: %w", err)
}
if exists {
return fmt.Errorf("cluster with name %s already exists", model.ClusterName)
Expand Down
19 changes: 10 additions & 9 deletions internal/cmd/ske/cluster/list/list.go
Original file line number Diff line number Diff line change
Expand Up @@ -68,19 +68,20 @@ func NewCmd(params *types.CmdParams) *cobra.Command {
return err
}

// Check if SKE is enabled for this project
enabled, err := serviceEnablementUtils.ProjectEnabled(ctx, serviceEnablementApiClient, model.ProjectId, model.Region)
if err != nil {
return err
}
if !enabled {
return fmt.Errorf("SKE isn't enabled for this project, please run 'stackit ske enable'")
}

// Call API
req := buildRequest(ctx, model, apiClient)
resp, err := req.Execute()
if err != nil {
// Check if SKE is enabled for this project
enabled, enabledErr := serviceEnablementUtils.ProjectEnabled(ctx, serviceEnablementApiClient, model.ProjectId, model.Region)
if enabledErr != nil {
return fmt.Errorf("check if project is enabled failed: %w", enabledErr)
}
if !enabled {
return &errors.ServiceDisabledError{
Service: "ske",
}
}
return fmt.Errorf("get SKE clusters: %w", err)
}
clusters := resp.Items
Expand Down
Loading