1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55
|
<?php
declare(strict_types=1);
namespace Pheanstalk\Tests\Unit\Command;
use InvalidArgumentException;
use Pheanstalk\Command\PeekCommand;
use Pheanstalk\Values\Job;
use Pheanstalk\Values\JobState;
use Pheanstalk\Values\RawResponse;
use Pheanstalk\Values\ResponseType;
use Pheanstalk\Values\Success;
use PHPUnit\Framework\Assert;
use PHPUnit\Framework\Attributes\CoversClass;
#[CoversClass(PeekCommand::class)]
final class PeekCommandTest extends CommandTestBase
{
public function testPeekReserved(): void
{
$this->expectException(InvalidArgumentException::class);
new PeekCommand(JobState::RESERVED);
}
public function testInterpretNotFound(): void
{
$result = $this->getSubject()->interpret(new RawResponse(ResponseType::NotFound));
Assert::assertInstanceOf(Success::class, $result);
}
public function testInterpretFound(): void
{
$data = <<<DATA
bacdefwf
afwwefawaw
DATA;
$id = "123141515151325132515";
$result = $this->getSubject()->interpret(new RawResponse(ResponseType::Found, $id, $data));
Assert::assertInstanceOf(Job::class, $result);
Assert::assertSame($id, $result->getId());
Assert::assertSame($data, $result->getData());
}
protected static function getSupportedResponses(): array
{
return [ResponseType::NotFound, ResponseType::Found];
}
protected function getSubject(?JobState $state = null): PeekCommand
{
return new PeekCommand($state ?? JobState::READY);
}
}
|