Merge pull request #20 from COSCUP/feat/optimize_reply

Feat/optimize reply

.env.example

@@ -3,3 +3,4 @@ LANGCHAIN_TRACING_V2=true
 LANGCHAIN_API_KEY=<LANGCHAIN_API_KEY>
 MODEL_API=<the model api from Mattermost>
 ACCESS_TOKEN=<Github access token>
+MATTERMOST_WEBHOOK_URL=<webhook url>

README.md

@@ -29,11 +29,14 @@ LANGCHAIN_TRACING_V2=true
 LANGCHAIN_API_KEY=<LANGCHAIN_API_KEY>
 MODEL_API=<the model api from Mattermost>
 ACCESS_TOKEN=<Github access token>
+MATTERMOST_WEBHOOK_URL=<Mattermost webhook url>
 ```
 > Note:
 > 1. You can get the `LANGCHAIN_API_KEY` from [LangSmith](https://www.langchain.com/langsmith).
 > 2. Get the `MODEL_API` from [Mattermost](https://chat.coscup.org/coscup/pl/hjez3dwmtjbk8du1rih9ne66wo).
 > 3. How to get Github access token: [Github Docs](https://docs.github.com/en/authentication/
+> 4. Get the `MATTERMOST_WEBHOOK_URL` from Mattermost incoming webhook page and copy the URL from [polyhistor-wait](https://chat.coscup.org/coscup/integrations/incoming_webhooks)
+
 keeping-your-account-and-data-secure/managing-your-personal-access-tokens).
 
 

src/routers/external.py

@@ -2,6 +2,7 @@
 import os
 import warnings
 
+import httpx
 from dotenv import load_dotenv
 from fastapi import APIRouter, Form, status
 from fastapi.responses import JSONResponse
@@ -84,10 +85,27 @@ async def askAPI(data: Query):
     tags=["external"],
 )
 async def chatbot(text: str = Form(...)):
+    if os.getenv("MODE") == "dev":
+        print("收到問題囉～請稍等一下")
+    else:
+        await post_to_mattermost("收到問題囉～請稍等一下")
+
     data = Query(query=text.lower())
     contents = await askAPI(data)
 
-    ans = "Question: " + text + "\n\n" + "Answer: " + "\n" + contents
+    ans = "Question: " + text + "\n\n" + "Answer: " + "\n" + contents + "\n\n" + "如果有什麼問題可以直接留言給我們，如果覺得答案不符合需求，也歡迎直接在留言處提供文件並標注 @jefflu 或 @jimmy_hong 或 @irischen"
 
     gc.collect()
     return JSONResponse(content={"response_type": "in_channel", "text": ans})
+
+
+async def post_to_mattermost(message: str):
+    webhook_url = os.getenv("MATTERMOST_WEBHOOK_URL")
+    if not webhook_url:
+        print("Mattermost webhook URL is not set")
+        return
+
+    payload = {"text": message}
+
+    async with httpx.AsyncClient() as client:
+        response = await client.post(webhook_url, json=payload)