Upload folder using huggingface_hub

app2.py

@@ -0,0 +1,75 @@
+from fastapi import FastAPI, Request
+from fastapi.responses import HTMLResponse, JSONResponse
+from fastapi.staticfiles import StaticFiles
+from fastapi.templating import Jinja2Templates
+import asyncio
+from google.cloud import dialogflowcx_v3 as dialogflow
+from google.oauth2 import service_account
+from google.api_core.client_options import ClientOptions
+
+# === Setup
+app = FastAPI()
+app.mount("/static", StaticFiles(directory="static"), name="static")
+templates = Jinja2Templates(directory="templates")
+
+path_to_key = 'credentials/plenary-stacker-457109-k5-6b664f4fa9ba.json'
+api_endpoint_ = 'europe-west2-dialogflow.googleapis.com'
+project_id_ = 'plenary-stacker-457109-k5'
+location_ = 'europe-west2'
+agent_id_ = 'c827abce-ac66-40e5-a7e5-aba7e90b74ae'
+session_id_ = 'unique-session-id'
+
+clt1 = None
+s_path = None
+
+def set_session():
+    client1 = dialogflow.SessionsClient(
+        credentials=service_account.Credentials.from_service_account_file(path_to_key),
+        client_options=ClientOptions(api_endpoint=api_endpoint_)
+    )
+    session_path1 = client1.session_path(project_id_, location_, agent_id_, session_id_)
+    return client1, session_path1
+
+async def get_response(message_):
+    global clt1, s_path
+    if clt1 is None or s_path is None:
+        clt1, s_path = set_session()
+
+    try:
+        query_input = dialogflow.QueryInput(
+            text=dialogflow.TextInput(text=message_),
+            language_code='en'
+        )
+        loop = asyncio.get_event_loop()
+        response = await loop.run_in_executor(
+            None,
+            lambda: clt1.detect_intent(request={"session": s_path, "query_input": query_input})
+        )
+        return extract_message(response)
+    except Exception as e:
+        return f'Error: {e}'
+
+def extract_message(response):
+    response_messages = response.query_result.response_messages
+    message_text = ''
+    for message in response_messages:
+        if message.text and hasattr(message.text.text, '__iter__'):
+            message_text += ''.join(message.text.text)
+    if not message_text:
+        message_text = response.query_result.fulfillment_text
+    return message_text
+
+@app.get("/", response_class=HTMLResponse)
+async def index(request: Request):
+    return templates.TemplateResponse("index2.html", {"request": request})
+
+@app.post("/chat", response_class=JSONResponse)
+async def chat_post(request: Request):
+    data = await request.json()
+    user_input = data.get("message", "")
+    # user_input = 'hey man'
+    response_text = await get_response(user_input)
+    return {"reply": response_text}
+
+# if __name__ == '__main__':
+#     app.run(debug=True)

app3.py

@@ -0,0 +1,75 @@
+from fastapi import FastAPI, Request
+from fastapi.responses import HTMLResponse, JSONResponse
+from fastapi.staticfiles import StaticFiles
+from fastapi.templating import Jinja2Templates
+import asyncio
+from google.cloud import dialogflowcx_v3 as dialogflow
+from google.oauth2 import service_account
+from google.api_core.client_options import ClientOptions
+
+# === Setup
+app = FastAPI()
+app.mount("/static", StaticFiles(directory="static"), name="static")
+templates = Jinja2Templates(directory="templates")
+
+path_to_key = 'credentials/plenary-stacker-457109-k5-6b664f4fa9ba.json'
+api_endpoint_ = 'europe-west2-dialogflow.googleapis.com'
+project_id_ = 'plenary-stacker-457109-k5'
+location_ = 'europe-west2'
+agent_id_ = 'c827abce-ac66-40e5-a7e5-aba7e90b74ae'
+session_id_ = 'unique-session-id'
+
+clt1 = None
+s_path = None
+
+def set_session():
+    client1 = dialogflow.SessionsClient(
+        credentials=service_account.Credentials.from_service_account_file(path_to_key),
+        client_options=ClientOptions(api_endpoint=api_endpoint_)
+    )
+    session_path1 = client1.session_path(project_id_, location_, agent_id_, session_id_)
+    return client1, session_path1
+
+async def get_response(message_):
+    global clt1, s_path
+    if clt1 is None or s_path is None:
+        clt1, s_path = set_session()
+
+    try:
+        query_input = dialogflow.QueryInput(
+            text=dialogflow.TextInput(text=message_),
+            language_code='en'
+        )
+        loop = asyncio.get_event_loop()
+        response = await loop.run_in_executor(
+            None,
+            lambda: clt1.detect_intent(request={"session": s_path, "query_input": query_input})
+        )
+        return extract_message(response)
+    except Exception as e:
+        return f'Error: {e}'
+
+def extract_message(response):
+    response_messages = response.query_result.response_messages
+    message_text = ''
+    for message in response_messages:
+        if message.text and hasattr(message.text.text, '__iter__'):
+            message_text += ''.join(message.text.text)
+    if not message_text:
+        message_text = response.query_result.fulfillment_text
+    return message_text
+
+@app.get("/", response_class=HTMLResponse)
+async def index(request: Request):
+    return templates.TemplateResponse("index2.html", {"request": request})
+
+@app.post("/chat", response_class=JSONResponse)
+async def chat_post(request: Request):
+    data = await request.json()
+    user_input = data.get("message", "")
+    # user_input = 'hey man'
+    response_text = await get_response(user_input)
+    return {"reply": response_text}
+
+# if __name__ == '__main__':
+#     app.run(debug=True)

requirements.txt

@@ -0,0 +1,5 @@
+fastapi==0.110.0
+uvicorn==0.29.0
+jinja2==3.1.3
+google-cloud-dialogflow-cx==1.14.1
+google-auth==2.29.0

static/script2.js

@@ -0,0 +1,27 @@
+async function sendMessage() {
+    const inputEl = document.getElementById("userInput");
+    const statusEl = document.getElementById("status");
+    const replyEl = document.getElementById("botReply");
+
+    const message = inputEl.value.trim();
+    if (!message) return;
+
+    // Update status
+    statusEl.innerText = "Connecting to service...";
+    await delay(300);
+
+    statusEl.innerText = "Getting data...";
+    const response = await fetch("/chat", {
+        method: "POST",
+        headers: { "Content-Type": "application/json" },
+        body: JSON.stringify({ message })
+    });
+
+    const data = await response.json();
+    statusEl.innerText = "Operation complete.";
+    replyEl.innerText = data.reply;
+}
+
+function delay(ms) {
+    return new Promise(resolve => setTimeout(resolve, ms));
+}

templates/index2.html

@@ -0,0 +1,15 @@
+<!DOCTYPE html>
+<html>
+<head>
+    <title>Async Chatbot</title>
+    <script src="/static/script2.js" defer></script>
+</head>
+<body>
+    <h2>Talk to the Bot</h2>
+    <input type="text" id="userInput" placeholder="Say something..." />
+    <button onclick="sendMessage()">Send</button>
+
+    <p><strong>Status:</strong> <span id="status">Idle</span></p>
+    <p><strong>Bot:</strong> <span id="botReply"></span></p>
+</body>
+</html>