use PSR-7 for IP address middleware

Author: mevdschee

src/Tqdev/PhpCrudApi/Middleware/IpAddressMiddleware.php

@@ -22,15 +22,15 @@ public function __construct(Router $router, Responder $responder, array $propert
         $this->reflection = $reflection;
     }
 
-    private function callHandler($record, string $operation, ReflectedTable $table) /*: object */
+    private function callHandler(ServerRequestInterface $request, $record, string $operation, ReflectedTable $table) /*: object */
     {
         $context = (array) $record;
         $columnNames = $this->getProperty('columns', '');
         if ($columnNames) {
             foreach (explode(',', $columnNames) as $columnName) {
                 if ($table->hasColumn($columnName)) {
                     if ($operation == 'create') {
-                        $context[$columnName] = $_SERVER['REMOTE_ADDR'];
+                        $context[$columnName] = $this->getIpAddress($request);
                     } else {
                         unset($context[$columnName]);
                     }
@@ -40,6 +40,18 @@ private function callHandler($record, string $operation, ReflectedTable $table)
         return (object) $context;
     }
 
+    private function getIpAddress(ServerRequestInterface $request): string
+    {
+        $reverseProxy = $this->getProperty('reverseProxy', '');
+        if ($reverseProxy) {
+            $ipAddress = array_pop($request->getHeader('X-Forwarded-For'));
+        } else {
+            $serverParams = $request->getServerParams();
+            $ipAddress = $serverParams['REMOTE_ADDR'] ?? '127.0.0.1';
+        }
+        return $ipAddress;
+    }
+
     public function process(ServerRequestInterface $request, RequestHandlerInterface $next): ResponseInterface
     {
         $operation = RequestUtils::getOperation($request);
@@ -53,10 +65,10 @@ public function process(ServerRequestInterface $request, RequestHandlerInterface
                         $table = $this->reflection->getTable($tableName);
                         if (is_array($record)) {
                             foreach ($record as &$r) {
-                                $r = $this->callHandler($r, $operation, $table);
+                                $r = $this->callHandler($request, $r, $operation, $table);
                             }
                         } else {
-                            $record = $this->callHandler($record, $operation, $table);
+                            $record = $this->callHandler($request, $record, $operation, $table);
                         }
                         $request = $request->withParsedBody($record);
                     }