better formatting

app.py

@@ -39,34 +39,24 @@ if not ray.is_initialized():
 
 
 async def main():
-
-    system_one_audio_status = st.empty()
-
-
-    system_one_audio_status.write("Initializing streaming")
-
-    # system_one_audio_output = st.empty()
-    # system_one_video_output = st.empty()
-    # system_one_audio_history = []
+    st.title("Project Charles")
 
     col1, col2 = st.columns(2)
 
     with col1:
-        listening = st.checkbox("Listen", value=True)
-        looking = st.checkbox("Look", value=False)
+        nested_col1, nested_col2 = st.columns(2)
+        with nested_col1:
+            listening = st.checkbox("Listen", value=True)
+        with nested_col2:
+            looking = st.checkbox("Look", value=False)
         charles_actor_debug_output = st.empty()
         environment_state_ouput = st.empty()
 
-    # Initialize resources if not already done
-    system_one_audio_status.write("Initializing streaming")
-    if "streamlit_av_queue" not in st.session_state:
-        from streamlit_av_queue import StreamlitAVQueue
-        st.session_state.streamlit_av_queue = StreamlitAVQueue()
-
-    system_one_audio_status.write("resources referecned")
-
-    system_one_audio_status.write("Initializing webrtc_streamer")
     with col2:
+        if "streamlit_av_queue" not in st.session_state:
+            from streamlit_av_queue import StreamlitAVQueue
+            st.session_state.streamlit_av_queue = StreamlitAVQueue()
+
         playing = st.checkbox("Playing", value=True)
         webrtc_ctx = webrtc_streamer(
             key="charles",
@@ -87,12 +77,11 @@ async def main():
             rtc_configuration={"iceServers": get_ice_servers()},
             async_processing=True,
         )
+        system_one_audio_status = st.markdown("Initializing streaming")
 
     if not webrtc_ctx.state.playing:
         exit
 
-    system_one_audio_status.write("Initializing speech")
-    
     from charles_actor import CharlesActor
     charles_actor = None
 

charles_actor.py

@@ -61,13 +61,19 @@ class CharlesActor:
             await self._initalize_resources()
             
         debug_output_history = []
+
+        def render_debug_output(list_of_strings):
+            table_content = "##### Chat history\n"
+            for item in reversed(list_of_strings):
+                # table_content += f"\n```markdown\n{item}\n```\n"
+                table_content += f"\n{item}\n"
+            self._charles_actor_debug_output = table_content
+
         def add_debug_output(output):
             debug_output_history.append(output)
             if len(debug_output_history) > 10:
                 debug_output_history.pop(0)
-            table_content = "| Charles Actor debug history |\n| --- |\n"
-            table_content += "\n".join([f"| {item} |" for item in reversed(debug_output_history)])
-            self._charles_actor_debug_output = table_content
+            render_debug_output(debug_output_history)
         
         self._state = "Waiting for input"
         total_video_frames = 0
@@ -123,12 +129,12 @@ class CharlesActor:
 
                     if speaker_finished and len(prompt) > 0 and prompt not in prompts_to_ignore:
                         print(f"Prompt: {prompt}")
-                        lines = []
+                        line = ""
                         for i, response in enumerate(current_responses):
-                            line = "🤖 " if len(lines) == 0 else "... "
-                            line += f"{response} [{speech_chunks_per_response[i]}]"
-                            lines.append(line)
-                        for line in reversed(lines):
+                            line += "🤖 " if len(line) == 0 else ""
+                            # line += f"{response} [{speech_chunks_per_response[i]}]  \n"
+                            line += f"[{speech_chunks_per_response[i]}] {response}  \n"
+                        if len(line) > 0:
                             add_debug_output(line)
                         add_debug_output(f"👨 {prompt}")
                         current_responses = []
@@ -156,23 +162,20 @@ class CharlesActor:
                 response_id = chunk['llm_sentence_id']
                 speech_chunks_per_response[response_id] += 1
 
-            table_content = "| Charles Actor debug history |\n| --- |\n"
-            debug_output_history_copy = debug_output_history.copy()
-            if len(robot_preview_text) > 0:
-                debug_output_history_copy.append(robot_preview_text)
-            lines = []
+            list_of_strings = debug_output_history.copy()
+            line = ""
             for i, response in enumerate(current_responses):
-                line = "🤖 " if len(lines) == 0 else "... "
-                line += f"{response} [{speech_chunks_per_response[i]}]"
-                lines.append(line)
-            for line in reversed(lines):
-                debug_output_history_copy.append(line)
+                line += "🤖 " if len(line) == 0 else ""
+                line += f"[{speech_chunks_per_response[i]}] {response}  \n"
+                # line += f"{response} [{speech_chunks_per_response[i]}]  \n"
+            if len(robot_preview_text) > 0:
+                line += robot_preview_text+"  \n"
+            list_of_strings.append(line)
             if len(human_preview_text) > 0:
-                debug_output_history_copy.append(human_preview_text)
-            if len(debug_output_history_copy) > 10:
-                debug_output_history_copy.pop(0)
-            table_content += "\n".join([f"| {item} |" for item in reversed(debug_output_history_copy)])
-            self._charles_actor_debug_output = table_content
+                list_of_strings.append(human_preview_text)
+            if len(list_of_strings) > 10:
+                list_of_strings.pop(0)
+            render_debug_output(list_of_strings)
 
 
             await asyncio.sleep(0.01)