EloquentPointEmailRepository.php

<?php

namespace Acme\Infrastructure\Repository;

use Acme\Domain\Exception\NotFoundException;
use Acme\Domain\Model\PointEmail;
use Acme\Domain\Model\UserId;
use Acme\Domain\Repository\PointEmailRepository;
use Acme\Infrastructure\Eloquent\EloquentUser;

final class EloquentPointEmailRepository implements PointEmailRepository
{
    /** @var EloquentUser */
    private $eloquentUser;

    /**
     * @param EloquentUser $eloquentUser
     */
    public function __construct(EloquentUser $eloquentUser)
    {
        $this->eloquentUser = $eloquentUser;
    }

    /**
     * @param UserId $id
     * @return PointEmail
     * @throws NotFoundException
     */
    public function findByUserId(UserId $id): PointEmail
    {
        $record = $this->eloquentUser->newQuery()
            ->join('user_points', 'user_points.user_id', '=', 'users.id')
            ->where('id', $id->asInt())
            ->first(['email', 'point']);

        if ($record === null) {
            throw new NotFoundException('PointEmail not found:' . $id);
        }

        return new PointEmail(
            $record->email,
            $record->point
        );
    }
}