Upload 20 files

Prova Commit Frontend

.gitattributes

@@ -33,3 +33,5 @@ saved_model/**/* 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
+static/2.png filter=lfs diff=lfs merge=lfs -text
+static/3.png filter=lfs diff=lfs merge=lfs -text

app.py

@@ -0,0 +1,16 @@
+from frontend_pages import st
+from frontend_pages.ConfigPage import ConfigPage
+from frontend_pages.ChatModelPage import ChatModelPage
+from frontend_pages.Dashboard import Dashboard
+
+st.set_page_config(layout="wide")
+
+PAGES = {
+    "Configurazione": ConfigPage,
+    "Dashboard": ChatModelPage,
+    # "Dashboard": Dashboard,
+}
+
+if __name__ == "__main__":
+    PAGES[st.sidebar.selectbox("Select a page", list(PAGES.keys()))]().render()
+    # PAGES["Chat with AI Model"]().render()

frontend_pages/BasePage.py

@@ -0,0 +1,22 @@
+from . import st, ABC, abstractmethod
+
+class BasePage(ABC):
+    _instance = None
+
+    def __new__(cls, *args, **kwargs):
+        if cls._instance is None:
+            cls._instance = super(BasePage, cls).__new__(cls)
+        return cls._instance
+
+    def __init__(self):
+        if not hasattr(self, 'initialized'):
+            self.api_keys = []
+            self.initialized = True
+
+    @abstractmethod
+    def render(self, keys : dict[str, str | None], **kwargs):
+        with st.sidebar:
+            st.title("API Key Input")
+            for key, default_value in keys.items():
+                st.session_state[key] = st.text_input(f"Enter API key for {key}", value=default_value, type="password")
+            st.divider()

frontend_pages/ChatModelPage.py

@@ -0,0 +1,148 @@
+from . import os, st, re, requests, stylable_container
+from .BasePage import BasePage
+
+from .modals import get_base64_image, create_call_modal, upload_call_modal_and_actions
+
+class RouterAgent:
+    def __call__(self, **kwargs):
+        agent_prompt_slash_code = re.findall(r"(\/[\w\-_]*)? *(.*)", kwargs.get('prompt'))
+        uri = agent_prompt_slash_code[0][0] or "/explain"
+        prompt = agent_prompt_slash_code[0][1]
+        print(f'{uri = }', f'{prompt = }')
+        response = requests.post(os.getenv("BACKEND_URL", "http://127.0.0.1:5000") + f'{uri}', json = {"prompt" : prompt})
+        if response.status_code != 200:
+            st.error(f"Error: {response.text}")
+            return
+        response_json = response.json()
+        print(f'{response_json = }')
+        return response_json["message"]
+
+class ChatModelPage(BasePage):
+    def __init__(self):
+        super().__init__()
+        self.model = None
+        self.router_agent = RouterAgent()
+
+    def render(self):
+        st.title("Dashboard")
+        self.sidebar_elements()
+        self.upfront_page()
+        self.init_messages()
+        self.reset_messages_sidebar_button()
+        # Display chat messages from history on app rerun
+        for message in st.session_state.messages:
+            with st.chat_message(message["role"]):
+                st.markdown(message["content"])
+        # React to user input
+        if prompt := st.chat_input("What is up?"):
+            # Display user message in chat message container
+            st.chat_message("user").markdown(prompt)
+            # Add user message to chat history
+            st.session_state.messages.append({"role": "user", "content": prompt})
+            response = self.get_agent_response(prompt = prompt)
+            # Display assistant response in chat message container
+            with st.chat_message("assistant"):st.markdown(response)
+            # Add assistant response to chat history
+            st.session_state.messages.append({"role": "assistant", "content": response})
+    
+    def init_messages(self):
+        # Initialize chat history
+        if "messages" not in st.session_state:
+            st.session_state.messages = []
+    
+    def get_agent_response(self, **kwargs):
+        # Get agent response
+        return self.router_agent(**kwargs)
+
+    def reset_messages_sidebar_button(self):
+        with st.sidebar:
+            # Reset chat history
+            if st.button("Reset chat"):
+                st.session_state.messages = []
+
+    def upfront_page(self):
+        tabs_and_dialogs_cols = st.columns(2)
+        with tabs_and_dialogs_cols[0]:
+            with stylable_container(
+                key = "create-call-button",
+                css_styles = f"""
+                    button {{
+                        background-image: url("data:image/png;base64,{get_base64_image("static/NewCallButton.png")}");
+                        background-size: cover;
+                        background-repeat: no-repeat;
+                        background-position: center;
+                        background-color: transparent;
+                        border: none;
+                        width: 298px;
+                        height: 164px;
+                    }}"""
+            ):
+                clicked_create_call_button = st.button("", key = "create-call-button")
+            if clicked_create_call_button:create_call_modal()
+            with stylable_container(
+                key = "upload-call-button",
+                css_styles = f"""
+                    button  {{
+                        background-image: url("data:image/png;base64,{get_base64_image("static/UploadCallButton.png")}");
+                        background-size: cover;
+                        background-repeat: no-repeat;
+                        background-position: center;
+                        background-color: transparent;
+                        border: none;
+                        width: 298px;
+                        height: 164px;
+                    }}"""
+            ):
+                clicked_create_call_button = st.button('', key='upload-call-button')
+            if clicked_create_call_button:upload_call_modal_and_actions()
+        with tabs_and_dialogs_cols[1]:
+            tabs = st.tabs(["Tasks"])
+            func_of_tabs = [ self.tasks ]
+            for tab, func in zip(tabs, func_of_tabs):
+                with tab:func()
+
+    def sidebar_elements(self):
+        actions = {"Project" : self.projects, "Team" : self.team }
+        with st.sidebar:
+            for label, action in actions.items():
+                st.header(label)
+                action()
+                st.divider()
+
+    def team(self):
+        teams_per_project = {"Projects": "Team1", "Projects2": "Team2", "Projects3": "Team3"}
+        st.write(teams_per_project[st.session_state.selected_project])
+        # st.image("static/2.png")
+
+    def tasks(self):
+        st.image("static/3.png")
+
+    def projects(self):
+        projects_available = ["Projects", "Projects2", "Projects3"]
+        st.session_state.selected_project = st.selectbox("Projects available", projects_available)
+
+    # def choose_agent(self):
+    #     # Choose agent
+    #     class RouterAgent:
+    #         def __call__(self, **kwargs):
+    #             agent_prompt_slash_code = re.findall(r"(\/[\w\-_]*) *(.*)", kwargs.get('prompt'))
+    #             uri = agent_prompt_slash_code[0][0]
+    #             prompt = agent_prompt_slash_code[0][1]
+    #             response = requests.post(os.getenv("BACKEND_URL") + f'/{uri}', json = {"prompt" : prompt})
+    #             if response.status_code != 200:
+    #                 st.error(f"Error: {response.text}")
+    #                 return
+    #             return response.json()
+    #     # agents = {
+    #     #     "Dummy Agent": {
+    #     #         "_class" : RouterAgent,
+    #     #     },
+    #     #     "Meeting Scheduler Agent": {
+    #     #         "_class" : DummyAgent,
+    #     #     }
+    #     # }
+    #     # agent_selected = st.sidebar.selectbox("Select agent", list(agents.keys()))
+    #     # agent_init_js = agents[agent_selected]
+    #     RouterAgent()
+    #     agent_class = agent_init_js.pop("_class")
+    #     return agent_class(**agent_init_js)

frontend_pages/ConfigPage.py

@@ -0,0 +1,6 @@
+from . import os
+from .BasePage import BasePage
+
+class ConfigPage(BasePage):
+    def render(self):
+        super().render(keys={"WATSON_API_KEY": os.getenv("WATSON_API_KEY")})

frontend_pages/Dashboard.py

@@ -0,0 +1,72 @@
+from . import os, st, stylable_container
+from .BasePage import BasePage
+
+from .modals import get_base64_image, create_call_modal, upload_call_modal_and_actions
+
+class Dashboard(BasePage):
+    def render(self):
+        st.title("Dashboard")
+        self.sidebar_elements()
+        self.upfront_page()
+
+    def upfront_page(self):
+        with st.sidebar:
+            tabs_and_dialogs_cols = st.columns(2)
+            with tabs_and_dialogs_cols[0]:
+                with stylable_container(
+                    key = "create-call-button",
+                    # css_styles = f"""
+                    #     button {{
+                    #         background-image: url("data:image/png;base64,{get_base64_image("static/NewCallButton.png")}");
+                    #         background-size: cover;
+                    #         background-repeat: no-repeat;
+                    #         background-position: center;
+                    #         background-color: transparent;
+                    #         border: none;
+                    #         width: 298px;
+                    #         height: 164px;
+                    #     }}"""
+                ):
+                    clicked_create_call_button = st.button("create-call-button", key = "create-call-button")
+                if clicked_create_call_button:create_call_modal()
+                with stylable_container(
+                    key = "upload-call-button",
+                    # css_styles = f"""
+                    #     button  {{
+                    #         background-image: url("data:image/png;base64,{get_base64_image("static/UploadCallButton.png")}");
+                    #         background-size: cover;
+                    #         background-repeat: no-repeat;
+                    #         background-position: center;
+                    #         background-color: transparent;
+                    #         border: none;
+                    #         width: 298px;
+                    #         height: 164px;
+                    #     }}"""
+                ):
+                    clicked_create_call_button = st.button('upload-call-button', key='upload-call-button')
+                if clicked_create_call_button:upload_call_modal_and_actions()
+            with tabs_and_dialogs_cols[1]:
+                tabs = st.tabs(["Tasks"])
+                func_of_tabs = [ self.tasks ]
+                for tab, func in zip(tabs, func_of_tabs):
+                    with tab:func()
+
+    def sidebar_elements(self):
+        actions = {"Project" : self.projects, "Team" : self.team }
+        with st.sidebar:
+            for label, action in actions.items():
+                st.header(label)
+                action()
+                st.divider()
+
+    def team(self):
+        teams_per_project = {"Projects": "Team1", "Projects2": "Team2", "Projects3": "Team3"}
+        st.write(teams_per_project[st.session_state.selected_project])
+        # st.image("static/2.png")
+
+    def tasks(self):
+        st.image("static/3.png")
+
+    def projects(self):
+        projects_available = ["Projects", "Projects2", "Projects3"]
+        st.session_state.selected_project = st.selectbox("Projects available", projects_available)

frontend_pages/__init__.py

@@ -0,0 +1,9 @@
+import streamlit as st
+import requests
+import re
+import os
+import base64
+from abc import ABC, abstractmethod
+from functools import  partial
+from streamlit_calendar import calendar
+from streamlit_extras.stylable_container import stylable_container

frontend_pages/load_css.py

@@ -0,0 +1,10 @@
+from . import  st
+
+def render_css(file_path):
+    with open(file_path, 'r') as file:
+        css_content = file.read()
+        st.markdown(f'<style>{css_content}</style>', unsafe_allow_html=True)
+
+# Example usage
+if __name__ == "__main__":
+    render_css('path_to_your_css_file.css')

frontend_pages/modals.py

@@ -0,0 +1,113 @@
+import random
+import docx
+from PyPDF2 import PdfFileReader
+import io
+
+from . import st, base64, os, requests, partial
+from .load_css import render_css
+
+st.markdown(f'<style></style>', unsafe_allow_html=True)
+
+def get_base64_image(image_path : str):
+    with open(image_path, "rb") as image_file:
+        return base64.b64encode(image_file.read()).decode()
+    
+@st.dialog("Create a Call")
+def create_call_modal():
+    st.multiselect("People", ["Alice", "Bob", "Charlie"])
+    st.multiselect("Tasks", ["Task 1", "Task 2", "Task 3"])
+    st.text_area("Prompt")
+    buttons = [
+        ("submit", lambda _ : st.balloons()), 
+        ("cancel", lambda _ : st.balloons())
+    ]
+    cols = st.columns(len(buttons))
+    for col, button in zip(cols, buttons): 
+        with col:
+            if st.button(button[0]):
+                button[1]()
+
+@st.dialog("Upload a Call")
+def upload_call_modal_and_actions():
+    uploaded_file = st.file_uploader(
+        # "Import a videocall recording or its transcripts", 
+        "Import a videocall recording transcript", 
+        type=['.txt', '.doc', '.docx', '.pdf'],
+        # type=['.txt', '.doc', '.docx', '.pdf', '.mp4', '.wav', '.flac'],
+        accept_multiple_files=False
+    )
+    transcript_text = get_transcript_text(uploaded_file) if uploaded_file else ""
+    buttons = {
+        # "Crea minuta": minuta_action_from_uploaded_call, 
+        # "Genera trascritto": transcript_action_from_uploaded_call, 
+        "QA from transcripts": partial(qa_from_transcripts, Transcript = transcript_text), 
+        "Generate Tasks from transcript": partial(create_tasks_action_from_uploaded_call_transcript, Transcript = transcript_text), 
+    }
+    _ = buttons[st.selectbox("Choose an action", buttons.keys())]()
+                
+def minuta_action_from_uploaded_call():
+    if st.button("Crea minuta"):
+        st.download_button("Scarica minuta", data = "moc_minuta.txt")
+
+def transcript_action_from_uploaded_call():
+    if st.button("Crea transcript"):
+        st.download_button("Scarica transcript", data = "moc_transcript.txt")
+    
+def get_transcript_text(uploaded_file):
+    if uploaded_file is not None:
+        file_extension = os.path.splitext(uploaded_file.name)[1].lower()
+        if file_extension == '.txt':
+            return get_text_from_txt(uploaded_file)
+        elif file_extension in ['.doc', '.docx']:
+            return get_text_from_doc(uploaded_file)
+        elif file_extension == '.pdf':
+            return get_text_from_pdf(uploaded_file)
+    return ""
+
+def get_text_from_txt(uploaded_file):
+    return uploaded_file.read().decode("utf-8")
+
+def get_text_from_doc(uploaded_file):
+    doc = docx.Document(uploaded_file)
+    return "\n".join([para.text for para in doc.paragraphs])
+
+def get_text_from_pdf(uploaded_file):
+    reader = PdfFileReader(io.BytesIO(uploaded_file.read()))
+    text = ""
+    for page_num in range(reader.getNumPages()):
+        text += reader.getPage(page_num).extract_text()
+    return text
+
+
+def qa_from_transcripts(Transcript : str):
+    Prompt = st.text_area("Prompt")
+    Transcript = st.text_area("Transcript")
+    Tasks = "\n\n".join(st.multiselect("Tasks", options = ["Task 1", "Task 2", "Task 3"]))
+    if st.button("QA from transcripts"):
+        response = requests.post(os.getenv("QA_TRANSCRIPT_ENDPOINT", "http://127.0.0.1:5000/transcript") , 
+            json = {
+                "prompt": Prompt,
+                "transcript" : Transcript or "",
+                "tasks": Tasks or [],
+            })
+        st.success(response.json())
+        return 
+
+def create_tasks_action_from_uploaded_call_transcript(Transcript : str):
+
+    if st.button("create_tasks"):
+        response = requests.post(os.getenv("QA_TRANSCRIPT_ENDPOINT", "http://127.0.0.1:5000/tasks/from_transcript") , json = {"transcript" : Transcript})
+        st.session_state.tasks = st.success(response.json())
+        return 
+    if st.session_state.get('tasks'):
+        task = st.selectbox("Select a task", st.session_state.tasks)
+        task_matchmaking(task)
+
+def task_matchmaking(task : str):
+    cols = st.columns(2)
+    with cols[0]:
+        st.markdown("### Task matchmaking")
+    with cols[1]:
+        st.multiselect("People", ["Alice", "Bob", "Charlie"])
+    if st.button("Assign"):
+        st.success("Task assigned")

requirements.txt

@@ -0,0 +1,140 @@
+altair==5.5.0
+annotated-types==0.7.0
+anyio==4.8.0
+attrs==25.1.0
+beautifulsoup4==4.13.3
+blinker==1.9.0
+cachetools==5.5.2
+certifi==2025.1.31
+charset-normalizer==3.4.1
+click==8.1.8
+colorama==0.4.6
+contourpy==1.3.1
+cycler==0.12.1
+entrypoints==0.4
+Faker==36.1.1
+fastapi==0.115.8
+favicon==0.7.0
+fonttools==4.56.0
+gitdb==4.0.12
+GitPython==3.1.44
+google-api-core==2.24.1
+google-api-python-client==2.161.0
+google-auth==2.38.0
+google-auth-httplib2==0.2.0
+google-auth-oauthlib==1.2.1
+google-cloud==0.34.0
+google-cloud-core==2.4.2
+google-cloud-storage==3.0.0
+google-cloud-vision==3.10.0
+google-crc32c==1.6.0
+google-resumable-media==2.7.2
+googleapis-common-protos==1.68.0
+gritql==0.1.5
+grpcio==1.70.0
+grpcio-status==1.70.0
+h11==0.14.0
+htbuilder==0.9.0
+httpcore==1.0.7
+httplib2==0.22.0
+httpx==0.28.1
+ibm-cos-sdk==2.13.6
+ibm-cos-sdk-core==2.13.6
+ibm-cos-sdk-s3transfer==2.13.6
+ibm_watsonx_ai==1.2.8
+idna==3.10
+importlib_metadata==8.6.1
+Jinja2==3.1.5
+jmespath==1.0.1
+jsonpatch==1.33
+jsonpointer==3.0.0
+jsonschema==4.23.0
+jsonschema-specifications==2024.10.1
+kiwisolver==1.4.8
+langchain-cli==0.0.35
+langchain-core==0.3.37
+langchain-ibm==0.3.6
+langgraph==0.2.74
+langgraph-checkpoint==2.0.16
+langgraph-sdk==0.1.53
+langserve==0.3.1
+langsmith==0.3.9
+lomond==0.3.3
+lxml==5.3.1
+Markdown==3.7
+markdown-it-py==3.0.0
+markdownlit==0.0.7
+MarkupSafe==3.0.2
+matplotlib==3.10.0
+mdurl==0.1.2
+msgpack==1.1.0
+narwhals==1.27.1
+numpy==1.26.4
+oauthlib==3.2.2
+orjson==3.10.15
+packaging==24.2
+pandas==2.1.4
+pillow==11.1.0
+plotly==6.0.0
+prometheus_client==0.21.1
+proto-plus==1.26.0
+protobuf==5.29.3
+pyarrow==19.0.1
+pyasn1==0.6.1
+pyasn1_modules==0.4.1
+pydantic==2.10.6
+pydantic_core==2.27.2
+pydeck==0.9.1
+Pygments==2.19.1
+pymdown-extensions==10.14.3
+pyparsing==3.2.1
+PyPDF2==3.0.1
+python-dateutil==2.9.0.post0
+python-docx==1.1.2
+python-dotenv==1.0.1
+pytz==2025.1
+PyYAML==6.0.2
+referencing==0.36.2
+requests==2.32.2
+requests-oauthlib==2.0.0
+requests-toolbelt==1.0.0
+rich==13.9.4
+rpds-py==0.23.1
+rsa==4.9
+setuptools==75.8.0
+shellingham==1.5.4
+six==1.17.0
+smmap==5.0.2
+sniffio==1.3.1
+soupsieve==2.6
+SQLAlchemy==2.0.38
+sse-starlette==1.8.2
+st-annotated-text==4.0.2
+st-theme==1.2.3
+starlette==0.45.3
+streamlit==1.42.2
+streamlit-calendar==1.2.1
+streamlit-camera-input-live==0.2.0
+streamlit-card==1.0.2
+streamlit-embedcode==0.1.2
+streamlit-extras==0.5.5
+streamlit-faker==0.0.3
+streamlit-image-coordinates==0.1.9
+streamlit-keyup==0.3.0
+streamlit-toggle-switch==1.0.2
+streamlit-vertical-slider==2.5.5
+tabulate==0.9.0
+tenacity==9.0.0
+toml==0.10.2
+tomlkit==0.13.2
+tornado==6.4.2
+typer==0.9.4
+typing_extensions==4.12.2
+tzdata==2025.1
+uritemplate==4.1.1
+urllib3==2.3.0
+uvicorn==0.34.0
+validators==0.34.0
+wheel==0.45.1
+zipp==3.21.0
+zstandard==0.23.0