resource_alicloud_havip.go

package alicloud

import (
	"fmt"
	"time"

	"github.com/aliyun/alibaba-cloud-sdk-go/services/vpc"
	"github.com/hashicorp/terraform/helper/resource"
	"github.com/hashicorp/terraform/helper/schema"
	"github.com/terraform-providers/terraform-provider-alicloud/alicloud/connectivity"
)

func resourceAliyunHaVip() *schema.Resource {
	return &schema.Resource{
		Create: resourceAliyunHaVipCreate,
		Read:   resourceAliyunHaVipRead,
		Update: resourceAliyunHaVipUpdate,
		Delete: resourceAliyunHaVipDelete,
		Importer: &schema.ResourceImporter{
			State: schema.ImportStatePassthrough,
		},

		Schema: map[string]*schema.Schema{
			"description": &schema.Schema{
				Type:         schema.TypeString,
				Optional:     true,
				ValidateFunc: validateInstanceDescription,
			},
			"ip_address": &schema.Schema{
				Type:     schema.TypeString,
				ForceNew: true,
				Optional: true,
				Computed: true,
			},

			"vswitch_id": &schema.Schema{
				Type:     schema.TypeString,
				Required: true,
				ForceNew: true,
			},
		},
	}
}

func resourceAliyunHaVipCreate(d *schema.ResourceData, meta interface{}) error {
	client := meta.(*connectivity.AliyunClient)
	haVipService := HaVipService{client}

	request := vpc.CreateCreateHaVipRequest()
	request.RegionId = client.RegionId

	request.VSwitchId = d.Get("vswitch_id").(string)
	request.IpAddress = d.Get("ip_address").(string)
	request.Description = d.Get("description").(string)
	request.ClientToken = buildClientToken("TF-AllocateHaVip")

	raw, err := client.WithVpcClient(func(vpcClient *vpc.Client) (interface{}, error) {
		return vpcClient.CreateHaVip(request)
	})
	if err != nil {
		return err
	}
	havip, _ := raw.(*vpc.CreateHaVipResponse)
	d.SetId(havip.HaVipId)
	if err := haVipService.WaitForHaVip(havip.HaVipId, Available, 2*DefaultTimeout); err != nil {
		return fmt.Errorf("WaitHaVip %s got error: %#v, %s", Available, err, havip.HaVipId)
	}
	return resourceAliyunHaVipRead(d, meta)
}

func resourceAliyunHaVipRead(d *schema.ResourceData, meta interface{}) error {
	client := meta.(*connectivity.AliyunClient)
	haVipService := HaVipService{client}

	resp, err := haVipService.DescribeHaVip(d.Id())
	if err != nil {
		if NotFoundError(err) {
			d.SetId("")
			return nil
		}
		return fmt.Errorf("Error Describe HaVip Attribute: %#v", err)
	}

	d.Set("vswitch_id", resp.VSwitchId)
	d.Set("ip_address", resp.IpAddress)
	d.Set("description", resp.Description)

	return nil
}

func resourceAliyunHaVipUpdate(d *schema.ResourceData, meta interface{}) error {
	client := meta.(*connectivity.AliyunClient)
	if d.HasChange("description") {
		request := vpc.CreateModifyHaVipAttributeRequest()
		request.HaVipId = d.Id()
		request.Description = d.Get("description").(string)
		_, err := client.WithVpcClient(func(vpcClient *vpc.Client) (interface{}, error) {
			return vpcClient.ModifyHaVipAttribute(request)
		})
		if err != nil {
			return err
		}
	}

	return resourceAliyunHaVipRead(d, meta)
}

func resourceAliyunHaVipDelete(d *schema.ResourceData, meta interface{}) error {
	client := meta.(*connectivity.AliyunClient)
	haVipService := HaVipService{client}

	if err := haVipService.WaitForHaVip(d.Id(), Available, 2*DefaultTimeout); err != nil {
		return fmt.Errorf("WaitHaVip %s got error: %#v, %s", Available, err, d.Id())
	}
	request := vpc.CreateDeleteHaVipRequest()
	request.HaVipId = d.Id()

	return resource.Retry(5*time.Minute, func() *resource.RetryError {
		_, err := client.WithVpcClient(func(vpcClient *vpc.Client) (interface{}, error) {
			return vpcClient.DeleteHaVip(request)
		})
		if err != nil {
			if IsExceptedError(err, InvalidHaVipIdNotFound) {
				return nil
			}
			return resource.NonRetryableError(err)
		}
		if _, err := haVipService.DescribeHaVip(d.Id()); err != nil {
			if NotFoundError(err) {
				return nil
			}
			return resource.RetryableError(fmt.Errorf("Error describing havip failed when deleting HaVip: %#v", err))
		}
		return nil
	})
}