ADDED TEST: PSR Adapters.

Author: hsehszroc

Src/PipelineBridge.php

@@ -77,9 +77,9 @@ public static function toMiddleware( mixed $middleware ): object {
 			if ( null === $middleware ) {
 				throw new TypeError(
 					sprintf(
-						'Non-existing class "%1$s". Middleware must be a Closure, an instance of %2$s'
-						. ' or classname of a class that implements %2$s.',
-						$provided,
+						'Invalid or Non-existing class "%1$s". Middleware must be a Closure, an'
+						. ' instance of %2$sor classname of a class that implements %2$s.',
+						$isClassName ? $provided : $provided::class,
 						$interface
 					)
 				);

Tests/BridgeTest.php

@@ -0,0 +1,67 @@
+<?php
+/**
+ * Pipeline bridge test.
+ *
+ * @package TheWebSolver\Codegarage\Test
+ */
+
+declare( strict_types = 1 );
+
+namespace TheWebSolver\Codegarage\Lib;
+
+use MiddlewareAdapter;
+use PHPUnit\Framework\TestCase;
+use TheWebSolver\Codegarage\Lib\PipelineBridge;
+use TheWebSolver\Codegarage\Lib\Psr7Adapter\Request;
+use TheWebSolver\Codegarage\Lib\Psr7Adapter\Response;
+use TheWebSolver\Codegarage\Lib\Psr15Adapter\Middleware;
+use TheWebSolver\Codegarage\Lib\Psr7Adapter\ResponseInterface;
+use TheWebSolver\Codegarage\Lib\Psr15Adapter\MiddlewareInterface;
+use TheWebSolver\Codegarage\Lib\Psr7Adapter\ServerRequestInterface;
+use TheWebSolver\Codegarage\Lib\Psr15Adapter\RequestHandlerInterface;
+
+class BridgeTest extends TestCase {
+	protected function setUp(): void {
+		require_once __DIR__ . '/Stub/PsrStubs.php';
+	}
+
+	public function testPSRBridge() {
+		PipelineBridge::setMiddlewareAdapter(
+			interface: MiddlewareInterface::class,
+			className: MiddlewareAdapter::class
+		);
+
+		$request = new Request();
+		$handler = new class() implements RequestHandlerInterface {
+			public function handle( ServerRequestInterface $request ): ResponseInterface {
+				$middlewares[] = Middleware::class;
+				$middlewares[] = static fn ( ServerRequestInterface $request, RequestHandlerInterface $h )
+					=> $request
+						->getAttribute( PipelineBridge::MIDDLEWARE_RESPONSE )
+						->withStatus( code: 300 );
+
+				$middlewares[] = new class() implements MiddlewareInterface {
+					public function process(
+						ServerRequestInterface $request,
+						RequestHandlerInterface $handler
+					): ResponseInterface {
+						$response = $request
+						->getAttribute( PipelineBridge::MIDDLEWARE_RESPONSE )
+						->withStatus( code: 350 );
+
+						return $response;
+					}
+				};
+
+				return ( new Pipeline() )
+					->use( $request, $this )
+					->send( subject: ( new Response() )->withStatus( code: 100 ) )
+					->through(
+						pipes: array_map( fn( $m ) => PipelineBridge::middlewareToPipe( $m ), $middlewares )
+					)->thenReturn();
+			}
+		};
+
+		$this->assertSame( expected: 350, actual: $handler->handle( $request )->getStatusCode() );
+	}
+}

Tests/Stub/PsrStubs.php

@@ -0,0 +1,101 @@
+<?php
+/**
+ * Stub adapters for PSR7 and PSR15.
+ *
+ * @package TheWebSolver\Codegarage\Test
+ *
+ * @phpcs:disable Universal.Namespaces.DisallowCurlyBraceSyntax.Forbidden
+ * @phpcs:disable Generic.Files.OneObjectStructurePerFile.MultipleFound
+ * @phpcs:disable Universal.Namespaces.OneDeclarationPerFile.MultipleFound
+ * @phpcs:disable Universal.Namespaces.DisallowDeclarationWithoutName.Forbidden
+ */
+
+declare( strict_types = 1 );
+
+namespace TheWebSolver\Codegarage\Lib\Psr7Adapter {
+	interface ServerRequestInterface {
+		public function withAttribute( string $name, mixed $value ): static;
+		public function getAttribute( string $name, mixed $default = null ): mixed;
+	}
+
+	interface ResponseInterface {
+		public function withStatus( int $code ): static;
+		public function getStatusCode(): int;
+	}
+
+	class Request implements ServerRequestInterface {
+		/** @var array<string,mixed> */
+		private array $attribute;
+
+		public function withAttribute( string $name, mixed $value ): static {
+			$new                     = clone $this;
+			$new->attribute[ $name ] = $value;
+
+			return $new;
+		}
+
+		public function getAttribute( string $name, mixed $default = null ): mixed {
+			return $this->attribute[ $name ] ?? $default;
+		}
+	}
+
+	class Response implements ResponseInterface {
+		private int $statusCode;
+
+		public function withStatus( int $code ): static {
+			$new             = clone $this;
+			$new->statusCode = $code;
+
+			return $new;
+		}
+
+		public function getStatusCode(): int {
+			return $this->statusCode;
+		}
+	}
+}
+
+namespace TheWebSolver\Codegarage\Lib\Psr15Adapter {
+	use TheWebSolver\Codegarage\Lib\PipelineBridge;
+	use TheWebSolver\Codegarage\Lib\Psr7Adapter\{ ServerRequestInterface, ResponseInterface };
+
+	interface RequestHandlerInterface {
+		public function handle( ServerRequestInterface $request ): ResponseInterface;
+	}
+
+	interface MiddlewareInterface {
+		public function process(
+			ServerRequestInterface $request,
+			RequestHandlerInterface $handler
+		): ResponseInterface;
+	}
+
+	class Middleware implements MiddlewareInterface {
+		public function process(
+			ServerRequestInterface $request,
+			RequestHandlerInterface $handler
+		): ResponseInterface {
+			$response = $request
+				->getAttribute( name: PipelineBridge::MIDDLEWARE_RESPONSE )
+				->withStatus( code: 200 );
+
+			return $response;
+		}
+	}
+}
+
+namespace {
+	use TheWebSolver\Codegarage\Lib\Psr7Adapter\{ ServerRequestInterface, ResponseInterface };
+	use TheWebSolver\Codegarage\Lib\Psr15Adapter\{ MiddlewareInterface, RequestHandlerInterface };
+
+	class MiddlewareAdapter implements MiddlewareInterface {
+		public function __construct( private readonly \Closure $middleware ) {}
+
+		public function process(
+			ServerRequestInterface $request,
+			RequestHandlerInterface $handler
+		): ResponseInterface {
+			return ( $this->middleware )( $request, $handler );
+		}
+	}
+}