delete_hidden_messages updated logic

app/conversation_manager.py

@@ -280,19 +280,18 @@ class ConversationManager:
         if old_thread is None:
             old_thread = self.current_thread
 
-        # create a new thread
-        messages = [msg for msg in self._get_current_thread_history(remove_system_message=False) if not msg['content'].startswith("[hidden]")]
-        if len(messages) >= 29:
-            messages = messages[-29:]
-        logger.info(f"Current Thread Messages: {messages}", extra={"user_id": self.user.user_id, "endpoint": "delete_hidden_messages"})
-
-        new_thread = self.client.beta.threads.create(messages=messages)
-
-        # delete old thread
-        self.client.beta.threads.delete(old_thread.id)
-
-        # set current thread
-        self.current_thread = new_thread
+        # find all hidden messages to delete
+        to_delete = [{'id': msg.id,'content': msg.content[0].text.value, 'role': msg.role} for msg in self.client.beta.threads.messages.list(self.current_thread.id, order="desc") if msg.content[0].text.value.startswith("[hidden]")]
+        logger.info(f"Marked for deletion= {to_delete}", extra={"user_id": self.user.user_id, "endpoint": "delete_hidden_messaged"})
+
+        for msg in to_delete:
+            # delete msg
+            deleted_message = self.client.beta.threads.messages.delete(
+                message_id=msg['id'],
+                thread_id=self.current_thread.id,
+            )
+            logger.info(f"Deleted Message = {deleted_message}", extra={"user_id": self.user.user_id, "endpoint": "delete_hidden_messaged"})
+        return True
     
     @catch_error
     def cancel_run(self, run, thread = None):