pangolin_mirror/olm
1
0
Fork 0
mirror of https://github.com/fosrl/olm.git synced 2026-02-08 05:56:41 +00:00
Code Issues Packages Projects Releases Wiki Activity

Set the error on terminate as well

Browse Source
This commit is contained in:
Owen
2026-01-16 14:59:13 -08:00
parent 2167f22713
commit 8ff58e6efc
1 changed files with 16 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
olm/connect.go
View File

@@ -241,10 +241,25 @@ func (o *Olm) handleOlmError(msg websocket.WSMessage) {
func (o *Olm) handleTerminate(msg websocket.WSMessage) { func (o *Olm) handleTerminate(msg websocket.WSMessage) {
logger.Info("Received terminate message") logger.Info("Received terminate message")
var errorData OlmErrorData
jsonData, err := json.Marshal(msg.Data)
if err != nil {
logger.Error("Error marshaling terminate error data: %v", err)
} else {
if err := json.Unmarshal(jsonData, &errorData); err != nil {
logger.Error("Error unmarshaling terminate error data: %v", err)
} else {
logger.Info("Terminate reason (code: %s): %s", errorData.Code, errorData.Message)
// Set the olm error in the API server so it can be exposed via status
o.apiServer.SetOlmError(errorData.Code, errorData.Message)
}
}
o.apiServer.SetTerminated(true) o.apiServer.SetTerminated(true)
o.apiServer.SetConnectionStatus(false) o.apiServer.SetConnectionStatus(false)
o.apiServer.SetRegistered(false) o.apiServer.SetRegistered(false)
o.apiServer.ClearOlmError()
o.apiServer.ClearPeerStatuses() o.apiServer.ClearPeerStatuses()
network.ClearNetworkSettings() network.ClearNetworkSettings()