resource_alicloud_fc_service.go

package alicloud

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

	"github.com/hashicorp/terraform-plugin-sdk/helper/validation"

	sls "github.com/aliyun/aliyun-log-go-sdk"
	"github.com/aliyun/fc-go-sdk"
	"github.com/aliyun/terraform-provider-alicloud/alicloud/connectivity"

	"github.com/hashicorp/terraform-plugin-sdk/helper/resource"
	"github.com/hashicorp/terraform-plugin-sdk/helper/schema"
)

func resourceAlicloudFCService() *schema.Resource {
	return &schema.Resource{
		Create: resourceAlicloudFCServiceCreate,
		Read:   resourceAlicloudFCServiceRead,
		Update: resourceAlicloudFCServiceUpdate,
		Delete: resourceAlicloudFCServiceDelete,
		Importer: &schema.ResourceImporter{
			State: schema.ImportStatePassthrough,
		},

		Schema: map[string]*schema.Schema{
			"name": {
				Type:          schema.TypeString,
				Optional:      true,
				Computed:      true,
				ForceNew:      true,
				ConflictsWith: []string{"name_prefix"},
				ValidateFunc:  validation.StringLenBetween(1, 128),
			},
			"name_prefix": {
				Type:         schema.TypeString,
				Optional:     true,
				ForceNew:     true,
				ValidateFunc: validation.StringLenBetween(0, 122),
			},

			"description": {
				Type:     schema.TypeString,
				Optional: true,
			},

			"tags": tagsSchemaWithIgnore(),
			"internet_access": {
				Type:     schema.TypeBool,
				Optional: true,
				Default:  true,
			},
			"role": {
				Type:     schema.TypeString,
				Optional: true,
			},
			"log_config": {
				Type:     schema.TypeList,
				Optional: true,
				MaxItems: 1,
				Elem: &schema.Resource{
					Schema: map[string]*schema.Schema{
						"project": {
							Type:     schema.TypeString,
							Required: true,
						},
						"logstore": {
							Type:     schema.TypeString,
							Required: true,
						},
						"enable_request_metrics": {
							Type:     schema.TypeBool,
							Optional: true,
						},
						"enable_instance_metrics": {
							Type:     schema.TypeBool,
							Optional: true,
						},
					},
				},
			},
			"vpc_config": {
				Type:     schema.TypeList,
				Optional: true,
				MaxItems: 1,
				Elem: &schema.Resource{
					Schema: map[string]*schema.Schema{
						"vswitch_ids": {
							Type:     schema.TypeSet,
							Required: true,
							Elem:     &schema.Schema{Type: schema.TypeString},
							Set:      schema.HashString,
						},
						"security_group_id": {
							Type:     schema.TypeString,
							Required: true,
						},
						"vpc_id": {
							Type:     schema.TypeString,
							Computed: true,
						},
					},
				},
			},
			"nas_config": {
				Type:     schema.TypeList,
				Optional: true,
				MaxItems: 1,
				Elem: &schema.Resource{
					Schema: map[string]*schema.Schema{
						"user_id": {
							Type:     schema.TypeInt,
							Required: true,
						},
						"group_id": {
							Type:     schema.TypeInt,
							Required: true,
						},
						"mount_points": {
							Type:     schema.TypeList,
							Required: true,
							Elem: &schema.Resource{
								Schema: map[string]*schema.Schema{
									"server_addr": {
										Type:     schema.TypeString,
										Required: true,
									},
									"mount_dir": {
										Type:     schema.TypeString,
										Required: true,
									},
								},
							},
						},
					},
				},
			},
			"tracing_config": {
				Type:     schema.TypeList,
				Optional: true,
				MaxItems: 1,
				Elem: &schema.Resource{
					Schema: map[string]*schema.Schema{
						"type": {
							Type:     schema.TypeString,
							Required: true,
						},
						"params": {
							Type:     schema.TypeMap,
							Required: true,
						},
					},
				},
			},
			"publish": {
				Type:     schema.TypeBool,
				Optional: true,
				Default:  false,
			},
			"version": {
				Type:     schema.TypeString,
				Computed: true,
			},
			"last_modified": {
				Type:     schema.TypeString,
				Computed: true,
			},
			"service_id": {
				Type:     schema.TypeString,
				Computed: true,
			},
		},
	}
}

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

	var name string
	if v, ok := d.GetOk("name"); ok {
		name = v.(string)
	} else if v, ok := d.GetOk("name_prefix"); ok {
		name = resource.PrefixedUniqueId(v.(string))
	} else {
		name = resource.UniqueId()
	}

	project, logstore, enable_request_metrics, enable_instance_metrics, err := parseLogConfig(d, meta)
	if err != nil {
		return WrapError(err)
	}
	request := &fc.CreateServiceInput{
		ServiceName:    StringPointer(name),
		Description:    StringPointer(d.Get("description").(string)),
		InternetAccess: BoolPointer(d.Get("internet_access").(bool)),
		Role:           StringPointer(d.Get("role").(string)),
		LogConfig: &fc.LogConfig{
			Project:               StringPointer(project),
			Logstore:              StringPointer(logstore),
			EnableRequestMetrics:  BoolPointer(enable_request_metrics),
			EnableInstanceMetrics: BoolPointer(enable_instance_metrics),
		},
	}
	vpcConfig, err := parseVpcConfig(d, meta)
	if err != nil {
		return WrapError(err)
	}
	request.VPCConfig = vpcConfig
	nasConfig, err := parseNasConfig(d)
	if err != nil {
		return WrapError(err)
	}
	request.NASConfig = nasConfig
	tracingConfig, err := parseTracingConfig(d)
	if err != nil {
		return WrapError(err)
	}
	request.TracingConfig = tracingConfig
	var requestInfo *fc.Client
	var response *fc.CreateServiceOutput
	if err := resource.Retry(2*time.Minute, func() *resource.RetryError {
		raw, err := client.WithFcClient(func(fcClient *fc.Client) (interface{}, error) {
			requestInfo = fcClient
			return fcClient.CreateService(request)
		})
		if err != nil {
			if IsExpectedErrors(err, []string{"AccessDenied", "does not exist"}) {
				return resource.RetryableError(err)
			}
			// Work around the "log project doest not exist" error since SLS log project CRUD is not strong consistency.
			if e, ok := err.(*fc.ServiceError); ok {
				if r := regexp.MustCompile("project.*does not exist"); e.ErrorCode == "InvalidArgument" && r.MatchString(e.ErrorMessage) {
					return resource.RetryableError(err)
				}
			}
			return resource.NonRetryableError(err)
		}
		addDebug("CreateService", raw, requestInfo, request)
		response, _ = raw.(*fc.CreateServiceOutput)
		return nil

	}); err != nil {
		return WrapErrorf(err, DefaultErrorMsg, "alicloud_fc_service", "CreateService", FcGoSdk)
	}

	d.SetId(*response.ServiceName)

	etag := response.Header.Get("ETag")
	if d.Get("publish").(bool) {
		input := &fc.PublishServiceVersionInput{
			ServiceName: response.ServiceName,
			IfMatch:     &etag,
		}
		input.Description = response.Description
		if err := resource.Retry(2*time.Minute, func() *resource.RetryError {
			raw, err := client.WithFcClient(func(fcClient *fc.Client) (interface{}, error) {
				requestInfo = fcClient
				return fcClient.PublishServiceVersion(input)
			})
			if err != nil {
				if IsExpectedErrors(err, []string{"AccessDenied", "ServiceNotFound"}) {
					return resource.RetryableError(err)
				}
				return resource.NonRetryableError(err)
			}
			addDebug("PublishServiceVersion", raw, requestInfo, request)
			return nil

		}); err != nil {
			return WrapErrorf(err, DefaultErrorMsg, "alicloud_fc_service", "PublishServiceVersion", FcGoSdk)
		}
	}
	if _, ok := d.GetOk("tags"); ok {
		resourceArn, err := parseResourceArn(d, meta)
		if err != nil {
			return WrapError(err)
		}
		fcService := FcService{client}

		err = fcService.SetResourceTags(d, &resourceArn)
		if err != nil {
			return WrapError(err)
		}
	}
	return resourceAlicloudFCServiceRead(d, meta)
}

func resourceAlicloudFCServiceRead(d *schema.ResourceData, meta interface{}) error {
	client := meta.(*connectivity.AliyunClient)
	fcService := FcService{client}

	object, err := fcService.DescribeFcService(d.Id())
	if err != nil {
		if NotFoundError(err) {
			d.SetId("")
			return nil
		}
		return WrapError(err)
	}

	d.Set("name", object.ServiceName)
	d.Set("service_id", object.ServiceID)
	d.Set("description", object.Description)
	d.Set("internet_access", object.InternetAccess)
	d.Set("role", object.Role)
	if tags := object.Tags; tags != nil {
		d.Set("tags", tagsToMap(tags))
	}
	var logConfigs []map[string]interface{}
	if logconfig := object.LogConfig; logconfig != nil && *logconfig.Project != "" {
		logConfigs = append(logConfigs, map[string]interface{}{
			"project":                 *logconfig.Project,
			"logstore":                *logconfig.Logstore,
			"enable_request_metrics":  *logconfig.EnableRequestMetrics,
			"enable_instance_metrics": *logconfig.EnableInstanceMetrics,
		})
	}
	if err := d.Set("log_config", logConfigs); err != nil {
		return WrapError(err)
	}
	var vpcConfigs []map[string]interface{}
	if vpcConfig := object.VPCConfig; vpcConfig != nil && *vpcConfig.VPCID != "" {
		vpcConfigs = append(vpcConfigs, map[string]interface{}{
			"vswitch_ids":       schema.NewSet(schema.HashString, convertListStringToListInterface(vpcConfig.VSwitchIDs)),
			"security_group_id": *vpcConfig.SecurityGroupID,
			"vpc_id":            *vpcConfig.VPCID,
		})
	}
	if err := d.Set("vpc_config", vpcConfigs); err != nil {
		return WrapError(err)
	}
	var nasConfigs []map[string]interface{}
	if cfg := object.NASConfig; cfg != nil && len(cfg.MountPoints) != 0 {
		dstCfg := make(map[string]interface{})
		dstCfg["user_id"] = cfg.UserID
		dstCfg["group_id"] = cfg.GroupID
		var mps []map[string]interface{}
		for _, v := range cfg.MountPoints {
			mps = append(mps, map[string]interface{}{
				"server_addr": v.ServerAddr,
				"mount_dir":   v.MountDir,
			})
		}
		dstCfg["mount_points"] = mps

		nasConfigs = append(nasConfigs, dstCfg)
	}
	if err := d.Set("nas_config", nasConfigs); err != nil {
		return WrapError(err)
	}

	var tracingConfigs []map[string]interface{}
	if tracingConfig := object.TracingConfig; tracingConfig != nil && tracingConfig.Type != nil {
		tracingConfigs = append(tracingConfigs, map[string]interface{}{
			"type":   tracingConfig.Type,
			"params": tracingConfig.Params,
		})
	}
	if err := d.Set("tracing_config", tracingConfigs); err != nil {
		return WrapError(err)
	}

	d.Set("last_modified", object.LastModifiedTime)

	// Get the latest version of the service.
	input := &fc.ListServiceVersionsInput{
		ServiceName: object.ServiceName,
		Limit:       Int32Pointer(1),
		Direction:   StringPointer("BACKWARD"),
	}
	if err := resource.Retry(2*time.Minute, func() *resource.RetryError {
		var requestInfo *fc.Client
		raw, err := client.WithFcClient(func(fcClient *fc.Client) (interface{}, error) {
			requestInfo = fcClient
			return fcClient.ListServiceVersions(input)
		})
		if err != nil {
			if IsExpectedErrors(err, []string{"AccessDenied", "ServiceNotFound"}) {
				return resource.RetryableError(err)
			}
			return resource.NonRetryableError(err)
		}
		addDebug("ListServiceVersions", raw, requestInfo, input)
		output, _ := raw.(*fc.ListServiceVersionsOutput)
		if len(output.Versions) > 0 {
			d.Set("version", output.Versions[0].VersionID)
		}
		return nil
	}); err != nil {
		return WrapErrorf(err, DefaultErrorMsg, "alicloud_fc_service", "PublishServiceVersion", FcGoSdk)
	}

	return nil
}

func resourceAlicloudFCServiceUpdate(d *schema.ResourceData, meta interface{}) error {
	client := meta.(*connectivity.AliyunClient)
	d.Partial(true)

	if d.HasChange("tags") {
		fcService := FcService{client}
		resourceArn, err := parseResourceArn(d, meta)
		if err != nil {
			return WrapError(err)
		}

		err = fcService.SetResourceTags(d, &resourceArn)
		if err != nil {
			return WrapError(err)
		}
	}

	request := &fc.UpdateServiceInput{}

	if d.HasChange("role") {
		request.Role = StringPointer(d.Get("role").(string))
		d.SetPartial("role")
	}
	if d.HasChange("internet_access") {
		request.InternetAccess = BoolPointer(d.Get("internet_access").(bool))
		d.SetPartial("internet_access")
	}
	if d.HasChange("description") {
		request.Description = StringPointer(d.Get("description").(string))
		d.SetPartial("description")
	}
	if d.HasChange("log_config") {
		project, logstore, enable_request_metrics, enable_instance_metrics, err := parseLogConfig(d, meta)
		if err != nil {
			return WrapError(err)
		}
		request.LogConfig = &fc.LogConfig{
			Project:               StringPointer(project),
			Logstore:              StringPointer(logstore),
			EnableRequestMetrics:  BoolPointer(enable_request_metrics),
			EnableInstanceMetrics: BoolPointer(enable_instance_metrics),
		}
		d.SetPartial("log_config")
	}

	if d.HasChange("vpc_config") {
		vpcConfig, err := parseVpcConfig(d, meta)
		if err != nil {
			return WrapError(err)
		}
		request.VPCConfig = vpcConfig
		d.SetPartial("vpc_config")
	}

	if d.HasChange("nas_config") {
		nasConfig, err := parseNasConfig(d)
		if err != nil {
			return WrapError(err)
		}
		request.NASConfig = nasConfig
		d.SetPartial("nas_config")
	}

	if d.HasChange("tracing_config") {
		tracingConfig, err := parseTracingConfig(d)
		if err != nil {
			return WrapError(err)
		}
		request.TracingConfig = tracingConfig
		d.SetPartial("tracing_config")
	}

	if request != nil {
		request.ServiceName = StringPointer(d.Id())
		var requestInfo *fc.Client
		var response *fc.UpdateServiceOutput
		if err := resource.Retry(2*time.Minute, func() *resource.RetryError {
			raw, err := client.WithFcClient(func(fcClient *fc.Client) (interface{}, error) {
				requestInfo = fcClient
				return fcClient.UpdateService(request)
			})
			if err != nil {
				// Work around the "log project doest not exist" error since SLS log project CRUD is not strong consistency.
				if e, ok := err.(*fc.ServiceError); ok {
					if r := regexp.MustCompile("project.*does not exist"); e.ErrorCode == "InvalidArgument" && r.MatchString(e.ErrorMessage) {
						return resource.RetryableError(err)
					}
				}
				return resource.NonRetryableError(err)
			}
			addDebug("UpdateService", raw, requestInfo, request)
			response, _ = raw.(*fc.UpdateServiceOutput)
			return nil
		}); err != nil {
			return WrapErrorf(err, DefaultErrorMsg, "alicloud_fc_service", "UpdateService", FcGoSdk)
		}

		etag := response.Header.Get("ETag")
		if d.Get("publish").(bool) {
			input := &fc.PublishServiceVersionInput{
				ServiceName: response.ServiceName,
				IfMatch:     &etag,
			}
			input.Description = response.Description
			if err := resource.Retry(2*time.Minute, func() *resource.RetryError {
				raw, err := client.WithFcClient(func(fcClient *fc.Client) (interface{}, error) {
					requestInfo = fcClient
					return fcClient.PublishServiceVersion(input)
				})
				if err != nil {
					if IsExpectedErrors(err, []string{"AccessDenied", "ServiceNotFound"}) {
						return resource.RetryableError(err)
					}
					return resource.NonRetryableError(err)
				}
				addDebug("PublishServiceVersion", raw, requestInfo, request)
				return nil

			}); err != nil {
				return WrapErrorf(err, DefaultErrorMsg, "alicloud_fc_service", "PublishServiceVersion", FcGoSdk)
			}
		}
	}

	d.Partial(false)
	return resourceAlicloudFCServiceRead(d, meta)
}

func resourceAlicloudFCServiceDelete(d *schema.ResourceData, meta interface{}) error {
	client := meta.(*connectivity.AliyunClient)
	fcService := FcService{client}

	// Delete the service versions.
	var nextToken *string
	for {
		input := &fc.ListServiceVersionsInput{
			ServiceName: StringPointer(d.Id()),
			Limit:       Int32Pointer(100),
			NextToken:   nextToken,
		}
		raw, err := client.WithFcClient(func(fcClient *fc.Client) (interface{}, error) {
			return fcClient.ListServiceVersions(input)
		})
		if err != nil {
			return WrapErrorf(err, DefaultErrorMsg, d.Id(), "ListServiceVersions", FcGoSdk)
		}

		output := raw.(*fc.ListServiceVersionsOutput)
		nextToken = output.NextToken
		for _, v := range output.Versions {
			// Delete the service version.
			input := &fc.DeleteServiceVersionInput{
				ServiceName: StringPointer(d.Id()),
				VersionID:   v.VersionID,
			}
			_, err := client.WithFcClient(func(fcClient *fc.Client) (interface{}, error) {
				return fcClient.DeleteServiceVersion(input)
			})
			if err != nil {
				return WrapErrorf(err, DefaultErrorMsg, d.Id(), v.VersionID, "DeleteServiceVersion", FcGoSdk)
			}
		}

		if nextToken == nil || *nextToken == "" {
			break
		}
	}

	// Delete the service.
	request := &fc.DeleteServiceInput{
		ServiceName: StringPointer(d.Id()),
	}
	var requestInfo *fc.Client
	raw, err := client.WithFcClient(func(fcClient *fc.Client) (interface{}, error) {
		requestInfo = fcClient
		return fcClient.DeleteService(request)
	})
	if err != nil {
		if IsExpectedErrors(err, []string{"ServiceNotFound"}) {
			return nil
		}
		return WrapErrorf(err, DefaultErrorMsg, d.Id(), "DeleteService", FcGoSdk)
	}
	addDebug("DeleteService", raw, requestInfo, request)
	return WrapError(fcService.WaitForFcService(d.Id(), Deleted, DefaultTimeout))
}

func parseVpcConfig(d *schema.ResourceData, meta interface{}) (config *fc.VPCConfig, err error) {
	client := meta.(*connectivity.AliyunClient)
	vpcService := VpcService{client}
	if v, ok := d.GetOk("vpc_config"); ok {

		confs := v.([]interface{})
		conf, ok := confs[0].(map[string]interface{})

		if !ok {
			return
		}
		if role, ok := d.GetOk("role"); !ok || role.(string) == "" {
			err = WrapError(Error("'role' is required when 'vpc_config' is set."))
			return
		}
		if conf != nil {
			vswitchIds := conf["vswitch_ids"].(*schema.Set).List()
			vsw, e := vpcService.DescribeVSwitch(vswitchIds[0].(string))
			if e != nil {
				err = WrapError(e)
				return
			}
			config = &fc.VPCConfig{
				VSwitchIDs:      expandStringList(vswitchIds),
				SecurityGroupID: StringPointer(conf["security_group_id"].(string)),
				VPCID:           StringPointer(vsw.VpcId),
			}
		}
	}
	return
}

func parseLogConfig(d *schema.ResourceData, meta interface{}) (project, logstore string, enable_request_metrics, enable_instance_metrics bool, err error) {
	client := meta.(*connectivity.AliyunClient)
	if v, ok := d.GetOk("log_config"); ok {

		configs := v.([]interface{})
		config, ok := configs[0].(map[string]interface{})

		if !ok {
			return
		}

		if config != nil {
			project = config["project"].(string)
			logstore = config["logstore"].(string)
			enable_request_metrics = config["enable_request_metrics"].(bool)
			enable_instance_metrics = config["enable_instance_metrics"].(bool)
		}
	}
	if project != "" {
		var requestInfo *sls.Client
		err = resource.Retry(2*time.Minute, func() *resource.RetryError {
			raw, e := client.WithLogClient(func(slsClient *sls.Client) (interface{}, error) {
				requestInfo = slsClient
				return slsClient.CheckProjectExist(project)
			})
			if e != nil {
				if NotFoundError(e) {
					return resource.RetryableError(e)
				}
				return resource.NonRetryableError(e)
			}
			addDebug("CheckProjectExist", raw, requestInfo, project)
			return nil
		})
	}

	if err != nil {
		err = WrapErrorf(err, DefaultErrorMsg, d.Id(), "CheckProjectExist", FcGoSdk)
		return
	}

	if logstore != "" {
		err = resource.Retry(2*time.Minute, func() *resource.RetryError {
			raw, e := client.WithLogClient(func(slsClient *sls.Client) (interface{}, error) {
				return slsClient.CheckLogstoreExist(project, logstore)
			})
			if e != nil {
				if NotFoundError(e) {
					return resource.RetryableError(e)
				}
				return resource.NonRetryableError(e)
			}
			addDebug("CheckLogstoreExist", raw)
			return nil
		})
	}
	return
}

func parseNasConfig(d *schema.ResourceData) (config *fc.NASConfig, err error) {
	if v, ok := d.GetOk("nas_config"); ok {
		config = fc.NewNASConfig()
		c, ok := v.([]interface{})[0].(map[string]interface{})
		if !ok {
			return nil, Error("Failed to parse nas config.")
		}
		config.UserID = Int32Pointer(int32(c["user_id"].(int)))
		config.GroupID = Int32Pointer(int32(c["group_id"].(int)))
		if mps, ok := c["mount_points"].([]interface{}); ok {
			for _, mp := range mps {
				m := mp.(map[string]interface{})
				config.MountPoints = append(config.MountPoints, fc.NASMountConfig{
					ServerAddr: m["server_addr"].(string),
					MountDir:   m["mount_dir"].(string),
				})
			}
		} else {
			return nil, Error("Failed to parse mount points.")
		}
	}
	return
}

func parseTracingConfig(d *schema.ResourceData) (tracingConfig *fc.TracingConfig, err error) {
	tracingConfig = fc.NewTracingConfig()
	if v, ok := d.GetOk("tracing_config"); ok {
		c, ok := v.([]interface{})[0].(map[string]interface{})
		if !ok {
			return nil, Error("Failed to parse tracing config.")
		}
		tracingConfig.Type = StringPointer(c["type"].(string))
		if params := c["params"].(map[string]interface{}); len(params) > 0 {
			byteVar, err := json.Marshal(params)
			if err != nil {
				return nil, WrapError(err)
			}
			err = json.Unmarshal(byteVar, &tracingConfig.Params)
			if err != nil {
				return nil, WrapError(err)
			}
		} else {
			return nil, Error("Failed to parse tracing config, params must be set.")
		}
	}
	return tracingConfig, nil
}

func parseResourceArn(d *schema.ResourceData, meta interface{}) (string, error) {
	client := meta.(*connectivity.AliyunClient)

	serviceName := d.Id()
	region := client.RegionId
	accountId, err := client.AccountId()
	if err != nil {
		return "", err
	}

	return fmt.Sprintf("acs:fc:%s:%s:services/%s", region, accountId, serviceName), nil
}