Energinet: remove deprecated implementation (#24439)
This commit is contained in:
parent
ca50a59693
commit
00b88c44aa
3 changed files with 1 additions and 130 deletions
|
|
@ -1,112 +0,0 @@
|
|||
package tariff
|
||||
|
||||
import (
|
||||
"errors"
|
||||
"fmt"
|
||||
"slices"
|
||||
"strings"
|
||||
"sync"
|
||||
"time"
|
||||
|
||||
"github.com/cenkalti/backoff/v4"
|
||||
"github.com/evcc-io/evcc/api"
|
||||
"github.com/evcc-io/evcc/tariff/energinet"
|
||||
"github.com/evcc-io/evcc/util"
|
||||
"github.com/evcc-io/evcc/util/request"
|
||||
)
|
||||
|
||||
type Energinet struct {
|
||||
*embed
|
||||
log *util.Logger
|
||||
region string
|
||||
data *util.Monitor[api.Rates]
|
||||
}
|
||||
|
||||
var _ api.Tariff = (*Energinet)(nil)
|
||||
|
||||
func init() {
|
||||
registry.Add("energinet", NewEnerginetFromConfig)
|
||||
}
|
||||
|
||||
func NewEnerginetFromConfig(other map[string]interface{}) (api.Tariff, error) {
|
||||
var cc struct {
|
||||
embed `mapstructure:",squash"`
|
||||
Region string
|
||||
}
|
||||
|
||||
if err := util.DecodeOther(other, &cc); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
if cc.Region == "" {
|
||||
return nil, errors.New("missing region")
|
||||
}
|
||||
|
||||
if err := cc.init(); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
t := &Energinet{
|
||||
embed: &cc.embed,
|
||||
log: util.NewLogger("energinet"),
|
||||
region: strings.ToLower(cc.Region),
|
||||
data: util.NewMonitor[api.Rates](2 * time.Hour),
|
||||
}
|
||||
|
||||
// TODO remove
|
||||
t.log.WARN.Println("tariff is deprecated and will be removed in a future version")
|
||||
|
||||
return runOrError(t)
|
||||
}
|
||||
|
||||
func (t *Energinet) run(done chan error) {
|
||||
var once sync.Once
|
||||
client := request.NewHelper(t.log)
|
||||
|
||||
for tick := time.Tick(time.Hour); ; <-tick {
|
||||
var res energinet.Prices
|
||||
|
||||
ts := time.Now().Truncate(time.Hour)
|
||||
uri := fmt.Sprintf(energinet.URI,
|
||||
ts.Format(energinet.TimeFormat),
|
||||
ts.Add(24*time.Hour).Format(energinet.TimeFormat),
|
||||
t.region)
|
||||
|
||||
if err := backoff.Retry(func() error {
|
||||
return backoffPermanentError(client.GetJSON(uri, &res))
|
||||
}, bo()); err != nil {
|
||||
once.Do(func() { done <- err })
|
||||
|
||||
t.log.ERROR.Println(err)
|
||||
continue
|
||||
}
|
||||
|
||||
data := make(api.Rates, 0, len(res.Records))
|
||||
for _, r := range res.Records {
|
||||
ts, _ := time.Parse("2006-01-02T15:04:05", r.HourUTC)
|
||||
ar := api.Rate{
|
||||
Start: ts.Local(),
|
||||
End: ts.Add(time.Hour).Local(),
|
||||
Value: t.totalPrice(r.SpotPriceDKK/1e3, ts),
|
||||
}
|
||||
data = append(data, ar)
|
||||
}
|
||||
|
||||
mergeRates(t.data, data)
|
||||
once.Do(func() { close(done) })
|
||||
}
|
||||
}
|
||||
|
||||
// Rates implements the api.Tariff interface
|
||||
func (t *Energinet) Rates() (api.Rates, error) {
|
||||
var res api.Rates
|
||||
err := t.data.GetFunc(func(val api.Rates) {
|
||||
res = slices.Clone(val)
|
||||
})
|
||||
return res, err
|
||||
}
|
||||
|
||||
// Type implements the api.Tariff interface
|
||||
func (t *Energinet) Type() api.TariffType {
|
||||
return api.TariffTypePriceForecast
|
||||
}
|
||||
|
|
@ -1,18 +0,0 @@
|
|||
package energinet
|
||||
|
||||
const (
|
||||
URI = "https://api.energidataservice.dk/dataset/Elspotprices?offset=0&start=%s&end=%s&filter={\"PriceArea\":[\"%s\"]}&timezone=dk&limit=48"
|
||||
TimeFormat = "2006-01-02T15:04" // RFC3339 short
|
||||
)
|
||||
|
||||
type Prices struct {
|
||||
Records []PriceInfo `json:"records"`
|
||||
}
|
||||
|
||||
type PriceInfo struct {
|
||||
HourUTC string
|
||||
HourDK string
|
||||
PriceArea string
|
||||
SpotPriceDKK float64
|
||||
SpotPriceEUR float64
|
||||
}
|
||||
|
|
@ -1,4 +1,5 @@
|
|||
template: energinet-price
|
||||
covers: ["energinet"]
|
||||
products:
|
||||
- brand: Energinet
|
||||
requirements:
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue