vh/NetAlertX
1
0
Fork 0
mirror of https://github.com/jokob-sk/NetAlertX.git synced 2025-12-07 09:36:05 -08:00
Code Issues Actions Packages Projects Releases Wiki Activity

chore: Try to reduce disk IO

Browse Source
This commit is contained in:
jokob-sk
2024-12-17 07:04:00 +11:00
parent c132374421
commit caf5a5347c
3 changed files with 34 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files

37
server/plugin.py
View File

@@ -861,26 +861,23 @@ def check_and_run_user_event(db, all_plugins, pluginsState):
event, param = "", ""
if len(columns) == 2:
event, param = columns
try:
# Process each event type
if event == 'test':
pluginsState = handle_test(param, db, all_plugins, pluginsState)
executed_events.append(f"test with param {param}")
execution_log.finalize_event("test")
elif event == 'run':
pluginsState = handle_run(param, db, all_plugins, pluginsState)
executed_events.append(f"run with param {param}")
execution_log.finalize_event("run")
elif event == 'update_api':
# async handling
update_api(db, all_plugins, False, param.split(','), True)
else:
mylog('minimal', ['[check_and_run_user_event] WARNING: Unhandled event in execution queue: ', event, ' | ', param])
execution_log.finalize_event(event) # Finalize unknown events to remove them
except Exception as e:
mylog('none', ['[check_and_run_user_event] ERROR: Error processing event "', event, '" with param "', param, '": ', str(e)])
# Process each event type
if event == 'test':
pluginsState = handle_test(param, db, all_plugins, pluginsState)
executed_events.append(f"test with param {param}")
execution_log.finalize_event("test")
elif event == 'run':
pluginsState = handle_run(param, db, all_plugins, pluginsState)
executed_events.append(f"run with param {param}")
execution_log.finalize_event("run")
elif event == 'update_api':
# async handling
update_api(db, all_plugins, False, param.split(','), True)
else:
mylog('minimal', ['[check_and_run_user_event] WARNING: Unhandled event in execution queue: ', event, ' | ', param])
execution_log.finalize_event(event) # Finalize unknown events to remove them
# Notify user about executed events (if applicable)
if len(executed_events) > 0 and executed_events: