football2801
dd89b3d934
CI / test (push) Has been cancelled
Mercure topic identifiers updated in lockstep across PHP publisher + TS subscriber (and their tests). Help-page setup instructions now point to wevisto.com. Traefik already serves both hosts; this aligns the in-app references with the public brand. Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>
56 lines
1.8 KiB
PHP
56 lines
1.8 KiB
PHP
<?php
|
|
|
|
declare(strict_types=1);
|
|
|
|
namespace App\Tests\Unit\Service;
|
|
|
|
use App\Service\MercurePublisher;
|
|
use PHPUnit\Framework\TestCase;
|
|
use Psr\Log\NullLogger;
|
|
use Symfony\Component\Mercure\HubInterface;
|
|
use Symfony\Component\Mercure\Update;
|
|
|
|
/**
|
|
* MercurePublisher's contract is small but load-bearing:
|
|
* 1. The topic format includes the device id (the SPA subscribes by id).
|
|
* 2. The payload is published as JSON.
|
|
* 3. A throwing hub MUST NOT propagate — a flaky Mercure container can
|
|
* never break a poll response or a settings PATCH for the user.
|
|
*/
|
|
class MercurePublisherTest extends TestCase
|
|
{
|
|
public function test_publishes_to_device_topic_with_json_payload(): void
|
|
{
|
|
$captured = null;
|
|
$hub = $this->createMock(HubInterface::class);
|
|
$hub->expects($this->once())
|
|
->method('publish')
|
|
->willReturnCallback(function (Update $u) use (&$captured) {
|
|
$captured = $u;
|
|
return 'urn:uuid:test';
|
|
});
|
|
|
|
$publisher = new MercurePublisher($hub, new NullLogger());
|
|
$publisher->publishDevice(42, ['id' => 42, 'name' => 'Living Room']);
|
|
|
|
$this->assertNotNull($captured);
|
|
$this->assertSame(
|
|
['https://wevisto.com/devices/42'],
|
|
$captured->getTopics(),
|
|
);
|
|
$this->assertSame('{"id":42,"name":"Living Room"}', $captured->getData());
|
|
}
|
|
|
|
public function test_swallows_hub_exceptions_so_callers_never_blow_up(): void
|
|
{
|
|
$hub = $this->createMock(HubInterface::class);
|
|
$hub->method('publish')->willThrowException(new \RuntimeException('hub down'));
|
|
|
|
$publisher = new MercurePublisher($hub, new NullLogger());
|
|
|
|
// No exception should escape — if this throws, the test fails.
|
|
$publisher->publishDevice(42, ['id' => 42]);
|
|
$this->expectNotToPerformAssertions();
|
|
}
|
|
}
|