feat(opensearch) use versioned sdk

Author: cgoetz-inovex

stackit/internal/conversion/conversion.go

@@ -131,11 +131,18 @@ func BoolValueToPointer(s basetypes.BoolValue) *bool {
 // StringListToPointer converts basetypes.ListValue to a pointer to a list of strings.
 // It returns nil if the value is null or unknown.
 func StringListToPointer(list basetypes.ListValue) (*[]string, error) {
+	result, err := StringListToSlice(list)
+	return &result, err
+}
+
+// StringListToSlice converts basetypes.ListValue to a list of strings.
+// It returns nil if the value is null or unknown.
+func StringListToSlice(list basetypes.ListValue) ([]string, error) {
 	if list.IsNull() || list.IsUnknown() {
 		return nil, nil
 	}
 
-	listStr := []string{}
+	var listStr []string
 	for i, el := range list.Elements() {
 		elStr, ok := el.(types.String)
 		if !ok {
@@ -144,7 +151,7 @@ func StringListToPointer(list basetypes.ListValue) (*[]string, error) {
 		listStr = append(listStr, elStr.ValueString())
 	}
 
-	return &listStr, nil
+	return listStr, nil
 }
 
 // StringSetToPointer converts basetypes.SetValue to a pointer to a list of strings.

stackit/internal/conversion/conversion_test.go

@@ -449,3 +449,59 @@ func TestStringSetToSlice(t *testing.T) {
 		})
 	}
 }
+
+func TestStringListToSlice(t *testing.T) {
+	t.Parallel()
+	tests := []struct {
+		name    string
+		in      basetypes.ListValue
+		want    []string
+		wantErr bool
+	}{
+		{
+			name: "unknown",
+			in:   basetypes.NewListUnknown(types.StringType),
+			want: nil,
+		},
+		{
+			name: "null",
+			in:   basetypes.NewListNull(types.StringType),
+			want: nil,
+		},
+		{
+			name:    "invalid type",
+			in:      basetypes.NewListValueMust(types.Int64Type, []attr.Value{types.Int64Value(123)}),
+			wantErr: true,
+		},
+		{
+			name: "some values",
+			in: basetypes.NewListValueMust(
+				types.StringType,
+				[]attr.Value{
+					types.StringValue("abc"),
+					types.StringValue("xyz"),
+				},
+			),
+			want: []string{
+				"abc",
+				"xyz",
+			},
+		},
+	}
+
+	for _, tt := range tests {
+		t.Run(tt.name, func(t *testing.T) {
+			t.Parallel()
+			got, err := StringListToSlice(tt.in)
+			if tt.wantErr && err == nil {
+				t.Fatal("expected error")
+			}
+			if !tt.wantErr && err != nil {
+				t.Fatalf("expected no error, got: %v", err)
+			}
+			if d := cmp.Diff(got, tt.want); d != "" {
+				t.Fatalf("no match, diff: %s", d)
+			}
+		})
+	}
+}

stackit/internal/services/opensearch/credential/datasource.go

@@ -17,7 +17,7 @@ import (
 
 	"github.com/hashicorp/terraform-plugin-framework/datasource/schema"
 	"github.com/hashicorp/terraform-plugin-framework/types"
-	"github.com/stackitcloud/stackit-sdk-go/services/opensearch"
+	opensearch "github.com/stackitcloud/stackit-sdk-go/services/opensearch/v1api"
 )
 
 // Ensure the implementation satisfies the expected interfaces.
@@ -107,7 +107,7 @@ func (r *credentialDataSource) Schema(_ context.Context, _ datasource.SchemaRequ
 				Computed:  true,
 				Sensitive: true,
 			},
-			"port": schema.Int64Attribute{
+			"port": schema.Int32Attribute{
 				Computed: true,
 			},
 			"scheme": schema.StringAttribute{
@@ -142,7 +142,7 @@ func (r *credentialDataSource) Read(ctx context.Context, req datasource.ReadRequ
 	ctx = tflog.SetField(ctx, "instance_id", instanceId)
 	ctx = tflog.SetField(ctx, "credential_id", credentialId)
 
-	recordSetResp, err := r.client.GetCredentials(ctx, projectId, instanceId, credentialId).Execute()
+	recordSetResp, err := r.client.DefaultAPI.GetCredentials(ctx, projectId, instanceId, credentialId).Execute()
 	if err != nil {
 		utils.LogError(
 			ctx,

stackit/internal/services/opensearch/credential/resource.go

@@ -21,8 +21,8 @@ import (
 	"github.com/hashicorp/terraform-plugin-framework/resource/schema/stringplanmodifier"
 	"github.com/hashicorp/terraform-plugin-framework/types"
 	"github.com/stackitcloud/stackit-sdk-go/core/oapierror"
-	"github.com/stackitcloud/stackit-sdk-go/services/opensearch"
-	"github.com/stackitcloud/stackit-sdk-go/services/opensearch/wait"
+	opensearch "github.com/stackitcloud/stackit-sdk-go/services/opensearch/v1api"
+	"github.com/stackitcloud/stackit-sdk-go/services/opensearch/v1api/wait"
 )
 
 // Ensure the implementation satisfies the expected interfaces.
@@ -40,7 +40,7 @@ type Model struct {
 	Host         types.String `tfsdk:"host"`
 	Hosts        types.List   `tfsdk:"hosts"`
 	Password     types.String `tfsdk:"password"`
-	Port         types.Int64  `tfsdk:"port"`
+	Port         types.Int32  `tfsdk:"port"`
 	Scheme       types.String `tfsdk:"scheme"`
 	Uri          types.String `tfsdk:"uri"`
 	Username     types.String `tfsdk:"username"`
@@ -142,7 +142,7 @@ func (r *credentialResource) Schema(_ context.Context, _ resource.SchemaRequest,
 				Computed:  true,
 				Sensitive: true,
 			},
-			"port": schema.Int64Attribute{
+			"port": schema.Int32Attribute{
 				Computed: true,
 			},
 			"scheme": schema.StringAttribute{
@@ -176,26 +176,22 @@ func (r *credentialResource) Create(ctx context.Context, req resource.CreateRequ
 	ctx = tflog.SetField(ctx, "instance_id", instanceId)
 
 	// Create new recordset
-	credentialsResp, err := r.client.CreateCredentials(ctx, projectId, instanceId).Execute()
+	credentialsResp, err := r.client.DefaultAPI.CreateCredentials(ctx, projectId, instanceId).Execute()
 	if err != nil {
 		core.LogAndAddError(ctx, &resp.Diagnostics, "Error creating credential", fmt.Sprintf("Calling API: %v", err))
 		return
 	}
 
 	ctx = core.LogResponse(ctx)
 
-	if credentialsResp.Id == nil {
-		core.LogAndAddError(ctx, &resp.Diagnostics, "Error creating credential", "Got empty credential id")
-		return
-	}
-	credentialId := *credentialsResp.Id
+	credentialId := credentialsResp.Id
 	ctx = utils.SetAndLogStateFields(ctx, &resp.Diagnostics, &resp.State, map[string]any{
 		"project_id":    projectId,
 		"instance_id":   instanceId,
 		"credential_id": credentialId,
 	})
 
-	waitResp, err := wait.CreateCredentialsWaitHandler(ctx, r.client, projectId, instanceId, credentialId).WaitWithContext(ctx)
+	waitResp, err := wait.CreateCredentialsWaitHandler(ctx, r.client.DefaultAPI, projectId, instanceId, credentialId).WaitWithContext(ctx)
 	if err != nil {
 		core.LogAndAddError(ctx, &resp.Diagnostics, "Error creating credential", fmt.Sprintf("Instance creation waiting: %v", err))
 		return
@@ -233,7 +229,7 @@ func (r *credentialResource) Read(ctx context.Context, req resource.ReadRequest,
 	ctx = tflog.SetField(ctx, "instance_id", instanceId)
 	ctx = tflog.SetField(ctx, "credential_id", credentialId)
 
-	recordSetResp, err := r.client.GetCredentials(ctx, projectId, instanceId, credentialId).Execute()
+	recordSetResp, err := r.client.DefaultAPI.GetCredentials(ctx, projectId, instanceId, credentialId).Execute()
 	if err != 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 && oapiErr.StatusCode == http.StatusNotFound {
@@ -287,14 +283,14 @@ func (r *credentialResource) Delete(ctx context.Context, req resource.DeleteRequ
 	ctx = tflog.SetField(ctx, "credential_id", credentialId)
 
 	// Delete existing record set
-	err := r.client.DeleteCredentials(ctx, projectId, instanceId, credentialId).Execute()
+	err := r.client.DefaultAPI.DeleteCredentials(ctx, projectId, instanceId, credentialId).Execute()
 	if err != nil {
 		core.LogAndAddError(ctx, &resp.Diagnostics, "Error deleting credential", fmt.Sprintf("Calling API: %v", err))
 	}
 
 	ctx = core.LogResponse(ctx)
 
-	_, err = wait.DeleteCredentialsWaitHandler(ctx, r.client, projectId, instanceId, credentialId).WaitWithContext(ctx)
+	_, err = wait.DeleteCredentialsWaitHandler(ctx, r.client.DefaultAPI, projectId, instanceId, credentialId).WaitWithContext(ctx)
 	if err != nil {
 		core.LogAndAddError(ctx, &resp.Diagnostics, "Error deleting credential", fmt.Sprintf("Instance deletion waiting: %v", err))
 		return
@@ -337,10 +333,8 @@ func mapFields(ctx context.Context, credentialsResp *opensearch.CredentialsRespo
 	var credentialId string
 	if model.CredentialId.ValueString() != "" {
 		credentialId = model.CredentialId.ValueString()
-	} else if credentialsResp.Id != nil {
-		credentialId = *credentialsResp.Id
 	} else {
-		return fmt.Errorf("credentials id not present")
+		credentialId = credentialsResp.Id
 	}
 
 	model.Id = utils.BuildInternalTerraformId(
@@ -354,24 +348,22 @@ func mapFields(ctx context.Context, credentialsResp *opensearch.CredentialsRespo
 
 	model.CredentialId = types.StringValue(credentialId)
 	model.Hosts = types.ListNull(types.StringType)
-	if credentials != nil {
-		if credentials.Hosts != nil {
-			respHosts := *credentials.Hosts
-			reconciledHosts := utils.ReconcileStringSlices(modelHosts, respHosts)
+	if credentials.Hosts != nil {
+		respHosts := credentials.Hosts
+		reconciledHosts := utils.ReconcileStringSlices(modelHosts, respHosts)
 
-			hostsTF, diags := types.ListValueFrom(ctx, types.StringType, reconciledHosts)
-			if diags.HasError() {
-				return fmt.Errorf("failed to map hosts: %w", core.DiagsToError(diags))
-			}
-
-			model.Hosts = hostsTF
+		hostsTF, diags := types.ListValueFrom(ctx, types.StringType, reconciledHosts)
+		if diags.HasError() {
+			return fmt.Errorf("failed to map hosts: %w", core.DiagsToError(diags))
 		}
-		model.Host = types.StringPointerValue(credentials.Host)
-		model.Password = types.StringPointerValue(credentials.Password)
-		model.Port = types.Int64PointerValue(credentials.Port)
-		model.Scheme = types.StringPointerValue(credentials.Scheme)
-		model.Uri = types.StringPointerValue(credentials.Uri)
-		model.Username = types.StringPointerValue(credentials.Username)
+
+		model.Hosts = hostsTF
 	}
+	model.Host = types.StringValue(credentials.Host)
+	model.Password = types.StringValue(credentials.Password)
+	model.Port = types.Int32PointerValue(credentials.Port)
+	model.Scheme = types.StringPointerValue(credentials.Scheme)
+	model.Uri = types.StringPointerValue(credentials.Uri)
+	model.Username = types.StringValue(credentials.Username)
 	return nil
 }

stackit/internal/services/opensearch/credential/resource_test.go

@@ -7,7 +7,7 @@ import (
 	"github.com/google/go-cmp/cmp"
 	"github.com/hashicorp/terraform-plugin-framework/attr"
 	"github.com/hashicorp/terraform-plugin-framework/types"
-	"github.com/stackitcloud/stackit-sdk-go/services/opensearch"
+	opensearch "github.com/stackitcloud/stackit-sdk-go/services/opensearch/v1api"
 )
 
 func TestMapFields(t *testing.T) {
@@ -25,7 +25,7 @@ func TestMapFields(t *testing.T) {
 				ProjectId:  types.StringValue("pid"),
 			},
 			&opensearch.CredentialsResponse{
-				Id:  new("cid"),
+				Id:  "cid",
 				Raw: &opensearch.RawCredentials{},
 			},
 			Model{
@@ -36,7 +36,7 @@ func TestMapFields(t *testing.T) {
 				Host:         types.StringNull(),
 				Hosts:        types.ListNull(types.StringType),
 				Password:     types.StringNull(),
-				Port:         types.Int64Null(),
+				Port:         types.Int32Null(),
 				Scheme:       types.StringNull(),
 				Uri:          types.StringNull(),
 				Username:     types.StringNull(),
@@ -50,19 +50,19 @@ func TestMapFields(t *testing.T) {
 				ProjectId:  types.StringValue("pid"),
 			},
 			&opensearch.CredentialsResponse{
-				Id: new("cid"),
+				Id: "cid",
 				Raw: &opensearch.RawCredentials{
-					Credentials: &opensearch.Credentials{
-						Host: new("host"),
-						Hosts: &[]string{
+					Credentials: opensearch.Credentials{
+						Host: "host",
+						Hosts: []string{
 							"host_1",
 							"",
 						},
-						Password: new("password"),
-						Port:     new(int64(1234)),
+						Password: "password",
+						Port:     new(int32(1234)),
 						Scheme:   new("scheme"),
 						Uri:      new("uri"),
-						Username: new("username"),
+						Username: "username",
 					},
 				},
 			},
@@ -77,7 +77,7 @@ func TestMapFields(t *testing.T) {
 					types.StringValue(""),
 				}),
 				Password: types.StringValue("password"),
-				Port:     types.Int64Value(1234),
+				Port:     types.Int32Value(1234),
 				Scheme:   types.StringValue("scheme"),
 				Uri:      types.StringValue("uri"),
 				Username: types.StringValue("username"),
@@ -96,20 +96,20 @@ func TestMapFields(t *testing.T) {
 				}),
 			},
 			&opensearch.CredentialsResponse{
-				Id: new("cid"),
+				Id: "cid",
 				Raw: &opensearch.RawCredentials{
-					Credentials: &opensearch.Credentials{
-						Host: new("host"),
-						Hosts: &[]string{
+					Credentials: opensearch.Credentials{
+						Host: "host",
+						Hosts: []string{
 							"",
 							"host_1",
 							"host_2",
 						},
-						Password: new("password"),
-						Port:     new(int64(1234)),
+						Password: "password",
+						Port:     new(int32(1234)),
 						Scheme:   new("scheme"),
 						Uri:      new("uri"),
-						Username: new("username"),
+						Username: "username",
 					},
 				},
 			},
@@ -125,7 +125,7 @@ func TestMapFields(t *testing.T) {
 					types.StringValue("host_1"),
 				}),
 				Password: types.StringValue("password"),
-				Port:     types.Int64Value(1234),
+				Port:     types.Int32Value(1234),
 				Scheme:   types.StringValue("scheme"),
 				Uri:      types.StringValue("uri"),
 				Username: types.StringValue("username"),
@@ -139,16 +139,16 @@ func TestMapFields(t *testing.T) {
 				ProjectId:  types.StringValue("pid"),
 			},
 			&opensearch.CredentialsResponse{
-				Id: new("cid"),
+				Id: "cid",
 				Raw: &opensearch.RawCredentials{
-					Credentials: &opensearch.Credentials{
-						Host:     new(""),
-						Hosts:    &[]string{},
-						Password: new(""),
-						Port:     new(int64(2123456789)),
+					Credentials: opensearch.Credentials{
+						Host:     "",
+						Hosts:    []string{},
+						Password: "",
+						Port:     new(int32(2123456789)),
 						Scheme:   nil,
 						Uri:      nil,
-						Username: new(""),
+						Username: "",
 					},
 				},
 			},
@@ -160,7 +160,7 @@ func TestMapFields(t *testing.T) {
 				Host:         types.StringValue(""),
 				Hosts:        types.ListValueMust(types.StringType, []attr.Value{}),
 				Password:     types.StringValue(""),
-				Port:         types.Int64Value(2123456789),
+				Port:         types.Int32Value(2123456789),
 				Scheme:       types.StringNull(),
 				Uri:          types.StringNull(),
 				Username:     types.StringValue(""),
@@ -194,7 +194,7 @@ func TestMapFields(t *testing.T) {
 				ProjectId:  types.StringValue("pid"),
 			},
 			&opensearch.CredentialsResponse{
-				Id: new("cid"),
+				Id: "cid",
 			},
 			Model{},
 			false,