From 8ceb7775d776562c99cd9023e832011fbf891e7a Mon Sep 17 00:00:00 2001
From: root <dev@okcuu.ru>
Date: Fri, 1 May 2026 20:05:51 +0300
Subject: [PATCH] internal/gui: wire StartEngine/StopEngine to internal/engine
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Replaces the stub flag-toggle with a real engine.Engine. GetStatus
now reports the engine's actual state machine value. Stats remain
randomised in P2.1 — real bytes-counters land in P2.4 with the tray
UI.

Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>
---
 internal/gui/app.go | 62 +++++++++++++++++++++++++++++++++------------
 1 file changed, 46 insertions(+), 16 deletions(-)

diff --git a/internal/gui/app.go b/internal/gui/app.go
index fd65de5..61508d2 100644
--- a/internal/gui/app.go
+++ b/internal/gui/app.go
@@ -11,6 +11,7 @@ import (
 	"time"
 
 	"git.okcu.io/root/drover-go/internal/checker"
+	"git.okcu.io/root/drover-go/internal/engine"
 	"github.com/wailsapp/wails/v2/pkg/runtime"
 )
 
@@ -26,7 +27,7 @@ type App struct {
 	version string
 
 	mu        sync.Mutex
-	running   bool
+	eng       *engine.Engine
 	startedAt time.Time
 
 	// muCheck guards cancelCheck and checkDone.
@@ -172,46 +173,75 @@ func (a *App) CancelCheck() {
 	}
 }
 
-// StartEngine flips the proxy on. In the stub we just toggle the flag and
-// note the start time so GetStats can produce a believable uptime.
-func (a *App) StartEngine() error {
+// StartEngine initializes and brings up the engine with the given config.
+func (a *App) StartEngine(cfg Config) error {
 	a.mu.Lock()
 	defer a.mu.Unlock()
-	a.running = true
+	if a.eng != nil && a.eng.Status() == engine.StatusActive {
+		return nil
+	}
+	e, err := engine.New(engine.Config{
+		ProxyAddr: fmt.Sprintf("%s:%d", cfg.Host, cfg.Port),
+		UseAuth:   cfg.Auth,
+		Login:     cfg.Login,
+		Password:  cfg.Password,
+		Targets:   []string{"Discord.exe", "DiscordCanary.exe", "DiscordPTB.exe", "Update.exe"},
+	})
+	if err != nil {
+		runtime.EventsEmit(a.ctx, "engine:status", map[string]any{"running": false, "error": err.Error()})
+		return err
+	}
+	if err := e.Start(a.ctx); err != nil {
+		runtime.EventsEmit(a.ctx, "engine:status", map[string]any{"running": false, "error": err.Error()})
+		return err
+	}
+	a.eng = e
 	a.startedAt = time.Now()
 	runtime.EventsEmit(a.ctx, "engine:status", map[string]any{"running": true})
 	return nil
 }
 
-// StopEngine turns the proxy off.
+// StopEngine shuts down the engine.
 func (a *App) StopEngine() error {
 	a.mu.Lock()
 	defer a.mu.Unlock()
-	a.running = false
+	if a.eng == nil {
+		return nil
+	}
+	err := a.eng.Stop()
+	a.eng = nil
 	runtime.EventsEmit(a.ctx, "engine:status", map[string]any{"running": false})
-	return nil
+	return err
 }
 
-// GetStatus is read by the frontend on first paint to know whether to
-// show "Idle" or "Active".
+// GetStatus returns the current engine state and uptime.
 func (a *App) GetStatus() map[string]any {
 	a.mu.Lock()
 	defer a.mu.Unlock()
-	return map[string]any{
-		"running": a.running,
+	running := a.eng != nil && a.eng.Status() == engine.StatusActive
+	res := map[string]any{
+		"running": running,
 		"uptimeS": int(time.Since(a.startedAt).Seconds()),
 	}
+	if a.eng != nil {
+		res["state"] = string(a.eng.Status())
+		if err := a.eng.LastError(); err != nil {
+			res["error"] = err.Error()
+		}
+	}
+	return res
 }
 
-// statsLoop emits a stats event every second when the engine is running.
-// Numbers are random but stable enough to look real.
+// statsLoop emits a stats event every second when the engine is active.
+// Numbers are random but stable enough to look real. P2.4 will replace
+// with real counters from engine.Engine.
 func (a *App) statsLoop() {
 	r := rand.New(rand.NewSource(time.Now().UnixNano()))
 	tick := time.NewTicker(time.Second)
 	defer tick.Stop()
 	for range tick.C {
 		a.mu.Lock()
-		if !a.running || a.ctx == nil {
+		if a.eng == nil || a.eng.Status() != engine.StatusActive || a.ctx == nil {
 			a.mu.Unlock()
 			continue
 		}
@@ -222,7 +252,7 @@ func (a *App) statsLoop() {
 			"up":      r.Intn(50_000) + 5_000,   // bytes/sec out
 			"down":    r.Intn(500_000) + 50_000, // bytes/sec in
 			"tcp":     r.Intn(8) + 1,
-			"udp":     r.Intn(5) + 1,
+			"udp":     0, // P2.1 scope: no UDP yet
 			"uptimeS": uptime,
 		})
 	}