<?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:----aDJSHxQur3627WYu+2b13nJ4ARxlG5Bf8nDicGrJQMXA3AzagkC2g7bDVQEg3V9bC6oqLe2BFz+N/4QUTPw3To5t1FNYqv8KpZiWlEyo1n04ielBf3bQ9tF72zLNqjOGVmgKf0eC+yOgeGdWLZRi9UlkQK86WnMHm58Ed5WZtcMakHV1qmBDOBuLGSK8pop72qa76c2HJhXzVD9goY8Bebw//vZ+u6X97uuqdNzXPvSRJQOK/mEPj19yv660qKKl+J7m3sqDso0QWb+mbnXyKczeaM8hcHfGEYuDEmHO3+hcbvIsmyUKuSy9DpnQHq6jzBf/Xu4Lm2PmrSPXoe+84wLF9JGK5yHMOPIVa3bT5jSf96WlP4sUJ8S5gAnd+cXlt3wIrZkI7aUVmJo7ieAutsMqkf2zy/7xfvVrCMUfVqhqi/zHkLOv9VXCF6bCphGOqoUe967LUS11MAQPfff1ERfiPwED2reeHTVFnP0cjwYTQJ1ORKDD+vlDJshgAyVU+NHi+lVka6r48uANpHmJjYqJNJDZ+pcqS/LUAmP+YCIfRTtu7sbTK/stF1iUhhafy4z164t8joJWWDL0XD5E2/KiDLWAe1IgGtTykQ+av2QbWq18+FnR707t8F09SyUIT9TEeYFmb6Lcp6CN93INiIQalbYYjnYU5NqGyt+wV1g=----ATTACHMENT:----OTkyMDIzODYwOTc1MDY4MSA5ODc1NjgwOTE0MDYxOTg1IDc1NDgzNjA4NTIxNTY5MjU=