Compare commits

...

2 Commits

2 changed files with 23 additions and 10 deletions

3
.gitignore vendored
View File

@ -1,3 +1,4 @@
srv_secrets.py
venv/
chroma_db/
chroma_db/
__pycache__/

View File

@ -102,21 +102,33 @@ def message_text(event):
# unique_docs = retriever_from_llm.get_relevant_documents(query=event.message.text)
with ApiClient(configuration) as api_client:
try:
answer = str(user_sessions[event.source.user_id]({"question": event.message.text})['answer'])
except:
answer = "message failed to process, please try again"
line_bot_api = MessagingApi(api_client)
line_bot_api.reply_message_with_http_info(
ReplyMessageRequest(
reply_token=event.reply_token,
messages=[TextMessage(text="Message received.\nProcessing... please wait")]
))
with ApiClient(configuration) as api_client:
line_bot_api = MessagingApi(api_client)
line_bot_api.push_message_with_http_info(
PushMessageRequest(
to=event.source.user_id,
messages=[TextMessage(text=str(user_sessions[event.source.user_id]({"question": event.message.text})['answer']))]
messages=[TextMessage(text=answer)]
))
# with ApiClient(configuration) as api_client:
# line_bot_api = MessagingApi(api_client)
# line_bot_api.reply_message_with_http_info(
# ReplyMessageRequest(
# reply_token=event.reply_token,
# messages=[TextMessage(text="Message received.\nProcessing... please wait")]
# ))
# with ApiClient(configuration) as api_client:
# line_bot_api = MessagingApi(api_client)
#
# line_bot_api.push_message_with_http_info(
# PushMessageRequest(to=event.source.user_id,messages=[TextMessage(text=answer)]))
# main is here
if __name__ == "__main__":