Conia\Chuck\ResponseFactory::createPsr7Stream()

Complexity

Conditions	4
Paths	3

Size

Total Lines	15
Code Lines	9

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	9
CRAP Score	4

Importance

Changes

0

1 Method

Rating	Name	Duplication	Size	Complexity
A	ResponseFactory::validateFile()	0	8	3

<?php

declare(strict_types=1);

namespace Conia\Chuck;

use Conia\Chuck\Exception\HttpNotFound;
use Conia\Chuck\Exception\RuntimeException;
use Conia\Chuck\Http\Factory;
use Conia\Chuck\Json;
use Conia\Chuck\Registry\Registry;
use Conia\Chuck\Response;
use finfo;
use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\StreamInterface;

class ResponseFactory
{
    public function __construct(protected Registry $registry)
    {
    }

    /**
     * @param null|resource|StreamInterface|string $body
     */
    public function create(
        int $code = 200,
        string $reasonPhrase = '',
    ): Response {
        return new Response($this->createPsr7Response($code, $reasonPhrase), $this->createHttpFactory());
    }

    /**
     * @param null|resource|StreamInterface|string $body
     */
    public function html(
        mixed $body = null,
        int $code = 200,
        string $reasonPhrase = '',
    ): Response {
        $psr7Response = $this->createPsr7Response($code, $reasonPhrase)->withAddedHeader(
            'Content-Type',
            'text/html'
        );

        if ($body) {
            $psr7Response = $psr7Response->withBody($this->createHttp($body));
        }

        return new Response($psr7Response, $this->createHttpFactory());
    }

    /**
     * @param null|resource|StreamInterface|string $body
     */
    public function text(
        mixed $body = null,
        int $code = 200,
        string $reasonPhrase = '',
    ): Response {
        $psr7Response = $this->createPsr7Response($code, $reasonPhrase)->withAddedHeader(
            'Content-Type',
            'text/plain'
        );

        if ($body) {
            $psr7Response = $psr7Response->withBody($this->createHttp($body));
        }

        return new Response($psr7Response, $this->createHttpFactory());
    }

    public function json(
        mixed $data,
        int $code = 200,
        string $reasonPhrase = '',
    ): Response {
        $psr7Response = $this->createPsr7Response($code, $reasonPhrase)->withAddedHeader(
            'Content-Type',
            'application/json'
        );

        $psr7Response = $psr7Response->withBody($this->createHttp(Json::encode($data)));

        return new Response($psr7Response, $this->createHttpFactory());
    }

    public function file(
        string $file,
        bool $throwNotFound = true,
        int $code = 200,
        string $reasonPhrase = '',
    ): Response {
        $this->validateFile($file, $throwNotFound);

        $finfo = new finfo(FILEINFO_MIME_TYPE);
        $contentType = $finfo->file($file);
        $finfo = new finfo(FILEINFO_MIME_ENCODING);
        $encoding = $finfo->file($file);

        $psr7Response = $this->createPsr7Response($code, $reasonPhrase)
            ->withAddedHeader('Content-Type', $contentType)
            ->withAddedHeader('Content-Transfer-Encoding', $encoding);

        $stream = $this->createHttpFactory()->streamFromFile($file, 'rb');
        $size = $stream->getSize();

        if (!is_null($size)) {
            $psr7Response = $psr7Response->withAddedHeader('Content-Length', (string)$size);
        }

        return new Response($psr7Response->withBody($stream), $this->createHttpFactory());
    }

    public function download(
        string $file,
        string $newName = '',
        bool $throwNotFound = true,
        int $code = 200,
        string $reasonPhrase = '',
    ): Response {
        $response = $this->file($file, $throwNotFound, $code, $reasonPhrase);
        $response->header(
            'Content-Disposition',
            'attachment; filename="' . ($newName ?: basename($file)) . '"'
        );

        return $response;
    }

    public function sendfile(
        string $file,
        bool $throwNotFound = true,
        int $code = 200,
        string $reasonPhrase = '',
    ): Response {
        $this->validateFile($file, $throwNotFound);
        $server = strtolower($_SERVER['SERVER_SOFTWARE'] ?? '');
        $psr7Response = $this->createPsr7Response($code, $reasonPhrase);

        if (strpos($server, 'nginx') !== false) {
            $psr7Response = $psr7Response->withAddedHeader('X-Accel-Redirect', $file);
        } else {
            $psr7Response = $psr7Response->withAddedHeader('X-Sendfile', $file);
        }

        return new Response($psr7Response, $this->createHttpFactory());
    }

    protected function createPsr7Response(
        int $code = 200,
        string $reasonPhrase = ''
    ): ResponseInterface {
        $response = $this->createHttpFactory()->response($code, $reasonPhrase);
        assert($response instanceof ResponseInterface);

        return $response;
    }

    protected function createHttpFactory(): Factory
    {
        $factory = $this->registry->get(Factory::class);
        assert($factory instanceof Factory);

        return $factory;
    }

    protected function createHttp(mixed $body): StreamInterface
    {
        $factory = $this->createHttpFactory();
        $stream = $factory->stream($body);
        assert($stream instanceof StreamInterface);

        return $stream;
    }

    protected function validateFile(string $file, bool $throwNotFound): void
    {
        if (!is_file($file)) {
            if ($throwNotFound) {
                throw new HttpNotFound();
            }

            throw new RuntimeException('File not found');
        }
    }
}