refactor: streamline message handling in chat and dashboard components

Author: zcesur

lib/algora_web/components/layouts/user.html.heex

@@ -109,7 +109,7 @@
       <%= if assigns[:threads] && assigns[:threads] != [] do %>
         <.separator class="mx-auto my-4 w-2/3" />
         <ul role="list" class="space-y-1">
-          <%= for %{thread: thread, contact: contact, path: path} <- @threads do %>
+          <%= for %{contact: contact, path: path} <- @threads do %>
             <li>
               <.link
                 class="flex justify-center p-2"

lib/algora_web/live/chat/thread_live.ex

@@ -31,15 +31,18 @@ defmodule AlgoraWeb.Chat.ThreadLive do
         content
       )
 
-    {:noreply, push_event(socket, "clear-input", %{selector: "#message-input"})}
+    {:noreply,
+     socket
+     |> Phoenix.Component.update(:messages, &(&1 ++ [message]))
+     |> push_event("clear-input", %{selector: "#message-input"})}
   end
 
   @impl true
   def handle_info(%Message{} = message, socket) do
     if message.id in Enum.map(socket.assigns.messages, & &1.id) do
       {:noreply, socket}
     else
-      {:noreply, assign(socket, :messages, socket.assigns.messages ++ [message])}
+      {:noreply, Phoenix.Component.update(socket, :messages, &(&1 ++ [message]))}
     end
   end
 

lib/algora_web/live/contract/view_live.ex

@@ -484,6 +484,10 @@ defmodule AlgoraWeb.Contract.ViewLive do
              not (socket.assigns.all_contexts |> Enum.map(& &1.id) |> Enum.member?(contract.client_id)) do
           {:ok, raise(AlgoraWeb.NotFoundError)}
         else
+          if connected?(socket) do
+            Chat.subscribe(thread.id)
+          end
+
           {:ok,
            socket
            |> assign(:contract, contract)
@@ -501,6 +505,14 @@ defmodule AlgoraWeb.Contract.ViewLive do
     end
   end
 
+  def handle_info(%Chat.Message{} = message, socket) do
+    if message.id in Enum.map(socket.assigns.messages, & &1.id) do
+      {:noreply, socket}
+    else
+      {:noreply, Phoenix.Component.update(socket, :messages, &(&1 ++ [message]))}
+    end
+  end
+
   def handle_event("send_message", %{"message" => content}, socket) do
     {:ok, message} =
       Chat.send_message(

lib/algora_web/live/org/dashboard_live.ex

@@ -534,7 +534,7 @@ defmodule AlgoraWeb.Org.DashboardLive do
     if message.id in Enum.map(socket.assigns.messages, & &1.id) do
       {:noreply, socket}
     else
-      {:noreply, assign(socket, :messages, socket.assigns.messages ++ [message])}
+      {:noreply, Phoenix.Component.update(socket, :messages, &(&1 ++ [message]))}
     end
   end