Mirrors/VILLASweb-backend-go
1
0
Fork 0
mirror of https://git.rwth-aachen.de/acs/public/villas/web-backend-go/ synced 2025-03-30 00:00:12 +01:00
Code Issues Releases Wiki Activity

AMQP: improve error handling of UUID extraction from message content #31

Browse source
This commit is contained in:
Sonja Happ 2019-11-21 13:03:36 +01:00
parent abb35ccfd9
commit 33d50a148d
1 changed files with 21 additions and 16 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

37
amqp/amqpclient.go
View file

@ -122,24 +122,29 @@ func ConnectAMQP(uri string) error {
var sToBeUpdated database.Simulator var sToBeUpdated database.Simulator
db := database.GetDB() db := database.GetDB()
err = db.Where("UUID = ?", gjson.Get(content, "properties.uuid")).Find(sToBeUpdated).Error simulatorUUID := gjson.Get(content, "properties.uuid").String()
if err != nil { if simulatorUUID == "" {
log.Println("AMQP: Unable to find simulator with UUID: ", gjson.Get(content, "properties.uuid"), " DB error message: ", err) log.Println("AMQP: Could not extract UUID of simulator from content of received message, SIMULATOR NOT UPDATED")
} } else {
err = db.Where("UUID = ?", simulatorUUID).Find(sToBeUpdated).Error
if err != nil {
log.Println("AMQP: Unable to find simulator with UUID: ", gjson.Get(content, "properties.uuid"), " DB error message: ", err)
}
err = db.Model(&sToBeUpdated).Updates(map[string]interface{}{ err = db.Model(&sToBeUpdated).Updates(map[string]interface{}{
"Host": gjson.Get(content, "host"), "Host": gjson.Get(content, "host"),
"Modeltype": gjson.Get(content, "model"), "Modeltype": gjson.Get(content, "model"),
"Uptime": gjson.Get(content, "uptime"), "Uptime": gjson.Get(content, "uptime"),
"State": gjson.Get(content, "state"), "State": gjson.Get(content, "state"),
"StateUpdateAt": time.Now().String(), "StateUpdateAt": time.Now().String(),
"RawProperties": gjson.Get(content, "properties"), "RawProperties": gjson.Get(content, "properties"),
}).Error }).Error
if err != nil { if err != nil {
log.Println("AMQP: Unable to update simulator in DB: ", err) log.Println("AMQP: Unable to update simulator in DB: ", err)
} }
log.Println("AMQP: Updated simulator with UUID ", gjson.Get(content, "properties.uuid")) log.Println("AMQP: Updated simulator with UUID ", gjson.Get(content, "properties.uuid"))
}
} }
}() }()