mirror of
https://github.com/fosrl/newt.git
synced 2026-03-26 04:26:39 +00:00
Send disconnecting message
This commit is contained in:
6
main.go
6
main.go
@@ -618,7 +618,7 @@ func runNewtMain(ctx context.Context) {
|
|||||||
var connected bool
|
var connected bool
|
||||||
var wgData WgData
|
var wgData WgData
|
||||||
var dockerEventMonitor *docker.EventMonitor
|
var dockerEventMonitor *docker.EventMonitor
|
||||||
|
|
||||||
if !disableClients {
|
if !disableClients {
|
||||||
setupClients(client)
|
setupClients(client)
|
||||||
}
|
}
|
||||||
@@ -1197,7 +1197,7 @@ persistent_keepalive_interval=5`, util.FixKey(privateKey.String()), util.FixKey(
|
|||||||
len(syncData.Targets.TCP), len(syncData.Targets.UDP), len(syncData.HealthCheckTargets))
|
len(syncData.Targets.TCP), len(syncData.Targets.UDP), len(syncData.HealthCheckTargets))
|
||||||
|
|
||||||
//TODO: TEST AND IMPLEMENT THIS
|
//TODO: TEST AND IMPLEMENT THIS
|
||||||
|
|
||||||
// // Build sets of desired targets (port -> target string)
|
// // Build sets of desired targets (port -> target string)
|
||||||
// desiredTCP := make(map[int]string)
|
// desiredTCP := make(map[int]string)
|
||||||
// for _, t := range syncData.Targets.TCP {
|
// for _, t := range syncData.Targets.TCP {
|
||||||
@@ -1794,6 +1794,8 @@ persistent_keepalive_interval=5`, util.FixKey(privateKey.String()), util.FixKey(
|
|||||||
pm.Stop()
|
pm.Stop()
|
||||||
}
|
}
|
||||||
|
|
||||||
|
client.SendMessage("newt/disconnecting", map[string]any{})
|
||||||
|
|
||||||
if client != nil {
|
if client != nil {
|
||||||
client.Close()
|
client.Close()
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user