@@ -70,7 +70,7 @@ discard block |
||
| 70 | 70 | $rpcService = $this->getRpcService(); |
| 71 | 71 | |
| 72 | 72 | /** |
| 73 | - * Парсим |
|
| 73 | + * Парсим |
|
| 74 | 74 | */ |
| 75 | 75 | try { |
| 76 | 76 | $data = $rpcService->jsonParse($rpcRun->getJson()); |
@@ -120,17 +120,17 @@ discard block |
||
| 120 | 120 | |
| 121 | 121 | try { |
| 122 | 122 | /** |
| 123 | - * валидируем и парсим JsonRPC |
|
| 123 | + * валидируем и парсим JsonRPC |
|
| 124 | 124 | */ |
| 125 | 125 | $rpcObj = $this->getRpcService()->getRpc($rpc); |
| 126 | 126 | |
| 127 | 127 | /** |
| 128 | - * Проверим авторизацию |
|
| 128 | + * Проверим авторизацию |
|
| 129 | 129 | */ |
| 130 | 130 | $this->authCheck($rpcObj->getMethod(), $rpcRun->getAuth()); |
| 131 | 131 | |
| 132 | 132 | /** |
| 133 | - * Пытаемся выполнить запрос |
|
| 133 | + * Пытаемся выполнить запрос |
|
| 134 | 134 | */ |
| 135 | 135 | $res['result'] = $this->getApiExeService()->exe( |
| 136 | 136 | $rpcRun, |
@@ -78,15 +78,15 @@ |
||
| 78 | 78 | $resArr = []; |
| 79 | 79 | foreach ($data as $rpc) { |
| 80 | 80 | switch (true) { |
| 81 | - case ($rpc instanceof stdClass): |
|
| 82 | - // TODO впилить паралельное выполнение, возможно amphp/amp |
|
| 83 | - $resArr[] = $this->oneRun( |
|
| 84 | - $rpcRun, |
|
| 85 | - $rpc |
|
| 86 | - ); |
|
| 87 | - break; |
|
| 88 | - default: |
|
| 89 | - $resArr[] = $this->getJsonStrError(); |
|
| 81 | + case ($rpc instanceof stdClass): |
|
| 82 | + // TODO впилить паралельное выполнение, возможно amphp/amp |
|
| 83 | + $resArr[] = $this->oneRun( |
|
| 84 | + $rpcRun, |
|
| 85 | + $rpc |
|
| 86 | + ); |
|
| 87 | + break; |
|
| 88 | + default: |
|
| 89 | + $resArr[] = $this->getJsonStrError(); |
|
| 90 | 90 | } |
| 91 | 91 | } |
| 92 | 92 | |
@@ -54,7 +54,7 @@ discard block |
||
| 54 | 54 | if (is_array($method['errors'])) { |
| 55 | 55 | $method['errors'] = array_values($method['errors']); |
| 56 | 56 | /** |
| 57 | - * @var RpcErrorDefinition $error |
|
| 57 | + * @var RpcErrorDefinition $error |
|
| 58 | 58 | */ |
| 59 | 59 | foreach ($method['errors'] as &$error) { |
| 60 | 60 | $error = $error->toArray(); |
@@ -91,13 +91,13 @@ discard block |
||
| 91 | 91 | $methods = []; |
| 92 | 92 | foreach ($procedures as $procedure) { |
| 93 | 93 | /** |
| 94 | - * @var RpcProcedureInterface $procObj |
|
| 94 | + * @var RpcProcedureInterface $procObj |
|
| 95 | 95 | */ |
| 96 | 96 | $procObj = $factory->get($procedure); |
| 97 | 97 | $procDef = $procObj->getDefinition(); |
| 98 | 98 | |
| 99 | 99 | /** |
| 100 | - * добавим ошибку авторизации |
|
| 100 | + * добавим ошибку авторизации |
|
| 101 | 101 | */ |
| 102 | 102 | if ($auth !== null && !in_array($procedure, $auth->getProcWithoutAuth(), true)) { |
| 103 | 103 | $procDef |
@@ -75,7 +75,7 @@ discard block |
||
| 75 | 75 | $factory = $model->getRpcFactory(); |
| 76 | 76 | $method = $rpc->getMethod(); |
| 77 | 77 | /** |
| 78 | - * Проверим существование метода |
|
| 78 | + * Проверим существование метода |
|
| 79 | 79 | */ |
| 80 | 80 | if ($factory->has($method) === false) { |
| 81 | 81 | throw new MethodNotFoundException( |
@@ -84,7 +84,7 @@ discard block |
||
| 84 | 84 | } |
| 85 | 85 | |
| 86 | 86 | /** |
| 87 | - * Создаем экземпляр класса |
|
| 87 | + * Создаем экземпляр класса |
|
| 88 | 88 | * |
| 89 | 89 | * @var RpcProcedureInterface $class |
| 90 | 90 | */ |
@@ -94,7 +94,7 @@ discard block |
||
| 94 | 94 | // $this->checkInterface($class, $method); |
| 95 | 95 | |
| 96 | 96 | /** |
| 97 | - * Валидируем парамертры ЗАПРОСА |
|
| 97 | + * Валидируем парамертры ЗАПРОСА |
|
| 98 | 98 | */ |
| 99 | 99 | if ($class->getDefinition()->getParams() !== null) { |
| 100 | 100 | $this->getValidator()->validate( |
@@ -119,14 +119,14 @@ discard block |
||
| 119 | 119 | } |
| 120 | 120 | |
| 121 | 121 | /** |
| 122 | - * засетим в метод RpcRequest |
|
| 122 | + * засетим в метод RpcRequest |
|
| 123 | 123 | */ |
| 124 | 124 | if (method_exists($class, 'setRpcRequest')) { |
| 125 | 125 | $class->setRpcRequest(new RpcRequest($rpc, $paramsObject)); |
| 126 | 126 | } |
| 127 | 127 | |
| 128 | 128 | /** |
| 129 | - * Выполним метод |
|
| 129 | + * Выполним метод |
|
| 130 | 130 | */ |
| 131 | 131 | try { |
| 132 | 132 | $res = $class->execute()->getResult(); |
@@ -146,7 +146,7 @@ discard block |
||
| 146 | 146 | |
| 147 | 147 | if ($model->isResponseCheck() && $class->getDefinition()->getResult() !== null) { |
| 148 | 148 | /** |
| 149 | - * Валидируем парамертры ОТВЕТА |
|
| 149 | + * Валидируем парамертры ОТВЕТА |
|
| 150 | 150 | */ |
| 151 | 151 | $this->getValidator()->validate( |
| 152 | 152 | $class->getDefinition()->getResult(), |