New Resource: azurerm_network_manager_ipam_pool

internal/services/network/network_manager_data_source_test.go

@@ -22,7 +22,7 @@ func testAccNetworkManagerDataSource_complete(t *testing.T) {
 			Check: acceptance.ComposeTestCheckFunc(
 				check.That(data.ResourceName).Key("location").IsNotEmpty(),
 				check.That(data.ResourceName).Key("description").IsNotEmpty(),
-				check.That(data.ResourceName).Key("scope_accesses.#").HasValue("2"),
+				check.That(data.ResourceName).Key("scope_accesses.#").HasValue("3"),
 				check.That(data.ResourceName).Key("scope_accesses.0").HasValue("Connectivity"),
 				check.That(data.ResourceName).Key("scope.#").HasValue("1"),
 				check.That(data.ResourceName).Key("scope.0.subscription_ids.#").HasValue("1"),

internal/services/network/network_manager_ipam_pool_resource.go

@@ -0,0 +1,303 @@
+package network
+
+import (
+	"context"
+	"fmt"
+	"log"
+	"regexp"
+	"time"
+
+	"github.com/hashicorp/go-azure-helpers/lang/pointer"
+	"github.com/hashicorp/go-azure-helpers/lang/response"
+	"github.com/hashicorp/go-azure-helpers/resourcemanager/commonschema"
+	"github.com/hashicorp/go-azure-helpers/resourcemanager/location"
+	"github.com/hashicorp/go-azure-helpers/resourcemanager/tags"
+	"github.com/hashicorp/go-azure-sdk/resource-manager/network/2024-05-01/ipampools"
+	"github.com/hashicorp/terraform-provider-azurerm/internal/sdk"
+	"github.com/hashicorp/terraform-provider-azurerm/internal/tf/pluginsdk"
+	"github.com/hashicorp/terraform-provider-azurerm/internal/tf/validation"
+)
+
+var (
+	_ sdk.Resource           = ManagerIpamPoolResource{}
+	_ sdk.ResourceWithUpdate = ManagerIpamPoolResource{}
+)
+
+type ManagerIpamPoolResource struct{}
+
+func (ManagerIpamPoolResource) IDValidationFunc() pluginsdk.SchemaValidateFunc {
+	return ipampools.ValidateIPamPoolID
+}
+
+func (ManagerIpamPoolResource) ResourceType() string {
+	return "azurerm_network_manager_ipam_pool"
+}
+
+func (ManagerIpamPoolResource) ModelObject() interface{} {
+	return &ManagerIpamPoolResourceModel{}
+}
+
+type ManagerIpamPoolResourceModel struct {
+	AddressPrefixes  []string               `tfschema:"address_prefixes"`
+	Description      string                 `tfschema:"description"`
+	DisplayName      string                 `tfschema:"display_name"`
+	Location         string                 `tfschema:"location"`
+	Name             string                 `tfschema:"name"`
+	NetworkManagerId string                 `tfschema:"network_manager_id"`
+	ParentPoolName   string                 `tfschema:"parent_pool_name"`
+	Tags             map[string]interface{} `tfschema:"tags"`
+}
+
+func (ManagerIpamPoolResource) Arguments() map[string]*pluginsdk.Schema {
+	return map[string]*pluginsdk.Schema{
+		"name": {
+			Type:     pluginsdk.TypeString,
+			Required: true,
+			ForceNew: true,
+			ValidateFunc: validation.StringMatch(
+				regexp.MustCompile(`^[a-zA-Z0-9\_\.\-]{1,64}$`),
+				"name must be between 1 and 64 characters long and can only contain letters, numbers, underscores(_), periods(.), and hyphens(-).",
+			),
+		},
+
+		"network_manager_id": commonschema.ResourceIDReferenceRequiredForceNew(&ipampools.NetworkManagerId{}),
+
+		"location": commonschema.Location(),
+
+		"display_name": {
+			Type:     pluginsdk.TypeString,
+			Required: true,
+			ValidateFunc: validation.StringMatch(
+				regexp.MustCompile(`^[a-zA-Z0-9\_\.\-]{1,64}$`),
+				"display_name must be between 1 and 64 characters long and can only contain letters, numbers, underscores(_), periods(.), and hyphens(-).",
+			),
+		},
+
+		"address_prefixes": {
+			Type:     pluginsdk.TypeList,
+			Required: true,
+			ForceNew: true,
+			Elem: &pluginsdk.Schema{
+				Type:         pluginsdk.TypeString,
+				ValidateFunc: validation.IsCIDR,
+			},
+		},
+
+		"parent_pool_name": {
+			Type:     pluginsdk.TypeString,
+			Optional: true,
+			ForceNew: true,
+			ValidateFunc: validation.StringMatch(
+				regexp.MustCompile(`^[a-zA-Z0-9\_\.\-]{1,64}$`),
+				"parent_pool_name must be between 1 and 64 characters long and can only contain letters, numbers, underscores(_), periods(.), and hyphens(-).",
+			),
+		},
+
+		"description": {
+			Type:         pluginsdk.TypeString,
+			Optional:     true,
+			ValidateFunc: validation.StringIsNotEmpty,
+		},
+
+		"tags": commonschema.Tags(),
+	}
+}
+
+func (ManagerIpamPoolResource) Attributes() map[string]*pluginsdk.Schema {
+	return map[string]*pluginsdk.Schema{}
+}
+
+func (r ManagerIpamPoolResource) Create() sdk.ResourceFunc {
+	return sdk.ResourceFunc{
+		Timeout: 30 * time.Minute,
+		Func: func(ctx context.Context, metadata sdk.ResourceMetaData) error {
+			client := metadata.Client.Network.IPamPools
+
+			var config ManagerIpamPoolResourceModel
+			if err := metadata.Decode(&config); err != nil {
+				return fmt.Errorf("decoding: %+v", err)
+			}
+
+			networkManagerId, err := ipampools.ParseNetworkManagerID(config.NetworkManagerId)
+			if err != nil {
+				return fmt.Errorf("parsing `network_manager_id`: %+v", err)
+			}
+
+			subscriptionId := metadata.Client.Account.SubscriptionId
+			id := ipampools.NewIPamPoolID(subscriptionId, networkManagerId.ResourceGroupName, networkManagerId.NetworkManagerName, config.Name)
+
+			existing, err := client.Get(ctx, id)
+			if err != nil && !response.WasNotFound(existing.HttpResponse) {
+				return fmt.Errorf("checking for presence of existing %s: %+v", id, err)
+			}
+			if !response.WasNotFound(existing.HttpResponse) {
+				return metadata.ResourceRequiresImport(r.ResourceType(), id)
+			}
+
+			payload := ipampools.IPamPool{
+				Name:     pointer.To(config.Name),
+				Location: location.Normalize(config.Location),
+				Tags:     tags.Expand(config.Tags),
+				Properties: ipampools.IPamPoolProperties{
+					AddressPrefixes: config.AddressPrefixes,
+					Description:     pointer.To(config.Description),
+					DisplayName:     pointer.To(config.DisplayName),
+					ParentPoolName:  pointer.To(config.ParentPoolName),
+				},
+			}
+
+			if err := client.CreateThenPoll(ctx, id, payload); err != nil {
+				return fmt.Errorf("performing create %s: %+v", id, err)
+			}
+
+			metadata.SetID(id)
+
+			return nil
+		},
+	}
+}
+
+func (r ManagerIpamPoolResource) Read() sdk.ResourceFunc {
+	return sdk.ResourceFunc{
+		Timeout: 5 * time.Minute,
+		Func: func(ctx context.Context, metadata sdk.ResourceMetaData) error {
+			client := metadata.Client.Network.IPamPools
+
+			id, err := ipampools.ParseIPamPoolID(metadata.ResourceData.Id())
+			if err != nil {
+				return err
+			}
+
+			resp, err := client.Get(ctx, *id)
+			if err != nil {
+				if response.WasNotFound(resp.HttpResponse) {
+					return metadata.MarkAsGone(id)
+				}
+
+				return fmt.Errorf("retrieving %s: %+v", id, err)
+			}
+
+			networkManagerId := ipampools.NewNetworkManagerID(id.SubscriptionId, id.ResourceGroupName, id.NetworkManagerName).ID()
+			schema := ManagerIpamPoolResourceModel{
+				Name:             id.IpamPoolName,
+				NetworkManagerId: networkManagerId,
+			}
+
+			if model := resp.Model; model != nil {
+				schema.Location = location.Normalize(model.Location)
+				schema.Tags = tags.Flatten(model.Tags)
+
+				props := model.Properties
+				schema.AddressPrefixes = props.AddressPrefixes
+				schema.Description = pointer.From(props.Description)
+				schema.DisplayName = pointer.From(props.DisplayName)
+				schema.ParentPoolName = pointer.From(props.ParentPoolName)
+			}
+
+			return metadata.Encode(&schema)
+		},
+	}
+}
+
+func (r ManagerIpamPoolResource) Update() sdk.ResourceFunc {
+	return sdk.ResourceFunc{
+		Timeout: 30 * time.Minute,
+		Func: func(ctx context.Context, metadata sdk.ResourceMetaData) error {
+			client := metadata.Client.Network.IPamPools
+
+			id, err := ipampools.ParseIPamPoolID(metadata.ResourceData.Id())
+			if err != nil {
+				return err
+			}
+
+			var model ManagerIpamPoolResourceModel
+			if err := metadata.Decode(&model); err != nil {
+				return fmt.Errorf("decoding: %+v", err)
+			}
+
+			parameters := ipampools.IPamPoolUpdate{
+				Properties: &ipampools.IPamPoolUpdateProperties{},
+			}
+
+			if metadata.ResourceData.HasChange("tags") {
+				parameters.Tags = tags.Expand(model.Tags)
+			}
+
+			if metadata.ResourceData.HasChange("description") {
+				parameters.Properties.Description = pointer.To(model.Description)
+			}
+
+			if metadata.ResourceData.HasChange("display_name") {
+				parameters.Properties.DisplayName = pointer.To(model.DisplayName)
+			}
+
+			if _, err := client.Update(ctx, *id, parameters); err != nil {
+				return fmt.Errorf("updating %s: %+v", id, err)
+			}
+			return nil
+		},
+	}
+}
+
+func (r ManagerIpamPoolResource) Delete() sdk.ResourceFunc {
+	return sdk.ResourceFunc{
+		Timeout: 30 * time.Minute,
+		Func: func(ctx context.Context, metadata sdk.ResourceMetaData) error {
+			client := metadata.Client.Network.IPamPools
+
+			id, err := ipampools.ParseIPamPoolID(metadata.ResourceData.Id())
+			if err != nil {
+				return err
+			}
+
+			if err := client.DeleteThenPoll(ctx, *id); err != nil {
+				return fmt.Errorf("deleting %s: %+v", id, err)
+			}
+
+			// https://github.com/Azure/azure-rest-api-specs/issues/31688
+			if err := resourceIpamPoolWaitForDeleted(ctx, *client, *id); err != nil {
+				return fmt.Errorf("waiting for %s to be deleted: %+v", id, err)
+			}
+
+			return nil
+		},
+	}
+}
+
+func resourceIpamPoolWaitForDeleted(ctx context.Context, client ipampools.IPamPoolsClient, id ipampools.IPamPoolId) error {
+	deadline, ok := ctx.Deadline()
+	if !ok {
+		return fmt.Errorf("internal error: context had no deadline")
+	}
+	state := &pluginsdk.StateChangeConf{
+		MinTimeout:                5 * time.Second,
+		ContinuousTargetOccurence: 3,
+		Pending:                   []string{"Exists"},
+		Target:                    []string{"NotFound"},
+		Refresh:                   resourceIpamPoolRefreshFunc(ctx, client, id),
+		Timeout:                   time.Until(deadline),
+	}
+
+	if _, err := state.WaitForStateContext(ctx); err != nil {
+		return fmt.Errorf("waiting for %s to be deleted: %+v", id, err)
+	}
+
+	return nil
+}
+
+func resourceIpamPoolRefreshFunc(ctx context.Context, client ipampools.IPamPoolsClient, id ipampools.IPamPoolId) pluginsdk.StateRefreshFunc {
+	return func() (interface{}, string, error) {
+		log.Printf("[DEBUG] Checking %s status ..", id)
+
+		resp, err := client.Get(ctx, id)
+		if err != nil {
+			if response.WasNotFound(resp.HttpResponse) {
+				return resp, "NotFound", nil
+			}
+
+			return resp, "Error", fmt.Errorf("retrieving %s: %+v", id, err)
+		}
+
+		return resp, "Exists", nil
+	}
+}