wip: feat: Subscribe to pubsub in HomeLive

lib/medical_transcription_web/live/home_live/index.ex

@@ -6,6 +6,8 @@ defmodule MedicalTranscriptionWeb.HomeLive.Index do
 
   @impl Phoenix.LiveView
   def mount(_params, session, socket) do
+    if connected?(socket), do: Phoenix.PubSub.subscribe(MedicalTranscription.PubSub, "transcriptions")
+
     # We're storing atoms in `:status` as LiveView's AsyncResult doesn't support modeling a "pending" state, but only
     # loading / ok / failed.
     initial_state = %{
@@ -83,16 +85,9 @@ defmodule MedicalTranscriptionWeb.HomeLive.Index do
         {:ok, dest}
       end)
 
-    uploaded_file = Enum.at(uploaded_files, 0)
-    live_view_pid = self()
-
-    {:ok, _transcription} =
-      Transcriptions.create_transcription(%{
-        user_id: socket.assigns.current_user.id,
-        filename: filename
-      })
-
-    Task.async(fn -> transcribe_and_tag_audio(live_view_pid, uploaded_file) end)
+    uploaded_files
+    |> Enum.at(0)
+    |> transcribe_and_tag_audio()
 
     socket =
       socket
@@ -149,7 +144,7 @@ defmodule MedicalTranscriptionWeb.HomeLive.Index do
   end
 
   @impl true
-  def handle_info({:transcription_row, chunk_result}, socket) do
+  def handle_info({:chunk, chunk_result}, socket) do
     # The processing sends a message as each chunk of text is coded. See here for some background and potential
     # inspiration for this: https://elixirforum.com/t/liveview-asynchronous-task-patterns/44695
 
@@ -213,9 +208,8 @@ defmodule MedicalTranscriptionWeb.HomeLive.Index do
     {:noreply, assign(socket, :status, :success)}
   end
 
-  defp transcribe_and_tag_audio(live_view_pid, audio_file_path) do
+  defp transcribe_and_tag_audio(audio_file_path) do
     MedicalTranscription.Transcription.stream_transcription_and_search(
-      live_view_pid,
       audio_file_path
     )
   end