init project

.env.template

@@ -0,0 +1,4 @@
+# .env.template
+FB_VERIFY_TOKEN=
+SUPABASE_KEY=
+VECTOR_API_KEY=

.gitignore

@@ -191,4 +191,5 @@ cython_debug/
 #  exclude from AI features like autocomplete and code analysis. Recommended for sensitive data
 #  refer to https://docs.cursor.com/context/ignore-files
 .cursorignore
-.cursorindexingignore
+.cursorindexingignore.env
+.DS_Store

Dockerfile

@@ -0,0 +1,5 @@
+FROM python:3.10-slim
+WORKDIR /app
+COPY . .
+RUN pip install --no-cache-dir -r requirements.txt
+CMD ["uvicorn", "app.main:app", "--host", "0.0.0.0", "--port", "7860"]

app/config.py

@@ -0,0 +1,26 @@
+import os
+from dotenv import load_dotenv
+
+# Tải biến môi trường từ file `.env`
+load_dotenv()
+
+# === Facebook Webhook ===
+# Token xác thực khi Facebook gửi GET webhook
+FB_VERIFY_TOKEN = os.getenv("FB_VERIFY_TOKEN")
+
+# Địa chỉ gửi tin nhắn Facebook Graph API
+FB_GRAPH_API = "https://graph.facebook.com/v22.0"
+
+# === Google Sheets ===
+# ID bảng tính và tên sheet
+GOOGLE_SHEET_ID = "1H7BxVgXy5GgzRVxg34TMWN6xgqI4gA8zwzIAIZp2NdI"
+GOOGLE_SHEET_NAME = "chat"
+
+# === Supabase ===
+# Địa chỉ Supabase và key truy cập
+SUPABASE_URL = "https://hekathwdexaukowdjtxj.supabase.co"  # Thay bằng domain thật
+SUPABASE_KEY = os.getenv("SUPABASE_KEY")
+
+# === Vector Search (pgvector + Supabase function) ===
+VECTOR_SEARCH_URL = "https://hekathwdexaukowdjtxj.supabase.co/rest/v1/rpc/match_documents"
+VECTOR_API_KEY = os.getenv("VECTOR_API_KEY")

app/handlers/parser.py

@@ -0,0 +1,48 @@
+from app.utils import log_task
+
+@log_task("Phân tích tin nhắn")
+def parse_message(message: dict) -> dict:
+    """
+    Args:
+      message: JSON từ Messenger
+    Returns:
+      dict chứa sender, page_id, text, attachments, command, content, vehicle
+    """
+    t = message.get("message", {}).get("text", "")
+    attachments = message.get("message", {}).get("attachments", [])
+    sid = message.get("sender", {}).get("id")
+    pid = message.get("recipient", {}).get("id")
+
+    res = {
+        "text": t,
+        "attachments": attachments,
+        "recipient_id": sid,
+        "page_id": pid,
+        "command": "",
+        "password": "",
+        "content": "",
+        "vehicle": detect_vehicle(t.lower())
+    }
+
+    if t.startswith("\\"):
+        parts = t[1:].split("\\")
+        res.update({
+            "command": parts[0].strip(),
+            "password": parts[1].strip() if len(parts) > 1 else "",
+            "content": "\\".join(parts[2:]).strip() if len(parts) > 2 else ""
+        })
+
+    return res
+
+def detect_vehicle(text: str) -> str:
+    """
+    Args:
+      text: nội dung tin nhắn
+    Returns:
+      một trong các phương tiện, hoặc "" nếu không tìm thấy
+    """
+    keywords = ["mô tô","xe máy điện","xe máy","ô tô","xe đạp","đi bộ"]
+    for k in keywords:
+        if k in text:
+            return k
+    return ""

app/handlers/webhook.py

@@ -0,0 +1,33 @@
+from fastapi import APIRouter, Request
+from app.config import FB_VERIFY_TOKEN
+from app.handlers.parser import parse_message
+from app.services.supabase import get_page_token
+from app.services.responder import send_fallback_message
+
+router = APIRouter()
+
+@router.get("/facebook-webhook")
+def verify_token(request: Request):
+    q = dict(request.query_params)
+    if q.get("hub.mode") == "subscribe" and q.get("hub.verify_token") == FB_VERIFY_TOKEN:
+        return q.get("hub.challenge")
+    return {"error": "Invalid token"}
+
+@router.post("/facebook-webhook")
+async def handle_message(request: Request):
+    body = await request.json()
+    try:
+        ev = body["entry"][0]["messaging"][0]
+        if ev.get("message", {}).get("is_echo"):
+            return {"status": "echo ignored"}
+
+        parsed = parse_message(ev)
+        parsed["token"] = get_page_token(parsed["page_id"])
+
+        if not parsed.get("vehicle"):
+            send_fallback_message(parsed["page_id"], parsed["recipient_id"], parsed["token"])
+            return {"status": "fallback sent"}
+
+        return {"status": "ok"}
+    except Exception as e:
+        return {"error": str(e)}

app/main.py

@@ -0,0 +1,5 @@
+from fastapi import FastAPI
+from app.handlers.webhook import router
+
+app = FastAPI()
+app.include_router(router)

app/services/responder.py

@@ -0,0 +1,15 @@
+import requests
+from app.utils import log_task
+from app.config import FB_GRAPH_API
+
+@log_task("Gửi fallback message")
+def send_fallback_message(page_id: str, recipient_id: str, token: str):
+    url = f"{FB_GRAPH_API}/{page_id}/messages"
+    data = {
+        "recipient": {"id": recipient_id},
+        "messaging_type": "RESPONSE",
+        "message": {"text": "Tôi chưa rõ phương tiện bạn đang sử dụng. Bạn có thể cung cấp thêm không?"}
+    }
+    params = {"access_token": token}
+    r = requests.post(url, json=data, params=params)
+    r.raise_for_status()

app/services/supabase.py

@@ -0,0 +1,10 @@
+from app.utils import log_task
+from app.config import SUPABASE_URL, SUPABASE_KEY
+
+@log_task("Lấy token page từ Supabase")
+def get_page_token(page_id: str) -> str:
+    """
+    Giả lập hoặc thực gọi Supabase để lấy token
+    """
+    dummy = {"123": "fake_token"}
+    return dummy.get(page_id, "unknown_token")

app/utils.py

@@ -0,0 +1,24 @@
+import time
+import logging
+from functools import wraps
+
+logging.basicConfig(level=logging.INFO)
+
+def log_task(name):
+    """
+    Decorator log thông tin task: bắt đầu, kết thúc, lỗi, thời gian.
+    """
+    def decorator(func):
+        @wraps(func)
+        def wrapper(*args, **kwargs):
+            logging.info(f"🔵 Bắt đầu: {name}")
+            start = time.time()
+            try:
+                result = func(*args, **kwargs)
+                logging.info(f"🟢 Kết thúc: {name} trong {time.time() - start:.2f}s")
+                return result
+            except Exception as e:
+                logging.error(f"🔴 Lỗi ở {name}: {e}", exc_info=True)
+                return {"error": str(e)}
+        return wrapper
+    return decorator

requirements.txt

@@ -0,0 +1,4 @@
+fastapi
+uvicorn
+requests
+python-dotenv