energy/p1-logger
1
0
Fork 0
Code Issues Pull requests Projects Releases 4 Packages 1 Wiki Activity Actions

Fix printing pointer instead of value for changed values.
All checks were successful
Build Docker image / build (push) Successful in 1m6s
Details

Browse source
This commit is contained in:
Pieter Hollander 2024-02-18 18:02:07 +01:00
parent cfbd22d259
commit ddfc896960
Signed by: pieter
SSH key fingerprint: SHA256:HbX+9cBXsop9SuvL+mELd29sK+7DehFfdVweFVDtMSg
1 changed files with 15 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
main.go
View file

@ -4,6 +4,7 @@ package main
import ( import (
"database/sql" "database/sql"
"encoding/json" "encoding/json"
"fmt"
"log" "log"
"os" "os"
"time" "time"
@ -139,6 +140,16 @@ func updateFieldIfChanged(currentValue *int, previousValue *int) (*int, bool) {
return currentValue, false // Return the original value if it's nil, indicating no change return currentValue, false // Return the original value if it's nil, indicating no change
} }
// safeDerefInt handles potential nil pointers to avoid a runtime panic
// log messages will display the actual integer values if the pointers are not nil,
// or "nil" if the pointers are nil.
func safeDerefInt(ptr *int) string {
if ptr != nil {
return fmt.Sprintf("%d", *ptr) // Dereference the pointer to get the value
}
return "nil" // Return a string indicating the value is nil
}
func mqttMessageHandler(client mqtt.Client, msg mqtt.Message) { func mqttMessageHandler(client mqtt.Client, msg mqtt.Message) {
// Parse JSON payload // Parse JSON payload
var payload Payload var payload Payload
@ -182,8 +193,10 @@ func mqttMessageHandler(client mqtt.Client, msg mqtt.Message) {
// If any value has changed, log all the relevant values // If any value has changed, log all the relevant values
if changed { if changed {
log.Printf("Values changed: dt1=%v, dt2=%v, rt1=%v, rt2=%v, g=%v\n", log.Printf("Values changed: dt1=%s, dt2=%s, rt1=%s, rt2=%s, g=%s\n",
payload.Dt1, payload.Dt2, payload.Rt1, payload.Rt2, payload.G) safeDerefInt(payload.Dt1), safeDerefInt(payload.Dt2),
safeDerefInt(payload.Rt1), safeDerefInt(payload.Rt2),
safeDerefInt(payload.G))
} }
// Insert data into PostgreSQL // Insert data into PostgreSQL
err = insertData(timestamp, payload) err = insertData(timestamp, payload)