only send future forecasts > 1 hour from now, not times in the past

This makes it so period=past and period=future don't end up overlapping
tedpearson · Dec 11, 2021 · 10fc020 · 10fc020
1 parent 5f912e8
commit 10fc020
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/weather/forecast.go b/weather/forecast.go
@@ -75,6 +75,10 @@ func toPoints(items []interface{}, options WriteOptions) (influxdb1.BatchPoints,
 	}
 	for _, item := range items {
 		t := reflect.ValueOf(item).FieldByName("Time").Interface().(time.Time)
+		// only send future datapoints.
+		if t.Before(time.Now().Add(time.Hour + 1)) {
+			continue
+		}
 		point, err := toPoint(t, item, options)
 		if err != nil {
 			log.Printf("Failed to create point: %+v", err)