mirror of
https://github.com/jokob-sk/NetAlertX.git
synced 2025-12-07 09:36:05 -08:00
109 lines
3.9 KiB
Python
Executable File
109 lines
3.9 KiB
Python
Executable File
#!/usr/bin/env python
|
|
|
|
import os
|
|
import pathlib
|
|
import sys
|
|
import hashlib
|
|
import requests
|
|
|
|
|
|
# Define the installation path and extend the system path for plugin imports
|
|
INSTALL_PATH = "/app"
|
|
sys.path.extend([f"{INSTALL_PATH}/front/plugins", f"{INSTALL_PATH}/server"])
|
|
|
|
from plugin_helper import Plugin_Object, Plugin_Objects, decodeBase64
|
|
from plugin_utils import get_plugins_configs
|
|
from logger import mylog
|
|
from helper import timeNowTZ, get_setting_value, encrypt_data
|
|
|
|
# Define the current path and log file paths
|
|
CUR_PATH = str(pathlib.Path(__file__).parent.resolve())
|
|
LOG_FILE = os.path.join(CUR_PATH, 'script.log')
|
|
RESULT_FILE = os.path.join(CUR_PATH, 'last_result.log')
|
|
|
|
pluginName = 'SYNC'
|
|
|
|
def main():
|
|
mylog('verbose', [f'[{pluginName}] In script'])
|
|
|
|
|
|
# Initialize the Plugin obj output file
|
|
plugin_objects = Plugin_Objects(RESULT_FILE)
|
|
|
|
# Retrieve configuration settings
|
|
plugins_to_sync = get_setting_value('SYNC_plugins')
|
|
api_token = get_setting_value('SYNC_api_token')
|
|
encryption_key = get_setting_value('SYNC_encryption_key')
|
|
hub_url = get_setting_value('SYNC_hub_url')
|
|
node_name = get_setting_value('SYNC_node_name')
|
|
|
|
# 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}'])
|
|
|
|
index = 0
|
|
for plugin in all_plugins:
|
|
pref = plugin["unique_prefix"]
|
|
|
|
if pref in plugins_to_sync:
|
|
index += 1
|
|
mylog('verbose', [f'[{pluginName}] synching "{pref}" ({index}/{len(plugins_to_sync)})'])
|
|
|
|
# Construct the file path for the plugin's last_result.log file
|
|
plugin_folder = plugin["code_name"]
|
|
file_path = f"{INSTALL_PATH}/front/plugins/{plugin_folder}/last_result.log"
|
|
|
|
if os.path.exists(file_path):
|
|
# Read the content of the log file
|
|
with open(file_path, 'r') as f:
|
|
file_content = f.read()
|
|
|
|
mylog('verbose', [f'[{pluginName}] Sending file_content: "{file_content}"'])
|
|
|
|
# Encrypt the log data using the encryption_key
|
|
encrypted_data = encrypt_data(file_content, encryption_key)
|
|
|
|
mylog('verbose', [f'[{pluginName}] Sending encrypted_data: "{encrypted_data}"'])
|
|
|
|
# Prepare the data payload for the POST request
|
|
data = {
|
|
'data': encrypted_data,
|
|
'plugin_folder': plugin_folder,
|
|
'node_name': node_name
|
|
}
|
|
|
|
# Set the authorization header with the API token
|
|
headers = {'Authorization': f'Bearer {api_token}'}
|
|
api_endpoint = f"{hub_url}/plugins/sync/hub.php"
|
|
response = requests.post(api_endpoint, data=data, headers=headers)
|
|
|
|
mylog('verbose', [f'[{pluginName}] response: "{response}"'])
|
|
|
|
if response.status_code == 200:
|
|
mylog('verbose', [f'[{pluginName}] Data for "{plugin_folder}" sent successfully'])
|
|
else:
|
|
mylog('verbose', [f'[{pluginName}] Failed to send data for "{plugin_folder}"'])
|
|
|
|
# log result
|
|
plugin_objects.add_object(
|
|
primaryId = pref,
|
|
secondaryId = timeNowTZ(),
|
|
watched1 = node_name,
|
|
watched2 = response.status_code,
|
|
watched3 = response,
|
|
watched4 = '',
|
|
extra = '',
|
|
foreignKey = '')
|
|
else:
|
|
mylog('verbose', [f'[{pluginName}] {plugin_folder}/last_result.log not found'])
|
|
|
|
# log result
|
|
plugin_objects.write_result_file()
|
|
|
|
return 0
|
|
|
|
if __name__ == '__main__':
|
|
main()
|