portal/app/tests/Feature/ClientTg/PollModerationTest.php

<?php

declare(strict_types=1);

use App\Jobs\ClientTg\PollTelegramModerationJob;
use App\Models\BalanceTransaction;
use App\Models\ClientTg\Campaign;
use App\Models\Tenant;
use App\Services\ClientTg\RobotResult;
use App\Services\ClientTg\TelegramCampaignChargeService;
use App\Services\ClientTg\TelegramRobotRunner;
use App\Services\NotificationService;
use Illuminate\Foundation\Testing\RefreshDatabase;
use Illuminate\Support\Facades\DB;
use Mockery\MockInterface;
use Tests\Concerns\SharesSupplierPdo;

// Опросчик перечисляет moderating-кампании через pgsql_supplier (BYPASSRLS).
// Шарим PDO, иначе данные транзакции RefreshDatabase не видны supplier-соединению.
uses(RefreshDatabase::class, SharesSupplierPdo::class);

/**
 * Задача 3.4 — PollTelegramModerationJob: опросчик вердикта модерации МТС.
 *
 * Живая отправка робота ставит `moderating` (задача 3.2). Опросчик раз в цикл
 * читает кабинет роботом-читалкой (в тестах — мок) по `mts_campaign_id` и применяет
 * вердикт:
 *   — `rejected` → статус `rejected` + причина; ВОЗВРАТ списанной сметы на ОБЩИЙ
 *     баланс тенанта (в бою); уведомление «отклонена»;
 *   — `approved` → `launched`; деньги НЕ трогаем (смету списали при запуске);
 *     уведомление «одобрена»;
 *   — `moderating` (ещё не проверено) / робот не смог прочитать → НЕ трогаем, ждём
 *     следующего цикла (деньги/статус без изменений).
 *
 * Денежная модель — списание/возврат с ОБЩЕГО баланса (`tenants.balance_rub`) через
 * TelegramCampaignChargeService; отдельного рекламного кошелька с заморозкой больше нет.
 */

/** Кампания в заданном статусе (self-contained), смета ненулевая. */
function pollCampaign(int $tenantId, string $status, ?string $mtsId = null, string $estimatedCost = '315.00'): Campaign
{
    return Campaign::query()->create([
        'tenant_id' => $tenantId,
        'status' => $status,
        'mts_campaign_id' => $mtsId,
        'ad_text' => 'Опрос-тест',
        'ord_category' => 'Размещение рекламы',
        'budget_cap_rub' => '1000.00',
        'audience_kind' => Campaign::AUDIENCE_LIST,
        'planned_count' => 0,
        'estimated_cost_rub' => $estimatedCost,
        'created_by' => 1,
    ]);
}

/** «Уже списано при запуске»: списывает смету кампании с общего баланса тенанта. */
function pollChargeCampaign(Tenant $tenant, Campaign $campaign): void
{
    DB::statement('SET LOCAL app.current_tenant_id = '.$tenant->id);
    app(TelegramCampaignChargeService::class)->charge($campaign, (string) $campaign->estimated_cost_rub);
}

/** Подменяет робота-читалку мок-результатом. */
function pollMockRobot(RobotResult $result): void
{
    $mock = Mockery::mock(TelegramRobotRunner::class);
    $mock->shouldReceive('readModeration')->andReturn($result);
    app()->instance(TelegramRobotRunner::class, $mock);
}

/** Мок NotificationService для проверки, какое уведомление ушло. */
function pollMockNotifications(): MockInterface
{
    $mock = Mockery::mock(NotificationService::class);
    app()->instance(NotificationService::class, $mock);

    return $mock;
}

it('RobotResult знает moderationStatus и разбирает его из JSON робота', function () {
    $r = RobotResult::fromRobotJson(['ok' => true, 'moderationStatus' => 'rejected', 'reason' => 'нельзя']);
    expect($r->moderationStatus)->toBe('rejected')
        ->and($r->reason)->toBe('нельзя');

    // Отсутствие поля → null (робот его пока не прислал).
    expect(RobotResult::fromRobotJson(['ok' => true])->moderationStatus)->toBeNull();
});

it('вердикт «отклонена» → rejected + причина, смета возвращена на общий баланс, уведомление «отклонена»', function () {
    config()->set('client_tg.sandbox', false);
    $t = Tenant::factory()->create(['balance_rub' => '5000.00']);
    $c = pollCampaign($t->id, Campaign::STATUS_MODERATING, '2231134', '315.00');

    // Уже списано при запуске кампании → баланс просел.
    pollChargeCampaign($t, $c);
    expect((string) $t->fresh()->balance_rub)->toBe('4685.00');

    pollMockRobot(new RobotResult(ok: true, moderationStatus: 'rejected', reason: 'Ссылка недоступна'));
    $notify = pollMockNotifications();
    $notify->shouldReceive('notifyTelegramCampaignRejected')->once();
    $notify->shouldReceive('notifyTelegramCampaignApproved')->never();

    PollTelegramModerationJob::dispatchSync();

    $fresh = Campaign::find($c->id);
    expect($fresh->status)->toBe(Campaign::STATUS_REJECTED)
        ->and($fresh->status_reason)->toBe('Ссылка недоступна')
        // Отказ вернул смету на общий баланс — восстановлен до фондирования.
        ->and((string) $t->fresh()->balance_rub)->toBe('5000.00')
        ->and(BalanceTransaction::where('type', BalanceTransaction::TYPE_TG_AD_REFUND)
            ->where('related_type', Campaign::class)
            ->where('related_id', $c->id)->count())->toBe(1);
});

it('вердикт «одобрена» → launched, уведомление «одобрена», деньги не тронуты', function () {
    config()->set('client_tg.sandbox', false);
    $t = Tenant::factory()->create(['balance_rub' => '5000.00']);
    $c = pollCampaign($t->id, Campaign::STATUS_MODERATING, '2231140', '315.00');

    // Списано при запуске; одобрение денег НЕ трогает.
    pollChargeCampaign($t, $c);

    pollMockRobot(new RobotResult(ok: true, moderationStatus: 'approved'));
    $notify = pollMockNotifications();
    $notify->shouldReceive('notifyTelegramCampaignApproved')->once();
    $notify->shouldReceive('notifyTelegramCampaignRejected')->never();

    PollTelegramModerationJob::dispatchSync();

    expect(Campaign::find($c->id)->status)->toBe(Campaign::STATUS_LAUNCHED)
        // Списание осталось — approve ничего не возвращает.
        ->and((string) $t->fresh()->balance_rub)->toBe('4685.00')
        ->and(BalanceTransaction::where('type', BalanceTransaction::TYPE_TG_AD_REFUND)
            ->where('related_type', Campaign::class)
            ->where('related_id', $c->id)->count())->toBe(0);
});

it('вердикт «ещё на модерации» → остаётся moderating, без уведомлений и без денег', function () {
    config()->set('client_tg.sandbox', false);
    $t = Tenant::factory()->create(['balance_rub' => '5000.00']);
    $c = pollCampaign($t->id, Campaign::STATUS_MODERATING, '2231150', '315.00');

    pollChargeCampaign($t, $c);

    pollMockRobot(new RobotResult(ok: true, moderationStatus: 'moderating'));
    $notify = pollMockNotifications();
    $notify->shouldReceive('notifyTelegramCampaignRejected')->never();
    $notify->shouldReceive('notifyTelegramCampaignApproved')->never();

    PollTelegramModerationJob::dispatchSync();

    expect(Campaign::find($c->id)->status)->toBe(Campaign::STATUS_MODERATING)
        // Ни списания, ни возврата — баланс остался на уровне после запуска.
        ->and((string) $t->fresh()->balance_rub)->toBe('4685.00')
        ->and(BalanceTransaction::where('type', BalanceTransaction::TYPE_TG_AD_REFUND)
            ->where('related_id', $c->id)->count())->toBe(0);
});

it('робот не смог прочитать вердикт (moderationStatus=null) → moderating без изменений', function () {
    config()->set('client_tg.sandbox', false);
    $t = Tenant::factory()->create();
    $c = pollCampaign($t->id, Campaign::STATUS_MODERATING, '2231160');

    pollMockRobot(new RobotResult(ok: false, reason: 'кабинет не открылся'));
    $notify = pollMockNotifications();
    $notify->shouldReceive('notifyTelegramCampaignRejected')->never();
    $notify->shouldReceive('notifyTelegramCampaignApproved')->never();

    PollTelegramModerationJob::dispatchSync();

    expect(Campaign::find($c->id)->status)->toBe(Campaign::STATUS_MODERATING);
});

it('moderating без mts_campaign_id не опрашивается (робот не зовётся)', function () {
    config()->set('client_tg.sandbox', false);
    $t = Tenant::factory()->create();
    $c = pollCampaign($t->id, Campaign::STATUS_MODERATING, null);

    // Робот-мок вернул бы approved, но кампанию без id опросчик даже не берёт.
    pollMockRobot(new RobotResult(ok: true, moderationStatus: 'approved'));
    $notify = pollMockNotifications();
    $notify->shouldReceive('notifyTelegramCampaignApproved')->never();

    PollTelegramModerationJob::dispatchSync();

    expect(Campaign::find($c->id)->status)->toBe(Campaign::STATUS_MODERATING);
});