admin/OpenJarvis
1
0
Fork 0
mirror of https://github.com/open-jarvis/OpenJarvis.git synced 2026-07-29 18:40:38 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat: reply in thread for Slack messages to reduce DM clutter

Browse Source 
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>
This commit is contained in:
Jon Saad-Falcon
2026-03-28 15:12:36 -07:00
co-authored by Claude Opus 4.6
parent 590e8b90a3
commit 9a6b1c1623
1 changed files with 30 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/openjarvis/server/agent_manager_routes.py
+30 -16
View File
@@ -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(