Skip to content

Commit 59ae92c

Browse files
committed
Refactor handleAutoUpdateVersion to outside handleSync
1 parent d2e198b commit 59ae92c

File tree

1 file changed

+12
-8
lines changed

1 file changed

+12
-8
lines changed

client/internal/engine.go

Lines changed: 12 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -703,22 +703,26 @@ func (e *Engine) PopulateNetbirdConfig(netbirdConfig *mgmProto.NetbirdConfig, mg
703703
return nil
704704
}
705705

706-
func (e *Engine) handleSync(update *mgmProto.SyncResponse) error {
707-
e.syncMsgMux.Lock()
708-
defer e.syncMsgMux.Unlock()
709-
710-
if update.GetAutoUpdateVersion() != skipAutoUpdateVersion {
711-
if e.updateManager == nil && update.GetAutoUpdateVersion() != disableAutoUpdate {
706+
func (e *Engine) handleAutoUpdateVersion(autoUpdateVersion string) {
707+
if autoUpdateVersion != skipAutoUpdateVersion {
708+
if e.updateManager == nil && autoUpdateVersion != disableAutoUpdate {
712709
e.updateManager = updatemanager.NewUpdateManager(e.statusRecorder)
713710
e.updateManager.Start(e.ctx)
714-
} else if e.updateManager != nil && update.GetAutoUpdateVersion() == disableAutoUpdate {
711+
} else if e.updateManager != nil && autoUpdateVersion == disableAutoUpdate {
715712
e.updateManager.Stop()
716713
e.updateManager = nil
717714
}
718715
if e.updateManager != nil {
719-
e.updateManager.SetVersion(update.GetAutoUpdateVersion())
716+
e.updateManager.SetVersion(autoUpdateVersion)
720717
}
721718
}
719+
}
720+
721+
func (e *Engine) handleSync(update *mgmProto.SyncResponse) error {
722+
e.syncMsgMux.Lock()
723+
defer e.syncMsgMux.Unlock()
724+
725+
e.handleAutoUpdateVersion(update.AutoUpdateVersion)
722726
if update.GetNetbirdConfig() != nil {
723727
wCfg := update.GetNetbirdConfig()
724728
err := e.updateTURNs(wCfg.GetTurns())

0 commit comments

Comments
 (0)