83 lines
2.5 KiB
PHP
83 lines
2.5 KiB
PHP
<?php
|
|
|
|
namespace App\Tests\Feature\Scraping;
|
|
|
|
use ApiPlatform\Symfony\Bundle\Test\ApiTestCase;
|
|
use App\Domain\Scraping\Domain\Model\ScrapingJob;
|
|
use App\Domain\Scraping\Domain\Model\ScrapingStatus;
|
|
use App\Domain\Scraping\Domain\Model\ValueObject\ImageUrl;
|
|
use App\Domain\Scraping\Domain\Model\ValueObject\PageNumber;
|
|
use Ramsey\Uuid\Uuid;
|
|
use Symfony\Component\Messenger\MessageBusInterface;
|
|
use App\Domain\Shared\Domain\Contract\JobRepositoryInterface;
|
|
use App\Domain\Shared\Domain\Model\JobStatus;
|
|
|
|
class ScrapingStatusTest extends ApiTestCase
|
|
{
|
|
private MessageBusInterface $messageBus;
|
|
private JobRepositoryInterface $repository;
|
|
|
|
protected function setUp(): void
|
|
{
|
|
parent::setUp();
|
|
|
|
self::bootKernel();
|
|
|
|
$this->messageBus = self::getContainer()->get(MessageBusInterface::class);
|
|
$this->repository = self::getContainer()->get(JobRepositoryInterface::class);
|
|
}
|
|
|
|
public function testGetScrapingStatus(): void
|
|
{
|
|
// Given
|
|
$jobId = Uuid::uuid4()->toString();
|
|
$job = new ScrapingJob($jobId, 'manga-123', 1, 'source-789');
|
|
|
|
$job->start();
|
|
|
|
$this->repository->save($job);
|
|
|
|
// When
|
|
$response = static::createClient()->request('GET', '/api/jobs?status=in_progress');
|
|
|
|
// Then
|
|
$this->assertResponseIsSuccessful();
|
|
|
|
$responseData = $response->toArray();
|
|
|
|
$this->assertArrayHasKey('hydra:member', $responseData);
|
|
$this->assertIsArray($responseData['hydra:member']);
|
|
$this->assertCount(1, $responseData['hydra:member']);
|
|
|
|
$jobData = $responseData['hydra:member'][0];
|
|
$this->assertEquals('/api/jobs/' . $jobId, $jobData['@id']);
|
|
$this->assertEquals('Job', $jobData['@type']);
|
|
$this->assertEquals($jobId, $jobData['id']);
|
|
$this->assertEquals('scraping_job', $jobData['type']);
|
|
$this->assertEquals(JobStatus::IN_PROGRESS->value, $jobData['status']);
|
|
$this->assertEquals([
|
|
'mangaId' => 'manga-123',
|
|
'chapterNumber' => 1,
|
|
'sourceId' => 'source-789'
|
|
], $jobData['context']);
|
|
}
|
|
|
|
public function testGetScrapingStatusForNonExistentJob(): void
|
|
{
|
|
// When
|
|
$response = static::createClient()->request('GET', '/api/jobs/non-existent-id?status=in_progress', [
|
|
'headers' => ['Accept' => 'application/json']
|
|
]);
|
|
|
|
// Then
|
|
$this->assertResponseStatusCodeSame(404);
|
|
}
|
|
|
|
protected function tearDown(): void
|
|
{
|
|
parent::tearDown();
|
|
|
|
self::ensureKernelShutdown();
|
|
}
|
|
}
|