package chart

import (
	"fmt"
	"strings"

	"github.com/yaoapp/gou"
	"github.com/yaoapp/kun/log"
)

func (dsl *DSL) computeData(process *gou.Process, values map[string]interface{}) error {

	messages := []string{}
	for key := range values {
		err := dsl.computeOut(process, key, values)
		if err != nil {
			messages = append(messages, err.Error())
		}
	}

	if len(messages) > 0 {
		return fmt.Errorf("%s", strings.Join(messages, ";"))
	}

	return nil
}

func (dsl *DSL) computeOut(process *gou.Process, key string, values map[string]interface{}) error {
	if name, has := dsl.ComputesOut[key]; has {
		compute, err := gou.ProcessOf(name, key, values[key], values)
		if err != nil {
			log.Error("[chart] %s compute-out -> %s %s %s", dsl.ID, name, key, err.Error())
			return fmt.Errorf("[chart] %s compute-out -> %s %s %s", dsl.ID, name, key, err.Error())
		}

		res, err := compute.WithGlobal(process.Global).WithSID(process.Sid).Exec()
		if err != nil {
			log.Error("[chart] %s compute-out -> %s %s %s", dsl.ID, name, key, err.Error())
			return fmt.Errorf("[chart] %s compute-out -> %s %s %s", dsl.ID, name, key, err.Error())
		}
		values[key] = res
	}
	return nil
}