feat: Broadcast when transcriptions are created

lib/medical_transcription_web/live/home_live/index.ex

@@ -5,6 +5,10 @@ defmodule MedicalTranscriptionWeb.HomeLive.Index do
 
   @impl Phoenix.LiveView
   def mount(_params, session, socket) do
+    if connected?(socket) do
+      Phoenix.PubSub.subscribe(:medicode_pubsub, "medicode:#{session["current_user"].id}")
+    end
+
     socket =
       socket
       |> assign(:transcriptions, list_transcriptions(session["current_user"]))
@@ -42,7 +46,6 @@ defmodule MedicalTranscriptionWeb.HomeLive.Index do
     {:noreply, socket}
   end
 
-  @impl true
   def handle_event("save", _params, socket) do
     _filename =
       socket.assigns.uploads.audio.entries
@@ -62,11 +65,27 @@ defmodule MedicalTranscriptionWeb.HomeLive.Index do
         filename: Enum.at(uploaded_files, 0)
       })
 
+    Phoenix.PubSub.broadcast(
+      :medicode_pubsub,
+      "medicode:#{socket.assigns.current_user.id}",
+      {:transcription_created, transcription.id}
+    )
+
     Transcriptions.transcribe_audio(transcription)
 
     {:noreply, push_navigate(socket, to: ~p"/transcriptions/#{transcription.id}")}
   end
 
+  def handle_info({:transcription_created, transcription_id}, socket) do
+    transcriptions = list_transcriptions(socket.assigns.current_user)
+
+    socket =
+      socket
+      |> assign(:transcriptions, transcriptions)
+
+    {:noreply, socket}
+  end
+
   def error_to_string(:too_large), do: "Too large"
   def error_to_string(:not_accepted), do: "You have selected an unacceptable file type"
 

lib/medical_transcription_web/live/transcriptions_live/show.ex

@@ -12,8 +12,10 @@ defmodule MedicalTranscriptionWeb.TranscriptionsLive.Show do
 
     if is_nil(transcription), do: raise(MedicalTranscription.Fallback)
 
-    if connected?(socket),
-      do: Phoenix.PubSub.subscribe(:medicode_pubsub, "transcriptions:#{transcription.id}")
+    if connected?(socket) do
+      Phoenix.PubSub.subscribe(:medicode_pubsub, "medicode:#{session["current_user"].id}")
+      Phoenix.PubSub.subscribe(:medicode_pubsub, "transcriptions:#{transcription.id}")
+    end
 
     transcription_chunk_ids = Enum.map(transcription.chunks, &%{id: &1.id})
 
@@ -108,6 +110,16 @@ defmodule MedicalTranscriptionWeb.TranscriptionsLive.Show do
   end
 
   @impl true
+  def handle_info({:transcription_created, transcription_id}, socket) do
+    transcriptions = list_transcriptions(socket.assigns.current_user)
+
+    socket =
+      socket
+      |> assign(:transcriptions, transcriptions)
+
+    {:noreply, socket}
+  end
+
   def handle_info({:transcription_updated, %{id: chunk_id}}, socket) do
     transcription = get_transcription(socket.assigns.transcription.id)