feat: Replace callback payloads with chunks

lib/medical_transcription/transcriptions/transcription_chunk.ex

@@ -6,6 +6,8 @@ defmodule MedicalTranscription.Transcriptions.TranscriptionChunk do
   @foreign_key_type :binary_id
   schema "transcription_chunks" do
     field :text, :string
+    field :start_mark, :string
+    field :end_mark, :string
 
     belongs_to :transcription, MedicalTranscription.Transcriptions.Transcription
 
@@ -15,7 +17,7 @@ defmodule MedicalTranscription.Transcriptions.TranscriptionChunk do
   @doc false
   def changeset(transcription_chunk, attrs) do
     transcription_chunk
-    |> cast(attrs, [:transcription_id, :text])
-    |> validate_required([:transcription_id, :text])
+    |> cast(attrs, [:transcription_id, :text, :start_mark, :end_mark])
+    |> validate_required([:transcription_id, :text, :start_mark, :end_mark])
   end
 end

lib/medical_transcription_web/components/transcription_text_component.ex

@@ -40,7 +40,7 @@ defmodule MedicalTranscriptionWeb.Components.TranscriptionTextComponent do
   def render(assigns) do
     # TODO: Adjust the blue border when editing
     ~H"""
-    <div class="flex gap-12 pb-10 border-b border-[#444444]/20">
+    <div id={@id} class="flex gap-12 pb-10 border-b border-[#444444]/20">
       <div class="flex-1 flex flex-col gap-4">
         <p class="px-2 text-[32px] leading-normal font-semibold">
           <%= if !is_nil(@start_mark) && !is_nil(@end_mark) do %>

lib/medical_transcription_web/live/home_live/sample_results.ex

@@ -6,9 +6,9 @@ defmodule MedicalTranscriptionWeb.HomeLive.Index.SampleResults do
 
       status: :success
 
-  And the `transcription_rows` stream with:
+  And the `chunks` stream with:
 
-      |> stream(:transcription_rows, MedicalTranscriptionWeb.HomeLive.Index.SampleResults.get_sample_results())
+      |> stream(:chunks, MedicalTranscriptionWeb.HomeLive.Index.SampleResults.get_sample_results())
   """
 
   alias AudioTagger.Structs.TagResult

lib/medical_transcription_web/live/transcriptions_live/show.ex

@@ -2,7 +2,10 @@ defmodule MedicalTranscriptionWeb.TranscriptionsLive.Show do
   use MedicalTranscriptionWeb, :live_view
 
   alias MedicalTranscription.Audio.RecordingPipeline
+  alias MedicalTranscription.Repo
   alias MedicalTranscription.Transcriptions
+  alias MedicalTranscription.Transcriptions.TranscriptionChunk
+
   alias MedicalTranscriptionWeb.Components.TranscriptionTextComponent
 
   @impl Phoenix.LiveView
@@ -30,8 +33,8 @@ defmodule MedicalTranscriptionWeb.TranscriptionsLive.Show do
     socket =
       socket
       |> assign(initial_state)
-      |> stream_configure(:transcription_rows, dom_id: &"transcription-row-#{&1.id}")
-      |> stream(:transcription_rows, [])
+      |> stream_configure(:chunks, dom_id: &"transcription-chunk-#{&1.id}")
+      |> stream(:chunks, transcription.chunks)
 
     {:ok, socket}
   end
@@ -54,12 +57,12 @@ defmodule MedicalTranscriptionWeb.TranscriptionsLive.Show do
 
           <div id="result_list" class="flex flex flex-col gap-14" phx-update="stream">
             <.live_component
-              :for={{dom_id, row} <- @streams.transcription_rows}
+              :for={{dom_id, chunk} <- @streams.chunks}
               module={TranscriptionTextComponent}
               id={dom_id}
-              start_mark={row.start_mark}
-              end_mark={row.end_mark}
-              text={row.text}
+              start_mark={chunk.start_mark}
+              end_mark={chunk.end_mark}
+              text={chunk.text}
               finalized_codes={@finalized_codes}
             />
           </div>
@@ -87,7 +90,6 @@ defmodule MedicalTranscriptionWeb.TranscriptionsLive.Show do
     {:noreply, socket}
   end
 
-  @impl true
   def handle_event("reset_to_pending", _params, socket) do
     {:noreply, assign(socket, :status, :pending)}
   end
@@ -112,11 +114,10 @@ defmodule MedicalTranscriptionWeb.TranscriptionsLive.Show do
   end
 
   @impl true
-  def handle_info({:transcription_updated, chunk_result}, socket) do
+  def handle_info({:transcription_updated, chunk}, 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)}
+    {:noreply, stream_insert(socket, :chunks, chunk)}
   end
 
   def handle_info({:transcription_started, _transcription}, socket) do
@@ -148,7 +149,7 @@ defmodule MedicalTranscriptionWeb.TranscriptionsLive.Show do
     socket =
       socket
       |> assign(:status, :streaming_audio)
-      |> stream_insert(:transcription_rows, result)
+      |> stream_insert(:chunks, result)
       |> assign(:current_recording_id, result.id)
 
     {:noreply, socket}
@@ -179,6 +180,11 @@ defmodule MedicalTranscriptionWeb.TranscriptionsLive.Show do
     {:noreply, assign(socket, :status, :success)}
   end
 
-  defp get_transcription(id), do: Transcriptions.get_transcription(id)
+  defp get_transcription(id) do
+    id
+    |> Transcriptions.get_transcription()
+    |> Repo.preload(:chunks)
+  end
+
   defp list_transcriptions(user), do: Transcriptions.list_transcriptions(user)
 end

test/medical_transcription_web/live/transcriptions_live_show_test.exs

@@ -2,12 +2,16 @@ defmodule MedicalTranscriptionWeb.TranscriptionsLive.ShowTest do
   use MedicalTranscriptionWeb.ConnCase, async: true
 
   import Phoenix.LiveViewTest
-  import MedicalTranscription.{AccountsFixtures, TranscriptionsFixtures}
+  import MedicalTranscription.{AccountsFixtures, TranscriptionsFixtures, TranscriptionChunksFixtures}
 
   setup %{conn: conn} do
     password = valid_user_password()
     user = user_fixture(%{password: password})
     transcription = transcription_fixture(%{filename: "my-audio.mp3"})
+
+    transcription_chunk_fixture(%{transcription_id: transcription.id, text: "Foo"})
+    transcription_chunk_fixture(%{transcription_id: transcription.id, text: "Bar"})
+
     %{conn: log_in_user(conn, user), current_user: user, transcription: transcription}
   end
 
@@ -18,8 +22,8 @@ defmodule MedicalTranscriptionWeb.TranscriptionsLive.ShowTest do
 
       {:ok, view, html} = live(conn)
       assert html =~ "my-audio.mp3"
-
-      assert_redirected view, ~p"/transcriptions/#{transcription.id}"
+      assert html =~ "Foo"
+      assert html =~ "Bar"
     end
 
     test "renders 'Not Found' for 404", %{conn: conn} do

test/support/fixtures/transcription_chunks_fixtures.ex

@@ -0,0 +1,32 @@
+defmodule MedicalTranscription.TranscriptionChunksFixtures do
+  @moduledoc """
+  This module defines test helpers for creating %TranscriptionChunk{}
+  entities via the `MedicalTranscription.Transcriptions` context.
+  """
+
+  import MedicalTranscription.TranscriptionsFixtures
+
+  @doc """
+  Generate a transcription chunk.
+  """
+  def transcription_chunk_fixture(attrs \\ %{}) do
+    transcription_id =
+      cond do
+        Map.has_key?(attrs, :transcription_id) -> attrs.transcription_id
+        Map.has_key?(attrs, :transcription) -> attrs.transcription
+        true -> transcription_fixture().id
+      end
+
+    {:ok, transcription_chunk} =
+      attrs
+      |> Enum.into(%{
+        transcription_id: transcription_id,
+        filename: "My transcription text",
+        start_mark: "00:00:00",
+        end_mark: "00:00:07"
+      })
+      |> MedicalTranscription.Transcriptions.create_chunk()
+
+    transcription_chunk
+  end
+end