feat: use http client with curl

.gitignore

@@ -6,3 +6,5 @@ composer.lock
 .phpunit.result.cache
 /build
 .vscode
+
+/coverage

composer.json

@@ -7,7 +7,8 @@
       "ext-curl": "*",
       "ext-json": "*",
       "ext-mbstring": "*",
-      "guzzlehttp/guzzle":"^7"
+    "psr/http-client": "^1.0",
+    "psr/http-message": "^2.0"
   },
     "require-dev": {
       "phpunit/phpunit": "^9",

src/Contracts/HttpClientInterface.php

@@ -3,7 +3,7 @@
 namespace Transbank\Contracts;
 
 use Psr\Http\Message\ResponseInterface;
-use GuzzleHttp\Exception\GuzzleException;
+use Transbank\Utils\Curl\Exceptions\CurlRequestException;
 
 interface HttpClientInterface
 {
@@ -13,7 +13,7 @@ interface HttpClientInterface
      * @param array|null $payload
      * @param array|null $options
      *
-     * @throws GuzzleException
+     * @throws CurlRequestException
      *
      * @return ResponseInterface
      */

src/PatpassComercio/Inscription.php

@@ -17,7 +17,7 @@
 use Transbank\Utils\RequestServiceTrait;
 use Transbank\Contracts\RequestService;
 use Transbank\PatpassComercio\Options;
-use GuzzleHttp\Exception\GuzzleException;
+use Transbank\Utils\Curl\Exceptions\CurlRequestException;
 
 class Inscription
 {
@@ -63,7 +63,7 @@ public function __construct(
      * @param string $city
      *
      * @throws InscriptionStartException
-     * @throws GuzzleException
+     * @throws CurlRequestException
      *
      * @return InscriptionStartResponse
      */
@@ -123,7 +123,7 @@ public function start(
      * @param string $token
      *
      * @throws InscriptionStatusException
-     * @throws GuzzleException
+     * @throws CurlRequestException
      *
      * @return InscriptionStatusResponse
      */

src/Utils/Curl/Client.php

@@ -0,0 +1,82 @@
+<?php
+
+namespace Transbank\Utils\Curl;
+
+use Psr\Http\Client\ClientInterface;
+use Psr\Http\Message\ResponseInterface;
+use Psr\Http\Message\RequestInterface;
+use Transbank\Utils\Curl\Exceptions\CurlRequestException;
+
+
+class Client implements ClientInterface
+{
+    private int $timeout;
+    public function __construct(int $timeout)
+    {
+        $this->timeout = $timeout;
+    }
+    public function sendRequest(RequestInterface $request): ResponseInterface
+    {
+        $curl = curl_init();
+
+        if (!$curl) {
+            throw new CurlRequestException('Unable to initialize cURL session.');
+        }
+
+        curl_setopt_array($curl, [
+            CURLOPT_URL => (string) $request->getUri(),
+            CURLOPT_CUSTOMREQUEST => $request->getMethod(),
+            CURLOPT_RETURNTRANSFER => true,
+            CURLOPT_HEADER => true,
+            CURLOPT_FOLLOWLOCATION => true,
+            CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
+            CURLOPT_TIMEOUT => $this->timeout,
+            CURLOPT_CONNECTTIMEOUT => $this->timeout,
+        ]);
+
+        $headers = [];
+        foreach ($request->getHeaders() as $name => $value) {
+            $headers[] = "$name: $value";
+        }
+        curl_setopt($curl, CURLOPT_HTTPHEADER, $headers);
+
+        $body = (string) $request->getBody();
+        if (!empty($body)) {
+            curl_setopt($curl, CURLOPT_POSTFIELDS, $body);
+        }
+
+        $response = curl_exec($curl);
+        if ($response === false) {
+            if (is_resource($curl)) {
+                curl_close($curl);
+            }
+            throw new CurlRequestException(curl_error($curl), curl_errno($curl));
+        }
+
+        $headerSize = curl_getinfo($curl, CURLINFO_HEADER_SIZE);
+        $statusCode = curl_getinfo($curl, CURLINFO_HTTP_CODE);
+        $rawHeaders = substr($response, 0, $headerSize);
+        $body = substr($response, $headerSize);
+
+        curl_close($curl);
+
+        $headers = $this->parseHeaders($rawHeaders);
+
+        return new Response($statusCode, $headers, $body);
+    }
+
+    private function parseHeaders(string $rawHeaders): array
+    {
+        $headers = [];
+        $lines = explode("\r\n", $rawHeaders);
+
+        foreach ($lines as $line) {
+            if (strpos($line, ':') !== false) {
+                list($name, $value) = explode(': ', $line, 2);
+                $headers[$name][] = $value;
+            }
+        }
+
+        return $headers;
+    }
+}

src/Utils/Curl/Exceptions/CurlRequestException.php

@@ -0,0 +1,24 @@
+<?php
+
+namespace Transbank\Utils\Curl\Exceptions;
+
+class CurlRequestException extends \Exception
+{
+    const DEFAULT_MESSAGE = 'An error happened on the request';
+
+    /**
+     * RequestException constructor.
+     *
+     * @param string $message
+     * @param \Throwable|null $previous
+     */
+    public function __construct(string $message = self::DEFAULT_MESSAGE, int $errorCode = 0, \Throwable|null $previous = null)
+    {
+        parent::__construct($message, $errorCode, $previous);
+    }
+
+    public function __toString(): string
+    {
+        return __CLASS__ . ": [error code {$this->code}]: {$this->message} in {$this->file} on line {$this->line}\n";
+    }
+}

src/Utils/Curl/Exceptions/StreamException.php

@@ -0,0 +1,19 @@
+<?php
+
+namespace Transbank\Utils\Curl\Exceptions;
+
+class StreamException extends \Exception
+{
+    const DEFAULT_MESSAGE = 'An error happened on the stream';
+
+    /**
+     * StreamException constructor.
+     *
+     * @param string $message
+     * @param \Throwable|null $previous
+     */
+    public function __construct(string $message = self::DEFAULT_MESSAGE, \Throwable|null $previous = null)
+    {
+        parent::__construct($message, 0, $previous);
+    }
+}

src/Utils/Curl/HttpCurlClient.php

@@ -0,0 +1,44 @@
+<?php
+
+namespace Transbank\Utils\Curl;
+
+use Composer\InstalledVersions;
+use Transbank\Contracts\HttpClientInterface;
+use Psr\Http\Message\ResponseInterface;
+
+
+class HttpCurlClient implements HttpClientInterface
+{
+    public function request(
+        string $method,
+        string $url,
+        array|null $payload = [],
+        array|null $options = null
+    ): ResponseInterface {
+        $installedVersion = 'unknown';
+
+        if (class_exists('\Composer\InstalledVersions') && InstalledVersions::isInstalled('transbank/transbank-sdk')) {
+            $installedVersion = InstalledVersions::getVersion('transbank/transbank-sdk') ?? 'unknown';
+        }
+
+        $baseHeaders = [
+            'Content-Type' => 'application/json',
+            'User-Agent'   => 'SDK-PHP/' . $installedVersion,
+        ];
+
+        $givenHeaders = $options['headers'] ?? [];
+        $headers = array_merge($baseHeaders, $givenHeaders);
+        if (!$payload) {
+            $payload = null;
+        }
+        if (is_array($payload)) {
+            $payload = json_encode($payload);
+        }
+
+        $requestTimeout = $options['timeout'] ?? 0;
+
+        $request = new Request($method, $url, $headers, $payload);
+        $client = new Client($requestTimeout);
+        return $client->sendRequest($request);
+    }
+}

src/Utils/Curl/MessageTrait.php

@@ -0,0 +1,63 @@
+<?php
+
+namespace Transbank\Utils\Curl;
+
+use Psr\Http\Message\StreamInterface;
+
+trait MessageTrait
+{
+    private string $protocolVersion = '1.1';
+    private array $headers = [];
+    private StreamInterface $body;
+
+    public function getProtocolVersion(): string
+    {
+        return $this->protocolVersion;
+    }
+
+    public function withProtocolVersion($version): static
+    {
+        $new = clone $this;
+        $new->protocolVersion = $version;
+        return $new;
+    }
+
+    public function getHeaders(): array
+    {
+        return $this->headers;
+    }
+
+    public function hasHeader($name): bool
+    {
+        return isset($this->headers[$name]);
+    }
+
+    public function getHeader($name): array
+    {
+        return isset($this->headers[$name]) ? [$this->headers[$name]] : [];
+    }
+
+    public function getHeaderLine($name): string
+    {
+        return implode(',', $this->getHeader($name));
+    }
+
+    public function withoutHeader($name): static
+    {
+        $new = clone $this;
+        unset($new->headers[$name]);
+        return $new;
+    }
+
+    public function getBody(): StreamInterface
+    {
+        return $this->body;
+    }
+
+    public function withBody(StreamInterface $body): static
+    {
+        $new = clone $this;
+        $new->body = $body;
+        return $new;
+    }
+}

src/Utils/Curl/Request.php

@@ -0,0 +1,92 @@
+<?php
+
+namespace Transbank\Utils\Curl;
+
+use Psr\Http\Message\RequestInterface;
+use Psr\Http\Message\UriInterface;
+use Psr\Http\Message\StreamInterface;
+
+class Request implements RequestInterface
+{
+    use MessageTrait;
+    private string $method;
+    private UriInterface|string $uri;
+    private string $requestTarget = '';
+
+    public function __construct(string $method, UriInterface|string $uri, array $headers = [], StreamInterface|string|null $body = null, string $protocolVersion = '1.1')
+    {
+        $this->method = $method;
+        $this->uri = is_string($uri) ? new Uri($uri) : $uri;
+        $this->body = $this->createBody($body);
+        $this->protocolVersion = $protocolVersion;
+        $this->headers = $headers;
+    }
+
+    public function getRequestTarget(): string
+    {
+        if ($this->requestTarget === '') {
+            $this->requestTarget = $this->uri->getPath() ?: '/';
+            if ($this->uri->getQuery()) {
+                $this->requestTarget .= '?' . $this->uri->getQuery();
+            }
+        }
+
+        return $this->requestTarget;
+    }
+
+    public function withRequestTarget($requestTarget): RequestInterface
+    {
+        $new = clone $this;
+        $new->requestTarget = $requestTarget;
+        return $new;
+    }
+
+    public function getMethod(): string
+    {
+        return $this->method;
+    }
+
+    public function withMethod($method): RequestInterface
+    {
+        $new = clone $this;
+        $new->method = $method;
+        return $new;
+    }
+
+    public function getUri(): UriInterface
+    {
+        return $this->uri;
+    }
+
+    public function withUri(UriInterface $uri, $preserveHost = false): RequestInterface
+    {
+        $new = clone $this;
+        $new->uri = $uri;
+
+        if (!$preserveHost || !$this->hasHeader('Host')) {
+            $new->headers['Host'] = [$uri->getHost()];
+        }
+
+        return $new;
+    }
+
+    public function withHeader($name, $value): RequestInterface
+    {
+        return clone $this;
+    }
+
+    public function withAddedHeader($name, $value): RequestInterface
+    {
+        return clone $this;
+    }
+
+    private function createBody($body = ''): StreamInterface
+    {
+        $resource = fopen('php://temp', 'rw+');
+        if (!empty($body)) {
+            fwrite($resource, $body);
+        }
+
+        return new Stream($resource);
+    }
+}