kreta / Kreta

use Kreta\Notifier\Domain\Model\Inbox\UserId;

use Kreta\Notifier\Domain\Model\Inbox\UserRepository;

class ReadNotificationHandler

{

    private $repository;

    public function __construct(UserRepository $repository)

    {

        $this->repository = $repository;

    }

    public function __invoke(ReadNotificationCommand $command) : void

    {

        $id = UserId::generate($command->userId());

        $notificationId = NotificationId::generate($command->notificationId());

        $user = $this->repository->get($id);

        $notification = $user->notification($notificationId);

        $user->readNotification($notification);

        $this->repository->save($user);

    }

}

use Kreta\Notifier\Domain\Model\Inbox\UserId;

use Kreta\Notifier\Domain\Model\Inbox\UserRepository;

class ReceiveNotificationHandler

{

    private $repository;

    public function __construct(UserRepository $repository)

    {

        $this->repository = $repository;

    }

    public function __invoke(ReceiveNotificationCommand $command) : void

    {

        $id = UserId::generate($command->userId());

        $notificationId = NotificationId::generate($command->notificationId());

        $body = new NotificationBody($command->body());

        $user = $this->repository->get($id);

        $user->receiveNotification($notificationId, $body);

        $this->repository->save($user);

    }

}

use Kreta\Notifier\Domain\Model\Inbox\UserId;

use Kreta\Notifier\Domain\Model\Inbox\UserRepository;

class UnreadNotificationHandler

{

    private $repository;

    public function __construct(UserRepository $repository)

    {

        $this->repository = $repository;

    }

    public function __invoke(UnreadNotificationCommand $command) : void

    {

        $id = UserId::generate($command->userId());

        $notificationId = NotificationId::generate($command->notificationId());

        $user = $this->repository->get($id);

        $notification = $user->notification($notificationId);

        $user->unreadNotification($notification);

        $this->repository->save($user);

    }

}