LunixREST\Server\HTTPServer

Complexity

Total Complexity

14

Size/Duplication

Total Lines	83
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	6

Test Coverage

Coverage

0%

Importance

Changes	2
Bugs	0	Features	1

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
D	handleRequest()	0	34	9
A	dumpResponse()	0	16	4

<?php
namespace LunixREST\Server;

use LunixREST\Endpoint\Exceptions\UnknownEndpointException;
use LunixREST\Exceptions\AccessDeniedException;
use LunixREST\Exceptions\InvalidAPIKeyException;
use LunixREST\Exceptions\ThrottleLimitExceededException;
use LunixREST\APIRequest\RequestFactory\RequestFactory;
use LunixREST\APIRequest\URLParser\Exceptions\InvalidRequestURLException;
use LunixREST\APIResponse\Exceptions\NotAcceptableResponseTypeException;
use LunixREST\Server\Exceptions\MethodNotFoundException;
use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\ServerRequestInterface;

class HTTPServer
{
    /**
     * @var Server
     */
    protected $server;
    /**
     * @var RequestFactory
     */
    private $requestFactory;

    /**
     * HTTPServer constructor.
     * @param Server $server
     * @param RequestFactory $requestFactory
     */
    //TODO: Add RequestLogger that we can pass through to log requests
    //TODO: Add ErrorLogger to log errors (500s)
    public function __construct(Server $server, RequestFactory $requestFactory)
    {
        $this->server = $server;
        $this->requestFactory = $requestFactory;
    }

    /**
     * clones a response, changing contents based on the handling of a given request
     * Taking in a response allows us not to define a specific response implementation to create
     * @param ServerRequestInterface $serverRequest
     * @param ResponseInterface $response
     * @return ResponseInterface
     */
    public function handleRequest(ServerRequestInterface $serverRequest, ResponseInterface $response): ResponseInterface
    {
        $response = $response->withProtocolVersion($serverRequest->getProtocolVersion());

        try {
            $APIRequest = $this->requestFactory->create($serverRequest);

            try {
                $APIResponse = $this->server->handleRequest($APIRequest);

                $response = $response->withStatus(200, "200 OK");
                $response = $response->withAddedHeader("Content-Type", $APIResponse->getMIMEType());
                $response = $response->withAddedHeader("Content-Length", $APIResponse->getAsDataStream()->getSize());
                $response = $response->withBody($APIResponse->getAsDataStream());
            } catch (InvalidAPIKeyException $e) {
                $response = $response->withStatus(400, "400 Bad Request");
            } catch (UnknownEndpointException $e) {
                $response = $response->withStatus(404, "404 Not Found");
            } catch (NotAcceptableResponseTypeException $e) {
                $response = $response->withStatus(406, "406 Not Acceptable");
            } catch (AccessDeniedException $e) {
                $response = $response->withStatus(403, "403 Access Denied");
            } catch (ThrottleLimitExceededException $e) {
                $response = $response->withStatus(429, "429 Too Many Requests");
            } catch (MethodNotFoundException | \Throwable $e) {

The class Throwable does not exist. Did you forget a USE statement, or did you not list all dependencies?

                $response = $response->withStatus(500, "500 Internal Server Error");
            }
        } catch (InvalidRequestURLException $e) {
            $response = $response->withStatus(400, "400 Bad Request");
        } catch (MethodNotFoundException | \Throwable $e) {

The class Throwable does not exist. Did you forget a USE statement, or did you not list all dependencies?

            $response = $response->withStatus(500, "500 Internal Server Error");
        }
        return $response;
    }

    public function dumpResponse(ResponseInterface $response) {
        header(sprintf("HTTP/%s", $response->getProtocolVersion()));

        header($response->getReasonPhrase(), true, $response->getStatusCode());

        foreach ($response->getHeaders() as $name => $values) {
            foreach ($values as $value) {
                header(sprintf('%s: %s', $name, $value), false);
            }
        }

        $body = $response->getBody();
        while(!$body->eof()) {
            echo $body->read(1024);
        }
    }
}