+```
+
+Параметры:
+- `tail`: количество строк для получения (или "all")
+- `since`: временная метка последнего обновления (опционально)
+
+## Переменные состояния
```javascript
-// Интервал обновления
-ajaxUpdateIntervalMs
-
-// Состояние активности
-ajaxUpdateEnabled
-
-// Состояние для каждого контейнера (для multi-view)
-containerStates // Map: containerId -> {lastTimestamp, lastSecondCount}
+let ajaxUpdateEnabled = true; // Состояние AJAX обновления (по умолчанию включен)
+let ajaxUpdateIntervalMs = 2000; // Интервал обновления в миллисекундах
+let ajaxUpdateInterval = null; // ID интервала
+const containerStates = new Map(); // Состояние контейнеров для отслеживания обновлений
```
-## Особенности реализации
+## Функции управления
-### Обработка новых логов
+### enableAjaxLogUpdate(intervalMs)
+Включает AJAX обновление логов с заданным интервалом.
-1. **Парсинг временных меток**: Система извлекает временные метки из логов Docker
-2. **Добавление в DOM**: Новые логи добавляются в конец существующего контента
-3. **Применение фильтров**: Автоматически применяются активные фильтры
-4. **Обновление счетчиков**: Пересчитываются счетчики уровней логов
-5. **Очистка дубликатов**: Удаляются дублированные строки
+### disableAjaxLogUpdate()
+Отключает AJAX обновление логов.
-### Управление состоянием
+### toggleAjaxLogUpdate()
+Переключает состояние AJAX обновления.
-- AJAX обновление автоматически останавливается при смене контейнера
-- При переключении в multi-view режим обновление также останавливается
-- Состояние контейнеров сбрасывается при смене режимов просмотра
-- В multi-view режиме состояние отслеживается отдельно для каждого контейнера
+### performAjaxLogUpdate()
+Выполняет одно обновление логов через AJAX.
-### Обработка ошибок
+### updateContainerLogs(containerId, tailLines, token)
+Обновляет логи для конкретного контейнера.
-- Ошибки сети не останавливают обновление
-- Все ошибки логируются в консоль
-- При отсутствии токена авторизации обновление пропускается
+### updateRefreshButtonVisibility()
+Обновляет видимость кнопки refresh и состояние кнопки update в зависимости от состояния AJAX autoupdate.
-## Преимущества
+### setAjaxUpdateState(enabled)
+Обновляет визуальное состояние кнопки update (зеленая/красная) в зависимости от состояния AJAX autoupdate.
-1. **Низкая нагрузка**: Только новые логи передаются по сети
-2. **Надежность**: Простая HTTP архитектура без WebSocket сложностей
-3. **Гибкость**: Настраиваемый интервал обновления
-4. **Совместимость**: Работает с существующими фильтрами и счетчиками
-5. **Производительность**: Минимальное влияние на производительность браузера
+## Интеграция с существующим кодом
-## Ограничения
+AJAX update интегрируется с существующими функциями:
-1. **Задержка**: Обновление происходит с заданным интервалом, не в реальном времени
-2. **Ограничения браузера**: Может быть ограничено политиками CORS
-3. **Нагрузка на сервер**: При большом количестве контейнеров может создавать нагрузку
+- **switchToSingle**: Останавливает AJAX обновление при смене контейнера
+- **switchToMultiView**: Останавливает AJAX обновление при переключении в multi-view
+- **refreshLogsAndCounters**: Ручное обновление логов (кнопка refresh)
-## Автор
+## Логирование
-Сергей Антропов
-Сайт: https://devops.org.ru
+Все операции AJAX update логируются в консоль браузера:
+
+```javascript
+console.log('AJAX обновление логов включено с интервалом 2000ms');
+console.log('AJAX обновление логов отключено');
+console.log('AJAX Update: Обновляем 2 контейнеров: ["container1", "container2"]');
+```
+
+## Обработка ошибок
+
+При ошибках AJAX запросов:
+
+- Обновление не останавливается автоматически
+- Ошибки логируются в консоль
+- Пользователь может вручную отключить обновление через чекбокс
+
+## Совместимость
+
+- Работает с существующими WebSocket соединениями
+- Поддерживает все режимы просмотра (single-view, multi-view)
+- Совместимо с фильтрацией и настройками уровней логирования
diff --git a/app/scripts/test_ajax_no_history.py b/app/scripts/test_ajax_no_history.py
deleted file mode 100644
index e682f68..0000000
--- a/app/scripts/test_ajax_no_history.py
+++ /dev/null
@@ -1,163 +0,0 @@
-#!/usr/bin/env python3
-"""
-Тест для проверки того, что при включенном AJAX обновлении
-история логов не загружается через WebSocket
-Автор: Сергей Антропов
-Сайт: https://devops.org.ru
-"""
-
-import asyncio
-import aiohttp
-import json
-import time
-from datetime import datetime
-
-async def test_ajax_no_history():
- """Тестирование того, что при AJAX обновлении история не загружается"""
-
- print("🧪 Тестирование AJAX обновления без загрузки истории")
- print("=" * 60)
-
- url = "http://localhost:9001"
- username = "admin"
- password = "admin"
-
- print(f"📡 URL: {url}")
- print(f"👤 Пользователь: {username}")
- print("=" * 50)
-
- async with aiohttp.ClientSession() as session:
- try:
- # 1. Получаем токен авторизации
- print("🔐 Получение токена авторизации...")
- auth_data = {'username': username, 'password': password}
- async with session.post(f'{url}/api/auth/login', json=auth_data) as response:
- if response.status != 200:
- print(f"❌ Ошибка авторизации: {response.status}")
- return False
-
- auth_response = await response.json()
- token = auth_response.get('access_token')
- if not token:
- print("❌ Токен не получен")
- return False
-
- print("✅ Токен получен успешно")
-
- # 2. Получаем список сервисов
- print("\n📋 Получение списка сервисов...")
- headers = {'Authorization': f'Bearer {token}'}
- async with session.get(f'{url}/api/services', headers=headers) as response:
- if response.status != 200:
- print(f"❌ Ошибка получения сервисов: {response.status}")
- return False
-
- services = await response.json()
- if not services:
- print("❌ Сервисы не найдены")
- return False
-
- # Выбираем первый сервис для тестирования
- service = services[0]
- container_id = service['id']
- container_name = service['name']
-
- print(f"✅ Выбран сервис: {container_name} ({container_id})")
-
- # 3. Получаем настройки приложения
- print("\n⚙️ Получение настроек приложения...")
- async with session.get(f'{url}/api/settings', headers=headers) as response:
- if response.status == 200:
- settings = await response.json()
- ajax_interval = settings.get('ajax_update_interval', 2000)
- print(f"✅ AJAX интервал: {ajax_interval}ms")
- else:
- print("⚠️ Не удалось получить настройки")
- ajax_interval = 2000
-
- # 4. Тестируем AJAX обновление без загрузки истории
- print(f"\n📊 Тестирование AJAX обновления для {container_name}...")
-
- # Первый запрос - получаем последние логи
- print("📤 Первый AJAX запрос (получение последних логов)...")
- start_time = time.time()
-
- url_params = f'/api/logs/{container_id}?tail=10'
- async with session.get(f'{url}{url_params}', headers=headers) as response:
- if response.status != 200:
- print(f"❌ Ошибка первого запроса: {response.status}")
- return False
-
- data = await response.json()
- first_logs_count = len(data.get('logs', []))
- first_timestamp = data.get('timestamp')
-
- first_request_time = (time.time() - start_time) * 1000
- print(f"✅ Получено {first_logs_count} строк логов за {first_request_time:.2f}ms")
- print(f"📅 Временная метка: {first_timestamp}")
-
- # 5. Ждем немного и делаем второй запрос
- print(f"\n⏳ Ожидание {ajax_interval/1000:.1f} секунды...")
- await asyncio.sleep(ajax_interval / 1000)
-
- print("📤 Второй AJAX запрос (проверка новых логов)...")
- start_time = time.time()
-
- # Второй запрос с параметром since
- url_params = f'/api/logs/{container_id}?tail=10&since={first_timestamp}'
- async with session.get(f'{url}{url_params}', headers=headers) as response:
- if response.status != 200:
- print(f"❌ Ошибка второго запроса: {response.status}")
- return False
-
- data = await response.json()
- second_logs_count = len(data.get('logs', []))
- second_timestamp = data.get('timestamp')
-
- second_request_time = (time.time() - start_time) * 1000
- print(f"✅ Получено {second_logs_count} строк логов за {second_request_time:.2f}ms")
- print(f"📅 Временная метка: {second_timestamp}")
-
- # 6. Анализируем результаты
- print(f"\n📈 Анализ результатов:")
- print(f" Первый запрос: {first_logs_count} строк за {first_request_time:.2f}ms")
- print(f" Второй запрос: {second_logs_count} строк за {second_request_time:.2f}ms")
-
- if second_logs_count == 0:
- print("✅ Второй запрос вернул 0 строк - это правильно, новых логов нет")
- else:
- print(f"ℹ️ Второй запрос вернул {second_logs_count} строк - возможно, появились новые логи")
-
- # 7. Проверяем, что WebSocket не используется для истории
- print(f"\n🔍 Проверка отсутствия WebSocket соединений...")
- print("✅ При включенном AJAX обновлении WebSocket соединения не должны открываться для загрузки истории")
- print("✅ Это означает, что история логов не загружается, что ускоряет открытие контейнера")
-
- print(f"\n🎉 Тест завершен успешно!")
- print(f"✅ AJAX обновление работает без загрузки истории логов")
- return True
-
- except Exception as e:
- print(f"❌ Ошибка тестирования: {e}")
- return False
-
-async def main():
- """Основная функция"""
- print("🚀 Запуск теста AJAX обновления без загрузки истории")
- print("=" * 60)
-
- result = await test_ajax_no_history()
-
- print("\n" + "=" * 60)
- if result:
- print("🎉 Все тесты прошли успешно!")
- print("✅ AJAX обновление работает корректно без загрузки истории")
- else:
- print("❌ Тесты завершились с ошибками")
-
- return result
-
-if __name__ == "__main__":
- import sys
- result = asyncio.run(main())
- sys.exit(0 if result else 1)
diff --git a/app/scripts/test_ajax_update.py b/app/scripts/test_ajax_update.py
deleted file mode 100644
index 6f976bd..0000000
--- a/app/scripts/test_ajax_update.py
+++ /dev/null
@@ -1,259 +0,0 @@
-#!/usr/bin/env python3
-# -*- coding: utf-8 -*-
-"""
-Тест AJAX обновления логов
-Автор: Сергей Антропов
-Сайт: https://devops.org.ru
-"""
-
-import asyncio
-import aiohttp
-import json
-import time
-from datetime import datetime
-import os
-import sys
-
-# Добавляем корневую директорию в путь
-sys.path.append(os.path.dirname(os.path.dirname(os.path.dirname(__file__))))
-
-async def test_ajax_logs_endpoint():
- """Тестирование эндпоинта AJAX логов"""
-
- # Настройки
- base_url = "http://localhost:9001"
- username = os.getenv("LOGBOARD_USER", "admin")
- password = os.getenv("LOGBOARD_PASS", "admin")
-
- print(f"🧪 Тестирование AJAX обновления логов")
- print(f"📡 URL: {base_url}")
- print(f"👤 Пользователь: {username}")
- print("=" * 50)
-
- async with aiohttp.ClientSession() as session:
- try:
- # 1. Получаем токен авторизации
- print("🔐 Получение токена авторизации...")
- auth_data = {
- "username": username,
- "password": password
- }
-
- async with session.post(f"{base_url}/api/auth/login", json=auth_data) as response:
- if response.status != 200:
- print(f"❌ Ошибка авторизации: {response.status}")
- return False
-
- auth_response = await response.json()
- token = auth_response.get("access_token")
-
- if not token:
- print("❌ Токен не получен")
- return False
-
- print("✅ Токен получен успешно")
-
- # 2. Получаем список контейнеров
- print("\n📋 Получение списка контейнеров...")
- headers = {"Authorization": f"Bearer {token}"}
-
- async with session.get(f"{base_url}/api/services", headers=headers) as response:
- if response.status != 200:
- print(f"❌ Ошибка получения контейнеров: {response.status}")
- return False
-
- containers = await response.json()
-
- if not containers:
- print("❌ Контейнеры не найдены")
- return False
-
- # Берем первый запущенный контейнер
- running_containers = [c for c in containers if c.get("status") == "running"]
- if not running_containers:
- print("❌ Запущенные контейнеры не найдены")
- return False
-
- test_container = running_containers[0]
- container_id = test_container["id"]
- container_name = test_container["name"]
-
- print(f"✅ Выбран контейнер: {container_name} ({container_id[:12]}...)")
-
- # 3. Тестируем эндпоинт AJAX логов
- print(f"\n📊 Тестирование эндпоинта /api/logs/{container_id[:12]}...")
-
- # Первый запрос
- print("📤 Первый запрос (получение последних логов)...")
- url = f"{base_url}/api/logs/{container_id}"
- params = {"tail": 10}
-
- async with session.get(url, headers=headers, params=params) as response:
- if response.status != 200:
- print(f"❌ Ошибка получения логов: {response.status}")
- return False
-
- data = await response.json()
-
- print(f"✅ Получено {data.get('total_lines', 0)} строк логов")
- print(f"📅 Временная метка: {data.get('timestamp', 'N/A')}")
-
- # Сохраняем временную метку для следующего запроса
- first_timestamp = data.get('timestamp')
-
- if data.get('logs'):
- print("📝 Пример лога:")
- sample_log = data['logs'][0]
- print(f" Время: {sample_log.get('timestamp', 'N/A')}")
- print(f" Сообщение: {sample_log.get('message', 'N/A')[:100]}...")
-
- # 4. Ждем немного и делаем второй запрос
- print(f"\n⏳ Ожидание 3 секунды...")
- await asyncio.sleep(3)
-
- print("📤 Второй запрос (получение логов без since)...")
- params = {"tail": 10}
-
- async with session.get(url, headers=headers, params=params) as response:
- if response.status != 200:
- print(f"❌ Ошибка получения логов: {response.status}")
- return False
-
- data = await response.json()
-
- print(f"✅ Получено {data.get('total_lines', 0)} строк логов")
- print(f"📅 Временная метка: {data.get('timestamp', 'N/A')}")
-
- if data.get('logs'):
- print("📝 Пример лога:")
- sample_log = data['logs'][0]
- print(f" Время: {sample_log.get('timestamp', 'N/A')}")
- print(f" Сообщение: {sample_log.get('message', 'N/A')[:100]}...")
-
- # 5. Тестируем статистику логов
- print(f"\n📈 Тестирование статистики логов...")
- stats_url = f"{base_url}/api/logs/stats/{container_id}"
-
- async with session.get(stats_url, headers=headers) as response:
- if response.status != 200:
- print(f"❌ Ошибка получения статистики: {response.status}")
- return False
-
- stats = await response.json()
-
- print("✅ Статистика логов:")
- print(f" DEBUG: {stats.get('debug', 0)}")
- print(f" INFO: {stats.get('info', 0)}")
- print(f" WARN: {stats.get('warn', 0)}")
- print(f" ERROR: {stats.get('error', 0)}")
-
- print("\n🎉 Все тесты прошли успешно!")
- return True
-
- except Exception as e:
- print(f"❌ Ошибка тестирования: {e}")
- return False
-
-async def test_ajax_performance():
- """Тестирование производительности AJAX запросов"""
-
- print(f"\n🚀 Тестирование производительности AJAX запросов")
- print("=" * 50)
-
- # Настройки
- base_url = "http://localhost:9001"
- username = os.getenv("LOGBOARD_USER", "admin")
- password = os.getenv("LOGBOARD_PASS", "admin")
-
- async with aiohttp.ClientSession() as session:
- try:
- # Получаем токен
- auth_data = {"username": username, "password": password}
- async with session.post(f"{base_url}/api/auth/login", json=auth_data) as response:
- auth_response = await response.json()
- token = auth_response.get("access_token")
- headers = {"Authorization": f"Bearer {token}"}
-
- # Получаем контейнер
- async with session.get(f"{base_url}/api/services", headers=headers) as response:
- containers = await response.json()
- running_containers = [c for c in containers if c.get("status") == "running"]
- if not running_containers:
- print("❌ Запущенные контейнеры не найдены")
- return False
-
- container_id = running_containers[0]["id"]
-
- # Тестируем производительность
- url = f"{base_url}/api/logs/{container_id}"
- params = {"tail": 50}
-
- print("📊 Выполнение 10 последовательных запросов...")
- start_time = time.time()
-
- for i in range(10):
- request_start = time.time()
- async with session.get(url, headers=headers, params=params) as response:
- await response.json()
- request_time = (time.time() - request_start) * 1000
- print(f" Запрос {i+1}: {request_time:.2f}ms")
-
- # Небольшая пауза между запросами
- await asyncio.sleep(0.1)
-
- total_time = time.time() - start_time
- avg_time = (total_time / 10) * 1000
-
- print(f"\n📈 Результаты производительности:")
- print(f" Общее время: {total_time:.2f}с")
- print(f" Среднее время запроса: {avg_time:.2f}ms")
- print(f" Запросов в секунду: {10/total_time:.2f}")
-
- if avg_time < 100:
- print("✅ Отличная производительность!")
- elif avg_time < 500:
- print("✅ Хорошая производительность")
- else:
- print("⚠️ Производительность может быть улучшена")
-
- return True
-
- except Exception as e:
- print(f"❌ Ошибка тестирования производительности: {e}")
- return False
-
-async def main():
- """Основная функция тестирования"""
- print("🧪 Запуск тестов AJAX обновления логов")
- print("=" * 60)
-
- # Проверяем, что сервер запущен
- try:
- async with aiohttp.ClientSession() as session:
- async with session.get("http://localhost:9001/healthz") as response:
- if response.status != 200:
- print("❌ Сервер LogBoard+ не запущен на порту 9001")
- print(" Запустите сервер командой: make up")
- return False
- except Exception:
- print("❌ Не удается подключиться к серверу LogBoard+")
- print(" Убедитесь, что сервер запущен: make up")
- return False
-
- # Запускаем тесты
- success1 = await test_ajax_logs_endpoint()
- success2 = await test_ajax_performance()
-
- print("\n" + "=" * 60)
- if success1 and success2:
- print("🎉 Все тесты прошли успешно!")
- print("✅ AJAX обновление логов работает корректно")
- return True
- else:
- print("❌ Некоторые тесты не прошли")
- print("🔧 Проверьте логи сервера и настройки")
- return False
-
-if __name__ == "__main__":
- result = asyncio.run(main())
- sys.exit(0 if result else 1)
diff --git a/app/scripts/test_all_logs.py b/app/scripts/test_all_logs.py
deleted file mode 100644
index 5aa10a7..0000000
--- a/app/scripts/test_all_logs.py
+++ /dev/null
@@ -1,148 +0,0 @@
-#!/usr/bin/env python3
-"""
-Тест для проверки опции "all logs" в AJAX обновлении
-Автор: Сергей Антропов
-Сайт: https://devops.org.ru
-"""
-
-import asyncio
-import aiohttp
-import json
-import time
-from datetime import datetime
-
-async def test_all_logs():
- """Тестирование опции 'all logs' в AJAX обновлении"""
-
- print("🧪 Тестирование опции 'all logs' в AJAX обновлении")
- print("=" * 60)
-
- url = "http://localhost:9001"
- username = "admin"
- password = "admin"
-
- print(f"📡 URL: {url}")
- print(f"👤 Пользователь: {username}")
- print("=" * 50)
-
- async with aiohttp.ClientSession() as session:
- try:
- # 1. Получаем токен авторизации
- print("🔐 Получение токена авторизации...")
- auth_data = {'username': username, 'password': password}
- async with session.post(f'{url}/api/auth/login', json=auth_data) as response:
- if response.status != 200:
- print(f"❌ Ошибка авторизации: {response.status}")
- return False
-
- auth_response = await response.json()
- token = auth_response.get('access_token')
- if not token:
- print("❌ Токен не получен")
- return False
-
- print("✅ Токен получен успешно")
-
- # 2. Получаем список сервисов
- print("\n📋 Получение списка сервисов...")
- headers = {'Authorization': f'Bearer {token}'}
- async with session.get(f'{url}/api/services', headers=headers) as response:
- if response.status != 200:
- print(f"❌ Ошибка получения сервисов: {response.status}")
- return False
-
- services = await response.json()
- if not services:
- print("❌ Сервисы не найдены")
- return False
-
- # Выбираем первый сервис для тестирования
- service = services[0]
- container_id = service['id']
- container_name = service['name']
-
- print(f"✅ Выбран сервис: {container_name} ({container_id})")
-
- # 3. Тестируем обычный запрос с ограничением
- print(f"\n📊 Тестирование обычного запроса (tail=10)...")
- start_time = time.time()
-
- url_params = f'/api/logs/{container_id}?tail=10'
- async with session.get(f'{url}{url_params}', headers=headers) as response:
- if response.status != 200:
- print(f"❌ Ошибка обычного запроса: {response.status}")
- return False
-
- data = await response.json()
- limited_logs_count = len(data.get('logs', []))
- limited_request_time = (time.time() - start_time) * 1000
-
- print(f"✅ Получено {limited_logs_count} строк логов за {limited_request_time:.2f}ms")
-
- # 4. Тестируем запрос всех логов
- print(f"\n📊 Тестирование запроса всех логов (tail=all)...")
- start_time = time.time()
-
- url_params = f'/api/logs/{container_id}?tail=all'
- async with session.get(f'{url}{url_params}', headers=headers) as response:
- if response.status != 200:
- print(f"❌ Ошибка запроса всех логов: {response.status}")
- return False
-
- data = await response.json()
- all_logs_count = len(data.get('logs', []))
- all_request_time = (time.time() - start_time) * 1000
-
- print(f"✅ Получено {all_logs_count} строк логов за {all_request_time:.2f}ms")
-
- # 5. Анализируем результаты
- print(f"\n📈 Анализ результатов:")
- print(f" Обычный запрос (tail=10): {limited_logs_count} строк за {limited_request_time:.2f}ms")
- print(f" Запрос всех логов (tail=all): {all_logs_count} строк за {all_request_time:.2f}ms")
-
- if all_logs_count >= limited_logs_count:
- print("✅ Запрос всех логов вернул больше или столько же строк - это правильно")
- else:
- print("⚠️ Запрос всех логов вернул меньше строк - возможно, в контейнере мало логов")
-
- # 6. Проверяем производительность
- print(f"\n⚡ Анализ производительности:")
- if all_request_time > limited_request_time:
- print(f"✅ Запрос всех логов занял больше времени ({all_request_time:.2f}ms vs {limited_request_time:.2f}ms) - это ожидаемо")
- else:
- print(f"ℹ️ Запрос всех логов занял меньше времени - возможно, в контейнере мало логов")
-
- # 7. Проверяем, что API правильно обрабатывает параметр
- print(f"\n🔍 Проверка обработки параметра 'all':")
- print("✅ API правильно обрабатывает параметр tail=all")
- print("✅ Возвращает все доступные логи контейнера")
- print("✅ Время запроса увеличивается при большем количестве логов")
-
- print(f"\n🎉 Тест завершен успешно!")
- print(f"✅ Опция 'all logs' работает корректно")
- return True
-
- except Exception as e:
- print(f"❌ Ошибка тестирования: {e}")
- return False
-
-async def main():
- """Основная функция"""
- print("🚀 Запуск теста опции 'all logs'")
- print("=" * 60)
-
- result = await test_all_logs()
-
- print("\n" + "=" * 60)
- if result:
- print("🎉 Все тесты прошли успешно!")
- print("✅ Опция 'all logs' работает корректно")
- else:
- print("❌ Тесты завершились с ошибками")
-
- return result
-
-if __name__ == "__main__":
- import sys
- result = asyncio.run(main())
- sys.exit(0 if result else 1)
diff --git a/app/scripts/test_color_formatting.py b/app/scripts/test_color_formatting.py
deleted file mode 100644
index a44883a..0000000
--- a/app/scripts/test_color_formatting.py
+++ /dev/null
@@ -1,166 +0,0 @@
-#!/usr/bin/env python3
-# -*- coding: utf-8 -*-
-"""
-Тест цветового форматирования логов
-Автор: Сергей Антропов
-Сайт: https://devops.org.ru
-"""
-
-import asyncio
-import aiohttp
-import json
-import time
-from datetime import datetime
-import os
-import sys
-
-async def test_color_formatting():
- """Тестирование цветового форматирования логов"""
-
- print("🎨 Тестирование цветового форматирования логов")
- print("=" * 50)
-
- # Настройки
- base_url = "http://localhost:9001"
- username = os.getenv("LOGBOARD_USER", "admin")
- password = os.getenv("LOGBOARD_PASS", "admin")
-
- async with aiohttp.ClientSession() as session:
- try:
- # 1. Получаем токен авторизации
- print("🔐 Получение токена авторизации...")
- auth_data = {
- "username": username,
- "password": password
- }
-
- async with session.post(f"{base_url}/api/auth/login", json=auth_data) as response:
- if response.status != 200:
- print(f"❌ Ошибка авторизации: {response.status}")
- return False
-
- auth_response = await response.json()
- token = auth_response.get("access_token")
-
- if not token:
- print("❌ Токен не получен")
- return False
-
- print("✅ Токен получен успешно")
-
- # 2. Получаем список контейнеров
- print("\n📋 Получение списка контейнеров...")
- headers = {"Authorization": f"Bearer {token}"}
-
- async with session.get(f"{base_url}/api/services", headers=headers) as response:
- if response.status != 200:
- print(f"❌ Ошибка получения контейнеров: {response.status}")
- return False
-
- containers = await response.json()
-
- if not containers:
- print("❌ Контейнеры не найдены")
- return False
-
- # Берем первый запущенный контейнер
- running_containers = [c for c in containers if c.get("status") == "running"]
- if not running_containers:
- print("❌ Запущенные контейнеры не найдены")
- return False
-
- test_container = running_containers[0]
- container_id = test_container["id"]
- container_name = test_container["name"]
-
- print(f"✅ Выбран контейнер: {container_name} ({container_id[:12]}...)")
-
- # 3. Тестируем получение логов с проверкой цветового форматирования
- print(f"\n🎨 Тестирование цветового форматирования для {container_id[:12]}...")
-
- url = f"{base_url}/api/logs/{container_id}"
- params = {"tail": 5}
-
- async with session.get(url, headers=headers, params=params) as response:
- if response.status != 200:
- print(f"❌ Ошибка получения логов: {response.status}")
- return False
-
- data = await response.json()
-
- print(f"✅ Получено {data.get('total_lines', 0)} строк логов")
-
- if data.get('logs'):
- print("\n📝 Анализ логов на предмет цветового форматирования:")
-
- for i, log in enumerate(data['logs'][:3]): # Проверяем первые 3 лога
- message = log.get('message', '')
- raw = log.get('raw', '')
-
- print(f"\n Лог {i+1}:")
- print(f" Сообщение: {message[:100]}...")
- print(f" Сырые данные: {raw[:100]}...")
-
- # Проверяем наличие ANSI кодов
- if '\u001b[' in raw or '\033[' in raw:
- print(" ✅ Обнаружены ANSI коды для цветового форматирования")
- else:
- print(" ℹ️ ANSI коды не обнаружены (нормально для некоторых логов)")
-
- # Проверяем уровни логирования
- message_lower = message.lower()
- if 'error' in message_lower or 'err' in message_lower:
- print(" 🔴 Уровень: ERROR")
- elif 'warning' in message_lower or 'warn' in message_lower:
- print(" 🟡 Уровень: WARNING")
- elif 'info' in message_lower:
- print(" 🔵 Уровень: INFO")
- elif 'debug' in message_lower:
- print(" 🟢 Уровень: DEBUG")
- else:
- print(" ⚪ Уровень: OTHER")
- else:
- print("❌ Логи не получены")
- return False
-
- print("\n🎉 Тест цветового форматирования завершен успешно!")
- return True
-
- except Exception as e:
- print(f"❌ Ошибка тестирования: {e}")
- return False
-
-async def main():
- """Основная функция тестирования"""
- print("🎨 Запуск тестов цветового форматирования логов")
- print("=" * 60)
-
- # Проверяем, что сервер запущен
- try:
- async with aiohttp.ClientSession() as session:
- async with session.get("http://localhost:9001/healthz") as response:
- if response.status != 200:
- print("❌ Сервер LogBoard+ не запущен на порту 9001")
- print(" Запустите сервер командой: make up")
- return False
- except Exception:
- print("❌ Не удается подключиться к серверу LogBoard+")
- print(" Убедитесь, что сервер запущен: make up")
- return False
-
- # Запускаем тесты
- success = await test_color_formatting()
-
- print("\n" + "=" * 60)
- if success:
- print("🎉 Все тесты прошли успешно!")
- print("✅ Цветовое форматирование логов работает корректно")
- return True
- else:
- print("❌ Некоторые тесты не прошли")
- print("🔧 Проверьте логи сервера и настройки")
- return False
-
-if __name__ == "__main__":
- result = asyncio.run(main())
- sys.exit(0 if result else 1)
diff --git a/app/scripts/test_multi_view_ajax.py b/app/scripts/test_multi_view_ajax.py
deleted file mode 100644
index 851e596..0000000
--- a/app/scripts/test_multi_view_ajax.py
+++ /dev/null
@@ -1,285 +0,0 @@
-#!/usr/bin/env python3
-# -*- coding: utf-8 -*-
-"""
-Тест AJAX обновления в multi-view режиме
-Автор: Сергей Антропов
-Сайт: https://devops.org.ru
-"""
-
-import asyncio
-import aiohttp
-import json
-import time
-from datetime import datetime
-import os
-import sys
-
-async def test_multi_view_ajax():
- """Тестирование AJAX обновления в multi-view режиме"""
-
- print("🔄 Тестирование AJAX обновления в multi-view режиме")
- print("=" * 60)
-
- # Настройки
- base_url = "http://localhost:9001"
- username = os.getenv("LOGBOARD_USER", "admin")
- password = os.getenv("LOGBOARD_PASS", "admin")
-
- async with aiohttp.ClientSession() as session:
- try:
- # 1. Получаем токен авторизации
- print("🔐 Получение токена авторизации...")
- auth_data = {
- "username": username,
- "password": password
- }
-
- async with session.post(f"{base_url}/api/auth/login", json=auth_data) as response:
- if response.status != 200:
- print(f"❌ Ошибка авторизации: {response.status}")
- return False
-
- auth_response = await response.json()
- token = auth_response.get("access_token")
-
- if not token:
- print("❌ Токен не получен")
- return False
-
- print("✅ Токен получен успешно")
-
- # 2. Получаем список контейнеров
- print("\n📋 Получение списка контейнеров...")
- headers = {"Authorization": f"Bearer {token}"}
-
- async with session.get(f"{base_url}/api/services", headers=headers) as response:
- if response.status != 200:
- print(f"❌ Ошибка получения контейнеров: {response.status}")
- return False
-
- containers = await response.json()
-
- if not containers:
- print("❌ Контейнеры не найдены")
- return False
-
- # Берем первые 3 запущенных контейнера для multi-view теста
- running_containers = [c for c in containers if c.get("status") == "running"]
- if len(running_containers) < 2:
- print("❌ Недостаточно запущенных контейнеров для multi-view теста (нужно минимум 2)")
- return False
-
- test_containers = running_containers[:3] # Берем первые 3
- print(f"✅ Выбрано {len(test_containers)} контейнеров для multi-view теста:")
- for i, container in enumerate(test_containers):
- print(f" {i+1}. {container['name']} ({container['id'][:12]}...)")
-
- # 3. Тестируем получение логов для каждого контейнера
- print(f"\n🔄 Тестирование AJAX обновления для {len(test_containers)} контейнеров...")
-
- container_results = {}
-
- for i, container in enumerate(test_containers):
- container_id = container["id"]
- container_name = container["name"]
-
- print(f"\n📊 Контейнер {i+1}: {container_name}")
-
- # Первый запрос
- url = f"{base_url}/api/logs/{container_id}"
- params = {"tail": 5}
-
- async with session.get(url, headers=headers, params=params) as response:
- if response.status != 200:
- print(f" ❌ Ошибка получения логов: {response.status}")
- continue
-
- data = await response.json()
- first_count = data.get('total_lines', 0)
- first_timestamp = data.get('timestamp')
-
- print(f" ✅ Первый запрос: {first_count} строк, timestamp: {first_timestamp}")
-
- # Ждем немного
- await asyncio.sleep(1)
-
- # Второй запрос с since
- params = {"tail": 5, "since": first_timestamp}
-
- async with session.get(url, headers=headers, params=params) as response:
- if response.status != 200:
- print(f" ❌ Ошибка получения новых логов: {response.status}")
- continue
-
- data = await response.json()
- second_count = data.get('total_lines', 0)
- second_timestamp = data.get('timestamp')
-
- print(f" ✅ Второй запрос: {second_count} строк, timestamp: {second_timestamp}")
-
- # Сохраняем результаты
- container_results[container_id] = {
- 'name': container_name,
- 'first_count': first_count,
- 'second_count': second_count,
- 'first_timestamp': first_timestamp,
- 'second_timestamp': second_timestamp
- }
-
- # 4. Анализируем результаты
- print(f"\n📈 Анализ результатов multi-view AJAX обновления:")
-
- total_containers = len(container_results)
- successful_containers = 0
-
- for container_id, result in container_results.items():
- print(f"\n 📦 {result['name']} ({container_id[:12]}...):")
- print(f" Первый запрос: {result['first_count']} строк")
- print(f" Второй запрос: {result['second_count']} строк")
-
- if result['second_count'] >= 0: # Успешный запрос
- successful_containers += 1
- print(f" ✅ Статус: Успешно")
- else:
- print(f" ❌ Статус: Ошибка")
-
- print(f"\n📊 Итоговая статистика:")
- print(f" Всего контейнеров: {total_containers}")
- print(f" Успешных: {successful_containers}")
- print(f" Успешность: {successful_containers/total_containers*100:.1f}%")
-
- if successful_containers == total_containers:
- print("\n🎉 Все контейнеры успешно обновляются через AJAX!")
- return True
- else:
- print(f"\n⚠️ {total_containers - successful_containers} контейнеров имеют проблемы")
- return False
-
- except Exception as e:
- print(f"❌ Ошибка тестирования: {e}")
- return False
-
-async def test_concurrent_ajax_requests():
- """Тестирование одновременных AJAX запросов (имитация multi-view)"""
-
- print(f"\n⚡ Тестирование одновременных AJAX запросов")
- print("=" * 50)
-
- # Настройки
- base_url = "http://localhost:9001"
- username = os.getenv("LOGBOARD_USER", "admin")
- password = os.getenv("LOGBOARD_PASS", "admin")
-
- async with aiohttp.ClientSession() as session:
- try:
- # Получаем токен
- auth_data = {"username": username, "password": password}
- async with session.post(f"{base_url}/api/auth/login", json=auth_data) as response:
- auth_response = await response.json()
- token = auth_response.get("access_token")
- headers = {"Authorization": f"Bearer {token}"}
-
- # Получаем контейнеры
- async with session.get(f"{base_url}/api/services", headers=headers) as response:
- containers = await response.json()
- running_containers = [c for c in containers if c.get("status") == "running"]
-
- if len(running_containers) < 2:
- print("❌ Недостаточно контейнеров для теста")
- return False
-
- test_containers = running_containers[:3]
-
- # Тестируем одновременные запросы
- print(f"📊 Выполнение одновременных запросов для {len(test_containers)} контейнеров...")
- start_time = time.time()
-
- async def fetch_container_logs(container):
- container_id = container["id"]
- url = f"{base_url}/api/logs/{container_id}"
- params = {"tail": 3}
-
- try:
- async with session.get(url, headers=headers, params=params) as response:
- data = await response.json()
- return {
- 'container_id': container_id,
- 'name': container['name'],
- 'status': response.status,
- 'lines': data.get('total_lines', 0),
- 'success': response.status == 200
- }
- except Exception as e:
- return {
- 'container_id': container_id,
- 'name': container['name'],
- 'status': 'error',
- 'lines': 0,
- 'success': False,
- 'error': str(e)
- }
-
- # Выполняем запросы одновременно
- tasks = [fetch_container_logs(container) for container in test_containers]
- results = await asyncio.gather(*tasks)
-
- total_time = time.time() - start_time
-
- # Анализируем результаты
- successful = sum(1 for r in results if r['success'])
-
- print(f"\n📈 Результаты одновременных запросов:")
- print(f" Время выполнения: {total_time:.2f}с")
- print(f" Успешных запросов: {successful}/{len(results)}")
- print(f" Среднее время на запрос: {total_time/len(results):.2f}с")
-
- for result in results:
- status_icon = "✅" if result['success'] else "❌"
- print(f" {status_icon} {result['name']}: {result['lines']} строк")
-
- if successful == len(results):
- print("✅ Все одновременные запросы выполнены успешно!")
- return True
- else:
- print(f"⚠️ {len(results) - successful} запросов завершились с ошибкой")
- return False
-
- except Exception as e:
- print(f"❌ Ошибка тестирования одновременных запросов: {e}")
- return False
-
-async def main():
- """Основная функция тестирования"""
- print("🔄 Запуск тестов multi-view AJAX обновления")
- print("=" * 70)
-
- # Проверяем, что сервер запущен
- try:
- async with aiohttp.ClientSession() as session:
- async with session.get("http://localhost:9001/healthz") as response:
- if response.status != 200:
- print("❌ Сервер LogBoard+ не запущен на порту 9001")
- print(" Запустите сервер командой: make up")
- return False
- except Exception:
- print("❌ Не удается подключиться к серверу LogBoard+")
- print(" Убедитесь, что сервер запущен: make up")
- return False
-
- # Запускаем тесты
- success1 = await test_multi_view_ajax()
- success2 = await test_concurrent_ajax_requests()
-
- print("\n" + "=" * 70)
- if success1 and success2:
- print("🎉 Все тесты прошли успешно!")
- print("✅ Multi-view AJAX обновление работает корректно")
- return True
- else:
- print("❌ Некоторые тесты не прошли")
- print("🔧 Проверьте логи сервера и настройки")
- return False
-
-if __name__ == "__main__":
- result = asyncio.run(main())
- sys.exit(0 if result else 1)
diff --git a/app/scripts/test_multi_view_layout.py b/app/scripts/test_multi_view_layout.py
deleted file mode 100644
index 0c6d0a8..0000000
--- a/app/scripts/test_multi_view_layout.py
+++ /dev/null
@@ -1,154 +0,0 @@
-#!/usr/bin/env python3
-"""
-Тест для проверки корректного отображения длинных названий контейнеров
-в multi-view режиме
-Автор: Сергей Антропов
-Сайт: https://devops.org.ru
-"""
-
-import asyncio
-import aiohttp
-import json
-import time
-from datetime import datetime
-
-async def test_multi_view_layout():
- """Тестирование отображения длинных названий в multi-view режиме"""
-
- print("🧪 Тестирование отображения длинных названий в multi-view режиме")
- print("=" * 70)
-
- url = "http://localhost:9001"
- username = "admin"
- password = "admin"
-
- print(f"📡 URL: {url}")
- print(f"👤 Пользователь: {username}")
- print("=" * 50)
-
- async with aiohttp.ClientSession() as session:
- try:
- # 1. Получаем токен авторизации
- print("🔐 Получение токена авторизации...")
- auth_data = {'username': username, 'password': password}
- async with session.post(f'{url}/api/auth/login', json=auth_data) as response:
- if (response.status != 200):
- print(f"❌ Ошибка авторизации: {response.status}")
- return False
-
- auth_response = await response.json()
- token = auth_response.get('access_token')
- if not token:
- print("❌ Токен не получен")
- return False
-
- print("✅ Токен получен успешно")
-
- # 2. Получаем список сервисов
- print("\n📋 Получение списка сервисов...")
- headers = {'Authorization': f'Bearer {token}'}
- async with session.get(f'{url}/api/services', headers=headers) as response:
- if response.status != 200:
- print(f"❌ Ошибка получения сервисов: {response.status}")
- return False
-
- services = await response.json()
- if not services:
- print("❌ Сервисы не найдены")
- return False
-
- print(f"✅ Найдено {len(services)} сервисов")
-
- # Анализируем названия сервисов
- print("\n📊 Анализ названий сервисов:")
- long_names = []
- short_names = []
-
- for service in services:
- name = service['name']
- if len(name) > 30:
- long_names.append(name)
- print(f" 🔴 Длинное название ({len(name)} символов): {name}")
- else:
- short_names.append(name)
- print(f" 🟢 Короткое название ({len(name)} символов): {name}")
-
- print(f"\n📈 Статистика названий:")
- print(f" Всего сервисов: {len(services)}")
- print(f" Коротких названий: {len(short_names)}")
- print(f" Длинных названий: {len(long_names)}")
-
- if long_names:
- print(f"\n⚠️ Обнаружены длинные названия, которые могут вызвать проблемы с отображением:")
- for name in long_names[:3]: # Показываем первые 3
- print(f" - {name}")
-
- print(f"\n✅ Рекомендации:")
- print(f" - CSS стили должны обрезать длинные названия с многоточием")
- print(f" - Кнопки LogLevels не должны уезжать вправо")
- print(f" - Заголовок должен иметь фиксированную высоту")
- else:
- print(f"\n✅ Все названия сервисов имеют приемлемую длину")
-
- # 3. Проверяем API для получения информации о контейнерах
- print(f"\n🔍 Проверка API контейнеров...")
- async with session.get(f'{url}/api/containers', headers=headers) as response:
- if response.status == 200:
- containers = await response.json()
- print(f"✅ API контейнеров доступен, найдено {len(containers)} контейнеров")
- else:
- print(f"⚠️ API контейнеров недоступен: {response.status}")
-
- # 4. Проверяем настройки приложения
- print(f"\n⚙️ Проверка настроек приложения...")
- async with session.get(f'{url}/api/settings', headers=headers) as response:
- if response.status == 200:
- settings = await response.json()
- print(f"✅ Настройки получены:")
- print(f" - AJAX Update Interval: {settings.get('ajax_update_interval')}ms")
- print(f" - Default Tail: {settings.get('default_tail')}")
- print(f" - Skip Unhealthy: {settings.get('skip_unhealthy')}")
- else:
- print(f"⚠️ Не удалось получить настройки: {response.status}")
-
- # 5. Рекомендации по CSS стилям
- print(f"\n🎨 Рекомендации по CSS стилям:")
- print(f" ✅ .multi-view-title должен иметь:")
- print(f" - overflow: hidden")
- print(f" - text-overflow: ellipsis")
- print(f" - white-space: nowrap")
- print(f" - min-width: 0")
- print(f" ✅ .multi-view-levels должен иметь:")
- print(f" - flex-shrink: 0")
- print(f" ✅ .level-btn должен иметь:")
- print(f" - flex-shrink: 0")
- print(f" - max-width: 50px")
-
- print(f"\n🎉 Тест завершен успешно!")
- print(f"✅ Анализ названий сервисов выполнен")
- return True
-
- except Exception as e:
- print(f"❌ Ошибка тестирования: {e}")
- return False
-
-async def main():
- """Основная функция"""
- print("🚀 Запуск теста отображения длинных названий в multi-view")
- print("=" * 70)
-
- result = await test_multi_view_layout()
-
- print("\n" + "=" * 70)
- if result:
- print("🎉 Все тесты прошли успешно!")
- print("✅ Анализ названий сервисов завершен")
- else:
- print("❌ Тесты завершились с ошибками")
-
- return result
-
-if __name__ == "__main__":
- import sys
- result = asyncio.run(main())
- sys.exit(0 if result else 1)
diff --git a/docker-compose.yml b/docker-compose.yml
index 13f809f..d6fdb53 100644
--- a/docker-compose.yml
+++ b/docker-compose.yml
@@ -30,6 +30,16 @@ services:
SMTP_USER: ''
SMTP_PASS: ''
SMTP_FROM: ''
+ # Docker настройки
+ DOCKER_HOST: unix:///var/run/docker.sock
+ DOCKER_NETWORKS: iaas,infrastructure_iaas
+ # Настройки фильтрации контейнеров
+ LOGBOARD_SKIP_UNHEALTHY: 'true'
+ LOGBOARD_CONTAINER_LIST_TIMEOUT: '10'
+ LOGBOARD_CONTAINER_INFO_TIMEOUT: '3'
+ LOGBOARD_HEALTH_CHECK_TIMEOUT: '2'
+ # Настройки AJAX обновления
+ LOGBOARD_AJAX_UPDATE_INTERVAL: '2000'
ports:
- 9001:9001
volumes:
diff --git a/env_comparison.md b/env_comparison.md
new file mode 100644
index 0000000..8dc2e17
--- /dev/null
+++ b/env_comparison.md
@@ -0,0 +1,153 @@
+# Сравнение переменных окружения
+
+## Обзор файлов
+
+- **docker-compose.yml** - переменные окружения, используемые в контейнере
+- **env.example** - пример файла с переменными окружения
+- **.env** - отсутствует (не создан)
+
+## Сравнительная таблица
+
+| Переменная | docker-compose.yml | env.example | Статус |
+|------------|-------------------|-------------|---------|
+| **Основные настройки** |
+| LOGBOARD_PORT | 9001 | 9001 | ✅ Совпадает |
+| LOGBOARD_TAIL | 500 | 500 | ✅ Совпадает |
+| LOGBOARD_USER | admin | admin | ✅ Совпадает |
+| LOGBOARD_PASS | admin | s3cret-change-me | ⚠️ Различается |
+| **Директории и пути** |
+| LOGBOARD_SNAPSHOT_DIR | /app/snapshots | /app/snapshots | ✅ Совпадает |
+| LOGBOARD_INDEX_HTML | ./templates/index.html | ./templates/index.html | ✅ Совпадает |
+| **Временная зона** |
+| TZ_TS | Europe/Moscow | (пусто) | ⚠️ Различается |
+| **Проекты** |
+| COMPOSE_PROJECT_NAME | (пусто) | (закомментировано) | ✅ Совпадает |
+| **Безопасность** |
+| SECRET_KEY | your-secret-key-here | your-secret-key-here | ✅ Совпадает |
+| ENCRYPTION_KEY | your-encryption-key-here | your-encryption-key-here | ✅ Совпадает |
+| **Логирование** |
+| LOG_LEVEL | INFO | INFO | ✅ Совпадает |
+| LOG_FORMAT | json | json | ✅ Совпадает |
+| **Веб-интерфейс** |
+| WEB_TITLE | LogBoard+ | LogBoard+ | ✅ Совпадает |
+| WEB_DESCRIPTION | Веб-панель для просмотра логов микросервисов | Веб-панель для просмотра логов микросервисов | ✅ Совпадает |
+| WEB_VERSION | 1.0.0 | 1.0.0 | ✅ Совпадает |
+| **Производительность** |
+| MAX_CONNECTIONS | 100 | 100 | ✅ Совпадает |
+| CONNECTION_TIMEOUT | 30 | 30 | ✅ Совпадает |
+| READ_TIMEOUT | 60 | 60 | ✅ Совпадает |
+| **Аутентификация** |
+| AUTH_ENABLED | true | true | ✅ Совпадает |
+| AUTH_METHOD | jwt | jwt | ✅ Совпадает |
+| SESSION_TIMEOUT | 3600 | 3600 | ✅ Совпадает |
+| **Уведомления** |
+| NOTIFICATIONS_ENABLED | false | false | ✅ Совпадает |
+| SMTP_HOST | (пусто) | (пусто) | ✅ Совпадает |
+| SMTP_PORT | 587 | 587 | ✅ Совпадает |
+| SMTP_USER | (пусто) | (пусто) | ✅ Совпадает |
+| SMTP_PASS | (пусто) | (пусто) | ✅ Совпадает |
+| SMTP_FROM | (пусто) | (пусто) | ✅ Совпадает |
+
+## Переменные только в env.example
+
+| Переменная | Значение | Описание |
+|------------|----------|----------|
+| DOCKER_HOST | unix:///var/run/docker.sock | Путь к Docker socket |
+| DOCKER_TLS_VERIFY | (пусто) | Проверка TLS для Docker |
+| DOCKER_CERT_PATH | (пусто) | Путь к сертификатам Docker |
+| DOCKER_NETWORKS | iaas,infrastructure_iaas | Внешние сети Docker |
+| LOGBOARD_SKIP_UNHEALTHY | true | Пропускать нездоровые контейнеры |
+| LOGBOARD_CONTAINER_LIST_TIMEOUT | 10 | Таймаут списка контейнеров |
+| LOGBOARD_CONTAINER_INFO_TIMEOUT | 3 | Таймаут информации о контейнере |
+| LOGBOARD_HEALTH_CHECK_TIMEOUT | 2 | Таймаут health check |
+| LOGBOARD_AJAX_UPDATE_INTERVAL | 2000 | Интервал AJAX обновления |
+
+## Переменные только в docker-compose.yml
+
+| Переменная | Значение | Описание |
+|------------|----------|----------|
+| (нет) | - | Все переменные из docker-compose.yml есть в env.example |
+
+## Рекомендации
+
+### 1. Создать .env файл
+```bash
+cp env.example .env
+```
+
+### 2. Обновить docker-compose.yml
+Добавить недостающие переменные из env.example:
+
+```yaml
+environment:
+ # Существующие переменные...
+
+ # Добавить недостающие:
+ DOCKER_HOST: unix:///var/run/docker.sock
+ DOCKER_NETWORKS: iaas,infrastructure_iaas
+ LOGBOARD_SKIP_UNHEALTHY: 'true'
+ LOGBOARD_CONTAINER_LIST_TIMEOUT: '10'
+ LOGBOARD_CONTAINER_INFO_TIMEOUT: '3'
+ LOGBOARD_HEALTH_CHECK_TIMEOUT: '2'
+ LOGBOARD_AJAX_UPDATE_INTERVAL: '2000'
+```
+
+### 3. Исправить различия
+- **LOGBOARD_PASS**: В docker-compose.yml используется `admin`, в env.example - `s3cret-change-me`
+- **TZ_TS**: В docker-compose.yml установлено `Europe/Moscow`, в env.example - пусто
+
+### 4. Безопасность
+- Изменить `SECRET_KEY` и `ENCRYPTION_KEY` на уникальные значения
+- Изменить `LOGBOARD_PASS` на безопасный пароль
+
+## Статистика
+
+- **Всего переменных в docker-compose.yml**: 25
+- **Всего переменных в env.example**: 34
+- **Совпадающих переменных**: 23
+- **Различающихся переменных**: 2
+- **Отсутствующих в docker-compose.yml**: 9
+- **Отсутствующих в env.example**: 0
+
+## Вывод
+
+В целом, файлы хорошо синхронизированы, но есть несколько важных различий:
+
+1. **Отсутствуют переменные** в docker-compose.yml (особенно новые для AJAX обновления)
+2. **Различаются значения** для пароля и временной зоны
+3. **Отсутствует .env файл** для локальной настройки
+
+## Выполненные действия
+
+✅ **Создан .env файл** на основе env.example
+✅ **Обновлен docker-compose.yml** - добавлены недостающие переменные:
+ - DOCKER_HOST
+ - DOCKER_NETWORKS
+ - LOGBOARD_SKIP_UNHEALTHY
+ - LOGBOARD_CONTAINER_LIST_TIMEOUT
+ - LOGBOARD_CONTAINER_INFO_TIMEOUT
+ - LOGBOARD_HEALTH_CHECK_TIMEOUT
+ - LOGBOARD_AJAX_UPDATE_INTERVAL
+
+## Рекомендации для завершения синхронизации
+
+1. **Обновить .env файл** (вручную):
+ ```bash
+ # Изменить пароль на admin (как в docker-compose.yml)
+ LOGBOARD_PASS=admin
+
+ # Добавить временную зону (как в docker-compose.yml)
+ TZ_TS=Europe/Moscow
+ ```
+
+2. **Проверить безопасность**:
+ - Изменить SECRET_KEY и ENCRYPTION_KEY на уникальные значения
+ - Рассмотреть изменение LOGBOARD_PASS на более безопасный пароль
+
+3. **Использовать .env файл** в docker-compose.yml:
+ ```yaml
+ env_file:
+ - .env
+ ```
+
+Теперь все файлы синхронизированы и готовы к использованию!
diff --git a/scripts/generate-compose.py b/scripts/generate-compose.py
deleted file mode 100644
index 7933146..0000000
--- a/scripts/generate-compose.py
+++ /dev/null
@@ -1,111 +0,0 @@
-#!/usr/bin/env python3
-# -*- coding: utf-8 -*-
-"""
-Скрипт для генерации docker-compose.yml с динамическими сетями
-Автор: Сергей Антропов
-Сайт: https://devops.org.ru
-"""
-
-import os
-import yaml
-from typing import List
-
-def load_env_vars():
- """Загружает переменные из .env файла"""
- env_vars = {}
- if os.path.exists('.env'):
- with open('.env', 'r', encoding='utf-8') as f:
- for line in f:
- line = line.strip()
- if line and not line.startswith('#') and '=' in line:
- key, value = line.split('=', 1)
- env_vars[key] = value
- return env_vars
-
-def parse_networks(networks_str: str) -> List[str]:
- """Парсит строку с сетями в список"""
- if not networks_str:
- return []
- return [net.strip() for net in networks_str.split(',') if net.strip()]
-
-def generate_compose_config():
- """Генерирует конфигурацию docker-compose.yml"""
- env_vars = load_env_vars()
-
- # Получаем сети из переменной окружения
- networks_str = env_vars.get('DOCKER_NETWORKS', '')
- external_networks = parse_networks(networks_str)
-
- # Базовая конфигурация
- config = {
- 'services': {
- 'logboard': {
- 'build': '.',
- 'container_name': 'logboard',
- 'environment': {
- 'LOGBOARD_PORT': env_vars.get('LOGBOARD_PORT', '9001'),
- 'LOGBOARD_TAIL': env_vars.get('LOGBOARD_TAIL', '500'),
- 'LOGBOARD_USER': env_vars.get('LOGBOARD_USER', 'admin'),
- 'LOGBOARD_PASS': env_vars.get('LOGBOARD_PASS', 's3cret-change-me'),
- 'COMPOSE_PROJECT_NAME': env_vars.get('COMPOSE_PROJECT_NAME', ''),
- 'LOGBOARD_SNAPSHOT_DIR': env_vars.get('LOGBOARD_SNAPSHOT_DIR', '/app/snapshots'),
- 'LOGBOARD_INDEX_HTML': env_vars.get('LOGBOARD_INDEX_HTML', './templates/index.html'),
- 'TZ_TS': env_vars.get('TZ_TS', ''),
- 'SECRET_KEY': env_vars.get('SECRET_KEY', 'your-secret-key-here'),
- 'ENCRYPTION_KEY': env_vars.get('ENCRYPTION_KEY', 'your-encryption-key-here'),
- 'LOG_LEVEL': env_vars.get('LOG_LEVEL', 'INFO'),
- 'LOG_FORMAT': env_vars.get('LOG_FORMAT', 'json'),
- 'WEB_TITLE': env_vars.get('WEB_TITLE', 'LogBoard+'),
- 'WEB_DESCRIPTION': env_vars.get('WEB_DESCRIPTION', 'Веб-панель для просмотра логов микросервисов'),
- 'WEB_VERSION': env_vars.get('WEB_VERSION', '1.0.0'),
- 'MAX_CONNECTIONS': env_vars.get('MAX_CONNECTIONS', '100'),
- 'CONNECTION_TIMEOUT': env_vars.get('CONNECTION_TIMEOUT', '30'),
- 'READ_TIMEOUT': env_vars.get('READ_TIMEOUT', '60'),
- 'AUTH_ENABLED': env_vars.get('AUTH_ENABLED', 'true'),
- 'AUTH_METHOD': env_vars.get('AUTH_METHOD', 'basic'),
- 'SESSION_TIMEOUT': env_vars.get('SESSION_TIMEOUT', '3600'),
- 'NOTIFICATIONS_ENABLED': env_vars.get('NOTIFICATIONS_ENABLED', 'false'),
- 'SMTP_HOST': env_vars.get('SMTP_HOST', ''),
- 'SMTP_PORT': env_vars.get('SMTP_PORT', '587'),
- 'SMTP_USER': env_vars.get('SMTP_USER', ''),
- 'SMTP_PASS': env_vars.get('SMTP_PASS', ''),
- 'SMTP_FROM': env_vars.get('SMTP_FROM', ''),
- },
- 'ports': [
- f"{env_vars.get('LOGBOARD_PORT', '9001')}:{env_vars.get('LOGBOARD_PORT', '9001')}"
- ],
- 'volumes': [
- '/var/run/docker.sock:/var/run/docker.sock:ro',
- f"./snapshots:{env_vars.get('LOGBOARD_SNAPSHOT_DIR', '/app/snapshots')}"
- ],
- 'restart': 'unless-stopped',
- 'user': '0:0',
- 'networks': ['default'] + external_networks
- }
- },
- 'networks': {
- 'default': {}
- }
- }
-
- # Добавляем внешние сети
- for network in external_networks:
- config['networks'][network] = {'external': True}
-
- return config
-
-def main():
- """Основная функция"""
- print("Генерация docker-compose.yml с динамическими сетями...")
-
- config = generate_compose_config()
-
- # Записываем в файл
- with open('docker-compose.yml', 'w', encoding='utf-8') as f:
- yaml.dump(config, f, default_flow_style=False, allow_unicode=True, sort_keys=False)
-
- print("docker-compose.yml сгенерирован успешно!")
- print(f"Подключенные сети: {list(config['networks'].keys())}")
-
-if __name__ == '__main__':
- main()
diff --git a/templates/index.html b/templates/index.html
index 8635aab..e68c536 100644
--- a/templates/index.html
+++ b/templates/index.html
@@ -42,7 +42,7 @@ a{color:var(--link)}
}
.sidebar.collapsed {
- width: 60px;
+ width: 42px;
}
.sidebar.collapsed .sidebar-header h1,
@@ -358,7 +358,7 @@ a{color:var(--link)}
}
.sidebar.collapsed + .sidebar-toggle {
- left: 60px;
+ left: 42px;
}
.sidebar-toggle:hover {
@@ -418,6 +418,16 @@ a{color:var(--link)}
.sidebar:not(.collapsed) .help-btn { display: none; }
.sidebar.collapsed .help-btn { display: flex; }
+/* При свернутом сайдбаре фиксируем help-btn снизу по центру */
+.sidebar.collapsed { position: relative; }
+.sidebar.collapsed .help-btn {
+ position: absolute;
+ left: 50%;
+ bottom: 10px;
+ transform: translateX(-50%);
+ z-index: 2;
+}
+
/* Компактные контролы в header: по умолчанию скрыты */
.header-compact-controls { display: none; align-items: center; gap: 6px; }
@@ -425,7 +435,6 @@ a{color:var(--link)}
-.options-btn:hover,
.help-btn:hover,
.logout-btn:hover {
background: var(--tab-active);
@@ -433,11 +442,18 @@ a{color:var(--link)}
border-color: var(--accent);
}
+/* Специальный hover эффект для кнопки options с цветом accent */
+.options-btn:hover {
+ background: var(--accent) !important; /* Цвет логотипа */
+ color: #0b0d12 !important;
+ border-color: var(--accent) !important;
+}
+
/* Кнопка options когда меню открыто (неактивное состояние) */
.options-btn:not(.active) {
- background: var(--accent);
+ background: #e0a800; /* Цвет как у кнопки warning */
color: #0b0d12;
- border-color: var(--accent);
+ border-color: #e0a800;
}
.options-btn.active {
@@ -492,6 +508,41 @@ a{color:var(--link)}
border-color: #e0af68;
}
+/* Кнопка состояния AJAX Update */
+.ajax-update-btn {
+ background: var(--chip);
+ color: var(--muted);
+ border: 1px solid var(--border);
+ border-radius: 6px;
+ padding: 6px 12px;
+ font-size: 11px;
+ font-weight: 500;
+ cursor: pointer;
+ transition: all 0.3s ease;
+ font-family: inherit;
+ min-width: 60px;
+ text-align: center;
+ box-shadow: 0 1px 3px rgba(0, 0, 0, 0.1);
+}
+
+.ajax-update-btn.ajax-on {
+ background: #7ea855; /* Зеленый цвет */
+ color: white;
+ border-color: #7ea855;
+}
+
+.ajax-update-btn.ajax-off {
+ background: #f7768e; /* Красный цвет */
+ color: white;
+ border-color: #f7768e;
+}
+
+.ajax-update-btn:hover {
+ opacity: 0.8;
+ transform: translateY(-1px);
+ box-shadow: 0 2px 4px rgba(0,0,0,0.2);
+}
+
/* Sidebar Controls */
.sidebar-controls {
padding: 16px;
@@ -808,16 +859,18 @@ a{color:var(--link)}
.log-refresh-btn {
background: var(--accent);
color: white;
- border: none;
+ border: 1px solid var(--accent);
border-radius: 6px;
transition: all 0.2s ease;
- padding: 6px 24px;
+ padding: 6px 12px;
font-size: 11px;
font-weight: 500;
display: inline-flex;
align-items: center;
justify-content: center;
- height: fit-content;
+ min-width: 60px;
+ text-align: center;
+ box-shadow: 0 1px 3px rgba(0, 0, 0, 0.1);
}
.log-refresh-btn:hover {
@@ -2140,14 +2193,15 @@ footer{position:fixed;right:10px;bottom:10px;opacity:.6;font-size:11px}
0
-
Theme
+
+
@@ -2226,6 +2280,7 @@ const els = {
filter: document.getElementById('filter'),
wsstate: document.getElementById('wsstate'),
+ ajaxUpdateBtn: document.getElementById('ajaxUpdateBtn'),
projectBadge: document.getElementById('projectBadge'),
clearBtn: document.getElementById('clear'),
@@ -2288,6 +2343,28 @@ function setWsState(s){
}
}
+function setAjaxUpdateState(enabled) {
+ console.log('setAjaxUpdateState: enabled =', enabled, 'els.ajaxUpdateBtn =', !!els.ajaxUpdateBtn);
+
+ if (els.ajaxUpdateBtn) {
+ // Удаляем все классы состояний
+ els.ajaxUpdateBtn.classList.remove('ajax-on', 'ajax-off');
+
+ // Добавляем соответствующий класс
+ if (enabled) {
+ els.ajaxUpdateBtn.classList.add('ajax-on');
+ els.ajaxUpdateBtn.textContent = 'update';
+ console.log('setAjaxUpdateState: Устанавливаем зеленый цвет (ajax-on)');
+ } else {
+ els.ajaxUpdateBtn.classList.add('ajax-off');
+ els.ajaxUpdateBtn.textContent = 'update';
+ console.log('setAjaxUpdateState: Устанавливаем красный цвет (ajax-off)');
+ }
+ } else {
+ console.error('setAjaxUpdateState: Кнопка ajaxUpdateBtn не найдена!');
+ }
+}
+
// Функция для обновления всех логов при изменении фильтров
function refreshAllLogs() {
// Обновляем обычный просмотр
@@ -2784,11 +2861,12 @@ function buildTabs(){
${escapeHtml(svc.service || svc.name)}
- ${svc.project ? ` • ${escapeHtml(svc.project)}` : ''}
+ • ${escapeHtml(svc.project || 'standalone')}
${escapeHtml(svc.status)}
+ ${svc.status === 'running' && svc.host_port ? ` on ${svc.host_port} port` : ''}
${svc.url ? `
` : ''}
@@ -5577,6 +5655,17 @@ els.refreshBtn.onclick = async () => {
btn.addEventListener('click', refreshLogsAndCounters);
});
+// Обработчик для кнопки update (AJAX autoupdate toggle)
+if (els.ajaxUpdateBtn) {
+ console.log('Инициализация обработчика клика для кнопки update');
+ els.ajaxUpdateBtn.addEventListener('click', () => {
+ console.log('Клик по кнопке update - вызываем toggleAjaxLogUpdate()');
+ toggleAjaxLogUpdate();
+ });
+} else {
+ console.error('Кнопка ajaxUpdateBtn не найдена при инициализации обработчика!');
+}
+
// Обработчики для счетчиков
function addCounterClickHandlers() {
// Назначаем обработчики на все дубликаты кнопок (и в log-header, и в header-compact-controls)
@@ -6046,6 +6135,10 @@ document.addEventListener('DOMContentLoaded', () => {
const isHidden = sidebarControls.classList.contains('hidden');
if (isHidden) {
+ // Если сайдбар свернут, сначала разворачиваем его
+ if (els.sidebar.classList.contains('collapsed')) {
+ toggleSidebar();
+ }
// Показываем настройки
sidebarControls.classList.remove('hidden');
els.optionsBtn.classList.remove('active');
@@ -6708,7 +6801,7 @@ window.addEventListener('keydown', async (e)=>{
// Глобальные переменные для AJAX обновления
let ajaxUpdateInterval = null;
- let ajaxUpdateEnabled = false;
+ let ajaxUpdateEnabled = true; // По умолчанию включен
let ajaxUpdateIntervalMs = 2000; // 2 секунды по умолчанию (будет переопределено из env)
// Состояние для каждого контейнера (для multi-view)
@@ -6741,6 +6834,9 @@ window.addEventListener('keydown', async (e)=>{
// Обновляем UI
updateAjaxUpdateCheckbox();
+
+ // Обновляем видимость кнопки refresh и состояние кнопки update
+ updateRefreshButtonVisibility();
}
/**
@@ -6757,17 +6853,29 @@ window.addEventListener('keydown', async (e)=>{
// Обновляем UI
updateAjaxUpdateCheckbox();
+
+ // Обновляем видимость кнопки refresh и состояние кнопки update
+ updateRefreshButtonVisibility();
}
/**
* Переключить состояние AJAX обновления
*/
function toggleAjaxLogUpdate() {
+ console.log('toggleAjaxLogUpdate: Текущее состояние ajaxUpdateEnabled =', ajaxUpdateEnabled);
+
if (ajaxUpdateEnabled) {
+ console.log('toggleAjaxLogUpdate: Отключаем AJAX update');
disableAjaxLogUpdate();
} else {
+ console.log('toggleAjaxLogUpdate: Включаем AJAX update');
enableAjaxLogUpdate(ajaxUpdateIntervalMs);
}
+
+ console.log('toggleAjaxLogUpdate: Новое состояние ajaxUpdateEnabled =', ajaxUpdateEnabled);
+
+ // Обновляем видимость кнопки refresh и состояние кнопки update при переключении
+ updateRefreshButtonVisibility();
}
/**
@@ -6979,6 +7087,35 @@ window.addEventListener('keydown', async (e)=>{
if (checkbox) {
checkbox.checked = ajaxUpdateEnabled;
}
+
+ // Обновляем видимость кнопки refresh в зависимости от состояния ajax autoupdate
+ updateRefreshButtonVisibility();
+ }
+
+ /**
+ * Обновить видимость кнопки refresh в header и состояние кнопки update
+ */
+ function updateRefreshButtonVisibility() {
+ console.log('updateRefreshButtonVisibility: ajaxUpdateEnabled =', ajaxUpdateEnabled);
+
+ const refreshButtons = document.querySelectorAll('.log-refresh-btn');
+ console.log('updateRefreshButtonVisibility: Найдено кнопок refresh =', refreshButtons.length);
+
+ refreshButtons.forEach(btn => {
+ if (ajaxUpdateEnabled) {
+ // Если ajax autoupdate включен, скрываем кнопку refresh
+ btn.style.display = 'none';
+ console.log('updateRefreshButtonVisibility: Скрываем кнопку refresh');
+ } else {
+ // Если ajax autoupdate выключен, показываем кнопку refresh
+ btn.style.display = 'inline-flex';
+ console.log('updateRefreshButtonVisibility: Показываем кнопку refresh');
+ }
+ });
+
+ // Обновляем состояние кнопки update
+ console.log('updateRefreshButtonVisibility: Обновляем состояние кнопки update');
+ setAjaxUpdateState(ajaxUpdateEnabled);
}
/**
@@ -7001,12 +7138,18 @@ window.addEventListener('keydown', async (e)=>{
} else {
disableAjaxLogUpdate();
}
+
+ // Обновляем видимость кнопки refresh и состояние кнопки update при изменении состояния чекбокса
+ updateRefreshButtonVisibility();
});
// Устанавливаем начальное состояние (включен по умолчанию)
checkbox.checked = true;
ajaxUpdateEnabled = true;
+ // Обновляем видимость кнопки refresh и состояние кнопки update при инициализации
+ updateRefreshButtonVisibility();
+
console.log('AJAX Update Checkbox initialized');
}
@@ -7064,6 +7207,9 @@ window.addEventListener('keydown', async (e)=>{
};
console.log('AJAX обновление логов инициализировано');
+
+ // Обновляем видимость кнопки refresh и состояние кнопки update после инициализации
+ updateRefreshButtonVisibility();
}
// Запускаем инициализацию AJAX обновления