Decode only binary message data

dashbitco · May 2, 2024 · c1f39a5 · c1f39a5
1 parent 1677741
commit c1f39a5
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/lib/broadway_cloud_pub_sub/pull_client.ex b/lib/broadway_cloud_pub_sub/pull_client.ex
@@ -167,9 +167,7 @@ defmodule BroadwayCloudPubSub.PullClient do
     end
   end
 
-  defp decode_message(%{"data" => nil} = message), do: message
-
-  defp decode_message(%{"data" => encoded_data} = message) do
+  defp decode_message(%{"data" => encoded_data} = message) when is_binary(encoded_data) do
     %{message | "data" => Base.decode64!(encoded_data)}
   end