php-qml/framework/php/tests/PublisherTest.php

<?php

declare(strict_types=1);

namespace PhpQml\Bridge\Tests;

use PhpQml\Bridge\Publisher;
use PhpQml\Bridge\Tests\Helper\HubSpy;
use PHPUnit\Framework\Attributes\CoversClass;
use PHPUnit\Framework\TestCase;
use Symfony\Component\Mercure\Update;

#[CoversClass(Publisher::class)]
final class PublisherTest extends TestCase
{
    public function testPublishWritesEnvelopeAsJsonOnTheGivenTopic(): void
    {
        $hub       = new HubSpy('urn:uuid:test');
        $publisher = new Publisher($hub);

        $id = $publisher->publish(
            'app://model/todo',
            ['op' => 'upsert', 'id' => '1', 'data' => ['done' => true], 'version' => 7],
        );

        self::assertSame('urn:uuid:test', $id);
        self::assertInstanceOf(Update::class, $hub->captured);
        self::assertSame(['app://model/todo'], $hub->captured->getTopics());
        self::assertJsonStringEqualsJsonString(
            '{"op":"upsert","id":"1","data":{"done":true},"version":7}',
            $hub->captured->getData(),
        );
        self::assertFalse($hub->captured->isPrivate());
    }

    public function testPrivateFlagIsForwarded(): void
    {
        $hub = new HubSpy();
        (new Publisher($hub))->publish('app://event/internal', ['data' => 'x'], private: true);

        self::assertNotNull($hub->captured);
        self::assertTrue($hub->captured->isPrivate());
    }
}