nexus/ProxMenux
2
0
Fork 0
mirror of https://github.com/MacRimi/ProxMenux.git synced 2026-04-18 18:12:15 +00:00
Code Issues Packages Projects Releases Wiki Activity

update health_persistence.py

Browse Source
This commit is contained in:
MacRimi
2026-04-01 13:01:48 +02:00
parent 618538a854
commit 46e0322e6f
2 changed files with 45 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
AppImage/scripts/ai_context_enrichment.py
View File

@@ -304,10 +304,23 @@ def enrich_context_for_ai(
context_parts = [] context_parts = []
combined_text = f"{title} {body} {journal_context}" combined_text = f"{title} {body} {journal_context}"
# 1. System uptime (always useful) # 1. System uptime - only relevant for errors, not informational notifications
uptime = get_system_uptime() # Uptime helps distinguish startup issues from runtime failures
if uptime and uptime != "unknown": uptime_relevant_types = [
context_parts.append(f"System uptime: {uptime}") 'error', 'critical', 'warning', 'service', 'system',
'disk', 'smart', 'storage', 'io_error', 'network',
'cluster', 'ha', 'vm', 'ct', 'container', 'backup'
]
# Exclude purely informational events
informational_types = ['update', 'upgrade', 'available', 'info', 'resolved']
is_uptime_relevant = any(t in event_type.lower() for t in uptime_relevant_types)
is_informational = any(t in event_type.lower() for t in informational_types)
if is_uptime_relevant and not is_informational:
uptime = get_system_uptime()
if uptime and uptime != "unknown":
context_parts.append(f"System uptime: {uptime}")
# 2. Event frequency # 2. Event frequency
error_key = data.get('error_key') or data.get('error_id') error_key = data.get('error_key') or data.get('error_id')

31
AppImage/scripts/health_persistence.py
View File

@@ -1820,6 +1820,19 @@ class HealthPersistence:
'WHERE id = ?', 'WHERE id = ?',
(device_name, model, size_bytes, now, old_id)) (device_name, model, size_bytes, now, old_id))
# If no serial provided, check if a record WITH serial already exists for this device
# This prevents creating duplicate entries (one with serial, one without)
effective_serial = serial or ''
if not serial:
cursor.execute('''
SELECT serial FROM disk_registry
WHERE device_name = ? AND serial != ''
ORDER BY last_seen DESC LIMIT 1
''', (device_name,))
existing = cursor.fetchone()
if existing and existing[0]:
effective_serial = existing[0] # Use the existing serial
cursor.execute(''' cursor.execute('''
INSERT INTO disk_registry (device_name, serial, model, size_bytes, first_seen, last_seen, removed) INSERT INTO disk_registry (device_name, serial, model, size_bytes, first_seen, last_seen, removed)
VALUES (?, ?, ?, ?, ?, ?, 0) VALUES (?, ?, ?, ?, ?, ?, 0)
@@ -1828,7 +1841,7 @@ class HealthPersistence:
size_bytes = COALESCE(excluded.size_bytes, size_bytes), size_bytes = COALESCE(excluded.size_bytes, size_bytes),
last_seen = excluded.last_seen, last_seen = excluded.last_seen,
removed = 0 removed = 0
''', (device_name, serial or '', model, size_bytes, now, now)) ''', (device_name, effective_serial, model, size_bytes, now, now))
conn.commit() conn.commit()
conn.close() conn.close()
@@ -1847,6 +1860,8 @@ class HealthPersistence:
linked observations, which helps with USB disks that may have linked observations, which helps with USB disks that may have
multiple registry entries (one with serial, one without). multiple registry entries (one with serial, one without).
""" """
clean_dev = device_name.replace('/dev/', '')
if serial: if serial:
cursor.execute( cursor.execute(
'SELECT id FROM disk_registry WHERE serial = ? AND serial != "" ORDER BY last_seen DESC LIMIT 1', 'SELECT id FROM disk_registry WHERE serial = ? AND serial != "" ORDER BY last_seen DESC LIMIT 1',
@@ -1854,9 +1869,19 @@ class HealthPersistence:
row = cursor.fetchone() row = cursor.fetchone()
if row: if row:
return row[0] return row[0]
else:
# No serial provided - first check if a record WITH serial exists for this device
# This prevents returning a duplicate record without serial
cursor.execute('''
SELECT id FROM disk_registry
WHERE device_name = ? AND serial != ''
ORDER BY last_seen DESC LIMIT 1
''', (clean_dev,))
row = cursor.fetchone()
if row:
return row[0]
# Fallback: match by device_name (strip /dev/ prefix) # Fallback: match by device_name
clean_dev = device_name.replace('/dev/', '')
if prefer_with_observations: if prefer_with_observations:
# First try to find a registry entry that has observations linked # First try to find a registry entry that has observations linked