Skip to content

Commit 3dc0d18

Browse files
authored
Stekker: fix duplicate values (#24609)
1 parent 7f68124 commit 3dc0d18

File tree

1 file changed

+14
-13
lines changed

1 file changed

+14
-13
lines changed

tariff/stekker.go

Lines changed: 14 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -27,9 +27,10 @@ var supportedRegions = []string{
2727
// Stekker provider
2828
type Stekker struct {
2929
*embed
30-
region string
31-
log *util.Logger
32-
data *util.Monitor[api.Rates]
30+
region string
31+
interval time.Duration
32+
log *util.Logger
33+
data *util.Monitor[api.Rates]
3334
}
3435

3536
var _ api.Tariff = (*Stekker)(nil)
@@ -59,18 +60,23 @@ func NewStekkerFromConfig(other map[string]interface{}) (api.Tariff, error) {
5960
return nil, err
6061
}
6162

63+
interval := time.Hour
64+
6265
switch cc.Region {
6366
case "BE":
6467
cc.Region = "BE-900"
68+
interval = 15 * time.Minute
6569
case "NL":
6670
cc.Region = "NL-900"
71+
interval = 15 * time.Minute
6772
}
6873

6974
t := &Stekker{
70-
embed: &cc.embed,
71-
region: cc.Region,
72-
log: util.NewLogger("stekker"),
73-
data: util.NewMonitor[api.Rates](2 * time.Hour),
75+
embed: &cc.embed,
76+
region: cc.Region,
77+
interval: interval,
78+
log: util.NewLogger("stekker"),
79+
data: util.NewMonitor[api.Rates](2 * time.Hour),
7480
}
7581

7682
return runOrError(t)
@@ -143,14 +149,9 @@ func (t *Stekker) run(done chan error) {
143149
continue
144150
}
145151

146-
duration := time.Hour
147-
if t.region == "BE" || t.region == "NL" {
148-
duration = SlotDuration
149-
}
150-
151152
res = append(res, api.Rate{
152153
Start: start,
153-
End: start.Add(duration),
154+
End: start.Add(t.interval),
154155
Value: t.totalPrice(yt/1000.0, start), // €/MWh → €/kWh
155156
})
156157
}

0 commit comments

Comments
 (0)