Start config service sooner and don't copy mutex

desktop/app/app.go

@@ -9,7 +9,6 @@ import (
 	"net"
 	"net/http"
 	"os"
-	"strings"
 	"sync"
 	"sync/atomic"
 	"time"
@@ -46,9 +45,8 @@ import (
 )
 
 var (
-	log                = golog.LoggerFor("lantern-desktop.app")
-	startTime          = time.Now()
-	translationAppName = strings.ToUpper(common.DefaultAppName)
+	log       = golog.LoggerFor("lantern-desktop.app")
+	startTime = time.Now()
 )
 
 func init() {
@@ -78,18 +76,16 @@ type App struct {
 
 	flashlight *flashlight.Flashlight
 
-	issueReporter *issueReporter
-	authClient    auth.AuthClient
-	proClient     proclient.ProClient
+	authClient auth.AuthClient
+	proClient  proclient.ProClient
 
 	selectedTab Tab
 
 	connectionStatusCallbacks []func(isConnected bool)
 
 	// Websocket-related settings
-	websocketAddr   string
-	websocketServer *http.Server
-	ws              ws.UIChannel
+	websocketAddr string
+	ws            ws.UIChannel
 
 	cachedUserData sync.Map
 	plansCache     sync.Map
@@ -145,9 +141,12 @@ func NewAppWithFlags(flags flashlight.Flags, configDir string) *App {
 
 	log.Debugf("Using configdir: %v", configDir)
 
-	app.issueReporter = newIssueReporter(app)
 	app.translations.Set(os.DirFS("locale/translation"))
 
+	if e := app.configService.StartService(app.ws); e != nil {
+		app.Exit(fmt.Errorf("unable to register config service: %q", e))
+	}
+
 	return app
 }
 
@@ -169,7 +168,6 @@ func (app *App) Run(ctx context.Context) {
 		}
 		proClient := proclient.NewClient(fmt.Sprintf("https://%s", common.ProAPIHost), &webclient.Opts{
 			UserConfig: userConfig,
-
 		})
 		authClient := auth.NewClient(fmt.Sprintf("https://%s", common.DFBaseUrl), userConfig)
 
@@ -230,6 +228,7 @@ func (app *App) Run(ctx context.Context) {
 			func(category, action, label string) {},
 			flashlight.WithOnConfig(app.onConfigUpdate),
 			flashlight.WithOnProxies(app.onProxiesUpdate),
+			flashlight.WithOnSucceedingProxy(app.onSucceedingProxy),
 		)
 		if err != nil {
 			app.Exit(err)
@@ -285,11 +284,6 @@ func (app *App) beforeStart(ctx context.Context, listenAddr string) {
 		os.Exit(0)
 	}
 
-	if e := app.configService.StartService(app.ws); e != nil {
-		app.Exit(fmt.Errorf("unable to register config service: %q", e))
-		return
-	}
-
 	if e := app.settings.StartService(app.ws); e != nil {
 		app.Exit(fmt.Errorf("unable to register settings service: %q", e))
 		return
@@ -443,13 +437,12 @@ func (app *App) onConfigUpdate(cfg *config.Global, src config.Source) {
 func (app *App) onProxiesUpdate(proxies []dialer.ProxyDialer, src config.Source) {
 	log.Debugf("[Startup Desktop] Got proxies update from %v", src)
 	app.fetchedProxiesConfig.Store(true)
-	app.hasSucceedingProxy.Store(true)
 	app.sendConfigOptions()
 }
 
-func (app *App) onSucceedingProxy(succeeding bool) {
-	app.hasSucceedingProxy.Store(succeeding)
-	log.Debugf("[Startup Desktop] onSucceedingProxy %v", succeeding)
+func (app *App) onSucceedingProxy() {
+	app.hasSucceedingProxy.Store(true)
+	log.Debugf("[Startup Desktop] onSucceedingProxy")
 }
 
 // HasSucceedingProxy returns whether or not the app is currently configured with any succeeding proxies

desktop/app/config.go

@@ -61,7 +61,7 @@ func (s *configService) StartService(channel ws.UIChannel) (err error) {
 	return err
 }
 
-func (s *configService) sendConfigOptions(cfg ConfigOptions) {
+func (s *configService) sendConfigOptions(cfg *ConfigOptions) {
 	b, _ := json.Marshal(&cfg)
 	log.Debugf("Sending config options to client %s", string(b))
 	s.service.Out <- cfg
@@ -90,7 +90,7 @@ func (app *App) sendConfigOptions() {
 	log.Debugf("DEBUG: Devices: %s", string(devices))
 	log.Debugf("Expiration date: %s", app.settings.GetExpirationDate())
 
-	app.configService.sendConfigOptions(ConfigOptions{
+	app.configService.sendConfigOptions(&ConfigOptions{
 		DevelopmentMode:      common.IsDevEnvironment(),
 		AppVersion:           common.ApplicationVersion,
 		ReplicaAddr:          "",

desktop/app/sysproxy.go

@@ -61,7 +61,7 @@ func (app *App) SysProxyOff() error {
 	log.Debug("Force clearing system proxy directly, just in case")
 	addr, found := getProxyAddr()
 	if !found {
-		err := fmt.Errorf("Unable to find proxy address, can't force clear system proxy")
+		err := fmt.Errorf("unable to find proxy address, can't force clear system proxy")
 		op.FailIf(log.Error(err))
 		return err
 	}

desktop/app/ws.go

@@ -42,9 +42,3 @@ func (app *App) WebsocketAddr() string {
 	}
 	return app.websocketAddr
 }
-
-func (app *App) setWebsocketServer(server *http.Server) {
-	app.mu.Lock()
-	defer app.mu.Unlock()
-	app.websocketServer = server
-}