From: Giorgio Ravera Date: Wed, 18 Feb 2026 18:28:57 +0000 (+0100) Subject: Added aliases management X-Git-Url: http://git.giorgioravera.it/?a=commitdiff_plain;h=2c1a5a93a04caa75f66a83082da1cc898280f1f7;p=network-manager.git Added aliases management --- diff --git a/backend/db/aliases.py b/backend/db/aliases.py new file mode 100644 index 0000000..0cbaf2a --- /dev/null +++ b/backend/db/aliases.py @@ -0,0 +1,169 @@ +# backend/db/aliases.py + +# Import standard modules +import ipaddress +import logging +import os +import re +import sqlite3 +# Import local modules +from backend.db.db import get_db, register_init +# Import Settings +from settings.settings import settings +# Import Log +from log.log import get_logger + +# ----------------------------- +# Check Data Input +# ----------------------------- +def validate_data(data: dict) -> dict: + # Check name + if "name" not in data: + raise ValueError("Missing required field: name") + name = str(data["name"]).strip() + if not name: + raise ValueError("Field 'name' cannot be empty") + + # Check target + if "target" not in data: + raise ValueError("Missing required field: target") + target = str(data["target"]).strip() + if not target: + raise ValueError("Field 'target' cannot be empty") + + # Check note + note = data.get("note") + + # Boolean normalization for DB (0/1) + ssl_enabled = int(bool(data.get("ssl_enabled", 0))) + + return { + "name": name, + "target": target, + "note": note, + "ssl_enabled": ssl_enabled, + } + +# ----------------------------- +# SELECT ALL ALIASES +# ----------------------------- +def get_aliases(): + conn = get_db() + cur = conn.execute("SELECT * FROM aliases ORDER BY target") + rows = [dict(r) for r in cur.fetchall()] + return rows + +# ----------------------------- +# SELECT SINGLE ALIAS +# ----------------------------- +def get_alias(alias_id: int): + conn = get_db() + cur = conn.execute("SELECT * FROM aliases WHERE id = ?", (alias_id,)) + row = cur.fetchone() + return dict(row) if row else None + +# ----------------------------- +# ADD ALIAS +# ----------------------------- +def add_alias(data: dict): + + # Validate input + cleaned = validate_data(data) + + conn = get_db() + try: + cur = conn.execute( + "INSERT INTO aliases (name, target, note, ssl_enabled) VALUES (?, ?, ?, ?)", + ( + cleaned["name"], + cleaned["target"], + cleaned["note"], + cleaned["ssl_enabled"], + ) + ) + conn.commit() + return cur.lastrowid + + except sqlite3.IntegrityError as e: + conn.rollback() + return -1 + + except Exception as e: + conn.rollback() + raise + +# ----------------------------- +# UPDATE ALIAS +# ----------------------------- +def update_alias(alias_id: int, data: dict) -> bool: + + # Validate input + cleaned = validate_data(data) + + conn = get_db() + try: + cur = conn.execute( + """ + UPDATE aliases + SET name=?, target=?, note=?, ssl_enabled=? + WHERE id=? + """, + ( + cleaned["name"], + cleaned["target"], + cleaned["note"], + cleaned["ssl_enabled"], + alias_id, + ) + ) + conn.commit() + return cur.rowcount > 0 + + except Exception: + conn.rollback() + raise + +# ----------------------------- +# DELETE ALIAS +# ----------------------------- +def delete_alias(alias_id: int) -> bool: + + # Validate input + if alias_id is None: + raise ValueError("alias_id cannot be None") + + conn = get_db() + try: + cur = conn.execute( + "DELETE FROM aliases WHERE id = ?", + (alias_id,) + ) + conn.commit() + + return cur.rowcount > 0 + + except Exception: + conn.rollback() + raise + +# ----------------------------- +# Initialize Aliases DB Table +# ----------------------------- +@register_init +def init_db_alias_table(cur): + logger = get_logger(__name__) + + # ALIASES TABLE + cur.execute(""" + CREATE TABLE aliases ( + id INTEGER PRIMARY KEY AUTOINCREMENT, + name TEXT NOT NULL UNIQUE, + target TEXT NOT NULL, + note TEXT, + ssl_enabled INTEGER NOT NULL DEFAULT 0 + ); + """) + cur.execute("CREATE INDEX idx_aliases_name ON aliases(name);") + + logger.info("ALIASES DB: Database initialized successfully for %s", settings.DOMAIN) + logger.info("ALIASES DB: Public IP: %s", settings.PUBLIC_IP) diff --git a/backend/db/hosts.py b/backend/db/hosts.py index 3287f27..7b0a639 100644 --- a/backend/db/hosts.py +++ b/backend/db/hosts.py @@ -20,13 +20,14 @@ MAC_RE = re.compile(r"^([0-9A-Fa-f]{2}([:\-])){5}([0-9A-Fa-f]{2})$") # Check Data Input # ----------------------------- def validate_data(data: dict) -> dict: + # Check name if "name" not in data: raise ValueError("Missing required field: name") - name = str(data["name"]).strip() if not name: raise ValueError("Field 'name' cannot be empty") + # Check IPv4 ipv4 = data.get("ipv4") if ipv4: try: @@ -34,6 +35,7 @@ def validate_data(data: dict) -> dict: except ValueError: raise ValueError(f"Invalid IPv4 address: {ipv4}") + # Check IPv6 ipv6 = data.get("ipv6") if ipv6: try: @@ -45,6 +47,7 @@ def validate_data(data: dict) -> dict: if mac and not MAC_RE.match(mac): raise ValueError(f"Invalid MAC address: {mac}") + # Check note note = data.get("note") # Normalizzazione boolean per DB (0/1) @@ -210,19 +213,6 @@ def init_db_hosts_table(cur): """) cur.execute("CREATE INDEX idx_hosts_name ON hosts(name);") - # ALIASES TABLE - cur.execute(""" - CREATE TABLE aliases ( - id INTEGER PRIMARY KEY AUTOINCREMENT, - host_id INTEGER NOT NULL, - alias TEXT NOT NULL, - note TEXT, - ssl_enabled INTEGER NOT NULL DEFAULT 0, - FOREIGN KEY (host_id) REFERENCES hosts(id) - ); - """) - cur.execute("CREATE INDEX idx_aliases_host ON aliases(host_id);") - # TXT TABLE cur.execute(""" CREATE TABLE txt_records ( diff --git a/backend/main.py b/backend/main.py index 4984ad0..1e9ba84 100644 --- a/backend/main.py +++ b/backend/main.py @@ -14,6 +14,7 @@ from backend.routes.backup import router as backup_router from backend.routes.health import router as health_router from backend.routes.login import router as login_router from backend.routes.hosts import router as hosts_router +from backend.routes.aliases import router as aliases_router from backend.routes.dns import router as dns_router from backend.routes.dhcp import router as dhcp_router # Import Security @@ -108,6 +109,7 @@ app.include_router(backup_router) app.include_router(health_router) app.include_router(login_router) app.include_router(hosts_router) +app.include_router(aliases_router) app.include_router(dns_router) app.include_router(dhcp_router) diff --git a/backend/routes/aliases.py b/backend/routes/aliases.py new file mode 100644 index 0000000..41b3ee8 --- /dev/null +++ b/backend/routes/aliases.py @@ -0,0 +1,266 @@ +# backend/routes/aliases.py + +# import standard modules +from fastapi import APIRouter, Request, Response, HTTPException, status +from fastapi.responses import FileResponse, JSONResponse, RedirectResponse +import ipaddress +import time +import os +# Import local modules +from backend.db.aliases import ( + get_aliases, + get_alias, + add_alias, + update_alias, + delete_alias +) +# Import Settings +from settings.settings import settings +# Import Logging +from log.log import setup_logging, get_logger + +# Create Router +router = APIRouter() + +# --------------------------------------------------------- +# FRONTEND PATHS (absolute paths inside Docker) +# --------------------------------------------------------- +# Aliass page +@router.get("/aliases") +def aliases(request: Request): + return FileResponse(os.path.join(settings.FRONTEND_DIR, "aliases.html")) + +# Serve aliases.js +@router.get("/js/aliases.js") +def css_aliases(): + return FileResponse(os.path.join(settings.FRONTEND_DIR, "js/aliases.js")) + +# --------------------------------------------------------- +# Get Aliass +# --------------------------------------------------------- +@router.get("/api/aliases", status_code=status.HTTP_200_OK, responses={ + 200: {"description": "Aliass found"}, + 500: {"description": "Internal server error"}, +}) +def api_get_aliases(request: Request): + try: + aliases = get_aliases() + return aliases or [] + + except Exception as e: + logger = get_logger("aliases") + logger.exception("Error getting list alias %s", str(e).strip()) + raise HTTPException( + status_code=status.HTTP_500_INTERNAL_SERVER_ERROR, + detail={ + "code": "ALIASES_GET_ERROR", + "status": "failure", + "message": "Internal error getting alias", + }, + ) + +# --------------------------------------------------------- +# Get Alias +# --------------------------------------------------------- +@router.get("/api/aliases/{alias_id}", status_code=status.HTTP_200_OK, responses={ + 200: {"description": "Alias found"}, + 404: {"description": "Alias not found"}, + 500: {"description": "Internal server error"}, +}) +def api_get_alias(request: Request, alias_id: int): + + try: + alias = get_alias(alias_id) + if not alias: # None or empty dict + raise HTTPException( + status_code=status.HTTP_404_NOT_FOUND, + detail={ + "code": "ALIAS_NOT_FOUND", + "status": "failure", + "message": "Alias not found", + "alias_id": alias_id, + }, + ) + return alias + + except Exception as e: + logger = get_logger("aliases") + logger.exception("Error adding alias %s: %s", alias_id, str(e).strip()) + took_ms = (time.monotonic_ns() - start_ns) / 1_000_000 + raise HTTPException( + status_code=status.HTTP_500_INTERNAL_SERVER_ERROR, + detail={ + "code": "ALIAS_GET_ERROR", + "status": "failure", + "message": "Internal error getting alias", + "took_ms": took_ms, + }, + ) + +# --------------------------------------------------------- +# Add Aliass +# --------------------------------------------------------- +@router.post("/api/aliases", status_code=status.HTTP_200_OK, responses={ + 200: {"description": "Alias added"}, + 409: {"description": "Alias already present"}, + 500: {"description": "Internal server error"}, +}) +def api_add_alias(request: Request, data: dict): + + # Inizializzazioni + start_ns = time.monotonic_ns() + + try: + alias_id = add_alias(data) + if(alias_id > 0): + took_ms = (time.monotonic_ns() - start_ns) / 1_000_000 + return JSONResponse( + status_code=status.HTTP_200_OK, + content={ + "code": "ALIAS_ADDED", + "status": "success", + "message": "Alias added successfully", + "alias_id": alias_id, + "took_ms": took_ms, + }, + ) + + # Already present + took_ms = (time.monotonic_ns() - start_ns) / 1_000_000 + raise HTTPException( + status_code=status.HTTP_409_CONFLICT, + detail={ + "code": "ALIAS_ALREADY_PRESENT", + "status": "failure", + "message": "Alias already present", + "took_ms": took_ms, + }, + ) + + except HTTPException as httpe: + raise httpe + + except Exception as e: + logger = get_logger("aliases") + logger.exception("Error adding alias: %s", str(e).strip()) + took_ms = (time.monotonic_ns() - start_ns) / 1_000_000 + raise HTTPException( + status_code=status.HTTP_500_INTERNAL_SERVER_ERROR, + detail={ + "code": "ALIAS_ADD_ERROR", + "status": "failure", + "message": "Internal error adding alias", + "took_ms": took_ms, + }, + ) + +# --------------------------------------------------------- +# Update Alias +# --------------------------------------------------------- +@router.put("/api/aliases/{alias_id}", status_code=status.HTTP_200_OK, responses={ + 200: {"description": "Alias updated"}, + 404: {"description": "Alias not found"}, + 500: {"description": "Internal server error"}, +}) +def api_update_alias(request: Request, data: dict, alias_id: int): + + # Inizializzazioni + start_ns = time.monotonic_ns() + + try: + updated = update_alias(alias_id, data) + if updated: + took_ms = (time.monotonic_ns() - start_ns) / 1_000_000 + return JSONResponse( + status_code=status.HTTP_200_OK, + content={ + "code": "ALIAS_UPDATED", + "status": "success", + "message": "Alias updated successfully", + "alias_id": alias_id, + "took_ms": took_ms, + }, + ) + + # Not Found + took_ms = (time.monotonic_ns() - start_ns) / 1_000_000 + raise HTTPException( + status_code=status.HTTP_404_NOT_FOUND, + detail={ + "code": "ALIAS_NOT_FOUND", + "status": "failure", + "message": "Alias not found", + "alias_id": alias_id, + "took_ms": took_ms, + }, + ) + + except Exception as e: + logger = get_logger("aliases") + logger.exception("Error updating alias %s: %s", alias_id, str(e).strip()) + took_ms = (time.monotonic_ns() - start_ns) / 1_000_000 + raise HTTPException( + status_code=status.HTTP_500_INTERNAL_SERVER_ERROR, + detail={ + "code": "ALIAS_UPDATE_ERROR", + "status": "failure", + "message": "Internal error updating alias", + "alias_id": alias_id, + "took_ms": took_ms, + }, + ) + +# --------------------------------------------------------- +# Delete +# --------------------------------------------------------- +@router.delete("/api/aliases/{alias_id}", status_code=status.HTTP_200_OK, responses={ + 200: {"description": "Alias deleted"}, + 404: {"description": "Alias not found"}, + 500: {"description": "Internal server error"}, +}) +def api_delete_alias(request: Request, alias_id: int): + + # Inizializzazioni + start_ns = time.monotonic_ns() + + try: + deleted = delete_alias(alias_id) + if deleted: + took_ms = (time.monotonic_ns() - start_ns) / 1_000_000 + return JSONResponse( + status_code=status.HTTP_200_OK, + content={ + "code": "ALIAS_DELETED", + "status": "success", + "message": "Alias deleted successfully", + "details": {"took_ms": took_ms, "alias_id": alias_id,}, + }, + ) + + # Not Found + took_ms = (time.monotonic_ns() - start_ns) / 1_000_000 + raise HTTPException( + status_code=status.HTTP_404_NOT_FOUND, + detail={ + "code": "ALIAS_NOT_FOUND", + "status": "failure", + "message": "Alias not found", + "alias_id": alias_id, + "took_ms": took_ms, + }, + ) + + except Exception as e: + logger = get_logger("aliases") + logger.exception("Error deleting alias %s: %s", alias_id, str(e).strip()) + took_ms = (time.monotonic_ns() - start_ns) / 1_000_000 + raise HTTPException( + status_code=status.HTTP_500_INTERNAL_SERVER_ERROR, + detail={ + "code": "ALIAS_DELETE_ERROR", + "status": "failure", + "message": "Internal error deleting alias", + "alias_id": alias_id, + "took_ms": took_ms, + }, + ) diff --git a/entrypoint.py b/entrypoint.py index 5b25579..29ec408 100755 --- a/entrypoint.py +++ b/entrypoint.py @@ -7,8 +7,9 @@ import sys import argparse # Import local modules from backend.db.db import init_db -import backend.db.hosts import backend.db.users +import backend.db.hosts +import backend.db.aliases # Import Settings from settings.settings import settings # Import Log diff --git a/frontend/aliases.html b/frontend/aliases.html new file mode 100644 index 0000000..f7beff8 --- /dev/null +++ b/frontend/aliases.html @@ -0,0 +1,167 @@ + + + + + Network Manager + + + + + + + + + + + + + + +
+
+ + + +
+
+ + +
+ + +
+
+
+ +
+

+ 🖧 + + Aliases List +

+
+ + +
+ + +
+
+ +
+
+ + +
+ + + +
+
+
+
+ + + + + + + + + + + + + +
Alias Target Note SSL Actions
+ + + + + + + + + + + diff --git a/frontend/hosts.html b/frontend/hosts.html index 148ed06..a00f497 100644 --- a/frontend/hosts.html +++ b/frontend/hosts.html @@ -96,12 +96,12 @@ - - - - - - + + + + + + @@ -124,31 +124,20 @@
- +
- -
+
-
diff --git a/frontend/js/aliases.js b/frontend/js/aliases.js new file mode 100644 index 0000000..a6e3a51 --- /dev/null +++ b/frontend/js/aliases.js @@ -0,0 +1,1022 @@ +// ----------------------------- +// Configuration parameters +// ----------------------------- +let timeoutToast = 3000; // milliseconds + +// ----------------------------- +// State variables +// ----------------------------- +let editingAliasId = null; +let sortDirection = {}; +let lastSort = null; // { colIndex: number, ascending: boolean } +const stringCollator = new Intl.Collator(undefined, { numeric: true, sensitivity: "base" }); + +// ----------------------------- +// Load all aliases into the table +// ----------------------------- +async function loadAliases() { + let aliases = []; + try { + // Fetch data + const res = await fetch(`/api/aliases`, { + headers: { Accept: 'application/json' }, + }); + + // Check content-type to avoid parsing errors + const contentType = res.headers.get("content-type") || ""; + if (!contentType.includes("application/json")) { + const err = new Error(`${res.status}: ${res.statusText}`); + err.status = res.status; + throw err; + } + + // Check JSON + let data; + try { + data = await res.json(); + aliases = Array.isArray(data) ? data : (Array.isArray(data?.data) ? data.data : []); + + } catch { + throw new Error('Invalid JSON payload'); + } + + // Check JSON errors + if (!res.ok) { + const serverMsg = data?.detail?.message?.trim(); + const base = `Error loading aliases`; + const err = new Error(serverMsg ? `${base}: ${serverMsg}` : base); + err.status = res.status; + throw err; + } + + } catch (err) { + console.error(err?.message || "Error loading aliases"); + showToast(err?.message || "Error loading aliase", false); + aliases = []; + } + + // DOM Reference + const tbody = document.querySelector("#hosts-table tbody"); + if (!tbody) { + console.warn('Element "#hosts-table tbody" not found in DOM.'); + return; + } + + // Svuota la tabella + tbody.innerHTML = ""; + + // if no aliases, show an empty row + if (!aliases.length) { + const trEmpty = document.createElement("tr"); + const tdEmpty = document.createElement("td"); + tdEmpty.colSpan = 7; + tdEmpty.textContent = "No alias available."; + tdEmpty.style.textAlign = "center"; + trEmpty.appendChild(tdEmpty); + tbody.appendChild(trEmpty); + return; + } + + // fragment per performance + const frag = document.createDocumentFragment(); + + aliases.forEach(h => { + const tr = document.createElement("tr"); + + // Name + { + const td = document.createElement("td"); + const val = (h.name ?? "").toString(); + td.textContent = val; + if (val) td.setAttribute("data-value", val.toLowerCase()); + tr.appendChild(td); + } + + // Target + { + const td = document.createElement("td"); + const val = (h.target ?? "").toString(); + td.textContent = val; + if (val) td.setAttribute("data-value", val.toLowerCase()); + tr.appendChild(td); + } + + // Note + { + const td = document.createElement("td"); + const val = (h.note ?? "").toString(); + td.textContent = val; + if (val) td.setAttribute("data-value", val.toLowerCase()); + tr.appendChild(td); + } + + // SSL (icon) + { + const td = document.createElement("td"); + const sslEnabled = !!h.ssl_enabled; + td.setAttribute("data-value", sslEnabled ? "true" : "false"); + td.setAttribute("aria-label", sslEnabled ? "SSL attivo" : "SSL non attivo"); + td.style.textAlign = "center"; + td.style.verticalAlign = "middle"; + if (sslEnabled) { + const icon = document.createElement("i"); + icon.className = "bi bi-shield-lock-fill icon icon-static"; + icon.setAttribute("aria-hidden", "true"); + td.appendChild(icon); + } + tr.appendChild(td); + } + + // Actions + { + const td = document.createElement("td"); + td.className = "actions"; + td.style.textAlign = "center"; + td.style.verticalAlign = "middle"; + + const id = Number(h.id); + + // Usa elementi reali invece di innerHTML con entity + const editSpan = document.createElement("span"); + editSpan.className = "action-icon"; + editSpan.setAttribute("role", "button"); + editSpan.tabIndex = 0; + editSpan.title = "Edit alias"; + editSpan.setAttribute("aria-label", "Edit alias"); + editSpan.setAttribute("data-bs-toggle", "modal"); + editSpan.setAttribute("data-bs-target", "#addAliasModal"); + editSpan.setAttribute("data-action", "edit"); + editSpan.setAttribute("data-alias-id", String(id)); + { + const i = document.createElement("i"); + i.className = "bi bi-pencil-fill icon icon-action"; + i.setAttribute("aria-hidden", "true"); + editSpan.appendChild(i); + } + + const delSpan = document.createElement("span"); + delSpan.className = "action-icon"; + delSpan.setAttribute("role", "button"); + delSpan.tabIndex = 0; + delSpan.title = "Delete alias"; + delSpan.setAttribute("aria-label", "Delete alias"); + delSpan.setAttribute("data-action", "delete"); + delSpan.setAttribute("data-alias-id", String(id)); + { + const i = document.createElement("i"); + i.className = "bi bi-trash-fill icon icon-action"; + i.setAttribute("aria-hidden", "true"); + delSpan.appendChild(i); + } + + td.appendChild(editSpan); + td.appendChild(delSpan); + tr.appendChild(td); + } + + frag.appendChild(tr); + }); + + // publish all rows + tbody.appendChild(frag); + + // apply last sorting + if (typeof lastSort === "object" && lastSort && Array.isArray(sortDirection)) { + if (Number.isInteger(lastSort.colIndex)) { + sortDirection[lastSort.colIndex] = !lastSort.ascending; + sortTable(lastSort.colIndex); + } + } +} + +// ----------------------------- +// Edit Alias: load data and pre-fill the form +// ----------------------------- +async function editAlias(id) { + // Clear form first + clearAddAliasForm(); + + // Fetch alias + const res = await fetch(`/api/aliases/${id}`, { + headers: { Accept: 'application/json' }, + }); + + // Check content-type to avoid parsing errors + const contentType = res.headers.get("content-type") || ""; + if (!contentType.includes("application/json")) { + const err = new Error(`Fetch failed for alias ${id}: ${res.statusText}`); + err.status = res.status; + throw err; + } + + // Check JSON + let data; + try { + data = await res.json(); + } catch { + throw new Error(`Fetch failed for alias ${id}: Invalid JSON payload`); + } + + // Check JSON errors + if (!res.ok) { + const serverMsg = data?.detail?.message?.trim(); + const base = `Fetch failed for alias ${id}`; + const err = new Error(serverMsg ? `${base}: ${serverMsg}` : base); + err.status = res.status; + throw err; + } + + // Store the ID of the alias being edited + editingAliasId = id; + + // Pre-fill the form fields + document.getElementById("aliasName").value = data.name ?? ""; + document.getElementById("aliasTarget").value = data.target ?? ""; + document.getElementById("aliasNote").value = data.note ?? ""; + document.getElementById("aliasSSL").checked = !!data.ssl_enabled; +} + +// ----------------------------- +// Save alias (CREATE OR UPDATE) +// ----------------------------- +async function saveAlias(aliasData) { + // Validate alias + if (!aliasData.name.trim()) { + showToast("Alias is required", false); + return false; + } + // Validate Target + if (!aliasData.target.trim()) { + showToast("Target is required", false); + return false; + } + + if (editingAliasId !== null) { + // Update existing alias + const res = await fetch(`/api/aliases/${editingAliasId}`, { + method: 'PUT', + headers: { 'Content-Type': 'application/json' }, + body: JSON.stringify(aliasData) + }); + + // Success without JSON + if (res.status === 204) { + showToast('Alias updated successfully', true); + return true; + } + + // Check content-type to avoid parsing errors + const contentType = res.headers.get("content-type") || ""; + if (!contentType.includes("application/json")) { + const err = new Error(`${res.status}: ${res.statusText}`); + err.status = res.status; + throw err; + } + + // Check JSON + let data; + try { + data = await res.json(); + } catch { + throw new Error('Invalid JSON payload'); + } + + // Check JSON errors + if (!res.ok) { + const serverMsg = data?.detail?.message?.trim(); + const base = `Error updating alias`; + const err = new Error(serverMsg ? `${base}: ${serverMsg}` : base); + err.status = res.status; + throw err; + } + + // Success + showToast(data?.message || 'Alias updated successfully', true); + return true; + + } else { + // Create new alias + const res = await fetch(`/api/aliases`, { + method: 'POST', + headers: { 'Content-Type': 'application/json' }, + body: JSON.stringify(aliasData) + }); + + // Success without JSON + if (res.status === 204) { + showToast('Alias created successfully', true); + return true; + } + + // Check content-type to avoid parsing errors + const contentType = res.headers.get("content-type") || ""; + if (!contentType.includes("application/json")) { + const err = new Error(`${res.status}: ${res.statusText}`); + err.status = res.status; + throw err; + } + + // Check JSON + let data; + try { + data = await res.json(); + } catch { + throw new Error('Invalid JSON payload'); + } + + // Check JSON errors + if (!res.ok) { + const serverMsg = data?.detail?.message?.trim(); + const base = `Error adding alias`; + const err = new Error(serverMsg ? `${base}: ${serverMsg}` : base); + err.status = res.status; + throw err; + } + + // Success + showToast(data?.message || 'Alias created successfully', true); + return true + } +} + +// ----------------------------- +// Prepare add alias form +// ----------------------------- +function clearAddAliasForm() { + // reset edit mode + editingAliasId = null; + // reset form fields + document.getElementById('addAliasForm')?.reset(); +} + +// ----------------------------- +// Close popup +// ----------------------------- +async function closeAddAliasModal() { + const modalEl = document.getElementById('addAliasModal'); + const modal = bootstrap.Modal.getInstance(modalEl) + || bootstrap.Modal.getOrCreateInstance(modalEl); + modal.hide(); +} + +// ----------------------------- +// Handle Add alias form submit +// ----------------------------- +async function handleAddAliasSubmit(e) { + // Prevent default form submission + e.preventDefault(); + + try { + // Retrieve form data + const data = { + name: document.getElementById('aliasName').value.trim(), + target: document.getElementById('aliasTarget').value.trim(), + note: document.getElementById('aliasNote').value.trim(), + ssl_enabled: document.getElementById('aliasSSL').checked ? 1 : 0 + }; + + const ok = await saveAlias(data); + if (ok !== false) { + // close modal and reload aliases + closeAddAliasModal(); + await loadAliases(); + return true + } + + } catch (err) { + console.error(err?.message || "Error saving alias"); + showToast(err?.message || "Error saving alias", false); + } + + return false; +} + +// ----------------------------- +// Handle delete alias action +// ----------------------------- +async function handleDeleteAlias(e, el) { + // Prevent default action + e.preventDefault(); + + // Get alias ID + const id = Number(el.dataset.aliasId); + if (!Number.isFinite(id)) { + console.warn('Delete: alias id not valid for delete:', id); + showToast('Alias id not valid for delete', false); + return; + } + + // Execute delete + try { + // Fetch data + const res = await fetch(`/api/aliases/${id}`, { + method: 'DELETE', + headers: { 'Accept': 'application/json' }, + }); + + // Check content-type to avoid parsing errors + const contentType = res.headers.get("content-type") || ""; + if (!contentType.includes("application/json")) { + const err = new Error(`${res.status}: ${res.statusText}`); + err.status = res.status; + throw err; + } + + // Check JSON + let data; + try { + data = await res.json(); + } catch { + throw new Error('Invalid JSON payload'); + } + + // Check JSON errors + if (!res.ok) { + const serverMsg = data?.detail?.message?.trim(); + const base = `Error deleting alias`; + const err = new Error(serverMsg ? `${base}: ${serverMsg}` : base); + err.status = res.status; + throw err; + } + + // Success + showToast(data?.message || 'Alias deleted successfully', true); + + // Reload aliases + await loadAliases(); + return true; + + } catch (err) { + console.error(err?.message || "Error deleting alias"); + showToast(err?.message || "Error deleting alias", false); + } + + return false; +} + +// ----------------------------- +// Handle reload DNS action +// ----------------------------- +async function handleReloadDNS() { + try { + // Fetch data + const res = await fetch(`/api/dns/reload`, { + method: 'POST', + headers: { 'Accept': 'application/json' }, + }); + + // Success without JSON + if (res.status === 204) { + showToast('DNS reload successfully', true); + return true; + } + + // Check content-type to avoid parsing errors + const contentType = res.headers.get("content-type") || ""; + if (!contentType.includes("application/json")) { + const err = new Error(`${res.status}: ${res.statusText}`); + err.status = res.status; + throw err; + } + + // Check JSON + let data; + try { + data = await res.json(); + } catch { + throw new Error('Invalid JSON payload'); + } + + // Check JSON errors + if (!res.ok) { + const serverMsg = data?.detail?.message?.trim(); + const base = `Error reloading DNS`; + const err = new Error(serverMsg ? `${base}: ${serverMsg}` : base); + err.status = res.status; + throw err; + } + + // Success + showToast(data?.message || 'DNS reload successfully', true); + return true; + + } catch (err) { + console.error(err?.message || "Error reloading DNS"); + showToast(err?.message || "Error reloading DNS", false); + } + + return false; +} + +// ----------------------------- +// Handle reload DHCP action +// ----------------------------- +async function handleReloadDHCP() { + try { + // Fetch data + const res = await fetch(`/api/dhcp/reload`, { + method: 'POST', + headers: { 'Accept': 'application/json' }, + }); + + // Success without JSON + if (res.status === 204) { + showToast('DHCP reload successfully', true); + return true; + } + + // Check content-type to avoid parsing errors + const contentType = res.headers.get("content-type") || ""; + if (!contentType.includes("application/json")) { + const err = new Error(`${res.status}: ${res.statusText}`); + err.status = res.status; + throw err; + } + + // Check JSON + let data; + try { + data = await res.json(); + } catch { + throw new Error('Error reloading DHCP: Invalid JSON payload'); + } + + // Check JSON errors + if (!res.ok) { + const serverMsg = data?.detail?.message?.trim(); + const base = `Error reloadin DHCP`; + const err = new Error(serverMsg ? `${base}: ${serverMsg}` : base); + err.status = res.status; + throw err; + } + + // Success + showToast(data?.message || 'DHCP reload successfully', true); + return true; + + } catch (err) { + console.error(err?.message || "Error reloading DHCP"); + showToast(err?.message || "Error reloading DHCP", false); + } + + return false; +} + +// ----------------------------- +// Display a temporary notification message +// ----------------------------- +function showToast(message, success = true) { + const toast = document.getElementById("toast"); + toast.textContent = message; + + toast.style.background = success ? "#28a745" : "#d9534f"; // green / red + + toast.classList.add("show"); + + setTimeout(() => { + toast.classList.remove("show"); + }, timeoutToast); +} + +// ----------------------------- +// filter aliases in the table +// ----------------------------- +function filterAliases() { + const query = document.getElementById("searchInput").value.toLowerCase(); + const rows = document.querySelectorAll("#hosts-table tbody tr"); + + rows.forEach(row => { + const text = row.textContent.toLowerCase(); + row.style.display = text.includes(query) ? "" : "none"; + }); +} + +// ----------------------------- +// Clear search on ESC key +// ----------------------------- +async function clearSearch() { + const input = document.getElementById("searchInput"); + input.value = ""; + input.blur(); + await loadAliases(); +} + +/** + * Parser per tipi di dato: + * - number: riconosce float, anche con virgole migliaia + * - date: tenta Date.parse su formati comuni + * - ipv4: ordina per valore numerico dei 4 ottetti + * - ipv6: espande '::' e ordina come BigInt 128-bit + * - mac: normalizza e ordina come BigInt 48-bit + * - version: ordina semver-like "1.2.10" + * - string: predefinito (locale-aware, case-insensitive, con numerico) + */ +function parseByType(value, type) { + const v = (value ?? "").trim(); + + if (v === "") return { type: "empty", value: null }; + + switch (type) { + case "number": { + // Rimuove separatori di migliaia (spazio, apostrofo, punto prima di gruppi da 3) + // e converte la virgola decimale in punto. + const norm = v.replace(/[\s'’\.](?=\d{3}\b)/g, "").replace(",", "."); + const n = Number(norm); + return isNaN(n) ? { type: "string", value: v.toLowerCase() } : { type: "number", value: n }; + } + + case "date": { + let time = Date.parse(v); + if (isNaN(time)) { + // prova formato DD/MM/YYYY [HH:mm] + const m = v.match(/^(\d{1,2})\/(\d{1,2})\/(\d{4})(?:\s+(\d{1,2}):(\d{2}))?$/); + if (m) { + const [_, d, mo, y, hh = "0", mm = "0"] = m; + time = Date.parse(`${y}-${mo.padStart(2,"0")}-${d.padStart(2,"0")}T${hh.padStart(2,"0")}:${mm.padStart(2,"0")}:00`); + } + } + return isNaN(time) ? { type: "string", value: v.toLowerCase() } : { type: "date", value: time }; + } + + case "ipv4": { + const m = v.match(/^(\d{1,3})\.(\d{1,3})\.(\d{1,3})\.(\d{1,3})$/); + if (m) { + const a = +m[1], b = +m[2], c = +m[3], d = +m[4]; + if ([a,b,c,d].every(n => Number.isInteger(n) && n >= 0 && n <= 255)) { + const num = ((a << 24) | (b << 16) | (c << 8) | d) >>> 0; // 32-bit unsigned + return { type: "ipv4", value: num }; + } + } + return { type: "string", value: v.toLowerCase() }; + } + + case "ipv6": { + // Espansione '::' e parsing 8 gruppi hex da 16 bit ? BigInt 128-bit + let s = v.toLowerCase().trim(); + const dbl = s.indexOf("::"); + let parts = []; + if (dbl >= 0) { + const left = s.slice(0, dbl).split(":").filter(Boolean); + const right = s.slice(dbl + 2).split(":").filter(Boolean); + const missing = 8 - (left.length + right.length); + if (missing < 0) return { type: "string", value: v.toLowerCase() }; + parts = [...left, ...Array(missing).fill("0"), ...right]; + } else { + parts = s.split(":"); + if (parts.length !== 8) return { type: "string", value: v.toLowerCase() }; + } + if (!parts.every(p => /^[0-9a-f]{1,4}$/.test(p))) { + return { type: "string", value: v.toLowerCase() }; + } + let big = 0n; + for (const p of parts) { + big = (big << 16n) + BigInt(parseInt(p, 16)); + } + return { type: "ipv6", value: big }; + } + + case "mac": { + // Accetta :, -, ., spazi o formato compatto; ordina come BigInt 48-bit + let s = v.toLowerCase().trim().replace(/[\s:\-\.]/g, ""); + if (!/^[0-9a-f]{12}$/.test(s)) { + return { type: "string", value: v.toLowerCase() }; + } + const mac = BigInt("0x" + s); + return { type: "mac", value: mac }; + } + + case "version": { + const segs = v.split(".").map(s => (/^\d+$/.test(s) ? Number(s) : s.toLowerCase())); + return { type: "version", value: segs }; + } + + default: + case "string": + return { type: "string", value: v.toLowerCase() }; + } +} + +/** + * Comparatore generico in base al tipo + */ +function comparator(aParsed, bParsed) { + // Celle vuote in fondo in asc + if (aParsed.type === "empty" && bParsed.type === "empty") return 0; + if (aParsed.type === "empty") return 1; + if (bParsed.type === "empty") return -1; + + // Se i tipi differiscono (capita se fallback a string), imponi una gerarchia: + // tipi “numerici” prima delle stringhe + if (aParsed.type !== bParsed.type) { + const rank = { number: 0, date: 0, ipv4: 0, ipv6: 0, mac: 0, version: 0, string: 1 }; + return (rank[aParsed.type] ?? 1) - (rank[bParsed.type] ?? 1); + } + + switch (aParsed.type) { + case "number": + case "date": + case "ipv4": + return aParsed.value - bParsed.value; + + case "ipv6": + case "mac": { + // Confronto BigInt + if (aParsed.value === bParsed.value) return 0; + return aParsed.value < bParsed.value ? -1 : 1; + } + + case "version": { + const a = aParsed.value, b = bParsed.value; + const len = Math.max(a.length, b.length); + for (let i = 0; i < len; i++) { + const av = a[i] ?? 0; + const bv = b[i] ?? 0; + if (typeof av === "number" && typeof bv === "number") { + if (av !== bv) return av - bv; + } else { + const as = String(av), bs = String(bv); + const cmp = stringCollator.compare(as, bs); + if (cmp !== 0) return cmp; + } + } + return 0; + } + + case "string": + default: + return stringCollator.compare(aParsed.value, bParsed.value); + } +} + +/** + * Aggiorna UI delle frecce e ARIA in thead + */ +function updateSortUI(table, colIndex, ascending) { + const ths = table.querySelectorAll("thead th"); + ths.forEach((th, i) => { + const arrow = th.querySelector(".sort-arrow"); + th.setAttribute("aria-sort", i === colIndex ? (ascending ? "ascending" : "descending") : "none"); + th.classList.toggle("is-sorted", i === colIndex); + if (arrow) { + arrow.classList.remove("asc", "desc"); + if (i === colIndex) arrow.classList.add(ascending ? "asc" : "desc"); + } + // Se usi pulsanti
Name IPv4 IPv6 MAC Note SSL Hostname IPv4 IPv6 MAC Note SSL Actions