From ebf3c6061f92b5c30c16869369995a016c960e1a 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?= Date: Thu, 11 Dec 2025 22:19:49 +0000 Subject: [PATCH] Delete src/server/mod.rs --- src/server/mod.rs | 824 ---------------------------------------------- 1 file changed, 824 deletions(-) delete mode 100644 src/server/mod.rs diff --git a/src/server/mod.rs b/src/server/mod.rs deleted file mode 100644 index 29528cb..0000000 --- a/src/server/mod.rs +++ /dev/null @@ -1,824 +0,0 @@ -// src/server/mod.rs -//! Сервер Futriix - полностью lock-free документо-ориентированная БД -//! -//! Основной модуль сервера, который инициализирует все компоненты системы: -//! - Базу данных с lock-free архитектурой -//! - Lua движок для выполнения скриптов -//! - Менеджер шардинга и репликации -//! - HTTP/HTTPS серверы -//! - CSV менеджер для импорта/экспорта данных -//! -//! Архитектурные особенности: -//! - Все операции выполняются без блокировок (lock-free) -//! - Используются атомарные структуры данных -//! - Поддержка транзакций через Software Transactional Memory -//! - Интеграция с Lua для кастомной логики - -#![allow(dead_code)] - -use std::sync::Arc; -use std::fs::OpenOptions; -use std::io::Write; - -use crate::common::Result; -use crate::common::config::Config; -use crate::lua_shell::LuaShell; - -// Импортируем подмодули -pub mod database; -pub mod lua_engine; -pub mod http; -pub mod sharding; -pub mod csv_import_export; - -/// Функция для логирования в файл -/// Используется для отладки и аудита работы сервера -/// Все сообщения записываются в файл futriix.log с временными метками -fn log_to_file(message: &str) { - if let Ok(mut file) = OpenOptions::new() - .create(true) - .append(true) - .open("futriix.log") - { - let timestamp = chrono::Local::now().format("%Y-%m-%d %H:%M:%S%.3f").to_string(); - let log_message = format!("[{}] {}\n", timestamp, message); - let _ = file.write_all(log_message.as_bytes()); - } -} - -/// Функция для вывода текста с ANSI цветом -/// Использует escape-последовательности для цветного форматирования вывода -#[allow(dead_code)] -fn print_colored(text: &str, ansi_color: &str) { - println!("{}{}\x1b[0m", ansi_color, text); -} - -/// Конвертация HEX цвета в ANSI escape code -/// Поддерживает формат #RRGGBB для установки произвольных цветов -fn hex_to_ansi(hex_color: &str) -> String { - let hex = hex_color.trim_start_matches('#'); - - if hex.len() == 6 { - if let (Ok(r), Ok(g), Ok(b)) = ( - u8::from_str_radix(&hex[0..2], 16), - u8::from_str_radix(&hex[2..4], 16), - u8::from_str_radix(&hex[4..6], 16), - ) { - return format!("\x1b[38;2;{};{};{}m", r, g, b); - } - } - - // Цвет по умолчанию: белый - "\x1b[38;2;255;255;255m".to_string() -} - -/// Основный сервер Futriix с полностью lock-free архитектурой -/// Координирует работу всех компонентов системы и предоставляет -/// единую точку входа для управления базой данных -pub struct FutriixServer { - config: Config, // Конфигурация сервера - database: Arc, // Lock-free база данных - lua_engine: lua_engine::LuaEngine, // Встроенный Lua интерпретатор - sharding_manager: Arc, // Менеджер шардинга и репликации - http_enabled: bool, // Флаг включения HTTP сервера - csv_manager: Arc, // Менеджер CSV операций -} - -impl FutriixServer { - /// Создание нового сервера с lock-free архитектурой - /// Инициализирует все компоненты системы на основе конфигурации - pub async fn new(config_path: &str) -> Result { - // Загрузка конфигурации из файла TOML - let config = Config::load(config_path)?; - - // Инициализация компонентов с lock-free подходами - let database = Arc::new(database::Database::new()); - let lua_engine = lua_engine::LuaEngine::new()?; - - // Генерируем уникальный ID для текущего узла - let node_id = format!("node_{}", uuid::Uuid::new_v4().to_string()[..8].to_string()); - - // Инициализация менеджера шардинга и репликации - let sharding_manager = Arc::new(sharding::ShardingManager::new( - config.sharding.virtual_nodes_per_node, - config.replication.enabled, - config.sharding.min_nodes_for_cluster, - node_id, - )); - - // Инициализация менеджера CSV - let csv_manager = Arc::new(csv_import_export::CsvManager::new( - database.clone(), - config.csv.clone(), - )); - - // Регистрация функций БД в Lua движке - // Это позволяет выполнять Lua скрипты с доступом к базе данных - lua_engine.register_db_functions(database.clone(), sharding_manager.clone())?; - - // Инициализация базы данных (создание системных коллекций и директорий) - FutriixServer::initialize_database(database.clone())?; - - // Проверяем, включен ли HTTP режим в конфигурации - let http_enabled = (config.server.http_port.is_some() && config.server.http) || - (config.server.https_port.is_some() && config.server.https); - - Ok(Self { - config, - database, - lua_engine, - sharding_manager, - http_enabled, - csv_manager, - }) - } - - /// Инициализация базы данных с lock-free структурами - /// Создает системные коллекции, директории для бэкапов и статических файлов - fn initialize_database(db: Arc) -> Result<()> { - // Создаем системные коллекции с lock-free доступом - // Эти коллекции используются для внутренних нужд системы - let _system_collection = db.get_collection("_system"); - let _users_collection = db.get_collection("_users"); - let _logs_collection = db.get_collection("_logs"); - let _procedures_collection = db.get_collection("_procedures"); - let _triggers_collection = db.get_collection("_triggers"); - let _csv_imports_collection = db.get_collection("_csv_imports"); - - // Создаем директорию для бэкапов, если она не существует - let backup_dir = "./futriix_backups"; - if let Err(e) = std::fs::create_dir_all(backup_dir) { - eprintln!("Warning: Failed to create backup directory '{}': {}", backup_dir, e); - } else { - println!("Backup directory created at: {}", backup_dir); - } - - // Создаем директорию для CSV файлов - let csv_dir = "./futriix_csv"; - if let Err(e) = std::fs::create_dir_all(csv_dir) { - eprintln!("Warning: Failed to create CSV directory '{}': {}", csv_dir, e); - } else { - println!("CSV directory created at: {}", csv_dir); - } - - // Создаем поддиректории для CSV импорта и экспорта - let import_dir = "./futriix_csv/import"; - let export_dir = "./futriix_csv/export"; - let _ = std::fs::create_dir_all(import_dir); - let _ = std::fs::create_dir_all(export_dir); - - // Создаем директорию для статических файлов веб-интерфейса - let static_dir = "static"; - if let Err(e) = std::fs::create_dir_all(static_dir) { - eprintln!("Warning: Failed to create static files directory '{}': {}", static_dir, e); - } else { - println!("Static files directory created at: {}", static_dir); - } - - // ИЗМЕНЕНИЕ: Создаем простой default.html для тестирования вместо index.html - // Используем default.html как точку входа для веб-интерфейса Futriix - let default_html_content = r#" - - - Futriix Database Server - - - - - -
-
- -
v1.0.0 • futriix 3i²
-
- -
-
-
🚀
-
Server Status
-
Online
-
Ready to accept connections
-
- -
-
🗄️
-
Database
-
Active
-
Lock-free architecture
-
- -
-
⚙️
-
Lua Engine
-
Running
-
Script execution enabled
-
- - - - -
-
💾
-
Storage
-
Ready
-
CSV import/export available
-
-
- -
-
System Information
-
-
-
Server Version
-
Futriix 1.0.0
-
-
-
Architecture
-
Wait-Free / Lock-Free
-
-
-
Protocol Support
-
HTTP/1.1, HTTP/2, HTTPS
-
-
-
Default Ports
-
HTTP: 9090, HTTPS: 8443
-
-
- -
-
-
📊
-
Real-time Analytics
-
-
-
🔒
-
Atomic Transactions
-
-
-
🚀
-
High Performance
-
-
-
📝
-
Lua Scripting
-
-
-
🔄
-
Auto-Sharding
-
-
-
💾
-
CSV Import/Export
-
-
-
- -
- API Status - Collections - Documentation - GitHub -
- -
-
Server Time
-
Loading...
-
- -
-

© 2025 Futriix Database Server. All rights reserved.

-

Built with Rust • Lock-Free Architecture • Enterprise Ready

-
-
- - - -"#; - - // ИЗМЕНЕНИЕ: Сохраняем как default.html вместо index.html - // Это обеспечивает лучшую совместимость и избегает конфликтов с другими системами - if let Err(e) = std::fs::write("static/default.html", default_html_content) { - eprintln!("Warning: Failed to create default.html: {}", e); - } else { - println!("Created enhanced default.html in static directory"); - println!("Web interface will be available at: http://localhost:9090/default.html"); - } - - let message = "Database initialized with system collections"; - println!("{}", message); - log_to_file(message); - - Ok(()) - } - - /// Запуск сервера с lock-free архитектурой - /// Координирует запуск HTTP серверов и интерактивной оболочки - pub async fn run(&self) -> Result<()> { - // Определяем режим работы и имя кластера - let cluster_name = &self.config.cluster.name; - - println!("Run: cluster (cluster: '{}')", cluster_name); - - log_to_file("Futriix Database Server started"); - log_to_file(&format!("Run: cluster (cluster: '{}')", cluster_name)); - - // Сначала запускаем HTTP серверы и ждем их запуска - if self.http_enabled { - self.start_http_servers().await?; - } else { - println!("HTTP/HTTPS servers disabled in configuration"); - } - - // Добавляем пустую строку после информации о серверах - println!(); - - let mut lua_shell = LuaShell::new( - self.lua_engine.clone(), - self.database.clone(), - self.sharding_manager.clone(), - self.csv_manager.clone(), - ); - - // Запуск интерактивной оболочки - lua_shell.run().await?; - - Ok(()) - } - - /// Запуск HTTP/HTTPS серверов с ожиданием их готовности - /// Создает отдельные задачи для каждого сервера и управляет их жизненным циклом - async fn start_http_servers(&self) -> Result<()> { - let static_config = self::http::StaticFilesConfig::default(); - let acl_config = self::http::AclConfig { - enabled: self.config.acl.enabled, - allowed_ips: self.config.acl.allowed_ips.clone(), - denied_ips: self.config.acl.denied_ips.clone(), - }; - - let mut http_server_handles = Vec::new(); - - // Запуск HTTP сервера, если настроен и включен - if let Some(http_port) = self.config.server.http_port { - if self.config.server.http { - let http_addr = format!("{}:{}", self.config.server.host, http_port); - let http_config = self::http::HttpConfig { - enabled: true, - port: http_port, - http2_enabled: self.config.server.http2_enabled.unwrap_or(false), - }; - - let db_clone = self.database.clone(); - let static_config_clone = static_config.clone(); - let acl_config_clone = acl_config.clone(); - - println!("Starting HTTP server on {}", http_addr); - - // Запускаем в фоновой задаче - let handle = tokio::spawn(async move { - match self::http::start_http_server(&http_addr, db_clone, static_config_clone, http_config, acl_config_clone).await { - Ok(_) => { - let message = format!("HTTP server started on {}", http_addr); - println!("{}", message); - log_to_file(&message); - } - Err(e) => { - let message = format!("Failed to start HTTP server: {}", e); - eprintln!("{}", message); - log_to_file(&message); - } - } - }); - - http_server_handles.push(handle); - } else { - println!("HTTP server disabled in configuration"); - } - } - - // Запуск HTTPS сервера, если настроен и включен - if let Some(https_port) = self.config.server.https_port { - if self.config.server.https && self.config.tls.enabled { - let https_addr = format!("{}:{}", self.config.server.host, https_port); - let tls_config = self::http::TlsConfig { - enabled: self.config.tls.enabled, - cert_path: self.config.tls.cert_path.clone(), - key_path: self.config.tls.key_path.clone(), - }; - - let db_clone = self.database.clone(); - let static_config_clone = static_config.clone(); - let acl_config_clone = acl_config.clone(); - - println!("Starting HTTPS server on {}", https_addr); - - let handle = tokio::spawn(async move { - match self::http::start_https_server(&https_addr, db_clone, static_config_clone, tls_config, acl_config_clone).await { - Ok(_) => { - let message = format!("HTTPS server started on {}", https_addr); - println!("{}", message); - log_to_file(&message); - } - Err(e) => { - let message = format!("Failed to start HTTPS server: {}", e); - eprintln!("{}", message); - log_to_file(&message); - } - } - }); - - http_server_handles.push(handle); - } else { - if !self.config.tls.enabled { - println!("HTTPS disabled: TLS not enabled in configuration"); - } else { - println!("HTTPS server disabled in configuration"); - } - } - } - - // Ждем небольшое время, чтобы серверы успели стартовать - if !http_server_handles.is_empty() { - println!("Waiting for HTTP servers to start..."); - tokio::time::sleep(tokio::time::Duration::from_millis(100)).await; - } - - Ok(()) - } - - /// Получение менеджера шардинга для внешнего использования - #[allow(dead_code)] - pub fn get_sharding_manager(&self) -> Arc { - self.sharding_manager.clone() - } - - /// Получение менеджера CSV для внешнего использования - #[allow(dead_code)] - pub fn get_csv_manager(&self) -> Arc { - self.csv_manager.clone() - } - - /// Получение базы данных для внешнего использования - #[allow(dead_code)] - pub fn get_database(&self) -> Arc { - self.database.clone() - } - - /// Получение Lua движка для внешнего использования - #[allow(dead_code)] - pub fn get_lua_engine(&self) -> lua_engine::LuaEngine { - self.lua_engine.clone() - } -}