<?php
require_once __DIR__ . '/../db/config.php';

if (isset($_GET['lead_id'])) {
    $lead_id = $_GET['lead_id'];

    try {
        $pdo = db();
        $stmt = $pdo->prepare("SELECT * FROM messages WHERE lead_id = ? ORDER BY created_at ASC");
        $stmt->execute([$lead_id]);
        $messages = $stmt->fetchAll();

        echo json_encode($messages);
    } catch (PDOException $e) {
        http_response_code(500);
        echo json_encode(['success' => false, 'message' => 'Database error: ' . $e->getMessage()]);
    }
} else {
    http_response_code(400);
    echo json_encode(['success' => false, 'message' => 'Invalid input']);
}