adding files

app.py

@@ -0,0 +1,18 @@
+from fastapi import FastAPI , Request, APIRouter, Depends, HTTPException
+from starlette.middleware.cors import CORSMiddleware
+from routers import receipt_radar_callback_router
+
+app = FastAPI()
+
+app.add_middleware(
+    CORSMiddleware,
+    allow_origins=["*"],
+    allow_credentials=True,
+    allow_methods=["DELETE", "GET", "POST", "PUT"],
+    allow_headers=["*"],
+)
+
+
+app = FastAPI()
+
+app.include_router(receipt_radar_callback_router.router)

constants.py

@@ -0,0 +1,14 @@
+from dotenv import load_dotenv
+import os
+load_dotenv()
+
+TOKEN_GENERATION_API="https://oauth2.googleapis.com/token"
+USER_INFO_API = "https://www.googleapis.com/oauth2/v1/userinfo"
+REFRESH_TOKEN_PAYLOAD={
+        
+        "client_id": os.getenv("GOOGLE_CLIENT_ID"),
+        "client_secret": os.getenv("GOOGLE_CLIENT_SECRET"),
+        "redirect_uri": os.getenv("GOOGLE_REDIRECT_URI"),
+        "grant_type": "authorization_code",
+        "access_type": "offline"
+    }

dependencies/database.py

@@ -0,0 +1,18 @@
+from supabase import create_client, Client
+import os
+from dotenv import load_dotenv
+load_dotenv()
+
+class SupabaseDb:
+    SUPABASE_URL: str = os.getenv("SUPABASE_URL")
+    SUPABASE_ANON_KEY: str = os.getenv("SUPABASE_ANON_KEY")
+
+    def supabase_client(self):
+        client = create_client(self.SUPABASE_URL,self.SUPABASE_ANON_KEY)
+        return client
+    
+    def get_hushh_id(self,email:str):
+        client = self.supabase_client()
+        response = client.table("receipt_radar_authenticate").select("*").eq('email',f'{email}').execute()
+        print(response)
+        return "omkar"

models/supabase_init.py

@@ -0,0 +1,19 @@
+from pydantic import BaseModel
+from dotenv import load_dotenv
+from supabase import create_client
+from functools import lru_cache
+import os
+
+@lru_cache(maxsize=1)
+class Supabase_Settings(BaseModel):
+
+    SUPABASE_URL: str = os.getenv("SUPABASE_URL")
+    SUPABASE_ANON_KEY: str = os.getenv("SUPABASE_ANON_KEY")
+    SUPABASE_SERVICE_KEY: str = os.getenv("SUPABASE_SERVICE_KEY")
+
+
+
+@lru_cache(maxsize=1)
+class Supabase_Clients:
+    values = Supabase_Settings()
+    anon_supabase = create_client(values.SUPABASE_URL, values.SUPABASE_ANON_KEY)

routers/receipt_radar_callback_router.py

@@ -0,0 +1,35 @@
+from fastapi import APIRouter , Request ,HTTPException
+from constants import TOKEN_GENERATION_API,REFRESH_TOKEN_PAYLOAD,USER_INFO_API
+import requests
+from dependencies import database as sp
+import os
+from dotenv import load_dotenv
+load_dotenv()
+
+router = APIRouter(prefix="/receipt_radar")
+
+@router.get("/callback")
+async def callback(code:str):
+    token_url = TOKEN_GENERATION_API
+    print("Authorisation code : ",code)
+    data= {
+        "code":code,
+        "client_id": os.getenv("GOOGLE_CLIENT_ID"),
+        "client_secret": os.getenv("GOOGLE_CLIENT_SECRET"),
+        "redirect_uri": os.getenv("GOOGLE_REDIRECT_URI"),
+        "grant_type": "authorization_code",
+        "access_type": "offline"
+    }
+    
+    response = requests.post(token_url, data=data)
+    print(response.json())
+    access_token = response.json().get("access_token",None)
+    refresh_token=response.json().get('refresh_token',None)
+    user_info_api = USER_INFO_API +"?access_token="+f"{access_token}"
+    user_info_response = requests.get(user_info_api)
+    user_email = user_info_response.json().get('email')
+    print(user_email)
+    # hushh_id = await sp.SupabaseDb().get_hushh_id(user_email)
+
+
+    return {"payload":response.json()}