102 lines
3.0 KiB
PHP
102 lines
3.0 KiB
PHP
<?php
|
||
|
||
declare(strict_types=1);
|
||
|
||
namespace HyperfTest\Cases\Unit\Service;
|
||
|
||
use App\Service\MqStatusService;
|
||
use Hyperf\Contract\ConfigInterface;
|
||
use PHPUnit\Framework\TestCase;
|
||
|
||
/**
|
||
* MqStatusService 单元测试
|
||
*
|
||
* 覆盖队列类型常量、状态判定逻辑
|
||
*
|
||
* @internal
|
||
* @coversNothing
|
||
*/
|
||
class MqStatusServiceTest extends TestCase
|
||
{
|
||
private MqStatusService $service;
|
||
|
||
protected function setUp(): void
|
||
{
|
||
parent::setUp();
|
||
|
||
$config = $this->createMock(ConfigInterface::class);
|
||
$this->service = new MqStatusService($config);
|
||
}
|
||
|
||
// ========== getValidQueueTypes ==========
|
||
|
||
public function test_get_valid_queue_types_returns_correct_list(): void
|
||
{
|
||
$types = $this->service->getValidQueueTypes();
|
||
|
||
$this->assertIsArray($types);
|
||
$this->assertContains('orders', $types);
|
||
$this->assertContains('products', $types);
|
||
$this->assertContains('refunds', $types);
|
||
$this->assertContains('inventory', $types);
|
||
$this->assertCount(4, $types);
|
||
}
|
||
|
||
// ========== getQueueStatus 状态判定 ==========
|
||
|
||
public function test_status_high_load_when_messages_over_100(): void
|
||
{
|
||
$this->assertSame('high_load', $this->service->getQueueStatus(101));
|
||
$this->assertSame('high_load', $this->service->getQueueStatus(500));
|
||
$this->assertSame('high_load', $this->service->getQueueStatus(10000));
|
||
}
|
||
|
||
public function test_status_processing_when_messages_over_10(): void
|
||
{
|
||
$this->assertSame('processing', $this->service->getQueueStatus(11));
|
||
$this->assertSame('processing', $this->service->getQueueStatus(50));
|
||
$this->assertSame('processing', $this->service->getQueueStatus(100));
|
||
}
|
||
|
||
public function test_status_active_when_messages_over_0(): void
|
||
{
|
||
$this->assertSame('active', $this->service->getQueueStatus(1));
|
||
$this->assertSame('active', $this->service->getQueueStatus(5));
|
||
$this->assertSame('active', $this->service->getQueueStatus(10));
|
||
}
|
||
|
||
public function test_status_empty_when_no_messages(): void
|
||
{
|
||
$this->assertSame('empty', $this->service->getQueueStatus(0));
|
||
}
|
||
|
||
// ========== 边界值测试 ==========
|
||
|
||
public function test_status_boundary_at_exactly_100(): void
|
||
{
|
||
// 100 条消息 → processing（> 10 且 <= 100）
|
||
$this->assertSame('processing', $this->service->getQueueStatus(100));
|
||
}
|
||
|
||
public function test_status_boundary_at_exactly_10(): void
|
||
{
|
||
// 10 条消息 → active（> 0 且 <= 10）
|
||
$this->assertSame('active', $this->service->getQueueStatus(10));
|
||
}
|
||
|
||
public function test_status_boundary_at_exactly_1(): void
|
||
{
|
||
$this->assertSame('active', $this->service->getQueueStatus(1));
|
||
}
|
||
|
||
// ========== QUEUE_TYPES 常量 ==========
|
||
|
||
public function test_queue_types_constant_matches_valid_types(): void
|
||
{
|
||
$this->assertSame(
|
||
MqStatusService::QUEUE_TYPES,
|
||
$this->service->getValidQueueTypes()
|
||
);
|
||
}
|
||
}
|