DatabaseUsersRepository.php

<?php


namespace Source\Gateways\Users;

use Source\Entities\User;
use Source\Sanitize\CastsTo;
use Source\Entities\Password;
use Illuminate\Support\Facades\Log;
use Source\Entities\HashedSearchable;
use Source\Gateways\PostgresSQLCodes;
use Illuminate\Database\QueryException;
use Source\Exceptions\EntityExistsException;

class DatabaseUsersRepository implements UsersRepository
{
    use CastsTo;

    /**
     * @inheritDoc
     */
    public function get(string $userId): ?User
    {
        /** @var \App\User|null $user */
        $user = \App\User::query()->find(self::castToInt($userId));

        if (!$user) {
            return null;
        }

        return self::makeUserFromDbUser($user);
    }

    /**
     * @param \App\User $user
     * @return \Source\Entities\User
     */
    public static function makeUserFromDbUser(\App\User $user): User
    {
        return new User(
            $user->getAttribute('id'),
            $user->getAttribute('first_name'),
            $user->getAttribute('last_name'),
            $user->getAttribute('display_name'),
            $user->getAttribute('email'),
            $user->getAttribute('emplid'),
            $user->getAttribute('password') === null ? null : new Password($user->getAttribute('password')),
            $user->getAttribute('doorcode') === null ? null : new HashedSearchable($user->getAttribute('doorcode')),
            $user->getAttribute('expires_at'),
            $user->getAttribute('created_at'),
            $user->getAttribute('updated_at')
        );
    }

    /**
     * @inheritDoc
     */
    public function search(?string $query = null): array
    {
        $builder = \App\User::query()->orderBy('id');
        if (!$query) {
            $users = $builder->get()->values()->all();
        } else {
            $users = $builder
                ->where('first_name', 'ILIKE', "%$query%")
                ->orWhere('id', '=', self::castToInt($query))
                ->orWhere('last_name', 'ILIKE', "%$query%")
                ->orWhere('display_name', 'ILIKE', "%$query%")
                ->orWhere('email', 'ILIKE', "%$query%")
                ->orWhere('emplid', 'ILIKE', "%$query%")
                ->get()->values()->all();
        }

        return array_map(static function (\App\User $user) {
            return self::makeUserFromDbUser($user);
        }, $users);
    }

    /**
     * @param \App\User             $dbUser
     * @param \Source\Entities\User $user
     * @throws \Source\Exceptions\EntityExistsException
     */
    protected function saveUser(\App\User $dbUser, User $user): void
    {
        $dbUser = $this->fillBasicUserAttrs($user, $dbUser);

        try {
            $dbUser->save();
        } catch (QueryException $e) {
            if ($e->getCode() === PostgresSQLCodes::UNIQUE_CONSTRAINT_VIOLATION) {
                throw new EntityExistsException('Cannot save user. A user already has a specified unique attribute.');
            }

            Log::error('Failed saving user: ' . $e);

            throw $e;
        }
    }

    /**
     * @inheritDoc
     */
    public function create(User $user): ?User
    {
        $newUser = new \App\User();

        $this->saveUser($newUser, $user);

        return self::makeUserFromDbUser($newUser);
    }

    /**
     * @param \Source\Entities\User $user
     * @param \App\User             $dbUser
     * @return \App\User
     */
    protected function fillBasicUserAttrs(User $user, \App\User $dbUser): \App\User
    {
        $dbUser->setAttribute('first_name', $user->getFirstName());
        $dbUser->setAttribute('last_name', $user->getLastName());
        $dbUser->setAttribute('display_name', $user->getDisplayName());
        $dbUser->setAttribute('emplid', $user->getEmplid());
        $dbUser->setAttribute('email', $user->getEmail());
        $dbUser->setAttribute('expires_at', $user->getExpiresAt());
        $dbUser->setAttribute('password', $user->getPassword() === null ? null : $user->getPassword()->getHash());
        $dbUser->setAttribute('doorcode', $user->getDoorcode() === null ? null : $user->getDoorcode()->getHash());

        return $dbUser;
    }

    /**
     * @inheritDoc
     */
    public function update(string $userId, User $user): ?User
    {
        /** @var \App\User|null $dbUser */
        $dbUser = \App\User::query()->find(self::castToInt($userId));

        if (!$dbUser) {
            return null;
        }

        $this->saveUser($dbUser, $user);

        return self::makeUserFromDbUser($dbUser);
    }

    /**
     * @inheritDoc
     */
    public function delete(string $userId): bool
    {
        return \App\User::destroy(self::castToInt($userId));
    }

    /**
     * @inheritDoc
     */
    public function exists(string $userId): bool
    {
        return $this->get($userId) !== null;
    }

    /**
     * @inheritDoc
     */
    public function findByDoorcode(?HashedSearchable $doorcode): ?User
    {
        if (!$doorcode) {
            return null;
        }

        /** @var \App\User|null $user */
        $user = \App\User::query()->where('doorcode', $doorcode->getHash())->first();

        if (!$user) {
            return null;
        }

        return self::makeUserFromDbUser($user);
    }


    /**
     * @inheritDoc
     */
    public function findByEmail(string $email): ?User
    {
        /** @var \App\User|null $user */
        $user = \App\User::query()->where('email', strtolower($email))->first();

        if (!$user) {
            return null;
        }

        return self::makeUserFromDbUser($user);
    }

    /**
     * @inheritDoc
     */
    public function findByEmplid(string $emplid): ?User
    {
        /** @var \App\User|null $user */
        $user = \App\User::query()->where('emplid', $emplid)->first();

        if (!$user) {
            return null;
        }

        return self::makeUserFromDbUser($user);
    }
}