From 5fe2d3a077bde20cf9aa732f027d178ea7678719 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=D0=93=D1=80=D0=B8=D0=B3=D0=BE=D1=80=D0=B8=D0=B9=20=D0=A1?=
 =?UTF-8?q?=D0=B0=D1=84=D1=80=D0=BE=D0=BD=D0=BE=D0=B2?=
 <gvsafronov@yandex.ru>
Date: Wed, 22 Apr 2026 19:19:10 +0000
Subject: [PATCH] Delete internal/api/webui.go

---
 internal/api/webui.go | 636 ------------------------------------------
 1 file changed, 636 deletions(-)
 delete mode 100644 internal/api/webui.go
diff --git a/internal/api/webui.go b/internal/api/webui.go
deleted file mode 100644
index 92ae861..0000000
--- a/internal/api/webui.go
+++ /dev/null
@@ -1,636 +0,0 @@
-/*
- * Copyright 2026 Safronov Grigorii
- *
- * Licensed under the CDDL, Version 1.0 (the "License");
- * you may not use this file except in compliance with the License.
- *
- * You may obtain a copy of the License at
- * https://opensource.org/licenses/CDDL-1.0
- */
- 
-// Файл: internal/api/webui.go
-// Назначение: Веб-интерфейс в стиле dashboard для управления СУБД futriis
-
-package api
-
-import (
-	"embed"
-	"encoding/json"
-	"fmt"
-	"io/fs"
-	"net/http"
-	"strconv"
-	"strings"
-	"time"
-
-	"futriis/internal/acl"
-	"futriis/internal/cluster"
-	"futriis/internal/log"
-	"futriis/internal/storage"
-)
-
-//go:embed static/*
-var staticFiles embed.FS
-
-// WebUIServer представляет сервер веб-интерфейса
-type WebUIServer struct {
-	store       *storage.Storage
-	coordinator *cluster.RaftCoordinator
-	aclManager  *acl.ACLManager
-	logger      *log.Logger
-	server      *http.Server
-	port        int
-	enabled     bool
-}
-
-// NewWebUIServer создаёт новый веб-сервер интерфейса
-func NewWebUIServer(port int, enabled bool, store *storage.Storage, coord *cluster.RaftCoordinator, aclMgr *acl.ACLManager, logger *log.Logger) *WebUIServer {
-	return &WebUIServer{
-		store:       store,
-		coordinator: coord,
-		aclManager:  aclMgr,
-		logger:      logger,
-		port:        port,
-		enabled:     enabled,
-	}
-}
-
-// Start запускает веб-сервер интерфейса
-func (w *WebUIServer) Start() error {
-	if !w.enabled {
-		w.logger.Info("Web UI is disabled in configuration")
-		return nil
-	}
-
-	mux := http.NewServeMux()
-
-	// Статические файлы
-	staticFS, err := fs.Sub(staticFiles, "static")
-	if err != nil {
-		return fmt.Errorf("failed to load static files: %v", err)
-	}
-	mux.Handle("/static/", http.StripPrefix("/static/", http.FileServer(http.FS(staticFS))))
-
-	// Главная страница
-	mux.HandleFunc("/", w.handleIndex)
-
-	// API для веб-интерфейса
-	mux.HandleFunc("/api/webui/databases", w.handleGetDatabases)
-	mux.HandleFunc("/api/webui/collections/", w.handleGetCollections)
-	mux.HandleFunc("/api/webui/documents/", w.handleDocuments)
-	mux.HandleFunc("/api/webui/cluster/status", w.handleClusterStatus)
-	mux.HandleFunc("/api/webui/cluster/nodes", w.handleClusterNodes)
-	mux.HandleFunc("/api/webui/stats", w.handleStats)
-	mux.HandleFunc("/api/webui/login", w.handleWebLogin)
-	mux.HandleFunc("/api/webui/logout", w.handleWebLogout)
-	mux.HandleFunc("/api/webui/session", w.handleSessionCheck)
-
-	w.server = &http.Server{
-		Addr:         fmt.Sprintf(":%d", w.port),
-		Handler:      mux,
-		ReadTimeout:  30 * time.Second,
-		WriteTimeout: 30 * time.Second,
-	}
-
-	w.logger.Info(fmt.Sprintf("Web UI started on port %d", w.port))
-	return w.server.ListenAndServe()
-}
-
-// Stop останавливает веб-сервер
-func (w *WebUIServer) Stop() error {
-	if w.server != nil {
-		return w.server.Close()
-	}
-	return nil
-}
-
-// handleIndex возвращает главную HTML страницу
-func (w *WebUIServer) handleIndex(wr http.ResponseWriter, r *http.Request) {
-	if r.URL.Path != "/" {
-		http.NotFound(wr, r)
-		return
-	}
-
-	html := `<!DOCTYPE html>
-<html lang="ru">
-<head>
-    <meta charset="UTF-8">
-    <meta name="viewport" content="width=device-width, initial-scale=1.0, user-scalable=yes">
-    <title>Futriis Database Management System</title>
-    <link rel="stylesheet" href="/static/style.css">
-    <link href="https://fonts.googleapis.com/css2?family=Inter:ital,wght@0,300;0,400;0,500;0,600;0,700;1,400&display=swap" rel="stylesheet">
-    <link rel="stylesheet" href="https://cdnjs.cloudflare.com/ajax/libs/font-awesome/6.4.0/css/all.min.css">
-</head>
-<body>
-    <div class="dashboard-container">
-        <!-- Вертикальное меню -->
-        <nav class="sidebar">
-            <div class="sidebar-header">
-                <div class="logo">
-                    <i class="fas fa-database"></i>
-                    <span>Futriis DB</span>
-                </div>
-                <button class="menu-toggle" id="menuToggle">
-                    <i class="fas fa-bars"></i>
-                </button>
-            </div>
-            
-            <ul class="nav-menu">
-                <li class="nav-item">
-                    <a href="#" class="nav-link" data-section="dashboard">
-                        <i class="fas fa-tachometer-alt"></i>
-                        <span>Панель управления</span>
-                    </a>
-                </li>
-                <li class="nav-item has-submenu">
-                    <a href="#" class="nav-link" data-submenu="crud">
-                        <i class="fas fa-table"></i>
-                        <span>Управление СУБД</span>
-                        <i class="fas fa-chevron-down"></i>
-                    </a>
-                    <ul class="submenu">
-                        <li><a href="#" data-action="create-db"><i class="fas fa-plus-circle"></i>Создать БД</a></li>
-                        <li><a href="#" data-action="create-collection"><i class="fas fa-layer-group"></i>Создать коллекцию</a></li>
-                        <li><a href="#" data-action="insert-doc"><i class="fas fa-file-import"></i>Вставить документ</a></li>
-                        <li><a href="#" data-action="find-doc"><i class="fas fa-search"></i>Найти документ</a></li>
-                        <li><a href="#" data-action="update-doc"><i class="fas fa-edit"></i>Обновить документ</a></li>
-                        <li><a href="#" data-action="delete-doc"><i class="fas fa-trash-alt"></i>Удалить документ</a></li>
-                    </ul>
-                </li>
-                <li class="nav-item">
-                    <a href="#" class="nav-link" data-section="cluster">
-                        <i class="fas fa-network-wired"></i>
-                        <span>Управление кластером</span>
-                    </a>
-                </li>
-                <li class="nav-item">
-                    <a href="#" class="nav-link" data-section="audit">
-                        <i class="fas fa-history"></i>
-                        <span>Аудит</span>
-                    </a>
-                </li>
-                <li class="nav-item">
-                    <a href="#" class="nav-link" data-section="settings">
-                        <i class="fas fa-cog"></i>
-                        <span>Настройки</span>
-                    </a>
-                </li>
-            </ul>
-            
-            <div class="sidebar-footer">
-                <div class="user-info" id="userInfo">
-                    <i class="fas fa-user-circle"></i>
-                    <span>Гость</span>
-                </div>
-                <button class="logout-btn" id="logoutBtn">
-                    <i class="fas fa-sign-out-alt"></i>
-                    <span>Выход</span>
-                </button>
-            </div>
-        </nav>
-        
-        <!-- Основной контент -->
-        <main class="main-content">
-            <header class="top-bar">
-                <h1 id="pageTitle">Панель управления</h1>
-                <div class="connection-status" id="connectionStatus">
-                    <i class="fas fa-circle"></i>
-                    <span>Подключено</span>
-                </div>
-            </header>
-            
-            <div class="content-area" id="contentArea">
-                <!-- Контент загружается динамически -->
-                <div class="loading-spinner">
-                    <i class="fas fa-spinner fa-pulse"></i>
-                    <p>Загрузка...</p>
-                </div>
-            </div>
-        </main>
-    </div>
-    
-    <!-- Модальные окна -->
-    <div id="modal" class="modal">
-        <div class="modal-content">
-            <div class="modal-header">
-                <h2 id="modalTitle">Заголовок</h2>
-                <button class="modal-close">&times;</button>
-            </div>
-            <div class="modal-body" id="modalBody">
-                <!-- Содержимое модального окна -->
-            </div>
-            <div class="modal-footer">
-                <button class="btn btn-secondary modal-close">Отмена</button>
-                <button class="btn btn-primary" id="modalConfirm">Подтвердить</button>
-            </div>
-        </div>
-    </div>
-    
-    <!-- Уведомления -->
-    <div id="notificationContainer" class="notification-container"></div>
-    
-    <script src="/static/app.js"></script>
-</body>
-</html>`
-	
-	wr.Header().Set("Content-Type", "text/html; charset=utf-8")
-	wr.Write([]byte(html))
-}
-
-// handleGetDatabases возвращает список баз данных
-func (w *WebUIServer) handleGetDatabases(wr http.ResponseWriter, r *http.Request) {
-	if !w.checkAuth(r) {
-		w.sendJSONError(wr, "Unauthorized", http.StatusUnauthorized)
-		return
-	}
-
-	databases := w.store.ListDatabases()
-	
-	dbInfo := make([]map[string]interface{}, 0)
-	for _, dbName := range databases {
-		db, err := w.store.GetDatabase(dbName)
-		if err == nil {
-			collections := db.ListCollections()
-			dbInfo = append(dbInfo, map[string]interface{}{
-				"name":        dbName,
-				"collections": len(collections),
-				"collections_list": collections,
-			})
-		}
-	}
-	
-	w.sendJSONSuccess(wr, dbInfo)
-}
-
-// handleGetCollections возвращает список коллекций в базе данных
-func (w *WebUIServer) handleGetCollections(wr http.ResponseWriter, r *http.Request) {
-	if !w.checkAuth(r) {
-		w.sendJSONError(wr, "Unauthorized", http.StatusUnauthorized)
-		return
-	}
-
-	path := strings.TrimPrefix(r.URL.Path, "/api/webui/collections/")
-	parts := strings.Split(path, "/")
-	
-	if len(parts) < 1 || parts[0] == "" {
-		w.sendJSONError(wr, "Database name required", http.StatusBadRequest)
-		return
-	}
-	
-	dbName := parts[0]
-	db, err := w.store.GetDatabase(dbName)
-	if err != nil {
-		w.sendJSONError(wr, err.Error(), http.StatusNotFound)
-		return
-	}
-	
-	collections := db.ListCollections()
-	collectionsInfo := make([]map[string]interface{}, 0)
-	
-	for _, collName := range collections {
-		coll, err := db.GetCollection(collName)
-		if err == nil {
-			collectionsInfo = append(collectionsInfo, map[string]interface{}{
-				"name":     collName,
-				"count":    coll.Count(),
-				"size":     coll.Size(),
-				"indexes":  coll.GetIndexes(),
-			})
-		}
-	}
-	
-	w.sendJSONSuccess(wr, map[string]interface{}{
-		"database":    dbName,
-		"collections": collectionsInfo,
-	})
-}
-
-// handleDocuments обрабатывает CRUD операции с документами
-func (w *WebUIServer) handleDocuments(wr http.ResponseWriter, r *http.Request) {
-	if !w.checkAuth(r) {
-		w.sendJSONError(wr, "Unauthorized", http.StatusUnauthorized)
-		return
-	}
-
-	path := strings.TrimPrefix(r.URL.Path, "/api/webui/documents/")
-	parts := strings.Split(path, "/")
-	
-	if len(parts) < 2 {
-		w.sendJSONError(wr, "Invalid path. Use /api/webui/documents/{database}/{collection}", http.StatusBadRequest)
-		return
-	}
-	
-	dbName := parts[0]
-	collName := parts[1]
-	
-	db, err := w.store.GetDatabase(dbName)
-	if err != nil {
-		w.sendJSONError(wr, err.Error(), http.StatusNotFound)
-		return
-	}
-	
-	coll, err := db.GetCollection(collName)
-	if err != nil {
-		w.sendJSONError(wr, err.Error(), http.StatusNotFound)
-		return
-	}
-	
-	switch r.Method {
-	case http.MethodGet:
-		// Получение документов с пагинацией
-		limit := 50
-		if limitStr := r.URL.Query().Get("limit"); limitStr != "" {
-			if l, err := strconv.Atoi(limitStr); err == nil && l > 0 && l <= 500 {
-				limit = l
-			}
-		}
-		
-		offset := 0
-		if offsetStr := r.URL.Query().Get("offset"); offsetStr != "" {
-			if o, err := strconv.Atoi(offsetStr); err == nil && o >= 0 {
-				offset = o
-			}
-		}
-		
-		allDocs := coll.GetAllDocuments()
-		start := offset
-		end := offset + limit
-		if start > len(allDocs) {
-			start = len(allDocs)
-		}
-		if end > len(allDocs) {
-			end = len(allDocs)
-		}
-		
-		docs := make([]map[string]interface{}, 0)
-		for _, doc := range allDocs[start:end] {
-			docs = append(docs, map[string]interface{}{
-				"id":         doc.ID,
-				"fields":     doc.GetFields(),
-				"created_at": doc.CreatedAt,
-				"updated_at": doc.UpdatedAt,
-				"version":    doc.Version,
-			})
-		}
-		
-		w.sendJSONSuccess(wr, map[string]interface{}{
-			"documents": docs,
-			"total":     len(allDocs),
-			"limit":     limit,
-			"offset":    offset,
-		})
-		
-	case http.MethodPost:
-		// Вставка документа
-		var docData map[string]interface{}
-		if err := json.NewDecoder(r.Body).Decode(&docData); err != nil {
-			w.sendJSONError(wr, "Invalid JSON", http.StatusBadRequest)
-			return
-		}
-		
-		if err := coll.InsertFromMap(docData); err != nil {
-			w.sendJSONError(wr, err.Error(), http.StatusBadRequest)
-			return
-		}
-		
-		w.sendJSONSuccess(wr, map[string]interface{}{
-			"status": "inserted",
-			"id":     docData["_id"],
-		})
-		
-	case http.MethodPut:
-		// Обновление документа
-		docID := r.URL.Query().Get("id")
-		if docID == "" {
-			w.sendJSONError(wr, "Document ID required", http.StatusBadRequest)
-			return
-		}
-		
-		var updates map[string]interface{}
-		if err := json.NewDecoder(r.Body).Decode(&updates); err != nil {
-			w.sendJSONError(wr, "Invalid JSON", http.StatusBadRequest)
-			return
-		}
-		
-		if err := coll.Update(docID, updates); err != nil {
-			w.sendJSONError(wr, err.Error(), http.StatusBadRequest)
-			return
-		}
-		
-		w.sendJSONSuccess(wr, map[string]interface{}{
-			"status": "updated",
-			"id":     docID,
-		})
-		
-	case http.MethodDelete:
-		// Удаление документа
-		docID := r.URL.Query().Get("id")
-		if docID == "" {
-			w.sendJSONError(wr, "Document ID required", http.StatusBadRequest)
-			return
-		}
-		
-		if err := coll.Delete(docID); err != nil {
-			w.sendJSONError(wr, err.Error(), http.StatusNotFound)
-			return
-		}
-		
-		w.sendJSONSuccess(wr, map[string]interface{}{
-			"status": "deleted",
-			"id":     docID,
-		})
-		
-	default:
-		w.sendJSONError(wr, "Method not allowed", http.StatusMethodNotAllowed)
-	}
-}
-
-// handleClusterStatus возвращает статус кластера
-func (w *WebUIServer) handleClusterStatus(wr http.ResponseWriter, r *http.Request) {
-	if !w.checkAuth(r) {
-		w.sendJSONError(wr, "Unauthorized", http.StatusUnauthorized)
-		return
-	}
-	
-	if w.coordinator == nil {
-		w.sendJSONError(wr, "Cluster not available", http.StatusServiceUnavailable)
-		return
-	}
-	
-	status := w.coordinator.GetClusterStatus()
-	w.sendJSONSuccess(wr, status)
-}
-
-// handleClusterNodes возвращает список узлов кластера
-func (w *WebUIServer) handleClusterNodes(wr http.ResponseWriter, r *http.Request) {
-	if !w.checkAuth(r) {
-		w.sendJSONError(wr, "Unauthorized", http.StatusUnauthorized)
-		return
-	}
-	
-	if w.coordinator == nil {
-		w.sendJSONError(wr, "Cluster not available", http.StatusServiceUnavailable)
-		return
-	}
-	
-	nodes := w.coordinator.GetAllNodes()
-	w.sendJSONSuccess(wr, nodes)
-}
-
-// handleStats возвращает статистику системы
-func (w *WebUIServer) handleStats(wr http.ResponseWriter, r *http.Request) {
-	if !w.checkAuth(r) {
-		w.sendJSONError(wr, "Unauthorized", http.StatusUnauthorized)
-		return
-	}
-	
-	databases := w.store.ListDatabases()
-	totalDocs := int64(0)
-	totalCollections := 0
-	
-	for _, dbName := range databases {
-		db, _ := w.store.GetDatabase(dbName)
-		if db != nil {
-			collections := db.ListCollections()
-			totalCollections += len(collections)
-			for _, collName := range collections {
-				coll, _ := db.GetCollection(collName)
-				if coll != nil {
-					totalDocs += coll.Count()
-				}
-			}
-		}
-	}
-	
-	stats := map[string]interface{}{
-		"databases":         len(databases),
-		"collections":       totalCollections,
-		"documents":         totalDocs,
-		"storage_used_mb":   float64(w.store.GetPageSize()*int64(len(databases))) / (1024 * 1024),
-		"uptime_seconds":    time.Now().Unix(),
-		"cluster_enabled":   w.coordinator != nil,
-		"replication_factor": 0,
-	}
-	
-	if w.coordinator != nil {
-		stats["replication_factor"] = w.coordinator.GetReplicationFactor()
-		stats["cluster_health"] = w.coordinator.GetClusterStatus().Health
-	}
-	
-	w.sendJSONSuccess(wr, stats)
-}
-
-// handleWebLogin обрабатывает вход в веб-интерфейс
-func (w *WebUIServer) handleWebLogin(wr http.ResponseWriter, r *http.Request) {
-	if r.Method != http.MethodPost {
-		w.sendJSONError(wr, "Method not allowed", http.StatusMethodNotAllowed)
-		return
-	}
-	
-	var creds struct {
-		Username string `json:"username"`
-		Password string `json:"password"`
-	}
-	
-	if err := json.NewDecoder(r.Body).Decode(&creds); err != nil {
-		w.sendJSONError(wr, "Invalid request body", http.StatusBadRequest)
-		return
-	}
-	
-	sessionID, err := w.aclManager.Authenticate(creds.Username, creds.Password)
-	if err != nil {
-		w.sendJSONError(wr, err.Error(), http.StatusUnauthorized)
-		return
-	}
-	
-	// Устанавливаем cookie сессии
-	http.SetCookie(wr, &http.Cookie{
-		Name:     "session_id",
-		Value:    sessionID,
-		Path:     "/",
-		MaxAge:   86400,
-		HttpOnly: true,
-		SameSite: http.SameSiteLaxMode,
-	})
-	
-	w.sendJSONSuccess(wr, map[string]interface{}{
-		"session_id": sessionID,
-		"username":   creds.Username,
-	})
-}
-
-// handleWebLogout обрабатывает выход из веб-интерфейса
-func (w *WebUIServer) handleWebLogout(wr http.ResponseWriter, r *http.Request) {
-	if cookie, err := r.Cookie("session_id"); err == nil {
-		w.aclManager.Logout(cookie.Value)
-	}
-	
-	http.SetCookie(wr, &http.Cookie{
-		Name:     "session_id",
-		Value:    "",
-		Path:     "/",
-		MaxAge:   -1,
-		HttpOnly: true,
-	})
-	
-	w.sendJSONSuccess(wr, map[string]interface{}{
-		"status": "logged out",
-	})
-}
-
-// handleSessionCheck проверяет активность сессии
-func (w *WebUIServer) handleSessionCheck(wr http.ResponseWriter, r *http.Request) {
-	sessionID := w.getSessionID(r)
-	if sessionID == "" {
-		w.sendJSONError(wr, "No session", http.StatusUnauthorized)
-		return
-	}
-	
-	if !w.aclManager.CheckSession(sessionID) {
-		w.sendJSONError(wr, "Invalid session", http.StatusUnauthorized)
-		return
-	}
-	
-	username := w.aclManager.GetUsername(sessionID)
-	w.sendJSONSuccess(wr, map[string]interface{}{
-		"authenticated": true,
-		"username":      username,
-	})
-}
-
-// checkAuth проверяет аутентификацию
-func (w *WebUIServer) checkAuth(r *http.Request) bool {
-	sessionID := w.getSessionID(r)
-	if sessionID == "" {
-		return false
-	}
-	return w.aclManager.CheckSession(sessionID)
-}
-
-// getSessionID возвращает ID сессии из cookie
-func (w *WebUIServer) getSessionID(r *http.Request) string {
-	if cookie, err := r.Cookie("session_id"); err == nil {
-		return cookie.Value
-	}
-	return ""
-}
-
-// sendJSONSuccess отправляет успешный JSON ответ
-func (w *WebUIServer) sendJSONSuccess(wr http.ResponseWriter, data interface{}) {
-	wr.Header().Set("Content-Type", "application/json")
-	wr.WriteHeader(http.StatusOK)
-	json.NewEncoder(wr).Encode(map[string]interface{}{
-		"success": true,
-		"data":    data,
-	})
-}
-
-// sendJSONError отправляет JSON ответ с ошибкой
-func (w *WebUIServer) sendJSONError(wr http.ResponseWriter, errMsg string, statusCode int) {
-	wr.Header().Set("Content-Type", "application/json")
-	wr.WriteHeader(statusCode)
-	json.NewEncoder(wr).Encode(map[string]interface{}{
-		"success": false,
-		"error":   errMsg,
-	})
-}
