|(>=)|(<=)|(§))'; const PATTERN_VALUE = '[A-Za-z\p{L}\p{M}0-9*_.$#^| -\\\]+'; protected $OpenApiSpec = null; protected function ApiResponse(\Psr\Http\Message\ResponseInterface $response, $data, $cache = false) { if ($cache) { $response = $response->withHeader('Cache-Control', 'max-age=2592000'); } $response->getBody()->write(json_encode($data)); return $response; } protected function EmptyApiResponse(\Psr\Http\Message\ResponseInterface $response, $status = 204) { return $response->withStatus($status); } protected function GenericErrorResponse(\Psr\Http\Message\ResponseInterface $response, $errorMessage, $status = 400) { return $response->withStatus($status)->withJson([ 'error_message' => $errorMessage ]); } public function FilteredApiResponse(\Psr\Http\Message\ResponseInterface $response, Result $data, array $query) { $data = $this->queryData($data, $query); return $this->ApiResponse($response, $data); } protected function queryData(Result $data, array $query) { if (isset($query['query'])) { $data = $this->filter($data, $query['query']); } if (isset($query['limit'])) { $data = $data->limit(intval($query['limit']), intval($query['offset'] ?? 0)); } if (isset($query['order'])) { $parts = explode(':', $query['order']); if (count($parts) == 1) { $data = $data->orderBy($parts[0]); } else { if ($parts[1] != 'asc' && $parts[1] != 'desc') { throw new \Exception('Invalid sort order ' . $parts[1]); } $data = $data->orderBy($parts[0], $parts[1]); } } return $data; } protected function filter(Result $data, array $query): Result { foreach ($query as $q) { $matches = []; preg_match( '/(?P' . self::PATTERN_FIELD . ')' . '(?P' . self::PATTERN_OPERATOR . ')' . '(?P' . self::PATTERN_VALUE . ')/u', $q, $matches ); if (!array_key_exists('field', $matches) || !array_key_exists('op', $matches) || !array_key_exists('value', $matches)) { throw new \Exception('Invalid query'); } $sqlOrNull = ''; if (strtolower($matches['value']) == 'null') { $sqlOrNull = ' OR ' . $matches['field'] . ' IS NULL'; } switch ($matches['op']) { case '=': $data = $data->where($matches['field'] . ' = ?' . $sqlOrNull, $matches['value']); break; case '!=': $data = $data->where($matches['field'] . ' != ?' . $sqlOrNull, $matches['value']); break; case '~': $data = $data->where($matches['field'] . ' LIKE ?', '%' . $matches['value'] . '%'); break; case '!~': $data = $data->where($matches['field'] . ' NOT LIKE ?', '%' . $matches['value'] . '%'); break; case '<': $data = $data->where($matches['field'] . ' < ?', $matches['value']); break; case '>': $data = $data->where($matches['field'] . ' > ?', $matches['value']); break; case '>=': $data = $data->where($matches['field'] . ' >= ?', $matches['value']); break; case '<=': $data = $data->where($matches['field'] . ' <= ?', $matches['value']); break; case '§': $data = $data->where($matches['field'] . ' REGEXP ?', $matches['value']); break; } } return $data; } protected function getOpenApispec() { if ($this->OpenApiSpec == null) { $this->OpenApiSpec = json_decode(file_get_contents(__DIR__ . '/../grocy.openapi.json')); } return $this->OpenApiSpec; } }