package sfxclient

import (
	"github.com/signalfx/golib/v3/datapoint"
)

// MultiCollector acts like a datapoint collector over multiple collectors.
type MultiCollector []Collector

// NewMultiCollector returns a collector that is the aggregate of every given collector.  It can be
// used to turn multiple collectors into a single collector.
func NewMultiCollector(collectors ...Collector) Collector {
	if len(collectors) == 1 {
		return collectors[0]
	}
	return MultiCollector(collectors)
}

// Datapoints returns the datapoints from every collector.
func (m MultiCollector) Datapoints() []*datapoint.Datapoint {
	ret := make([]*datapoint.Datapoint, 0)
	for _, col := range m {
		ret = append(ret, col.Datapoints()...)
	}
	return ret
}

var _ Collector = MultiCollector(nil)

// WithDimensions adds dimensions on top of the datapoints of a collector.  This can be used to take
// an existing Collector and include extra dimensions.
type WithDimensions struct {
	Dimensions map[string]string
	Collector  Collector
}

var _ Collector = &WithDimensions{}

// Datapoints calls datapoints and adds on Dimensions
func (w *WithDimensions) Datapoints() []*datapoint.Datapoint {
	return w.appendDimensions(w.Collector.Datapoints())
}

func (w *WithDimensions) appendDimensions(dps []*datapoint.Datapoint) []*datapoint.Datapoint {
	if len(w.Dimensions) == 0 {
		return dps
	}
	for _, dp := range dps {
		dp.Dimensions = datapoint.AddMaps(dp.Dimensions, w.Dimensions)
	}
	return dps
}