1 files changed, 200 insertions, 0 deletions
diff --git a/libs/jsonrpc/src/JsonRPC/Request/RequestParser.php b/libs/jsonrpc/src/JsonRPC/Request/RequestParser.php
new file mode 100644
index 00000000..ea1b7d43
--- /dev/null
+++ b/libs/jsonrpc/src/JsonRPC/Request/RequestParser.php
@@ -0,0 +1,200 @@
+<?php
+
+namespace JsonRPC\Request;
+
+use Exception;
+use JsonRPC\Exception\AccessDeniedException;
+use JsonRPC\Exception\AuthenticationFailureException;
+use JsonRPC\Exception\InvalidJsonRpcFormatException;
+use JsonRPC\MiddlewareHandler;
+use JsonRPC\ProcedureHandler;
+use JsonRPC\Response\ResponseBuilder;
+use JsonRPC\Validator\JsonFormatValidator;
+use JsonRPC\Validator\RpcFormatValidator;
+
+/**
+ * Class RequestParser
+ *
+ * @package JsonRPC
+ * @author  Frederic Guillot
+ */
+class RequestParser
+{
+    /**
+     * Request payload
+     *
+     * @access protected
+     * @var mixed
+     */
+    protected $payload;
+
+    /**
+     * List of exceptions that should not be relayed to the client
+     *
+     * @access protected
+     * @var array()
+     */
+    protected $localExceptions = array(
+        'JsonRPC\Exception\AuthenticationFailureException',
+        'JsonRPC\Exception\AccessDeniedException',
+    );
+
+    /**
+     * ProcedureHandler
+     *
+     * @access protected
+     * @var ProcedureHandler
+     */
+    protected $procedureHandler;
+
+    /**
+     * MiddlewareHandler
+     *
+     * @access protected
+     * @var MiddlewareHandler
+     */
+    protected $middlewareHandler;
+
+    /**
+     * Get new object instance
+     *
+     * @static
+     * @access public
+     * @return RequestParser
+     */
+    public static function create()
+    {
+        return new static();
+    }
+
+    /**
+     * Set payload
+     *
+     * @access public
+     * @param  mixed $payload
+     * @return $this
+     */
+    public function withPayload($payload)
+    {
+        $this->payload = $payload;
+        return $this;
+    }
+
+    /**
+     * Exception classes that should not be relayed to the client
+     *
+     * @access public
+     * @param  mixed $exception
+     * @return $this
+     */
+    public function withLocalException($exception)
+    {
+        if (is_array($exception)) {
+            $this->localExceptions = array_merge($this->localExceptions, $exception);
+        } else {
+            $this->localExceptions[] = $exception;
+        }
+        
+        return $this;
+    }
+
+    /**
+     * Set procedure handler
+     *
+     * @access public
+     * @param  ProcedureHandler $procedureHandler
+     * @return $this
+     */
+    public function withProcedureHandler(ProcedureHandler $procedureHandler)
+    {
+        $this->procedureHandler = $procedureHandler;
+        return $this;
+    }
+
+    /**
+     * Set middleware handler
+     *
+     * @access public
+     * @param  MiddlewareHandler $middlewareHandler
+     * @return $this
+     */
+    public function withMiddlewareHandler(MiddlewareHandler $middlewareHandler)
+    {
+        $this->middlewareHandler = $middlewareHandler;
+        return $this;
+    }
+
+    /**
+     * Parse incoming request
+     *
+     * @access public
+     * @return string
+     * @throws AccessDeniedException
+     * @throws AuthenticationFailureException
+     */
+    public function parse()
+    {
+        try {
+
+            JsonFormatValidator::validate($this->payload);
+            RpcFormatValidator::validate($this->payload);
+
+            $this->middlewareHandler
+                ->withProcedure($this->payload['method'])
+                ->execute();
+
+            $result = $this->procedureHandler->executeProcedure(
+                $this->payload['method'],
+                empty($this->payload['params']) ? array() : $this->payload['params']
+            );
+
+            if (! $this->isNotification()) {
+                return ResponseBuilder::create()
+                    ->withId($this->payload['id'])
+                    ->withResult($result)
+                    ->build();
+            }
+        } catch (Exception $e) {
+            return $this->handleExceptions($e);
+        }
+
+        return '';
+    }
+
+    /**
+     * Handle exceptions
+     *
+     * @access protected
+     * @param  Exception $e
+     * @return string
+     * @throws Exception
+     */
+    protected function handleExceptions(Exception $e)
+    {
+        foreach ($this->localExceptions as $exception) {
+            if ($e instanceof $exception) {
+                throw $e;
+            }
+        }
+
+        if ($e instanceof InvalidJsonRpcFormatException || ! $this->isNotification()) {
+            return ResponseBuilder::create()
+                ->withId(isset($this->payload['id']) ? $this->payload['id'] : null)
+                ->withException($e)
+                ->build();
+        }
+
+        return '';
+    }
+
+    /**
+     * Return true if the message is a notification
+     *
+     * @access protected
+     * @return bool
+     */
+    protected function isNotification()
+    {
+        return is_array($this->payload) && !isset($this->payload['id']);
+    }
+}