Upload files

.dockerignore

@@ -0,0 +1,9 @@
+__pycache__/
+*.pyc
+*.pyo
+*.pyd
+.env
+.git/
+DIFF.md
+PR.md
+README.md 

.gitignore

@@ -0,0 +1,51 @@
+# These are some examples of commonly ignored file patterns.
+# You should customize this list as applicable to your project.
+# Learn more about .gitignore:
+#     https://www.atlassian.com/git/tutorials/saving-changes/gitignore
+
+# Node artifact files
+node_modules/
+dist/
+
+# Compiled Java class files
+*.class
+
+# Compiled Python bytecode
+*.py[cod]
+
+# Log files
+*.log
+
+# Package files
+*.jar
+
+# Maven
+target/
+dist/
+
+# JetBrains IDE
+.idea/
+
+# Unit test reports
+TEST*.xml
+
+# Generated by MacOS
+.DS_Store
+
+# Generated by Windows
+Thumbs.db
+
+# Applications
+*.app
+*.exe
+*.war
+
+# Large media files
+*.mp4
+*.tiff
+*.avi
+*.flv
+*.mov
+*.wmv
+
+.env

Dockerfile

@@ -0,0 +1,37 @@
+
+FROM python:latest
+
+RUN apt-get update \
+ && apt-get install unzip \
+ && apt install pv
+
+WORKDIR /code
+
+COPY ./requirements.txt /code/requirements.txt
+
+RUN pip install --no-cache-dir --upgrade -r /code/requirements.txt
+
+# Set up a new user named "user" with user ID 1000
+RUN useradd -m -u 1000 user
+
+# Switch to the "user" user
+USER user
+
+# Set home to the user's home directory
+ENV HOME=/home/user \
+	PATH=/home/user/.local/bin:$PATH
+
+# Set the working directory to the user's home directory
+WORKDIR $HOME/app
+
+# Try and run pip command after setting the user with `USER user` to avoid permission issues with Python
+RUN pip install --no-cache-dir --upgrade pip
+# RUN pip install gdown tqdm
+# RUN gdown --id 0B7EVK8r0v71pZjFTYXZWM3FlRnM
+
+# Copy the current directory contents into the container at $HOME/app setting the owner to the user
+COPY --chown=user . $HOME/app
+# RUN n_files=`unzip -l image_align_celeba.zip | tail -n 1 | xargs echo -n | cut -d' ' -f2`
+# RUN unzip -oq img_align_celeba.zip | tqdm --desc extracted --unit files --unit_scale --total $n_files > /dev/null
+
+CMD ["python", "index.py"]

agent/code_review.py

@@ -0,0 +1,414 @@
+from __future__ import annotations
+
+import argparse
+import asyncio
+import json
+import os
+from pathlib import Path
+from typing import List, Optional, Dict, Iterable, Tuple
+
+from pydantic import BaseModel, Field
+from pydantic_ai import Agent, RunContext
+from dotenv import load_dotenv
+
+load_dotenv()
+
+# =============================
+# Data models for structured output
+# =============================
+
+
+class Issue(BaseModel):
+    title: str = Field(..., description="Short, actionable issue title")
+    description: str = Field(..., description="Clear explanation, why it matters, and how to fix")
+    severity: str = Field(..., description="One of: low, medium, high, critical")
+    line: Optional[int] = Field(None, description="Line number if known/applicable")
+    rule: Optional[str] = Field(None, description="Optional rule or best practice identifier")
+
+
+class FileReview(BaseModel):
+    file_path: str
+    summary: str
+    score: int = Field(..., ge=0, le=10, description="10 = excellent, 0 = very poor")
+    issues: List[Issue] = Field(default_factory=list)
+    suggestions: List[str] = Field(default_factory=list)
+
+
+class CodeReviewResponse(BaseModel):
+    overall_summary: str
+    overall_score: int = Field(..., ge=0, le=10)
+    files: List[FileReview]
+    quick_actions: List[str] = Field(default_factory=list, description="Concise TODOs that can be applied immediately")
+
+class DiffDeps(BaseModel):
+    diff: str
+
+# =============================
+# Agent definition (Pydantic AI)
+# =============================
+
+
+DEFAULT_MODEL = "google-gla:gemini-2.5-flash"
+
+
+
+code_review_agent = Agent(
+    model = DEFAULT_MODEL,
+    deps_type = DiffDeps,
+    output_type = str,
+)
+
+
+@code_review_agent.system_prompt
+def systemt_prompt(ctx: RunContext) -> str:
+    return f"""
+You are a code review agent focused on analyzing pull request changes and generating concise summary change logs.
+
+## Your Role
+- Review code changes in pull requests
+- Generate clear, actionable summary change logs
+- Focus solely on what changed and its impact
+
+## What to Review
+- **Code modifications**: Added, deleted, or modified lines
+- **Functional changes**: New features, bug fixes, refactoring
+- **Structural changes**: File additions/deletions, directory reorganization
+- **Dependency updates**: Package changes, version bumps
+
+## What to Include in Summary
+1. **High-level overview**: Brief description of the PR's purpose
+2. **Key changes**: List of main modifications made
+3. **Files affected**: Count and types of files changed
+4. **Impact assessment**: Brief note on potential effects
+
+## Output Format
+```
+## Pull Request Summary
+
+**Purpose**: [Brief description of what this PR accomplishes]
+
+**Changes Made**:
+- [Change 1 with file reference]
+- [Change 2 with file reference]
+- [Change 3 with file reference]
+
+**Files Modified**: X files changed (+Y additions, -Z deletions)
+
+**Impact**: [Brief assessment of the changes' significance]
+```
+
+## What NOT to Focus On
+- Code style preferences (unless specifically requested)
+- Performance optimizations (unless critical)
+- Architecture discussions
+- Non-functional requirements
+- Testing strategies (unless tests are part of the changes)
+
+## Guidelines
+- Keep summaries concise but informative
+- Use clear, non-technical language when possible
+- Highlight breaking changes prominently
+- Focus on the "what" not the "how" or "why"
+- Maintain objectivity in descriptions
+
+Diff in pull request:
+{ctx.deps.diff}
+    """
+
+
+def read_text_file(path: str) -> str:
+    """Read a UTF-8 text file from disk and return its contents. Truncates very large files.
+
+    Args:
+        path: Absolute or relative path to a text file.
+    Returns:
+        File text content (possibly truncated to keep context size reasonable).
+    """
+    file_path = Path(path)
+    if not file_path.exists() or not file_path.is_file():
+        raise FileNotFoundError(f"File not found: {path}")
+
+    try:
+        text = file_path.read_text(encoding="utf-8", errors="ignore")
+    except Exception as exc:  # pragma: no cover - defensive
+        raise RuntimeError(f"Failed to read file: {path}: {exc}")
+
+    max_chars = 200_000
+    if len(text) > max_chars:
+        head = text[: max_chars // 2]
+        tail = text[-max_chars // 2 :]
+        return f"{head}\n\n... [truncated] ...\n\n{tail}"
+    return text
+
+
+def list_code_files(
+    ctx: RunContext,
+    root: str,
+    include_extensions: List[str] | None = None,
+    exclude_dirs: List[str] | None = None,
+    max_files: int = 200,
+) -> List[str]:
+    """List code files under a directory.
+
+    Args:
+        root: Directory root to scan
+        include_extensions: e.g. [".py", ".ts", ".js", ".tsx", ".java"]. If omitted, uses a sensible default set.
+        exclude_dirs: Directory names to skip (e.g. ["node_modules", ".git", "dist", "build"]).
+        max_files: Upper bound on number of results to avoid huge contexts.
+    Returns:
+        List of file paths (strings) relative to the provided root where possible.
+    """
+    root_path = Path(root)
+    if not root_path.exists():
+        raise FileNotFoundError(f"Root directory not found: {root}")
+
+    default_exts = [
+        ".py",
+        ".ts",
+        ".tsx",
+        ".js",
+        ".jsx",
+        ".java",
+        ".kt",
+        ".go",
+        ".rs",
+        ".rb",
+        ".php",
+        ".cs",
+        ".cpp",
+        ".cc",
+        ".c",
+        ".m",
+        ".mm",
+        ".sql",
+        ".yml",
+        ".yaml",
+        ".toml",
+        ".json",
+        ".md",
+    ]
+    exts = [e.lower() for e in (include_extensions or default_exts)]
+    excluded = set(exclude_dirs or {".git", "node_modules", "dist", "build", ".venv", "__pycache__"})
+
+    results: List[str] = []
+    for path in root_path.rglob("*"):
+        if path.is_dir():
+            if path.name in excluded:
+                # Skip excluded directories entirely
+                # Use try/except to ignore permission errors
+                try:
+                    # Prevent descending further
+                    continue
+                finally:
+                    ...
+            continue
+        if path.suffix.lower() in exts:
+            results.append(str(path))
+            if len(results) >= max_files:
+                break
+    return results
+
+
+# =============================
+# Utilities
+# =============================
+
+
+def gather_targets(paths: List[str]) -> Tuple[List[str], List[str]]:
+    """Split inputs into files and directories; expand files list from directories.
+
+    Returns (files, dirs)
+    """
+    files: List[str] = []
+    dirs: List[str] = []
+    for p in paths:
+        path = Path(p)
+        if path.is_file():
+            files.append(str(path))
+        elif path.is_dir():
+            dirs.append(str(path))
+        else:
+            # Ignore non-existent
+            continue
+    return files, dirs
+
+
+def build_user_prompt(
+    files: List[str],
+    dirs: List[str],
+    focus_areas: List[str],
+    max_inline_chars: int = 60_000,
+) -> str:
+    """Create a concise instruction for the agent, listing files and review goals.
+
+    We do not inline large file contents; the agent can use tools to load them on demand.
+    Small files may be inlined to reduce tool calls.
+    """
+    focus_text = ", ".join(focus_areas) if focus_areas else "general quality"
+
+    # Try to inline very small files to prime the context
+    inline_blobs: List[str] = []
+    inlined_total = 0
+    for f in files:
+        try:
+            text = Path(f).read_text(encoding="utf-8", errors="ignore")
+        except Exception:
+            continue
+        if len(text) <= 8_000 and (inlined_total + len(text)) <= max_inline_chars:
+            inline_blobs.append(f"File: {f}\n\n{text}")
+            inlined_total += len(text)
+
+    file_list_section = "\n".join(f"- {p}" for p in files)
+    dir_list_section = "\n".join(f"- {d}" for d in dirs)
+
+    inline_section = ("\n\n" + "\n\n".join(inline_blobs)) if inline_blobs else ""
+
+    return (
+        "Perform a comprehensive code review for the repository subset below.\n\n"
+        f"Focus areas: {focus_text}.\n\n"
+        "Files:\n" + file_list_section + "\n\n"
+        + ("Directories (you may list and inspect files using the provided tools):\n" + dir_list_section + "\n\n" if dirs else "")
+        + "Use the read_text_file and list_code_files tools to fetch any file content you need.\n"
+        + inline_section
+    )
+
+
+def render_markdown(result: CodeReviewResponse) -> str:
+    """Render a human-readable Markdown report from the structured output."""
+    lines: List[str] = []
+    lines.append("# Code Review Report")
+    lines.append("")
+    lines.append(f"Overall Score: {result.overall_score}/10")
+    lines.append("")
+    lines.append(result.overall_summary)
+    lines.append("")
+
+    for f in result.files:
+        lines.append(f"## {f.file_path} — Score: {f.score}/10")
+        lines.append("")
+        if f.summary:
+            lines.append(f.summary)
+            lines.append("")
+        if f.issues:
+            lines.append("### Issues")
+            for idx, issue in enumerate(f.issues, start=1):
+                where = f" (line {issue.line})" if issue.line is not None else ""
+                rule = f" — {issue.rule}" if issue.rule else ""
+                lines.append(f"- [{issue.severity.upper()}]{where}{rule}: {issue.title}")
+                lines.append(f"  - {issue.description}")
+            lines.append("")
+        if f.suggestions:
+            lines.append("### Suggestions")
+            for s in f.suggestions:
+                lines.append(f"- {s}")
+            lines.append("")
+
+    if result.quick_actions:
+        lines.append("## Quick Actions")
+        for qa in result.quick_actions:
+            lines.append(f"- {qa}")
+        lines.append("")
+
+    return "\n".join(lines)
+
+
+# =============================
+# Public API
+# =============================
+
+
+async def review_paths(
+    paths: List[str],
+    focus_areas: Optional[List[str]] = None,
+    model: Optional[str] = None,
+) -> CodeReviewResponse:
+    files, dirs = gather_targets(paths)
+
+    agent = code_review_agent if model is None else Agent(
+        model=model,
+        result_model=CodeReviewResponse,
+        system_prompt=SYSTEM_PROMPT,
+    )
+
+    user_prompt = build_user_prompt(files, dirs, focus_areas or [])
+    run = await agent.run(user_prompt)
+    return run.data
+
+
+async def review_code_string(
+    code: str,
+    filename: str = "snippet",
+    focus_areas: Optional[List[str]] = None,
+    model: Optional[str] = None,
+) -> CodeReviewResponse:
+    agent = code_review_agent if model is None else Agent(
+        model=model,
+        result_model=CodeReviewResponse,
+        system_prompt=SYSTEM_PROMPT,
+    )
+    prompt = (
+        f"Review the following code ({filename}).\n\n"  # noqa: E501
+        f"Focus areas: {', '.join(focus_areas or []) or 'general quality'}.\n\n"
+        f"{code}"
+    )
+    run = await agent.run(prompt)
+    return run.data
+
+
+# =============================
+# CLI
+# =============================
+
+
+def parse_args(argv: Optional[List[str]] = None) -> argparse.Namespace:
+    parser = argparse.ArgumentParser(description="Run code review agent using pydantic-ai")
+    parser.add_argument(
+        "paths",
+        nargs="*",
+        help="Files or directories to review",
+    )
+    parser.add_argument(
+        "--focus",
+        nargs="*",
+        default=[],
+        help="Optional focus areas, e.g. security performance readability accessibility",
+    )
+    parser.add_argument(
+        "--model",
+        default=None,
+        help="Model id, e.g. openai:gpt-4o or openai:gpt-4o-mini (defaults to env CODE_REVIEW_MODEL or gpt-4o-mini)",
+    )
+    parser.add_argument(
+        "--out",
+        default=None,
+        help="If provided, write a Markdown report to this file",
+    )
+    return parser.parse_args(argv)
+
+
+def main(argv: Optional[List[str]] = None) -> int:
+    args = parse_args(argv)
+    if not args.paths:
+        print("No input paths provided. Nothing to review.")
+        return 2
+
+    result = asyncio.run(review_paths(args.paths, focus_areas=args.focus, model=args.model))
+
+    md = render_markdown(result)
+    if args.out:
+        Path(args.out).write_text(md, encoding="utf-8")
+        print(f"Saved review report to {args.out}")
+    else:
+        print(md)
+    return 0
+
+
+if __name__ == "__main__":
+    # raise SystemExit(main())
+    path = "DIFF.md"
+    data = read_text_file(path)
+    res = code_review_agent.run_sync("", deps = data)
+
+    print(res.output)
+
+

index.py

@@ -0,0 +1,117 @@
+from flask import Flask, request, jsonify
+from tool import create_session, get_pull_request_overview, get_diff, send_slack_message, save_md_report
+from dotenv import load_dotenv
+import os
+from agent.code_review import code_review_agent, read_text_file, DiffDeps
+
+# Set up ENVIRONMENT VARIABLE
+load_dotenv()
+WORKSPACE_ID = os.getenv("WORKSPACE_ID")
+BITBUCKET_USERNAME = os.getenv("BITBUCKET_USERNAME")
+BITBUCKET_APP_PASSWORD = os.getenv("BITBUCKET_APP_PASSWORD")
+DEFAULT_BASE_URL = os.getenv("DEFAULT_BASE_URL")
+REPO_SLUG = os.getenv("REPO_SLUG")
+SLACK_WEBHOOK_URL = os.getenv("SLACK_WEBHOOK_URL")
+SLACK_BOT_TOKEN = os.getenv("SLACK_BOT_TOKEN")
+SLACK_CHANNEL = os.getenv("SLACK_CHANNEL")
+
+
+app = Flask(__name__)
+
+
+@app.route("/webhook", methods=["POST"])
+def webhook():
+    event_key = request.headers.get("X-Event-Key")  # ví dụ: pullrequest:created, repo:push
+    payload = request.json
+
+    print("=== Webhook Received ===")
+    print("Event:", event_key)
+
+    # Xử lý Pull Request event
+    if event_key and event_key.startswith("pullrequest"):
+        if payload and "pullrequest" in payload:
+            pr = payload["pullrequest"]
+            pr_info = {
+                "id": pr.get("id"),
+                "title": pr.get("title"),
+                "state": pr.get("state"),
+                "author": pr.get("author", {}).get("display_name"),
+                "source_branch": pr.get("source", {}).get("branch", {}).get("name"),
+                "destination_branch": pr.get("destination", {}).get("branch", {}).get("name"),
+            }
+            print("Pull Request Info:", pr_info)
+
+
+        PR_ID = pr_info["id"]
+
+        session = create_session(BITBUCKET_USERNAME, BITBUCKET_APP_PASSWORD)
+        data = get_pull_request_overview(
+            session = session, 
+            workspace = WORKSPACE_ID, # args.workspace, 
+            repo_slug = REPO_SLUG, 
+            pr_id = PR_ID, 
+            base_url = DEFAULT_BASE_URL
+        )
+
+        title = data["title"]
+        description = data["description"]
+        source_branch = data["source"]["branch"]["name"]
+        destination_branch = data["destination"]["branch"]["name"]
+        author = data["author"]["display_name"]
+        created_on = data["created_on"]
+        reviewers = data.get("reviewers", [])
+        reviewer_mentions = " ".join([f"@{r.get('nickname')}" for r in reviewers]) if reviewers else "None"
+        pr_link = data["links"]["html"]["href"]
+        changelog = data["summary"]["raw"]
+        diff_url = data["links"]["diff"]["href"]
+
+
+        pr_report = f"""
+    # [{REPO_SLUG}] PR #{PR_ID}: {title}
+    *{description}*
+
+    **🌿 Branch Information:**
+    - **Source Branch:** {source_branch} → **Target Branch:** {destination_branch}
+
+    **👤 Người tạo:** {author}
+
+    **📅 Thời gian tạo:** 2024-08-20 14:30:00 +07:00
+
+    **👥 Reviewers:**
+    {reviewer_mentions}
+
+    **🔗 Link Pull Request:** [PR #{PR_ID}: Implement user authentication system]({pr_link})
+        """
+
+        save_md_report("PR.md", pr_report)
+
+        diff = get_diff(session, diff_url)
+        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"
+        ) 
+
+        print("Running Agent ...")
+
+        code_review_result = code_review_agent.run_sync("", deps = DiffDeps(diff = diff[:-10_000]))
+        code_review_text = getattr(code_review_result, "output", None) or str(code_review_result)
+
+        send_slack_message(
+            message_text = code_review_text,
+            webhook_url = SLACK_WEBHOOK_URL,
+            bot_token = SLACK_BOT_TOKEN,
+            channel = "pull-request"
+        )
+        print("Sent code review") 
+
+        return jsonify({"status": "ok"}), 200
+
+
+if __name__ == "__main__":
+    app.run(host="0.0.0.0", port=3000)

requirements.txt

@@ -0,0 +1,4 @@
+python-dotenv
+requests
+pydantic-ai
+flask

tool.py

@@ -0,0 +1,264 @@
+import os
+import json
+import argparse
+from typing import Dict, Any, List, Optional, Tuple
+from dotenv import load_dotenv
+
+import requests
+
+# Set up ENVIRONMENT VARIABLE
+load_dotenv()
+WORKSPACE_ID = os.getenv("WORKSPACE_ID")
+BITBUCKET_USERNAME = os.getenv("BITBUCKET_USERNAME")
+BITBUCKET_APP_PASSWORD = os.getenv("BITBUCKET_APP_PASSWORD")
+DEFAULT_BASE_URL = "https://api.bitbucket.org/2.0"
+SLACK_WEBHOOK_URL = os.getenv("SLACK_WEBHOOK_URL")
+SLACK_BOT_TOKEN = os.getenv("SLACK_BOT_TOKEN")
+SLACK_CHANNEL = os.getenv("SLACK_CHANNEL")
+
+
+def create_session(username: Optional[str] = None, app_password: Optional[str] = None) -> requests.Session:
+    """
+    Create an authenticated session for Bitbucket Cloud using Basic Auth (username + App Password).
+    Falls back to BITBUCKET_USERNAME and BITBUCKET_APP_PASSWORD environment variables.
+    """
+    resolved_username = username or os.getenv("BITBUCKET_USERNAME")
+    resolved_app_password = app_password or os.getenv("BITBUCKET_APP_PASSWORD")
+
+    if not resolved_username or not resolved_app_password:
+        raise ValueError(
+            "Missing credentials. Provide --username and --app-password or set env vars "
+            "BITBUCKET_USERNAME and BITBUCKET_APP_PASSWORD."
+        )
+
+    session = requests.Session()
+    session.auth = (resolved_username, resolved_app_password)
+    session.headers.update({"Accept": "application/json"})
+    return session
+
+
+def _request_json(session: requests.Session, method: str, url: str, params: Optional[Dict[str, Any]] = None) -> Dict[str, Any]:
+    response = session.request(method, url, params=params, timeout=30)
+    response.raise_for_status()
+    return response.json()
+
+
+def _paginate_all(session: requests.Session, url: str, params: Optional[Dict[str, Any]] = None) -> List[Dict[str, Any]]:
+    """
+    Retrieve all pages for Bitbucket v2.0 endpoints that return 'values' and 'next'.
+    """
+    aggregated_values: List[Dict[str, Any]] = []
+    next_url: Optional[str] = url
+    query_params: Dict[str, Any] = dict(params or {})
+    if "pagelen" not in query_params:
+        query_params["pagelen"] = 100
+
+    while next_url:
+        data = _request_json(session, "GET", next_url, params=query_params if next_url == url else None)
+        values = data.get("values", [])
+        aggregated_values.extend(values)
+        next_url = data.get("next")
+    return aggregated_values
+
+
+def get_pull_request_overview(session: requests.Session, workspace: str, repo_slug: str, pr_id: int, base_url: str = DEFAULT_BASE_URL) -> Dict[str, Any]:
+    url = f"{base_url}/repositories/{workspace}/{repo_slug}/pullrequests/{pr_id}"
+    return _request_json(session, "GET", url)
+
+
+def get_pull_request_commits(session: requests.Session, workspace: str, repo_slug: str, pr_id: int, base_url: str = DEFAULT_BASE_URL) -> List[Dict[str, Any]]:
+    url = f"{base_url}/repositories/{workspace}/{repo_slug}/pullrequests/{pr_id}/commits"
+    return _paginate_all(session, url)
+
+
+def get_pull_request_comments(session: requests.Session, workspace: str, repo_slug: str, pr_id: int, base_url: str = DEFAULT_BASE_URL) -> List[Dict[str, Any]]:
+    url = f"{base_url}/repositories/{workspace}/{repo_slug}/pullrequests/{pr_id}/comments"
+    return _paginate_all(session, url)
+
+
+def get_pull_request_activity(session: requests.Session, workspace: str, repo_slug: str, pr_id: int, base_url: str = DEFAULT_BASE_URL) -> List[Dict[str, Any]]:
+    url = f"{base_url}/repositories/{workspace}/{repo_slug}/pullrequests/{pr_id}/activity"
+    return _paginate_all(session, url)
+
+
+def get_pull_request_diff(session: requests.Session, workspace: str, repo_slug: str, pr_id: int, base_url: str = DEFAULT_BASE_URL) -> str:
+    """
+    Returns unified diff text for the PR. This endpoint returns text/plain.
+    """
+    url = f"{base_url}/repositories/{workspace}/{repo_slug}/pullrequests/{pr_id}/diff"
+    headers = {"Accept": "text/plain"}
+    response = session.get(url, headers=headers, timeout=60)
+    response.raise_for_status()
+    return response.text
+
+
+def get_diff(session, diff_url):
+    response = session.request('GET', diff_url, timeout=30)
+    response.raise_for_status()
+    
+    return response.text
+
+
+def save_md_report(filename, content):
+    with open(filename, "w", encoding="utf-8") as f:
+        f.write(content)
+        print(f"Saved {filename} file")
+
+
+def send_slack_message(
+    message_text: str,
+    *,
+    webhook_url: Optional[str] = None,
+    bot_token: Optional[str] = None,
+    channel: Optional[str] = None,
+    blocks: Optional[List[Dict[str, Any]]] = None,
+    thread_ts: Optional[str] = None,
+) -> Dict[str, Any]:
+    """
+    Gửi tin nhắn tới Slack bằng 1 trong 2 phương thức:
+    1) Incoming Webhook (ưu tiên nếu có SLACK_WEBHOOK_URL hoặc truyền webhook_url)
+    2) Slack Web API (chat.postMessage) với SLACK_BOT_TOKEN + channel
+
+    Trả về dict kết quả đã chuẩn hoá, bao gồm khoá 'ok' và 'method'.
+    Ném ValueError khi thiếu thông tin c���u hình cần thiết.
+    """
+    resolved_webhook_url = webhook_url or SLACK_WEBHOOK_URL
+    resolved_bot_token = bot_token or SLACK_BOT_TOKEN
+    resolved_channel = channel or SLACK_CHANNEL
+
+    # Ưu tiên gửi qua Incoming Webhook nếu có
+    if resolved_webhook_url:
+        payload: Dict[str, Any] = {"text": message_text}
+        if blocks is not None:
+            payload["blocks"] = blocks
+
+        response = requests.post(resolved_webhook_url, json=payload, timeout=15)
+        try:
+            response.raise_for_status()
+        except Exception as exc:
+            raise ValueError(f"Slack webhook request failed: {exc}") from exc
+
+        return {
+            "ok": response.status_code == 200 and response.text.strip().lower() == "ok",
+            "method": "webhook",
+            "status_code": response.status_code,
+            "response": response.text,
+        }
+
+    # Fallback: dùng Slack Web API nếu có token + channel
+    if resolved_bot_token and resolved_channel:
+        api_url = "https://slack.com/api/chat.postMessage"
+        headers = {
+            "Authorization": f"Bearer {resolved_bot_token}",
+            "Content-Type": "application/json",
+        }
+        payload: Dict[str, Any] = {
+            "channel": resolved_channel,
+            "text": message_text,
+        }
+        if blocks is not None:
+            payload["blocks"] = blocks
+        if thread_ts is not None:
+            payload["thread_ts"] = thread_ts
+
+        response = requests.post(api_url, headers=headers, json=payload, timeout=15)
+        try:
+            response.raise_for_status()
+        except Exception as exc:
+            raise ValueError(f"Slack API request failed: {exc}") from exc
+
+        data = response.json()
+        if not data.get("ok", False):
+            error_detail = data.get("error", "unknown_error")
+            raise ValueError(f"Slack API responded with error: {error_detail}")
+
+        return {
+            "ok": True,
+            "method": "web_api",
+            "status_code": response.status_code,
+            "response": data,
+        }
+
+    raise ValueError(
+        "Missing Slack configuration. Provide SLACK_WEBHOOK_URL or SLACK_BOT_TOKEN and SLACK_CHANNEL."
+    )
+
+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")
+    # parser.add_argument("--password", required=True, help="Bitbucket app password")
+    # parser.add_argument("--workspace", required=True, help="Bitbucket workspace ID or slug")
+    # parser.add_argument("--repo", required=True, help="Repository slug")
+    # parser.add_argument("--pr", required=True, type=int, help="Pull request ID")
+    # parser.add_argument("--username", help="Bitbucket username (or set BITBUCKET_USERNAME)")
+    # parser.add_argument("--app-password", help="Bitbucket App Password (or set BITBUCKET_APP_PASSWORD)")
+    # parser.add_argument(
+    #     "--include",
+    #     nargs="*",
+    #     choices=["overview", "commits", "comments", "activity", "diff"],
+    #     help="Sections to include. Default: all",
+    # )
+    # parser.add_argument("--base-url", default=DEFAULT_BASE_URL, help="Base API URL. Default is Bitbucket Cloud v2.0")
+    # args = parser.parse_args()
+
+    session = create_session(BITBUCKET_USERNAME, BITBUCKET_APP_PASSWORD)
+
+    data = get_pull_request_overview(
+        session = session, 
+        workspace = WORKSPACE_ID, # args.workspace, 
+        repo_slug = REPO_SLUG, 
+        pr_id = PR_ID, 
+        base_url = DEFAULT_BASE_URL
+    )
+
+    # Lấy các thông tin cần thiết
+    title = data["title"]
+    description = data["description"]
+    source_branch = data["source"]["branch"]["name"]
+    destination_branch = data["destination"]["branch"]["name"]
+    author = data["author"]["display_name"]
+    created_on = data["created_on"]
+    reviewers = data.get("reviewers", [])
+    reviewer_mentions = " ".join([f"@{r.get('nickname')}" for r in reviewers]) if reviewers else "None"
+    pr_link = data["links"]["html"]["href"]
+    changelog = data["summary"]["raw"]
+    diff_url = data["links"]["diff"]["href"]
+
+
+    pr_report = f"""
+# [{args.repo}] PR #{args.pr}: {title}
+*{description}*
+
+**🌿 Branch Information:**
+- **Source Branch:** {source_branch} → **Target Branch:** {destination_branch}
+
+**👤 Người tạo:** {author}
+
+**📅 Thời gian tạo:** 2024-08-20 14:30:00 +07:00
+
+**👥 Reviewers:**
+{reviewer_mentions}
+
+**🔗 Link Pull Request:** [PR #{args.pr}: Implement user authentication system]({pr_link})
+
+---
+
+## 📝 Changelogs: 
+    """
+
+    save_md_report("PR.md", pr_report)
+
+    data = get_diff(session, diff_url)
+
+    save_md_report("DIFF.md", data)
+
+
+if __name__ == "__main__":
+    send_slack_message(
+        message_text = "Hello",
+        webhook_url = SLACK_WEBHOOK_URL,
+        bot_token = SLACK_BOT_TOKEN,
+        channel = "pull-request"
+    ) 
+
+