ArrayAccessor facades for CLI & HTTP

Author: mlebkowski

src/Cli/InputParams.php

@@ -0,0 +1,39 @@
+<?php
+declare(strict_types=1);
+
+namespace WonderNetwork\SlimKernel\Cli;
+
+use RuntimeException;
+use Symfony\Component\Console\Input\InputInterface;
+use WonderNetwork\SlimKernel\Accessor\ArrayAccessor;
+
+/**
+ * @property ArrayAccessor $arguments
+ * @property ArrayAccessor $options
+ */
+final class InputParams {
+    private ArrayAccessor $arguments;
+    private ArrayAccessor $options;
+
+    public static function ofInput(InputInterface $input): self {
+        return new self(
+            ArrayAccessor::of($input->getArguments()),
+            ArrayAccessor::of($input->getOptions()),
+        );
+    }
+
+    public function __construct(ArrayAccessor $arguments, ArrayAccessor $options) {
+        $this->arguments = $arguments;
+        $this->options = $options;
+    }
+
+    public function __get(string $name): ArrayAccessor {
+        switch ($name) {
+            case 'arguments':
+                return $this->arguments;
+            case 'options':
+                return $this->options;
+        }
+        throw new RuntimeException("Unknown collection: $name");
+    }
+}

src/Http/RequestParams.php

@@ -0,0 +1,64 @@
+<?php
+declare(strict_types=1);
+
+namespace WonderNetwork\SlimKernel\Http;
+
+use Psr\Http\Message\ServerRequestInterface;
+use RuntimeException;
+use Slim\Exception\HttpBadRequestException;
+use Slim\Exception\HttpNotFoundException;
+use WonderNetwork\SlimKernel\Accessor\ArrayAccessor;
+
+/**
+ * @property ArrayAccessor $params
+ * @property ArrayAccessor $query
+ * @property ArrayAccessor $server
+ */
+final class RequestParams {
+    private ArrayAccessor $params;
+    private ArrayAccessor $query;
+    private ArrayAccessor $server;
+    private ServerRequestInterface $request;
+
+    public static function of(ServerRequestInterface $request): self {
+        return new self($request);
+    }
+
+    public function __construct(ServerRequestInterface $request) {
+        $this->params = ArrayAccessor::of($request->getParsedBody(), [$this, 'exceptionFactory']);
+        $this->query = ArrayAccessor::of($request->getQueryParams(), [$this, 'exceptionFactory']);
+        $this->server = ArrayAccessor::of($request->getServerParams(), [$this, 'exceptionFactory']);
+        $this->request = $request;
+    }
+
+    public function exceptionFactory(string $message): HttpBadRequestException {
+        return new HttpBadRequestException($this->request, $message);
+    }
+
+    public function __get(string $name): ArrayAccessor {
+        switch ($name) {
+            case 'params':
+                return $this->params;
+            case 'query':
+                return $this->query;
+            case 'server':
+                return $this->server;
+        }
+
+        throw new RuntimeException("Unknown collection: $name");
+    }
+
+    /** @return never */
+    public function notFound(string $message = null): void {
+        throw new HttpNotFoundException($this->request, $message);
+    }
+
+    /** @return never */
+    public function badRequest(string $message = null): void {
+        throw new HttpBadRequestException($this->request, $message);
+    }
+
+    public function request(): ServerRequestInterface {
+        return $this->request;
+    }
+}

src/Http/RouteArgument.php

@@ -0,0 +1,33 @@
+<?php
+declare(strict_types=1);
+
+namespace WonderNetwork\SlimKernel\Http;
+
+use Psr\Http\Message\ServerRequestInterface;
+use Slim\Exception\HttpBadRequestException;
+use Slim\Routing\RouteContext;
+
+final class RouteArgument {
+    public static function maybe(ServerRequestInterface $request, string $name): string {
+        return self::find($request, $name) ?? '';
+    }
+
+    public static function find(ServerRequestInterface $request, string $name): ?string {
+        $route = RouteContext::fromRequest($request)->getRoute();
+        if (null === $route) {
+            throw new HttpBadRequestException(
+                $request,
+                "Route is not initialized on request while accessing $name",
+            );
+        }
+        return $route->getArgument($name);
+    }
+
+    public static function get(ServerRequestInterface $request, string $name): string {
+        $value = self::find($request, $name);
+        if (null === $value) {
+            throw new HttpBadRequestException($request, "Route argument $name not found");
+        }
+        return $value;
+    }
+}