web-base/Core/API/Traits/Pagination.trait.php

<?php

namespace Core\API\Traits;

use Core\API\Parameter\IntegerType;
use Core\API\Parameter\StringType;
use Core\Driver\SQL\Condition\Condition;
use Core\Driver\SQL\SQL;
use Core\Objects\DatabaseEntity\Controller\DatabaseEntityHandler;
use Core\Objects\DatabaseEntity\Controller\DatabaseEntityQuery;

trait Pagination {

  function getPaginationParameters(array $orderColumns, string $defaultOrderBy = null,
                                   string $defaultSortOrder = "asc", int $maxPageSize = 100): array {
    $this->paginationOrderColumns = $orderColumns;
    $defaultOrderBy = $defaultOrderBy ?? current($orderColumns);

    return [
      'page' => new IntegerType('page', 1,PHP_INT_MAX, true, 1),
      'count' => new IntegerType('count', 1, $maxPageSize, true, 25),
      'orderBy' => new StringType('orderBy', -1, true, $defaultOrderBy, array_values($orderColumns)),
      'sortOrder' => new StringType('sortOrder', -1, true, $defaultSortOrder, ['asc', 'desc']),
    ];
  }

  function initPagination(SQL $sql, string $class, ?Condition $condition = null, ?array $joins = null): bool {
    $this->paginationClass = $class;
    $this->paginationCondition = $condition;
    $this->entityCount = call_user_func("$this->paginationClass::count", $sql, $condition, $joins);
    $this->pageSize = $this->getParam("count");
    $this->page = $this->getParam("page");
    if ($this->entityCount === false) {
      return $this->createError("Error fetching $this->paginationClass::count: " . $sql->getLastError());
    }

    $pageCount = intval(ceil($this->entityCount / $this->pageSize));
    $this->page = max(1, min($this->page, $pageCount)); // number of pages changed due to pageSize / filter

    $this->result["pagination"] = [
      "current" => $this->page,
      "pageSize" => $this->pageSize,
      "pageCount" => $pageCount,
      "total" => $this->entityCount
    ];

    return true;
  }

  function createPaginationQuery(SQL $sql, ?array $additionalValues = null, ?array $joins = null): DatabaseEntityQuery {
    $page = $this->getParam("page");
    $count = $this->getParam("count");
    $orderBy = $this->getParam("orderBy");
    $sortOrder = $this->getParam("sortOrder");

    $baseQuery = call_user_func("$this->paginationClass::createBuilder", $sql, false);
    $entityQuery = $baseQuery
      ->fetchEntities()
      ->limit($count)
      ->offset(($page - 1) * $count);

    if ($this->paginationCondition) {
      $entityQuery->where($this->paginationCondition);
    }

    if ($additionalValues) {
      foreach ($additionalValues as $additionalValue) {
        $entityQuery->addCustomValue($additionalValue);
      }
    }

    if ($joins) {
      foreach ($joins as $join) {
        $entityQuery->addJoin($join);
      }
    }

    if ($orderBy) {
      $sortColumn = array_search($orderBy, $this->paginationOrderColumns);
      if (is_string($sortColumn)) {
        $entityQuery->orderBy($sortColumn);
      } else {
        $handler = $baseQuery->getHandler();
        $baseTable = $handler->getTableName();
        $sortColumn = DatabaseEntityHandler::buildColumnName($orderBy);
        $fullyQualifiedColumn = "$baseTable.$sortColumn";
        $selectedColumns = $baseQuery->getSelectValues();
        if (in_array($sortColumn, $selectedColumns)) {
          $entityQuery->orderBy($sortColumn);
        } else if (in_array($fullyQualifiedColumn, $selectedColumns)) {
          $entityQuery->orderBy($fullyQualifiedColumn);
        } else {
          $entityQuery->orderBy($orderBy);
        }
      }
    }

    if ($sortOrder === "asc") {
      $entityQuery->ascending();
    } else {
      $entityQuery->descending();
    }

    return $entityQuery;
  }
}