1: | <?php |
2: | |
3: | declare(strict_types=1); |
4: | |
5: | |
6: | |
7: | |
8: | |
9: | |
10: | |
11: | |
12: | |
13: | |
14: | |
15: | |
16: | |
17: | |
18: | |
19: | |
20: | |
21: | |
22: | namespace OpenSearch\Namespaces; |
23: | |
24: | use OpenSearch\Common\Exceptions\Missing404Exception; |
25: | use OpenSearch\Common\Exceptions\RoutingMissingException; |
26: | use OpenSearch\Endpoints\AbstractEndpoint; |
27: | use OpenSearch\Transport; |
28: | use GuzzleHttp\Ring\Future\FutureArrayInterface; |
29: | |
30: | abstract class BooleanRequestWrapper |
31: | { |
32: | |
33: | |
34: | |
35: | |
36: | |
37: | |
38: | public static function performRequest(AbstractEndpoint $endpoint, Transport $transport) |
39: | { |
40: | try { |
41: | $response = $transport->performRequest( |
42: | $endpoint->getMethod(), |
43: | $endpoint->getURI(), |
44: | $endpoint->getParams(), |
45: | $endpoint->getBody(), |
46: | $endpoint->getOptions() |
47: | ); |
48: | |
49: | $response = $transport->resultOrFuture($response, $endpoint->getOptions()); |
50: | if (!($response instanceof FutureArrayInterface)) { |
51: | if ($response['status'] === 200) { |
52: | return true; |
53: | } else { |
54: | return false; |
55: | } |
56: | } else { |
57: | |
58: | return $response; |
59: | } |
60: | } catch (Missing404Exception $exception) { |
61: | return false; |
62: | } catch (RoutingMissingException $exception) { |
63: | return false; |
64: | } |
65: | } |
66: | } |
67: | |