<?php
chdir(__DIR__);

include '../config/config.php';
include '../database/connector.php';
include '../classes/telegram.php';

$bot = new TelegramBot($bot_token);

$limit = 100;
$forward_all = $db->prepare("SELECT * FROM `forward_all` WHERE `status` = 0 LIMIT :limit");
$forward_all->bindValue(':limit', $limit, PDO::PARAM_INT);
$forward_all->execute();

if ($forward_all->rowCount() == 0) {
    die("هیچ پیامی برای فوروارد وجود ندارد.");
}

$delete_stmt = $db->prepare("DELETE FROM `forward_all` WHERE `id` = :id");

$success_count = 0;
$fail_count = 0;

while ($row = $forward_all->fetch(PDO::FETCH_ASSOC)) {
    $from_id = $row['from_id'];
    $message_id = $row['message_id'];
    $user_id = $row['chat_id'];
    $id = $row['id'];

    $response = $bot->forwardMessage($user_id, $from_id, $message_id);

    if ($response->ok) {
        $success_count++;
    } else {
        $fail_count++;
    }

    $delete_stmt->execute(['id' => $id]);
}
die;