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

add API query for villas-relay manager to async routine #65

Browse source
This commit is contained in:
Sonja Happ 2021-05-26 14:08:31 +02:00
parent 1b3e4e907c
commit ce0b57e57b
1 changed files with 45 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

49
routes/infrastructure-component/ic_apiquery.go
View file

@ -66,7 +66,7 @@ func QueryICAPIs(d time.Duration) {
if ic.Category == "gateway" && ic.Type == "villas-node" {
log.Println("External API: checking for IC", ic.Name)
log.Println("External API: checking for villas-node gateway", ic.Name)
statusResponse, err := client.R().SetHeader("Accept", "application/json").Get(ic.APIURL + "/status")
if err != nil {
log.Println("Error querying status of", ic.Name, err)
@ -118,7 +118,7 @@ func QueryICAPIs(d time.Duration) {
// validate the update
err = updatedIC.validate()
if err != nil {
log.Println("Error validating updated IC", ic.Name, ic.UUID, err.Error())
log.Println("Error validating updated villas-node gateway", ic.Name, ic.UUID, err.Error())
continue
}
@ -126,20 +126,61 @@ func QueryICAPIs(d time.Duration) {
var x InfrastructureComponent
err = x.byID(ic.ID)
if err != nil {
log.Println("Error getting IC by ID", ic.Name, err)
log.Println("Error getting villas-node gateway by ID", ic.Name, err)
continue
}
u := updatedIC.updatedIC(x)
err = x.update(u)
if err != nil {
log.Println("Error updating IC", ic.Name, ic.UUID, err.Error())
log.Println("Error updating villas-node gateway", ic.Name, ic.UUID, err.Error())
continue
}
} else if ic.Category == "manager" && ic.Type == "villas-relay" {
log.Println("External API: checking for villas-relay manager", ic.Name)
statusResponse, err := client.R().SetHeader("Accept", "application/json").Get(ic.APIURL)
if err != nil {
log.Println("Error querying API of", ic.Name, err)
continue
}
var status map[string]interface{}
err = json.Unmarshal(statusResponse.Body(), &status)
if err != nil {
log.Println("Error unmarshalling status villas-relay manager", ic.Name, err)
continue
}
var updatedIC UpdateICRequest
statusRaw, _ := json.Marshal(status)
updatedIC.InfrastructureComponent.StatusUpdateRaw = postgres.Jsonb{RawMessage: statusRaw}
updatedIC.InfrastructureComponent.UUID = fmt.Sprintf("%v", status["uuid"])
// validate the update
err = updatedIC.validate()
if err != nil {
log.Println("Error validating updated villas-relay manager", ic.Name, ic.UUID, err.Error())
continue
}
// create the update and update IC in DB
var x InfrastructureComponent
err = x.byID(ic.ID)
if err != nil {
log.Println("Error getting villas-relay manager by ID", ic.Name, err)
continue
}
u := updatedIC.updatedIC(x)
err = x.update(u)
if err != nil {
log.Println("Error updating villas-relay manager", ic.Name, ic.UUID, err.Error())
continue
}
} else if ic.Category == "gateway" && ic.Type == "villas-relay" {
// TODO add code here once API for VILLASrelay sessions is available
}
}
}