first commit

.env

@@ -0,0 +1,5 @@
+PROJECT_ID = "busbooking-451909"
+LOCATION = "us-central1"
+AGENT_ID = "76716506-e80a-413a-931b-6b61ef715d31"
+LANGUAGE_CODE="vi"
+GOOGLE_APPLICATION_CREDENTIALS="app/data/busbooking-451909-aa92e337868d.json"

Dockerfile

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

app/api/routes.py

@@ -0,0 +1,20 @@
+from typing import Optional
+from fastapi import FastAPI, APIRouter, HTTPException, Request, Response, status 
+from fastapi.responses import JSONResponse, RedirectResponse, HTMLResponse
+from pydantic import BaseModel
+
+from app.services.service import chatbot_response
+from app.types.response import Message, ResponseAPI
+
+router = APIRouter()
+
+@router.post("/chat") 
+def chat(message: Message) -> ResponseAPI:
+    session_id = message.session_id
+    message_content = message.message_content
+    data = chatbot_response(session_id, message_content)
+    return ResponseAPI(data=data, status=status.HTTP_200_OK)
+
+@router.get("/")
+def home():
+    return "API CHATBOT BUS BOOKING"

app/core/config.py

@@ -0,0 +1,14 @@
+import os
+from dotenv import load_dotenv
+
+load_dotenv()  # Load biến môi trường từ file .env
+
+class Settings:
+    API_BASE_URL = os.getenv("API_BASE_URL")  # API gốc (backend dev)
+    PROJECT_ID = os.getenv("PROJECT_ID")
+    LOCATION = os.getenv("LOCATION")
+    AGENT_ID = os.getenv("AGENT_ID")
+    LANGUAGE_CODE = os.getenv("LANGUAGE_CODE")
+    GOOGLE_APPLICATION_CREDENTIALS=os.getenv("GOOGLE_APPLICATION_CREDENTIALS")
+
+settings = Settings()

app/data/busbooking-451909-aa92e337868d.json

@@ -0,0 +1,13 @@
+{
+  "type": "service_account",
+  "project_id": "busbooking-451909",
+  "private_key_id": "aa92e337868d77340f1e1bc3d0119738f48b8a49",
+  "private_key": "-----BEGIN PRIVATE KEY-----\nMIIEvgIBADANBgkqhkiG9w0BAQEFAASCBKgwggSkAgEAAoIBAQDwozPFZx+v2DH+\nXFMLaft+4tnaWKPDGEgQ0IGwmXUtgVzd7iuH/fI9tXFiRw1ecFGAzundf1qiJJis\npMgfMxXm5fWpaKa4AM5LKxootKYPLZeJ3/N+BhJkCSmDXZmk6TuBff3WBRUkDj9n\nQTnpRSCBsCxArvm2zw6PSUqHwPiW/g05q6escmHXZUO3wpLgFz41u1Xy7M2Rc/bO\n3j6OYogYxZkp5aY5EpWhUKO2+qNVaVQqDweJhQ7/M+UpX5Va9VdMAM7dm3BUIy1Y\n3c8NDgUvL5uXKljoHrPpGXm+1QZTnrT18y3Jmo5PxkIF0u/SXDnFTYl9CL876ewq\nYaN55d9fAgMBAAECggEAArpm8Nr9cfnqfy6+xkdaUZLy01Xj7WdOEdq7Taw/ttdb\nnSyBE9aeM3LmKS4TCboOQn6WCivSdDoj/PkVR71Fh0ueIGCOW1GvBQ0lC8cYht2G\ndUqzsP8SoE22ScX64vK9+PbbtNxz4+fBckM8C9f7yVyc89LIA/mO+bLkBGv8pYGQ\nNg2Po8Oi8wjA06XMEaFVfrURnyQoUVVeIXBn/L0TViL/vSo0wshYQw9hoXI6RrUW\n1SDjfRmzOIt63R7x4Bn/BZYvgjtRewAL325ooZVXqrzXHZ9yinC/7BIrxQCF9Ncr\nuKok9SDhNES2OUUbO8QlwW4EVvTkiCb59r26jqU26QKBgQD6K2AyZ1u2XRI9HpW3\nsAeshUDcG/Gj0cnWQlpe6hr+UOrMt7LIgOhuQeR1/5EZ/ZLG8FYKE096ffP/2ND8\nG+JzTTj5Fiv9ZzUdKWPQGE5D6TwJmVAO6R8ZaodykkIgg7Thn17og4EbeSAqNtey\nh2LSLnYrT9imjfR78n+vPYCwfQKBgQD2PvRknpN+zMYnMUA/pho0/c7G8kbORiWp\nDpHabHDbtdKSgWC3enQ3bVPSeGiZNvrjSar+1/8H2C3WovhgYTp4o7+IdM2cKWOZ\nJsQNbgoXYgeaylIiwZGRQN0x1q4ho2w3UGxu3spupyFFo8yNRay8JkCI6OMX+ZWd\nG2QXQEOSCwKBgQCrZa55uhC+x9NoJp1DBYqsa3t9knOi3mffsQRDhTdLSFsmOTF3\nZ8JXUDPbmGZsnSvDuwPn0UUh0kuq3XyJTf1/K8g9+C/ZZK2iNipZd12f75sfpHeS\nT6vr+O2l1IkTx8jU0CDxQq/hB8K+yWZMva85+3UgxYrUyetYRFOw131k7QKBgGxc\nt9+viOi75FdK7SMVTWMUbfJOm6oaZGhI6RZdsix9jvS5yn3zfUEG82QjaKRD9ZQf\nzwfmtWwWTdWuUe7X2otMQ/UgsXqPHC1BSfU+/2Ha2c3cStjQpeZtzOkpt+dFq1GM\nKqt/j0WydonW0yU4DBOgIbYeBhF+28APVbSFqzaRAoGBAPRPNNCJcbIsCZEyBgwn\nCgK9W5anZDVmtwXbAVAoKMzzxFVi49W+6Lduw9oeTqgx9J1AdQMwV27I0hcPtfBE\nw5IVhrQsd6dRKDt/CJwEN6/iR9AqLx3T/rO342yOIi9GSPsFISQiiPDywfkNSzj6\nhT0eDw3eRs/RUv0zqcjFUjNI\n-----END PRIVATE KEY-----\n",
+  "client_email": "chatbot@busbooking-451909.iam.gserviceaccount.com",
+  "client_id": "111019976759266480456",
+  "auth_uri": "https://accounts.google.com/o/oauth2/auth",
+  "token_uri": "https://oauth2.googleapis.com/token",
+  "auth_provider_x509_cert_url": "https://www.googleapis.com/oauth2/v1/certs",
+  "client_x509_cert_url": "https://www.googleapis.com/robot/v1/metadata/x509/chatbot%40busbooking-451909.iam.gserviceaccount.com",
+  "universe_domain": "googleapis.com"
+}

app/services/api.py

@@ -0,0 +1,61 @@
+import httpx
+from app.core.config import settings
+from typing import Optional, Dict, Any
+
+API_BASE_URL = settings.API_BASE_URL  # Lấy base URL từ config
+
+async def get(endpoint: str, params: Optional[Dict[str, Any]] = None, headers: Optional[Dict[str, str]] = None):
+    """Gọi API GET"""
+    url = f"{API_BASE_URL}{endpoint}"
+    headers = headers or {}
+    async with httpx.AsyncClient() as client:
+        try:
+            response = await client.get(url, headers=headers, params=params)
+            response.raise_for_status()
+            return response.json()
+        except httpx.HTTPStatusError as http_err:
+            return {"error": f"HTTP {http_err.response.status_code}: {http_err.response.text}"}
+        except Exception as err:
+            return {"error": f"Request failed: {str(err)}"}
+
+async def post(endpoint: str , payload: Dict[str, Any] = None,headers: Optional[Dict[str, str]] = None):
+    """Gọi API POST"""
+    url = f"{API_BASE_URL}{endpoint}"
+    headers = headers or {"Content-Type": "application/json"}
+    async with httpx.AsyncClient() as client:
+        try:
+            response = await client.post(url, json=payload, headers=headers)
+            response.raise_for_status()
+            return response.json()
+        except httpx.HTTPStatusError as http_err:
+            return {"error": f"HTTP {http_err.response.status_code}: {http_err.response.text}"}
+        except Exception as err:
+            return {"error": f"Request failed: {str(err)}"}
+
+async def put_api(endpoint: str, payload: Dict[str, Any], headers: Optional[Dict[str, str]] = None):
+    """Gọi API PUT"""
+    url = f"{API_BASE_URL}{endpoint}"
+    headers = headers or {"Content-Type": "application/json"}
+    async with httpx.AsyncClient() as client:
+        try:
+            response = await client.put(url, json=payload, headers=headers)
+            response.raise_for_status()
+            return response.json()
+        except httpx.HTTPStatusError as http_err:
+            return {"error": f"HTTP {http_err.response.status_code}: {http_err.response.text}"}
+        except Exception as err:
+            return {"error": f"Request failed: {str(err)}"}
+
+async def delete_api(endpoint: str, params: Optional[Dict[str, Any]] = None, headers: Optional[Dict[str, str]] = None):
+    """Gọi API DELETE"""
+    url = f"{API_BASE_URL}{endpoint}"
+    headers = headers or {}
+    async with httpx.AsyncClient() as client:
+        try:
+            response = await client.delete(url, headers=headers, params=params)
+            response.raise_for_status()
+            return response.json()
+        except httpx.HTTPStatusError as http_err:
+            return {"error": f"HTTP {http_err.response.status_code}: {http_err.response.text}"}
+        except Exception as err:
+            return {"error": f"Request failed: {str(err)}"}

app/services/service.py

@@ -0,0 +1,57 @@
+import os
+from dotenv import load_dotenv
+from google.cloud import dialogflowcx_v3beta1 as dialogflow
+from google.api_core.client_options import ClientOptions
+from app.core.config import settings
+
+os.environ["GOOGLE_APPLICATION_CREDENTIALS"] = settings.GOOGLE_APPLICATION_CREDENTIALS
+PROJECT_ID = settings.PROJECT_ID
+LOCATION = settings.LOCATION # Vị trí agent của bạn
+AGENT_ID = settings.AGENT_ID
+LANGUAGE_CODE = settings.LANGUAGE_CODE
+
+def chatbot_response(
+    session_id: str,
+    texts: list
+):
+    """Gửi văn bản đến Dialogflow CX và nhận phản hồi"""
+
+    endpoint = f"{LOCATION}-dialogflow.googleapis.com"
+    client_options = ClientOptions(api_endpoint=endpoint)
+    client = dialogflow.SessionsClient(client_options=client_options)
+
+    session_path = f"projects/{PROJECT_ID}/locations/{LOCATION}/agents/{AGENT_ID}/sessions/{session_id}"
+
+    extracted_texts = []
+    all_chip_options = []
+    for text in texts:
+        text_input = dialogflow.TextInput(text=text)
+        query_input = dialogflow.QueryInput(text=text_input, language_code=LANGUAGE_CODE)
+
+        request = dialogflow.DetectIntentRequest(
+            session=session_path, 
+            query_input=query_input
+        )
+
+        response = client.detect_intent(request=request)
+        query_result = response.query_result
+
+        for message in query_result.response_messages:
+            if hasattr(message, "text") and message.text.text:
+                extracted_texts.extend(message.text.text)
+
+            chip_opttion = []
+            if hasattr(message, "payload") and message.payload:
+                payload_dict = dict(message.payload) 
+                if "richContent" in payload_dict:
+                    rich_content = payload_dict["richContent"]
+                    for item_group in rich_content:
+                        for item in item_group:
+                            if item.get("type") == "chips":
+                                options = item.get("options", [])
+                                chip_opttion.extend([opt["text"] for opt in options])
+        all_chip_options.append(chip_opttion)   
+        
+    response = {"text": extracted_texts, "payload": all_chip_options}
+
+    return response

app/types/response.py

@@ -0,0 +1,16 @@
+
+from typing import Optional
+from pydantic import BaseModel
+
+
+class Items(BaseModel):
+    text: list[str]
+    payload: list[list[str]]
+
+class ResponseAPI(BaseModel):
+    status : int
+    data : Optional[Items] = None
+
+class Message(BaseModel):
+    session_id : str
+    message_content: list[str]

main.py

@@ -0,0 +1,10 @@
+from fastapi import FastAPI
+from app.api.routes import router # type: ignore
+
+app = FastAPI(title="FastAPI Proxy Service")
+
+app.include_router(router, prefix="/api")
+
+if __name__ == "__main__":
+    import uvicorn
+    uvicorn.run(app, host="0.0.0.0", port=8000, reload=True)

requirements.txt

@@ -0,0 +1,39 @@
+annotated-types==0.7.0
+anyio==4.8.0
+cachetools==5.5.2
+certifi==2025.1.31
+charset-normalizer==3.4.1
+click==8.1.8
+colorama==0.4.6
+exceptiongroup==1.2.2
+fastapi==0.115.11
+google-api-core==2.24.1
+google-auth==2.38.0
+google-cloud-dialogflow-cx==1.40.0
+googleapis-common-protos==1.69.1
+grpcio==1.71.0rc2
+grpcio-status==1.71.0rc2
+h11==0.14.0
+httpcore==1.0.7
+httptools==0.6.4
+httpx==0.28.1
+idna==3.10
+Jinja2==3.1.6
+MarkupSafe==3.0.2
+proto-plus==1.26.0
+protobuf==5.29.3
+pyasn1==0.6.1
+pyasn1_modules==0.4.1
+pydantic==2.10.6
+pydantic_core==2.27.2
+python-dotenv==1.0.1
+PyYAML==6.0.2
+requests==2.32.3
+rsa==4.9
+sniffio==1.3.1
+starlette==0.46.0
+typing_extensions==4.12.2
+urllib3==2.3.0
+uvicorn==0.34.0
+watchfiles==1.0.4
+websockets==15.0.1