chore: collect tickers

Jak12-3 · Mar 17, 2024 · 6fd387d · 6fd387d
1 parent b86fbfa
commit 6fd387d
Show file tree

Hide file tree

Showing 17 changed files with 35 additions and 18 deletions.
diff --git a/charger/mennekes-compact.go b/charger/mennekes-compact.go
@@ -116,7 +116,8 @@ func NewMennekesCompact(uri, device, comset string, baudrate int, proto modbus.P
 }
 
 func (wb *MennekesCompact) heartbeat(timeout time.Duration) {
-	for ; true; <-time.Tick(timeout) {
+	tick := time.NewTicker(timeout)
+	for ; true; <-tick.C {
 		if _, err := wb.conn.WriteSingleRegister(mennekesRegHeartbeat, mennekesHeartbeatToken); err != nil {
 			wb.log.ERROR.Println("heartbeat:", err)
 		}

diff --git a/charger/ocpp/connector.go b/charger/ocpp/connector.go
@@ -73,7 +73,8 @@ func (conn *Connector) TriggerMessageRequest(feature remotetrigger.MessageTrigge
 // WatchDog triggers meter values messages if older than timeout.
 // Must be wrapped in a goroutine.
 func (conn *Connector) WatchDog(timeout time.Duration) {
-	for ; true; <-time.Tick(timeout) {
+	tick := time.NewTicker(timeout)
+	for ; true; <-tick.C {
 		conn.mu.Lock()
 		update := conn.txnId != 0 && conn.clock.Since(conn.meterUpdated) > timeout
 		conn.mu.Unlock()

diff --git a/server/updater/watch.go b/server/updater/watch.go
@@ -28,7 +28,8 @@ func (u *watch) Send(key string, val interface{}) {
 }
 
 func (u *watch) watchReleases(installed string, out chan *github.RepositoryRelease) {
-	for ; true; <-time.Tick(6 * time.Hour) {
+	tick := time.NewTicker(6 * time.Hour)
+	for ; true; <-tick.C {
 		rel, err := u.findReleaseUpdate(installed)
 		if err != nil {
 			u.log.ERROR.Printf("version check failed: %v (installed: %s)", err, installed)

diff --git a/tariff/amber.go b/tariff/amber.go
@@ -84,7 +84,8 @@ func (t *Amber) run(done chan error) {
 	var once sync.Once
 	bo := newBackoff()
 
-	for ; true; <-time.Tick(time.Minute) {
+	tick := time.NewTicker(time.Minute)
+	for ; true; <-tick.C {
 		var res []amber.PriceInfo
 
 		if err := backoff.Retry(func() error {

diff --git a/tariff/awattar.go b/tariff/awattar.go
@@ -58,7 +58,8 @@ func (t *Awattar) run(done chan error) {
 	bo := newBackoff()
 	client := request.NewHelper(t.log)
 
-	for ; true; <-time.Tick(time.Hour) {
+	tick := time.NewTicker(time.Hour)
+	for ; true; <-tick.C {
 		var res awattar.Prices
 
 		if err := backoff.Retry(func() error {

diff --git a/tariff/edf-tempo.go b/tariff/edf-tempo.go
@@ -104,7 +104,8 @@ func (t *EdfTempo) run(done chan error) {
 	var once sync.Once
 	bo := newBackoff()
 
-	for ; true; <-time.Tick(time.Hour) {
+	tick := time.NewTicker(time.Hour)
+	for ; true; <-tick.C {
 		var res struct {
 			Data struct {
 				Values []struct {

diff --git a/tariff/electricitymaps.go b/tariff/electricitymaps.go
@@ -82,7 +82,8 @@ func (t *ElectricityMaps) run(done chan error) {
 	bo := newBackoff()
 	uri := fmt.Sprintf("%s/carbon-intensity/forecast?zone=%s", t.uri, t.zone)
 
-	for ; true; <-time.Tick(time.Hour) {
+	tick := time.NewTicker(time.Hour)
+	for ; true; <-tick.C {
 		var res CarbonIntensity
 
 		if err := backoff.Retry(func() error {

diff --git a/tariff/elering.go b/tariff/elering.go
@@ -62,7 +62,8 @@ func (t *Elering) run(done chan error) {
 	client := request.NewHelper(t.log)
 	bo := newBackoff()
 
-	for ; true; <-time.Tick(time.Hour) {
+	tick := time.NewTicker(time.Hour)
+	for ; true; <-tick.C {
 		var res elering.NpsPrice
 
 		ts := time.Now().Truncate(time.Hour)

diff --git a/tariff/energinet.go b/tariff/energinet.go
@@ -61,7 +61,8 @@ func (t *Energinet) run(done chan error) {
 	client := request.NewHelper(t.log)
 	bo := newBackoff()
 
-	for ; true; <-time.Tick(time.Hour) {
+	tick := time.NewTicker(time.Hour)
+	for ; true; <-tick.C {
 		var res energinet.Prices
 
 		ts := time.Now().Truncate(time.Hour)

diff --git a/tariff/entsoe.go b/tariff/entsoe.go
@@ -89,7 +89,8 @@ func (t *Entsoe) run(done chan error) {
 	bo := newBackoff()
 
 	// Data updated by ESO every half hour, but we only need data every hour to stay current.
-	for ; true; <-time.Tick(time.Hour) {
+	tick := time.NewTicker(time.Hour)
+	for ; true; <-tick.C {
 		var tr entsoe.PublicationMarketDocument
 
 		if err := backoff.Retry(func() error {

diff --git a/tariff/groupe-e.go b/tariff/groupe-e.go
@@ -44,7 +44,8 @@ func (t *GroupeE) run(done chan error) {
 	bo := newBackoff()
 	client := request.NewHelper(t.log)
 
-	for ; true; <-time.Tick(time.Hour) {
+	tick := time.NewTicker(time.Hour)
+	for ; true; <-tick.C {
 		var res []struct {
 			StartTimestamp time.Time `json:"start_timestamp"`
 			EndTimestamp   time.Time `json:"end_timestamp"`

diff --git a/tariff/gruenstromindex.go b/tariff/gruenstromindex.go
@@ -92,7 +92,8 @@ func (t *GrünStromIndex) run(done chan error) {
 	bo := newBackoff()
 	uri := fmt.Sprintf("https://api.corrently.io/v2.0/gsi/prediction?zip=%s", t.zip)
 
-	for ; true; <-time.Tick(time.Hour) {
+	tick := time.NewTicker(time.Hour)
+	for ; true; <-tick.C {
 		var res gsiForecast
 
 		err := backoff.Retry(func() error {

diff --git a/tariff/ngeso.go b/tariff/ngeso.go
@@ -75,7 +75,8 @@ func (t *Ngeso) run(done chan error) {
 	}
 
 	// Data updated by ESO every half hour, but we only need data every hour to stay current.
-	for ; true; <-time.Tick(time.Hour) {
+	tick := time.NewTicker(time.Hour)
+	for ; true; <-tick.C {
 		res, err := backoff.RetryWithData(func() (ngeso.CarbonForecastResponse, error) {
 			res, err := tReq.DoRequest(client)
 			var se request.StatusError

diff --git a/tariff/octopus.go b/tariff/octopus.go
@@ -62,7 +62,8 @@ func (t *Octopus) run(done chan error) {
 	client := request.NewHelper(t.log)
 	bo := newBackoff()
 
-	for ; true; <-time.Tick(time.Hour) {
+	tick := time.NewTicker(time.Hour)
+	for ; true; <-tick.C {
 		var res octopus.UnitRates
 
 		if err := backoff.Retry(func() error {

diff --git a/tariff/pun.go b/tariff/pun.go
@@ -81,7 +81,8 @@ func (t *Pun) run(done chan error) {
 	var once sync.Once
 	bo := newBackoff()
 
-	for ; true; <-time.Tick(time.Hour) {
+	tick := time.NewTicker(time.Hour)
+	for ; true; <-tick.C {
 		var today api.Rates
 		if err := backoff.Retry(func() error {
 			var err error
@@ -109,7 +110,7 @@ func (t *Pun) run(done chan error) {
 			continue
 		}
 
-		//merge today and tomorrow data
+		// merge today and tomorrow data
 		data := append(today, tomorrow...)
 		t.data.Set(data)
 

diff --git a/tariff/smartenergy.go b/tariff/smartenergy.go
@@ -51,7 +51,8 @@ func (t *SmartEnergy) run(done chan error) {
 	client := request.NewHelper(t.log)
 	bo := newBackoff()
 
-	for ; true; <-time.Tick(time.Hour) {
+	tick := time.NewTicker(time.Hour)
+	for ; true; <-tick.C {
 		var res smartenergy.Prices
 
 		if err := backoff.Retry(func() error {

diff --git a/tariff/tibber.go b/tariff/tibber.go
@@ -78,7 +78,8 @@ func (t *Tibber) run(done chan error) {
 		"id": graphql.ID(t.homeID),
 	}
 
-	for ; true; <-time.Tick(time.Hour) {
+	tick := time.NewTicker(time.Hour)
+	for ; true; <-tick.C {
 		var res struct {
 			Viewer struct {
 				Home struct {