testing endpoint

app.py

@@ -48,7 +48,7 @@ from PIL import Image
 
 # pytesseract
 import pytesseract
-from auth.clerk import verify_clerk_jwt
+# from auth.clerk import verify_clerk_jwt
 
 # --- MODIFIED: Replaced old tool imports with the new one ---
 from tools.tools import analyze_contract
@@ -125,117 +125,117 @@ async def analyze_contract_endpoint(file: UploadFile = File(...)):
         )
     
 
-@app.post("/upload")
-async def upload_file(authorization: str = Header(...), file: UploadFile = File(...)):
-    if not authorization.startswith("Bearer "):
-        raise HTTPException(status_code=401, detail="Missing Bearer token")
-
-    token = authorization.split(" ")[1]
-    claims = await verify_clerk_jwt(token)
-
-    user_id = claims.get("sub")  # Clerk user ID
-    filename = f"{user_id}/{uuid.uuid4()}.png"
-
-    # Upload to Supabase Storage
-    async with httpx.AsyncClient() as client:
-        upload_resp = await client.post(
-            f"{SUPABASE_URL}/storage/v1/object/user-documents/{filename}",
-            headers={
-                "Authorization": f"Bearer {SUPABASE_SERVICE_ROLE_KEY}",
-                "Content-Type": file.content_type,
-            },
-            content=await file.read(),
-        )
+# @app.post("/upload")
+# async def upload_file(authorization: str = Header(...), file: UploadFile = File(...)):
+#     if not authorization.startswith("Bearer "):
+#         raise HTTPException(status_code=401, detail="Missing Bearer token")
 
-    if upload_resp.status_code != 200:
-        raise HTTPException(
-            status_code=500, detail="Failed to upload to Supabase Storage"
-        )
+#     token = authorization.split(" ")[1]
+#     claims = await verify_clerk_jwt(token)
 
-    file_url = f"user-documents/{filename}"
-
-    # Insert metadata to `documents` table
-    async with httpx.AsyncClient() as client:
-        insert_resp = await client.post(
-            f"{SUPABASE_URL}/rest/v1/documents",
-            headers={
-                "Authorization": f"Bearer {SUPABASE_SERVICE_ROLE_KEY}",
-                "apikey": SUPABASE_SERVICE_ROLE_KEY,
-                "Content-Type": "application/json",
-                "Prefer": "return=representation",
-            },
-            json={
-                "user_id": user_id,
-                "filename": filename.split("/")[-1],
-                "file_url": file_url,
-            },
-        )
+#     user_id = claims.get("sub")  # Clerk user ID
+#     filename = f"{user_id}/{uuid.uuid4()}.png"
 
-    if insert_resp.status_code >= 300:
-        raise HTTPException(
-            status_code=500, detail="Failed to insert document metadata"
-        )
+#     # Upload to Supabase Storage
+#     async with httpx.AsyncClient() as client:
+#         upload_resp = await client.post(
+#             f"{SUPABASE_URL}/storage/v1/object/user-documents/{filename}",
+#             headers={
+#                 "Authorization": f"Bearer {SUPABASE_SERVICE_ROLE_KEY}",
+#                 "Content-Type": file.content_type,
+#             },
+#             content=await file.read(),
+#         )
 
-    return {"message": f"File uploaded as {filename}"}
+#     if upload_resp.status_code != 200:
+#         raise HTTPException(
+#             status_code=500, detail="Failed to upload to Supabase Storage"
+#         )
 
+#     file_url = f"user-documents/{filename}"
 
-@app.get("/api/documents")
-async def get_user_documents(
-    credentials: HTTPAuthorizationCredentials = Depends(security),
-):
-    token = credentials.credentials
-    claims = await verify_clerk_jwt(token)
-    user_id = claims.get("sub")
-    if not user_id:
-        raise HTTPException(status_code=401, detail="Invalid user")
-
-    # Step 1: Get documents from Supabase
-    async with httpx.AsyncClient() as client:
-        resp = await client.get(
-            f"{SUPABASE_URL}/rest/v1/documents?user_id=eq.{user_id}",
-            headers={
-                "apikey": SUPABASE_SERVICE_ROLE_KEY,
-                "Authorization": f"Bearer {SUPABASE_SERVICE_ROLE_KEY}",
-                "Accept": "application/json",
-            },
-        )
+#     # Insert metadata to `documents` table
+#     async with httpx.AsyncClient() as client:
+#         insert_resp = await client.post(
+#             f"{SUPABASE_URL}/rest/v1/documents",
+#             headers={
+#                 "Authorization": f"Bearer {SUPABASE_SERVICE_ROLE_KEY}",
+#                 "apikey": SUPABASE_SERVICE_ROLE_KEY,
+#                 "Content-Type": "application/json",
+#                 "Prefer": "return=representation",
+#             },
+#             json={
+#                 "user_id": user_id,
+#                 "filename": filename.split("/")[-1],
+#                 "file_url": file_url,
+#             },
+#         )
 
-    if resp.status_code != 200:
-        raise HTTPException(status_code=500, detail="Failed to fetch documents")
-
-    documents = resp.json()
-
-    # Step 2: Get signed URLs for each file
-    async with httpx.AsyncClient() as client:
-        for doc in documents:
-            file_path = doc["file_url"].split("user-documents/", 1)[-1]
-            if not file_path:
-                doc["signed_url"] = None
-                continue
-
-            signed_url_resp = await client.post(
-                f"{SUPABASE_URL}/storage/v1/object/sign/user-documents/{file_path}",
-                headers={
-                    "apikey": SUPABASE_SERVICE_ROLE_KEY,
-                    "Authorization": f"Bearer {SUPABASE_SERVICE_ROLE_KEY}",
-                    # "Content-Type": "application/json"
-                },
-                json={"expiresIn": 3600},  # 1 hour
-            )
+#     if insert_resp.status_code >= 300:
+#         raise HTTPException(
+#             status_code=500, detail="Failed to insert document metadata"
+#         )
+
+#     return {"message": f"File uploaded as {filename}"}
+
+
+# @app.get("/api/documents")
+# async def get_user_documents(
+#     credentials: HTTPAuthorizationCredentials = Depends(security),
+# ):
+#     token = credentials.credentials
+#     claims = await verify_clerk_jwt(token)
+#     user_id = claims.get("sub")
+#     if not user_id:
+#         raise HTTPException(status_code=401, detail="Invalid user")
+
+#     # Step 1: Get documents from Supabase
+#     async with httpx.AsyncClient() as client:
+#         resp = await client.get(
+#             f"{SUPABASE_URL}/rest/v1/documents?user_id=eq.{user_id}",
+#             headers={
+#                 "apikey": SUPABASE_SERVICE_ROLE_KEY,
+#                 "Authorization": f"Bearer {SUPABASE_SERVICE_ROLE_KEY}",
+#                 "Accept": "application/json",
+#             },
+#         )
+
+#     if resp.status_code != 200:
+#         raise HTTPException(status_code=500, detail="Failed to fetch documents")
+
+#     documents = resp.json()
+
+#     # Step 2: Get signed URLs for each file
+#     async with httpx.AsyncClient() as client:
+#         for doc in documents:
+#             file_path = doc["file_url"].split("user-documents/", 1)[-1]
+#             if not file_path:
+#                 doc["signed_url"] = None
+#                 continue
+
+#             signed_url_resp = await client.post(
+#                 f"{SUPABASE_URL}/storage/v1/object/sign/user-documents/{file_path}",
+#                 headers={
+#                     "apikey": SUPABASE_SERVICE_ROLE_KEY,
+#                     "Authorization": f"Bearer {SUPABASE_SERVICE_ROLE_KEY}",
+#                     # "Content-Type": "application/json"
+#                 },
+#                 json={"expiresIn": 3600},  # 1 hour
+#             )
 
-            if signed_url_resp.status_code == 200:
-                print(
-                    f"{SUPABASE_URL}/storage/v1{signed_url_resp.json().get('signedURL')}"
-                )
-                doc["signed_url"] = (
-                    f"{SUPABASE_URL}/storage/v1{signed_url_resp.json().get('signedURL')}"
-                )
+#             if signed_url_resp.status_code == 200:
+#                 print(
+#                     f"{SUPABASE_URL}/storage/v1{signed_url_resp.json().get('signedURL')}"
+#                 )
+#                 doc["signed_url"] = (
+#                     f"{SUPABASE_URL}/storage/v1{signed_url_resp.json().get('signedURL')}"
+#                 )
 
-            else:
-                doc["signed_url"] = None
-    print(documents)
+#             else:
+#                 doc["signed_url"] = None
+#     print(documents)
 
-    return documents
+#     return documents
 
 
 # --- END: NEW ENDPOINT FOR THE REFACTORED TOOL ---