Updated

main.py

@@ -1,6 +1,7 @@
 import os
 import uvicorn
-from fastapi import FastAPI, HTTPException
+import requests
+from fastapi import FastAPI, HTTPException, Query
 from fastapi.middleware.cors import CORSMiddleware
 from supabase import create_client, Client
 from dotenv import load_dotenv
@@ -22,8 +23,62 @@ app.add_middleware(
     allow_headers=["*"],
 )
 
+# Fallback rates in case API fails
+EXCHANGE_RATES = {
+    "USD": 1.0,
+    "EUR": 1.08,
+    "GBP": 1.25,
+    "INR": 0.012,
+    "SEK": 0.095,
+    "JPY": 0.0067,
+    "CAD": 0.74,
+    "AUD": 0.65,
+    "CNY": 0.14,
+    "AED": 0.27
+}
+
+def fetch_live_rates():
+    global EXCHANGE_RATES
+    try:
+        # Using a free standard API for USD base rates
+        response = requests.get("https://api.exchangerate-api.com/v4/latest/USD")
+        data = response.json()
+        if "rates" in data:
+            EXCHANGE_RATES = data["rates"]
+            # Ensure USD is 1.0
+            EXCHANGE_RATES["USD"] = 1.0
+            print("Successfully fetched live exchange rates.")
+    except Exception as e:
+        print(f"Failed to fetch live rates, using fallback. Error: {e}")
+
+@app.on_event("startup")
+async def startup_event():
+    fetch_live_rates()
+
+def get_exchange_rate(currency_code: str) -> float:
+    return EXCHANGE_RATES.get(currency_code.upper(), 1.0)
+
+def convert_price(price: float, from_curr: str, to_curr: str) -> float:
+    # If currencies are the same, return original price
+    if from_curr.upper() == to_curr.upper():
+        return price
+    
+    # Logic: Convert 'from' to USD, then USD to 'to'
+    # API returns rates where 1 USD = X Currency
+    # Price in USD = Price / Rate(from)
+    # Price in Target = Price in USD * Rate(to)
+    
+    rate_from = get_exchange_rate(from_curr)
+    rate_to = get_exchange_rate(to_curr)
+    
+    if rate_from == 0:
+        return price
+
+    price_in_usd = price / rate_from
+    return price_in_usd * rate_to
+
 @app.get("/api/analyze/{rfq_id}", response_model=AnalysisResponse)
-async def analyze_rfq(rfq_id: str):
+async def analyze_rfq(rfq_id: str, target_currency: str = Query("USD")):
     items_res = supabase.table('rfq_line_items').select("*").eq('rfq_id', rfq_id).execute()
     if not items_res.data:
         raise HTTPException(status_code=404, detail="RFQ Items not found")
@@ -34,21 +89,33 @@ async def analyze_rfq(rfq_id: str):
     ]
 
     quotes_res = supabase.table('quotations').select(
-        "id, vendor_id, vendors(vendor_name, rating, is_verified)"
+        "id, vendor_id, metadata, vendors(vendor_name, rating, is_verified)"
     ).eq('rfq_id', rfq_id).execute()
 
     quote_ids = [q['id'] for q in quotes_res.data]
     if not quote_ids:
-        return AnalysisResponse(rfq_id=rfq_id, strategies={}, recommended_strategy="None")
+        return AnalysisResponse(
+            rfq_id=rfq_id, 
+            currency=target_currency,
+            strategies={}, 
+            recommended_strategy="None"
+        )
 
     q_items_res = supabase.table('quotation_items').select(
         "rfq_item_id, unit_price, delivery_time_days, quotation_id, brand, manufacturer"
     ).in_('quotation_id', quote_ids).execute()
 
-    vendor_map = {} 
+    vendor_map = {}
+    quote_currency_map = {}
 
     for q in quotes_res.data:
         v_id = q['vendor_id']
+        
+        meta = q.get('metadata') or {}
+        logistics = meta.get('logistics') or {}
+        currency = logistics.get('currency', 'USD')
+        quote_currency_map[q['id']] = currency
+
         if v_id not in vendor_map:
             vendor_data = q['vendors']
             vendor_map[v_id] = VendorOffer(
@@ -65,9 +132,14 @@ async def analyze_rfq(rfq_id: str):
         q_id = qi['quotation_id']
         if q_id in q_to_v:
             v_id = q_to_v[q_id]
+            
+            source_curr = quote_currency_map.get(q_id, "USD")
+            original_price = qi['unit_price']
+            converted_price = convert_price(original_price, source_curr, target_currency)
+
             vendor_map[v_id].offers.append(QuoteOffer(
                 rfq_item_id=qi['rfq_item_id'],
-                unit_price=qi['unit_price'],
+                unit_price=converted_price,
                 delivery_days=qi.get('delivery_time_days', 7),
                 brand=qi.get('brand'),
                 manufacturer=qi.get('manufacturer')
@@ -87,6 +159,7 @@ async def analyze_rfq(rfq_id: str):
 
     return AnalysisResponse(
         rfq_id=rfq_id,
+        currency=target_currency,
         strategies=results,
         recommended_strategy=rec
     )

models.py

@@ -21,6 +21,7 @@ class StrategyResult(BaseModel):
 
 class AnalysisResponse(BaseModel):
     rfq_id: str
+    currency: str
     strategies: Dict[str, StrategyResult]
     recommended_strategy: str
 

requirements.txt

@@ -4,4 +4,5 @@ supabase
 pandas
 numpy
 pydantic
-python-dotenv
+python-dotenv
+requests