Only respond in a thread for same room destination

Author: vanstee

lib/cog/pipeline/output_sink.ex

@@ -150,7 +150,18 @@ defmodule Cog.Pipeline.OutputSink do
 
   defp send_to_adapter({type, targets}, signal, state) do
     output = output_for(type, signal, nil)
-    Enum.each(targets, &ChatAdapter.send(state.conn, &1.provider, &1.room, output, state.request.metadata))
+    metadata = state.request.metadata
+
+    Enum.each(targets, fn target ->
+      metadata = case target.room.id == state.request.room.id do
+        true ->
+          metadata
+        false ->
+          %{metadata | thread_id: nil}
+      end
+
+      ChatAdapter.send(state.conn, target.provider, target.room, output, metadata)
+    end)
   end
 
   defp early_exit_response(%DoneSignal{}=signal, state) do