custom_functions.go

package flexibleengine

import (
	"fmt"
	"reflect"
	"strings"

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

func checkCssClusterV1ExtendClusterFinished(data interface{}) bool {
	//actions --- the behaviors on a cluster
	v, err := navigateValue(data, []string{"actions"}, nil)
	e, err := isEmptyValue(reflect.ValueOf(v))
	if err == nil && !e {
		return false
	}

	//actionProgress --- indicates the progress in percentage
	v, err = navigateValue(data, []string{"actionProgress"}, nil)
	e, err = isEmptyValue(reflect.ValueOf(v))
	if err == nil && !e {
		return false
	}

	instances, err := navigateValue(data, []string{"instances"}, nil)
	if err != nil {
		return false
	}
	if v, ok := instances.([]interface{}); ok {
		if len(v) == 0 {
			return false
		}
		for _, item := range v {
			status, err := navigateValue(item, []string{"status"}, nil)
			if err != nil {
				return false
			}
			if s, ok := status.(string); !ok || "200" != s {
				return false
			}
		}
		return true
	}
	return false
}

func expandCssClusterV1ExtendClusterNodeNum(d interface{}, arrayIndex map[string]int) (interface{}, error) {
	t, _ := navigateValue(d, []string{"terraform_resource_data"}, nil)
	rd := t.(*schema.ResourceData)

	oldv, newv := rd.GetChange("node_number")
	v := newv.(int) - oldv.(int)
	if v < 0 {
		return 0, fmt.Errorf("node_number only supports to be extended")
	}
	return v, nil
}

func expandCssClusterV1ExtendClusterVolumeSize(d interface{}, arrayIndex map[string]int) (interface{}, error) {
	t, _ := navigateValue(d, []string{"terraform_resource_data"}, nil)
	rd := t.(*schema.ResourceData)

	//volume size location: reference to the Schema of css_cluster_v1
	oldv, newv := rd.GetChange("node_config.0.volume.0.size")
	v := newv.(int) - oldv.(int)
	if v < 0 {
		return 0, fmt.Errorf("volume size only supports to be extended")
	}
	return v, nil
}

func expandRdsInstanceV3CreateRegion(d interface{}, arrayIndex map[string]int) (interface{}, error) {
	return navigateValue(d, []string{"region"}, arrayIndex)
}

func flattenRdsInstanceV3HAReplicationMode(d interface{}, arrayIndex map[string]int, currentValue interface{}) (interface{}, error) {
	v, err := navigateValue(d, []string{"list", "flavor_ref"}, nil)
	if err != nil {
		return nil, err
	}
	if strings.HasSuffix(v.(string), ".ha") {
		return navigateValue(d, []string{"list", "ha", "replication_mode"}, nil)
	}
	return "", nil
}