tienvx/pact-messenger-bundle

Pact Messenger Bundle

Maintainers

Details

github.com/tienvx/pact-messenger-bundle

Source

Issues

Installs: 2

Dependents: 0

Suggesters: 0

Security: 0

Stars: 1

Watchers: 2

Forks: 0

Open Issues: 0

Type:symfony-bundle

v1.0.0 2024-03-28 16:23 UTC

Requires

Requires (Dev)

Conflicts

MIT e8b0b2399f7e6620d4c68328833bf0ca137d1e80

This package is auto-updated.

Last update: 2024-10-31 00:31:15 UTC

README

This Symfony Bundle allow collecting dispatched message using Symfony Messenger.

Installation

composer require tienvx/pact-messenger-bundle

Documentation

namespace App\MessageDispatcher;

use App\Message\UserCreated;
use Tienvx\Bundle\PactMessengerBundle\Service\EnvelopeCollectorInterface;
use Tienvx\Bundle\PactProviderBundle\Attribute\AsMessageDispatcher;
use Tienvx\Bundle\PactProviderBundle\Model\Message;
use Tienvx\Bundle\PactProviderBundle\MessageDispatcher\DispatcherInterface;

#[AsMessageDispatcher(description: 'User created message')]
class UserDispatcher implements DispatcherInterface
{
    public function __construct(private EnvelopeCollectorInterface $collector)
    {
    }

    public function dispatch(): ?Message
    {
        $envelope = $this->collector->getSingle(UserCreated::class);
        if (!$envelope) {
            return null;
        }
        $message = $envelope->getMessage();
        if (!$message instanceof UserCreated) {
            return null;
        }

        return new Message(
            \json_encode([
                'class' => UserCreated::class,
                'id' => $message->userId,
            ]),
            'application/json',
            json_encode(['contentType' => 'application/json'])
        );
    }
}

License

MIT