zmiany w changlogach, alertach itp

This commit is contained in:
Mateusz Gruszczyński 2025-03-04 11:00:51 +01:00
parent 85a37e4a78
commit 73a4e6149a
4 changed files with 218 additions and 101 deletions

154
app.py
View File

@ -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,35 +448,39 @@ def fetch_changelogs(force=False):
changelog_url = "https://mikrotik.com/download/changelogs"
current_date = datetime.utcnow()
try:
logging.info(f"Pobieranie changelogów z {changelog_url}...")
response = requests.get(changelog_url, timeout=10)
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:
def process_section(section):
a_tag = section.find("a")
if not a_tag:
continue
return None
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
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")
continue
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}")
continue
return None
try:
changelog_response = requests.get(changelog_file_url, timeout=10)
@ -481,36 +489,62 @@ def fetch_changelogs(force=False):
if not changelog_lines:
logging.warning(f"Pusty changelog dla wersji {version_text}")
continue
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")
continue # Pomijamy wpis bez daty
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}")
continue
return None
# Filtrowanie: dla 7.x pomijamy wersje starsze niż 1 rok, dla 6.x starsze niż 2 lata
# 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")
continue
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")
continue
return None
# Określenie typu wydania (stable, rc, beta)
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=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
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/<int:device_id>/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/<int:device_id>/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

View File

@ -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);
}
</style>
{% block extra_head %}{% endblock %}
</head>

View File

@ -201,6 +201,11 @@ body.dark-mode .table-bordered > :not(caption) > * > * {
<button id="mass-firmware-cancel-btn" class="btn btn-secondary ms-2">Anuluj</button>
</div>
<!-- Overlay informujący o zakończonym odświeżaniu -->
<div id="mass-update-overlay" style="display:none; position: fixed; top:0; left:0; width:100%; height:100%; background: rgba(0,0,0,0.7); z-index:1100; color:white; text-align:center; padding-top:200px;">
<h3>Polecnie odświeżenia urządzeń wykonane!</h3>
</div>
<script>
// Ten sam skrypt masowych akcji, przeniesiony bez zmian w logice
document.addEventListener('DOMContentLoaded', function() {
@ -241,12 +246,12 @@ body.dark-mode .table-bordered > :not(caption) > * > * {
// Pokaż overlay z paskiem postępu (5 minut)
var overlay = document.getElementById('mass-system-update-overlay');
overlay.style.display = 'block';
var timeLeft = 300; // 300 sekund
var timeLeft = 200; // 200 sekund
var progressBar = document.getElementById('mass-system-progress');
var timerDisplay = document.getElementById('mass-system-timer');
var interval = setInterval(function(){
timeLeft--;
var percent = ((300 - timeLeft) / 300) * 100;
var percent = ((200 - timeLeft) / 200) * 100;
progressBar.style.width = percent + '%';
timerDisplay.textContent = timeLeft + ' sekund';
if(timeLeft <= 0){
@ -298,12 +303,12 @@ body.dark-mode .table-bordered > :not(caption) > * > * {
.then(function() {
var overlay = document.getElementById('mass-firmware-update-overlay');
overlay.style.display = 'block';
var timeLeft = 120; // 120 sekund
var timeLeft = 90; // 90 sekund
var progressBar = document.getElementById('mass-firmware-progress');
var timerDisplay = document.getElementById('mass-firmware-timer');
var interval = setInterval(function(){
timeLeft--;
var percent = ((120 - timeLeft) / 120) * 100;
var percent = ((90 - timeLeft) / 90) * 100;
progressBar.style.width = percent + '%';
timerDisplay.textContent = timeLeft + ' sekund';
if(timeLeft <= 0){
@ -327,11 +332,19 @@ body.dark-mode .table-bordered > :not(caption) > * > * {
alert("Wybierz przynajmniej jedno urządzenie.");
return;
}
// Dla każdego wybranego urządzenia wykonaj force_check
selectedDevices.forEach(function(id) {
fetch(`/device/${id}/force_check`, { method: 'GET' })
.catch(function(error){ console.error('Błąd force check dla urządzenia ' + id, error); });
.catch(function(error) {
console.error('Błąd force check dla urządzenia ' + id, error);
});
setTimeout(function(){ location.reload(); }, 2000);
});
// Pokaż overlay informujący o zakończonym odświeżaniu
document.getElementById('mass-update-overlay').style.display = 'block';
// Po 4 sekundach odśwież stronę
setTimeout(function() {
location.reload();
}, 4000);
});
</script>
{% endblock %}

View File

@ -63,9 +63,8 @@
<div class="card border-0 shadow">
<div class="card-header d-flex justify-content-between align-items-center">
<h4 class="mb-0">Changelog RouterOS</h4>
<a href="{{ url_for('force_fetch_changelogs') }}"
class="btn btn-danger btn-sm"
onclick="return confirm('Czy na pewno chcesz ręcznie pobrać wszystkie changelogi? Operacja usunie wszystkie stare wpisy.');">
<!-- Przycisk do wywołania aktualizacji changelogów -->
<a href="#" id="updateChangelog" class="btn btn-danger btn-sm">
Aktualizuj changelogi
</a>
</div>
@ -151,4 +150,56 @@
</div> <!-- /card-body -->
</div> <!-- /card -->
</div>
<!-- Modal z progressem -->
<div class="modal fade" id="progressModal" tabindex="-1" role="dialog" aria-labelledby="progressModalLabel" aria-hidden="true">
<div class="modal-dialog modal-dialog-centered" role="document">
<div class="modal-content">
<div class="modal-header">
<h5 class="modal-title" id="progressModalLabel">Pobieranie changelogów</h5>
</div>
<div class="modal-body">
<div class="spinner-border" role="status">
<span class="visually-hidden">Ładowanie...</span>
</div>
<p>Proszę czekać, trwa pobieranie changelogów...</p>
<!-- Możesz dodać miejsce na logi, jeśli chcesz wyświetlać szczegóły postępu -->
<div id="progressLog" style="max-height:200px; overflow-y:auto;"></div>
</div>
</div>
</div>
</div>
<script>
// Upewnij się, że Bootstrap JS jest załadowany (np. przez CDN)
document.getElementById("updateChangelog").addEventListener("click", function(e) {
e.preventDefault();
// Pokaż modal
var progressModalEl = document.getElementById("progressModal");
var progressModal = new bootstrap.Modal(progressModalEl);
progressModal.show();
// Opcjonalnie wyczyść poprzednie logi
document.getElementById("progressLog").innerHTML = "";
// Wywołanie endpointu force_fetch_changelogs
fetch("{{ url_for('force_fetch_changelogs') }}")
.then(response => response.text())
.then(data => {
// Aktualizacja logu możesz dodać otrzymane dane, jeśli są potrzebne
document.getElementById("progressLog").innerHTML += "<p>Pobieranie zakończone.</p>";
// Po krótkiej chwili zamknij modal i odśwież całą stronę
setTimeout(() => {
progressModal.hide();
location.reload();
}, 1000);
})
.catch(error => {
document.getElementById("progressLog").innerHTML += "<p>Błąd: " + error + "</p>";
setTimeout(() => {
progressModal.hide();
}, 2000);
});
});
</script>
{% endblock %}