chore: Remove unused logic from HomeLive

lib/medical_transcription_web/live/home_live/index.ex

@@ -1,30 +1,13 @@
 defmodule MedicalTranscriptionWeb.HomeLive.Index do
   use MedicalTranscriptionWeb, :live_view
 
-  alias MedicalTranscription.Audio.RecordingPipeline
   alias MedicalTranscription.Transcriptions
 
   @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 = %{
-      current_recording_id: 0,
-      uploaded_file_name: nil,
-      status: :pending,
-      audio_pipeline: nil,
-      summary_keywords: [],
-      transcriptions: list_transcriptions(session["current_user"]),
-      finalized_codes: []
-    }
-
     socket =
       socket
-      |> assign(initial_state)
-      |> stream_configure(:transcription_rows, dom_id: &"transcription-row-#{&1.id}")
-      |> stream(:transcription_rows, [])
+      |> assign(:transcriptions, list_transcriptions(session["current_user"]))
       |> allow_upload(:audio, accept: ~w(.mp3), max_entries: 1)
 
     {:ok, socket}
@@ -42,23 +25,11 @@ defmodule MedicalTranscriptionWeb.HomeLive.Index do
       <main class="flex-1 pl-16 pr-16 pt-[25px]">
         <div class="flex flex-col h-full mx-auto max-w-5xl">
           <div class="flex-1 flex flex-col space-y-6">
-            <%= if @status != :pending do %>
-              <.live_component
-                module={MedicalTranscriptionWeb.Components.ResultListComponent}
-                id="result_list"
-                rows={@streams.transcription_rows}
-                summary_keywords={@summary_keywords}
-                finalized_codes={@finalized_codes}
-              />
-            <% end %>
-
-            <%= if @status == :pending do %>
-              <div class="flex-1 flex flex-col justify-center items-center gap-4">
-                <img src={~p"/images/logo.svg"} width="106" />
-                <p class="text-2xl leading-normal font-semibold">Medical Code Transcriber</p>
-              </div>
-              <.upload_form audio_upload={@uploads.audio} />
-            <% end %>
+            <div class="flex-1 flex flex-col justify-center items-center gap-4">
+              <img src={~p"/images/logo.svg"} width="106" />
+              <p class="text-2xl leading-normal font-semibold">Medical Code Transcriber</p>
+            </div>
+            <.upload_form audio_upload={@uploads.audio} />
           </div>
         </div>
       </main>
@@ -85,132 +56,15 @@ defmodule MedicalTranscriptionWeb.HomeLive.Index do
         {:ok, dest}
       end)
 
-    {:ok, transcription} = Transcriptions.create_transcription(%{
-      user_id: socket.assigns.current_user.id,
-      filename: Enum.at(uploaded_files, 0)
-    })
+    {:ok, transcription} =
+      Transcriptions.create_transcription(%{
+        user_id: socket.assigns.current_user.id,
+        filename: Enum.at(uploaded_files, 0)
+      })
 
     Transcriptions.transcribe_audio(transcription)
 
     {:noreply, push_navigate(socket, to: ~p"/transcriptions/#{transcription.id}")}
-    #
-    # socket =
-    #   socket
-    #   |> assign(:status, :loading)
-    #   |> assign(:summary_keywords, [])
-    #   |> assign(:transcription_rows, [])
-    #   |> assign(:uploaded_file_name, filename)
-    #   |> assign(:transcriptions, list_transcriptions(socket.assigns.current_user))
-    #
-    # {:noreply, socket}
-  end
-
-  @impl true
-  def handle_event("add_feedback", params, socket) do
-    text_vector = MedicalTranscription.Coding.compute_vector_as_list(params["text"])
-
-    result =
-      params
-      |> Map.put("text_vector", text_vector)
-      |> MedicalTranscription.Feedback.track_response()
-
-    socket =
-      case result do
-        {:ok, message} -> put_flash(socket, :info, message)
-        {:error, messages} -> put_flash(socket, :error, messages)
-      end
-
-    {:noreply, socket}
-  end
-
-  @impl true
-  def handle_event("reset_to_pending", _params, socket) do
-    {:noreply, assign(socket, :status, :pending)}
-  end
-
-  @impl true
-  def handle_event("toggle_recording", _params, socket) do
-    socket =
-      if is_nil(socket.assigns.audio_pipeline) do
-        pipeline = RecordingPipeline.start_pipeline(self())
-
-        socket
-        |> assign(:status, :streaming_audio)
-        |> assign(:audio_pipeline, pipeline)
-      else
-        RecordingPipeline.stop_pipeline(socket.assigns.audio_pipeline)
-
-        socket
-        |> assign(:status, :success)
-        |> assign(:audio_pipeline, nil)
-      end
-
-    {:noreply, socket}
-  end
-
-  @impl true
-  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
-
-    {:noreply, stream_insert(socket, :transcription_rows, chunk_result)}
-  end
-
-  @impl true
-  def handle_info({:new_keywords, new_keywords}, socket) do
-    socket =
-      update(socket, :summary_keywords, fn keywords -> keywords ++ [new_keywords] end)
-
-    {:noreply, socket}
-  end
-
-  @impl true
-  def handle_info({:received_audio_payload, transcribed_text}, socket) do
-    tags = MedicalTranscription.Coding.process_chunk(transcribed_text)
-
-    result = %{
-      id: socket.assigns.current_recording_id + 1,
-      start_mark: nil,
-      end_mark: nil,
-      text: transcribed_text,
-      tags: tags
-    }
-
-    socket =
-      socket
-      |> assign(:status, :streaming_audio)
-      |> stream_insert(:transcription_rows, result)
-      |> assign(:current_recording_id, result.id)
-
-    {:noreply, socket}
-  end
-
-  @impl Phoenix.LiveView
-  def handle_info({"toggle_user_selected_code", {:add, code}}, socket) do
-    new_codes =
-      if Enum.any?(socket.assigns.finalized_codes, code) do
-        socket.assigns.finalized_codes
-      else
-        socket.assigns.finalized_codes ++ [code]
-      end
-
-    {:noreply, assign(socket, :finalized_codes, new_codes)}
-  end
-
-  @impl Phoenix.LiveView
-  def handle_info({"toggle_user_selected_code", {:remove, code}}, socket) do
-    new_codes = Enum.reject(socket.assigns.finalized_codes, &(&1 == code))
-
-    {:noreply, assign(socket, :finalized_codes, new_codes)}
-  end
-
-  @impl true
-  def handle_info({ref, _result}, socket) do
-    # See this Fly article for the usage of Task.async to start `transcribe_and_tag_audio/2` and handle the end of the
-    # task here: https://fly.io/phoenix-files/liveview-async-task/
-    Process.demonitor(ref, [:flush])
-
-    {:noreply, assign(socket, :status, :success)}
   end
 
   def error_to_string(:too_large), do: "Too large"