stackit-dev-tools/terraform-provider-stackitprivatepreview
3
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

feat(dns): add option to get dns_zone by dns_name (#856)

Browse source 
* feat: add option to get dns_zone by dns_name
This commit is contained in:
Marcel Jacek 2025-05-22 11:06:04 +02:00 • committed by GitHub
parent d7b6530b87
commit 913cc1415e
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
5 changed files with 159 additions and 43 deletions
Download patch file Download diff file Expand all files Collapse all files

85
stackit/internal/services/dns/zone/datasource.go
View file

@ -5,6 +5,8 @@ import (
"fmt"
"net/http"
"github.com/hashicorp/terraform-plugin-framework-validators/datasourcevalidator"
"github.com/hashicorp/terraform-plugin-framework/path"
"github.com/stackitcloud/terraform-provider-stackit/stackit/internal/conversion"
dnsUtils "github.com/stackitcloud/terraform-provider-stackit/stackit/internal/services/dns/utils"
@ -39,6 +41,16 @@ func (d *zoneDataSource) Metadata(_ context.Context, req datasource.MetadataRequ
resp.TypeName = req.ProviderTypeName + "_dns_zone"
}
// ConfigValidators validates the resource configuration
func (d *zoneDataSource) ConfigValidators(_ context.Context) []datasource.ConfigValidator {
return []datasource.ConfigValidator{
datasourcevalidator.ExactlyOneOf(
path.MatchRoot("zone_id"),
path.MatchRoot("dns_name"),
),
}
}
func (d *zoneDataSource) Configure(ctx context.Context, req datasource.ConfigureRequest, resp *datasource.ConfigureResponse) {
providerData, ok := conversion.ParseProviderData(ctx, req.ProviderData, &resp.Diagnostics)
if !ok {
@ -72,7 +84,7 @@ func (d *zoneDataSource) Schema(_ context.Context, _ datasource.SchemaRequest, r
},
"zone_id": schema.StringAttribute{
Description: "The zone ID.",
Required: true,
Optional: true,
Validators: []validator.String{
validate.UUID(),
validate.NoSeparator(),
@ -84,7 +96,7 @@ func (d *zoneDataSource) Schema(_ context.Context, _ datasource.SchemaRequest, r
},
"dns_name": schema.StringAttribute{
Description: "The zone name. E.g. `example.com`",
Computed: true,
Optional: true,
},
"description": schema.StringAttribute{
Description: "Description of the zone.",
@ -169,24 +181,65 @@ func (d *zoneDataSource) Read(ctx context.Context, req datasource.ReadRequest, r
}
projectId := model.ProjectId.ValueString()
zoneId := model.ZoneId.ValueString()
dnsName := model.DnsName.ValueString()
ctx = tflog.SetField(ctx, "project_id", projectId)
ctx = tflog.SetField(ctx, "zone_id", zoneId)
ctx = tflog.SetField(ctx, "dns_name", dnsName)
zoneResp, err := d.client.GetZone(ctx, projectId, zoneId).Execute()
if err != nil {
utils.LogError(
ctx,
&resp.Diagnostics,
err,
"Reading zone",
fmt.Sprintf("Zone with ID %q does not exist in project %q.", zoneId, projectId),
map[int]string{
http.StatusForbidden: fmt.Sprintf("Project with ID %q not found or forbidden access", projectId),
},
)
resp.State.RemoveResource(ctx)
return
var zoneResp *dns.ZoneResponse
var err error
if zoneId != "" {
zoneResp, err = d.client.GetZone(ctx, projectId, zoneId).Execute()
if err != nil {
utils.LogError(
ctx,
&resp.Diagnostics,
err,
"Reading zone",
fmt.Sprintf("Zone with ID %q does not exist in project %q.", zoneId, projectId),
map[int]string{
http.StatusForbidden: fmt.Sprintf("Project with ID %q not found or forbidden access", projectId),
},
)
resp.State.RemoveResource(ctx)
return
}
} else {
listZoneResp, err := d.client.ListZones(ctx, projectId).
DnsNameEq(dnsName).
ActiveEq(true).
Execute()
if err != nil {
utils.LogError(
ctx,
&resp.Diagnostics,
err,
"Reading zone",
fmt.Sprintf("Zone with DNS name %q does not exist in project %q.", dnsName, projectId),
map[int]string{
http.StatusForbidden: fmt.Sprintf("Project with ID %q not found or forbidden access", projectId),
},
)
resp.State.RemoveResource(ctx)
return
}
if *listZoneResp.TotalItems != 1 {
utils.LogError(
ctx,
&resp.Diagnostics,
fmt.Errorf("zone with DNS name %q does not exist in project %q", dnsName, projectId),
"Reading zone",
fmt.Sprintf("Zone with DNS name %q does not exist in project %q.", dnsName, projectId),
nil,
)
resp.State.RemoveResource(ctx)
return
}
zones := *listZoneResp.Zones
zoneResp = dns.NewZoneResponse(zones[0])
}
if zoneResp != nil && zoneResp.Zone.State != nil && *zoneResp.Zone.State == dns.ZONESTATE_DELETE_SUCCEEDED {
resp.State.RemoveResource(ctx)
core.LogAndAddError(ctx, &resp.Diagnostics, "Error reading zone", "Zone was deleted successfully")