app.py

from fastapi import FastAPI, HTTPException
from supabase import create_client, Client
from typing import List, Dict
from datetime import datetime
import os
from dotenv import load_dotenv
import json
load_dotenv()
import logging
import json
app = FastAPI()

# Initialize Supabase client
url: str = os.getenv('SUPABASE_URL')
key: str = os.getenv('SUPABASE_KEY')
supabase: Client = create_client(url, key)


@app.get('/insurance_data')
async def get_insurance_data(hushh_id:str):
    response = supabase.table('receipt_radar_structured_data_duplicate').select('metadata,message_id,company,logo').eq("user_id",hushh_id).eq("brand_category",'Insurance').execute()
    resp = response.data
    res = {}
    print(resp)
    for r in resp:
        message_id = r.get('message_id')
        if r.get('metadata') is not None and r.get('metadata') != 'null':
            ds = json.loads(r.get('metadata'))
            if ds.get('insurance_type') is not None and ds.get('insurance_type') != ""  and ds.get('policy_details') is not None and ds.get('coverage_details') is not None:
                if ds.get('insurance_type') not in res:
                    res[ds.get('insurance_type')] = []
                res[ds.get('insurance_type')].append({"message_id":message_id,"policy_details":ds.get('policy_details') ,"coverage_details": ds.get('coverage_details'),"domain":r.get('company'),"logo":r.get('logo')}) 
    return res



@app.get("/insurance-analytics")
async def get_insurance_analytics():
    
        # Fetch data from Supabase
    response = supabase.table("insurance_data").select("*").eq("hushh_id","4b7fa719-244e-4ae8-9025-651a9a41e43f").execute()
    receipts = response.data
    print(receipts)
    analytics = {
            "policy_overview": {
                "types_of_policies": {},
                "total_coverage_amount": 0,
                "premium_payments": {
                    "total": 0,
                    "frequency_distribution": {}
                }
            },
            "claim_patterns": {
                "total_claims": 0,
                "total_claim_amount": 0
            },
            "policy_renewal": {
                "total_policies": len(receipts),
                "active_policies": 0,
                "lapsed_policies": 0
            }
        }

    current_date = datetime.now()

    for receipt in receipts:
        metadata = json.loads(receipt['metadata'])
        print("printing metadata")
        print(metadata)

            # Policy overview
        policy_type = metadata.get('policy_type')
        analytics['policy_overview']['types_of_policies'][policy_type] = analytics['policy_overview']['types_of_policies'].get(policy_type, 0) + 1
            
        coverage_amount = float(metadata.get('coverage_amount', 0))
        analytics['policy_overview']['total_coverage_amount'] += coverage_amount
            
        premium_amount = float(metadata.get('premium_amount', 0))
        analytics['policy_overview']['premium_payments']['total'] += premium_amount
            
        premium_frequency = metadata.get('premium_frequency')
        analytics['policy_overview']['premium_payments']['frequency_distribution'][premium_frequency] = analytics['policy_overview']['premium_payments']['frequency_distribution'].get(premium_frequency, 0) + 1

            # Claim patterns
        if metadata.get('claim_number'):
            analytics['claim_patterns']['total_claims'] += 1
            claim_amount = metadata.get('claim_amount')
            if claim_amount is not None:
                try:
                    claim_amount = float(claim_amount)
                    analytics['claim_patterns']['total_claim_amount'] += claim_amount
                except:
                    logging.warning(f"Invalid claim amount: {claim_amount}")
            # Policy renewal
            # Policy renewal
            try:
                policy_end_date = datetime.strptime(metadata.get('policy_end_date'), "%m-%d-%Y")
                if policy_end_date > current_date:
                    analytics['policy_renewal']['active_policies'] += 1
                else:
                    analytics['policy_renewal']['lapsed_policies'] += 1
            except (ValueError, TypeError):
                logging.error(f"Invalid date format for policy_end_date: {metadata.get('policy_end_date')}")

        # Calculate percentage distribution for premium frequency
        total_policies = sum(analytics['policy_overview']['premium_payments']['frequency_distribution'].values())
        if total_policies > 0:
            analytics['policy_overview']['premium_payments']['frequency_percentage'] = {
                freq: (count / total_policies) * 100 
                for freq, count in analytics['policy_overview']['premium_payments']['frequency_distribution'].items()
            }
        else:
            logging.warning("No valid policies found for frequency percentage calculation")

        logging.debug(f"Final analytics: {analytics}")

        return analytics