<?php
chdir(__DIR__);

require '../configs/configs.php';
require '../functions/methods.php';

$limit = 100;

$stmt = $pdo->prepare("SELECT * FROM send_all WHERE status = 0 LIMIT :limit");
$stmt->bindValue(":limit", $limit, PDO::PARAM_INT);
$stmt->execute();

if ($stmt->rowCount() == 0) {
    die("هیچ پیامی برای ارسال وجود ندارد.");
}

$updateStatus = $pdo->prepare("UPDATE send_all SET status = 1 WHERE id = :id");
$deleteStmt   = $pdo->prepare("DELETE FROM send_all WHERE id = :id");

while ($row = $stmt->fetch(PDO::FETCH_ASSOC)) {

    $user_id = $row['chat_id'];
    $text    = $row['text'];
    $id      = $row['id'];

    $response = sendMessage($user_id, $text);

    if ($response && isset($response->ok) && $response->ok == true) {
        $updateStatus->execute(["id" => $id]);
        $deleteStmt->execute(["id" => $id]);
        echo "✔ ارسال شد → {$user_id}\n";
    } else {
        echo "❌ ارسال ناموفق برای {$user_id}\n";
        var_dump($response);
        echo "\n-------------\n";
        $updateStatus->execute(["id" => $id]);
        $deleteStmt->execute(["id" => $id]);
    }
}

die;