From 67379d7c4f1d13d28a925faa945bb85c0cf4a32e Mon Sep 17 00:00:00 2001
From: cnohall <christopher.nohall@gmail.com>
Date: Fri, 6 Sep 2024 09:52:21 +0900
Subject: [PATCH] incorporate websocket

---
 .../Blockonomics/Blockonomics.php             | 27 +++++++++----------
 .../BlockonomicsPaymentDriver.php             |  1 +
 .../gateways/blockonomics/pay.blade.php       | 24 +++++++++++++++++
 3 files changed, 37 insertions(+), 15 deletions(-)

diff --git a/app/PaymentDrivers/Blockonomics/Blockonomics.php b/app/PaymentDrivers/Blockonomics/Blockonomics.php
index e5cc5c72812b..3fa41439a4c4 100644
--- a/app/PaymentDrivers/Blockonomics/Blockonomics.php
+++ b/app/PaymentDrivers/Blockonomics/Blockonomics.php
@@ -77,11 +77,7 @@ class Blockonomics implements MethodInterface
 
         if ($status != 200) {
             echo "ERROR: " . $status . ' ' . $responseObj->message;
-        } else {
-            echo "Success: " . $status;
-            echo json_encode($responseObj);
         }
-
         return $responseObj;
     }
 
@@ -157,11 +153,14 @@ class Blockonomics implements MethodInterface
         $data['amount'] = $data['total']['amount_with_fee'];
         $data['currency'] = $this->driver_class->client->getCurrencyCode();
         $btc_amount = $data['amount'] / $this->getBTCPrice();
-        $data['btc_amount'] = round($btc_amount, 10);
-        $data['btc_address'] = $this->getBTCAddress();
+        $data['btc_amount'] = number_format($btc_amount, 10, '.', '');
+        $btc_address = $this->getBTCAddress();
+        $data['btc_address'] = $btc_address;
         $data['invoice_id'] = $this->invoice_id;
         $data['end_time'] = $this->getTenMinutesCountDownEndTime();
         $data['callback_url'] = $this->setCallbackUrl();
+
+        $data['websocket_url'] = 'wss://www.blockonomics.co/payment/' . $btc_address;
         return render('gateways.blockonomics.pay', $data);
     }
 
@@ -183,15 +182,13 @@ class Blockonomics implements MethodInterface
         }
 
         try {
-            // $data = [
-            //     'payment_method' => '',
-            //     'payment_type' => PaymentType::CRYPTO,
-            //     'amount' => 200,
-            //     'transaction_reference' => 123,
-            //     'gateway_type_id' => GatewayType::CRYPTO,
-            // ];
-
-            // $payment = $this->createPayment($data, Payment::STATUS_COMPLETED);
+            $data = [
+                'payment_method' => '',
+                'payment_type' => PaymentType::CRYPTO,
+                'amount' => 200,
+                'transaction_reference' => 123,
+                'gateway_type_id' => GatewayType::CRYPTO,
+            ];
             return redirect()->route('client.payments.show', ['payment' => $this->encodePrimaryKey(6)]);
 
         } catch (\Throwable $e) {
diff --git a/app/PaymentDrivers/BlockonomicsPaymentDriver.php b/app/PaymentDrivers/BlockonomicsPaymentDriver.php
index e71273879bd4..9d954cf9ce48 100644
--- a/app/PaymentDrivers/BlockonomicsPaymentDriver.php
+++ b/app/PaymentDrivers/BlockonomicsPaymentDriver.php
@@ -125,6 +125,7 @@ class BlockonomicsPaymentDriver extends BaseDriver
 
     public function processPaymentResponse($request)
     {
+        echo "It reached the processPaymentResponse";
         return $this->payment_method->paymentResponse($request);
     }
 
diff --git a/resources/views/portal/ninja2020/gateways/blockonomics/pay.blade.php b/resources/views/portal/ninja2020/gateways/blockonomics/pay.blade.php
index f2574eb7a596..1151140f120a 100644
--- a/resources/views/portal/ninja2020/gateways/blockonomics/pay.blade.php
+++ b/resources/views/portal/ninja2020/gateways/blockonomics/pay.blade.php
@@ -54,6 +54,30 @@
         var x = setInterval(updateCountdown, 1000);
     </script>
 
+    <script>
+        var webSocketUrl = "{{ $websocket_url }}";
+        const ws = new WebSocket(webSocketUrl);
+
+        ws.onopen = function() {
+            console.log('WebSocket connection established');
+        };
+
+        ws.onmessage = function(event) {
+            const data = JSON.parse(event.data);
+            console.log('Payment status:', data.status);
+            document.getElementById('server-response').submit();
+        };
+
+        ws.onerror = function(error) {
+            console.error('WebSocket error:', error);
+        };
+
+        ws.onclose = function() {
+            console.log('WebSocket connection closed');
+        };
+
+    </script>
+
     <style type="text/css">    
         .blockonomics-payment-wrapper {
             justify-content: center;