Changeset View
Changeset View
Standalone View
Standalone View
src/applications/diffusion/query/DiffusionQuery.php
| Show First 20 Lines • Show All 67 Lines • ▼ Show 20 Lines | final public static function callConduitWithDiffusionRequest( | ||||
| foreach ($core_params as $key => $value) { | foreach ($core_params as $key => $value) { | ||||
| if (empty($method_params[$key])) { | if (empty($method_params[$key])) { | ||||
| unset($core_params[$key]); | unset($core_params[$key]); | ||||
| } | } | ||||
| } | } | ||||
| $params = $params + $core_params; | $params = $params + $core_params; | ||||
| $client = $repository->newConduitClient( | $future = $repository->newConduitFuture( | ||||
| $user, | $user, | ||||
| $method, | |||||
| $params, | |||||
| $drequest->getIsClusterRequest()); | $drequest->getIsClusterRequest()); | ||||
| if (!$client) { | |||||
| $result = id(new ConduitCall($method, $params)) | |||||
| ->setUser($user) | |||||
| ->execute(); | |||||
| $future = new ImmediateFuture($result); | |||||
| } else { | |||||
| $future = $client->callMethod($method, $params); | |||||
| } | |||||
| if (!$return_future) { | if (!$return_future) { | ||||
| return $future->resolve(); | return $future->resolve(); | ||||
| } | } | ||||
| return $future; | return $future; | ||||
| } | } | ||||
| ▲ Show 20 Lines • Show All 131 Lines • Show Last 20 Lines | |||||