func dataSourceProcessorKVRead()

in internal/elasticsearch/ingest/processor_kv_data_source.go [135:212]
71 lines of code
18 McCabe index (conditional complexity)

func dataSourceProcessorKVRead(ctx context.Context, d *schema.ResourceData, meta interface{}) diag.Diagnostics {
	var diags diag.Diagnostics

	processor := &models.ProcessorKV{}

	processor.Field = d.Get("field").(string)
	processor.FieldSplit = d.Get("field_split").(string)
	processor.ValueSplit = d.Get("value_split").(string)
	processor.IgnoreFailure = d.Get("ignore_failure").(bool)
	processor.IgnoreMissing = d.Get("ignore_missing").(bool)
	processor.StripBrackets = d.Get("strip_brackets").(bool)

	if v, ok := d.GetOk("include_keys"); ok {
		kk := v.(*schema.Set)
		keys := make([]string, kk.Len())
		for i, k := range kk.List() {
			keys[i] = k.(string)
		}
		processor.IncludeKeys = keys
	}
	if v, ok := d.GetOk("exclude_keys"); ok {
		kk := v.(*schema.Set)
		keys := make([]string, kk.Len())
		for i, k := range kk.List() {
			keys[i] = k.(string)
		}
		processor.ExcludeKeys = keys
	}
	if v, ok := d.GetOk("target_field"); ok {
		processor.TargetField = v.(string)
	}
	if v, ok := d.GetOk("prefix"); ok {
		processor.Prefix = v.(string)
	}
	if v, ok := d.GetOk("trim_key"); ok {
		processor.TrimKey = v.(string)
	}
	if v, ok := d.GetOk("trim_value"); ok {
		processor.TrimValue = v.(string)
	}
	if v, ok := d.GetOk("description"); ok {
		processor.Description = v.(string)
	}
	if v, ok := d.GetOk("if"); ok {
		processor.If = v.(string)
	}
	if v, ok := d.GetOk("tag"); ok {
		processor.Tag = v.(string)
	}
	if v, ok := d.GetOk("on_failure"); ok {
		onFailure := make([]map[string]interface{}, len(v.([]interface{})))
		for i, f := range v.([]interface{}) {
			item := make(map[string]interface{})
			if err := json.NewDecoder(strings.NewReader(f.(string))).Decode(&item); err != nil {
				return diag.FromErr(err)
			}
			onFailure[i] = item
		}
		processor.OnFailure = onFailure
	}

	processorJson, err := json.MarshalIndent(map[string]*models.ProcessorKV{"kv": processor}, "", " ")
	if err != nil {
		return diag.FromErr(err)
	}
	if err := d.Set("json", string(processorJson)); err != nil {
		return diag.FromErr(err)
	}

	hash, err := utils.StringToHash(string(processorJson))
	if err != nil {
		return diag.FromErr(err)
	}

	d.SetId(*hash)

	return diags
}