@@ -621,17 +621,15 @@ public function bulk(array $params)
621
621
public function request ($ path , $ method = Request::GET , $ data = array (), array $ query = array ())
622
622
{
623
623
$ connection = $ this ->getConnection ();
624
+ $ request = null ;
625
+ $ response = null ;
626
+
624
627
try {
625
628
$ request = new Request ($ path , $ method , $ data , $ query , $ connection );
626
-
627
- $ this ->_log ($ request );
628
-
629
629
$ response = $ request ->send ();
630
630
631
631
$ this ->_lastRequest = $ request ;
632
632
$ this ->_lastResponse = $ response ;
633
-
634
- return $ response ;
635
633
} catch (ConnectionException $ e ) {
636
634
$ this ->_connectionPool ->onFail ($ connection , $ e , $ this );
637
635
@@ -642,6 +640,10 @@ public function request($path, $method = Request::GET, $data = array(), array $q
642
640
643
641
return $ this ->request ($ path , $ method , $ data , $ query );
644
642
}
643
+
644
+ $ this ->_log ($ request , $ response );
645
+
646
+ return $ response ;
645
647
}
646
648
647
649
/**
@@ -673,29 +675,41 @@ public function refreshAll()
673
675
/**
674
676
* Log a request if the logger is present.
675
677
*
676
- * @param \Elastica\Request $request
677
- *
678
- * @throws Exception\RuntimeException
678
+ * @param Request $request
679
+ * @param Response $response
679
680
*/
680
- protected function _log (Request $ request )
681
+ protected function _log (Request $ request, Response $ response = null )
681
682
{
682
683
if (!$ this ->_logger ) {
683
684
return ;
684
685
}
685
686
686
- $ this ->_logger ->debug ('Elastica Request ' , $ request ->toArray ());
687
+ $ this ->_logger ->debug ('Elastica Request ' , [
688
+ 'request ' => $ request ->toArray (),
689
+ 'response ' => $ response ? $ response ->getData () : null
690
+ ]);
687
691
}
688
692
689
693
/**
690
- * @return \Elastica\Request
694
+ * Replace the existing logger.
695
+ *
696
+ * @param LoggerInterface $logger
697
+ */
698
+ public function setLogger (LoggerInterface $ logger )
699
+ {
700
+ $ this ->_logger = $ logger ;
701
+ }
702
+
703
+ /**
704
+ * @return Request
691
705
*/
692
706
public function getLastRequest ()
693
707
{
694
708
return $ this ->_lastRequest ;
695
709
}
696
710
697
711
/**
698
- * @return \Elastica\ Response
712
+ * @return Response
699
713
*/
700
714
public function getLastResponse ()
701
715
{
0 commit comments