🚀 Automated sync from GitHub

src/ux_agent.py

@@ -575,12 +575,14 @@ class AgentUX:
                 
         return pd.DataFrame(columns=["Timestamp", "Operator_ID", "Feedback_Text", "Image_Reference"])
 
-    def get_pending_dataframe(self):
+    def get_pending_dataframe(self, dialect_filter="All"):
         if os.path.exists(self.PENDING_FILE): 
             df = pd.read_csv(self.PENDING_FILE)
             cols = ["User", "Data_Origin", "Utterance", "Dialect", "Clarification", "Clarification_Source", "Tone", "Audio", "Timestamp"]
             for c in cols:
                 if c not in df.columns: df[c] = ""
+            if dialect_filter and dialect_filter != "All":
+                df = df[df["Dialect"] == dialect_filter]
             return df[cols]
         return pd.DataFrame(columns=["User", "Data_Origin", "Utterance", "Dialect", "Clarification", "Clarification_Source", "Tone", "Audio", "Timestamp"])
 
@@ -655,25 +657,28 @@ class AgentUX:
         self.last_pending_count = count
         return f"### {label} - Review Submissions from React Games", sound
 
-    def admin_approve_pending(self, index, edited_utt, edited_clar, edited_tone):
+    def admin_approve_pending(self, index, edited_utt, edited_dialect, edited_clar, edited_tone, trimmed_audio_path):
         try:
             df = pd.read_csv(self.PENDING_FILE)
             row = df.iloc[int(index)]
             
             # 🟢 Use the edited text instead of the original row data
             final_utt = edited_utt if edited_utt else row["Utterance"]
+            final_dialect = edited_dialect if edited_dialect else row["Dialect"]
             final_clar = edited_clar if edited_clar else row["Clarification"]
             final_tone = edited_tone if edited_tone else row["Tone"]
             
+            final_audio = trimmed_audio_path if trimmed_audio_path and os.path.exists(trimmed_audio_path) else row["Audio"]
+            
             self.trust.update_dataset_csv(
-                row["Dialect"], final_utt, final_clar, final_tone,
-                row.get("Context", ""), "", row["Audio"], row.get("Pragmatic_Analysis", ""),
+                final_dialect, final_utt, final_clar, final_tone,
+                row.get("Context", ""), "", final_audio, row.get("Pragmatic_Analysis", ""),
                 row.get("Data_Origin", ""), "Admin Edit", row.get("User", "")
             )
             
             payload = {
                 "original": final_utt,
-                "dialect": row["Dialect"],
+                "dialect": final_dialect,
                 "clarification": final_clar,
                 "tone": final_tone,
                 "user": str(row.get("User", "")) 
@@ -975,11 +980,12 @@ class AgentUX:
                     pending_header = gr.Markdown("### 👮 Pending (0) - Review Submissions from React Games")
                     with gr.Row():
                         with gr.Column(scale=3):
+                            filter_dialect = gr.Dropdown(choices=["All"] + dropdown_choices, value="All", label="Filter by Dialect")
                             pending_df = gr.Dataframe(headers=["User", "Data_Origin", "Utterance", "Dialect", "Clarification", "Tone", "Audio", "Timestamp"], interactive=False, wrap=False, row_count=(1, "dynamic"))
                         with gr.Column(scale=1):
                             gr.Markdown("#### 🎧 Audio Auditor")
                             btn_refresh = gr.Button("🔄 Refresh List")
-                            pending_audio_player = gr.Audio(label="Click a row to load audio", type="filepath", interactive=False)
+                            pending_audio_player = gr.Audio(label="Trim or Preview Audio", type="filepath", interactive=True)
                             audit_log = gr.Textbox(label="Audit Status", interactive=False)
                     
                     # 🟢 NEW: Editable Textboxes for Admin Corrections
@@ -987,6 +993,7 @@ class AgentUX:
                     with gr.Row():
                         pending_idx = gr.Number(label="Row Index", precision=0, interactive=False)
                         edit_utt = gr.Textbox(label="Utterance", interactive=True)
+                        edit_dialect = gr.Textbox(label="Dialect / Language", interactive=True)
                         edit_clar = gr.Textbox(label="Clarification / Meaning", interactive=True)
                         edit_tone = gr.Textbox(label="Tone", interactive=True)
 
@@ -1150,19 +1157,21 @@ class AgentUX:
                     utt = str(row.get("Utterance", ""))
                     clar = str(row.get("Clarification", ""))
                     tone = str(row.get("Tone", ""))
-                    return audio_path, idx, utt, clar, tone
+                    dialect = str(row.get("Dialect", ""))
+                    return audio_path, idx, utt, dialect, clar, tone
                 except: 
-                    return None, 0, "", "", ""
+                    return None, 0, "", "", "", ""
 
-            btn_refresh.click(self.get_pending_dataframe, outputs=[pending_df])
+            filter_dialect.change(self.get_pending_dataframe, inputs=[filter_dialect], outputs=[pending_df])
+            btn_refresh.click(self.get_pending_dataframe, inputs=[filter_dialect], outputs=[pending_df])
             
             # 🟢 FIX: Fill the textboxes when a row is clicked
-            pending_df.select(select_pending_row, [pending_df], [pending_audio_player, pending_idx, edit_utt, edit_clar, edit_tone])
+            pending_df.select(select_pending_row, [pending_df], [pending_audio_player, pending_idx, edit_utt, edit_dialect, edit_clar, edit_tone])
             
             # 🟢 FIX: Pass the edited textboxes to the approval function, then auto-refresh the table
-            btn_appr_p.click(self.admin_approve_pending, inputs=[pending_idx, edit_utt, edit_clar, edit_tone], outputs=[audit_log]).then(self.get_pending_dataframe, outputs=[pending_df])
-            btn_rejt_p.click(self.admin_reject_pending, inputs=[pending_idx], outputs=[audit_log]).then(self.get_pending_dataframe, outputs=[pending_df])
-            btn_clear_pending.click(self.admin_clear_all_pending, outputs=[audit_log]).then(self.get_pending_dataframe, outputs=[pending_df])
+            btn_appr_p.click(self.admin_approve_pending, inputs=[pending_idx, edit_utt, edit_dialect, edit_clar, edit_tone, pending_audio_player], outputs=[audit_log]).then(self.get_pending_dataframe, inputs=[filter_dialect], outputs=[pending_df])
+            btn_rejt_p.click(self.admin_reject_pending, inputs=[pending_idx], outputs=[audit_log]).then(self.get_pending_dataframe, inputs=[filter_dialect], outputs=[pending_df])
+            btn_clear_pending.click(self.admin_clear_all_pending, outputs=[audit_log]).then(self.get_pending_dataframe, inputs=[filter_dialect], outputs=[pending_df])
 
             def trigger_recovery():
                 try: