STHACK 2025 - DropValt Railway - Sabotage 1/2

<?php

require 'vendor/autoload.php'; // Charger Predis via Composer
use Predis\Client;

require 'db/db.php'; // Charger la configuration de la base de données

echo "Start trigger webhooks\n";

// Configuration de Redis
$redis = new Client([
    'scheme' => 'tcp',
    'host' => '127.0.0.1',
    'port' => 6379,
]);

// Nom de la liste Redis à surveiller
$redisList = 'station_events';

// Fonction pour envoyer plusieurs requêtes HTTP POST en parallèle
function triggerWebhooksAsync($webhooks, $payload) {
    $multiHandle = curl_multi_init();
    $handles = [];
    
    foreach ($webhooks as $webhook) {
        $ch = curl_init();
        curl_setopt_array($ch, [
            CURLOPT_URL => $webhook['url'],
            CURLOPT_POST => true,
            CURLOPT_POSTFIELDS => $payload, // Transmettre le payload comme corps de la requête
            CURLOPT_TIMEOUT => 1, // Timeout court
            CURLOPT_HTTPHEADER => [
                'Content-Type: application/json',
                'Accept: application/json',
            ],
            CURLOPT_RETURNTRANSFER => true, // Capturer la réponse
        ]);
        curl_multi_add_handle($multiHandle, $ch);
        $handles[$webhook['id']] = $ch;
    }

    // Exécuter toutes les requêtes en parallèle
    do {
        $status = curl_multi_exec($multiHandle, $active);
        curl_multi_select($multiHandle);
    } while ($active && $status == CURLM_OK);

    // Récupérer les réponses et les codes HTTP
    $results = [];
    foreach ($handles as $webhookId => $ch) {
        $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
        $response = curl_multi_getcontent($ch);
        $results[] = [
            'webhook_id' => $webhookId,
            'http_code' => $httpCode,
            'response' => $response,
        ];
        curl_multi_remove_handle($multiHandle, $ch);
        curl_close($ch);
    }
    
    curl_multi_close($multiHandle);
    return $results;
}

echo "Listening for new events in Redis list: $redisList...\n";

while (true) {
    try {
        // Attendre un nouvel événement dans la liste Redis
        $event = $redis->blpop($redisList, 0); // [list_name, event_data]
        
        if ($event) {
            $eventData = json_decode($event[1], true);
            
            if (!$eventData || !isset($eventData['type'], $eventData['timestamp'], $eventData['infos'])) {
                echo "Invalid event data: " . $event[1] . "\n";
                continue;
            }
            
            // Récupérer tous les webhooks
            $webhooks = $pdo->query("SELECT * FROM webhook")->fetchAll(PDO::FETCH_ASSOC);
            
            // Préparer le payload
            $payload = json_encode([
                'type' => $eventData['type'],
                'timestamp' => $eventData['timestamp'],
                'infos' => $eventData['infos'],
            ]);
            
            // Déclencher les webhooks de manière asynchrone
            echo "Triggering webhooks asynchronously...\n";
            $results = triggerWebhooksAsync($webhooks, $payload);
            
            // Enregistrer les tentatives dans la base de données
            foreach ($results as $result) {
                $stmt = $pdo->prepare("INSERT INTO webhook_attempt (webhook_id, at, url, body, status, response) VALUES (:webhook_id, :at, :url, :body, :status, :response)");
                $stmt->execute([
                    ':webhook_id' => $result['webhook_id'],
                    ':at' => date('Y-m-d H:i:s'),
                    ':url' => $webhooks[array_search($result['webhook_id'], array_column($webhooks, 'id'))]['url'],
                    ':body' => $payload,
                    ':status' => $result['http_code'],
                    ':response' => $result['response'],
                ]);
                
                if ($result['http_code'] >= 200 && $result['http_code'] < 300) {
                    echo "Webhook triggered successfully for ID {$result['webhook_id']}. Response: {$result['response']}\n";
                } else {
                    echo "Failed to trigger webhook for ID {$result['webhook_id']}. HTTP Code: {$result['http_code']}. Response: {$result['response']}\n";
                }
            }
        }
    } catch (Exception $e) {
        echo "An error occurred: " . $e->getMessage() . "\n";
    }
}