welcome message issue

.gitignore

@@ -138,4 +138,5 @@ dmypy.json
 cython_debug/
 service-account.json
 .env.test
-uploads/
+uploads/
+slack_state

src/controllers/_bot_controller.py

@@ -60,6 +60,7 @@ class BotController:
                                                 "slack_id": slack_user_id,
                                             },
                                         )
+                                        user_service.send_message(user.id, "Welcome to MandalaBot", team.token)
 
                         if not user:
                             logger.error("User not found or created")
@@ -71,8 +72,10 @@ class BotController:
                                     file_id = file["id"]
                                     logger.info(f"Processing file id: {file_id}")
                                     async with SlackBotService() as slack_bot_service:
-                                        uploaded_file = await slack_bot_service.save_file(
-                                            team, file
+                                        uploaded_file = (
+                                            await slack_bot_service.save_file(
+                                                team, file
+                                            )
                                         )
                                         if uploaded_file:
                                             await file_service.process_file(
@@ -82,7 +85,9 @@ class BotController:
                                                 slack_token=team.token,
                                             )
                                         else:
-                                            logger.error(f"Failed to save file {file_id}")
+                                            logger.error(
+                                                f"Failed to save file {file_id}"
+                                            )
 
                             elif "file" in actual_event:
                                 file_id = actual_event["file"]["id"]
@@ -147,6 +152,8 @@ class BotController:
                                             "slack_id": slack_user["id"],
                                         },
                                     )
+                                    await user_service.send_message(user.id, "Welcome to MandalaBot", team.token)
+
             return {"message": "installed successfully"}
         except HTTPException as e:
             logger.warning(e)

src/services/_slack_bot_service.py

@@ -35,7 +35,7 @@ class SlackBotService:
 
     async def generate_auth_url(self):
         state = self.state_store.issue()
-
+        print(">>>>>>>>>>>>>>>>>>", os.getenv("SLACK_REDIRECT_URI"))
         url_generator = AuthorizeUrlGenerator(
             client_id=os.environ.get("SLACK_CLIENT_ID"),
             redirect_uri=os.getenv("SLACK_REDIRECT_URI"),
@@ -90,8 +90,8 @@ class SlackBotService:
                             detail="Failed to download file from Slack",
                         )
 
-    async def send_im_message(self, slack_id: str, message: str, to_channel=False):
-        async with SlackClient() as slack_client:
+    async def send_im_message(self, slack_id: str, message: str, token: str, to_channel=False):
+        async with SlackClient(token=token) as slack_client:
             await slack_client.send_message(slack_id, message, to_channel)
 
     async def get_user_email(self, token: str, user_id: str) -> str | None:

src/services/_user_service.py

@@ -56,7 +56,9 @@ class UserService:
         """Get user by Slack ID"""
         return await self.user_repository.get_user_by_slack_id(slack_id)
 
-    async def update_user_frequency(self, user_id: int, frequency: ContentDeliveryFrequency) -> Optional[User]:
+    async def update_user_frequency(
+        self, user_id: int, frequency: ContentDeliveryFrequency
+    ) -> Optional[User]:
         """Update user's content delivery frequency and next delivery date"""
         # First get the user to access last_message_sent_at
         async with self.user_repository.get_session() as session:
@@ -71,18 +73,18 @@ class UserService:
 
             update_data = {
                 "content_delivery_frequency": frequency,
-                "next_content_delivery_date": next_delivery_date
+                "next_content_delivery_date": next_delivery_date,
             }
 
             return await self.user_repository.patch(user_id, update_data)
 
-    async def send_message(self, user_id: int, message: str):
+    async def send_message(self, user_id: int, message: str, token: str):
         """Send message to user"""
         user = await self.user_repository.get(user_id)
 
         if user and user.slack_id:
             async with SlackBotService() as slack_bot_service:
-                await slack_bot_service.send_im_message(user.slack_id, message)
+                await slack_bot_service.send_im_message(user.slack_id, message, token)
         else:
             logger.error(f"User not found for user_id: {user_id}")
             return {"message": "User not found"}