Integrate with site planner

cmd/config.go

@@ -113,6 +113,7 @@ type tariffConfig struct {
 	Currency string
 	Grid     typedConfig
 	FeedIn   typedConfig
+	Planner  typedConfig
 }
 
 type networkConfig struct {

cmd/setup.go

@@ -227,7 +227,7 @@ func configureMessengers(conf messagingConfig, cache *util.Cache) (chan push.Eve
 }
 
 func configureTariffs(conf tariffConfig) (tariff.Tariffs, error) {
-	var grid, feedin api.Tariff
+	var grid, feedin, planner api.Tariff
 	var currencyCode currency.Unit = currency.EUR
 	var err error
 
@@ -243,11 +243,15 @@ func configureTariffs(conf tariffConfig) (tariff.Tariffs, error) {
 		feedin, err = tariff.NewFromConfig(conf.FeedIn.Type, conf.FeedIn.Other)
 	}
 
+	if err == nil && conf.Planner.Type != "" {
+		planner, err = tariff.NewFromConfig(conf.Planner.Type, conf.Planner.Other)
+	}
+
 	if err != nil {
 		err = fmt.Errorf("failed configuring tariff: %w", err)
 	}
 
-	tariffs := tariff.NewTariffs(currencyCode, grid, feedin)
+	tariffs := tariff.NewTariffs(currencyCode, grid, feedin, planner)
 
 	return *tariffs, err
 }

core/site.go

@@ -120,8 +120,8 @@ func NewSiteFromConfig(
 		lp.coordinator = coordinator.NewAdapter(lp, site.coordinator)
 
 		// planner
-		if gridTariff := site.tariffs.Grid; gridTariff != nil {
-			lp.planner = planner.New(lp.log, gridTariff)
+		if plannerTariff := site.tariffs.Planner; plannerTariff != nil {
+			lp.planner = planner.New(lp.log, plannerTariff)
 		}
 
 		if serverdb.Instance != nil {

tariff/electricitymaps.go

@@ -93,23 +93,19 @@ func (t *ElectricityMaps) Run() {
 	}
 }
 
-func (t *ElectricityMaps) CurrentPrice() (float64, error) {
+func (t *ElectricityMaps) Rates() (api.Rates, error) {
 	t.mux.Lock()
 	defer t.mux.Unlock()
 
-	now := time.Now()
-
-	for _, pi := range t.data {
-		ts := pi.Datetime
-
-		if (ts.Before(now) || ts.Equal(now)) && ts.Add(time.Hour).After(now) {
-			return pi.CarbonIntensity, nil
+	res := make(api.Rates, 0, len(t.data))
+	for _, r := range t.data {
+		ar := api.Rate{
+			Start: r.Datetime,
+			End:   r.Datetime.Add(time.Hour),
+			Price: r.CarbonIntensity,
 		}
+		res = append(res, ar)
 	}
 
-	return 0, errors.New("unable to find current slot")
-}
-
-func (t *ElectricityMaps) IsCheap() (bool, error) {
-	return false, nil
+	return res, nil
 }

tariff/tariffs.go

@@ -6,15 +6,19 @@ import (
 )
 
 type Tariffs struct {
-	Currency currency.Unit
-	Grid     api.Tariff
-	FeedIn   api.Tariff
+	Currency              currency.Unit
+	Grid, FeedIn, Planner api.Tariff
 }
 
-func NewTariffs(currency currency.Unit, grid api.Tariff, feedin api.Tariff) *Tariffs {
-	t := Tariffs{}
-	t.Currency = currency
-	t.Grid = grid
-	t.FeedIn = feedin
-	return &t
+func NewTariffs(currency currency.Unit, grid, feedin, planner api.Tariff) *Tariffs {
+	if planner == nil {
+		planner = grid
+	}
+
+	return &Tariffs{
+		Currency: currency,
+		Grid:     grid,
+		FeedIn:   feedin,
+		Planner:  planner,
+	}
 }