TheCodingMachine\Gotenberg\Client

Complexity

Total Complexity

11

Size/Duplication

Total Lines	88
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	2
A	store()	0	11	2
A	handleResponse()	0	7	2
A	post()	0	3	1
A	makeMultipartFormDataRequest()	0	31	4

<?php

declare(strict_types=1);

namespace TheCodingMachine\Gotenberg;

use Exception;
use GuzzleHttp\Psr7\MultipartStream;
use Http\Client\HttpClient;
use Http\Discovery\HttpClientDiscovery;
use Http\Discovery\MessageFactoryDiscovery;
use Psr\Http\Message\RequestInterface;
use Psr\Http\Message\ResponseInterface;
use function assert;
use function fclose;
use function fopen;
use function fwrite;
use function is_resource;

final class Client
{
    /** @var HttpClient */
    private $client;

    /** @var string */
    private $apiURL;

    public function __construct(string $apiURL, ?HttpClient $client = null)
    {
        $this->apiURL = $apiURL;
        $this->client = $client ?: HttpClientDiscovery::find();
    }

    /**
     * Sends the given documents to the API and returns the response.
     *
     * @throws ClientException
     * @throws Exception
     */
    public function post(GotenbergRequestInterface $request): ResponseInterface
    {
        return $this->handleResponse($this->client->sendRequest($this->makeMultipartFormDataRequest($request)));
    }

    /**
     * Sends the given documents to the API, stores the resulting PDF in the given destination.
     *
     * @throws ClientException
     * @throws RequestException
     * @throws Exception
     */
    public function store(GotenbergRequestInterface $request, string $destination): void
    {
        if ($request->hasWebhook()) {
            throw new RequestException('Cannot use method store with a webhook.');
        }
        $response = $this->handleResponse($this->client->sendRequest($this->makeMultipartFormDataRequest($request)));
        $fileStream = $response->getBody();
        $fp = fopen($destination, 'w');
        assert(is_resource($fp));
        fwrite($fp, $fileStream->getContents());
        fclose($fp);
    }

    private function makeMultipartFormDataRequest(GotenbergRequestInterface $request): RequestInterface
    {
        $multipartData = [];
        foreach ($request->getFormValues() as $fieldName => $fieldValue) {
            $multipartData[] = [
                'name' => $fieldName,
                'contents' => $fieldValue,
            ];
        }
        /**
         * @var string $filename
         * @var Document $document
         */
        foreach ($request->getFormFiles() as $filename => $document) {
            $multipartData[] = [
                'name' => 'files',
                'filename' => $filename,
                'contents' => $document->getFileStream(),
            ];
        }
        $body = new MultipartStream($multipartData);
        $messageFactory = MessageFactoryDiscovery::find();
        $message = $messageFactory
            ->createRequest('POST', $this->apiURL . $request->getPostURL())
            ->withHeader('Content-Type', 'multipart/form-data; boundary="' . $body->getBoundary() . '"')
            ->withBody($body);
        foreach ($request->getCustomHTTPHeaders() as $key => $value) {
            $message = $message->withHeader($key, $value);
        }

        return $message;
    }

    /**
     * @throws ClientException
     */
    private function handleResponse(ResponseInterface $response): ResponseInterface
    {
        switch ($response->getStatusCode()) {
            case 200:
                return $response;
            default:
                throw new ClientException($response->getBody()->getContents(), $response->getStatusCode());
        }
    }
}