debug3

app.py

@@ -228,43 +228,29 @@ class SupabaseAsyncInstallationStore(AsyncInstallationStore):
 # Initialize installation store
 installation_store = SupabaseAsyncInstallationStore(supabase)
 
-# Custom authorize function with token rotation
-async def async_authorize(enterprise_id, team_id, user_id):
-    """Custom authorization with automatic token rotation."""
-    logger.info(f"Authorizing request for team: {team_id}")
-    
-    # Try to find installation (will auto-rotate if needed)
-    installation = await installation_store.async_find_installation(
-        enterprise_id=enterprise_id,
-        team_id=team_id,
-        user_id=user_id
-    )
-    
-    if installation:
-        return AuthorizeResult(
-            enterprise_id=enterprise_id or installation.enterprise_id,
-            team_id=team_id,
-            user_id=user_id or installation.user_id,
-            bot_token=installation.bot_token,
-            bot_user_id=installation.bot_user_id,
-        )
-    
-    logger.warning(f"No installation found for team {team_id}")
-    return None
-
 # Initialize Bolt Async App with OAuth
+# Note: When using oauth_settings, authorization is handled automatically
+# The installation_store's async_find_installation method handles token rotation
 app = AsyncApp(
     signing_secret=SLACK_SIGNING_SECRET,
     installation_store=installation_store,
-    authorize=async_authorize,
+    # DO NOT use 'authorize' when using 'oauth_settings' - they conflict
     oauth_settings=AsyncOAuthSettings(
         client_id=SLACK_CLIENT_ID,
         client_secret=SLACK_CLIENT_SECRET,
         scopes=[
-            "app_mentions:read",
-            "files:read",
-            "chat:write",
-            "channels:read",
+            # Core required scopes
+            "app_mentions:read",      # Listen when bot is @mentioned
+            "chat:write",             # Send messages as the bot
+            "files:read",             # Read uploaded files
+            "channels:read",          # View basic channel info
+            # DM support (recommended)
+            "im:read",                # View DM info
+            "im:write",               # Send DMs
+            "im:history",             # Read DM messages
+            # Optional: for private channels
+            # "groups:read",          # View private channel info
+            # "channels:history",     # Read channel message history
         ],
         install_path="/slack/install",
         redirect_uri_path="/slack/oauth_redirect",
@@ -468,6 +454,39 @@ async def handle_mention(event, say):
         logger.error(f"Error answering query '{user_query}': {e}")
         await say(f"❌ Error: {str(e)}")
 
+@app.event("message")
+async def handle_message(event, say):
+    """Handles direct messages to the bot."""
+    # Only respond to DMs (not channel messages)
+    if event.get("channel_type") == "im":
+        text = event.get("text", "").strip()
+        
+        if not text:
+            return
+        
+        # Don't respond to bot's own messages
+        if event.get("bot_id"):
+            return
+        
+        try:
+            if await is_table_empty():
+                await say("📚 My knowledge base is empty. Please share PDF or DOCX files in a channel where I'm present!")
+                return
+            
+            results = await search_documents(text, match_count=5)
+            
+            if not results:
+                await say("🔍 I couldn't find relevant information. Try asking about uploaded documents.")
+                return
+            
+            context = " ".join([doc["content"] for doc in results])
+            answer = await answer_question(text, context)
+            
+            await say(f"💡 **Answer:** {answer}\n\n_Found from {len(results)} document chunks._")
+        except Exception as e:
+            logger.error(f"Error in DM handler: {e}")
+            await say(f"❌ Error: {str(e)}")
+
 # --- FastAPI Routes ---
 handler = AsyncSlackRequestHandler(app)