Marcel_Henselin
4549ba63e5
## Description
<!-- **Please link some issue here describing what you are trying to achieve.**
In case there is no issue present for your PR, please consider creating one.
At least please give us some description what you are trying to achieve and why your change is needed. -->
relates to #1234
## Checklist
- [ ] Issue was linked above
- [ ] Code format was applied: `make fmt`
- [ ] Examples were added / adjusted (see `examples/` directory)
- [x] Docs are up-to-date: `make generate-docs` (will be checked by CI)
- [ ] Unit tests got implemented or updated
- [ ] Acceptance tests got implemented or updated (see e.g. [here](f5f99d1709/stackit/internal/services/dns/dns_acc_test.go))
- [x] Unit tests are passing: `make test` (will be checked by CI)
- [x] No linter issues: `make lint` (will be checked by CI)
Reviewed-on: #31
Reviewed-by: Andre_Harms <andre.harms@stackit.cloud>
294 lines
10 KiB
Go
294 lines
10 KiB
Go
// Copyright (c) STACKIT
|
|
|
|
package sqlserverflex
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"net/http"
|
|
|
|
"tf-provider.git.onstackit.cloud/stackit-dev-tools/terraform-provider-stackitprivatepreview/stackit/internal/conversion"
|
|
sqlserverflexalpha "tf-provider.git.onstackit.cloud/stackit-dev-tools/terraform-provider-stackitprivatepreview/stackit/internal/services/sqlserverflexalpha/instance/datasources_gen"
|
|
sqlserverflexalpha2 "tf-provider.git.onstackit.cloud/stackit-dev-tools/terraform-provider-stackitprivatepreview/stackit/internal/services/sqlserverflexalpha/instance/resources_gen"
|
|
sqlserverflexUtils "tf-provider.git.onstackit.cloud/stackit-dev-tools/terraform-provider-stackitprivatepreview/stackit/internal/services/sqlserverflexalpha/utils"
|
|
|
|
sqlserverflex "tf-provider.git.onstackit.cloud/stackit-dev-tools/terraform-provider-stackitprivatepreview/pkg_gen/sqlserverflexalpha"
|
|
|
|
"github.com/hashicorp/terraform-plugin-framework/datasource"
|
|
"github.com/hashicorp/terraform-plugin-log/tflog"
|
|
"tf-provider.git.onstackit.cloud/stackit-dev-tools/terraform-provider-stackitprivatepreview/stackit/internal/core"
|
|
"tf-provider.git.onstackit.cloud/stackit-dev-tools/terraform-provider-stackitprivatepreview/stackit/internal/utils"
|
|
)
|
|
|
|
// Ensure the implementation satisfies the expected interfaces.
|
|
var (
|
|
_ datasource.DataSource = &instanceDataSource{}
|
|
)
|
|
|
|
// NewInstanceDataSource is a helper function to simplify the provider implementation.
|
|
func NewInstanceDataSource() datasource.DataSource {
|
|
return &instanceDataSource{}
|
|
}
|
|
|
|
// instanceDataSource is the data source implementation.
|
|
type instanceDataSource struct {
|
|
client *sqlserverflex.APIClient
|
|
providerData core.ProviderData
|
|
}
|
|
|
|
// Metadata returns the data source type name.
|
|
func (r *instanceDataSource) Metadata(_ context.Context, req datasource.MetadataRequest, resp *datasource.MetadataResponse) {
|
|
resp.TypeName = req.ProviderTypeName + "_sqlserverflexalpha_instance"
|
|
}
|
|
|
|
// Configure adds the provider configured client to the data source.
|
|
func (r *instanceDataSource) Configure(ctx context.Context, req datasource.ConfigureRequest, resp *datasource.ConfigureResponse) {
|
|
var ok bool
|
|
r.providerData, ok = conversion.ParseProviderData(ctx, req.ProviderData, &resp.Diagnostics)
|
|
if !ok {
|
|
return
|
|
}
|
|
|
|
apiClient := sqlserverflexUtils.ConfigureClient(ctx, &r.providerData, &resp.Diagnostics)
|
|
if resp.Diagnostics.HasError() {
|
|
return
|
|
}
|
|
r.client = apiClient
|
|
tflog.Info(ctx, "SQLServer Flex instance client configured")
|
|
}
|
|
|
|
// Schema defines the schema for the data source.
|
|
func (r *instanceDataSource) Schema(ctx context.Context, _ datasource.SchemaRequest, resp *datasource.SchemaResponse) {
|
|
//descriptions := map[string]string{
|
|
// "main": "SQLServer Flex ALPHA instance resource schema. Must have a `region` specified in the provider configuration.",
|
|
// "id": "Terraform's internal resource ID. It is structured as \"`project_id`,`region`,`instance_id`\".",
|
|
// "instance_id": "ID of the SQLServer Flex instance.",
|
|
// "project_id": "STACKIT project ID to which the instance is associated.",
|
|
// "name": "Instance name.",
|
|
// "access_scope": "The access scope of the instance. (e.g. SNA)",
|
|
// "acl": "The Access Control List (ACL) for the SQLServer Flex instance.",
|
|
// "backup_schedule": `The backup schedule. Should follow the cron scheduling system format (e.g. "0 0 * * *")`,
|
|
// "region": "The resource region. If not defined, the provider region is used.",
|
|
// "encryption": "The encryption block.",
|
|
// "network": "The network block.",
|
|
// "keyring_id": "STACKIT KMS - KeyRing ID of the encryption key to use.",
|
|
// "key_id": "STACKIT KMS - Key ID of the encryption key to use.",
|
|
// "key_version": "STACKIT KMS - Key version to use in the encryption key.",
|
|
// "service:account": "STACKIT KMS - service account to use in the encryption key.",
|
|
// "instance_address": "The returned instance IP address of the SQLServer Flex instance.",
|
|
// "router_address": "The returned router IP address of the SQLServer Flex instance.",
|
|
//}
|
|
|
|
resp.Schema = sqlserverflexalpha.InstanceDataSourceSchema(ctx)
|
|
|
|
//resp.Schema = schema.Schema{
|
|
// Description: descriptions["main"],
|
|
// Attributes: map[string]schema.Attribute{
|
|
// "id": schema.StringAttribute{
|
|
// Description: descriptions["id"],
|
|
// Computed: true,
|
|
// },
|
|
// "instance_id": schema.StringAttribute{
|
|
// Description: descriptions["instance_id"],
|
|
// Required: true,
|
|
// Validators: []validator.String{
|
|
// validate.UUID(),
|
|
// validate.NoSeparator(),
|
|
// },
|
|
// },
|
|
// "project_id": schema.StringAttribute{
|
|
// Description: descriptions["project_id"],
|
|
// Required: true,
|
|
// Validators: []validator.String{
|
|
// validate.UUID(),
|
|
// validate.NoSeparator(),
|
|
// },
|
|
// },
|
|
// "name": schema.StringAttribute{
|
|
// Description: descriptions["name"],
|
|
// Computed: true,
|
|
// },
|
|
// "backup_schedule": schema.StringAttribute{
|
|
// Description: descriptions["backup_schedule"],
|
|
// Computed: true,
|
|
// },
|
|
// "is_deletable": schema.BoolAttribute{
|
|
// Description: descriptions["is_deletable"],
|
|
// Computed: true,
|
|
// },
|
|
// "flavor": schema.SingleNestedAttribute{
|
|
// Computed: true,
|
|
// Attributes: map[string]schema.Attribute{
|
|
// "id": schema.StringAttribute{
|
|
// Computed: true,
|
|
// },
|
|
// "description": schema.StringAttribute{
|
|
// Computed: true,
|
|
// },
|
|
// "cpu": schema.Int64Attribute{
|
|
// Computed: true,
|
|
// },
|
|
// "ram": schema.Int64Attribute{
|
|
// Computed: true,
|
|
// },
|
|
// "node_type": schema.StringAttribute{
|
|
// Computed: true,
|
|
// },
|
|
// },
|
|
// },
|
|
// "replicas": schema.Int64Attribute{
|
|
// Computed: true,
|
|
// },
|
|
// "storage": schema.SingleNestedAttribute{
|
|
// Computed: true,
|
|
// Attributes: map[string]schema.Attribute{
|
|
// "class": schema.StringAttribute{
|
|
// Computed: true,
|
|
// },
|
|
// "size": schema.Int64Attribute{
|
|
// Computed: true,
|
|
// },
|
|
// },
|
|
// },
|
|
// "version": schema.StringAttribute{
|
|
// Computed: true,
|
|
// },
|
|
// "status": schema.StringAttribute{
|
|
// Computed: true,
|
|
// },
|
|
// "edition": schema.StringAttribute{
|
|
// Computed: true,
|
|
// },
|
|
// "retention_days": schema.Int64Attribute{
|
|
// Computed: true,
|
|
// },
|
|
// "region": schema.StringAttribute{
|
|
// // the region cannot be found, so it has to be passed
|
|
// Optional: true,
|
|
// Description: descriptions["region"],
|
|
// },
|
|
// "encryption": schema.SingleNestedAttribute{
|
|
// Computed: true,
|
|
// Attributes: map[string]schema.Attribute{
|
|
// "key_id": schema.StringAttribute{
|
|
// Description: descriptions["key_id"],
|
|
// Computed: true,
|
|
// },
|
|
// "key_version": schema.StringAttribute{
|
|
// Description: descriptions["key_version"],
|
|
// Computed: true,
|
|
// },
|
|
// "keyring_id": schema.StringAttribute{
|
|
// Description: descriptions["keyring_id"],
|
|
// Computed: true,
|
|
// },
|
|
// "service_account": schema.StringAttribute{
|
|
// Description: descriptions["service_account"],
|
|
// Computed: true,
|
|
// },
|
|
// },
|
|
// Description: descriptions["encryption"],
|
|
// },
|
|
// "network": schema.SingleNestedAttribute{
|
|
// Computed: true,
|
|
// Attributes: map[string]schema.Attribute{
|
|
// "access_scope": schema.StringAttribute{
|
|
// Description: descriptions["access_scope"],
|
|
// Computed: true,
|
|
// },
|
|
// "instance_address": schema.StringAttribute{
|
|
// Description: descriptions["instance_address"],
|
|
// Computed: true,
|
|
// },
|
|
// "router_address": schema.StringAttribute{
|
|
// Description: descriptions["router_address"],
|
|
// Computed: true,
|
|
// },
|
|
// "acl": schema.ListAttribute{
|
|
// Description: descriptions["acl"],
|
|
// ElementType: types.StringType,
|
|
// Computed: true,
|
|
// },
|
|
// },
|
|
// Description: descriptions["network"],
|
|
// },
|
|
// },
|
|
//}
|
|
}
|
|
|
|
// Read refreshes the Terraform state with the latest data.
|
|
func (r *instanceDataSource) Read(ctx context.Context, req datasource.ReadRequest, resp *datasource.ReadResponse) { // nolint:gocritic // function signature required by Terraform
|
|
var model sqlserverflexalpha2.InstanceModel
|
|
diags := req.Config.Get(ctx, &model)
|
|
resp.Diagnostics.Append(diags...)
|
|
if resp.Diagnostics.HasError() {
|
|
return
|
|
}
|
|
|
|
ctx = core.InitProviderContext(ctx)
|
|
|
|
projectId := model.ProjectId.ValueString()
|
|
instanceId := model.InstanceId.ValueString()
|
|
region := r.providerData.GetRegionWithOverride(model.Region)
|
|
ctx = tflog.SetField(ctx, "project_id", projectId)
|
|
ctx = tflog.SetField(ctx, "instance_id", instanceId)
|
|
ctx = tflog.SetField(ctx, "region", region)
|
|
instanceResp, err := r.client.GetInstanceRequest(ctx, projectId, region, instanceId).Execute()
|
|
if err != nil {
|
|
utils.LogError(
|
|
ctx,
|
|
&resp.Diagnostics,
|
|
err,
|
|
"Reading instance",
|
|
fmt.Sprintf("Instance with ID %q does not exist in project %q.", instanceId, projectId),
|
|
map[int]string{
|
|
http.StatusForbidden: fmt.Sprintf("Project with ID %q not found or forbidden access", projectId),
|
|
},
|
|
)
|
|
resp.State.RemoveResource(ctx)
|
|
return
|
|
}
|
|
|
|
ctx = core.LogResponse(ctx)
|
|
|
|
//var storage = &storageModel{}
|
|
//if !model.Storage.IsNull() && !model.Storage.IsUnknown() {
|
|
// diags = model.Storage.As(ctx, storage, basetypes.ObjectAsOptions{})
|
|
// resp.Diagnostics.Append(diags...)
|
|
// if resp.Diagnostics.HasError() {
|
|
// return
|
|
// }
|
|
//}
|
|
//
|
|
//var encryption = &encryptionModel{}
|
|
//if !model.Encryption.IsNull() && !model.Encryption.IsUnknown() {
|
|
// diags = model.Encryption.As(ctx, encryption, basetypes.ObjectAsOptions{})
|
|
// resp.Diagnostics.Append(diags...)
|
|
// if resp.Diagnostics.HasError() {
|
|
// return
|
|
// }
|
|
//}
|
|
//
|
|
//var network = &networkModel{}
|
|
//if !model.Network.IsNull() && !model.Network.IsUnknown() {
|
|
// diags = model.Network.As(ctx, network, basetypes.ObjectAsOptions{})
|
|
// resp.Diagnostics.Append(diags...)
|
|
// if resp.Diagnostics.HasError() {
|
|
// return
|
|
// }
|
|
//}
|
|
|
|
err = mapResponseToModel(ctx, instanceResp, &model, resp.Diagnostics)
|
|
//err = mapFields(ctx, instanceResp, &model, storage, encryption, network, region)
|
|
if err != nil {
|
|
core.LogAndAddError(ctx, &resp.Diagnostics, "Error reading instance", fmt.Sprintf("Processing API payload: %v", err))
|
|
return
|
|
}
|
|
// Set refreshed state
|
|
diags = resp.State.Set(ctx, model)
|
|
resp.Diagnostics.Append(diags...)
|
|
if resp.Diagnostics.HasError() {
|
|
return
|
|
}
|
|
tflog.Info(ctx, "SQLServer Flex instance read")
|
|
}
|