@@ -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(), |