feat: add real-time message subscription and handling in contract view

Author: zcesur

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(