Merge pull request #321 from alexweav/query-files

Query files by term

apps/services/lib/services/audio/downloader.ex

@@ -21,6 +21,18 @@ defmodule Services.Audio.Downloader do
     end
   end
 
+  @doc """
+  Queries files by name.
+  """
+  def query_files(term) do
+    uri = "/files?name=" <> URI.encode(term)
+
+    case Downloader.get(uri) do
+      {:ok, %Response{status_code: 200, body: body}} -> {:ok, body}
+      response -> {:error, response}
+    end
+  end
+
   @doc """
   Gets the metadata for a file managed the downloader, by path.
   """

apps/services/lib/services/voice.ex

@@ -30,7 +30,9 @@ defmodule Services.Voice do
 
   def handle_message("!play " <> audio_file_to_play, message, _) do
     with :ok <- Downloader.available?(),
-         {:ok, file_metadata} <- Downloader.get_file(audio_file_to_play),
+         {:ok, file_response} <- Downloader.query_files(audio_file_to_play),
+         # Downloader.get_file(audio_file_to_play),
+         {:ok, file_metadata} <- get_file_by_term(file_response),
          {:ok, audio_file} <- Briefly.create(),
          :ok <- Downloader.download_file(file_metadata["path"], audio_file) do
       transcode_and_send(audio_file, message)
@@ -85,6 +87,14 @@ defmodule Services.Voice do
     end
   end
 
+  defp get_file_by_term(%{"files" => []}) do
+    {:error, :notfound}
+  end
+
+  defp get_file_by_term(resp) do
+    {:ok, Enum.at(resp["files"], 0)}
+  end
+
   defp send_silence_sigil(connection) do
     _ =
       Enum.reduce(1..5, {nil, connection}, fn _, {last_time, conn} ->