resource_alicloud_cms_alarm.go

package alicloud

import (
	"encoding/json"
	"fmt"
	"strings"
	"time"

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

func resourceAlicloudCmsAlarm() *schema.Resource {
	return &schema.Resource{
		Create: resourceAlicloudCmsAlarmCreate,
		Read:   resourceAlicloudCmsAlarmRead,
		Update: resourceAlicloudCmsAlarmUpdate,
		Delete: resourceAlicloudCmsAlarmDelete,
		Importer: &schema.ResourceImporter{
			State: schema.ImportStatePassthrough,
		},

		Schema: map[string]*schema.Schema{
			"name": {
				Type:     schema.TypeString,
				Required: true,
			},
			"project": {
				Type:     schema.TypeString,
				Required: true,
				ForceNew: true,
			},
			"metric": {
				Type:     schema.TypeString,
				Required: true,
				ForceNew: true,
			},
			"dimensions": {
				Type:     schema.TypeMap,
				Required: true,
				ForceNew: true,
				Elem:     schema.TypeString,
			},
			"period": {
				Type:     schema.TypeInt,
				Optional: true,
				Default:  300,
			},
			"statistics": {
				Type:     schema.TypeString,
				Optional: true,
				Default:  Average,
				ValidateFunc: validateAllowedStringValue([]string{
					string(Average), string(Minimum), string(Maximum),
				}),
			},
			"operator": {
				Type:     schema.TypeString,
				Optional: true,
				Default:  Equal,
				ValidateFunc: validateAllowedStringValue([]string{
					MoreThan, MoreThanOrEqual, LessThan, LessThanOrEqual, Equal, NotEqual,
				}),
			},
			"threshold": {
				Type:     schema.TypeString,
				Required: true,
			},
			"triggered_count": {
				Type:     schema.TypeInt,
				Optional: true,
				Default:  3,
			},
			"contact_groups": {
				Type:     schema.TypeList,
				Required: true,
				Elem:     &schema.Schema{Type: schema.TypeString},
			},
			"start_time": {
				Type:         schema.TypeInt,
				Optional:     true,
				Default:      0,
				ValidateFunc: validateIntegerInRange(0, 24),
			},
			"end_time": {
				Type:         schema.TypeInt,
				Optional:     true,
				Default:      24,
				ValidateFunc: validateIntegerInRange(0, 24),
			},
			"silence_time": {
				Type:         schema.TypeInt,
				Optional:     true,
				Default:      86400,
				ValidateFunc: validateIntegerInRange(300, 86400),
			},

			"notify_type": {
				Type:         schema.TypeInt,
				Optional:     true,
				ValidateFunc: validateAllowedIntValue([]int{0, 1}),
			},

			"enabled": {
				Type:     schema.TypeBool,
				Optional: true,
				Default:  true,
			},

			"status": {
				Type:     schema.TypeString,
				Computed: true,
			},
			"webhook": {
				Type:     schema.TypeString,
				Optional: true,
			},
		},
	}
}

func resourceAlicloudCmsAlarmCreate(d *schema.ResourceData, meta interface{}) error {
	client := meta.(*connectivity.AliyunClient)
	cmsService := CmsService{client}

	request := cms.CreateCreateAlarmRequest()

	request.Name = d.Get("name").(string)
	request.Namespace = d.Get("project").(string)
	request.MetricName = d.Get("metric").(string)
	request.Period = requests.NewInteger(d.Get("period").(int))
	request.Statistics = d.Get("statistics").(string)
	request.ComparisonOperator = d.Get("operator").(string)
	request.Threshold = d.Get("threshold").(string)
	request.EvaluationCount = requests.NewInteger(d.Get("triggered_count").(int))
	request.ContactGroups = convertListToJsonString(d.Get("contact_groups").([]interface{}))
	request.StartTime = requests.NewInteger(d.Get("start_time").(int))
	request.EndTime = requests.NewInteger(d.Get("end_time").(int))
	request.SilenceTime = requests.NewInteger(d.Get("silence_time").(int))
	request.NotifyType = requests.NewInteger(d.Get("notify_type").(int))

	if webhook, ok := d.GetOk("webhook"); ok && webhook.(string) != "" {
		request.Webhook = cmsService.BuildJsonWebhook(webhook.(string))
	}

	var dimList []map[string]string
	if dimensions, ok := d.GetOk("dimensions"); ok {
		for k, v := range dimensions.(map[string]interface{}) {
			values := strings.Split(v.(string), COMMA_SEPARATED)
			if len(values) > 0 {
				for _, vv := range values {
					dimList = append(dimList, map[string]string{k: Trim(vv)})
				}
			} else {
				dimList = append(dimList, map[string]string{k: Trim(v.(string))})
			}

		}
	}
	if len(dimList) > 0 {
		if bytes, err := json.Marshal(dimList); err != nil {
			return fmt.Errorf("Marshaling dimensions to json string got an error: %#v.", err)
		} else {
			request.Dimensions = string(bytes[:])
		}
	}
	raw, err := client.WithCmsClient(func(cmsClient *cms.Client) (interface{}, error) {
		return cmsClient.CreateAlarm(request)
	})
	if err != nil {
		return fmt.Errorf("Creating alarm got an error: %#v", err)
	}
	response, _ := raw.(*cms.CreateAlarmResponse)
	d.SetId(response.Data)

	return resourceAlicloudCmsAlarmUpdate(d, meta)
}

func resourceAlicloudCmsAlarmRead(d *schema.ResourceData, meta interface{}) error {
	client := meta.(*connectivity.AliyunClient)
	cmsService := CmsService{client}

	alarm, err := cmsService.DescribeAlarm(d.Id())

	if err != nil {
		if NotFoundError(err) {
			d.SetId("")
			return nil
		}
		return err
	}

	d.Set("name", alarm.Name)
	d.Set("project", alarm.Namespace)
	d.Set("metric", alarm.MetricName)
	d.Set("period", alarm.Period)
	d.Set("statistics", alarm.Statistics)
	d.Set("operator", alarm.ComparisonOperator)
	d.Set("threshold", alarm.Threshold)
	d.Set("triggered_count", alarm.EvaluationCount)
	d.Set("start_time", alarm.StartTime)
	d.Set("end_time", alarm.EndTime)
	d.Set("silence_time", alarm.SilenceTime)
	d.Set("notify_type", alarm.NotifyType)
	d.Set("status", alarm.State)
	d.Set("enabled", alarm.Enable)

	if alarm.Webhook != "null" {
		webhook, err := cmsService.ExtractWebhookFromJson(alarm.Webhook)
		if err != nil {
			return fmt.Errorf("Extracting webhook from json got an error: %#v.", err)

		}
		d.Set("webhook", webhook)
	}

	var groups []string
	if err := json.Unmarshal([]byte(alarm.ContactGroups), &groups); err != nil {
		return fmt.Errorf("Unmarshaling contact groups got an error: %#v.", err)
	} else {
		d.Set("contact_groups", groups)
	}

	var dims []string
	if err := json.Unmarshal([]byte(alarm.Dimensions), &dims); err != nil {
		return fmt.Errorf("Unmarshaling Dimensions got an error: %#v.", err)
	}
	d.Set("dimensions", dims)

	return nil
}

func resourceAlicloudCmsAlarmUpdate(d *schema.ResourceData, meta interface{}) error {
	client := meta.(*connectivity.AliyunClient)
	cmsService := CmsService{client}

	d.Partial(true)

	if d.Get("enabled").(bool) {
		request := cms.CreateEnableAlarmRequest()
		request.Id = d.Id()

		_, err := client.WithCmsClient(func(cmsClient *cms.Client) (interface{}, error) {
			return cmsClient.EnableAlarm(request)
		})
		if err != nil {
			return fmt.Errorf("Enabling alarm got an error: %#v", err)
		}
	} else {
		request := cms.CreateDisableAlarmRequest()
		request.Id = d.Id()

		_, err := client.WithCmsClient(func(cmsClient *cms.Client) (interface{}, error) {
			return cmsClient.DisableAlarm(request)
		})
		if err != nil {
			return fmt.Errorf("Disableing alarm got an error: %#v", err)
		}
	}
	if err := cmsService.WaitForCmsAlarm(d.Id(), d.Get("enabled").(bool), 102); err != nil {
		return err
	}

	if d.IsNewResource() {
		d.Partial(false)
		return resourceAlicloudCmsAlarmRead(d, meta)
	}

	update := false
	request := cms.CreateUpdateAlarmRequest()
	request.Id = d.Id()
	request.ComparisonOperator = d.Get("operator").(string)
	request.Threshold = d.Get("threshold").(string)

	if d.HasChange("Name") {
		update = true
		request.Name = d.Get("name").(string)
	}
	if d.HasChange("period") {
		update = true
		request.Period = requests.NewInteger(d.Get("period").(int))
	}
	if d.HasChange("statistics") {
		update = true
		request.Statistics = d.Get("statistics").(string)
	}
	if d.HasChange("operator") {
		update = true
	}
	if d.HasChange("threshold") {
		update = true
	}
	if d.HasChange("triggered_count") {
		update = true
		request.EvaluationCount = requests.NewInteger(d.Get("triggered_count").(int))
	}
	if d.HasChange("contact_groups") {
		update = true
		request.ContactGroups = convertListToJsonString(d.Get("contact_groups").([]interface{}))
	}
	if d.HasChange("start_time") {
		update = true
		request.StartTime = requests.NewInteger(d.Get("start_time").(int))
	}
	if d.HasChange("end_time") {
		update = true
		request.EndTime = requests.NewInteger(d.Get("end_time").(int))
	}
	if d.HasChange("silence_time") {
		update = true
		request.SilenceTime = requests.NewInteger(d.Get("silence_time").(int))
	}
	if d.HasChange("notify_type") {
		update = true
		request.NotifyType = requests.NewInteger(d.Get("notify_type").(int))
	}
	if d.HasChange("webhook") {
		update = true
		request.Webhook = cmsService.BuildJsonWebhook(d.Get("webhook").(string))
	}

	if update {
		_, err := client.WithCmsClient(func(cmsClient *cms.Client) (interface{}, error) {
			return cmsClient.UpdateAlarm(request)
		})
		if err != nil {
			return fmt.Errorf("Updating alarm got an error: %#v", err)
		}

		d.SetPartial("name")
		d.SetPartial("period")
		d.SetPartial("statistics")
		d.SetPartial("operator")
		d.SetPartial("threshold")
		d.SetPartial("triggered_count")
		d.SetPartial("contact_groups")
		d.SetPartial("start_time")
		d.SetPartial("end_time")
		d.SetPartial("silence_time")
		d.SetPartial("notify_type")
		d.SetPartial("webhook")
	}

	d.Partial(false)

	return resourceAlicloudCmsAlarmRead(d, meta)
}

func resourceAlicloudCmsAlarmDelete(d *schema.ResourceData, meta interface{}) error {
	client := meta.(*connectivity.AliyunClient)
	cmsService := CmsService{client}
	request := cms.CreateDeleteAlarmRequest()

	request.Id = d.Id()

	return resource.Retry(3*time.Minute, func() *resource.RetryError {
		_, err := client.WithCmsClient(func(cmsClient *cms.Client) (interface{}, error) {
			return cmsClient.DeleteAlarm(request)
		})

		if err != nil {
			return resource.NonRetryableError(fmt.Errorf("Deleting alarm rule got an error: %#v", err))
		}

		resp, err := cmsService.DescribeAlarm(d.Id())
		if err != nil {
			if NotFoundError(err) {
				return nil
			}
			return resource.NonRetryableError(fmt.Errorf("Describe alarm rule got an error: %#v", err))
		}
		if resp.Id == "" {
			return nil
		}

		return resource.RetryableError(fmt.Errorf("Deleting alarm rule got an error: %#v", err))
	})
}