refactor: Move code search into TranscriptionTextComponent

lib/medical_transcription/transcription.ex

@@ -1,18 +1,8 @@
 defmodule MedicalTranscription.Transcription do
   @moduledoc """
-  Takes a path to an audio file and transcribes it to text. As each chunk is available, it passes it to the `Coding`
-  context to look for possible matching codes.
+  Takes a path to an audio file and transcribes it to text.
   """
 
-  alias MedicalTranscription.Coding
-
-  defp get_tags_and_send_result(chunk, index, live_view_pid) do
-    tags = Coding.process_chunk(chunk.text)
-    result = build_result(index, chunk, tags)
-
-    send(live_view_pid, {:transcription_row, result})
-  end
-
   # Ideas for future exploration:
   # - Instead of storing the long description vectors in a binary file on disk, we could store them within a vector DB
   #   (such as pgvector or Pinecone.io)
@@ -25,7 +15,7 @@ defmodule MedicalTranscription.Transcription do
       audio_file_path
       |> stream_transcription()
       |> Enum.reduce("", fn {chunk, index}, acc ->
-        get_tags_and_send_result(chunk, index + 1, live_view_pid)
+        send_result(chunk, index + 1, live_view_pid)
 
         acc <> chunk.text
       end)
@@ -36,7 +26,7 @@ defmodule MedicalTranscription.Transcription do
       end_timestamp_seconds: nil
     }
 
-    get_tags_and_send_result(summary_chunk, 0, live_view_pid)
+    send_result(summary_chunk, 0, live_view_pid)
   end
 
   defp stream_transcription(audio_file_path) do
@@ -45,14 +35,15 @@ defmodule MedicalTranscription.Transcription do
     |> Stream.with_index()
   end
 
-  defp build_result(index, chunk, tags) do
-    %{
+  defp send_result(chunk, index, live_view_pid) do
+    result = %{
       id: index,
       start_mark: format_timestamp(chunk.start_timestamp_seconds),
       end_mark: format_timestamp(chunk.end_timestamp_seconds),
-      text: chunk.text,
-      tags: tags
+      text: chunk.text
     }
+
+    send(live_view_pid, {:transcription_row, result})
   end
 
   defp format_timestamp(seconds) when is_nil(seconds), do: nil

lib/medical_transcription_web/components/components.ex

@@ -149,7 +149,6 @@ defmodule MedicalTranscriptionWeb.Components do
           start_mark={row.start_mark}
           end_mark={row.end_mark}
           text={row.text}
-          tags={%Phoenix.LiveView.AsyncResult{ok?: true, result: row.tags}}
         />
       <% end %>
     </div>

lib/medical_transcription_web/components/transcription_text_component.ex

@@ -1,13 +1,16 @@
 defmodule MedicalTranscriptionWeb.Components.TranscriptionTextComponent do
   @moduledoc """
-  Represents a portion of transcribed text and its codes and starts a task to determine keywords within the text.
-  """
+  Represents a portion of transcribed text.
 
-  alias MedicalTranscription.Coding
+  Once rendered, starts tasks to find relevant codes and keywords for the text.
+  """
   use MedicalTranscriptionWeb, :live_component
+
   import MedicalTranscriptionWeb.Components
   import MedicalTranscriptionWeb.Components.KeywordHighlighter
+
   alias AudioTagger.KeywordFinder
+  alias MedicalTranscription.Coding
   alias MedicalTranscription.Coding.CodeVectorMatch
 
   @impl Phoenix.LiveComponent
@@ -17,22 +20,19 @@ defmodule MedicalTranscriptionWeb.Components.TranscriptionTextComponent do
     {:ok, socket}
   end
 
-  defp assign_initial_state(
-         %{start_mark: start_mark, end_mark: end_mark, text: text, tags: tags},
-         socket
-       ) do
+  defp assign_initial_state(%{start_mark: start_mark, end_mark: end_mark, text: text}, socket) do
     self_pid = self()
 
     initial_state = %{
       start_mark: start_mark,
       end_mark: end_mark,
       text: text,
-      tags: tags,
       editing: false
     }
 
     socket
     |> assign(initial_state)
+    |> assign_async(:tags, fn -> classify_text(text) end)
     |> assign_async(:keywords, fn -> find_keywords(self_pid, text) end)
   end