Create app.py

app.py

@@ -0,0 +1,93 @@
+import os
+import tempfile
+import streamlit as st
+from streamlit_chat import message
+from pdfquery import PDFQuery
+from dotenv import load_dotenv
+from gtts import gTTS
+import io
+import base64
+
+# Load environment variables from .env file
+load_dotenv()
+
+st.set_page_config(page_title="Wise Chat Labs")
+
+def display_messages():
+    st.subheader("Chat")
+    for i, (msg, is_user) in enumerate(st.session_state["messages"]):
+        message(msg, is_user=is_user, key=str(i))
+    st.session_state["thinking_spinner"] = st.empty()
+
+def generate_tts_audio(text):
+    tts = gTTS(text=text, lang='en')
+    audio_bytes = io.BytesIO()
+    tts.write_to_fp(audio_bytes)
+    audio_bytes.seek(0)
+    return audio_bytes
+
+def play_audio(audio_bytes):
+    base64_audio = base64.b64encode(audio_bytes.read()).decode('utf-8')
+    audio_html = f'<audio autoplay><source src="data:audio/mp3;base64,{base64_audio}" type="audio/mp3"></audio>'
+    st.markdown(audio_html, unsafe_allow_html=True)
+
+def process_input():
+    if st.session_state["user_input"] and len(st.session_state["user_input"].strip()) > 0:
+        user_text = st.session_state["user_input"].strip()
+        with st.session_state["thinking_spinner"], st.spinner("Thinking..."):
+            query_text = st.session_state["pdfquery"].ask(user_text)
+
+        # Generate and play audio for the response with autoplay
+        audio_response = generate_tts_audio(query_text)
+        play_audio(audio_response)
+
+        st.session_state["messages"].append((user_text, True))
+        st.session_state["messages"].append((query_text, False))
+
+def read_and_save_file():
+    st.session_state["pdfquery"].forget()  # to reset the knowledge base
+    st.session_state["messages"] = []
+    st.session_state["user_input"] = ""
+
+    for file in st.session_state["file_uploader"]:
+        with tempfile.NamedTemporaryFile(delete=False) as tf:
+            tf.write(file.getbuffer())
+            file_path = tf.name
+
+        with st.session_state["ingestion_spinner"], st.spinner(f"Ingesting {file.name}"):
+            st.session_state["pdfquery"].ingest(file_path)
+        os.remove(file_path)
+
+def is_openai_api_key_set() -> bool:
+    return len(st.session_state["OPENAI_API_KEY"]) > 0
+
+def main():
+    if len(st.session_state) == 0:
+        st.session_state["messages"] = []
+        st.session_state["OPENAI_API_KEY"] = os.getenv("OPENAI_API_KEY", "")
+        if is_openai_api_key_set():
+            st.session_state["pdfquery"] = PDFQuery(st.session_state["OPENAI_API_KEY"])
+        else:
+            st.session_state["pdfquery"] = None
+
+    st.header("ChatPDF")
+
+    st.subheader("Upload a document")
+    st.file_uploader(
+        "Upload document",
+        type=["pdf"],
+        key="file_uploader",
+        on_change=read_and_save_file,
+        label_visibility="collapsed",
+        accept_multiple_files=True,
+        disabled=not is_openai_api_key_set(),
+    )
+
+    st.session_state["ingestion_spinner"] = st.empty()
+
+    display_messages()
+    st.text_input("Message", key="user_input", disabled=not is_openai_api_key_set(), on_change=process_input)
+
+
+if __name__ == "__main__":
+    main()