composer/php-json-rpc
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

JsonResponse

Browse Source
This commit is contained in:
dongwei 2019-01-19 17:10:30 +08:00
parent ffca2c303b
commit d5470ca40d
2 changed files with 7 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/Server/JsonRpcMethod.php
View File

@ -17,29 +17,23 @@ class JsonRpcMethod
public function response($result) public function response($result)
{ {
return JsonResponse::create([ return [
'jsonrpc' => '2.0', 'jsonrpc' => '2.0',
'result' => $result, 'result' => $result,
'id' => $this->id 'id' => $this->id
]); ];
} }
/**
*
* @param $code
* @param $msg
* @return static
*/
public function error($code, $msg) public function error($code, $msg)
{ {
return JsonResponse::create([ return [
'jsonrpc' => '2.0', 'jsonrpc' => '2.0',
'error' => [ 'error' => [
'code' => $code, 'code' => $code,
'message' => is_array($msg) ? json_encode($msg) : $msg, 'message' => is_array($msg) ? json_encode($msg) : $msg,
], ],
'id' => $this->id 'id' => $this->id
]); ];
} }
} }

5
src/Server/JsonRpcServer.php
View File

@ -65,8 +65,9 @@ class JsonRpcServer
app('rpc.logger')->info('server', [$id, $class,$method, $params, $this->request->header('client_app'), $this->request->header('client_addr'), $this->request->header('client_host')]); app('rpc.logger')->info('server', [$id, $class,$method, $params, $this->request->header('client_app'), $this->request->header('client_addr'), $this->request->header('client_host')]);
$ret = call_user_func_array([(new $class($id, $this->request)), $function], $params); $ret = call_user_func_array([(new $class($id, $this->request)), $function], $params);
app('rpc.logger')->info('server_result', [$id, \GuzzleHttp\json_decode($ret, true)]); app('rpc.logger')->info('server_result', [$id, $ret]);
return $ret;
return JsonResponse::create($ret);
} catch (\InvalidArgumentException $e) { } catch (\InvalidArgumentException $e) {
return $this->error(self::Rpc_Error_Parse_Error); return $this->error(self::Rpc_Error_Parse_Error);