Update app.py

app.py

@@ -41,6 +41,7 @@ ENCRYPTED_CONNECT_SID = encrypt_value('s%3A7Bwbww_JK7pW55D-B57-3b7bi-FzrzEZ.ezXP
 ENCRYPTED_API_URL = encrypt_value('https://astra-bank-moh1812.replit.app/api/transactions')
 ENCRYPTED_REFERER = encrypt_value('https://astra-bank-moh1812.replit.app/')
 ENCRYPTED_ETAG = encrypt_value('W/"6e3-L0zHI4rHMa4nHmyewyA/4y+lL6c"')
+ENCRYPTED_BANK_BASE_URL = encrypt_value('https://astra-bank-moh1812.replit.app')
 
 class PaymentLink(db.Model):
     id = db.Column(db.String(36), primary_key=True, default=lambda: str(uuid.uuid4()))
@@ -102,6 +103,90 @@ def check_for_payment(amount, existing_transaction_ids):
         print(f"Error checking for payment: {e}")
         return None
 
+def get_user_uuid(email):
+    try:
+        base_url = decrypt_value(ENCRYPTED_BANK_BASE_URL)
+        connect_sid = decrypt_value(ENCRYPTED_CONNECT_SID)
+        referer = decrypt_value(ENCRYPTED_REFERER)
+        
+        url = f"{base_url}/api/user"
+        params = {'email': email}
+        
+        headers = {
+            'accept': '*/*',
+            'accept-language': 'en-US,en;q=0.9',
+            'cache-control': 'no-cache',
+            'priority': 'u=1, i',
+            'referer': referer,
+            'sec-ch-ua': '"Chromium";v="142", "Google Chrome";v="142", "Not_A Brand";v="99"',
+            'sec-ch-ua-mobile': '?1',
+            'sec-ch-ua-platform': '"Android"',
+            'sec-fetch-dest': 'empty',
+            'sec-fetch-mode': 'cors',
+            'sec-fetch-site': 'same-origin',
+            'user-agent': 'Mozilla/5.0 (Linux; Android 6.0; Nexus 5 Build/MRA58N) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/142.0.0.0 Mobile Safari/537.36'
+        }
+        
+        cookies = {
+            'connect.sid': connect_sid
+        }
+        
+        response = requests.get(url, params=params, headers=headers, cookies=cookies, timeout=10)
+        if response.status_code == 200:
+            return response.text.strip()
+        else:
+            print(f"Error getting user UUID: {response.status_code} - {response.text}")
+            return None
+    except Exception as e:
+        print(f"Error getting user UUID: {e}")
+        return None
+
+def send_money(to_user_id, amount, description):
+    try:
+        base_url = decrypt_value(ENCRYPTED_BANK_BASE_URL)
+        connect_sid = decrypt_value(ENCRYPTED_CONNECT_SID)
+        referer = decrypt_value(ENCRYPTED_REFERER)
+        
+        url = f"{base_url}/api/send-money"
+        
+        headers = {
+            'accept': '*/*',
+            'accept-language': 'en-US,en;q=0.9',
+            'cache-control': 'no-cache',
+            'content-type': 'application/json',
+            'origin': base_url,
+            'pragma': 'no-cache',
+            'priority': 'u=1, i',
+            'referer': referer,
+            'sec-ch-ua': '"Chromium";v="142", "Google Chrome";v="142", "Not_A Brand";v="99"',
+            'sec-ch-ua-mobile': '?1',
+            'sec-ch-ua-platform': '"Android"',
+            'sec-fetch-dest': 'empty',
+            'sec-fetch-mode': 'cors',
+            'sec-fetch-site': 'same-origin',
+            'user-agent': 'Mozilla/5.0 (Linux; Android 6.0; Nexus 5 Build/MRA58N) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/142.0.0.0 Mobile Safari/537.36'
+        }
+        
+        cookies = {
+            'connect.sid': connect_sid
+        }
+        
+        data = {
+            'toUserId': to_user_id,
+            'amount': amount,
+            'description': description
+        }
+        
+        response = requests.post(url, json=data, headers=headers, cookies=cookies, timeout=10)
+        if response.status_code == 200:
+            return True, response.json()
+        else:
+            print(f"Error sending money: {response.status_code} - {response.text}")
+            return False, response.text
+    except Exception as e:
+        print(f"Error sending money: {e}")
+        return False, str(e)
+
 with app.app_context():
     db.create_all()
 
@@ -205,6 +290,24 @@ def process_payment(payment_id):
         payment_link.paid = True
         db.session.commit()
 
+        if payment_link.recipient_email:
+            try:
+                user_uuid = get_user_uuid(payment_link.recipient_email)
+                if user_uuid:
+                    success, result = send_money(
+                        to_user_id=user_uuid,
+                        amount=payment_link.amount,
+                        description=payment_link.description
+                    )
+                    if success:
+                        print(f"Successfully sent {payment_link.amount} Astras to {payment_link.recipient_email}")
+                    else:
+                        print(f"Failed to send money: {result}")
+                else:
+                    print(f"Could not find user UUID for email: {payment_link.recipient_email}")
+            except Exception as e:
+                print(f"Error processing recipient payment: {e}")
+
         return jsonify({'success': True, 'message': 'Payment confirmed successfully'})
 
     except Exception as e: