Server::run() - Code Metrics - Veejayspb/jsonrpc - Measure and Improve Code Quality continuously with Scrutinizer

Server::run() C
last analyzed 2021-02-22 18:27 UTC

↳ Parent: Server

Complexity

Conditions	14
Paths	69

Size

Total Lines	41
Code Lines	26

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
cc	14
eloc	26
c	1
b	0
f	0
nc	69
nop	0
dl	0
loc	41
rs	6.2666

How to fix Complexity

<?php

namespace veejay\jsonrpc;

use Error;
use veejay\jsonrpc\batch\Request;
use veejay\jsonrpc\batch\Response;
use veejay\jsonrpc\exception\Exception;

class Server
{
    /**
     * Api for responses.
     * @var Api
     */
    protected $api;

    /**
     * Max amount of requests.
     * 0 - unlimited.
     * @var int|null
     */
    protected $limit;

    /**
     * @param Api $api
     * @param int $limit
     */
    public function __construct(Api $api, int $limit = 0)
    {
        $this->api = $api;
        $this->limit = $limit;
    }

    /**
     * Run server.
     * @return string
     */
    public function run()
    {
        try {
            $data = $this->getData();
            $multiple = is_array($data);
            if (is_object($data)) {
                $data = [$data];
            }

            if (empty($data)) {
                throw new Exception(Response::INVALID_REQUEST);
            } elseif ($this->limit !== 0 && $this->limit < count($data)) {
                throw new Exception(Response::LIMIT_EXCEEDED);
            }

            $responses = [];
            foreach ((array)$data as $datum) {
                $request = (new Request)->setProperties($datum);
                $response = $this->getResponse($request);
                if ($response->isNotification() && !$response->hasError()) {
                    continue;
                }
                $responses[] = $response->getData();
            }

            // Check if ID already exists
            $ids = [];
            foreach ($responses as $response) {
                if ($response->id === null) continue;
                if (in_array($response->id, $ids, true)) {
                    throw new Exception(Response::DUPLICATED_ID);
                }
                array_push($ids, $response->id);
            }

        } catch (Exception $exception) {
            return (string)$exception;
        }

        if (empty($responses)) return '';
        return json_encode($multiple ? $responses : current($responses));
    }

    /**
     * Create Response object for Request.
     * @param Request $request
     * @return Response
     */
    protected function getResponse(Request $request): Response
    {
        $response = new Response;
        $response->jsonrpc = Response::VERSION;
        $response->id = $request->id;

        $this->validate($request, $response);
        if ($response->hasError()) {
            return $response;
        }

        try {
            $response->result = call_user_func_array([$this->api, $request->method], [(array)$request->params]);
        } catch (Exception $e) {
            $response->setError($e->getCode(), $e->getMessage());
        } catch (Error $e) {
            $response->setError(Response::INTERNAL_ERROR);
        }

        return $response;
    }

    /**
     * Validate Request and set error.
     * @param Request $request
     * @param Response $response
     * @return void
     */
    protected function validate(Request $request, Response $response)
    {
        $type = gettype($request->id);
        if (
            $request->jsonrpc !== Response::VERSION ||
            !is_string($request->method) ||
            !in_array($type, ['NULL', 'integer', 'string'])
        ) {
            $response->setError(Response::INVALID_REQUEST);
        } elseif (!is_array($request->params) && !is_object($request->params) && !is_null($request->params)) {
            $response->setError(Response::INVALID_PARAMS);
        }
    }

    /**
     * Get data from request.
     * @return mixed
     * @throws Exception
     */
    protected function getData()
    {
        $content = $this->getRawContent();
        $data = is_string($content) ? @json_decode($content) : null;
        if ($data === null) {
            throw new Exception(Response::PARSE_ERROR);
        }
        return $data;
    }

    /**
     * Read raw content.
     * @return string|false
     */
    protected function getRawContent()
    {
        return @file_get_contents('php://input');
    }
}


1			<?php
2
3			namespace veejay\jsonrpc;
4
5			use Error;
6			use veejay\jsonrpc\batch\Request;
7			use veejay\jsonrpc\batch\Response;
8			use veejay\jsonrpc\exception\Exception;
9
10			class Server
11			{
12			/**
13			* Api for responses.
14			* @var Api
15			*/
16			protected $api;
17
18			/**
19			* Max amount of requests.
20			* 0 - unlimited.
21			* @var int\|null
22			*/
23			protected $limit;
24
25			/**
26			* @param Api $api
27			* @param int $limit
28			*/
29			public function __construct(Api $api, int $limit = 0)
30			{
31			$this->api = $api;
32			$this->limit = $limit;
33			}
34
35			/**
36			* Run server.
37			* @return string
38			*/
39			public function run()
40			{
41			try {
42			$data = $this->getData();
43			$multiple = is_array($data);
44			if (is_object($data)) {
45			$data = [$data];
46			}
47
48			if (empty($data)) {
49			throw new Exception(Response::INVALID_REQUEST);
50			} elseif ($this->limit !== 0 && $this->limit < count($data)) {
51			throw new Exception(Response::LIMIT_EXCEEDED);
52			}
53
54			$responses = [];
55			foreach ((array)$data as $datum) {
56			$request = (new Request)->setProperties($datum);
57			$response = $this->getResponse($request);
58			if ($response->isNotification() && !$response->hasError()) {
59			continue;
60			}
61			$responses[] = $response->getData();
62			}
63
64			// Check if ID already exists
65			$ids = [];
66			foreach ($responses as $response) {
67			if ($response->id === null) continue;
68			if (in_array($response->id, $ids, true)) {
69			throw new Exception(Response::DUPLICATED_ID);
70			}
71			array_push($ids, $response->id);
72			}
73
74			} catch (Exception $exception) {
75			return (string)$exception;
76			}
77
78			if (empty($responses)) return '';
79			return json_encode($multiple ? $responses : current($responses));
80			}
81
82			/**
83			* Create Response object for Request.
84			* @param Request $request
85			* @return Response
86			*/
87			protected function getResponse(Request $request): Response
88			{
89			$response = new Response;
90			$response->jsonrpc = Response::VERSION;
91			$response->id = $request->id;
92
93			$this->validate($request, $response);
94			if ($response->hasError()) {
95			return $response;
96			}
97
98			try {
99			$response->result = call_user_func_array([$this->api, $request->method], [(array)$request->params]);
100			} catch (Exception $e) {
101			$response->setError($e->getCode(), $e->getMessage());
102			} catch (Error $e) {
103			$response->setError(Response::INTERNAL_ERROR);
104			}
105
106			return $response;
107			}
108
109			/**
110			* Validate Request and set error.
111			* @param Request $request
112			* @param Response $response
113			* @return void
114			*/
115			protected function validate(Request $request, Response $response)
116			{
117			$type = gettype($request->id);
118			if (
119			$request->jsonrpc !== Response::VERSION \|\|
120			!is_string($request->method) \|\|
121			!in_array($type, ['NULL', 'integer', 'string'])
122			) {
123			$response->setError(Response::INVALID_REQUEST);
124			} elseif (!is_array($request->params) && !is_object($request->params) && !is_null($request->params)) {
125			$response->setError(Response::INVALID_PARAMS);
126			}
127			}
128
129			/**
130			* Get data from request.
131			* @return mixed
132			* @throws Exception
133			*/
134			protected function getData()
135			{
136			$content = $this->getRawContent();
137			$data = is_string($content) ? @json_decode($content) : null;
138			if ($data === null) {
139			throw new Exception(Response::PARSE_ERROR);
140			}
141			return $data;
142			}
143
144			/**
145			* Read raw content.
146			* @return string\|false
147			*/
148			protected function getRawContent()
149			{
150			return @file_get_contents('php://input');
151			}
152			}
153

Veejayspb / jsonrpc

Server::run() C last analyzed 2021-02-22 18:27 UTC

Complexity

Size

Duplication

Importance

How to fix Complexity

Long Method

Duplication Side-by-Side

Filter issues like

Server::run() C
last analyzed 2021-02-22 18:27 UTC