Final commit Slack message

index.py

@@ -88,6 +88,19 @@ def webhook():
                 print(diff)
 
                 # save_md_report("DIFF.md", data)
+                
+                send_slack_message(
+                    message_text = pr_report,
+                    webhook_url = SLACK_WEBHOOK_URL,
+                    bot_token = SLACK_BOT_TOKEN,
+                    channel = "pull-request",
+                    blocks = [
+                        {
+                            "type": "markdown",
+                            "text": "<@U099W8UMBAQ>"
+                        }
+                    ]
+                ) 
 
                 send_slack_message(
                     message_text = pr_report,
@@ -111,7 +124,13 @@ def webhook():
                     message_text = code_review_text,
                     webhook_url = SLACK_WEBHOOK_URL,
                     bot_token = SLACK_BOT_TOKEN,
-                    channel = "pull-request"
+                    channel = "pull-request", 
+                    blocks = [
+                        {
+                            "type": "markdown",
+                            "text": code_review_text
+                        }
+                    ]
                 )
                 print("Sent code review") 
 

test_logfire.py

@@ -60,37 +60,62 @@ load_dotenv()
 #     # Test async tracing
 #     asyncio.run(test_logfire_tracing())
     
-from tool import send_slack_message
+from tool import send_slack_message, list_slack_users, get_slack_usergroups
 from dotenv import load_dotenv
 
 load_dotenv()
 
-report = f"""# [] PR #1: Change something PR
-Hello World
+# report = f"""# [] PR #1: Change something PR
+# Hello World
 
-**🌿 Branch Information:**
-- **Source Branch:**  → **Target Branch:** 
+# **🌿 Branch Information:**
+# - **Source Branch:**  → **Target Branch:** 
 
-**👤 Người tạo:** Hải Huỳnh @Hai Huynh
+# **👤 Người tạo:** Hải Huỳnh @Hai Huynh
 
-**📅 Thời gian tạo:** 2024-08-20 14:30:00 +07:00
+# **📅 Thời gian tạo:** 2024-08-20 14:30:00 +07:00
 
-**👥 Reviewers:**
+# **👥 Reviewers:**
 
-**🔗 Link Pull Request:** [PR #1: Implement user authentication system](https://google.com.vn)
-"""
+# **🔗 Link Pull Request:** [PR #1: Implement user authentication system](https://google.com.vn)
+# """
+
+
+# send_slack_message(
+#     message_text = "Hello, *World*",                
+#     webhook_url = os.getenv("SLACK_WEBHOOK_URL"),
+#     bot_token = os.getenv("SLACK_BOT_TOKEN"),
+#     channel = "pull-request",
+#     blocks = [
+#         {
+#             "type": "markdown",
+#             "text": report
+#         }
+#     ]
+# ) 
+
+import requests
 
+# Thay token bằng bot token Slack của bạn
+SLACK_BOT_TOKEN = os.getenv("SLACK_BOT_TOKEN")
+SLACK_WEBHOOK_URL = os.getenv("SLACK_WEBHOOK_URL")
+url = "https://slack.com/api/users.list"
+
+users = list_slack_users()
+groups = get_slack_usergroups(SLACK_BOT_TOKEN)
+
+# print(users)
+print(groups)
 
 send_slack_message(
-    message_text = "Hello, *World*",                
-    webhook_url = os.getenv("SLACK_WEBHOOK_URL"),
-    bot_token = os.getenv("SLACK_BOT_TOKEN"),
+    message_text = "",
+    webhook_url = SLACK_WEBHOOK_URL,
+    bot_token = SLACK_BOT_TOKEN,
     channel = "pull-request",
     blocks = [
         {
             "type": "markdown",
-            "text": report
+            "text": "<@U099W8UMBAQ>"
         }
     ]
-) 
-
+) 

tool.py

@@ -34,7 +34,6 @@ def create_session(username: Optional[str] = None, app_password: Optional[str] =
     session = requests.Session()
     session.auth = (resolved_username, resolved_app_password)
     session.headers.update({"Accept": "application/json"})
-    session.headers.update({"Content-Type": "application/json"})
     return session
 
 
@@ -230,6 +229,81 @@ def send_slack_message(
         "Missing Slack configuration. Provide SLACK_WEBHOOK_URL or SLACK_BOT_TOKEN and SLACK_CHANNEL."
     )
 
+def list_slack_users(*, bot_token: Optional[str] = None, include_bots: bool = True) -> List[Dict[str, Any]]:
+    """
+    Trả về danh sách user Slack sử dụng Web API users.list (có phân trang).
+    - bot_token: ưu tiên dùng tham số, nếu không có sẽ lấy SLACK_BOT_TOKEN từ env
+    - include_bots: False để lọc bỏ bot
+    """
+    token = bot_token or SLACK_BOT_TOKEN
+    if not token:
+        raise ValueError("Missing Slack bot token. Provide bot_token or set SLACK_BOT_TOKEN.")
+
+    users: List[Dict[str, Any]] = []
+    cursor: Optional[str] = None
+    headers = {
+        "Authorization": f"Bearer {token}",
+        "Content-Type": "application/x-www-form-urlencoded; charset=utf-8",
+    }
+
+    while True:
+        params: Dict[str, Any] = {"limit": 200}
+        if cursor:
+            params["cursor"] = cursor
+
+        resp = requests.get("https://slack.com/api/users.list", headers=headers, params=params, timeout=30)
+        resp.raise_for_status()
+        data = resp.json()
+        if not data.get("ok", False):
+            raise ValueError(f"Slack API responded with error: {data.get('error', 'unknown_error')}")
+
+        page_members = data.get("members", [])
+        if not include_bots:
+            page_members = [m for m in page_members if not m.get("is_bot", False)]
+        users.extend(page_members)
+
+        cursor = (data.get("response_metadata") or {}).get("next_cursor")
+        if not cursor:
+            break
+
+    return users
+
+def get_slack_usergroups(bot_token: str):
+    """
+    Lấy danh sách Slack User Groups (subteams).
+    
+    Args:
+        bot_token (str): Slack Bot Token (bắt đầu bằng xoxb-...).
+        
+    Returns:
+        list[dict]: Danh sách user groups gồm {id, handle, name, description}.
+    """
+    url = "https://slack.com/api/usergroups.list"
+    headers = {
+        "Authorization": f"Bearer {bot_token}"
+    }
+
+    response = requests.get(url, headers=headers)
+
+    if response.status_code == 200:
+        data = response.json()
+        if data.get("ok"):
+            usergroups = []
+            for group in data.get("usergroups", []):
+                usergroups.append({
+                    "id": group.get("id"),                  # subteam ID
+                    "handle": group.get("handle"),          # ví dụ: dev, qa
+                    "name": group.get("name"),              # tên đầy đủ
+                    "description": group.get("description") # mô tả
+                })
+            return usergroups
+        else:
+            raise Exception(f"Slack API error: {data.get('error')}")
+    else:
+        raise Exception(f"HTTP Error: {response.status_code}")
+
+
+
 def main() -> None:
     # parser = argparse.ArgumentParser(description="Fetch full details of a Bitbucket Cloud pull request.")
     # parser.add_argument("--username", required=True, help="Bitbucket username")