louis/oktopus
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(cwmp): cpe last connection info

Browse Source
This commit is contained in:
leandrofars 2024-06-09 19:15:57 -03:00
parent c7ce3f1c95
commit 86faee584c
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
backend/services/acs/internal/server/handler/cwmp.go
View File

@ -79,9 +79,6 @@ func (h *Handler) CwmpHandler(w http.ResponseWriter, r *http.Request) {
} }
h.pub(NATS_CWMP_SUBJECT_PREFIX+sn+".info", tmp) h.pub(NATS_CWMP_SUBJECT_PREFIX+sn+".info", tmp)
} }
obj := h.Cpes[sn]
cpe := &obj
cpe.LastConnection = time.Now()
log.Printf("Received an Inform from device %s withEventCodes %s", addr, Inform.GetEvents()) log.Printf("Received an Inform from device %s withEventCodes %s", addr, Inform.GetEvents())
@ -116,6 +113,9 @@ func (h *Handler) CwmpHandler(w http.ResponseWriter, r *http.Request) {
} else if e.KindOf() == "GetParameterValuesResponse" { } else if e.KindOf() == "GetParameterValuesResponse" {
log.Println("Receive GetParameterValuesResponse from CPE:", cpe.SerialNumber) log.Println("Receive GetParameterValuesResponse from CPE:", cpe.SerialNumber)
msgAnswer(cpe.Waiting.Callback, cpe.Waiting.Time, h.acsConfig.DeviceAnswerTimeout, tmp) msgAnswer(cpe.Waiting.Callback, cpe.Waiting.Time, h.acsConfig.DeviceAnswerTimeout, tmp)
} else if e.KindOf() == "SetParameterValuesResponse" {
log.Println("Receive SetParameterValuesResponse from CPE:", cpe.SerialNumber)
msgAnswer(cpe.Waiting.Callback, cpe.Waiting.Time, h.acsConfig.DeviceAnswerTimeout, tmp)
}else if e.KindOf() == "Fault" { }else if e.KindOf() == "Fault" {
log.Println("Receive FaultResponse from CPE:", cpe.SerialNumber) log.Println("Receive FaultResponse from CPE:", cpe.SerialNumber)
msgAnswer(cpe.Waiting.Callback, cpe.Waiting.Time, h.acsConfig.DeviceAnswerTimeout, tmp) msgAnswer(cpe.Waiting.Callback, cpe.Waiting.Time, h.acsConfig.DeviceAnswerTimeout, tmp)
@ -143,8 +143,8 @@ func (h *Handler) CwmpHandler(w http.ResponseWriter, r *http.Request) {
w.WriteHeader(204) w.WriteHeader(204)
} }
} }
cpe.LastConnection = time.Now()
h.Cpes[cpe.SerialNumber] = cpe h.Cpes[cpe.SerialNumber] = cpe
log.Println("---End of CWMP Handler---")
} }
func (h *Handler) ConnectionRequest(cpe CPE) error { func (h *Handler) ConnectionRequest(cpe CPE) error {