update final design

test.py

@@ -0,0 +1,103 @@
+import serial
+import json
+import requests
+import time
+from datetime import datetime, timedelta
+
+class PlaidDataSender:
+    def __init__(self, access_token, serial_port='/dev/tty.usbserial-0001', baud_rate=115200):
+        self.access_token = access_token
+        self.serial_port = serial_port
+        self.baud_rate = baud_rate
+        self.api_base_url = 'http://localhost:3000'
+
+    def fetch_financial_data(self):
+        """Fetch real financial data from Plaid API"""
+        headers = {'plaid-access-token': self.access_token}
+        
+        # Fetch accounts
+        accounts_response = requests.get(
+            f'{self.api_base_url}/api/accounts', 
+            headers=headers
+        )
+        accounts_data = accounts_response.json()
+        
+        # Fetch transactions
+        transactions_response = requests.get(
+            f'{self.api_base_url}/api/transactions', 
+            headers=headers
+        )
+        transactions_data = transactions_response.json()
+
+        # Calculate totals
+        total_balance = sum(account['balances']['current'] for account in accounts_data['accounts'])
+        transactions = transactions_data['transactions']
+        total_income = sum(trans['amount'] for trans in transactions if trans['amount'] > 0)
+        total_expenses = sum(trans['amount'] for trans in transactions if trans['amount'] < 0)
+
+        # Format data for ESP32
+        financial_summary = {
+            "bank_balance": round(total_balance, 2),
+            "total_income": round(total_income, 2),
+            "total_expenses": round(abs(total_expenses), 2),
+            "net_amount": round(total_income + total_expenses, 2),
+            "recent_transactions": [
+                {
+                    "name": trans['merchant_name'] or trans['name'],
+                    "amount": trans['amount'],
+                    "type": "income" if trans['amount'] > 0 else "expense",
+                    "date": trans['date']
+                }
+                for trans in sorted(transactions, key=lambda x: x['date'], reverse=True)[:5]
+            ]
+        }
+
+        return financial_summary
+
+    def run(self):
+        """Run the data sender"""
+        try:
+            # Setup serial connection
+            with serial.Serial(self.serial_port, self.baud_rate, timeout=1) as ser:
+                print(f"Connected to ESP32 on {self.serial_port}")
+                time.sleep(2)  # Wait for connection to establish
+
+                while True:
+                    try:
+                        # Fetch latest financial data
+                        financial_data = self.fetch_financial_data()
+                        
+                        # Convert to JSON and send
+                        json_data = json.dumps(financial_data)
+                        ser.write((json_data + '\n').encode('utf-8'))
+                        
+                        print(f"Sent financial data: {json_data}")
+                        time.sleep(10)  # Wait 5 seconds before next update
+                        
+                    except requests.RequestException as e:
+                        print(f"API Error: {e}")
+                        time.sleep(5)
+                    except Exception as e:
+                        print(f"Error sending data: {e}")
+                        time.sleep(1)
+
+        except serial.SerialException as e:
+            print(f"Serial connection error: {e}")
+        except KeyboardInterrupt:
+            print("\nStopped by user")
+
+def main():
+    # Replace with your Plaid access token
+    access_token = "access-sandbox-1331c29e-2e5a-492b-ac03-623c4a7aa146"
+    
+    # Create and run the sender
+    sender = PlaidDataSender(
+        access_token=access_token,
+        serial_port='/dev/tty.usbserial-0001',  # Hardcoded serial port
+        baud_rate=115200
+    )
+    
+    sender.run()
+
+if __name__ == "__main__":
+    main()