resource_ibm_is_vpn_server_route.go

// Copyright IBM Corp. 2022 All Rights Reserved.
// Licensed under the Mozilla Public License v2.0

package vpc

import (
	"context"
	"fmt"
	"log"
	"time"

	"github.com/IBM-Cloud/terraform-provider-ibm/ibm/flex"
	"github.com/IBM-Cloud/terraform-provider-ibm/ibm/validate"
	"github.com/IBM/go-sdk-core/v5/core"
	"github.com/hashicorp/terraform-plugin-sdk/v2/diag"
	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/resource"
	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/schema"

	"github.com/IBM/vpc-go-sdk/vpcv1"
)

const (
	isVPNServerRouteStatusPending  = "pending"
	isVPNServerRouteStatusUpdating = "updating"
	isVPNServerRouteStatusStable   = "stable"
	isVPNServerRouteStatusFailed   = "failed"

	isVPNServerRouteStatusDeleting = "deleting"
	isVPNServerRouteStatusDeleted  = "deleted"
)

func ResourceIBMIsVPNServerRoute() *schema.Resource {
	return &schema.Resource{
		CreateContext: resourceIBMIsVPNServerRouteCreate,
		ReadContext:   resourceIBMIsVPNServerRouteRead,
		UpdateContext: resourceIBMIsVPNServerRouteUpdate,
		DeleteContext: resourceIBMIsVPNServerRouteDelete,
		Importer:      &schema.ResourceImporter{},

		Timeouts: &schema.ResourceTimeout{
			Create: schema.DefaultTimeout(10 * time.Minute),
			Update: schema.DefaultTimeout(10 * time.Minute),
			Delete: schema.DefaultTimeout(10 * time.Minute),
		},

		Schema: map[string]*schema.Schema{
			"vpn_server": &schema.Schema{
				Type:        schema.TypeString,
				Required:    true,
				ForceNew:    true,
				Description: "The VPN server identifier.",
			},
			"vpn_route": &schema.Schema{
				Type:        schema.TypeString,
				Computed:    true,
				Description: "The VPN route identifier.",
			},
			"destination": &schema.Schema{
				Type:         schema.TypeString,
				Required:     true,
				ForceNew:     true,
				ValidateFunc: validate.InvokeValidator("ibm_is_vpn_server_route", "destination"),
				Description:  "The destination to use for this VPN route in the VPN server. Must be unique within the VPN server. If an incoming packet does not match any destination, it will be dropped.",
			},
			"action": &schema.Schema{
				Type:         schema.TypeString,
				Optional:     true,
				ForceNew:     true,
				Default:      "deliver",
				ValidateFunc: validate.InvokeValidator("ibm_is_vpn_server_route", "action"),
				Description:  "The action to perform with a packet matching the VPN route:- `translate`: translate the source IP address to one of the private IP addresses of the VPN server, then deliver the packet to target.- `deliver`: deliver the packet to the target.- `drop`: drop the packetThe enumerated values for this property are expected to expand in the future. When processing this property, check for and log unknown values. Optionally halt processing and surface the error, or bypass the VPN route on which the unexpected property value was encountered.",
			},
			"name": &schema.Schema{
				Type:         schema.TypeString,
				Optional:     true,
				Computed:     true,
				ValidateFunc: validate.InvokeValidator("ibm_is_vpn_server_route", "name"),
				Description:  "The user-defined name for this VPN route. If unspecified, the name will be a hyphenated list of randomly-selected words. Names must be unique within the VPN server the VPN route resides in.",
			},
			"created_at": &schema.Schema{
				Type:        schema.TypeString,
				Computed:    true,
				Description: "The date and time that the VPN route was created.",
			},
			"href": &schema.Schema{
				Type:        schema.TypeString,
				Computed:    true,
				Description: "The URL for this VPN route.",
			},
			"lifecycle_state": &schema.Schema{
				Type:        schema.TypeString,
				Computed:    true,
				Description: "The lifecycle state of the VPN route.",
			},
			"resource_type": &schema.Schema{
				Type:        schema.TypeString,
				Computed:    true,
				Description: "The resource type.",
			},
		},
	}
}

func ResourceIBMIsVPNServerRouteValidator() *validate.ResourceValidator {
	validateSchema := make([]validate.ValidateSchema, 0)
	validateSchema = append(validateSchema,
		validate.ValidateSchema{
			Identifier:                 "destination",
			ValidateFunctionIdentifier: validate.ValidateRegexp,
			Type:                       validate.TypeString,
			Required:                   true,
			Regexp:                     `^(([0-9]|[1-9][0-9]|1[0-9]{2}|2[0-4][0-9]|25[0-5])\.){3}([0-9]|[1-9][0-9]|1[0-9]{2}|2[0-4][0-9]|25[0-5])(\/(3[0-2]|[1-2][0-9]|[0-9]))$`,
		},
		validate.ValidateSchema{
			Identifier:                 "action",
			ValidateFunctionIdentifier: validate.ValidateAllowedStringValue,
			Type:                       validate.TypeString,
			Optional:                   true,
			AllowedValues:              "deliver, drop, translate",
		},
		validate.ValidateSchema{
			Identifier:                 "name",
			ValidateFunctionIdentifier: validate.ValidateRegexpLen,
			Type:                       validate.TypeString,
			Optional:                   true,
			Regexp:                     `^([a-z]|[a-z][-a-z0-9]*[a-z0-9])$`,
			MinValueLength:             1,
			MaxValueLength:             63,
		},
	)

	resourceValidator := validate.ResourceValidator{ResourceName: "ibm_is_vpn_server_route", Schema: validateSchema}
	return &resourceValidator
}

func resourceIBMIsVPNServerRouteCreate(context context.Context, d *schema.ResourceData, meta interface{}) diag.Diagnostics {
	sess, err := vpcClient(meta)
	if err != nil {
		return diag.FromErr(err)
	}

	createVPNServerRouteOptions := &vpcv1.CreateVPNServerRouteOptions{}

	createVPNServerRouteOptions.SetVPNServerID(d.Get("vpn_server").(string))
	createVPNServerRouteOptions.SetDestination(d.Get("destination").(string))
	if _, ok := d.GetOk("action"); ok {
		createVPNServerRouteOptions.SetAction(d.Get("action").(string))
	}
	if _, ok := d.GetOk("name"); ok {
		createVPNServerRouteOptions.SetName(d.Get("name").(string))
	}

	vpnServerRoute, response, err := sess.CreateVPNServerRouteWithContext(context, createVPNServerRouteOptions)
	if err != nil {
		log.Printf("[DEBUG] CreateVPNServerRouteWithContext failed %s\n%s", err, response)
		return diag.FromErr(fmt.Errorf("[ERROR] CreateVPNServerRouteWithContext failed %s\n%s", err, response))
	}

	d.SetId(fmt.Sprintf("%s/%s", *createVPNServerRouteOptions.VPNServerID, *vpnServerRoute.ID))

	_, err = isWaitForVPNServerRouteStable(context, sess, d, d.Timeout(schema.TimeoutCreate))
	if err != nil {
		return diag.FromErr(fmt.Errorf("[ERROR] VPNServer Route failed %s\n", err))
	}
	return resourceIBMIsVPNServerRouteRead(context, d, meta)
}

func isWaitForVPNServerRouteStable(context context.Context, sess *vpcv1.VpcV1, d *schema.ResourceData, timeout time.Duration) (interface{}, error) {

	log.Printf("Waiting for VPN Server  Route(%s) to be stable.", d.Id())
	stateConf := &resource.StateChangeConf{
		Pending: []string{isVPNServerStatusPending, isVPNServerRouteStatusUpdating},
		Target:  []string{isVPNServerStatusStable, isVPNServerRouteStatusFailed},
		Refresh: func() (interface{}, string, error) {
			getVPNServerRouteOptions := &vpcv1.GetVPNServerRouteOptions{}

			parts, err := flex.SepIdParts(d.Id(), "/")
			if err != nil {
				log.Printf("[DEBUG] Getting ID failed %s", err)
				return nil, "", fmt.Errorf("Error Getting VPC Server: %s", err)
			}

			getVPNServerRouteOptions.SetVPNServerID(parts[0])
			getVPNServerRouteOptions.SetID(parts[1])

			vpnServerRoute, response, err := sess.GetVPNServerRouteWithContext(context, getVPNServerRouteOptions)
			if err != nil {
				log.Printf("[DEBUG] GetVPNServerRouteWithContext failed %s\n%s", err, response)
				return vpnServerRoute, "", fmt.Errorf("Error Getting VPC Server Route: %s\n%s", err, response)
			}

			if *vpnServerRoute.LifecycleState == "stable" || *vpnServerRoute.LifecycleState == "failed" {
				return vpnServerRoute, *vpnServerRoute.LifecycleState, nil
			}
			return vpnServerRoute, *vpnServerRoute.LifecycleState, nil
		},
		Timeout:    timeout,
		Delay:      10 * time.Second,
		MinTimeout: 10 * time.Second,
	}

	return stateConf.WaitForState()
}
func resourceIBMIsVPNServerRouteRead(context context.Context, d *schema.ResourceData, meta interface{}) diag.Diagnostics {
	sess, err := vpcClient(meta)
	if err != nil {
		return diag.FromErr(err)
	}

	getVPNServerRouteOptions := &vpcv1.GetVPNServerRouteOptions{}

	parts, err := flex.SepIdParts(d.Id(), "/")
	if err != nil {
		return diag.FromErr(err)
	}

	getVPNServerRouteOptions.SetVPNServerID(parts[0])
	getVPNServerRouteOptions.SetID(parts[1])

	vpnServerRoute, response, err := sess.GetVPNServerRouteWithContext(context, getVPNServerRouteOptions)
	if err != nil {
		if response != nil && response.StatusCode == 404 {
			d.SetId("")
			return nil
		}
		log.Printf("[DEBUG] GetVPNServerRouteWithContext failed %s\n%s", err, response)
		return diag.FromErr(fmt.Errorf("[ERROR] GetVPNServerRouteWithContext failed %s\n%s", err, response))
	}

	if err = d.Set("vpn_server", getVPNServerRouteOptions.VPNServerID); err != nil {
		return diag.FromErr(fmt.Errorf("[ERROR] Error setting vpn_server: %s", err))
	}
	if err = d.Set("vpn_route", getVPNServerRouteOptions.ID); err != nil {
		return diag.FromErr(fmt.Errorf("[ERROR] Error setting vpn_route: %s", err))
	}

	if err = d.Set("destination", vpnServerRoute.Destination); err != nil {
		return diag.FromErr(fmt.Errorf("[ERROR] Error setting destination: %s", err))
	}
	if err = d.Set("action", vpnServerRoute.Action); err != nil {
		return diag.FromErr(fmt.Errorf("[ERROR] Error setting action: %s", err))
	}
	if err = d.Set("name", vpnServerRoute.Name); err != nil {
		return diag.FromErr(fmt.Errorf("[ERROR] Error setting name: %s", err))
	}
	if err = d.Set("created_at", flex.DateTimeToString(vpnServerRoute.CreatedAt)); err != nil {
		return diag.FromErr(fmt.Errorf("[ERROR] Error setting created_at: %s", err))
	}
	if err = d.Set("href", vpnServerRoute.Href); err != nil {
		return diag.FromErr(fmt.Errorf("[ERROR] Error setting href: %s", err))
	}
	if err = d.Set("lifecycle_state", vpnServerRoute.LifecycleState); err != nil {
		return diag.FromErr(fmt.Errorf("[ERROR] Error setting lifecycle_state: %s", err))
	}
	if err = d.Set("resource_type", vpnServerRoute.ResourceType); err != nil {
		return diag.FromErr(fmt.Errorf("[ERROR] Error setting resource_type: %s", err))
	}

	return nil
}

func resourceIBMIsVPNServerRouteUpdate(context context.Context, d *schema.ResourceData, meta interface{}) diag.Diagnostics {
	sess, err := vpcClient(meta)
	if err != nil {
		return diag.FromErr(err)
	}

	updateVPNServerRouteOptions := &vpcv1.UpdateVPNServerRouteOptions{}

	parts, err := flex.SepIdParts(d.Id(), "/")
	if err != nil {
		return diag.FromErr(err)
	}

	updateVPNServerRouteOptions.SetVPNServerID(parts[0])
	updateVPNServerRouteOptions.SetID(parts[1])

	hasChange := false

	patchVals := &vpcv1.VPNServerRoutePatch{}

	if d.HasChange("name") {
		patchVals.Name = core.StringPtr(d.Get("name").(string))
		hasChange = true
	}

	if hasChange {
		updateVPNServerRouteOptions.VPNServerRoutePatch, _ = patchVals.AsPatch()
		_, response, err := sess.UpdateVPNServerRouteWithContext(context, updateVPNServerRouteOptions)
		if err != nil {
			log.Printf("[DEBUG] UpdateVPNServerRouteWithContext failed %s\n%s", err, response)
			return diag.FromErr(fmt.Errorf("[ERROR] UpdateVPNServerRouteWithContext failed %s\n%s", err, response))
		}
		_, err = isWaitForVPNServerRouteStable(context, sess, d, d.Timeout(schema.TimeoutUpdate))
		if err != nil {
			return diag.FromErr(fmt.Errorf("[ERROR] VPNServer Route failed %s\n", err))
		}
	}

	return resourceIBMIsVPNServerRouteRead(context, d, meta)
}

func resourceIBMIsVPNServerRouteDelete(context context.Context, d *schema.ResourceData, meta interface{}) diag.Diagnostics {
	sess, err := vpcClient(meta)
	if err != nil {
		return diag.FromErr(err)
	}

	deleteVPNServerRouteOptions := &vpcv1.DeleteVPNServerRouteOptions{}

	parts, err := flex.SepIdParts(d.Id(), "/")
	if err != nil {
		return diag.FromErr(err)
	}

	deleteVPNServerRouteOptions.SetVPNServerID(parts[0])
	deleteVPNServerRouteOptions.SetID(parts[1])

	response, err := sess.DeleteVPNServerRouteWithContext(context, deleteVPNServerRouteOptions)
	if err != nil {
		log.Printf("[DEBUG] DeleteVPNServerRouteWithContext failed %s\n%s", err, response)
		return diag.FromErr(fmt.Errorf("[ERROR] DeleteVPNServerRouteWithContext failed %s\n%s", err, response))
	}
	_, err = isWaitForVPNServerRouteDeleted(context, sess, d)
	if err != nil {
		return diag.FromErr(fmt.Errorf("[ERROR] VPNServer Route failed %s\n", err))
	}
	d.SetId("")

	return nil
}

func isWaitForVPNServerRouteDeleted(context context.Context, sess *vpcv1.VpcV1, d *schema.ResourceData) (interface{}, error) {

	log.Printf("Waiting for VPN Server  Route(%s) to be deleted.", d.Id())
	stateConf := &resource.StateChangeConf{
		Pending: []string{"retry", isVPNServerRouteStatusDeleting},
		Target:  []string{isVPNServerStatusDeleted, isVPNServerRouteStatusFailed},
		Refresh: func() (interface{}, string, error) {
			getVPNServerRouteOptions := &vpcv1.GetVPNServerRouteOptions{}

			parts, err := flex.SepIdParts(d.Id(), "/")
			if err != nil {
				log.Printf("[DEBUG] Getting ID failed %s", err)
				return nil, "", fmt.Errorf("Error Getting VPC Server: %s", err)
			}

			getVPNServerRouteOptions.SetVPNServerID(parts[0])
			getVPNServerRouteOptions.SetID(parts[1])

			vpnServerRoute, response, err := sess.GetVPNServerRouteWithContext(context, getVPNServerRouteOptions)
			if err != nil {
				if response != nil && response.StatusCode == 404 {
					return vpnServerRoute, isVPNServerRouteStatusDeleted, nil
				}
				return vpnServerRoute, isVPNServerRouteStatusDeleting, fmt.Errorf("The VPC route %s failed to delete: %s\n%s", d.Id(), err, response)
			}
			return vpnServerRoute, isVPNServerRouteStatusDeleting, nil

		},
		Timeout:    d.Timeout(schema.TimeoutDelete),
		Delay:      10 * time.Second,
		MinTimeout: 10 * time.Second,
	}

	return stateConf.WaitForState()
}