DatabaseGroupsRepository.php

<?php


namespace Source\Gateways\Groups;

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

class DatabaseGroupsRepository implements GroupsRepository
{
    use CastsTo;

    /**
     * @param \App\Group             $dbGroup
     * @param \Source\Entities\Group $group
     * @throws \Source\Exceptions\EntityExistsException
     */
    protected function saveGroup(\App\Group $dbGroup, Group $group): void
    {
        $dbGroup = self::fillBasicAttrs($group, $dbGroup);

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

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

            throw $e;
        }
    }

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

        if (!$group) {
            return null;
        }

        return self::makeGroupFromDbGroup($group);
    }

    /**
     * @param \App\Group $group
     * @return \Source\Entities\Group
     */
    public static function makeGroupFromDbGroup(\App\Group $group): Group
    {
        return new Group(
            $group->getAttribute('id'),
            $group->getAttribute('title'),
            $group->getAttribute('description'),
            $group->getAttribute('created_at'),
            $group->getAttribute('updated_at')
        );
    }

    /**
     * @inheritDoc
     */
    public function search(?string $query = null): array
    {
        if ($query) {
            $groups = \App\Group::query()
                ->where('title', 'ILIKE', "%$query%")
                ->orWhere('description', 'ILIKE', "%$query%")
                ->get()->values()->all();
        } else {
            $groups = \App\Group::all()->values()->all();
        }

        return array_map(function (\App\Group $group) {
            return $this->makeGroupFromDbGroup($group);
        }, $groups);
    }

    /**
     * @inheritDoc
     */
    public function create(Group $group): Group
    {
        $newGroup = new \App\Group();

        $this->saveGroup($newGroup, $group);

        return self::makeGroupFromDbGroup($newGroup);
    }

    protected static function fillBasicAttrs(Group $group, \App\Group $dbGroup): \App\Group
    {
        $dbGroup->setAttribute('title', $group->getTitle());
        $dbGroup->setAttribute('description', $group->getDescription());

        return $dbGroup;
    }

    /**
     * @inheritDoc
     */
    public function update(string $groupId, Group $group): ?Group
    {
        /** @var \App\Group|null $dbGroup */
        $dbGroup = \App\Group::query()->find(self::castToInt($groupId));

        if (!$dbGroup) {
            return null;
        }

        $this->saveGroup($dbGroup, $group);

        return self::makeGroupFromDbGroup($dbGroup);
    }

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

    /**
     * @inheritDoc
     */
    public function exists(Group $group): bool
    {
        return \App\Group::query()->where('title', $group->getTitle())->orWhere('id', $group->getId())->first() !== null;
    }
}