LOADED_PLUGINS.",
"DISCOVER_PLUGINS_name": "Descobreix els plugins",
"DevDetail_Children_Title": "Relacions filles",
@@ -141,7 +141,7 @@
"DevDetail_SessionTable_Duration": "Durada",
"DevDetail_SessionTable_IP": "IP",
"DevDetail_SessionTable_Order": "Ordre",
- "DevDetail_Shortcut_CurrentStatus": "Estat actual",
+ "DevDetail_Shortcut_CurrentStatus": "Estat",
"DevDetail_Shortcut_DownAlerts": "Aturar alertes",
"DevDetail_Shortcut_Presence": "Presència",
"DevDetail_Shortcut_Sessions": "Sessions",
@@ -250,7 +250,7 @@
"Device_TableHead_NetworkSite": "Network Site",
"Device_TableHead_Owner": "Propietari",
"Device_TableHead_ParentRelType": "Tipus de relació",
- "Device_TableHead_Parent_MAC": "Node pare de xarxa",
+ "Device_TableHead_Parent_MAC": "Node pare",
"Device_TableHead_Port": "Port",
"Device_TableHead_PresentLastScan": "Presència",
"Device_TableHead_ReqNicsOnline": "Requereix NICs En línia",
@@ -346,7 +346,7 @@
"Gen_LockedDB": "ERROR - DB podria estar bloquejada - Fes servir F12 Eines desenvolupament -> Consola o provar-ho més tard.",
"Gen_NetworkMask": "Màscara de xarxa",
"Gen_New": "Nou",
- "Gen_No_Data": "",
+ "Gen_No_Data": "Sense dades",
"Gen_Offline": "Fora de línia",
"Gen_Okay": "Ok",
"Gen_Online": "En línia",
@@ -808,4 +808,4 @@
"settings_system_label": "Sistema",
"settings_update_item_warning": "Actualitza el valor sota. Sigues curós de seguir el format anterior. No hi ha validació.",
"test_event_tooltip": "Deseu els canvis primer abans de comprovar la configuració."
-}
\ No newline at end of file
+}
diff --git a/front/php/templates/language/pt_pt.json b/front/php/templates/language/pt_pt.json
index 15aca397..a5629325 100644
--- a/front/php/templates/language/pt_pt.json
+++ b/front/php/templates/language/pt_pt.json
@@ -37,7 +37,7 @@
"BackDevDetail_Tools_WOL_error": "O comando NÃO foi executado.",
"BackDevDetail_Tools_WOL_okay": "O comando foi executado.",
"BackDevices_Arpscan_disabled": "Análise Arp Desativada",
- "BackDevices_Arpscan_enabled": "Análise ARP Ativada",
+ "BackDevices_Arpscan_enabled": "Análise Arp Ativada",
"BackDevices_Backup_CopError": "A base da dados original não pode ser gravada.",
"BackDevices_Backup_Failed": "A copia de segurança foi parcialmente executada. O arquivo não pode ser criado ou está vazio.",
"BackDevices_Backup_okay": "A copia de segurança foi feita executado corretamente com o novo arquivo",
@@ -61,14 +61,14 @@
"BackDevices_Restore_okay": "Restauração executada com sucesso.",
"BackDevices_darkmode_disabled": "Modo Noturno Desativado",
"BackDevices_darkmode_enabled": "Modo Noturno Ativado",
- "CLEAR_NEW_FLAG_description": "Se ativado (0 está desativado), dispositivos marcados comoNovo Dispositivo serão desmarcados se o limite (especificado em horas) exceder o tempo da Primeira Sessão .",
+ "CLEAR_NEW_FLAG_description": "Se ativado (0 está desativado), dispositivos marcados como Novo Dispositivo serão desmarcados se o limite (especificado em horas) exceder o tempo da Primeira Sessão.",
"CLEAR_NEW_FLAG_name": "Limpar a flag nova",
"CustProps_cant_remove": "Não é possível remover, é necessária pelo menos uma propriedade.",
"DAYS_TO_KEEP_EVENTS_description": "Esta é uma definição de manutenção. Especifica o número de dias de entradas de eventos que serão mantidas. Todos os eventos mais antigos serão apagados periodicamente. Também se aplica ao Histórico de eventos do plug-in.",
"DAYS_TO_KEEP_EVENTS_name": "Apagar eventos mais antigos que",
"DEEP_SLEEP_description": "Diminui a utilização do CPU ao prolongar tempos de espera ociosos entre ciclos de processamento. Quando ativo, análises podem ser atrasadas por até 1 minuto e o UI pode ficar menos responsivo.",
"DEEP_SLEEP_name": "Sleep profundo",
- "DISCOVER_PLUGINS_description": "Desative esta opção para acelerar a inicialização e a gravação de definições. Quando desativada, os plug-ins não são descobertos e não é possível adicionar novos plug-ins à definiçãoLOADED_PLUGINS.",
+ "DISCOVER_PLUGINS_description": "Desative esta opção para acelerar a inicialização e a gravação de definições. Quando desativada, os plug-ins não são descobertos e não é possível adicionar novos plug-ins à definição LOADED_PLUGINS.",
"DISCOVER_PLUGINS_name": "Descobrir plugins",
"DevDetail_Children_Title": "Relacionamentos de crianças",
"DevDetail_Copy_Device_Title": "Copiar pormenores do dispositivo",
@@ -98,7 +98,7 @@
"DevDetail_MainInfo_Location": "Localização",
"DevDetail_MainInfo_Name": "Nome",
"DevDetail_MainInfo_Network": " Node (MAC)",
- "DevDetail_MainInfo_Network_Port": "Porta",
+ "DevDetail_MainInfo_Network_Port": " Porta",
"DevDetail_MainInfo_Network_Site": "Site",
"DevDetail_MainInfo_Network_Title": "Detalhes de Rede",
"DevDetail_MainInfo_Owner": "Proprietário",
@@ -341,7 +341,7 @@
"Gen_Filter": "Filtro",
"Gen_Flapping": "Flapping",
"Gen_Generate": "Gerar",
- "Gen_InvalidMac": "Endereço MAC Inválido.",
+ "Gen_InvalidMac": "Endereço Mac inválido.",
"Gen_Invalid_Value": "Um valor inválido foi inserido",
"Gen_LockedDB": "ERRO - A base de dados pode estar bloqueada - Verifique F12 Ferramentas de desenvolvimento -> Console ou tente mais tarde.",
"Gen_NetworkMask": "Máscara de Rede",
@@ -350,7 +350,7 @@
"Gen_Offline": "Offline",
"Gen_Okay": "Ok",
"Gen_Online": "Online",
- "Gen_Purge": "Purge",
+ "Gen_Purge": "Purgar",
"Gen_ReadDocs": "Leia mais em documentos.",
"Gen_Remove_All": "Remover tudo",
"Gen_Remove_Last": "Remover o último",
@@ -495,7 +495,7 @@
"Maintenance_Tool_upgrade_database_noti_text": "Tem certeza de que deseja atualizar a base de dados?DBCLNP_NOTIFI_HIST. app.conf. Tente reiniciar o contentoer e ler a documentação de permissões de ficheiro",
+ "settings_saved": "/server и, как правило, не должно изменяться.",
+ "BACKEND_API_URL_description": "Используется для обеспечения связи между фронтендом и бэкендом. По умолчанию это значение установлено на /server и, как правило, не должно изменяться.",
"BACKEND_API_URL_name": "URL-адрес серверного API",
"BackDevDetail_Actions_Ask_Run": "Вы хотите выполнить действие?",
"BackDevDetail_Actions_Not_Registered": "Действие не зарегистрировано:· ",
diff --git a/front/plugins/dig_scan/config.json b/front/plugins/dig_scan/config.json
index fb39b55d..9c176e7f 100755
--- a/front/plugins/dig_scan/config.json
+++ b/front/plugins/dig_scan/config.json
@@ -52,7 +52,7 @@
{ "elementType": "select", "elementOptions": [], "transformers": [] }
]
},
- "default_value": "before_name_updates",
+ "default_value": "disabled",
"options": [
"disabled",
"before_name_updates",
diff --git a/front/plugins/icmp_scan/icmp.py b/front/plugins/icmp_scan/icmp.py
index e5955cd1..91be5311 100755
--- a/front/plugins/icmp_scan/icmp.py
+++ b/front/plugins/icmp_scan/icmp.py
@@ -209,53 +209,83 @@ def execute_fping(timeout, args, all_devices, plugin_objects, subnets, interface
def run_fping(targets):
targets = expand_subnets(targets)
+
if not targets:
return []
- is_ipv6 = any(':' in t for t in targets)
- cmd = ["fping", "-a"] + args.split() + targets
- if is_ipv6:
- cmd.insert(1, "-6") # insert -6 after "fping"
+ ipv4_targets = [t for t in targets if ':' not in t]
+ ipv6_targets = [t for t in targets if ':' in t]
- if interfaces:
- cmd += ["-I", ",".join(interfaces)]
+ def run_family(family_targets, ipv6=False):
+ if not family_targets:
+ return []
- mylog("verbose", [f"[{pluginName}] fping cmd: {' '.join(cmd)}"])
+ interface_list = interfaces if interfaces else [None]
- try:
- output = subprocess.check_output(
- cmd,
- stderr=subprocess.DEVNULL,
- timeout=timeout,
- text=True
- )
- except subprocess.CalledProcessError as e:
- output = e.output
- mylog("none", [f"[{pluginName}] fping returned non-zero exit code, reading alive hosts anyway"])
- except subprocess.TimeoutExpired:
- mylog("none", [f"[{pluginName}] fping timeout"])
- return []
+ all_results = []
+ seen_ips = set()
- results = []
- for line in output.splitlines():
- line = line.strip()
- if not line:
- continue
+ for interface in interface_list:
- # Skip unreachable, timed out, or 100% packet loss
- if "unreachable" in line.lower() or "timed out" in line.lower() or "100% loss" in line.lower():
- mylog("debug", [f"[{pluginName}] fping skipping {line}"])
- continue
+ cmd = ["fping", "-a"]
- match = ip_regex.search(line)
- if match:
- ip = match.group(0)
- mylog("debug", [f"[{pluginName}] adding {ip} from {line}"])
- results.append((ip, line))
- else:
- mylog("verbose", [f"[{pluginName}] fping non-parseable {line}"])
+ if ipv6:
+ cmd.append("-6")
- return results
+ cmd += args.split()
+
+ if interface:
+ cmd += ["-I", interface]
+
+ cmd += family_targets
+
+ mylog("verbose", [f"[{pluginName}] fping cmd: {' '.join(cmd)}"])
+
+ try:
+ output = subprocess.check_output(
+ cmd,
+ stderr=subprocess.DEVNULL,
+ timeout=timeout,
+ text=True
+ )
+
+ except subprocess.CalledProcessError as e:
+ output = e.output
+ mylog("none", [
+ f"[{pluginName}] fping returned non-zero exit code "
+ f"on interface {interface}, reading alive hosts anyway"
+ ])
+
+ except subprocess.TimeoutExpired:
+ mylog("none", [
+ f"[{pluginName}] fping timeout on interface {interface}"
+ ])
+ continue
+
+ for line in output.splitlines():
+ line = line.strip()
+ if not line:
+ continue
+
+ lower_line = line.lower()
+
+ if "unreachable" in lower_line or "timed out" in lower_line or "100% loss" in lower_line:
+ continue
+
+ match = ip_regex.search(line)
+
+ if match:
+ ip = match.group(0)
+
+ if ip in seen_ips:
+ continue
+
+ seen_ips.add(ip)
+ all_results.append((ip, line))
+
+ return all_results
+
+ return run_family(ipv4_targets, ipv6=False) + run_family(ipv6_targets, ipv6=True)
# Scan subnets
mylog("verbose", [f"[{pluginName}] run_fping: subnets {subnets}"])
diff --git a/front/plugins/kea_api/README.md b/front/plugins/kea_api/README.md
new file mode 100755
index 00000000..9ddc174c
--- /dev/null
+++ b/front/plugins/kea_api/README.md
@@ -0,0 +1,99 @@
+## Overview
+
+A plugin allowing for importing devices from the Kea DHCP API.
+https://www.isc.org/kea/
+
+And specifically:
+https://kea.readthedocs.io/en/kea-2.6.3/api.html#lease4-get-all
+
+
+### Usage
+
+To enable the API, first you want to add something like this to your main kea configuration (this is for debian 13):
+
+```json
+ "control-socket": {
+ "socket-type": "unix",
+ "socket-name": "/run/kea/kea4-ctrl-socket"
+ },
+
+ "hooks-libraries": [
+ {
+ "library": "/usr/lib/x86_64-linux-gnu/kea/hooks/libdhcp_lease_cmds.so"
+ }
+ ],
+```
+
+
+And you need to install kea-ctrl-agent, with a config that looks something like this:
+
+```json
+{
+"Control-agent": {
+ "http-host": "127.0.0.1",
+ "http-port": 8000,
+
+ "authentication": {
+ "type": "basic",
+ "realm": "Kea Control Agent",
+ "directory": "/etc/kea",
+ "clients": [
+ {
+ "user": "kea-api",
+ "password-file": "kea-api-password"
+ }
+ ]
+ },
+ "control-sockets": {
+ "dhcp4": {
+ "socket-type": "unix",
+ "socket-name": "/run/kea/kea4-ctrl-socket"
+ }
+ },
+ "loggers": [
+ {
+ "name": "kea-ctrl-agent",
+ "output-options": [
+ {
+ "output": "stdout",
+ "pattern": "%-5p %m\n"
+ }
+ ],
+ "severity": "INFO",
+ "debuglevel": 0
+ }
+ ]
+}
+}
+```
+
+You will need to configure the plugin with the URL to the API, and the username and password configured above (from kea-api-password file in the example)
+
+
+#### Required Settings
+
+These settings are required, besides the common device scanner settings:
+
+- **Kea Control Agent URL** (`KEALSS_URL`): The full URL, including port number, to the Kea API.
+ - Default: `http://127.0.0.1:8000`
+ - This mirrors what you set up in the kea-ctrl-agent configuration.
+
+- **Basic Auth Username** (`KEALSS_USER`): The user to use for authenticating with the Kea API.
+ - Default: `kea-api`
+ - This mirrors what you set up in the kea-ctrl-agent configuration.
+
+- **Basic Auth Password** (`KEALSS_PASS`): The password to use for authenticating with the Kea API.
+ - This mirrors what you set up in the kea-ctrl-agent configuration.
+ - When using a password file, it should be the content of the password file.
+
+
+### Notes
+
+- This was tested on a basic Debian 13 install.
+- When you install kea-ctrl-agent, it should ask you about creating a password.
+- It's possible to run kea-ctrl-agent without password, but it's not recommended and at the moment we don't support that.
+- I may provide some minimal support, if you ask nicely :)
+
+- Version: 1.0.0
+- Author: `void-spark`
+- Release Date: `11/05/2026`
diff --git a/front/plugins/kea_api/config.json b/front/plugins/kea_api/config.json
new file mode 100644
index 00000000..6bc00f3d
--- /dev/null
+++ b/front/plugins/kea_api/config.json
@@ -0,0 +1,455 @@
+{
+ "code_name": "kea_api",
+ "unique_prefix": "KEALSS",
+ "plugin_type": "device_scanner",
+ "execution_order" : "Layer_3",
+ "enabled": true,
+ "data_source": "script",
+ "data_filters": [
+ {
+ "compare_column": "objectPrimaryId",
+ "compare_operator": "==",
+ "compare_field_id": "txtMacFilter",
+ "compare_js_template": "'{value}'.toString()",
+ "compare_use_quotes": true
+ }
+ ],
+ "show_ui": true,
+ "localized": ["display_name", "description", "icon"],
+ "mapped_to_table": "CurrentScan",
+ "display_name": [{"language_code": "en_us", "string": "Kea DHCP API"}],
+ "icon": [{"language_code": "en_us", "string": ""}],
+ "description": [{"language_code": "en_us", "string": "Imports leases via Kea Control Agent REST API"}],
+ "database_column_definitions": [
+ {
+ "column": "index",
+ "css_classes": "col-sm-2",
+ "show": true,
+ "type": "none",
+ "default_value": "",
+ "options": [],
+ "localized": ["name"],
+ "name": [{"language_code": "en_us", "string": "Index"}]
+ },
+ {
+ "column": "objectPrimaryId",
+ "mapped_to_column": "scanMac",
+ "css_classes": "col-sm-2",
+ "show": true,
+ "type": "device_mac",
+ "default_value": "",
+ "options": [],
+ "localized": ["name"],
+ "name": [{"language_code": "en_us", "string": "MAC address"}]
+ },
+ {
+ "column": "objectSecondaryId",
+ "mapped_to_column": "scanLastIP",
+ "css_classes": "col-sm-2",
+ "show": true,
+ "type": "device_ip",
+ "default_value": "",
+ "options": [],
+ "localized": ["name"],
+ "name": [{"language_code": "en_us", "string": "IP" }]
+ },
+ {
+ "column": "dateTimeCreated",
+ "css_classes": "col-sm-2",
+ "show": true,
+ "type": "label",
+ "default_value": "",
+ "options": [],
+ "localized": ["name"],
+ "name": [{"language_code": "en_us", "string": "Created"}]
+ },
+ {
+ "column": "dateTimeChanged",
+ "mapped_to_column": "scanLastConnection",
+ "css_classes": "col-sm-2",
+ "show": true,
+ "type": "label",
+ "default_value": "",
+ "options": [],
+ "localized": ["name"],
+ "name": [{"language_code": "en_us", "string": "Changed"}]
+ },
+ {
+ "column": "watchedValue1",
+ "css_classes": "col-sm-2",
+ "show": true,
+ "type": "label",
+ "default_value": "",
+ "options": [],
+ "localized": ["name"],
+ "name": [{"language_code": "en_us", "string": "Is active"}]
+ },
+ {
+ "column": "watchedValue2",
+ "mapped_to_column": "scanName",
+ "css_classes": "col-sm-2",
+ "show": true,
+ "type": "label",
+ "default_value": "",
+ "options": [],
+ "localized": ["name"],
+ "name": [{"language_code": "en_us", "string": "Hostname"}]
+ },
+ {
+ "column": "watchedValue4",
+ "css_classes": "col-sm-2",
+ "show": true,
+ "type": "label",
+ "default_value": "",
+ "options": [],
+ "localized": ["name"],
+ "name": [{"language_code": "en_us", "string": "State"}]
+ },
+ {
+ "column": "userData",
+ "css_classes": "col-sm-2",
+ "show": false,
+ "type": "textbox_save",
+ "default_value": "",
+ "options": [],
+ "localized": ["name"],
+ "name": [{"language_code": "en_us", "string": "Comments"}]
+ },
+ {
+ "column": "Dummy",
+ "mapped_to_column": "scanSourcePlugin",
+ "mapped_to_column_data": {
+ "value": "KEALSS"
+ },
+ "css_classes": "col-sm-2",
+ "show": false,
+ "type": "label",
+ "default_value": "",
+ "options": [],
+ "localized": ["name"],
+ "name": [{"language_code": "en_us", "string": "Scan method"}]
+ },
+ {
+ "column": "status",
+ "css_classes": "col-sm-1",
+ "show": true,
+ "type": "replace",
+ "default_value": "",
+ "options": [
+ {
+ "equals": "watched-not-changed",
+ "replacement": "Kea API. If you select schedule the scheduling settings from below are applied. If you select once the scan is run only once on start of the application (container) or after you update your settings. ⚠ Use the same schedule if you have multiple Device scanners enabled."
+ }
+ ]
+ },
+ {
+ "function": "CMD",
+ "type": {
+ "dataType": "string",
+ "elements": [
+ { "elementType": "input", "elementOptions": [], "transformers": [] }
+ ]
+ },
+ "default_value": "python3 /app/front/plugins/kea_api/script.py",
+ "options": [],
+ "localized": ["name", "description"],
+ "name": [{"language_code": "en_us", "string": "Command"}],
+ "description": [{"language_code": "en_us", "string": "Command to run"}]
+ },
+ {
+ "function": "URL",
+ "localized": ["name", "description"],
+ "name": [{"language_code": "en_us", "string": "API URL"}],
+ "description": [{"language_code": "en_us", "string": "Kea Control Agent URL"}],
+ "type": {
+ "dataType": "string",
+ "elements": [
+ {
+ "elementType": "input",
+ "elementOptions": [],
+ "transformers": []
+ }
+ ]
+ },
+ "default_value": "http://127.0.0.1:8000"
+ },
+ {
+ "function": "USER",
+ "localized": ["name", "description"],
+ "name": [{"language_code": "en_us", "string": "API User"}],
+ "description": [{"language_code": "en_us", "string": "Basic Auth Username"}],
+ "type": {
+ "dataType": "string",
+ "elements": [
+ {
+ "elementType": "input",
+ "elementOptions": [],
+ "transformers": []
+ }
+ ]
+ },
+ "default_value": "kea-api"
+ },
+ {
+ "function": "PASS",
+ "localized": ["name", "description"],
+ "name": [{"language_code": "en_us", "string": "API Password"}],
+ "description": [{"language_code": "en_us", "string": "Basic Auth Password"}],
+ "type": {
+ "dataType": "string",
+ "elements": [
+ {
+ "elementType": "input",
+ "elementOptions": [{"type": "password"}],
+ "transformers": []
+ }
+ ]
+ },
+ "default_value": ""
+ },
+ {
+ "function": "RUN_SCHD",
+ "type": {
+ "dataType": "string",
+ "elements": [
+ {
+ "elementType": "span",
+ "elementOptions": [
+ {
+ "cssClasses": "input-group-addon validityCheck"
+ },
+ {
+ "getStringKey": "Gen_ValidIcon"
+ }
+ ],
+ "transformers": []
+ },
+ {
+ "elementType": "input",
+ "elementOptions": [
+ {
+ "focusout": "validateRegex(this)"
+ },
+ {
+ "base64Regex": "Xig/OlwqfCg/OlswLTldfFsxLTVdWzAtOV18WzAtOV0rLVswLTldK3xcKi9bMC05XSspKVxzKyg/OlwqfCg/OlswLTldfDFbMC05XXwyWzAtM118WzAtOV0rLVswLTldK3xcKi9bMC05XSspKVxzKyg/OlwqfCg/OlsxLTldfFsxMl1bMC05XXwzWzAxXXxbMC05XSstWzAtOV0rfFwqL1swLTldKykpXHMrKD86XCp8KD86WzEtOV18MVswLTJdfFswLTldKy1bMC05XSt8XCovWzAtOV0rKSlccysoPzpcKnwoPzpbMC02XXxbMC02XS1bMC02XXxcKi9bMC05XSspKSQ="
+ }
+ ],
+ "transformers": []
+ }
+ ]
+ },
+ "default_value": "0 2 * * *",
+ "options": [],
+ "localized": ["name", "description"],
+ "name": [
+ {
+ "language_code": "en_us",
+ "string": "Schedule"
+ }
+ ],
+ "description": [
+ {
+ "language_code": "en_us",
+ "string": "Only enabled if you select schedule in the KEALSS_RUN setting. Make sure you enter the schedule in the correct cron-like format (e.g. validate at crontab.guru). For example entering 0 4 * * * will run the scan after 4 am in the TIMEZONE you set above. Will be run NEXT time the time passes. Source = USER or Source = LOCKED)."
+ }
+ ]
+ },
+ {
+ "function": "SET_EMPTY",
+ "type": {
+ "dataType": "array",
+ "elements": [
+ {
+ "elementType": "select",
+ "elementOptions": [{ "multiple": "true", "orderable": "true" }],
+ "transformers": []
+ }
+ ]
+ },
+ "default_value": [],
+ "options": [
+ "devMac",
+ "devLastIP",
+ "devName",
+ "devSourcePlugin"
+ ],
+ "localized": ["name", "description"],
+ "name": [
+ {
+ "language_code": "en_us",
+ "string": "Set empty columns"
+ }
+ ],
+ "description": [
+ {
+ "language_code": "en_us",
+ "string": "These columns are only overwritten if they are empty (NULL / empty string) or if their Source is set to NEWDEV"
+ }
+ ]
+ },
+ {
+ "function": "WATCH",
+ "type": {
+ "dataType": "array",
+ "elements": [
+ {
+ "elementType": "select",
+ "elementOptions": [{ "multiple": "true", "orderable": "true"}],
+ "transformers": []
+ }
+ ]
+ },
+ "default_value": ["watchedValue1", "watchedValue4"],
+ "options": [
+ "watchedValue1",
+ "watchedValue2",
+ "watchedValue4"
+ ],
+ "localized": ["name", "description"],
+ "name": [
+ {
+ "language_code": "en_us",
+ "string": "Watched"
+ }
+ ],
+ "description": [
+ {
+ "language_code": "en_us",
+ "string": "Send a notification if selected values change. Use CTRL + Click to select/deselect. watchedValue1 is Active watchedValue2 is Hostname watchedValue4 is Statenew means a new unique (unique combination of PrimaryId and SecondaryId) object was discovered. watched-changed means that selected watchedValueN columns changed."
+ }
+ ]
+ }
+ ]
+}
\ No newline at end of file
diff --git a/front/plugins/kea_api/script.py b/front/plugins/kea_api/script.py
new file mode 100644
index 00000000..9dc72d8c
--- /dev/null
+++ b/front/plugins/kea_api/script.py
@@ -0,0 +1,75 @@
+#!/usr/bin/env python3
+import os
+import sys
+import requests
+
+sys.path.insert(0, os.path.join(os.path.dirname(__file__), '../../server'))
+sys.path.insert(0, os.path.join(os.path.dirname(__file__), '../plugins'))
+
+from plugin_helper import Plugin_Objects, mylog, handleEmpty, is_mac
+from helper import get_setting_value
+from const import logPath
+
+pluginName = 'KEALSS'
+LOG_PATH = logPath + '/plugins'
+LOG_FILE = os.path.join(LOG_PATH, f'script.{pluginName}.log')
+RESULT_FILE = os.path.join(LOG_PATH, f'last_result.{pluginName}.log')
+
+plugin_objects = Plugin_Objects(RESULT_FILE)
+
+
+def main():
+ try:
+ url = get_setting_value(f'{pluginName}_URL')
+ user = get_setting_value(f'{pluginName}_USER')
+ password = get_setting_value(f'{pluginName}_PASS')
+ timeout = get_setting_value(f'{pluginName}_RUN_TIMEOUT')
+
+ mylog('verbose', [f'[{pluginName}] Querying Kea API at {url}'])
+
+ payload = {'command': 'lease4-get-all', 'service': ['dhcp4']}
+
+ response = requests.post(url, json=payload, auth=(user, password), timeout=max(1, timeout - 1))
+ response.raise_for_status()
+ data = response.json()
+
+ count = 0
+ for entry in data:
+ text = entry.get('text', '[API provided no text]')
+ # Result: 0 (success), 1 (error), or 3 (empty).
+ if entry['result'] == 0:
+ leases = entry['arguments']['leases']
+ for lease in leases:
+ mac = lease['hw-address']
+ state = lease['state']
+ if is_mac(mac):
+ plugin_objects.add_object(
+ primaryId = mac,
+ secondaryId = lease['ip-address'],
+ # Active or not, similar to watched1 of DHCPLSS plugin
+ watched1 = state == 0,
+ watched2 = lease['hostname'],
+ watched3 = None,
+ # Default (or assigned) (0), declined (1), expired-reclaimed (2), released (3), and registered (4)).
+ watched4 = state,
+ extra = None,
+ foreignKey = mac
+ )
+ count += 1
+ plugin_objects.write_result_file()
+
+ mylog('verbose', [f'[{pluginName}] Kea API response: {text}'])
+ mylog('verbose', [f'[{pluginName}] Successfully imported {count} devices reported by Kea API'])
+ elif entry['result'] == 1:
+ mylog('none', [f'[{pluginName}] ⚠ ERROR: Kea API indicated error: {text}'])
+ elif entry['result'] == 3:
+ mylog('verbose', [f'[{pluginName}] Kea API indicates no entries found: {text}'])
+
+
+ except Exception as e:
+ mylog('none', [f'[{pluginName}] ⚠ ERROR: {str(e)}'])
+
+
+
+if __name__ == '__main__':
+ main()
diff --git a/front/plugins/sync/config.json b/front/plugins/sync/config.json
index 7179071b..e364c339 100755
--- a/front/plugins/sync/config.json
+++ b/front/plugins/sync/config.json
@@ -613,7 +613,8 @@
"options": [
"devMac",
"devName",
- "devVendor"
+ "devVendor",
+ "devLastIP"
],
"localized": ["name", "description"],
"name": [
@@ -810,7 +811,7 @@
"column": "Dummy",
"mapped_to_column": "scanSourcePlugin",
"mapped_to_column_data": {
- "value": "sync"
+ "value": "SYNC"
},
"css_classes": "col-sm-2",
"show": false,
diff --git a/server/api_server/api_server_start.py b/server/api_server/api_server_start.py
index 484e19f0..f1342397 100755
--- a/server/api_server/api_server_start.py
+++ b/server/api_server/api_server_start.py
@@ -185,9 +185,6 @@ def is_authorized():
return is_authorized_result
-
-
-
@app.route('/mcp/sse', methods=['GET', 'POST', 'OPTIONS'])
def api_mcp_sse():
if not is_authorized():
diff --git a/server/api_server/sync_endpoint.py b/server/api_server/sync_endpoint.py
index 23529161..51d1704b 100755
--- a/server/api_server/sync_endpoint.py
+++ b/server/api_server/sync_endpoint.py
@@ -1,13 +1,15 @@
import os
import base64
from flask import jsonify, request
-from logger import mylog
+from logger import mylog, Logger
from helper import get_setting_value
from utils.datetime_utils import timeNowUTC
from messaging.in_app import write_notification
INSTALL_PATH = os.getenv("NETALERTX_APP", "/app")
+# Make sure log level is initialized correctly
+lggr = Logger(get_setting_value('LOG_LEVEL'))
def handle_sync_get():
"""Handle GET requests for SYNC (NODE → HUB)."""
@@ -28,7 +30,11 @@ def handle_sync_get():
response_data = base64.b64encode(raw_data).decode("utf-8")
- write_notification("[Plugin: SYNC] Data sent", "info", timeNowUTC())
+ message = "[Plugin: SYNC] Data sent"
+ mylog('verbose', [message])
+ if lggr.isAbove('verbose'):
+ write_notification(message, 'info', timeNowUTC())
+
return jsonify({
"node_name": get_setting_value("SYNC_node_name"),
"status": 200,
diff --git a/server/initialise.py b/server/initialise.py
index 9509b06b..bf53c494 100755
--- a/server/initialise.py
+++ b/server/initialise.py
@@ -488,7 +488,7 @@ def importConfigs(pm, db, all_plugins):
# Plugins START
# -----------------
- # necessary_plugins = ['UI', 'CUSTPROP', 'CLOUD' ,'DBCLNP', 'INTRNT','MAINT','NEWDEV', 'SETPWD', 'SYNC', 'VNDRPDT', 'WORKFLOWS']
+ # necessary_plugins = ['UI', 'CUSTPROP', 'HEARTBEAT' ,'DBCLNP', 'INTRNT','MAINT','NEWDEV', 'SETPWD', 'SYNC', 'VNDRPDT', 'WORKFLOWS']
necessary_plugins = [
"UI",
"CUSTPROP",
diff --git a/server/messaging/reporting.py b/server/messaging/reporting.py
index dfe9f087..52cbf475 100755
--- a/server/messaging/reporting.py
+++ b/server/messaging/reporting.py
@@ -35,11 +35,10 @@ from messaging.notification_sections import ( # noqa: E402 [flake8 lint suppres
)
import conf # noqa: E402 [flake8 lint suppression]
+
# ===============================================================================
# Timezone conversion
# ===============================================================================
-
-
def get_datetime_fields_from_columns(column_names):
return [
col for col in column_names
@@ -81,6 +80,7 @@ def apply_timezone(data, fields):
for field in fields:
value = row.get(field)
+
if not value:
continue
@@ -226,11 +226,24 @@ def get_notifications(db):
try:
json_obj = db.get_table_as_json(sqlQuery, parameters)
+ data = apply_timezone_to_json(json_obj, section)
except Exception as e:
- mylog("minimal", [f"[Notification] DB error in section {section}: ", e])
+ mylog("none", [f"[Notification] apply_timezone failed for section {section}: ", e])
+
+ # fallback: preserve raw DB payload instead of dropping section
+ try:
+ data = json_obj.json.get("data", [])
+ except Exception:
+ data = []
+
+ final_json[section] = data
+ final_json[f"{section}_meta"] = {
+ "title": SECTION_TITLES.get(section, section),
+ "columnNames": getattr(json_obj, "columnNames", [])
+ }
continue
- final_json[section] = json_obj.json.get("data", [])
+ final_json[section] = data
final_json[f"{section}_meta"] = {
"title": SECTION_TITLES.get(section, section),
"columnNames": getattr(json_obj, "columnNames", [])
diff --git a/server/utils/datetime_utils.py b/server/utils/datetime_utils.py
index df125b39..4366e7c0 100644
--- a/server/utils/datetime_utils.py
+++ b/server/utils/datetime_utils.py
@@ -206,17 +206,18 @@ def format_date_iso(date_val: str) -> Optional[str]:
else:
dt = date_val
- # 2. If it has no timezone, assume it's UTC (our DB storage format)
- # then CONVERT to user's configured timezone
+ # 2. Normalize to UTC first, then convert to target timezone
if dt.tzinfo is None:
- # Mark as UTC first — critical: localize() would label without converting
dt = dt.replace(tzinfo=datetime.UTC)
- # Resolve target timezone; fall back to UTC if conf.tz is missing/invalid
- try:
- target_tz = conf.tz if isinstance(conf.tz, datetime.tzinfo) else ZoneInfo(conf.tz)
- except (ZoneInfoNotFoundError, ValueError, TypeError):
- target_tz = datetime.UTC
- dt = dt.astimezone(target_tz)
+ else:
+ dt = dt.astimezone(datetime.UTC)
+
+ try:
+ target_tz = conf.tz if isinstance(conf.tz, datetime.tzinfo) else ZoneInfo(str(conf.tz))
+ except Exception:
+ target_tz = datetime.UTC
+
+ dt = dt.astimezone(target_tz)
# 3. Return the string. .isoformat() will now include the +11:00 or +10:00
return dt.isoformat()