Do not panic on invalid metrics data.

brocaar · brocaar · commit d8ea9edd05c8 · 2022-09-01T11:34:44.000+01:00
diff --git a/main.go b/main.go
@@ -1107,7 +1107,7 @@ func migrateDeviceMetrics(devEUI []byte) {
 		}
 
 		if err := csRedis.HSet(context.Background(), newKey, vals).Err(); err != nil {
-			panic(err)
+			log.Printf("Migrate device metrics error: %s", err)
 		}
 		if err := csRedis.PExpire(context.Background(), newKey, ttl[aggregation]).Err(); err != nil {
 			panic(err)
@@ -1146,7 +1146,7 @@ func migrateGatewayMetrics(gatewayID []byte) {
 		}
 
 		if err := csRedis.HSet(context.Background(), newKey, vals).Err(); err != nil {
-			panic(err)
+			log.Panicf("Migrate gateway metrics error: %s", err)
 		}
 		if err := csRedis.PExpire(context.Background(), newKey, ttl[aggregation]).Err(); err != nil {
 			panic(err)

Original file line number	Diff line number	Diff line change
`@@ -1107,7 +1107,7 @@ func migrateDeviceMetrics(devEUI []byte) {`
`1107`	`1107`	`}`
`1108`	`1108`
`1109`	`1109`	`if err := csRedis.HSet(context.Background(), newKey, vals).Err(); err != nil {`
`1110`		`- panic(err)`
	`1110`	`+ log.Printf("Migrate device metrics error: %s", err)`
`1111`	`1111`	`}`
`1112`	`1112`	`if err := csRedis.PExpire(context.Background(), newKey, ttl[aggregation]).Err(); err != nil {`
`1113`	`1113`	`panic(err)`
`@@ -1146,7 +1146,7 @@ func migrateGatewayMetrics(gatewayID []byte) {`
`1146`	`1146`	`}`
`1147`	`1147`
`1148`	`1148`	`if err := csRedis.HSet(context.Background(), newKey, vals).Err(); err != nil {`
`1149`		`- panic(err)`
	`1149`	`+ log.Panicf("Migrate gateway metrics error: %s", err)`
`1150`	`1150`	`}`
`1151`	`1151`	`if err := csRedis.PExpire(context.Background(), newKey, ttl[aggregation]).Err(); err != nil {`
`1152`	`1152`	`panic(err)`