mirror of
https://github.com/fosrl/olm.git
synced 2026-02-08 05:56:41 +00:00
Handle termination message
This commit is contained in:
11
main.go
11
main.go
@@ -220,6 +220,17 @@ func main() {
|
|||||||
var connected bool
|
var connected bool
|
||||||
var wgData WgData
|
var wgData WgData
|
||||||
|
|
||||||
|
client.RegisterHandler("newt/terminate", func(msg websocket.WSMessage) {
|
||||||
|
logger.Info("Received terminate message")
|
||||||
|
if pm != nil {
|
||||||
|
pm.Stop()
|
||||||
|
}
|
||||||
|
if dev != nil {
|
||||||
|
dev.Close()
|
||||||
|
}
|
||||||
|
client.Close()
|
||||||
|
})
|
||||||
|
|
||||||
// Register handlers for different message types
|
// Register handlers for different message types
|
||||||
client.RegisterHandler("newt/wg/connect", func(msg websocket.WSMessage) {
|
client.RegisterHandler("newt/wg/connect", func(msg websocket.WSMessage) {
|
||||||
logger.Info("Received registration message")
|
logger.Info("Received registration message")
|
||||||
|
|||||||
@@ -86,6 +86,10 @@ func (c *Client) Close() error {
|
|||||||
if c.conn != nil {
|
if c.conn != nil {
|
||||||
return c.conn.Close()
|
return c.conn.Close()
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// stop the ping monitor
|
||||||
|
c.setConnected(false)
|
||||||
|
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user