wip

Author: tobyzerner

composer.json

@@ -6,8 +6,7 @@
         "json-api-php/json-api": "^2.0",
         "psr/http-message": "^1.0",
         "psr/http-server-handler": "^1.0",
-        "spatie/macroable": "^1.0",
-        "zendframework/zend-diactoros": "^2.0"
+        "zendframework/zend-diactoros": "^2.1"
     },
     "license": "MIT",
     "authors": [

src/Adapter/EloquentAdapter.php

@@ -119,7 +119,28 @@ public function delete($model)
 
     public function filterByAttribute($query, Attribute $field, $value)
     {
-        $query->where($this->getAttributeProperty($field), $value);
+        $property = $this->getAttributeProperty($field);
+
+        if (preg_match('/(.+)\.\.(.+)/', $value, $matches)) {
+            if ($matches[1] !== '*') {
+                $query->where($property, '>=', $matches[1]);
+            }
+            if ($matches[2] !== '*') {
+                $query->where($property, '<=', $matches[2]);
+            }
+
+            return;
+        }
+
+        foreach (['>=', '>', '<=', '<'] as $operator) {
+            if (strpos($value, $operator) === 0) {
+                $query->where($property, $operator, substr($value, strlen($operator)));
+
+                return;
+            }
+        }
+
+        $query->where($property, $value);
     }
 
     public function filterByHasOne($query, HasOne $field, array $ids)

src/Api.php

@@ -123,12 +123,13 @@ public function handleError($e)
         }
 
         $errors = $e->getJsonApiErrors();
+        $status = $e->getJsonApiStatus();
 
         $data = new JsonApi\ErrorDocument(
             ...$errors
         );
 
-        return new JsonApiResponse($data);
+        return new JsonApiResponse($data, $status);
     }
 
     public function getBaseUrl(): string

src/ErrorProviderInterface.php

@@ -5,4 +5,6 @@
 interface ErrorProviderInterface
 {
     public function getJsonApiErrors(): array;
+
+    public function getJsonApiStatus(): string;
 }

src/Exception/BadRequestException.php

@@ -34,9 +34,14 @@ public function getJsonApiErrors(): array
         return [
             new Error(
                 new Error\Title('Bad Request'),
-                new Error\Status('400'),
+                new Error\Status($this->getJsonApiStatus()),
                 ...$members
             )
         ];
     }
+
+    public function getJsonApiStatus(): string
+    {
+        return '400';
+    }
 }

src/Exception/ForbiddenException.php

@@ -5,15 +5,20 @@
 use JsonApiPhp\JsonApi\Error;
 use Tobscure\JsonApiServer\ErrorProviderInterface;
 
-class BadRequestException extends \DomainException implements ErrorProviderInterface
+class ForbiddenException extends \DomainException implements ErrorProviderInterface
 {
     public function getJsonApiErrors(): array
     {
         return [
             new Error(
                 new Error\Title('Forbidden'),
-                new Error\Status('403')
+                new Error\Status($this->getJsonApiStatus())
             )
         ];
     }
+
+    public function getJsonApiStatus(): string
+    {
+        return '403';
+    }
 }

src/Exception/InternalServerErrorException.php

@@ -16,4 +16,9 @@ public function getJsonApiErrors(): array
             )
         ];
     }
+
+    public function getJsonApiStatus(): string
+    {
+        return '500';
+    }
 }

src/Exception/MethodNotAllowedException.php

@@ -5,7 +5,7 @@
 use JsonApiPhp\JsonApi\Error;
 use Tobscure\JsonApiServer\ErrorProviderInterface;
 
-class BadRequestException extends \DomainException implements ErrorProviderInterface
+class MethodNotAllowedException extends \DomainException implements ErrorProviderInterface
 {
     public function getJsonApiErrors(): array
     {

src/Handler/Concerns/SavesData.php

@@ -48,15 +48,15 @@ private function parseData($body): array
         $body = (array) $body;
 
         if (! isset($body['data'])) {
-            throw new BadRequestException;
+            throw new BadRequestException('Root data attribute missing');
         }
 
         if (isset($body['data']['attributes']) && ! is_array($body['data']['attributes'])) {
-            throw new BadRequestException;
+            throw new BadRequestException('data.attributes must be an object');
         }
 
         if (isset($body['data']['relationships']) && ! is_array($body['data']['relationships'])) {
-            throw new BadRequestException;
+            throw new BadRequestException('data.relationships must be an object');
         }
 
         return array_merge(

src/Handler/Index.php

@@ -127,6 +127,14 @@ private function buildUrl(Request $request, array $overrideParams = []): string
             unset($queryParams['page']['offset']);
         }
 
+        if (isset($queryParams['filter'])) {
+            foreach ($queryParams['filter'] as $k => &$v) {
+                if ($v === null) {
+                    $v = '';
+                }
+            }
+        }
+
         $queryString = http_build_query($queryParams);
 
         return $selfUrl.($queryString ? '?'.$queryString : '');