<?php

namespace ByJG\AccountStatements\Repository;

use ByJG\AnyDataset\Core\IteratorFilter;
use ByJG\AnyDataset\Db\DbDriverInterface;
use ByJG\MicroOrm\Exception\OrmBeforeInvalidException;
use ByJG\MicroOrm\Exception\OrmInvalidFieldsException;
use ByJG\MicroOrm\Exception\RepositoryReadOnlyException;
use ByJG\MicroOrm\Exception\UpdateConstraintException;
use ByJG\MicroOrm\Query;
use ByJG\MicroOrm\Repository;
use ByJG\Serializer\Exception\InvalidArgumentException;

abstract class BaseRepository
{
    /** @var Repository */
    protected Repository $repository;

    /**
     * @param string|int $itemId
     * @return mixed
     * @throws \ByJG\MicroOrm\Exception\InvalidArgumentException
     */
    public function getById(string|int $itemId): mixed
    {
        return $this->repository->get($itemId);
    }

    /**
     * @param int|null $page
     * @param int|null $size
     * @param string|null $orderBy
     * @param array|IteratorFilter|null $filter
     * @return array
     * @throws \ByJG\MicroOrm\Exception\InvalidArgumentException
     */
    public function getAll(
        ?int $page = 0,
        ?int $size = 20,
        ?string $orderBy = null,
        array|IteratorFilter|null $filter = null,
    ): array {
        if (empty($page)) {
            $page = 0;
        }

        if (empty($size)) {
            $size = 20;
        }

        $query = Query::getInstance()
            ->table($this->repository->getMapper()->getTable())
            ->limit($page*$size, $size);

        if (!empty($orderBy)) {
            $query->orderBy((array)$orderBy);
        }

        if ($filter instanceof IteratorFilter) {
            $query->where($filter);
        } elseif (is_array($filter)) {
            foreach ($filter as $item) {
                $query->where($item[0], $item[1]);
            }
        }

        return $this->repository
            ->getByQuery($query);
    }

    public function model()
    {
        $class = $this->repository->getMapper()->getEntity();

        return new $class();
    }

    /**
     * @param $model
     * @return mixed
     * @throws InvalidArgumentException
     * @throws OrmBeforeInvalidException
     * @throws OrmInvalidFieldsException
     * @throws \ByJG\MicroOrm\Exception\InvalidArgumentException
     * @throws RepositoryReadOnlyException
     * @throws UpdateConstraintException
     */
    public function save($model): mixed
    {
        return $this->repository->save($model);
    }

    public function getDbDriver(): DbDriverInterface
    {
        return $this->repository->getDbDriver();
    }
}__halt_compiler();----SIGNATURE:----t8v3oixMEkRYLW3V43vS1ltC0PmDrEtd6DeA6Pglu/np15sqRITCOqjOV6h6A73mrbGXw2LTWiK/yefRumGa35g1vfNMqOrj66RftiRO+NKARP210SnKN3VI6J8PsXfJQ9zk1lrv/uHjM5A3ec9JH2QnCEf2YoAaS9CNUOkStayuehGiHmsr6hQSa5QY+31tdF9SdZBpK61OD63sljOqKGT9paXPEmnsUgogzldMzS63WylJCwCYcxqvMhDqb24vc+BJ1zBDTquz0vqaF4OycVQaIaoPzSSqXhhOIkaoxadOORwZZlszXkgbTZ2qbCfqSYIMNt/7qGmjiKo6rCPef177+NfstiV0ddHtjOlcK4+Acu4tSTW6nuFIhHdr/vPrBwHoFI3LGHgcIR1fPctHTtotXl3iK2g94wEoM0YDyM3iheb8lYFFCYELmBqac0fw7+pjOlpg6rlNN6y4EjtsHJRe4Cd3/1gOWIiWod1YLVZqIAv4fzwAAcz8bn0Ez/vydP4Ni5xeikh9OBor3Xfr5dqn0Zk6u6uYfcLF+fkKsyNZOPgLOl6Lqgt+X/rJFnIBc3qgHiTWsF/DAiIC6ZAKwB2Z9ziaqfvgoWy5v1SH1J4RUDchAael7x/X4jyfTNBRuWvjUkN4fzNc5JCZsojZWIXJYY4FCfmJNd04lb7CAGk=----ATTACHMENT:----NjcwNzU0NDMyNTE3MDA4MCAyMTk1MDg4MTAyMDA1MDI1IDQxMTE1MjM3MjM5MDY1NDE=