ApiClients\Middleware\Cache\Document

Complexity

Total Complexity

6

Size/Duplication

Total Lines	72
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

100%

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	__toString()	0	16	1
A	createFromString()	0	15	1
A	createFromResponse()	0	4	1
A	getResponse()	0	4	1
A	hasExpired()	0	4	1

<?php declare(strict_types=1);

namespace ApiClients\Middleware\Cache;

use Psr\Http\Message\ResponseInterface;
use RingCentral\Psr7\BufferStream;
use RingCentral\Psr7\Response;

final class Document
{
    /**
     * @var ResponseInterface
     */
    private $response;

    /**
     * @var int
     */
    private $expiresAt;

    private function __construct(ResponseInterface $response, int $expiresAt)
    {
        $this->response = $response;
        $this->expiresAt = $expiresAt;
    }

    public function __toString(): string
    {
        $contents = $this->response->getBody()->getContents();
        $stream = new BufferStream(\strlen($contents));
        $stream->write($contents);
        $this->response = $this->response->withBody($stream);

        return \json_encode([
            'status_code' => $this->response->getStatusCode(),
            'headers' => $this->response->getHeaders(),
            'body' => $contents,
            'protocol_version' => $this->response->getProtocolVersion(),
            'reason_phrase' => $this->response->getReasonPhrase(),
            'expires_at' => $this->expiresAt,
        ]);
    }

    public static function createFromString(string $json): self
    {
        $document = \json_decode($json, true);

        return new self(
            new Response(
                $document['status_code'],
                $document['headers'],
                $document['body'],
                $document['protocol_version'],
                $document['reason_phrase']
            ),
            $document['expires_at']
        );
    }

    public static function createFromResponse(ResponseInterface $response, int $ttl): self
    {
        return new self($response, \time() + $ttl);
    }

    /**
     * @return ResponseInterface
     */
    public function getResponse(): ResponseInterface
    {
        return $this->response;
    }

    /**
     * @return bool
     */
    public function hasExpired(): bool
    {
        return \time() >= $this->expiresAt;
    }
}