initial commit

Author: proggeler

.gitignore

@@ -0,0 +1,4 @@
+.idea
+vendor
+composer.lock
+.phpunit.result.cache

README.md

@@ -0,0 +1,4 @@
+# Http Request Middleware
+
+## Installation
+`composer require dmt-software/http-client-middleware`

composer.json

@@ -0,0 +1,31 @@
+{
+    "name": "dmt-software/http-client-middleware",
+    "description": "HTTP client request handler",
+    "type": "library",
+    "license": "MIT",
+    "authors": [
+        {
+            "name": "Bas de Mes",
+            "email": "bas@dmt-software.nl"
+        }
+    ],
+    "autoload": {
+        "psr-4": {
+            "DMT\\Http\\Client\\": "src/"
+        }
+    },
+    "require": {
+        "php": ">=7.4",
+        "psr/http-message": "^1.0",
+        "psr/http-client": "^1.0"
+    },
+    "autoload-dev": {
+        "psr-4": {
+            "DMT\\Test\\Http\\Client\\": "tests/"
+        }
+    },
+    "require-dev": {
+        "phpunit/phpunit": "^8.5 | ^9.5",
+        "guzzlehttp/guzzle": "^7.4"
+    }
+}

phpunit.xml

@@ -0,0 +1,22 @@
+<?xml version="1.0" encoding="UTF-8"?>
+
+<phpunit backupGlobals="false"
+         backupStaticAttributes="false"
+         bootstrap="vendor/autoload.php"
+         colors="true"
+         convertErrorsToExceptions="true"
+         convertNoticesToExceptions="true"
+         convertWarningsToExceptions="true"
+         processIsolation="false"
+         stopOnFailure="false">
+    <testsuites>
+        <testsuite name="Test Suite">
+            <directory>tests/</directory>
+        </testsuite>
+    </testsuites>
+    <filter>
+        <whitelist>
+            <directory>src/</directory>
+        </whitelist>
+    </filter>
+</phpunit>

src/MiddlewareInterface.php

@@ -0,0 +1,20 @@
+<?php
+
+namespace DMT\Http\Client;
+
+use Psr\Http\Client\ClientExceptionInterface;
+use Psr\Http\Message\RequestInterface;
+use Psr\Http\Message\ResponseInterface;
+
+interface MiddlewareInterface
+{
+    /**
+     * Process the request
+     *
+     * @param RequestInterface $request
+     * @param RequestHandlerInterface $handler
+     * @return ResponseInterface
+     * @throws ClientExceptionInterface
+     */
+    public function process(RequestInterface $request, RequestHandlerInterface $handler): ResponseInterface;
+}

src/RequestHandler.php

@@ -0,0 +1,41 @@
+<?php
+
+namespace DMT\Http\Client;
+
+use Psr\Http\Client\ClientExceptionInterface;
+use Psr\Http\Client\ClientInterface;
+use Psr\Http\Message\RequestInterface;
+use Psr\Http\Message\ResponseInterface;
+
+final class RequestHandler implements RequestHandlerInterface
+{
+    private ClientInterface $client;
+    /** @var MiddlewareInterface[]  */
+    private array $middleware = [];
+
+    /**
+     * @param ClientInterface $client
+     * @param MiddlewareInterface|null ...$middleware
+     */
+    public function __construct(ClientInterface $client, ?MiddlewareInterface ...$middleware)
+    {
+        $this->client = $client;
+        $this->middleware = $middleware;
+    }
+
+    /**
+     * Handle the client request.
+     *
+     * @param RequestInterface $request
+     * @return ResponseInterface
+     * @throws ClientExceptionInterface
+     */
+    public function handle(RequestInterface $request): ResponseInterface
+    {
+        while (count($this->middleware)) {
+            return array_shift($this->middleware)->process($request, $this);
+        }
+
+        return $this->client->sendRequest($request);
+    }
+}

src/RequestHandlerInterface.php

@@ -0,0 +1,19 @@
+<?php
+
+namespace DMT\Http\Client;
+
+use Psr\Http\Client\ClientExceptionInterface;
+use Psr\Http\Message\RequestInterface;
+use Psr\Http\Message\ResponseInterface;
+
+interface RequestHandlerInterface
+{
+    /**
+     * Handle the client request.
+     *
+     * @param RequestInterface $request
+     * @return ResponseInterface
+     * @throws ClientExceptionInterface
+     */
+    public function handle(RequestInterface $request): ResponseInterface;
+}

tests/RequestHandlerTest.php

@@ -0,0 +1,51 @@
+<?php
+
+namespace DMT\Test\Http\Client;
+
+use DMT\Http\Client\MiddlewareInterface;
+use DMT\Http\Client\RequestHandler;
+use DMT\Http\Client\RequestHandlerInterface;
+use GuzzleHttp\Client;
+use GuzzleHttp\Handler\MockHandler;
+use GuzzleHttp\HandlerStack;
+use GuzzleHttp\Psr7\Request;
+use GuzzleHttp\Psr7\Response;
+use PHPUnit\Framework\TestCase;
+use Psr\Http\Client\ClientInterface;
+use Psr\Http\Message\RequestInterface;
+use Psr\Http\Message\ResponseInterface;
+
+class RequestHandlerTest extends TestCase
+{
+    public function testHandle()
+    {
+        $response = (new RequestHandler($this->getClient()))->handle(new Request('GET', '/'));
+
+        $this->assertInstanceOf(ResponseInterface::class, $response);
+        $this->assertSame(200, $response->getStatusCode());
+    }
+
+    public function testHandleWithMiddleware()
+    {
+        $middleware = new class implements MiddlewareInterface {
+            public function process(RequestInterface $request, RequestHandlerInterface $handler): ResponseInterface
+            {
+                return $handler->handle($request)->withStatus(404);
+            }
+        };
+
+        $response = (new RequestHandler($this->getClient(), $middleware))->handle(new Request('GET', '/'));
+
+        $this->assertInstanceOf(ResponseInterface::class, $response);
+        $this->assertSame(404, $response->getStatusCode());
+    }
+
+    private function getClient(): ClientInterface
+    {
+        return new Client([
+            'handler' => HandlerStack::create(
+                new MockHandler([new Response()])
+            )
+        ]);
+    }
+}