@@ -325,7 +325,7 @@ |
||
325 | 325 | ]); |
326 | 326 | throw $e; |
327 | 327 | } catch (ConnectionException $e) { |
328 | - $this->_logger->warning('Manticore Search Request failed '.$this->_connectionPool->retries_attempts.':', [ |
|
328 | + $this->_logger->warning('Manticore Search Request failed ' . $this->_connectionPool->retries_attempts . ':', [ |
|
329 | 329 | 'exception' => $e->getMessage(), |
330 | 330 | 'request' => $e->getRequest()->toArray() |
331 | 331 | ]); |
@@ -31,11 +31,11 @@ discard block |
||
31 | 31 | * @param LoggerInterface|null $logger |
32 | 32 | */ |
33 | 33 | |
34 | - public function __construct(Connection $connection = null,LoggerInterface $logger = null) |
|
34 | + public function __construct(Connection $connection = null, LoggerInterface $logger = null) |
|
35 | 35 | { |
36 | 36 | $this->client = HttpClientDiscovery::find(); |
37 | 37 | $this->messageFactory = MessageFactoryDiscovery::find(); |
38 | - parent::__construct($connection,$logger); |
|
38 | + parent::__construct($connection, $logger); |
|
39 | 39 | } |
40 | 40 | |
41 | 41 | /** |
@@ -44,7 +44,7 @@ discard block |
||
44 | 44 | * @return Response |
45 | 45 | * @throws \Http\Client\Exception |
46 | 46 | */ |
47 | - public function execute(Request $request, $params=[]) |
|
47 | + public function execute(Request $request, $params = []) |
|
48 | 48 | { |
49 | 49 | $connection = $this->getConnection(); |
50 | 50 | |
@@ -71,25 +71,25 @@ discard block |
||
71 | 71 | $message = $this->messageFactory->createRequest($method, $url, $headers, $content); |
72 | 72 | try { |
73 | 73 | $responsePSR = $this->client->sendRequest($message); |
74 | - }catch (\Exception $e) { |
|
75 | - throw new ConnectionException($e->getMessage(),$request); |
|
74 | + } catch (\Exception $e) { |
|
75 | + throw new ConnectionException($e->getMessage(), $request); |
|
76 | 76 | } |
77 | 77 | $end = microtime(true); |
78 | 78 | $status = $responsePSR->getStatusCode(); |
79 | 79 | $response = new Response($responsePSR->getBody(), $status); |
80 | 80 | $time = $end-$start; |
81 | 81 | $response->setTime($time); |
82 | - $this->_logger->debug('Request body:',[ |
|
82 | + $this->_logger->debug('Request body:', [ |
|
83 | 83 | 'connection' => $connection->getConfig(), |
84 | 84 | 'payload'=> $request->getBody() |
85 | 85 | ]); |
86 | - $this->_logger->info('Request:',[ |
|
86 | + $this->_logger->info('Request:', [ |
|
87 | 87 | 'url' => $url, |
88 | 88 | 'status' => $status, |
89 | 89 | 'time' => $time |
90 | 90 | ] |
91 | 91 | ); |
92 | - $this->_logger->debug('Response body:',$response->getResponse()); |
|
92 | + $this->_logger->debug('Response body:', $response->getResponse()); |
|
93 | 93 | |
94 | 94 | return $response; |
95 | 95 | } |