gasstations: only store blocks on price changes

rubiojr · rubiojr · commit 21a4762a48aa · 2025-10-13T16:42:47.000+02:00
diff --git a/pkg/datasources/gasstations/blocks.go b/pkg/datasources/gasstations/blocks.go
@@ -75,7 +75,9 @@ func NewGasStationBlockWithSource(
 		"source":     source,
 	}
 
-	blockID := fmt.Sprintf("gasstation-%s-%d", stationID, createdAt.Unix())
+	// Use content-based ID so we only create new blocks when prices change
+	// This prevents storing duplicate data when prices remain the same
+	blockID := fmt.Sprintf("gasstation-%s-%s-%s-%s-%s", stationID, gasoline95, diesel, gasoline98, biodiesel)
 
 	return &GasStationBlock{
 		id:         blockID,

Original file line number	Diff line number	Diff line change
`@@ -75,7 +75,9 @@ func NewGasStationBlockWithSource(`
`75`	`75`	`"source": source,`
`76`	`76`	`}`
`77`	`77`
`78`		`- blockID := fmt.Sprintf("gasstation-%s-%d", stationID, createdAt.Unix())`
	`78`	`+ // Use content-based ID so we only create new blocks when prices change`
	`79`	`+ // This prevents storing duplicate data when prices remain the same`
	`80`	`+ blockID := fmt.Sprintf("gasstation-%s-%s-%s-%s-%s", stationID, gasoline95, diesel, gasoline98, biodiesel)`
`79`	`81`
`80`	`82`	`return &GasStationBlock{`
`81`	`83`	`id: blockID,`