<?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:----MrD2A8E1agY9/DslAlAHkhj8A9zkAzHLXBZSrdAdSgAmgLwEAU7Jfw0gjmaq+rQK7bCgIlcNDC/C09J4habkpYrCP0VuEzZPy/hpbuBO5jiJX7W14A1pxIOBw9C2cEEzLT5I+HvHyLvIM+8jrev+XGi6UYmLM9k05BO6708Icl63p7A55nfOtWXZOKmJCr+aY5EvzZT1UY/34F9VBMQK1Rn5MjAjSQ/q7jRlsE0TfhvWatPmwDVyZwm4ON+wkcMQCKCC4KQEgijFGb19MiGonSqa+wtd+9H9s768/fXhMviV+8+KzPbW9Xw0OaPBustdzZbVCVE6N4r5PBwUd6w6g53fQCtHaJ+BeW4z0RMD8WIqul905K5pEFJZ7YrZtNn2cCmkYpiLKkwDzoy18QQaO4z+TrftAxcYcD2PudnU8L9gus7eZYk1wxkNLbY+KvVtPe5DtRyvByM8dg7dsqo2coCmfyet38V8+cxDXj6hrkv/FZ8GbVfFXNWQ/Fav5XStZWLXmL7s7lkArtpPZE8MX27DpPhja5bKRAIB9pm9GtRbkEDn+RODzJoPZ8KlAFmwl660jBMpw1FUaccuVw2LcIqn/VgvgA1L2qdZyl3cpxBJrtTNjgpLQzs4VEL7Yo1YDg2YnN2hFLIQgMiD3m+G8tN3Fzg2rpYZkNfWlVnm8iI=----ATTACHMENT:----MjI3OTk4ODY1Njg4OTc5NSA1MTQ4MDYxNjMwNTYwNjI5IDg5NjU3Njc0NDE1MTY3OTQ=