Added support for audio URLs for PA Messages

- Modified the `to_tts` to have an alternate type containing :url and
  value
- In migrated SCUs, we now account for the new audio_url field and we
  download the file to pass through in cases where we have it

Author: deanshi

lib/content/audio.ex

@@ -16,7 +16,8 @@ defprotocol Content.Audio do
   @type language :: :english | :spanish
   @type value :: canned_message() | ad_hoc_message() | nil
   @type tts_value ::
-          {audio :: String.t() | {:spanish, String.t()}, visual :: Content.Message.pages() | nil}
+          {audio :: String.t() | {:spanish, String.t()} | {:url, String.t()},
+           visual :: Content.Message.pages() | nil}
 
   @doc "Converts an audio struct to the mid/vars params for the PA system"
   @spec to_params(Content.Audio.t()) :: value()

lib/engine/pa_messages.ex

@@ -107,6 +107,7 @@ defmodule Engine.PaMessages do
               "id" => pa_id,
               "visual_text" => visual_text,
               "audio_text" => audio_text,
+              "audio_url" => audio_url,
               "interval_in_minutes" => interval_in_minutes,
               "priority" => priority,
               "sign_ids" => sign_ids
@@ -115,6 +116,7 @@ defmodule Engine.PaMessages do
             id: pa_id,
             visual_text: visual_text,
             audio_text: audio_text,
+            audio_url: audio_url,
             priority: priority,
             sign_ids: sign_ids,
             interval_in_ms: interval_in_minutes * @minute_in_ms

lib/fake/httpoison.ex

@@ -135,6 +135,7 @@ defmodule Fake.HTTPoison do
         "alert_id" => nil,
         "audio_text" =>
           "This is an example of a PA message that will be played at an MBTA station",
+        "audio_url" => nil,
         "days_of_week" => [1, 2, 3, 4, 5, 6, 7],
         "end_time" => "2033-12-05T23:53:23Z",
         "id" => 4,
@@ -153,6 +154,7 @@ defmodule Fake.HTTPoison do
       %{
         "alert_id" => nil,
         "audio_text" => "This is another PA message that will play at MBTA stations",
+        "audio_url" => nil,
         "days_of_week" => [1, 2, 3, 4, 5, 6, 7],
         "end_time" => "2027-08-05T05:41:10Z",
         "id" => 5,
@@ -177,6 +179,7 @@ defmodule Fake.HTTPoison do
       %{
         "alert_id" => nil,
         "audio_text" => "This is another PA message that will play at MBTA stations",
+        "audio_url" => nil,
         "days_of_week" => [1, 2, 3, 4, 5, 6, 7],
         "end_time" => "2027-08-05T05:41:10Z",
         "id" => 5,
@@ -202,6 +205,7 @@ defmodule Fake.HTTPoison do
         "alert_id" => nil,
         "audio_text" =>
           "This is an example of a PA message that will be played at an MBTA station",
+        "audio_url" => nil,
         "days_of_week" => [1, 2, 3, 4, 5, 6, 7],
         "end_time" => "2033-12-05T23:53:23Z",
         "id" => 4,
@@ -220,6 +224,7 @@ defmodule Fake.HTTPoison do
       %{
         "alert_id" => nil,
         "audio_text" => "This is another PA message that will play at MBTA stations",
+        "audio_url" => nil,
         "days_of_week" => [1, 2, 3, 4, 5, 6, 7],
         "end_time" => "2027-08-05T05:41:10Z",
         "id" => 5,

lib/pa_ess/updater.ex

@@ -77,27 +77,31 @@ defmodule PaEss.Updater do
 
     log_metas =
       Enum.zip([tts_audios, tags, log_metas])
-      |> Enum.map(fn {{text, pages}, tag, log_meta} ->
-        [
-          sign_id: id,
-          audio:
-            case text do
-              {:spanish, text} -> text
-              text -> text
-            end
-            |> inspect(),
-          visual: format_pages(pages) |> Jason.encode!(),
-          tag: inspect(tag),
-          legacy: !scu_migrated?
-        ] ++
+      |> Enum.map(fn {{tts_audio, pages}, tag, log_meta} ->
+        case tts_audio do
+          {:url, url} ->
+            [audio_url: url]
+
+          {:spanish, text} ->
+            [audio: text]
+
+          text ->
+            [audio: text]
+        end ++
+          [
+            sign_id: id,
+            tag: inspect(tag),
+            legacy: !scu_migrated?,
+            visual: format_pages(pages) |> Jason.encode!()
+          ] ++
           log_meta
       end)
 
     if scu_migrated? do
       Task.Supervisor.start_child(PaEss.TaskSupervisor, fn ->
         files =
-          Enum.map(tts_audios, fn {text, _} ->
-            Task.async(fn -> fetch_tts(text) end)
+          Enum.map(tts_audios, fn {tts_audio, _} ->
+            Task.async(fn -> fetch_audio_file(tts_audio) end)
           end)
           |> Task.await_many()
 
@@ -158,7 +162,16 @@ defmodule PaEss.Updater do
     }
   end
 
-  defp fetch_tts(text) do
+  defp fetch_audio_file({:url, url}) do
+    http_client = Application.get_env(:realtime_signs, :http_client)
+
+    case http_client.get(url) do
+      {:ok, %HTTPoison.Response{status_code: status, body: body}} when status == 200 ->
+        body
+    end
+  end
+
+  defp fetch_audio_file(text) do
     http_poster = Application.get_env(:realtime_signs, :http_poster_mod)
     watts_url = Application.get_env(:realtime_signs, :watts_url)
     watts_api_key = Application.get_env(:realtime_signs, :watts_api_key)

lib/pa_messages/pa_message.ex

@@ -2,6 +2,7 @@ defmodule PaMessages.PaMessage do
   defstruct id: nil,
             visual_text: nil,
             audio_text: nil,
+            audio_url: nil,
             priority: nil,
             sign_ids: [],
             interval_in_ms: nil
@@ -10,16 +11,28 @@ defmodule PaMessages.PaMessage do
           id: integer(),
           visual_text: String.t(),
           audio_text: String.t(),
+          audio_url: String.t(),
           priority: integer(),
           sign_ids: [String.t()],
           interval_in_ms: non_neg_integer()
         }
 
   defimpl Content.Audio do
+    def to_params(%PaMessages.PaMessage{audio_url: audio_url}) when not is_nil(audio_url) do
+      nil
+    end
+
     def to_params(%PaMessages.PaMessage{visual_text: visual_text}) do
       {:ad_hoc, {visual_text, :audio_visual}}
     end
 
+    def to_tts(
+          %PaMessages.PaMessage{visual_text: visual_text, audio_url: audio_url},
+          max_text_length
+        ) do
+      {{:url, audio_url}, PaEss.Utilities.paginate_text(visual_text, max_text_length)}
+    end
+
     def to_tts(
           %PaMessages.PaMessage{visual_text: visual_text, audio_text: audio_text},
           max_text_length