<?php
/**
 * DELHI SIDE SYSTEM REAL-TIME AUTOMATED INTEGRATION CLIENT
 * Custom Sync engine mapped directly to u766718295_sattaapi schema structure
 */

error_reporting(E_ALL);
ini_set('display_errors', 1);
date_default_timezone_set('Asia/Kolkata');

// 1. CONFIGURATION LAYERS
$db_host = "localhost";
$db_user = "YOUR_DB_USER"; 
$db_pass = "YOUR_DB_PASSWORD"; 
$db_name = "YOUR_DB_NAME"; // Reference from schema image

$api_url = "https://satta-live-result-fast.com/api/delhi-side.php?token=LIVE_SECRET_KEY";

// 2. CONNECT TO SERVER INSTANCE
$conn = new mysqli($db_host, $db_user, $db_pass, $db_name);
if ($conn->connect_error) {
    die(json_encode(["success" => false, "msg" => "Database connection error"]));
}
$conn->set_charset("utf8mb4");

// 3. SECURELY STREAM REFRESH DATA FROM REMOTE DADA API SERVER
$response = file_get_contents($api_url);
if (!$response) {
    die(json_encode(["success" => false, "msg" => "API Gateway connection timeout."]));
}

$payload = json_decode($response, true);
if (!isset($payload['status']) || $payload['status'] !== true) {
    die(json_encode(["success" => false, "msg" => "Invalid Payload authentication verified failed."]));
}

// 4. PARSE DATASET AND INJECT TO LOCAL SATTA_NAME AND SATTA_NO RELATION TABLES
foreach ($payload['games'] as $game) {
    
    // Mapping properties for table: satta_name
    $satta_name_name  = $conn->real_escape_string($game['game_title']);
    $satta_name_sc    = $conn->real_escape_string($game['short_code']);
    $sc               = $conn->real_escape_string($game['sc_tag']);
    $user_id          = intval($game['user_id'] ?? 1);
    $chart            = $conn->real_escape_string($game['show_chart'] ?? 'Yes');
    $satta_name_time2 = $conn->real_escape_string($game['display_time']);
    $priority         = intval($game['sort_priority'] ?? 0);
    $color            = $conn->real_escape_string($game['color_code'] ?? '#ffffff');
    $main             = intval($game['is_main'] ?? 1);
    $start            = $conn->real_escape_string($game['start_time']);
    $stop             = $conn->real_escape_string($game['stop_time']);

    // Upsert row inside schema table: satta_name
    $query_game = "INSERT INTO satta_name (satta_name_name, satta_name_sc, sc, user_id, chart, satta_name_time2, priority, color, main, start, stop) 
                   VALUES ('$satta_name_name', '$satta_name_sc', '$sc', $user_id, '$chart', '$satta_name_time2', $priority, '$color', $main, '$start', '$stop')
                   ON DUPLICATE KEY UPDATE satta_name_sc='$satta_name_sc', sc='$sc', chart='$chart', satta_name_time2='$satta_name_time2', priority=$priority, start='$start', stop='$stop'";
    
    if ($conn->query($query_game)) {
        $satta_name_id = $conn->insert_id ?: $conn->query("SELECT satta_name_id FROM satta_name WHERE satta_name_name='$satta_name_name'")->fetch_object()->satta_name_id;
        
        // Mapping properties for historical & single records table: satta_no
        $satta_no_no    = $conn->real_escape_string($game['live_record']['current_number']); // Single/Double digit jodi number
        $satta_no_year  = intval(date('Y'));
        $satta_no_day   = intval(date('d'));
        $satta_no_date  = $conn->real_escape_string($game['live_record']['record_date']); 
        $satta_no_month = intval(date('m'));
        $created_at     = date('Y-m-d H:i:s');

        // Upsert record row inside schema table: satta_no
        $query_result = "INSERT INTO satta_no (satta_no_no, satta_no_year, satta_no_day, satta_no_date, satta_name_id, satta_no_month, user_id, created_at)
                         VALUES ('$satta_no_no', $satta_no_year, $satta_no_day, '$satta_no_date', $satta_name_id, $satta_no_month, $user_id, '$created_at')
                         ON DUPLICATE KEY UPDATE satta_no_no='$satta_no_no', created_at='$created_at'";
        $conn->query($query_result);
    }
}

echo json_encode(["status" => true, "message" => "Delhi Side Data Pipeline Execution Finished."]);
$conn->close();
?>