From 9a6b1c16237b9b00df0fcd044bb4e2a178492a64 Mon Sep 17 00:00:00 2001
From: Jon Saad-Falcon <41205309+jonsaadfalcon@users.noreply.github.com>
Date: Sat, 28 Mar 2026 15:12:36 -0700
Subject: [PATCH] feat: reply in thread for Slack messages to reduce DM clutter
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

All bot replies (acknowledgment, progress updates, final response)
now use thread_ts to reply in the thread of the user's message.
Keeps the DM conversation clean — one thread per question.

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
---
 src/openjarvis/server/agent_manager_routes.py | 46 ++++++++++++-------
 1 file changed, 30 insertions(+), 16 deletions(-)

diff --git a/src/openjarvis/server/agent_manager_routes.py b/src/openjarvis/server/agent_manager_routes.py
index 8c7fb556..d56d79ea 100644
--- a/src/openjarvis/server/agent_manager_routes.py
+++ b/src/openjarvis/server/agent_manager_routes.py
@@ -1467,14 +1467,14 @@ def create_agent_manager_router(
                         text = _re.sub(r"\n{3,}", "\n\n", text)
                         return text.strip()
 
-                    def _process_queue(say_fn):
+                    def _process_queue(say_fn, thread_ts):
                         """Process queued messages sequentially."""
                         while not _msg_queue.empty():
-                            text = _msg_queue.get()
+                            _text, _ts = _msg_queue.get()
                             _processing.set()
                             if dr_agent:
                                 try:
-                                    result = dr_agent.run(text)
+                                    result = dr_agent.run(_text)
                                     reply = (
                                         result.content
                                         or "No results found."
@@ -1485,7 +1485,10 @@ def create_agent_manager_router(
                                 reply = (
                                     "Agent not available."
                                 )
-                            say_fn(_to_slack_fmt(reply))
+                            say_fn(
+                                text=_to_slack_fmt(reply),
+                                thread_ts=_ts,
+                            )
                             _processing.clear()
 
                     @bolt_app.event("message")
@@ -1494,23 +1497,31 @@ def create_agent_manager_router(
                         if not text:
                             return
 
+                        # Use message ts as thread parent
+                        msg_ts = event.get("ts", "")
+
                         if _processing.is_set():
-                            # Already working on something
-                            _msg_queue.put(text)
+                            _msg_queue.put((text, msg_ts))
                             qsize = _msg_queue.qsize()
                             say(
-                                "Message received! "
-                                f"Message {qsize + 1} in queue"
-                                f" of {qsize + 1}, "
-                                "will respond ASAP"
+                                text=(
+                                    "Message received! "
+                                    f"Message {qsize + 1} in "
+                                    f"queue of {qsize + 1}, "
+                                    "will respond ASAP"
+                                ),
+                                thread_ts=msg_ts,
                             )
                             return
 
                         say(
-                            "Message received! "
-                            "Working on it now..."
+                            text=(
+                                "Message received! "
+                                "Working on it now..."
+                            ),
+                            thread_ts=msg_ts,
                         )
-                        _msg_queue.put(text)
+                        _msg_queue.put((text, msg_ts))
 
                         # Start progress updater
                         _stop_progress = _thr.Event()
@@ -1524,8 +1535,11 @@ def create_agent_manager_router(
                                 mins += 1
                                 if _processing.is_set():
                                     say(
-                                        "Still working! "
-                                        "Will reply ASAP"
+                                        text=(
+                                            "Still working! "
+                                            "Will reply ASAP"
+                                        ),
+                                        thread_ts=msg_ts,
                                     )
 
                         pt = _thr.Thread(
@@ -1535,7 +1549,7 @@ def create_agent_manager_router(
                         pt.start()
 
                         # Process in current thread
-                        _process_queue(say)
+                        _process_queue(say, msg_ts)
                         _stop_progress.set()
 
                     sm_handler = SocketModeHandler(