changeing script path

.gitattributes

@@ -0,0 +1,35 @@
+*.7z filter=lfs diff=lfs merge=lfs -text
+*.arrow filter=lfs diff=lfs merge=lfs -text
+*.bin filter=lfs diff=lfs merge=lfs -text
+*.bz2 filter=lfs diff=lfs merge=lfs -text
+*.ckpt filter=lfs diff=lfs merge=lfs -text
+*.ftz filter=lfs diff=lfs merge=lfs -text
+*.gz filter=lfs diff=lfs merge=lfs -text
+*.h5 filter=lfs diff=lfs merge=lfs -text
+*.joblib filter=lfs diff=lfs merge=lfs -text
+*.lfs.* filter=lfs diff=lfs merge=lfs -text
+*.mlmodel filter=lfs diff=lfs merge=lfs -text
+*.model filter=lfs diff=lfs merge=lfs -text
+*.msgpack filter=lfs diff=lfs merge=lfs -text
+*.npy filter=lfs diff=lfs merge=lfs -text
+*.npz filter=lfs diff=lfs merge=lfs -text
+*.onnx filter=lfs diff=lfs merge=lfs -text
+*.ot filter=lfs diff=lfs merge=lfs -text
+*.parquet filter=lfs diff=lfs merge=lfs -text
+*.pb filter=lfs diff=lfs merge=lfs -text
+*.pickle filter=lfs diff=lfs merge=lfs -text
+*.pkl filter=lfs diff=lfs merge=lfs -text
+*.pt filter=lfs diff=lfs merge=lfs -text
+*.pth filter=lfs diff=lfs merge=lfs -text
+*.rar filter=lfs diff=lfs merge=lfs -text
+*.safetensors filter=lfs diff=lfs merge=lfs -text
+saved_model/**/* filter=lfs diff=lfs merge=lfs -text
+*.tar.* filter=lfs diff=lfs merge=lfs -text
+*.tar filter=lfs diff=lfs merge=lfs -text
+*.tflite filter=lfs diff=lfs merge=lfs -text
+*.tgz filter=lfs diff=lfs merge=lfs -text
+*.wasm filter=lfs diff=lfs merge=lfs -text
+*.xz filter=lfs diff=lfs merge=lfs -text
+*.zip filter=lfs diff=lfs merge=lfs -text
+*.zst filter=lfs diff=lfs merge=lfs -text
+*tfevents* filter=lfs diff=lfs merge=lfs -text

Dockerfile

@@ -0,0 +1,18 @@
+FROM python:3.10
+
+# Set working directory
+WORKDIR /app
+
+# Copy all project files
+COPY . .
+
+# Install dependencies
+RUN pip install --upgrade pip
+RUN pip install -r requirements.txt
+
+# Expose port 7860 as required by Hugging Face
+EXPOSE 7860
+
+# Run the FastAPI app
+CMD ["uvicorn", "app3:app", "--host", "0.0.0.0", "--port", "7860"]
+-port", "7860"]

README.md

@@ -0,0 +1,11 @@
+---
+title: async_chatbot
+emoji: 🌖
+colorFrom: pink
+colorTo: purple
+sdk: docker
+pinned: false
+short_description: testing chatbot with sycin chating
+---
+
+Check out the configuration reference at https://huggingface.co/docs/hub/spaces-config-reference

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,86 @@
+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
+#
+import os
+import json
+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'\
+credentials_info = json.loads(os.getenv("GOOGLE_CREDENTIALS_JSON"))
+credentials = service_account.Credentials.from_service_account_info(credentials_info)
+
+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_)
+    # )
+    client1 = dialogflow.SessionsClient(
+        credentials=credentials,
+        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,44 @@
+<!DOCTYPE html>
+<html>
+<head>
+    <title>Async Chatbot</title>
+    <!-- <script src="/static/script2.js" defer></script> -->
+    <script >
+        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));
+        }
+    </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>