fix3

app.py

@@ -12,7 +12,7 @@ from uvicorn import run as uvicorn_run
 
 # Slack Libraries (Async versions)
 from slack_bolt.async_app import AsyncApp
-from slack_bolt.adapter.fastapi import AsyncSlackRequestHandler
+from slack_bolt.adapter.fastapi.async_handler import AsyncSlackRequestHandler
 from slack_sdk.oauth.installation_store.async_installation_store import AsyncInstallationStore
 from slack_sdk.oauth import AuthorizeUrlGenerator
 from slack_bolt.models.installation import Installation
@@ -76,9 +76,8 @@ class SupabaseAsyncInstallationStore(AsyncInstallationStore):
         }
         try:
             await asyncio.to_thread(
-                self.supabase.table("installations").upsert, data, on_conflict="team_id"
+                lambda: self.supabase.table("installations").upsert(data, on_conflict="team_id").execute()
             )
-            await asyncio.to_thread(self.supabase.table("installations").upsert(data, on_conflict="team_id").execute)
             logger.info(f"Saved installation for team: {installation.team_id}")
         except Exception as e:
             logger.error(f"Failed to save installation for team {installation.team_id}: {e}")
@@ -87,7 +86,7 @@ class SupabaseAsyncInstallationStore(AsyncInstallationStore):
     async def fetch_installation(self, team_id: str, *, enterprise_id: str | None = None, user_id: str | None = None) -> Installation | None:
         try:
             result = await asyncio.to_thread(
-                self.supabase.table("installations").select("*").eq("team_id", team_id).execute
+                lambda: self.supabase.table("installations").select("*").eq("team_id", team_id).execute()
             )
             if not result.data:
                 return None
@@ -105,12 +104,12 @@ class SupabaseAsyncInstallationStore(AsyncInstallationStore):
             )
         except Exception as e:
             logger.error(f"Failed to fetch installation for team {team_id}: {e}")
-            raise
+            return None
 
     async def delete(self, team_id: str, *, enterprise_id: str | None = None, user_id: str | None = None) -> None:
         try:
             await asyncio.to_thread(
-                self.supabase.table("installations").delete().eq("team_id", team_id).execute
+                lambda: self.supabase.table("installations").delete().eq("team_id", team_id).execute()
             )
             logger.info(f"Deleted installation for team: {team_id}")
         except Exception as e:
@@ -210,10 +209,10 @@ async def store_embeddings(chunks: List[str]):
         embedding = embed_text(chunk)
         try:
             await asyncio.to_thread(
-                supabase.table("documents").insert({
-                    "content": chunk,
-                    "embedding": embedding
-                }).execute
+                lambda c=chunk, e=embedding: supabase.table("documents").insert({
+                    "content": c,
+                    "embedding": e
+                }).execute()
             )
         except Exception as e:
             logger.error(f"Failed to insert chunk into Supabase: {str(e)}")
@@ -222,7 +221,7 @@ async def is_table_empty() -> bool:
     """Checks if the documents table has any records."""
     try:
         result = await asyncio.to_thread(
-            supabase.table("documents").select("id", count="exact").limit(1).execute
+            lambda: supabase.table("documents").select("id", count="exact").limit(1).execute()
         )
         return result.count == 0
     except Exception as e:
@@ -236,9 +235,9 @@ async def search_documents(query: str, match_count: int = 5) -> List[Dict[str, A
     query_embedding = embed_text(query)
     try:
         result = await asyncio.to_thread(
-            lambda: supabase.rpc("match_documents", {
-                "query_embedding": query_embedding,
-                "match_count": match_count
+            lambda qe=query_embedding, mc=match_count: supabase.rpc("match_documents", {
+                "query_embedding": qe,
+                "match_count": mc
             }).execute()
         )
         return result.data
@@ -257,7 +256,7 @@ async def answer_question(question: str, context: str) -> str:
         context_slice = context[:MAX_CONTEXT_LEN]
         
         result = await asyncio.to_thread(
-            qa_pipeline, question=question, context=context_slice
+            lambda: qa_pipeline(question=question, context=context_slice)
         )
         return result['answer']
     except Exception as e:
@@ -373,7 +372,7 @@ async def health():
     db_status = "error"
     try:
         await asyncio.to_thread(
-            supabase.table("installations").select("team_id").limit(1).execute
+            lambda: supabase.table("installations").select("team_id").limit(1).execute()
         )
         db_status = "ok"
     except Exception as e:
@@ -391,6 +390,7 @@ async def install_url():
             scopes=["app_mentions:read", "files:read", "chat:write", "im:read", "im:write", "channels:read"]
         )
         # NOTE: The redirect_uri should match your Slack App config (e.g., https://yourspace.hf.space/slack/oauth/callback)
+        # If needed, add: redirect_uri=os.environ.get("SLACK_REDIRECT_URI")
         url = generator.generate(state="state")
         return {"install_url": url}
     except Exception as e:
@@ -403,7 +403,7 @@ async def oauth_callback(request: Request):
     try:
         response = await handler.handle_async(request)
         # For successful OAuth, return a simple HTML response
-        if response.status_code == 200:
+        if hasattr(response, 'status_code') and response.status_code == 200:
             return HTMLResponse(
                 content="<html><body><h1>Installation successful!</h1><p>You can now use the bot in your Slack workspace.</p></body></html>",
                 status_code=200