UsersFacadeForProductivity.php

<?php

/**
 * This file is part of the todocler package.
 *
 * (C) Alan Gabriel Bem <alan.bem@gmail.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

declare(strict_types=1);

namespace Users\Infrastructure;

use Productivity;
use Streak\Application\QueryBus;
use Users\Application\Projector\RegisteredUsers\Doctrine\Entity\RegisteredUser;
use Users\Application\Query\FindUser;
use Users\Application\Query\IsUserRegistered;

/**
 * @author Alan Gabriel Bem <alan.bem@gmail.com>
 *
 * @see \Users\Infrastructure\UsersFacadeForProductivityTest
 */
final class UsersFacadeForProductivity implements Productivity\UsersFacade
{
    public function __construct(private QueryBus $bus)
    {
    }

    public function isUserRegistered(string $email) : bool
    {
        try {
            return $this->bus->dispatch(new IsUserRegistered($email));
        } catch (\Throwable) {
            // projection does not exist yet
            return false;
        }
    }

    public function findRegisteredUser(string $email) : ?object
    {
        try {
            /** @var ?RegisteredUser $user */
            $user = $this->bus->dispatch(new FindUser($email));
        } catch (\Throwable) {
            // projection does not exists yet
            return null;
        }

        if (null === $user) {
            return null;
        }

        return (object) [
            'id' => $user->getId(),
            'email' => $user->getEmail(),
        ];
    }
}