Improving Listener updates

digitickets · Oct 22, 2018 · 19d2a85 · 19d2a85
1 parent 4609582
commit 19d2a85
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 2 deletions.
diff --git a/src/Messages/CompletePurchaseRequest.php b/src/Messages/CompletePurchaseRequest.php
@@ -35,14 +35,17 @@ public function sendData($data)
             $scpSimpleQueryResponse = $scpClient->scpSimpleQuery($data);
         } catch (\Throwable $t) {
             foreach ($this->getGateway()->getListeners() as $listener) {
-                $listener->update('completeException', $t);
+                $listener->update('completeExceptionSend', $scpClient->__getLastRequest());
+                $listener->update('completeExceptionRcv', $scpClient->__getLastResponse());
             }
             error_log($t->getMessage().' '.$t->getTraceAsString());
             return $this->response = new CompletePurchaseResponse($this, $t);
         }
 
         foreach ($this->getGateway()->getListeners() as $listener) {
             $listener->update('completeReceive', $scpSimpleQueryResponse);
+            $listener->update('completeExceptionSend', $scpClient->__getLastRequest());
+            $listener->update('completeExceptionRcv', $scpClient->__getLastResponse());
         }
 
         return $this->response = new CompletePurchaseResponse($this, $scpSimpleQueryResponse);

diff --git a/src/Messages/PurchaseRequest.php b/src/Messages/PurchaseRequest.php
@@ -131,13 +131,16 @@ public function sendData($data)
         } catch (\Throwable $t) {
             error_log($t->getMessage().' '.$t->getTraceAsString());
             foreach ($this->getGateway()->getListeners() as $listener) {
-                $listener->update('receiveException', $t);
+                $listener->update('receiveExceptionSend', $scpClient->__getLastRequest());
+                $listener->update('receiveExceptionRcv', $scpClient->__getLastResponse());
             }
             return $this->response = new PurchaseResponse($this, $t);
         }
 
         foreach ($this->getGateway()->getListeners() as $listener) {
             $listener->update('purchaseReceive', $scpSimpleInvokeResponse);
+            $listener->update('receiveExceptionSend', $scpClient->__getLastRequest());
+            $listener->update('receiveExceptionRcv', $scpClient->__getLastResponse());
         }
 
         return $this->response = new PurchaseResponse($this, $scpSimpleInvokeResponse);