fix: add an error for get_payload() (#297)

supabase · Feb 2, 2024 · ac02bde · ac02bde
1 parent f3aa905
commit ac02bde
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/VERSION b/VERSION
@@ -1 +1 @@
-1.1.30
+1.1.31
diff --git a/lib/supavisor/protocol/client.ex b/lib/supavisor/protocol/client.ex
@@ -65,7 +65,7 @@ defmodule Supavisor.Protocol.Client do
 
   def decode_pkt(_), do: {:error, :header_mismatch}
 
-  @spec get_payload(binary) :: {:ok, String.t()} | {:error, any}
+  @spec get_payload(binary | any()) :: {:ok, String.t()} | {:error, any}
   def get_payload(<<char::8, pkt_len::32, rest::binary>>) do
     case tag(char) do
       nil ->
@@ -84,6 +84,8 @@ defmodule Supavisor.Protocol.Client do
     end
   end
 
+  def get_payload(msg), do: {:error, {:invalid_msg, msg}}
+
   @spec tag(byte) :: atom | nil
   def tag(char) do
     case char do