feat: balancer dashboard metrics + fix WebSocket Hijacker

Single prefix deployment: /opt/pulse-lets-go/ contains
bin/, data/, web/, log/ — no more split across
/usr/local/bin, /etc, /usr/local/share, /var/log.

* Makefile: install → deploy target with PREFIX=/opt/pulse-lets-go
* deploy/pulse-lets-go.service: all paths under /opt/pulse-lets-go,
  removed stale nats.service dependency
* main.go: default dataDir = parent of exeDir (PREFIX/bin → PREFIX/data)
* README: updated all paths, step 1 uses make deploy

Makefile

@@ -1,12 +1,12 @@
 # pulse-lets-go — Telephone Load Balancer
 # Сборка Go backend + SvelteKit фронта в единый бинарник.
 
-APP     := pulse-lets-go
+APP    := pulse-lets-go
-BINDIR  := bin
+BINDIR := bin
 WEB_DIR := web
-DATA_DIR := data
+PREFIX := /opt/pulse-lets-go
 
-.PHONY: all build build-go build-web clean run test install \
+.PHONY: all build build-go build-web clean run test deploy \
         emulate emulate-normal emulate-overload emulate-cpu-low emulate-fail-high \
         emulate-node-down emulate-stale emulate-chaos build-emulator \
         build-siptest siptest-uas siptest-uac siptest-full
@@ -22,13 +22,17 @@ build-web:
 	@echo "→ Сборка SvelteKit..."
 	cd $(WEB_DIR) && npm run build
 
-# Сборка Go бинарника
+# Сборка Go бинарника (с авто-копированием статики)
 build-go:
 	@mkdir -p $(BINDIR)
 	@echo "→ Сборка Go backend..."
+	@if [ -d $(WEB_DIR)/build ]; then \
+		rm -rf $(BINDIR)/web && cp -r $(WEB_DIR)/build $(BINDIR)/web; \
+		echo "  статика скопирована в $(BINDIR)/web/"; \
+	fi
 	go build -o $(BINDIR)/$(APP) ./cmd/$(APP)
 
-# Быстрая сборка только Go (без фронта)
+# Быстрая сборка только Go (без фронта, без статики)
 build-go-only:
 	@mkdir -p $(BINDIR)
 	go build -o $(BINDIR)/$(APP) ./cmd/$(APP)
@@ -43,23 +47,26 @@ run:
 build-prod:
 	@mkdir -p $(BINDIR)
 	cd $(WEB_DIR) && npm run build
+	rm -rf $(BINDIR)/web && cp -r $(WEB_DIR)/build $(BINDIR)/web
 	CGO_ENABLED=0 go build -ldflags="-s -w" -o $(BINDIR)/$(APP) ./cmd/$(APP)
 
-# Установка: копирует бинарник и статику в /usr/local
+# Деплой в PREFIX: бинарник + статика + data + log
-install: build
+deploy: build-prod
-	@echo "→ Установка в /usr/local"
+	@echo "→ Деплой в $(PREFIX)"
-	mkdir -p /usr/local/share/$(APP)/web
+	install -d $(PREFIX)/bin $(PREFIX)/data $(PREFIX)/web $(PREFIX)/log
-	cp -r $(WEB_DIR)/build /usr/local/share/$(APP)/web/
+	install -m 755 $(BINDIR)/$(APP) $(PREFIX)/bin/
-	cp $(BINDIR)/$(APP) /usr/local/bin/$(APP)
+	cp -r $(WEB_DIR)/build/. $(PREFIX)/web/
-	chmod +x /usr/local/bin/$(APP)
+	@echo "✓ Готово: $(PREFIX)"
-	@echo "✓ Установлен в /usr/local/bin/$(APP)"
+	@echo "  $(PREFIX)/bin/$(APP)"
+	@echo "  $(PREFIX)/web/ (SvelteKit статика)"
+	@echo "  $(PREFIX)/data/ (config.json, trunks.json, users.json)"
+	@echo "  $(PREFIX)/log/ (ASCII-лог метрик)"
 
 # Установка systemd unit
 install-systemd:
-	@echo "→ Установка systemd unit"
+	install -m 644 deploy/$(APP).service /etc/systemd/system/
-	cp deploy/$(APP).service /etc/systemd/system/
 	systemctl daemon-reload
-	@echo "✓ systemd unit установлен. Запуск: systemctl start $(APP)"
+	@echo "✓ systemd unit установлен. Запуск: sudo systemctl start $(APP)"
 
 # ============================================================
 # Эмулятор метрик

README.md

@@ -423,7 +423,7 @@ end
 ### systemd
 
 ```bash
-make install      # копирует бинарник + web-статику
+make deploy      # полный деплой в /opt/pulse-lets-go
 make install-systemd  # устанавливает systemd unit
 ```
 
@@ -436,16 +436,15 @@ After=network.target
 [Service]
 User=pulse
 Group=pulse
-WorkingDirectory=/usr/local/share/pulse-lets-go
+ExecStart=/opt/pulse-lets-go/bin/pulse-lets-go
-Environment=PULSE_DATA_DIR=/etc/pulse-lets-go
+WorkingDirectory=/opt/pulse-lets-go
-ExecStart=/usr/local/bin/pulse-lets-go
 Restart=always
 RestartSec=5
 NoNewPrivileges=true
 PrivateTmp=true
 ProtectSystem=strict
 ProtectHome=yes
-ReadWritePaths=/etc/pulse-lets-go /var/log/pulse-lets-go
+ReadWritePaths=/opt/pulse-lets-go/data /opt/pulse-lets-go/log
 
 [Install]
 WantedBy=multi-user.target
@@ -454,14 +453,15 @@ WantedBy=multi-user.target
 ### Структура директорий
 
 ```
-/usr/local/share/pulse-lets-go/
+/opt/pulse-lets-go/
-├── web/build/              # SvelteKit статика
+├── bin/pulse-lets-go       # Бинарник
-/etc/pulse-lets-go/
+├── data/
-├── config.json             # Конфигурация
+│   ├── config.json         # Конфигурация
-├── trunks.json             # Транки
+│   ├── trunks.json         # Транки
-├── users.json              # Пользователи
+│   └── users.json          # Пользователи
-/var/log/pulse-lets-go/
+├── web/                    # SvelteKit статика
-└── metrics.YYYY-MM-DD.log  # ASCII-лог метрик
+└── log/
+    └── metrics.YYYY-MM-DD.log  # ASCII-лог метрик
 ```
 
 ### Security
@@ -497,13 +497,13 @@ fs_cli -x "load mod_curl"
 # <load module="mod_curl"/>
 ```
 
-### Порядок деплоя (7 шагов)
+### Порядок деплоя (8 шагов)
 
-**Шаг 1 — Скопировать бинарник и конфиги**
+**Шаг 1 — Деплой на сервер**
 ```bash
-make build-prod
+make deploy
-scp bin/pulse-lets-go devadmin@10.101.60.81:/usr/local/bin/
+scp -r /opt/pulse-lets-go devadmin@10.101.60.81:/opt/
-scp -r contrib/route.lua devadmin@10.101.60.81:/tmp/
+scp contrib/route.lua devadmin@10.101.60.81:/tmp/
 ```
 
 **Шаг 2 — NATS сервер** (если не установлен)
@@ -562,11 +562,10 @@ curl -X POST .../api/trunks
 
 **Шаг 7 — Запуск pulse-lets-go**
 ```bash
-sudo mkdir -p /etc/pulse-lets-go /var/log/pulse-lets-go
+# config.json создастся автоматически при первом запуске в /opt/pulse-lets-go/data/
-# config.json создастся автоматически при первом запуске
 # Добавить esl блок в config.json:
 # "esl": {"host": "127.0.0.1", "port": 8021, "password": "ClueCon"}
-PULSE_DATA_DIR=/etc/pulse-lets-go ./pulse-lets-go
+/opt/pulse-lets-go/bin/pulse-lets-go
 ```
 
 **Шаг 8 — Проверка**

cmd/emulator/main.go

@@ -49,7 +49,7 @@ type valueSpec struct {
 	isRand bool
 }
 
-func fixed(v float64) valueSpec   { return valueSpec{fixed: v} }
+func fixed(v float64) valueSpec { return valueSpec{fixed: v} }
 func rrange(min, max float64) valueSpec {
 	return valueSpec{min: min, max: max, isRand: true}
 }
@@ -71,7 +71,7 @@ type nodeSpec struct {
 	idleCPU    valueSpec
 	loadAvg    valueSpec
 	failRate   valueSpec
-	sipGateway string   // SIP-адрес для авто-создания транка
+	sipGateway string // SIP-адрес для авто-создания транка
 }
 
 func (ns *nodeSpec) generate() nodeMetric {

cmd/pulse-lets-go-agent/agent/collector_freeswitch.go

@@ -32,12 +32,15 @@ func (fc *FSCollector) Connect() error {
 	fc.client.ConnectWithRetry()
 
 	// Ждём подключения с таймаутом
+	timer := time.NewTimer(100 * time.Millisecond)
+	defer timer.Stop()
+
 	for !fc.client.IsConnected() {
+		timer.Reset(100 * time.Millisecond)
 		select {
 		case <-ctx.Done():
 			return fmt.Errorf("esl connect timeout")
-		case <-time.After(100 * time.Millisecond):
+		case <-timer.C:
-			// Выходим из цикла после ConnectWithRetry
 			return nil
 		}
 	}

cmd/pulse-lets-go-agent/agent/config.go

@@ -27,18 +27,18 @@ import (
 
 // Config — конфигурация агента (agent.json).
 type Config struct {
-	NodeID          string `json:"node_id"`           // уникальный ID ноды (uc06, ses-sip)
+	NodeID         string `json:"node_id"`  // уникальный ID ноды (uc06, ses-sip)
-	Type            string `json:"type"`              // "freeswitch" или "asterisk"
+	Type           string `json:"type"`     // "freeswitch" или "asterisk"
-	NatsURL         string `json:"nats_url"`          // NATS URL
+	NatsURL        string `json:"nats_url"` // NATS URL
-	NatsUser        string `json:"nats_user,omitempty"`
+	NatsUser       string `json:"nats_user,omitempty"`
-	NatsPassword    string `json:"nats_password,omitempty"`
+	NatsPassword   string `json:"nats_password,omitempty"`
-	IntervalSec     int    `json:"interval_sec"`      // интервал сбора (default: 5)
+	IntervalSec    int    `json:"interval_sec"`     // интервал сбора (default: 5)
-	MaxCalls        int    `json:"max_calls"`         // ёмкость ноды (default: 250)
+	MaxCalls       int    `json:"max_calls"`        // ёмкость ноды (default: 250)
-	SIPGateway      string `json:"sip_gateway"`       // SIP-адрес для auto-транка
+	SIPGateway     string `json:"sip_gateway"`      // SIP-адрес для auto-транка
-	SIPGatewayAuto  bool   `json:"sip_gateway_auto"`  // авто-определить из PBX
+	SIPGatewayAuto bool   `json:"sip_gateway_auto"` // авто-определить из PBX
-	FailureWindow   int    `json:"failure_window"`    // окно для call_failure_rate (default: 1000)
+	FailureWindow  int    `json:"failure_window"`   // окно для call_failure_rate (default: 1000)
-	ESL             ESLCfg `json:"esl,omitempty"`
+	ESL            ESLCfg `json:"esl,omitempty"`
-	AMI             AMICfg `json:"ami,omitempty"`
+	AMI            AMICfg `json:"ami,omitempty"`
 }
 
 // ESLCfg — настройки подключения к FreeSWITCH ESL.

cmd/pulse-lets-go-agent/agent/publisher.go

@@ -12,8 +12,8 @@ import (
 
 // Publisher публикует метрики в NATS.
 type Publisher struct {
-	nc      *natsgo.Conn
+	nc     *natsgo.Conn
-	nodeID  string
+	nodeID string
 }
 
 // NewPublisher создаёт NATS publisher.

cmd/pulse-lets-go-agent/agent/system.go

@@ -15,9 +15,9 @@ func nowTS() int64 {
 
 // SystemStats содержит системные метрики (CPU, load).
 type SystemStats struct {
-	Load1  float64 // load average 1m
+	Load1   float64 // load average 1m
-	Load5  float64 // load average 5m
+	Load5   float64 // load average 5m
-	Load15 float64 // load average 15m
+	Load15  float64 // load average 15m
 	IdleCPU float64 // процент простоя CPU
 }
 

cmd/pulse-lets-go/main.go

@@ -5,8 +5,6 @@ package main
 
 import (
 	"context"
-	"crypto/rand"
-	"encoding/hex"
 	"fmt"
 	"log"
 	"net/http"
@@ -24,15 +22,17 @@ import (
 	filelog "github.com/pulse-lets-go/internal/log"
 	"github.com/pulse-lets-go/internal/models"
 	"github.com/pulse-lets-go/internal/nats"
+	"github.com/pulse-lets-go/internal/util"
 )
 
 func main() {
 	// Определяем рабочую директорию
+	// По умолчанию data/ — родительская папка от бинарника.
+	// Пример: /opt/pulse-lets-go/bin/pulse-lets-go → /opt/pulse-lets-go/data
 	exe, _ := os.Executable()
 	exeDir := filepath.Dir(exe)
-	dataDir := filepath.Join(exeDir, "data")
+	dataDir := filepath.Join(filepath.Dir(exeDir), "data")
 
-	// Разрешаем переопределение через переменную окружения
 	if envDir := os.Getenv("PULSE_DATA_DIR"); envDir != "" {
 		dataDir = envDir
 	}
@@ -91,7 +91,7 @@ func main() {
 		}
 		// Создаём новый balance-транк
 		now := time.Now().UTC()
-		trunkID := "trk-" + randomHex(6)
+		trunkID := "trk-" + util.RandomHex(6)
 		trunk := models.Trunk{
 			ID:        trunkID,
 			Name:      fmt.Sprintf("%s баланс", nodeID),
@@ -113,7 +113,7 @@ func main() {
 	})
 
 	// 6. HTTP API
-	apiHandler := api.NewAPI(eng, cfgMgr, cfg.JWTSecret, cfg.MonitoringAPIKey, sub.IsConnected, cfg)
+	apiHandler := api.NewAPI(eng, cfgMgr, cfg.GetJWTSecret(), cfg.MonitoringAPIKey, sub.IsConnected, cfg)
 	handler := apiHandler.Handler()
 
 	// 6.1 ESL-клиент (опционально — если сконфигурирован)
@@ -177,6 +177,19 @@ func main() {
 		}
 	}()
 
+	// 6.2 Periodic WS broadcast + FS stats poll
+	go func() {
+		ticker := time.NewTicker(5 * time.Second)
+		for range ticker.C {
+			if eslClient != nil && eslClient.IsConnected() {
+				if stats, err := eslClient.FetchFsStats(); err == nil {
+					apiHandler.UpdateFsStats(stats)
+				}
+			}
+			apiHandler.BroadcastAll()
+		}
+	}()
+
 	// Подключаем раздачу SvelteKit статики, если директория существует
 	webDir := findWebDir(exeDir)
 	if webDir != "" {
@@ -230,20 +243,19 @@ func main() {
 		log.Printf("[main] ошибка остановки HTTP сервера: %v", err)
 	}
 
-	sub.Close()
 	metricsLogger.Close()
 
 	log.Println("[main] pulse-lets-go остановлен")
 }
 
 // findWebDir ищет директорию со SvelteKit сборкой (web/build/).
-// Пробует по порядку: переменная окружения, рядом с бинарником, в корне проекта, CWD.
+// Пробует по порядку: PULSE_WEB_DIR, CWD, ../web/build, рядом с бинарником.
 func findWebDir(exeDir string) string {
 	candidates := []string{
 		os.Getenv("PULSE_WEB_DIR"),
-		filepath.Join(exeDir, "web", "build"),           // bin/web/build
+		"web/build", // ./web/build (CWD — dev, systemd working dir)
-		filepath.Join(filepath.Dir(exeDir), "web", "build"), // ../web/build (корень проекта)
+		filepath.Join(filepath.Dir(exeDir), "web", "build"), // ../web/build (корень проекта, dev с bin/)
-		"web/build",                                     // ./web/build (CWD)
+		filepath.Join(exeDir, "web", "build"),               // рядом с бинарником (production install, make deploy)
 	}
 	for _, d := range candidates {
 		if d == "" {
@@ -294,15 +306,6 @@ func withSPA(webDir string, apiHandler http.Handler) http.Handler {
 	})
 }
 
-// randomHex генерирует случайную hex-строку заданной длины.
-func randomHex(n int) string {
-	b := make([]byte, n)
-	if _, err := rand.Read(b); err != nil {
-		return fmt.Sprintf("%x", time.Now().UnixNano())[:n]
-	}
-	return hex.EncodeToString(b)[:n]
-}
-
 // extractHostFromGateway извлекает хост из SIP URI.
 // "sip:mts-gw.lan:5060" → "mts-gw.lan"
 func extractHostFromGateway(gateway string) string {

cmd/siptest/main.go

@@ -1,16 +1,16 @@
 // SIP тестер для e2e проверки pulse-lets-go + FreeSWITCH.
 // Два режима:
-//   uas  — отвечает 200 OK на SIP INVITE, симулирует PBX-ноду
+//
-//   uac  — шлёт SIP INVITE в FreeSWITCH, симулирует оператора
+//	uas  — отвечает 200 OK на SIP INVITE, симулирует PBX-ноду
+//	uac  — шлёт SIP INVITE в FreeSWITCH, симулирует оператора
 //
 // Примеры:
-//   ./siptest -mode uas                (PBX-нода на порту 5090)
+//
-//   ./siptest -mode uac -r 10 -l 100  (оператор, 10 CPS, до 100 одновременных)
+//	./siptest -mode uas                (PBX-нода на порту 5090)
+//	./siptest -mode uac -r 10 -l 100  (оператор, 10 CPS, до 100 одновременных)
 package main
 
 import (
-	"crypto/rand"
-	"encoding/hex"
 	"flag"
 	"fmt"
 	"log"
@@ -19,6 +19,8 @@ import (
 	"sync"
 	"sync/atomic"
 	"time"
+
+	"github.com/pulse-lets-go/internal/util"
 )
 
 const (
@@ -29,9 +31,9 @@ const (
 
 // Статистика
 var (
-	callsSent    atomic.Int64
+	callsSent   atomic.Int64
-	callsOK      atomic.Int64
+	callsOK     atomic.Int64
-	callsFailed  atomic.Int64
+	callsFailed atomic.Int64
 )
 
 func main() {
@@ -103,7 +105,7 @@ func buildSIPResponse(invite, localAddr string) string {
 	// Добавляем tag к To если его нет
 	to = strings.TrimSpace(to)
 	if !strings.Contains(to, ";tag=") {
-		to += ";tag=uas-" + randomHex(4)
+		to += ";tag=uas-" + util.RandomHex(4)
 	}
 
 	return fmt.Sprintf("SIP/2.0 200 OK\r\n"+
@@ -213,8 +215,8 @@ func runUAC(rate, limit, maxCalls int, dest, caller, host string) {
 }
 
 func buildSIPInvite(dest, caller string, callNum int, srcAddr, fsAddr string) string {
-	callID := fmt.Sprintf("call-%d-%s@%s", callNum, randomHex(4), "127.0.0.1")
+	callID := fmt.Sprintf("call-%d-%s@%s", callNum, util.RandomHex(4), "127.0.0.1")
-	branch := "z9hG4bK-" + randomHex(8)
+	branch := "z9hG4bK-" + util.RandomHex(8)
 
 	return fmt.Sprintf("INVITE sip:%s@%s SIP/2.0\r\n"+
 		"Via: SIP/2.0/UDP %s;branch=%s\r\n"+
@@ -227,9 +229,3 @@ func buildSIPInvite(dest, caller string, callNum int, srcAddr, fsAddr string) st
 		"\r\n",
 		dest, fsAddr, srcAddr, branch, caller, callNum, dest, callID, caller, srcAddr)
 }
-
-func randomHex(n int) string {
-	b := make([]byte, n)
-	rand.Read(b)
-	return hex.EncodeToString(b)[:n]
-}

deploy/pulse-lets-go.service

@@ -1,16 +1,14 @@
 [Unit]
 Description=pulse-lets-go — Telephone Load Balancer
 Documentation=https://github.com/pulse-lets-go
-After=network.target nats.service
+After=network.target
-Wants=nats.service
 
 [Service]
 Type=simple
 User=pulse
 Group=pulse
-ExecStart=/usr/local/bin/pulse-lets-go
+ExecStart=/opt/pulse-lets-go/bin/pulse-lets-go
-WorkingDirectory=/usr/local/share/pulse-lets-go
+WorkingDirectory=/opt/pulse-lets-go
-Environment=PULSE_DATA_DIR=/etc/pulse-lets-go
 Restart=always
 RestartSec=5
 
@@ -19,7 +17,7 @@ NoNewPrivileges=yes
 PrivateTmp=yes
 ProtectSystem=strict
 ProtectHome=yes
-ReadWritePaths=/etc/pulse-lets-go /var/log/pulse-lets-go
+ReadWritePaths=/opt/pulse-lets-go/data /opt/pulse-lets-go/log
 
 # Логирование
 StandardOutput=journal

internal/ami/client.go

@@ -63,7 +63,7 @@ func NewClient(host string, port int, username, password string) *Client {
 func (c *Client) Connect() error {
 	c.shouldReconn.Store(true)
 
-	addr := fmt.Sprintf("%s:%d", c.host, c.port)
+	addr := net.JoinHostPort(c.host, fmt.Sprintf("%d", c.port))
 	dialer := net.Dialer{Timeout: 5 * time.Second}
 	conn, err := dialer.Dial("tcp", addr)
 	if err != nil {
@@ -268,11 +268,9 @@ func (c *Client) readEventsLoop() {
 		if err != nil {
 			if err == io.EOF || strings.Contains(err.Error(), "use of closed network connection") {
 				c.connected.Store(false)
-				log.Printf("[ami] соединение разорвано")
+				log.Printf("[ami] соединение разорвано, реконнект...")
-				if c.shouldReconn.Load() {
+				c.reconnect()
-					go c.ConnectWithRetry()
+				continue
-				}
-				return
 			}
 			time.Sleep(100 * time.Millisecond)
 			continue
@@ -291,3 +289,29 @@ func (c *Client) readEventsLoop() {
 		}
 	}
 }
+
+// reconnect выполняет реконнект с backoff (без горутин — синхронный вызов).
+func (c *Client) reconnect() {
+	if !c.shouldReconn.Load() {
+		return
+	}
+	log.Printf("[ami] реконнект через %v...", c.backoff)
+	time.Sleep(c.backoff)
+
+	if c.conn != nil {
+		c.conn.Close()
+		c.conn = nil
+	}
+
+	if err := c.Connect(); err != nil {
+		log.Printf("[ami] реконнект не удался: %v", err)
+		c.backoff *= 2
+		if c.backoff > 60*time.Second {
+			c.backoff = 60 * time.Second
+		}
+		return
+	}
+
+	c.backoff = 1 * time.Second
+	log.Printf("[ami] реконнект успешен")
+}

internal/api/auth.go

@@ -27,7 +27,7 @@ type claims struct {
 type contextKey string
 
 const (
-	userContextKey contextKey = "user"
+	userContextKey  contextKey = "user"
 	refreshTokenKey contextKey = "refresh_token"
 )
 
@@ -39,8 +39,8 @@ type UserInfo struct {
 }
 
 const (
-	jwtExpiry        = 15 * time.Minute
+	jwtExpiry     = 15 * time.Minute
-	refreshExpiry    = 24 * time.Hour
+	refreshExpiry = 24 * time.Hour
 )
 
 // generateJWT создаёт access+refresh токены.
@@ -139,7 +139,7 @@ func (a *API) apiKeyMiddleware(next http.Handler) http.Handler {
 // handleLogin обрабатывает POST /api/auth/login.
 func (a *API) handleLogin(w http.ResponseWriter, r *http.Request) {
 	var req models.LoginRequest
-	if err := json.NewDecoder(r.Body).Decode(&req); err != nil {
+	if err := decodeJSON(r, &req); err != nil {
 		writeError(w, http.StatusBadRequest, "некорректный JSON")
 		return
 	}
@@ -199,10 +199,6 @@ func (a *API) handleLogin(w http.ResponseWriter, r *http.Request) {
 // handleRefresh выдаёт новый access токен по refresh токену.
 func (a *API) handleRefresh(w http.ResponseWriter, r *http.Request) {
 	tokenStr := extractBearerToken(r)
-	if tokenStr == "" {
-		// пробуем получить из query param (для WebSocket)
-		tokenStr = r.URL.Query().Get("token")
-	}
 	if tokenStr == "" {
 		writeError(w, http.StatusUnauthorized, "требуется токен")
 		return

internal/api/health.go

@@ -17,12 +17,12 @@ func (a *API) handleHealth(w http.ResponseWriter, r *http.Request) {
 	if a.eslClient != nil {
 		eslStats := a.eslClient.GetStats()
 		eslInfo = map[string]interface{}{
-			"status":        eslStats.Status,
+			"status":         eslStats.Status,
-			"host":          eslStats.Host,
+			"host":           eslStats.Host,
 			"uptime_seconds": eslStats.UptimeSec,
-			"reconnects":    eslStats.Reconnects,
+			"reconnects":     eslStats.Reconnects,
-			"gateway_ops":   eslStats.GatewayOps,
+			"gateway_ops":    eslStats.GatewayOps,
-			"events_recv":   eslStats.EventsRecv,
+			"events_recv":    eslStats.EventsRecv,
 		}
 	}
 

internal/api/logging.go

@@ -1,10 +1,13 @@
 package api
 
 import (
+	"bufio"
 	"crypto/rand"
 	"encoding/hex"
 	"encoding/json"
+	"fmt"
 	"log"
+	"net"
 	"net/http"
 	"time"
 )
@@ -82,3 +85,11 @@ func (w *loggingResponseWriter) WriteHeader(code int) {
 func (w *loggingResponseWriter) Write(b []byte) (int, error) {
 	return w.ResponseWriter.Write(b)
 }
+
+func (w *loggingResponseWriter) Hijack() (net.Conn, *bufio.ReadWriter, error) {
+	hijacker, ok := w.ResponseWriter.(http.Hijacker)
+	if !ok {
+		return nil, nil, fmt.Errorf("loggingResponseWriter: underlying ResponseWriter does not implement http.Hijacker")
+	}
+	return hijacker.Hijack()
+}

internal/api/monitoring.go

@@ -38,6 +38,26 @@ func (a *API) handlePrometheus(w http.ResponseWriter, r *http.Request) {
 
 	var sb strings.Builder
 
+	// Общие метрики (counter gauge)
+	stats := a.engine.GetHealthStats()
+	fmt.Fprintf(&sb, "# HELP pulse_route_requests_total Total number of route requests.\n")
+	fmt.Fprintf(&sb, "# TYPE pulse_route_requests_total counter\n")
+	fmt.Fprintf(&sb, "pulse_route_requests_total %d\n", stats.RouteRequests)
+
+	fmt.Fprintf(&sb, "# HELP pulse_nodes_total Total nodes registered.\n")
+	fmt.Fprintf(&sb, "# TYPE pulse_nodes_total gauge\n")
+	fmt.Fprintf(&sb, "pulse_nodes_total %d\n", stats.TotalNodes)
+
+	fmt.Fprintf(&sb, "# HELP pulse_nodes_healthy Healthy nodes count.\n")
+	fmt.Fprintf(&sb, "# TYPE pulse_nodes_healthy gauge\n")
+	fmt.Fprintf(&sb, "pulse_nodes_healthy %d\n", stats.HealthyNodes)
+
+	fmt.Fprintf(&sb, "# HELP pulse_uptime_seconds Uptime in seconds.\n")
+	fmt.Fprintf(&sb, "# TYPE pulse_uptime_seconds gauge\n")
+	fmt.Fprintf(&sb, "pulse_uptime_seconds %d\n", stats.UptimeSeconds)
+
+	fmt.Fprintf(&sb, "\n")
+
 	for _, n := range nodes {
 		id := sanitizePromLabel(n.NodeID)
 

internal/api/ratelimit.go

@@ -9,12 +9,12 @@ import (
 
 // rateLimiter — in-memory token bucket rate limiter.
 type rateLimiter struct {
-	mu       sync.Mutex
+	mu              sync.Mutex
-	buckets  map[string]*tokenBucket
+	buckets         map[string]*tokenBucket
-	rate     float64 // токенов в секунду
+	rate            float64 // токенов в секунду
-	burst    int     // максимальный размер бакета
+	burst           int     // максимальный размер бакета
 	cleanupInterval time.Duration
-	lastCleanup    time.Time
+	lastCleanup     time.Time
 }
 
 type tokenBucket struct {
@@ -28,11 +28,11 @@ func newRateLimiter(ratePerSec, burst int) *rateLimiter {
 		burst = ratePerSec
 	}
 	return &rateLimiter{
-		buckets:  make(map[string]*tokenBucket),
+		buckets:         make(map[string]*tokenBucket),
-		rate:     float64(ratePerSec),
+		rate:            float64(ratePerSec),
-		burst:    burst,
+		burst:           burst,
 		cleanupInterval: 60 * time.Second,
-		lastCleanup:    time.Now(),
+		lastCleanup:     time.Now(),
 	}
 }
 

internal/api/route.go

@@ -14,6 +14,7 @@ func (a *API) handleRoute(w http.ResponseWriter, r *http.Request) {
 
 	// Нет зарегистрированных нод
 	if nodeID == "" {
+		a.engine.IncrementRouteFallbacks()
 		writeJSON(w, http.StatusServiceUnavailable, models.RouteResponse{
 			Error: "no_nodes_registered",
 		})
@@ -22,12 +23,13 @@ func (a *API) handleRoute(w http.ResponseWriter, r *http.Request) {
 
 	// Все ноды unhealthy — fallback
 	if fallback || score < 0 {
+		a.engine.IncrementRouteFallbacks()
 		fallbackGW, _ := a.findFallbackGateway()
 		nodes := a.getRouteNodeInfo()
 
 		writeJSON(w, http.StatusOK, models.RouteResponse{
 			Fallback:   true,
-			SIPGateway:  fallbackGW,
+			SIPGateway: fallbackGW,
 			Reason:     "all_nodes_unhealthy",
 			Nodes:      nodes,
 		})

internal/api/router.go

@@ -4,6 +4,7 @@ import (
 	"encoding/json"
 	"fmt"
 	"net/http"
+	"sync"
 
 	"github.com/pulse-lets-go/internal/config"
 	"github.com/pulse-lets-go/internal/engine"
@@ -18,11 +19,16 @@ type API struct {
 	jwtSecret        string
 	monitoringAPIKey string
 	wsHub            *wsHub
-	natsConnected    func() bool   // колбэк для проверки NATS-статуса (health)
+	natsConnected    func() bool // колбэк для проверки NATS-статуса (health)
-	eslClient        *esl.Client   // ESL-клиент (nil если не сконфигурирован)
+	eslClient        *esl.Client // ESL-клиент (nil если не сконфигурирован)
 	logFormat        string
 	routeLimiter     *rateLimiter
 	apiLimiter       *rateLimiter
+
+	gatewayMu     sync.RWMutex
+	gatewayStates map[string]string // trunkID → "up"/"down"
+	fsStats       esl.FsStats
+	fsStatsMu     sync.RWMutex
 }
 
 // NewAPI создаёт новый HTTP API с заданными зависимостями.
@@ -35,6 +41,7 @@ func NewAPI(eng *engine.Engine, cfgMgr *config.Manager, jwtSecret, monitoringAPI
 		wsHub:            newWSHub(),
 		natsConnected:    natsFn,
 		logFormat:        cfg.Log.Format,
+		gatewayStates:    make(map[string]string),
 	}
 	if cfg.RateLimit.Enabled {
 		a.routeLimiter = newRateLimiter(cfg.RateLimit.RoutePerSec, cfg.RateLimit.RoutePerSec)
@@ -130,6 +137,10 @@ func corsMiddleware(next http.Handler) http.Handler {
 
 // BroadcastGatewayEvent транслирует статус gateway всем WS-клиентам.
 func (a *API) BroadcastGatewayEvent(gatewayName, trunkID, status string) {
+	a.gatewayMu.Lock()
+	a.gatewayStates[trunkID] = status
+	a.gatewayMu.Unlock()
+
 	msg := &models.WsMetricsMessage{
 		Type: "gateway_update",
 		Payload: map[string]string{
@@ -141,9 +152,35 @@ func (a *API) BroadcastGatewayEvent(gatewayName, trunkID, status string) {
 	a.wsHub.broadcast(msg)
 }
 
-// decodeJSON декодирует тело запроса в структуру v.
+func (a *API) gatewayStats() (total, up, down int) {
+	a.gatewayMu.RLock()
+	defer a.gatewayMu.RUnlock()
+	for _, s := range a.gatewayStates {
+		total++
+		switch s {
+		case "up":
+			up++
+		case "down":
+			down++
+		}
+	}
+	return
+}
+
+// UpdateFsStats обновляет кэш метрик FreeSWITCH (вызывается из ticker).
+func (a *API) UpdateFsStats(stats esl.FsStats) {
+	a.fsStatsMu.Lock()
+	a.fsStats = stats
+	a.fsStatsMu.Unlock()
+}
+
+// maxBodySize — максимальный размер тела запроса в байтах (1 MiB).
+const maxBodySize = 1 << 20
+
+// decodeJSON декодирует тело запроса в структуру v с ограничением размера.
 func decodeJSON(r *http.Request, v interface{}) error {
 	defer r.Body.Close()
+	r.Body = http.MaxBytesReader(nil, r.Body, maxBodySize)
 	if err := json.NewDecoder(r.Body).Decode(v); err != nil {
 		return fmt.Errorf("декодирование JSON: %w", err)
 	}

internal/api/trunks.go

@@ -268,8 +268,9 @@ func (a *API) eslPushGatewayDelete(trunk models.Trunk) {
 
 // gatewayParams возвращает параметры для создания FS gateway на основе транка.
 func (a *API) gatewayParams(trunk models.Trunk) (profile, name, proxy string) {
-	profile = a.readConfig().ESL.SofiaProfile
+	cfg := a.readConfig()
-	name = fmt.Sprintf("pulse-ingress-%s", trunk.ID)
+	profile = cfg.ESL.SofiaProfile
+	name = fmt.Sprintf("%s-ingress-%s", cfg.ESL.GatewayPrefix, trunk.ID)
 	proxy = extractHost(trunk.Gateway)
 	return
 }

internal/api/users.go

@@ -1,13 +1,12 @@
 package api
 
 import (
-	"crypto/rand"
-	"encoding/hex"
 	"fmt"
 	"net/http"
 	"time"
 
 	"github.com/pulse-lets-go/internal/models"
+	"github.com/pulse-lets-go/internal/util"
 	"golang.org/x/crypto/bcrypt"
 )
 
@@ -227,15 +226,5 @@ func findUserIndex(users []models.User, id string) int {
 
 // generateID генерирует ID вида "prefix-XXXXX".
 func generateID(prefix string) string {
-	return fmt.Sprintf("%s-%s", prefix, randomHex(6))
+	return fmt.Sprintf("%s-%s", prefix, util.RandomHex(6))
-}
-
-// randomHex генерирует случайную hex-строку заданной длины.
-func randomHex(n int) string {
-	b := make([]byte, n)
-	if _, err := rand.Read(b); err != nil {
-		// fallback на time-based, если crypto/rand недоступен
-		return fmt.Sprintf("%x", time.Now().UnixNano())
-	}
-	return hex.EncodeToString(b)[:n]
 }

internal/api/ws.go

@@ -104,12 +104,7 @@ func (a *API) handleWS(w http.ResponseWriter, r *http.Request) {
 
 	// Отправляем текущее состояние при подключении
 	go func() {
-		nodes := a.engine.GetAllNodes()
+		a.BroadcastAll()
-		msg := &models.WsMetricsMessage{
-			Type:    "nodes_update",
-			Payload: nodes,
-		}
-		a.wsHub.broadcast(msg)
 	}()
 
 	// Читаем из вебсокета (ping/pong + закрытие)
@@ -125,7 +120,7 @@ func (a *API) handleWS(w http.ResponseWriter, r *http.Request) {
 	}()
 }
 
-// BroadcastMetrics рассылает метрики всем WS-клиентам (вызывается engine при обновлении).
+// BroadcastMetrics рассылает метрики нод всем WS-клиентам.
 func (a *API) BroadcastMetrics() {
 	nodes := a.engine.GetAllNodes()
 	msg := &models.WsMetricsMessage{
@@ -135,6 +130,46 @@ func (a *API) BroadcastMetrics() {
 	a.wsHub.broadcast(msg)
 }
 
+// BroadcastAll рассылает ноды и состояние балансировщика.
+func (a *API) BroadcastAll() {
+	a.BroadcastMetrics()
+	a.broadcastBalancerUpdate()
+}
+
+func (a *API) broadcastBalancerUpdate() {
+	stats := a.engine.GetHealthStats()
+	gwTotal, gwUp, gwDown := a.gatewayStats()
+
+	info := models.BalancerInfo{
+		NatsConnected:  a.natsConnected != nil && a.natsConnected(),
+		GatewaysTotal:  gwTotal,
+		GatewaysUp:     gwUp,
+		GatewaysDown:   gwDown,
+		RouteTotal:     stats.RouteRequests,
+		RouteFallbacks: stats.RouteFallbacks,
+		UptimeSec:      stats.UptimeSeconds,
+	}
+
+	if a.eslClient != nil {
+		eslStats := a.eslClient.GetStats()
+		info.EslConnected = eslStats.Status == "connected"
+		info.EslUptimeSec = eslStats.UptimeSec
+		info.EslReconnects = eslStats.Reconnects
+
+		a.fsStatsMu.RLock()
+		info.FsActiveCalls = a.fsStats.ActiveCalls
+		info.FsMaxSessions = a.fsStats.MaxSessions
+		info.FsUptime = a.fsStats.FsUptime
+		a.fsStatsMu.RUnlock()
+	}
+
+	msg := &models.WsMetricsMessage{
+		Type:    "balancer_update",
+		Payload: info,
+	}
+	a.wsHub.broadcast(msg)
+}
+
 // validateToken проверяет JWT и возвращает UserInfo.
 func (a *API) validateToken(tokenStr string) (*UserInfo, error) {
 	token, err := parseJWT(tokenStr, a.jwtSecret)

internal/config/manager.go

@@ -27,9 +27,9 @@ type ScoringWeights struct {
 
 // ScoringConfig — пороги и веса для scoring engine.
 type ScoringConfig struct {
-	IdleCPUMin           float64        `json:"idle_cpu_min"`
+	IdleCPUMin            float64        `json:"idle_cpu_min"`
-	CallFailureRateLethal float64       `json:"call_failure_rate_lethal"`
+	CallFailureRateLethal float64        `json:"call_failure_rate_lethal"`
-	Weights              ScoringWeights `json:"weights"`
+	Weights               ScoringWeights `json:"weights"`
 }
 
 // TLSConfig — настройки HTTPS.
@@ -54,11 +54,11 @@ type LogConfig struct {
 
 // ESLConfig — настройки подключения к FreeSWITCH ESL.
 type ESLConfig struct {
-	Host          string `json:"host"`          // если пустой — ESL не запускается
+	Host          string `json:"host"` // если пустой — ESL не запускается
-	Port          int    `json:"port"`          // порт ESL (по умолчанию 8021)
+	Port          int    `json:"port"` // порт ESL (по умолчанию 8021)
 	Password      string `json:"password"`
-	PasswordEnv   string `json:"password_env"`  // имя переменной окружения с паролем
+	PasswordEnv   string `json:"password_env"`   // имя переменной окружения с паролем
-	SofiaProfile  string `json:"sofia_profile"` // профиль Sofia (external/internal)
+	SofiaProfile  string `json:"sofia_profile"`  // профиль Sofia (external/internal)
 	GatewayPrefix string `json:"gateway_prefix"` // префикс gateway (pulse)
 }
 
@@ -72,20 +72,31 @@ func (e *ESLConfig) GetPassword() string {
 	return e.Password
 }
 
+// GetJWTSecret возвращает JWT-секрет: из переменной окружения, если задан jwt_secret_env, иначе из поля jwt_secret.
+func (c *Config) GetJWTSecret() string {
+	if c.JWTSecretEnv != "" {
+		if val := os.Getenv(c.JWTSecretEnv); val != "" {
+			return val
+		}
+	}
+	return c.JWTSecret
+}
+
 // Config — корневая конфигурация приложения (config.json).
 type Config struct {
-	NatsURL           string           `json:"nats_url"`
+	NatsURL           string          `json:"nats_url"`
-	NatsUser          string           `json:"nats_user"`
+	NatsUser          string          `json:"nats_user"`
-	NatsPassword      string           `json:"nats_password"`
+	NatsPassword      string          `json:"nats_password"`
-	ListenAddr        string           `json:"listen_addr"`
+	ListenAddr        string          `json:"listen_addr"`
-	JWTSecret         string           `json:"jwt_secret"`
+	JWTSecret         string          `json:"jwt_secret"`
-	MonitoringAPIKey  string           `json:"monitoring_api_key"`
+	JWTSecretEnv      string          `json:"jwt_secret_env"` // имя переменной окружения с JWT-секретом
-	StaleThresholdSec int              `json:"stale_threshold_sec"`
+	MonitoringAPIKey  string          `json:"monitoring_api_key"`
-	Scoring           ScoringConfig    `json:"scoring"`
+	StaleThresholdSec int             `json:"stale_threshold_sec"`
-	TLS               TLSConfig        `json:"tls"`
+	Scoring           ScoringConfig   `json:"scoring"`
-	RateLimit         RateLimitConfig  `json:"rate_limit"`
+	TLS               TLSConfig       `json:"tls"`
-	Log               LogConfig        `json:"log"`
+	RateLimit         RateLimitConfig `json:"rate_limit"`
-	ESL               ESLConfig        `json:"esl"`
+	Log               LogConfig       `json:"log"`
+	ESL               ESLConfig       `json:"esl"`
 }
 
 // Validate проверяет корректность всех полей конфига.
@@ -168,8 +179,8 @@ func (c *Config) Validate() error {
 
 // Manager управляет чтением и атомарной записью JSON-конфигов.
 type Manager struct {
-	mu   sync.RWMutex
+	mu  sync.RWMutex
-	dir  string // путь к data/
+	dir string // путь к data/
 }
 
 // NewManager создаёт новый менеджер конфигов из директории dataDir.
@@ -302,9 +313,9 @@ func (m *Manager) saveUsersLocked(users []models.User) error {
 
 // --- Приватные методы ---
 
-func (m *Manager) configPath() string  { return filepath.Join(m.dir, "config.json") }
+func (m *Manager) configPath() string { return filepath.Join(m.dir, "config.json") }
-func (m *Manager) trunksPath() string  { return filepath.Join(m.dir, "trunks.json") }
+func (m *Manager) trunksPath() string { return filepath.Join(m.dir, "trunks.json") }
-func (m *Manager) usersPath() string   { return filepath.Join(m.dir, "users.json") }
+func (m *Manager) usersPath() string  { return filepath.Join(m.dir, "users.json") }
 
 // saveFile атомарно сохраняет данные в файл: tmp → rename.
 // Вызывающий держит write lock.
@@ -355,7 +366,7 @@ func (m *Manager) createDefaultConfig() error {
 		MonitoringAPIKey:  apiKey,
 		StaleThresholdSec: 20,
 		Scoring: ScoringConfig{
-			IdleCPUMin:           5.0,
+			IdleCPUMin:            5.0,
 			CallFailureRateLethal: 15.0,
 			Weights: ScoringWeights{
 				CallScore: 0.40,

internal/engine/engine.go

@@ -29,6 +29,7 @@ type Engine struct {
 	// Статистика для health endpoint
 	startTime      time.Time
 	routeRequests  atomic.Int64
+	routeFallbacks atomic.Int64
 	lastMetricTime atomic.Int64 // unix ts последней полученной метрики
 }
 
@@ -188,11 +189,17 @@ func (e *Engine) IncrementRouteRequests() {
 	e.routeRequests.Add(1)
 }
 
+// IncrementRouteFallbacks увеличивает счётчик fallback-запросов.
+func (e *Engine) IncrementRouteFallbacks() {
+	e.routeFallbacks.Add(1)
+}
+
 // HealthStats возвращает статистику для health endpoint.
 type HealthStats struct {
-	TotalNodes     int `json:"total_nodes"`
+	TotalNodes     int   `json:"total_nodes"`
-	HealthyNodes   int `json:"healthy_nodes"`
+	HealthyNodes   int   `json:"healthy_nodes"`
 	RouteRequests  int64 `json:"route_requests_total"`
+	RouteFallbacks int64 `json:"route_fallbacks_total"`
 	UptimeSeconds  int64 `json:"uptime_seconds"`
 	LastMetricTS   int64 `json:"last_metric_ts"`
 }
@@ -212,6 +219,7 @@ func (e *Engine) GetHealthStats() HealthStats {
 		TotalNodes:     len(e.nodes),
 		HealthyNodes:   healthy,
 		RouteRequests:  e.routeRequests.Load(),
+		RouteFallbacks: e.routeFallbacks.Load(),
 		UptimeSeconds:  int64(time.Since(e.startTime).Seconds()),
 		LastMetricTS:   e.lastMetricTime.Load(),
 	}

internal/engine/engine_test.go

@@ -12,7 +12,7 @@ func defaultCfg() *config.Config {
 	return &config.Config{
 		StaleThresholdSec: 20,
 		Scoring: config.ScoringConfig{
-			IdleCPUMin:           5.0,
+			IdleCPUMin:            5.0,
 			CallFailureRateLethal: 15.0,
 			Weights: config.ScoringWeights{
 				CallScore: 0.40,

internal/esl/client.go

@@ -36,10 +36,10 @@ type Client struct {
 	port     int
 	password string
 
-	conn    net.Conn
+	conn   net.Conn
-	reader  *bufio.Reader
+	reader *bufio.Reader
-	mu      sync.Mutex // защищает отправку синхронных команд (auth, subscribe)
+	mu     sync.Mutex // защищает отправку синхронных команд (auth, subscribe)
-	sendMu  sync.Mutex // защищает запись в сокет (async gateway commands)
+	sendMu sync.Mutex // защищает запись в сокет (async gateway commands)
 
 	connected atomic.Bool
 	eventsCh  chan *Event
@@ -109,7 +109,7 @@ func (c *Client) tryConnect() error {
 		c.closeCh = make(chan struct{})
 	}
 
-	addr := fmt.Sprintf("%s:%d", c.host, c.port)
+	addr := net.JoinHostPort(c.host, fmt.Sprintf("%d", c.port))
 	dialer := net.Dialer{Timeout: 5 * time.Second}
 	conn, err := dialer.Dial("tcp", addr)
 	if err != nil {
@@ -119,7 +119,7 @@ func (c *Client) tryConnect() error {
 	c.reader = bufio.NewReader(conn)
 
 	// 1. Читаем auth/request
-	headers, _, err := c.readMessageLocked()
+	headers, _, err := c.readMessage()
 	if err != nil {
 		conn.Close()
 		return fmt.Errorf("чтение auth/request: %w", err)
@@ -137,7 +137,7 @@ func (c *Client) tryConnect() error {
 	}
 
 	// 3. Читаем auth response
-	headers, _, err = c.readMessageLocked()
+	headers, _, err = c.readMessage()
 	if err != nil {
 		conn.Close()
 		return fmt.Errorf("чтение auth response: %w", err)
@@ -199,7 +199,7 @@ func (c *Client) Send(command string) (map[string]string, string, error) {
 	}
 
 	// Читаем ответ
-	return c.readMessageLocked()
+	return c.readMessage()
 }
 
 // Subscribe подписывается на события ESL.
@@ -263,7 +263,7 @@ func (c *Client) readEventsLoop() {
 			continue
 		}
 
-		headers, body, err := c.readMessageUnlocked()
+		headers, body, err := c.readMessage()
 
 		if err != nil {
 			if err == io.EOF || strings.Contains(err.Error(), "use of closed network connection") {
@@ -330,48 +330,9 @@ func (c *Client) reconnect() {
 
 // --- Приватные методы ---
 
-// readMessageUnlocked читает одно ESL-сообщение: заголовки + тело.
+// readMessage читает одно ESL-сообщение: заголовки + тело.
-// Должна вызываться только из readEventsLoop (одиночный читатель).
+// Вызывающий должен гарантировать монопольный доступ к c.reader.
-func (c *Client) readMessageUnlocked() (map[string]string, string, error) {
+func (c *Client) readMessage() (map[string]string, string, error) {
-	headers := make(map[string]string)
-
-	for {
-		line, err := c.reader.ReadString('\n')
-		if err != nil {
-			return nil, "", err
-		}
-		line = strings.TrimRight(line, "\r\n")
-		if line == "" {
-			break // конец заголовков
-		}
-
-		parts := strings.SplitN(line, ":", 2)
-		if len(parts) == 2 {
-			headers[strings.TrimSpace(parts[0])] = strings.TrimSpace(parts[1])
-		}
-	}
-
-	// Читаем тело согласно Content-Length
-	cl := headers["Content-Length"]
-	if cl == "" {
-		return headers, "", nil
-	}
-	length, err := strconv.Atoi(cl)
-	if err != nil {
-		return headers, "", fmt.Errorf("некорректный Content-Length: %s", cl)
-	}
-
-	body := make([]byte, length)
-	if _, err := io.ReadFull(c.reader, body); err != nil {
-		return headers, "", fmt.Errorf("чтение тела (Content-Length=%d): %w", length, err)
-	}
-
-	return headers, strings.TrimSpace(string(body)), nil
-}
-
-// readMessageLocked читает одно ESL-сообщение: заголовки + тело.
-// Вызывающий держит c.mu (для синхронных команд Send).
-func (c *Client) readMessageLocked() (map[string]string, string, error) {
 	headers := make(map[string]string)
 
 	for {
@@ -412,12 +373,12 @@ func (c *Client) readMessageLocked() (map[string]string, string, error) {
 
 // Stats возвращает статистику ESL-клиента для health endpoint.
 type Stats struct {
-	Status       string `json:"status"`
+	Status     string `json:"status"`
-	Host         string `json:"host"`
+	Host       string `json:"host"`
-	Reconnects   int64  `json:"reconnects"`
+	Reconnects int64  `json:"reconnects"`
-	GatewayOps   int64  `json:"gateway_ops_total"`
+	GatewayOps int64  `json:"gateway_ops_total"`
-	EventsRecv   int64  `json:"events_received"`
+	EventsRecv int64  `json:"events_received"`
-	UptimeSec    int64  `json:"uptime_seconds"`
+	UptimeSec  int64  `json:"uptime_seconds"`
 }
 
 // GetStats возвращает текущую статистику.
@@ -440,3 +401,70 @@ func (c *Client) GetStats() Stats {
 func (c *Client) IncGatewayOps() {
 	c.gatewayOps.Add(1)
 }
+
+// --- FS stats ---
+
+// FsStats — показатели FreeSWITCH балансировщика.
+type FsStats struct {
+	ActiveCalls int
+	MaxSessions int
+	FsUptime    string
+}
+
+// FetchFsStats запрашивает метрики FreeSWITCH через api команды.
+func (c *Client) FetchFsStats() (FsStats, error) {
+	if !c.connected.Load() {
+		return FsStats{}, fmt.Errorf("esl не подключён")
+	}
+	var stats FsStats
+
+	_, body, err := c.Send("api show calls count")
+	if err != nil {
+		return FsStats{}, err
+	}
+	stats.ActiveCalls = parseFirstInt(body)
+
+	_, body, err = c.Send("api status")
+	if err != nil {
+		return stats, err
+	}
+	stats.MaxSessions = parseMaxSessions(body)
+	stats.FsUptime = parseUptime(body)
+
+	return stats, nil
+}
+
+func parseFirstInt(s string) int {
+	s = strings.TrimSpace(s)
+	for i, c := range s {
+		if c < '0' || c > '9' {
+			if i == 0 {
+				return 0
+			}
+			v, err := strconv.Atoi(s[:i])
+			if err != nil {
+				return 0
+			}
+			return v
+		}
+	}
+	return 0
+}
+
+func parseMaxSessions(body string) int {
+	for _, line := range strings.Split(body, "\n") {
+		if strings.Contains(line, "session(s) max") {
+			return parseFirstInt(line)
+		}
+	}
+	return 0
+}
+
+func parseUptime(body string) string {
+	for _, line := range strings.Split(body, "\n") {
+		if strings.HasPrefix(line, "UP ") {
+			return strings.TrimPrefix(line, "UP ")
+		}
+	}
+	return ""
+}

internal/esl/events.go

@@ -16,6 +16,7 @@ type EventHandler func(eventName string, headers map[string]string, body string)
 //   - Вызывает onConnect (например, для GatewaySyncAll)
 //   - Подписывается на события SOFIA::gateway_register/unregister
 //   - Запускает чтение асинхронных событий
+//
 // При разрыве соединения — автоматический реконнект.
 func (c *Client) StartEventLoop(ctx context.Context, profile string, onConnect func(), onEvent EventHandler) {
 	const subscribeEvents = "SOFIA::gateway_register SOFIA::gateway_unregister SOFIA::gateway_expire"

internal/esl/gateway.go

@@ -32,8 +32,8 @@ func (c *Client) GatewayDelete(profile, name string) error {
 	return nil
 }
 
-// GatewayList возвращает список имён gateway в заданном профиле.
+// GatewayList возвращает список имён gateway в заданном профиле с указанным префиксом.
-func (c *Client) GatewayList(profile string) ([]string, error) {
+func (c *Client) GatewayList(profile, prefix string) ([]string, error) {
 	cmd := fmt.Sprintf("api sofia profile %s gwlist", profile)
 	_, body, err := c.Send(cmd)
 
@@ -49,8 +49,8 @@ func (c *Client) GatewayList(profile string) ([]string, error) {
 		if line == "" || strings.HasPrefix(line, "Name:") || strings.HasPrefix(line, "====") {
 			continue
 		}
-		// Ищем строки вида "pulse-ingress-xxxxx      sip:..."
+		// Ищем строки вида "<prefix>-ingress-xxxxx      sip:..."
-		if strings.Contains(line, "pulse-") {
+		if strings.Contains(line, prefix+"-ingress-") {
 			parts := strings.Fields(line)
 			if len(parts) > 0 {
 				gateways = append(gateways, parts[0])

internal/log/logger.go

@@ -15,10 +15,10 @@ import (
 
 // Logger — потокобезопасный логгер метрик в ASCII-файл с дневной ротацией.
 type Logger struct {
-	mu     sync.Mutex
+	mu    sync.Mutex
-	dir    string
+	dir   string
-	file   *os.File
+	file  *os.File
-	today  string // YYYY-MM-DD последнего открытого файла
+	today string // YYYY-MM-DD последнего открытого файла
 }
 
 // NewLogger создаёт логгер, записывающий в dataDir/.

internal/models/types.go

@@ -7,15 +7,15 @@ import "time"
 
 // NodeMetric — сообщение, публикуемое нодой в NATS каждые 5 сек.
 type NodeMetric struct {
-	NodeID           string  `json:"node_id"`
+	NodeID          string  `json:"node_id"`
-	TS               int64   `json:"ts"`                 // unix timestamp
+	TS              int64   `json:"ts"`     // unix timestamp
-	Status           string  `json:"status"`             // "ok", "degraded", "down"
+	Status          string  `json:"status"` // "ok", "degraded", "down"
-	ActiveCalls      int     `json:"active_calls"`
+	ActiveCalls     int     `json:"active_calls"`
-	MaxCalls         int     `json:"max_calls"`
+	MaxCalls        int     `json:"max_calls"`
-	IdleCPU          float64 `json:"idle_cpu"`           // 0..100 %
+	IdleCPU         float64 `json:"idle_cpu"`              // 0..100 %
-	LoadAvg          float64 `json:"load_avg"`           // system load average (1m)
+	LoadAvg         float64 `json:"load_avg"`              // system load average (1m)
-	CallFailureRate  float64 `json:"call_failure_rate"`  // 0.0..100.0 %
+	CallFailureRate float64 `json:"call_failure_rate"`     // 0.0..100.0 %
-	SIPGateway       string  `json:"sip_gateway,omitempty"` // SIP-адрес ноды для авто-создания транка
+	SIPGateway      string  `json:"sip_gateway,omitempty"` // SIP-адрес ноды для авто-создания транка
 }
 
 // --- In-memory состояние ноды в engine ---
@@ -24,8 +24,8 @@ type NodeMetric struct {
 // Содержит данные последней метрики + поля ручного управления.
 type NodeState struct {
 	NodeMetric
-	Disabled       bool   `json:"disabled"`
+	Disabled       bool    `json:"disabled"`
-	DisabledReason string `json:"disabled_reason"`
+	DisabledReason string  `json:"disabled_reason"`
 	Score          float64 `json:"score"`
 	LethalReason   string  `json:"lethal_reason,omitempty"` // причина, если score = -100
 }
@@ -46,7 +46,7 @@ type Trunk struct {
 	ID          string    `json:"id"`
 	Name        string    `json:"name"`
 	Type        TrunkType `json:"type"`
-	NodeID      string    `json:"node_id,omitempty"`    // только для balance
+	NodeID      string    `json:"node_id,omitempty"` // только для balance
 	Gateway     string    `json:"gateway"`
 	Codecs      []string  `json:"codecs,omitempty"`
 	Context     string    `json:"context,omitempty"`
@@ -68,10 +68,10 @@ const (
 
 // User — модель пользователя (из users.json).
 type User struct {
-	ID           string   `json:"id"`
+	ID           string    `json:"id"`
-	Username     string   `json:"username"`
+	Username     string    `json:"username"`
-	PasswordHash string   `json:"password_hash"`
+	PasswordHash string    `json:"password_hash"`
-	Role         UserRole `json:"role"`
+	Role         UserRole  `json:"role"`
 	CreatedAt    time.Time `json:"created_at"`
 	UpdatedAt    time.Time `json:"updated_at"`
 }
@@ -96,27 +96,27 @@ type LoginResponse struct {
 // RouteResponse — ответ на запрос маршрутизации.
 type RouteResponse struct {
 	// Успех
-	NodeID      string  `json:"node_id,omitempty"`
+	NodeID     string  `json:"node_id,omitempty"`
-	Score       float64 `json:"score,omitempty"`
+	Score      float64 `json:"score,omitempty"`
-	SIPGateway  string  `json:"sip_gateway,omitempty"`
+	SIPGateway string  `json:"sip_gateway,omitempty"`
 
 	// Fallback
-	Fallback    bool   `json:"fallback,omitempty"`
+	Fallback bool   `json:"fallback,omitempty"`
-	Reason      string `json:"reason,omitempty"`
+	Reason   string `json:"reason,omitempty"`
 
 	// Общая информация о нодах
-	Nodes       []RouteNodeInfo `json:"nodes,omitempty"`
+	Nodes []RouteNodeInfo `json:"nodes,omitempty"`
 
 	// Ошибка
-	Error       string `json:"error,omitempty"`
+	Error string `json:"error,omitempty"`
 }
 
 // RouteNodeInfo — информация о ноде в ответе маршрутизации.
 type RouteNodeInfo struct {
 	ID     string  `json:"id"`
 	Score  float64 `json:"score"`
-	Reason string `json:"reason,omitempty"`
+	Reason string  `json:"reason,omitempty"`
-	Status string `json:"status"`
+	Status string  `json:"status"`
 }
 
 // --- API: Nodes ---
@@ -129,20 +129,20 @@ type ToggleNodeRequest struct {
 
 // NodeInfo — информация о ноде для фронта.
 type NodeInfo struct {
-	NodeID         string  `json:"node_id"`
+	NodeID          string  `json:"node_id"`
-	TS             int64   `json:"ts"`
+	TS              int64   `json:"ts"`
-	Status         string  `json:"status"`
+	Status          string  `json:"status"`
-	ActiveCalls    int     `json:"active_calls"`
+	ActiveCalls     int     `json:"active_calls"`
-	MaxCalls       int     `json:"max_calls"`
+	MaxCalls        int     `json:"max_calls"`
-	IdleCPU        float64 `json:"idle_cpu"`
+	IdleCPU         float64 `json:"idle_cpu"`
-	LoadAvg        float64 `json:"load_avg"`
+	LoadAvg         float64 `json:"load_avg"`
 	CallFailureRate float64 `json:"call_failure_rate"`
-	Disabled       bool    `json:"disabled"`
+	Disabled        bool    `json:"disabled"`
-	DisabledReason string  `json:"disabled_reason,omitempty"`
+	DisabledReason  string  `json:"disabled_reason,omitempty"`
-	Score          float64 `json:"score"`
+	Score           float64 `json:"score"`
-	LethalReason   string  `json:"lethal_reason,omitempty"`
+	LethalReason    string  `json:"lethal_reason,omitempty"`
-	IsStale        bool    `json:"is_stale"`
+	IsStale         bool    `json:"is_stale"`
-	SecondsAgo     float64 `json:"seconds_ago"`
+	SecondsAgo      float64 `json:"seconds_ago"`
 }
 
 // --- API: Users ---
@@ -191,17 +191,17 @@ type UpdateTrunkRequest struct {
 
 // ZabbixNode — элемент LLD (Low-Level Discovery) для Zabbix.
 type ZabbixNode struct {
-	NodeID         string  `json:"{#NODE_ID}"`
+	NodeID          string  `json:"{#NODE_ID}"`
-	Status         string  `json:"{#STATUS}"`
+	Status          string  `json:"{#STATUS}"`
-	ActiveCalls    int     `json:"{#ACTIVE_CALLS}"`
+	ActiveCalls     int     `json:"{#ACTIVE_CALLS}"`
-	MaxCalls       int     `json:"{#MAX_CALLS}"`
+	MaxCalls        int     `json:"{#MAX_CALLS}"`
-	IdleCPU        float64 `json:"{#IDLE_CPU}"`
+	IdleCPU         float64 `json:"{#IDLE_CPU}"`
-	LoadAvg        float64 `json:"{#LOAD_AVG}"`
+	LoadAvg         float64 `json:"{#LOAD_AVG}"`
 	CallFailureRate float64 `json:"{#CALL_FAILURE_RATE}"`
-	Score          float64 `json:"{#SCORE}"`
+	Score           float64 `json:"{#SCORE}"`
-	Disabled       bool    `json:"{#DISABLED}"`
+	Disabled        bool    `json:"{#DISABLED}"`
-	IsStale        bool    `json:"{#IS_STALE}"`
+	IsStale         bool    `json:"{#IS_STALE}"`
-	SecondsAgo     float64 `json:"{#SECONDS_AGO}"`
+	SecondsAgo      float64 `json:"{#SECONDS_AGO}"`
 }
 
 // ZabbixResponse — ответ на запрос Zabbix LLD.
@@ -209,10 +209,29 @@ type ZabbixResponse struct {
 	Data []ZabbixNode `json:"data"`
 }
 
+// --- Balancer ---
+
+// BalancerInfo — состояние балансировщика для дашборда.
+type BalancerInfo struct {
+	EslConnected   bool   `json:"esl_connected"`
+	EslUptimeSec   int64  `json:"esl_uptime_sec,omitempty"`
+	EslReconnects  int64  `json:"esl_reconnects,omitempty"`
+	NatsConnected  bool   `json:"nats_connected"`
+	GatewaysTotal  int    `json:"gateways_total"`
+	GatewaysUp     int    `json:"gateways_up"`
+	GatewaysDown   int    `json:"gateways_down"`
+	FsActiveCalls  int    `json:"fs_active_calls"`
+	FsMaxSessions  int    `json:"fs_max_sessions"`
+	FsUptime       string `json:"fs_uptime"`
+	RouteTotal     int64  `json:"route_total"`
+	RouteFallbacks int64  `json:"route_fallbacks"`
+	UptimeSec      int64  `json:"uptime_sec"`
+}
+
 // --- WebSocket ---
 
 // WsMetricsMessage — сообщение, отправляемое по WebSocket.
 type WsMetricsMessage struct {
-	Type    string      `json:"type"`    // "nodes_update", "node_toggle", etc
+	Type    string      `json:"type"` // "nodes_update", "balancer_update", "gateway_update", etc
 	Payload interface{} `json:"payload"`
 }

internal/nats/subscriber.go

@@ -9,9 +9,9 @@ import (
 
 	natsgo "github.com/nats-io/nats.go"
 
-	"github.com/pulse-lets-go/internal/models"
 	"github.com/pulse-lets-go/internal/engine"
 	filelog "github.com/pulse-lets-go/internal/log"
+	"github.com/pulse-lets-go/internal/models"
 )
 
 const subject = "pulse.metrics.>"

internal/util/util.go

@@ -0,0 +1,18 @@
+package util
+
+import (
+	"crypto/rand"
+	"encoding/hex"
+	"fmt"
+	"time"
+)
+
+// RandomHex генерирует случайную hex-строку из n байт.
+// При ошибке crypto/rand использует time-based fallback.
+func RandomHex(n int) string {
+	b := make([]byte, n)
+	if _, err := rand.Read(b); err != nil {
+		return fmt.Sprintf("%x", time.Now().UnixNano())[:n*2]
+	}
+	return hex.EncodeToString(b)[:n*2]
+}

web/src/lib/api.ts

@@ -184,6 +184,22 @@ export async function deleteUser(id: string) {
 }
 
 // --- WebSocket ---
+export interface BalancerInfo {
+  esl_connected: boolean;
+  esl_uptime_sec: number;
+  esl_reconnects: number;
+  nats_connected: boolean;
+  gateways_total: number;
+  gateways_up: number;
+  gateways_down: number;
+  fs_active_calls: number;
+  fs_max_sessions: number;
+  fs_uptime: string;
+  route_total: number;
+  route_fallbacks: number;
+  uptime_sec: number;
+}
+
 export function connectWebSocket(onMessage: (data: any) => void): WebSocket {
   const token = getToken();
   const proto = window.location.protocol === 'https:' ? 'wss' : 'ws';

web/src/routes/+layout.svelte

@@ -1,31 +1,40 @@
 <script lang="ts">
-  import { browser } from '$app/environment';
   import { page } from '$app/stores';
+  import { goto } from '$app/navigation';
   import '../app.css';
   import { Toaster } from 'svelte-sonner';
-  import { LogIn, LayoutDashboard, Phone, Cable, Users } from 'lucide-svelte';
+  import { LayoutDashboard, Phone, Cable, Users } from 'lucide-svelte';
 
-  let token: string | null = browser ? localStorage.getItem('token') : null;
+  let token: string | null = null;
-  let user: { username: string; role: string } | null = token
+  let user: { username: string; role: string } | null = null;
-    ? (() => { try { return JSON.parse(atob(token.split('.')[1])); } catch { return null; } })()
-    : null;
 
-  function logout() {
+  function updateAuth() {
-    if (browser) {
+    token = typeof localStorage !== 'undefined' ? localStorage.getItem('token') : null;
-      localStorage.removeItem('token');
+    if (token) {
-      localStorage.removeItem('refreshToken');
+      try { user = JSON.parse(atob(token.split('.')[1])); } catch { user = null; }
+    } else {
+      user = null;
     }
-    token = null;
-    user = null;
   }
 
-  $: pathname = browser ? window.location.pathname : '';
+  function logout() {
-  $: isLogin = pathname === '/login';
+    localStorage.removeItem('token');
+    localStorage.removeItem('refreshToken');
+    updateAuth();
+    goto('/login');
+  }
+
+  let pathname = $derived($page.url.pathname);
+
+  $effect(() => {
+    $page.url.pathname;
+    updateAuth();
+  });
 </script>
 
 <Toaster position="top-right" />
 
-{#if !isLogin}
+{#if pathname !== '/login'}
   <div class="flex min-h-screen">
     <!-- Sidebar -->
     <aside class="w-64 border-r bg-card flex flex-col">

web/src/routes/+page.svelte

@@ -4,11 +4,12 @@
   import { onMount, onDestroy } from 'svelte';
   import {
     getNodes, connectWebSocket, isAuthenticated,
-    type NodeInfo
+    type NodeInfo, type BalancerInfo
   } from '$lib/api';
-  import { Activity, Phone, Zap, AlertTriangle, Wifi, Server } from 'lucide-svelte';
+  import { Activity, Phone, Zap, AlertTriangle, Wifi, Server, Plug, Globe, ArrowLeftRight, Network } from 'lucide-svelte';
 
   let nodes: NodeInfo[] = [];
+  let balancer: BalancerInfo | null = null;
   let ws: WebSocket | null = null;
   let error: string | null = null;
 
@@ -21,6 +22,8 @@
     ws = connectWebSocket((msg) => {
       if (msg.type === 'nodes_update') {
         nodes = msg.payload;
+      } else if (msg.type === 'balancer_update') {
+        balancer = msg.payload;
       }
     });
   });
@@ -67,10 +70,31 @@
     }
   }
 
+  function dotColor(ok: boolean, degrade?: boolean): string {
+    if (ok) return 'bg-green-500';
+    if (degrade) return 'bg-yellow-500';
+    return 'bg-red-500';
+  }
+
+  function fmtUptime(sec: number): string {
+    if (sec < 60) return `${sec}с`;
+    if (sec < 3600) return `${Math.floor(sec / 60)}м`;
+    if (sec < 86400) return `${Math.floor(sec / 3600)}ч`;
+    return `${Math.floor(sec / 86400)}д`;
+  }
+
+  function fmtNum(n: number): string {
+    if (n >= 1000) return (n / 1000).toFixed(1) + 'K';
+    return String(n);
+  }
+
   $: healthyCount = nodes.filter(n => n.score >= 0 && !n.disabled && !n.is_stale).length;
   $: totalCalls = nodes.reduce((s, n) => s + n.active_calls, 0);
   $: avgScore = nodes.length > 0 ? nodes.reduce((s, n) => s + n.score, 0) / nodes.length : 0;
   $: unhealthyList = nodes.filter(n => n.score < 0 || n.disabled || n.is_stale);
+  $: fallbackPct = balancer && balancer.route_total > 0
+    ? (balancer.route_fallbacks / balancer.route_total * 100).toFixed(1)
+    : '0';
 </script>
 
 {#if error}
@@ -79,6 +103,51 @@
   </div>
 {/if}
 
+<!-- Balancer Status Bar -->
+{#if balancer}
+  <div class="flex flex-wrap items-center gap-1 text-xs text-muted-foreground mb-4 px-3 py-2 border rounded-md bg-muted/30">
+    <span class="flex items-center gap-1 mr-2">
+      <span class="w-1.5 h-1.5 rounded-full {dotColor(balancer.esl_connected)}"></span>
+      <Plug class="h-3 w-3" />
+      ESL {balancer.esl_connected ? 'Online' : 'Offline'}
+      {#if balancer.esl_uptime_sec > 0}{fmtUptime(balancer.esl_uptime_sec)}{/if}
+    </span>
+    <span class="opacity-30">|</span>
+    <span class="flex items-center gap-1 mr-2">
+      <span class="w-1.5 h-1.5 rounded-full {dotColor(balancer.nats_connected)}"></span>
+      <Network class="h-3 w-3" />
+      NATS {balancer.nats_connected ? 'Online' : 'Offline'}
+    </span>
+    <span class="opacity-30">|</span>
+    <span class="flex items-center gap-1 mr-2">
+      <span class="w-1.5 h-1.5 rounded-full {balancer.gateways_down > 0 ? 'bg-red-500' : 'bg-green-500'}"></span>
+      <Globe class="h-3 w-3" />
+      GW {balancer.gateways_up}/{balancer.gateways_total}
+      {#if balancer.gateways_down > 0}
+        <span class="text-red-500">({balancer.gateways_down} down)</span>
+      {/if}
+    </span>
+    <span class="opacity-30">|</span>
+    <span class="flex items-center gap-1">
+      <ArrowLeftRight class="h-3 w-3" />
+      R {fmtNum(balancer.route_total)}
+      {#if balancer.route_fallbacks > 0}
+        <span class="text-orange-500">({fallbackPct}% fb)</span>
+      {/if}
+    </span>
+    {#if balancer.esl_connected && balancer.fs_max_sessions > 0}
+      <span class="opacity-30">|</span>
+      <span class="flex items-center gap-1">
+        <Phone class="h-3 w-3" />
+        FS {balancer.fs_active_calls}·{balancer.fs_max_sessions}
+        {#if balancer.fs_uptime}
+          <span class="opacity-50">{balancer.fs_uptime}</span>
+        {/if}
+      </span>
+    {/if}
+  </div>
+{/if}
+
 <!-- Summary Cards -->
 <div class="grid grid-cols-1 sm:grid-cols-2 lg:grid-cols-4 gap-4 mb-6">
   <div class="border rounded-lg p-4 bg-card">