<?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);

    $apiRoot = getenv('NETALERTX_API') ?: '/tmp/api';
    $file_path = rtrim($apiRoot, '/') . '/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'] ?? '';
    $file_path = $_POST['file_path'] ?? '';
    $node_name = $_POST['node_name'] ?? '';
    $plugin = $_POST['plugin'] ?? '';

    $logRoot = getenv('NETALERTX_PLUGINS_LOG') ?: (rtrim(getenv('NETALERTX_LOG') ?: '/tmp/log', '/') . '/plugins');
    $storage_path = rtrim($logRoot, '/');

    // // check location
    // 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.{$plugin}.encoded.{$node_name}.*.log");
    $decoded_files = glob("{$storage_path}/last_result.{$plugin}.decoded.{$node_name}.*.log");

    $files = array_merge($encoded_files, $decoded_files);
    $file_count = count($files) + 1;

    $file_path_new = "{$storage_path}/last_result.{$plugin}.encoded.{$node_name}.{$file_count}.log";

    // Save the decoded data to the file
    file_put_contents($file_path_new, $data);
    http_response_code(200);
    echo 'Data received and stored successfully';
    write_notification("[Plugin: SYNC] Data received ({$file_path_new})", "info");

} else {
    http_response_code(405);
    echo 'Method Not Allowed';
    write_notification("[Plugin: SYNC] Method Not Allowed", "alert");
}
?>