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 3 Packages Projects Releases Wiki Activity

🔃 Sync Hub v0.7 - Devices working

Browse Source
This commit is contained in:
jokob-sk
2024-06-07 21:23:49 +10:00
parent d63e0d9fd2
commit 26e4249f5c
3 changed files with 12 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
front/plugins/sync/config.json
View File

@@ -514,7 +514,7 @@
"name" : "SYNC_instance_type",
"value": "hub"
},
"default_value":"0 2 * * 3",
"default_value":"*/5 * * * *",
"options": [],
"localized": ["name", "description"],
"name" : [{

15
front/plugins/sync/sync.py
View File

@@ -44,7 +44,6 @@ def main():
# Get all plugin configurations
all_plugins = get_plugins_configs()
mylog('verbose', [f'[{pluginName}] DEBUG {len(all_plugins)}'])
mylog('verbose', [f'[{pluginName}] plugins_to_sync {plugins_to_sync}'])
# Plugins processing
@@ -104,6 +103,8 @@ def main():
unique_mac_addresses = set()
device_data = []
mylog('verbose', [f'[{pluginName}] Devices files to process: "{files_to_process}"'])
for file_path in files_to_process:
# only process received .log files, skipping the one logging the progress of this plugin
@@ -112,8 +113,8 @@ def main():
# Store e.g. Node_1 from last_result.encoded.Node_1.1.log
tmp_SyncHubNodeName = ''
if len(filename.split('.')) > 3:
tmp_SyncHubNodeName = filename.split('.')[2]
if len(file_path.split('.')) > 3:
tmp_SyncHubNodeName = file_path.split('.')[2]
with open(file_path, 'r') as f:
data = json.load(f)
@@ -131,10 +132,14 @@ def main():
# Filter out existing devices
new_devices = [device for device in device_data if device['dev_MAC'] not in existing_mac_addresses]
# Remove 'rowid' key if it exists
for device in new_devices:
device.pop('rowid', None)
# Prepare the insert statement
if new_devices:
columns = ', '.join(new_devices[0].keys())
placeholders = ', '.join('?' for _ in new_devices[0])
columns = ', '.join(k for k in new_devices[0].keys() if k != 'rowid')
placeholders = ', '.join('?' for k in new_devices[0] if k != 'rowid')
sql = f'INSERT INTO Devices ({columns}) VALUES ({placeholders})'
# Extract values for the new devices