From 73a4e6149adb0df2c3ac0cabee674104aec0f407 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Mateusz=20Gruszczy=C5=84ski?= Date: Tue, 4 Mar 2025 11:00:51 +0100 Subject: [PATCH] zmiany w changlogach, alertach itp --- app.py | 212 +++++++++++++++---------- templates/base.html | 17 ++ templates/devices.html | 29 +++- templates/routeros_changelog_tabs.html | 61 ++++++- 4 files changed, 218 insertions(+), 101 deletions(-) diff --git a/app.py b/app.py index 96c2385..eaf6208 100644 --- a/app.py +++ b/app.py @@ -26,6 +26,10 @@ try: except ImportError: date_parser = None +from concurrent.futures import ThreadPoolExecutor, as_completed + +logging.basicConfig(level=logging.INFO) + # Konfiguracja aplikacji app = Flask(__name__) app.config['SECRET_KEY'] = 'twoj-sekret-klucz' @@ -444,73 +448,103 @@ def fetch_changelogs(force=False): changelog_url = "https://mikrotik.com/download/changelogs" current_date = datetime.utcnow() + def process_section(section): + a_tag = section.find("a") + if not a_tag: + return None + + raw_text = a_tag.get_text(strip=True) + logging.info(f"raw_text: {raw_text}") + + # Najpierw próbujemy znaleźć wersję za pomocą wzorca z "in" + match = re.search(r"in\s+(\d+\.\d+(?:\.\d+)?(?:beta|rc)?\d*)", raw_text) + if match: + version_text = match.group(1) + logging.info(f"Parsed version (pattern 1): {version_text}") + else: + # Jeśli nie znaleziono, próbujemy wychwycić wersję na początku łańcucha z dołączoną datą + match = re.match(r"^(\d+\.\d+(?:\.\d+)?(?:beta|rc)?\d*)(\d{4}-\d{2}-\d{2})", raw_text) + if match: + version_text = match.group(1) + logging.info(f"Parsed version (pattern 2): {version_text}") + else: + version_text = raw_text + logging.info("Brak dopasowania regex, używam raw_text jako wersji") + + # Pomijamy wersje, które nie zaczynają się od "6." lub "7." + if not (version_text.startswith("6.") or version_text.startswith("7.")): + logging.info(f"Pomijam wersję {version_text} – nie jest 6.x ani 7.x") + return None + + details_div = section.find("div", class_="content") + changelog_file_url = details_div.get("data-url") if details_div else None + if not changelog_file_url: + logging.warning(f"Brak URL changeloga dla wersji {version_text}") + return None + + try: + changelog_response = requests.get(changelog_file_url, timeout=10) + changelog_response.raise_for_status() + changelog_lines = changelog_response.text.splitlines() + + if not changelog_lines: + logging.warning(f"Pusty changelog dla wersji {version_text}") + return None + + first_line = changelog_lines[0].strip() + release_date_dt = parse_release_date(first_line) + if release_date_dt is None: + logging.warning(f"Nie udało się wyłuskać daty dla wersji {version_text}, pomijam ten changelog") + return None + + changelog_text = "\n".join(changelog_lines).strip() + except Exception as e: + logging.error(f"Błąd pobierania changeloga z {changelog_file_url}: {e}") + return None + + # Filtrowanie według daty: dla 7.x pomijamy wersje starsze niż 1 rok, dla 6.x starsze niż 2 lata + if version_text.startswith("7.") and release_date_dt < (current_date - timedelta(days=365)): + logging.info(f"Pomijam wersję {version_text} - starsza niż 1 rok") + return None + if version_text.startswith("6.") and release_date_dt < (current_date - timedelta(days=730)): + logging.info(f"Pomijam wersję {version_text} - starsza niż 2 lata") + return None + + release_type = get_release_type(version_text) + return { + "version": version_text, + "details": changelog_text, + "category": "6.x" if version_text.startswith("6.") else "7.x", + "timestamp": release_date_dt, + "release_type": release_type + } + try: logging.info(f"Pobieranie changelogów z {changelog_url}...") - response = requests.get(changelog_url, timeout=10) + response = requests.get(changelog_url, timeout=30) response.raise_for_status() soup = BeautifulSoup(response.text, "html.parser") changelog_sections = soup.find_all("li", class_="accordion-navigation") logging.info(f"Znaleziono {len(changelog_sections)} sekcji changelogów.") new_entries = 0 - for section in changelog_sections: - a_tag = section.find("a") - if not a_tag: - continue - - raw_text = a_tag.get_text(strip=True) - match = re.match(r"([0-9.]+[a-zA-Z0-9]*)", raw_text) - version_text = match.group(1) if match else raw_text - - # Pomijamy wersje, które nie zaczynają się od "6." lub "7." - if not (version_text.startswith("6.") or version_text.startswith("7.")): - logging.info(f"Pomijam wersję {version_text} – nie jest 6.x ani 7.x") - continue - - details_div = section.find("div", class_="content") - changelog_file_url = details_div.get("data-url") if details_div else None - - if not changelog_file_url: - logging.warning(f"Brak URL changeloga dla wersji {version_text}") - continue - - try: - changelog_response = requests.get(changelog_file_url, timeout=10) - changelog_response.raise_for_status() - changelog_lines = changelog_response.text.splitlines() - - if not changelog_lines: - logging.warning(f"Pusty changelog dla wersji {version_text}") - continue - - first_line = changelog_lines[0].strip() - release_date_dt = parse_release_date(first_line) - if release_date_dt is None: - logging.warning(f"Nie udało się wyłuskać daty dla wersji {version_text}, pomijam ten changelog") - continue # Pomijamy wpis bez daty - - changelog_text = "\n".join(changelog_lines).strip() - except Exception as e: - logging.error(f"Błąd pobierania changeloga z {changelog_file_url}: {e}") - continue - - # Filtrowanie: dla 7.x pomijamy wersje starsze niż 1 rok, dla 6.x starsze niż 2 lata - if version_text.startswith("7.") and release_date_dt < (current_date - timedelta(days=365)): - logging.info(f"Pomijam wersję {version_text} - starsza niż 1 rok") - continue - if version_text.startswith("6.") and release_date_dt < (current_date - timedelta(days=730)): - logging.info(f"Pomijam wersję {version_text} - starsza niż 2 lata") - continue - - # Określenie typu wydania (stable, rc, beta) - release_type = get_release_type(version_text) + results = [] + # Używamy równoległego przetwarzania sekcji + with ThreadPoolExecutor(max_workers=8) as executor: + futures = [executor.submit(process_section, section) for section in changelog_sections] + for future in as_completed(futures): + result = future.result() + if result is not None: + results.append(result) + # Dodajemy wyniki do bazy danych + for entry in results: new_entry = ChangelogEntry( - version=version_text, - details=changelog_text, - category="6.x" if version_text.startswith("6.") else "7.x", - timestamp=release_date_dt, - release_type=release_type + version=entry["version"], + details=entry["details"], + category=entry["category"], + timestamp=entry["timestamp"], + release_type=entry["release_type"] ) db.session.add(new_entry) new_entries += 1 @@ -520,6 +554,8 @@ def fetch_changelogs(force=False): except Exception as e: logging.error(f"Błąd podczas pobierania changelogów: {e}") + + def detect_anomalies(): with app.app_context(): # Ustal okres analizy, np. ostatnie 24 godziny @@ -632,7 +668,7 @@ def register(): password = request.form['password'] # Prosta walidacja – warto rozszerzyć if User.query.filter_by(username=username).first(): - flash("Użytkownik o tej nazwie już istnieje.") + flash("Użytkownik o tej nazwie już istnieje.", "error") return redirect(url_for('register')) new_user = User(username=username, email=email) new_user.set_password(password) @@ -642,7 +678,7 @@ def register(): default_settings = Settings(user_id=new_user.id, check_interval=60) db.session.add(default_settings) db.session.commit() - flash("Rejestracja zakończona. Możesz się zalogować.") + flash("Rejestracja zakończona. Możesz się zalogować.", "success") return redirect(url_for('login')) return render_template('register.html') @@ -655,10 +691,10 @@ def login(): user = User.query.filter_by(username=username).first() if user and user.check_password(password): login_user(user) - flash("Zalogowano pomyślnie.") + flash("Zalogowano pomyślnie.", "success") return redirect(url_for('dashboard')) else: - flash("Nieprawidłowa nazwa użytkownika lub hasło.") + flash("Nieprawidłowa nazwa użytkownika lub hasło.", "error") return render_template('login.html') # Wylogowanie @@ -666,7 +702,7 @@ def login(): @login_required def logout(): logout_user() - flash("Wylogowano.") + flash("Wylogowano.", "success") return redirect(url_for('index')) # Lista urządzeń użytkownika @@ -700,7 +736,7 @@ def add_device(): ) db.session.add(new_device) db.session.commit() - flash("Urządzenie dodane.") + flash("Urządzenie dodane.", "success") return redirect(url_for('devices')) return render_template('add_device.html') @@ -710,7 +746,7 @@ def add_device(): def device_detail(device_id): device = Device.query.get_or_404(device_id) if device.user_id != current_user.id: - flash("Brak dostępu.") + flash("Brak dostępu.", "error") return redirect(url_for('devices')) resource_data = {} try: @@ -774,7 +810,7 @@ def settings(): except Exception as e: app.logger.error(f"Error rescheduling job: {e}") - flash("Ustawienia zapisane.") + flash("Ustawienia zapisane.", "success") return redirect(url_for('settings')) return render_template('settings.html', settings=user_settings) @@ -783,7 +819,7 @@ def settings(): def edit_device(device_id): device = Device.query.get_or_404(device_id) if device.user_id != current_user.id: - flash("Brak dostępu.") + flash("Brak dostępu.", "error") return redirect(url_for('devices')) if request.method == 'POST': device.name = request.form.get('name', device.name) @@ -795,7 +831,7 @@ def edit_device(device_id): device.use_ssl = bool(request.form.get('use_ssl')) device.ssl_insecure = bool(request.form.get('ssl_insecure')) db.session.commit() - flash("Urządzenie zaktualizowane.") + flash("Urządzenie zaktualizowane.", "success") return redirect(url_for('devices')) return render_template('edit_device.html', device=device) @@ -804,7 +840,7 @@ def edit_device(device_id): def force_check(device_id): device = Device.query.get_or_404(device_id) if device.user_id != current_user.id: - flash("Brak dostępu.") + flash("Brak dostępu.", "error") return redirect(url_for('devices')) result, update_available, current_version, current_firmware, upgrade_firmware = check_device_update(device) device.last_log = result @@ -814,7 +850,7 @@ def force_check(device_id): device.current_firmware = current_firmware device.upgrade_firmware = upgrade_firmware db.session.commit() - flash("Sprawdzenie urządzenia zakończone.") + flash("Sprawdzenie urządzenia zakończone.", "success") return redirect(url_for('devices')) @app.route('/device//update', methods=['POST']) @@ -822,7 +858,7 @@ def force_check(device_id): def update_device(device_id): device = Device.query.get_or_404(device_id) if device.user_id != current_user.id: - flash("Brak dostępu.") + flash("Brak dostępu.", "error") return redirect(url_for('devices')) try: app.logger.debug(f"Initiating system update for device {device.ip}") @@ -853,11 +889,11 @@ def update_device(device_id): db.session.add(history) db.session.commit() - flash("Aktualizacja systemu została rozpoczęta.") + flash("Aktualizacja systemu została rozpoczęta.", "success") app.logger.debug("System update command executed successfully") except Exception as e: app.logger.error(f"Błąd podczas aktualizacji urządzenia {device.ip}: {e}", exc_info=True) - flash(f"Błąd podczas aktualizacji: {e}") + flash(f"Błąd podczas aktualizacji: {e}", "error") return redirect(url_for('device_detail', device_id=device.id)) @app.route('/device//update_firmware', methods=['POST']) @@ -865,7 +901,7 @@ def update_device(device_id): def update_firmware(device_id): device = Device.query.get_or_404(device_id) if device.user_id != current_user.id: - flash("Brak dostępu.") + flash("Brak dostępu.", "error") return redirect(url_for('devices')) try: api = librouteros.connect( @@ -886,9 +922,9 @@ def update_firmware(device_id): db.session.add(history) db.session.commit() - flash("Aktualizacja firmware została rozpoczęta.") + flash("Aktualizacja firmware została rozpoczęta.", "success") except Exception as e: - flash(f"Błąd podczas aktualizacji firmware: {e}") + flash(f"Błąd podczas aktualizacji firmware: {e}", "error") return redirect(url_for('device_detail', device_id=device.id)) @app.route('/test_pushover', methods=['POST']) @@ -896,7 +932,7 @@ def update_firmware(device_id): def test_pushover(): message = "To jest testowe powiadomienie Pushover z RouterOS Update." send_pushover_notification(current_user, message) - flash("Test powiadomienia Pushover wysłany.") + flash("Test powiadomienia Pushover wysłany.", "success") return redirect(url_for('settings')) @app.route('/test_email', methods=['POST']) @@ -905,7 +941,7 @@ def test_email(): subject = "Testowy E-mail z RouterOS Update" message = "To jest testowa wiadomość e-mail wysłana z RouterOS Update." send_email_notification(current_user, subject, message) - flash("Testowy e-mail wysłany.") + flash("Testowy e-mail wysłany.", "success") return redirect(url_for('settings')) @app.route('/change_password', methods=['GET', 'POST']) @@ -916,14 +952,14 @@ def change_password(): new_password = request.form.get('new_password') confirm_password = request.form.get('confirm_password') if not current_user.check_password(old_password): - flash("Stare hasło jest nieprawidłowe.") + flash("Stare hasło jest nieprawidłowe.", "error") return redirect(url_for('reset_password')) if new_password != confirm_password: - flash("Nowe hasło i potwierdzenie nie są zgodne.") + flash("Nowe hasło i potwierdzenie nie są zgodne.", "warning") return redirect(url_for('reset_password')) current_user.set_password(new_password) db.session.commit() - flash("Hasło zostało zresetowane.") + flash("Hasło zostało zresetowane.", "success") return redirect(url_for('reset_password')) return render_template('change_password.html') @@ -932,17 +968,17 @@ def change_password(): def clean_logs(): days = request.form.get('days') if not days: - flash("Podaj liczbę dni.") + flash("Podaj liczbę dni.", "warning") return redirect(url_for('logs')) try: days = int(days) except ValueError: - flash("Niepoprawna wartość dni.") + flash("Niepoprawna wartość dni.", "warning") return redirect(url_for('logs')) cutoff = datetime.utcnow() - timedelta(days=days) num_deleted = Log.query.filter(Log.user_id == current_user.id, Log.timestamp < cutoff).delete() db.session.commit() - flash(f"Usunięto {num_deleted} logów starszych niż {days} dni.") + flash(f"Usunięto {num_deleted} logów starszych niż {days} dni.", "success") return redirect(url_for('logs')) @app.route('/update_history') @@ -962,7 +998,7 @@ def anomalies(): def update_selected_devices(): selected_ids = request.form.getlist('selected_devices') if not selected_ids: - flash("Nie wybrano żadnych urządzeń.") + flash("Nie wybrano żadnych urządzeń.", "error") return redirect(url_for('devices')) for device_id in selected_ids: device = Device.query.get(device_id) @@ -978,7 +1014,7 @@ def update_selected_devices(): log_entry = Log(message=result, device_id=device.id, user_id=device.user_id) db.session.add(log_entry) db.session.commit() - flash("Wybrane urządzenia zostały zaktualizowane.") + flash("Wybrane urządzenia zostały zaktualizowane.", "success") return redirect(url_for('devices')) @app.route('/routeros_changelog') @@ -1023,7 +1059,7 @@ def force_fetch_changelogs(): def restart_device(device_id): device = Device.query.get_or_404(device_id) if device.user_id != current_user.id: - flash("Brak dostępu.") + flash("Brak dostępu.", "error") return redirect(url_for('devices')) try: api = librouteros.connect( @@ -1036,9 +1072,9 @@ def restart_device(device_id): # Wysyłamy komendę reboot list(api('/system/reboot')) - flash("Komenda reboot została wysłana.") + flash("Komenda reboot została wysłana.", "success") except Exception as e: - flash(f"Błąd podczas wysyłania komendy reboot: {e}") + flash(f"Błąd podczas wysyłania komendy reboot: {e}", "error") return ('', 204) # Zwracamy odpowiedź bez treści dla żądania AJAX # Zamknięcie harmonogramu przy zatrzymaniu aplikacji diff --git a/templates/base.html b/templates/base.html index 37e5b06..cc563a0 100644 --- a/templates/base.html +++ b/templates/base.html @@ -145,6 +145,23 @@ padding: 0.5rem; } } + + /* ========== Modal w trybie ciemny, ========== */ + .dark-mode .modal-content { + background-color: #333; + color: #ddd; + border: none; + } + .dark-mode .modal-header, + .dark-mode .modal-footer { + border-color: #444; + } + .dark-mode .modal-title { + color: #fff; + } + .dark-mode .btn-close { + filter: invert(1); + } {% block extra_head %}{% endblock %} diff --git a/templates/devices.html b/templates/devices.html index 71eb295..e2f63d5 100644 --- a/templates/devices.html +++ b/templates/devices.html @@ -201,6 +201,11 @@ body.dark-mode .table-bordered > :not(caption) > * > * { + + + {% endblock %} diff --git a/templates/routeros_changelog_tabs.html b/templates/routeros_changelog_tabs.html index 899593c..52dca78 100644 --- a/templates/routeros_changelog_tabs.html +++ b/templates/routeros_changelog_tabs.html @@ -63,11 +63,10 @@

Changelog RouterOS

- - Aktualizuj changelogi - + + + Aktualizuj changelogi +
@@ -151,4 +150,56 @@
+ + + + + {% endblock %}