Spaces:

NeerajCodz
/

rag-slack

Sleeping

App Files Files Community

NeerajCodz commited on Dec 5, 2025

Commit

ee7cf13

verified ·

1 Parent(s): bfcab68

debug

Browse files

Files changed (1) hide show

app.py +22 -8

app.py CHANGED Viewed

@@ -76,20 +76,23 @@ class SupabaseAsyncInstallationStore(AsyncInstallationStore):
             "app_id": installation.app_id,
         }
         try:
-            await asyncio.to_thread(
                 lambda: 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}")
             raise
     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(
                 lambda: self.supabase.table("installations").select("*").eq("team_id", team_id).execute()
             )
             if not result.data:
                 return None
             data = result.data[0]
@@ -357,12 +360,11 @@ async def handle_mention(event, say, client):
 # Initialize the Async Slack Request Handler
 handler = AsyncSlackRequestHandler(app)
-# In the slack_events endpoint (around line 364)
 @api.post("/slack/events")
 async def slack_events(request: Request):
     """Endpoint for all Slack event subscriptions."""
     try:
-        return await handler.handle(request)  # Changed from handle_async
     except Exception as e:
         logger.error(f"Error handling Slack events: {e}")
         raise
@@ -403,26 +405,38 @@ async def install_url():
         logger.error(f"Error generating install URL: {e}")
         raise
-# In the oauth_callback endpoint
 @api.get("/slack/oauth/callback")
 async def oauth_callback(request: Request):
     """Handles the OAuth callback from Slack to complete installation."""
     try:
-        response = await handler.handle(request)  # Changed from handle_async
         # For successful OAuth, return a simple HTML response
         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
             )
         return response
     except Exception as e:
         logger.error(f"OAuth Callback Error: {e}")
         return HTMLResponse(
-            content=f"<html><body><h1>Installation Failed!</h1><p>Error: {str(e)}</p></body></html>",
             status_code=500
         )
 if __name__ == "__main__":
     port = int(os.environ.get("PORT", 7860))

             "app_id": installation.app_id,
         }
         try:
+            result = await asyncio.to_thread(
                 lambda: self.supabase.table("installations").upsert(data, on_conflict="team_id").execute()
             )
+            logger.info(f"Saved installation for team: {installation.team_id}. Result: {result.data}")
         except Exception as e:
             logger.error(f"Failed to save installation for team {installation.team_id}: {e}")
             raise
     async def fetch_installation(self, team_id: str, *, enterprise_id: str | None = None, user_id: str | None = None) -> Installation | None:
+        logger.info(f"Fetching installation for team_id: {team_id}, enterprise_id: {enterprise_id}, user_id: {user_id}")  # DEBUG LOG
         try:
             result = await asyncio.to_thread(
                 lambda: self.supabase.table("installations").select("*").eq("team_id", team_id).execute()
             )
+            logger.info(f"Fetch result for {team_id}: {len(result.data)} rows")  # DEBUG LOG
             if not result.data:
+                logger.warning(f"No installation found for team {team_id}")  # Instead of error here
                 return None
             data = result.data[0]
 # Initialize the Async Slack Request Handler
 handler = AsyncSlackRequestHandler(app)
 @api.post("/slack/events")
 async def slack_events(request: Request):
     """Endpoint for all Slack event subscriptions."""
     try:
+        return await handler.handle(request)
     except Exception as e:
         logger.error(f"Error handling Slack events: {e}")
         raise
         logger.error(f"Error generating install URL: {e}")
         raise
 @api.get("/slack/oauth/callback")
 async def oauth_callback(request: Request):
     """Handles the OAuth callback from Slack to complete installation."""
     try:
+        response = await handler.handle(request)
+        logger.info(f"OAuth callback response: {response.status_code if hasattr(response, 'status_code') else 'No status'}")  # DEBUG
         # For successful OAuth, return a simple HTML response
         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><p>Check Supabase for new installation data.</p></body></html>",
                 status_code=200
             )
         return response
     except Exception as e:
         logger.error(f"OAuth Callback Error: {e}")
         return HTMLResponse(
+            content=f"<html><body><h1>Installation Failed!</h1><p>Error: {str(e)}</p><p>Check logs and Supabase.</p></body></html>",
             status_code=500
         )
+# Optional: Add a debug endpoint to check installation
+@api.get("/debug/installations")
+async def debug_installations():
+    """Debug: List all installations (remove in prod)."""
+    try:
+        result = await asyncio.to_thread(
+            lambda: supabase.table("installations").select("*").execute()
+        )
+        return {"installations": result.data}
+    except Exception as e:
+        return {"error": str(e)}
 if __name__ == "__main__":
     port = int(os.environ.get("PORT", 7860))