DatabaseDoorsRepository.php

<?php


namespace Source\Gateways\Doors;

use Carbon\Carbon;
use Source\Entities\Door;
use Source\Sanitize\CastsTo;
use Illuminate\Support\Facades\Log;
use Source\Entities\HashedSearchable;
use Source\Gateways\PostgresSQLCodes;
use Illuminate\Database\QueryException;
use Illuminate\Database\Eloquent\Builder;
use Source\Exceptions\EntityExistsException;
use Source\Exceptions\EntityNotFoundException;

class DatabaseDoorsRepository implements DoorsRepository
{
    use CastsTo;

    /**
     * @param \App\Door             $dbDoor
     * @param \Source\Entities\Door $door
     * @throws \Source\Exceptions\EntityExistsException
     */
    protected function saveDoor(\App\Door $dbDoor, Door $door): void
    {
        $dbDoor->setAttribute('location', $door->getLocation());
        $dbDoor->setAttribute('name', $door->getName());
        $dbDoor->setAttribute('api_token', $door->getToken()->getHash());
        $dbDoor->setAttribute('version', $door->getVersion());
        $dbDoor->setAttribute('last_seen_at', $door->getLastSeenAt());
        $dbDoor->setAttribute('public', $door->isPublic());
        $dbDoor->setAttribute('notes', $door->getNotes());

        try {
            $dbDoor->save();
        } catch (QueryException $e) {
            if ($e->getCode() === PostgresSQLCodes::UNIQUE_CONSTRAINT_VIOLATION) {
                throw new EntityExistsException('Cannot save door. Door already exists.');
            }

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

            throw $e;
        }
    }

    /**
     * @inheritDoc
     */
    public function create(Door $door): Door
    {
        $dbDoor = new \App\Door();

        $this->saveDoor($dbDoor, $door);

        return self::makeDoorFromDb($dbDoor);
    }

    public static function makeDoorFromDb(\App\Door $door): Door
    {
        return new Door(
            $door->getAttribute('id'),
            $door->getAttribute('location'),
            $door->getAttribute('name'),
            new HashedSearchable($door->getAttribute('api_token')),
            $door->getAttribute('public'),
            $door->getAttribute('notes'),
            $door->getAttribute('version'),
            $door->getAttribute('created_at'),
            $door->getAttribute('updated_at'),
            $door->getAttribute('last_seen_at')
        );
    }

    /**
     * @inheritDoc
     */
    public function getByToken(?HashedSearchable $token): ?Door
    {
        if (!$token) {
            return null;
        }

        /** @var \App\Door|null $door */
        $door = \App\Door::query()->where('api_token', $token->getHash())->first();

        if (!$door) {
            return null;
        }

        return self::makeDoorFromDb($door);
    }

    /**
     * @inheritDoc
     */
    public function touch(string $doorId, Carbon $seen, ?string $version): void
    {
        $updated = [
            'last_seen_at' => $seen,
        ];

        // If we have a new version to set, set it.
        if ($version) {
            $updated['version'] = $version;
        }

        \App\Door::query()->where('id', self::castToInt($doorId))->update($updated);
    }

    /**
     * @inheritDoc
     */
    public function get(string $doorId): ?Door
    {
        /** @var \App\Door|null $door */
        $door = \App\Door::query()->find(self::castToInt($doorId));
        if (!$door) {
            return null;
        }

        return self::makeDoorFromDb($door);
    }

    /**
     * @inheritDoc
     */
    public function search(?string $query = null, ?int $seenSinceSeconds = null, ?int $awolForSeconds = null): array
    {
        $doors = \App\Door::query()->orderBy('location');

        if ($seenSinceSeconds > 0) {
            $doors->whereNotNull('last_seen_at')
                ->where('last_seen_at', '>=', Carbon::now()->subRealSeconds($seenSinceSeconds));
        }

        if ($awolForSeconds > 0) {
            $doors->whereNotNull('last_seen_at')
                ->where('last_seen_at', '<', Carbon::now()->subRealSeconds($awolForSeconds));
        }

        if ($query) {
            $doors->where(static function (Builder $builder) use ($query) {
                $builder->where('location', 'ILIKE', "%$query%")
                    ->orWhere('id', '=', self::castToInt($query))
                    ->orWhere('name', 'ILIKE', "%$query%")
                    ->orWhere('version', 'ILIKE', "%$query%");
            });
        }

        return array_map(fn (\App\Door $door): Door => self::makeDoorFromDb($door), $doors->get()->values()->all());
    }

    /**
     * @inheritDoc
     */
    public function findByName(?string $name): ?Door
    {
        if (!$name) {
            return null;
        }

        /** @var \App\Door|null $door */
        $door = \App\Door::query()->where('name', $name)->first();

        if (!$door) {
            return null;
        }

        return self::makeDoorFromDb($door);
    }

    /**
     * @inheritDoc
     */
    public function update(string $doorId, Door $door): Door
    {
        /** @var \App\Door|null $dbDoor */
        $dbDoor = \App\Door::query()->find(self::castToInt($doorId));

        if (!$dbDoor) {
            throw new EntityNotFoundException('Could not update door. Door not found.');
        }

        $this->saveDoor($dbDoor, $door);

        return self::makeDoorFromDb($dbDoor);
    }

    /**
     * @inheritDoc
     */
    public function delete(string $doorId): int
    {
        return \App\Door::destroy(self::castToInt($doorId));
    }

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

    /**
     * @inheritDoc
     */
    public function searchByLocation(string $location): array
    {
        $doors = \App\Door::query()->where('location', '=', $location);

        return array_map(fn (\App\Door $door): Door => self::makeDoorFromDb($door), $doors->get()->values()->all());
    }
}