mirror of
https://github.com/jokob-sk/NetAlertX.git
synced 2025-12-06 17:15:38 -08:00
101 lines
3.1 KiB
PHP
Executable File
101 lines
3.1 KiB
PHP
Executable File
<?php
|
|
|
|
// External files
|
|
require '/app/front/php/server/init.php';
|
|
|
|
$method = $_SERVER['REQUEST_METHOD'];
|
|
|
|
// ----------------------------------------------
|
|
// Method to check authorization
|
|
function checkAuthorization($method) {
|
|
// Retrieve the authorization header
|
|
$headers = apache_request_headers();
|
|
$auth_header = $headers['Authorization'] ?? '';
|
|
$expected_token = 'Bearer ' . getSettingValue('API_TOKEN');
|
|
|
|
// Verify the authorization token
|
|
if ($auth_header !== $expected_token) {
|
|
http_response_code(403);
|
|
echo 'Forbidden';
|
|
write_notification("[Plugin: SYNC] Incoming data: Incorrect API Token (".$method.")", "alert");
|
|
exit;
|
|
}
|
|
}
|
|
|
|
// ----------------------------------------------
|
|
// Function to return JSON response
|
|
function jsonResponse($status, $data = '', $message = '') {
|
|
http_response_code($status);
|
|
header('Content-Type: application/json');
|
|
echo json_encode([
|
|
'node_name' => getSettingValue('SYNC_node_name'),
|
|
'status' => $status,
|
|
'message' => $message,
|
|
'data_base64' => $data,
|
|
'timestamp' => date('Y-m-d H:i:s')
|
|
]);
|
|
}
|
|
|
|
// ----------------------------------------------
|
|
// MAIN
|
|
// ----------------------------------------------
|
|
|
|
|
|
// requesting data (this is a NODE)
|
|
if ($method === 'GET') {
|
|
checkAuthorization($method);
|
|
|
|
$file_path = "/app/api/table_devices.json";
|
|
|
|
$data = file_get_contents($file_path);
|
|
|
|
// Prepare the data to return as a JSON response
|
|
$response_data = base64_encode($data);
|
|
|
|
// Return JSON response
|
|
jsonResponse(200, $response_data, 'OK');
|
|
|
|
write_notification("[Plugin: SYNC] Data sent", "info");
|
|
|
|
}
|
|
// receiving data (this is a HUB)
|
|
else if ($method === 'POST') {
|
|
checkAuthorization($method);
|
|
|
|
// Retrieve and decode the data from the POST request
|
|
$data = $_POST['data'] ?? '';
|
|
$plugin_folder = $_POST['plugin_folder'] ?? '';
|
|
$node_name = $_POST['node_name'] ?? '';
|
|
|
|
$storage_path = "/app/front/plugins/{$plugin_folder}";
|
|
|
|
// Create the storage directory if it doesn't exist
|
|
if (!is_dir($storage_path)) {
|
|
echo "Could not open folder: {$storage_path}";
|
|
write_notification("[Plugin: SYNC] Could not open folder: {$storage_path}", "alert");
|
|
http_response_code(500);
|
|
exit;
|
|
}
|
|
|
|
// Generate a unique file path to avoid overwriting existing files
|
|
$encoded_files = glob("{$storage_path}/last_result.encoded.{$node_name}.*.log");
|
|
$decoded_files = glob("{$storage_path}/last_result.decoded.{$node_name}.*.log");
|
|
|
|
$files = array_merge($encoded_files, $decoded_files);
|
|
$file_count = count($files) + 1;
|
|
|
|
$file_path = "{$storage_path}/last_result.encoded.{$node_name}.{$file_count}.log";
|
|
|
|
// Save the decoded data to the file
|
|
file_put_contents($file_path, $data);
|
|
http_response_code(200);
|
|
echo 'Data received and stored successfully';
|
|
write_notification("[Plugin: SYNC] Data received ({$plugin_folder})", "info");
|
|
|
|
} else {
|
|
http_response_code(405);
|
|
echo 'Method Not Allowed';
|
|
write_notification("[Plugin: SYNC] Method Not Allowed", "alert");
|
|
}
|
|
?>
|