Дмитрий
b23d380d69
Сессия 2 плана docs/superpowers/plans/2026-07-27-client-telegram-ads-module.md.
Сердце модуля: по кампании запускаем браузер-робота кабинета МТС (у МТС нет API),
парсим его JSON и ведём статус-машину. В тестах робот замокан node-скриптами.
- Статус-машина Campaign: draft → queued → running → (draft_ready | launched |
failed | rejected); недопустимый переход — DomainException, статус не меняется
(глобальное исключение, а не доменный класс: deptrac Model: [], ADR-005).
Терминальные статусы без исходящих (resubmit — Сессия 5).
- TelegramRobotRunner: формирует task.json и запускает `node bin/run.js --task <file>`
через Symfony Process, разбирает {ok,matched,launched,campaignId}. Таймаут и
непарсабельный вывод → аккуратный RobotResult::failed, воркер не падает.
- RunTelegramCampaignJob: queued → running, собирает кандидатов, пишет временный
файл номеров (ПДн, чистится в finally), зовёт робота ВНЕ транзакции, итог пишет
под tenant-контекстом (SET LOCAL). ok+draft → draft_ready + matched; ошибка → failed
(причина в журнал — колонки нет, как у СМС-близнеца; показ клиенту — Сессия 5).
Идемпотентно: работает только со статусом queued. Денег в песочнице не трогает.
- Песочница config/client_tg.php + .env.example: TG_SANDBOX (по умолчанию ВКЛ) —
робот только draft, деньги/запуск выключены. Живой режим — осознанно в Сессии 6.
Реальная точка входа робота — bin/run.js --task (в плане текст «src/runner.js» —
вольная стенография). Живое списание отложено на Сессию 6: робот пока не возвращает
фактическую стоимость.
Проверки: 50 из 50 Pest зелёные (24 новых), phpstan 0 по своему коду, робот в тестах
замокан (кабинет МТС не тронут).
Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>
84 lines
3.0 KiB
PHP
84 lines
3.0 KiB
PHP
<?php
|
|
|
|
declare(strict_types=1);
|
|
|
|
use App\Models\ClientTg\Campaign;
|
|
use App\Models\Tenant;
|
|
use Illuminate\Foundation\Testing\RefreshDatabase;
|
|
|
|
uses(RefreshDatabase::class);
|
|
|
|
/**
|
|
* Статус-машина Telegram-кампании (план §Сессия 2, задача 2.1):
|
|
* draft → queued → running → (draft_ready | launched | failed | rejected)
|
|
* Недопустимый переход — исключение, статус не меняется.
|
|
*/
|
|
|
|
/** Создаёт кампанию в нужном статусе без фабрики (её у ClientTg нет — зеркало СМС). */
|
|
function tgCampaign(string $status): Campaign
|
|
{
|
|
$tenant = Tenant::factory()->create();
|
|
|
|
return Campaign::query()->create([
|
|
'tenant_id' => $tenant->id,
|
|
'status' => $status,
|
|
'ad_text' => 'Тест',
|
|
'ord_category' => 'Размещение рекламы',
|
|
'budget_cap_rub' => '1000.00',
|
|
'audience_kind' => Campaign::AUDIENCE_DEALS,
|
|
'planned_count' => 0,
|
|
'estimated_cost_rub' => '0.00',
|
|
'created_by' => 1,
|
|
]);
|
|
}
|
|
|
|
it('разрешает канонический путь draft → queued → running → draft_ready', function () {
|
|
$c = tgCampaign(Campaign::STATUS_DRAFT);
|
|
|
|
$c->transitionTo(Campaign::STATUS_QUEUED);
|
|
expect($c->status)->toBe(Campaign::STATUS_QUEUED);
|
|
|
|
$c->transitionTo(Campaign::STATUS_RUNNING);
|
|
expect($c->status)->toBe(Campaign::STATUS_RUNNING);
|
|
|
|
$c->transitionTo(Campaign::STATUS_DRAFT_READY);
|
|
expect($c->status)->toBe(Campaign::STATUS_DRAFT_READY);
|
|
|
|
// Переход персистится в БД, а не только в объекте.
|
|
expect(Campaign::find($c->id)->status)->toBe(Campaign::STATUS_DRAFT_READY);
|
|
});
|
|
|
|
it('из running допускает launched / failed / rejected', function (string $to) {
|
|
$c = tgCampaign(Campaign::STATUS_RUNNING);
|
|
$c->transitionTo($to);
|
|
expect($c->status)->toBe($to);
|
|
})->with([
|
|
Campaign::STATUS_LAUNCHED,
|
|
Campaign::STATUS_FAILED,
|
|
Campaign::STATUS_REJECTED,
|
|
]);
|
|
|
|
it('запрещает перескок draft → running (минуя queued) и не меняет статус', function () {
|
|
$c = tgCampaign(Campaign::STATUS_DRAFT);
|
|
|
|
expect(fn () => $c->transitionTo(Campaign::STATUS_RUNNING))
|
|
->toThrow(DomainException::class);
|
|
|
|
expect($c->status)->toBe(Campaign::STATUS_DRAFT);
|
|
expect(Campaign::find($c->id)->status)->toBe(Campaign::STATUS_DRAFT);
|
|
});
|
|
|
|
it('запрещает уход из терминального статуса', function () {
|
|
$c = tgCampaign(Campaign::STATUS_LAUNCHED);
|
|
|
|
expect(fn () => $c->transitionTo(Campaign::STATUS_RUNNING))
|
|
->toThrow(DomainException::class);
|
|
});
|
|
|
|
it('canTransitionTo сообщает допустимость без броска', function () {
|
|
$c = tgCampaign(Campaign::STATUS_QUEUED);
|
|
|
|
expect($c->canTransitionTo(Campaign::STATUS_RUNNING))->toBeTrue()
|
|
->and($c->canTransitionTo(Campaign::STATUS_DRAFT_READY))->toBeFalse();
|
|
});
|