HttpService.php

Go to the documentation of this file.

<?php
 
declare(strict_types=1);
 
namespace ILIAS\News\Common;
 
use ILIAS\Filesystem\Stream\Stream;
use ILIAS\Filesystem\Stream\Streams;
use ILIAS\HTTP\Services as IliasHttpServices;
use ILIAS\Refinery\Factory as Refinery;
use ILIAS\Refinery\Transformation;
use Psr\Http\Message\ServerRequestInterface;
 
class HttpService
{
    public const string KEY_REF_ID = 'ref_id';
 
    public const string ALL_OBJECTS = 'ALL_OBJECTS';
 
    public function __construct(
        private readonly IliasHttpServices $http,
        private readonly Refinery $refinery
    ) {
    }
 
    public function getRequest(): ServerRequestInterface
    {
        return $this->http->request();
    }
 
    public function getRefId(): int
    {
        return $this->get(self::KEY_REF_ID, $this->refinery->kindlyTo()->int());
    }
 
    public function resolveRowParameter(string $key): string|int
    {
        return $this->get(
            $key,
            $this->refinery->byTrying(
                [
                    $this->refinery->kindlyTo()->int(),
                    $this->refinery->kindlyTo()->string(),
                    $this->refinery->custom()->transformation(static fn(array $value): string|int => $value[0])
                ]
            )
        );
    }
 
    public function resolveRowParameters(string $key): array|string
    {
        return $this->get($key, $this->refinery->custom()->transformation(
            static fn(array|string $value): array|string => $value === self::ALL_OBJECTS || $value[0] === self::ALL_OBJECTS
                ? self::ALL_OBJECTS
                : array_map('intval', $value)
        )) ?? [];
    }
 
    public function get(string $key, Transformation $t): mixed
    {
        $wrapper = $this->http->wrapper();
 
        return match(true) {
            $wrapper->post()->has($key) => $wrapper->post()->retrieve($key, $t),
            $wrapper->query()->has($key) => $wrapper->query()->retrieve($key, $t),
            default => null,
        };
    }
 
    public function sendAsync(mixed $response): void
    {
        $response = match(true) {
            is_string($response) => Streams::ofString($response),
            is_resource($response) => Streams::ofResource($response),
            default => $response,
        };
 
        $this->http->saveResponse($this->http->response()->withBody($response));
        $this->http->sendResponse();
        $this->http->close();
    }
 
    public function has(string $key): bool
    {
        return $this->http->wrapper()->query()->has($key) || $this->http->wrapper()->post()->has($key);
    }
}