// Package realtimedata define real time data operation functions
package realtimedata

import (
	"context"

	"modelRT/config"
	"modelRT/constants"
	"modelRT/diagram"
	"modelRT/logger"
	"modelRT/network"
	"modelRT/pool"
)

// RealTimeDataChan define channel of real time data receive
var RealTimeDataChan chan network.RealTimeDataReceiveRequest

func init() {
	RealTimeDataChan = make(chan network.RealTimeDataReceiveRequest, 100)
}

// ReceiveChan define func of real time data receive and process
func ReceiveChan(ctx context.Context) {
	for {
		select {
		case <-ctx.Done():
			return
		case realTimeData := <-RealTimeDataChan:
			componentUUID := realTimeData.PayLoad.ComponentUUID
			component, err := diagram.GetComponentMap(componentUUID)
			if err != nil {
				logger.Error(ctx, "query component info from diagram map by componet id failed", "component_uuid", componentUUID, "error", err)
				continue
			}

			componentType := component.Type
			if componentType != constants.DemoType {
				logger.Error(ctx, "can not process real time data of component type not equal DemoType", "component_uuid", componentUUID)
				continue
			}

			var anchorName string
			var compareValUpperLimit, compareValLowerLimit float64
			var anchorRealTimeData []float64
			var calculateFunc func(archorValue float64, args ...float64) float64

			// calculateFunc, params := config.SelectAnchorCalculateFuncAndParams(componentType, anchorName, componentData)

			for _, param := range realTimeData.PayLoad.Values {
				anchorRealTimeData = append(anchorRealTimeData, param.Value)
			}

			anchorConfig := config.AnchorParamConfig{
				AnchorParamBaseConfig: config.AnchorParamBaseConfig{
					ComponentUUID:        componentUUID,
					AnchorName:           anchorName,
					CompareValUpperLimit: compareValUpperLimit,
					CompareValLowerLimit: compareValLowerLimit,
					AnchorRealTimeData:   anchorRealTimeData,
				},
				CalculateFunc:   calculateFunc,
				CalculateParams: []float64{},
			}
			anchorChan, err := pool.GetAnchorParamChan(ctx, componentUUID)
			if err != nil {
				logger.Error(ctx, "get anchor param chan failed", "component_uuid", componentUUID, "error", err)
				continue
			}
			anchorChan <- anchorConfig
		default:
		}
	}
}