refactor: rename boolean functions to follow naming conventions

Author: abc3

lib/sequin/accounts/impersonate.ex

@@ -64,7 +64,7 @@ defmodule Sequin.Accounts.Impersonate do
   end
 
   defp find_user(user_id) do
-    if Sequin.String.is_uuid?(user_id) do
+    if Sequin.String.uuid?(user_id) do
       Accounts.get_user(user_id)
     else
       Accounts.get_user(email: user_id)

lib/sequin/aws/sns.ex

@@ -35,7 +35,7 @@ defmodule Sequin.Aws.SNS do
 
   def publish_messages(%Client{} = client, topic_arn, messages) do
     entries =
-      if is_fifo?(topic_arn) do
+      if fifo?(topic_arn) do
         Enum.map(messages, fn msg ->
           %{
             "Id" => Map.fetch!(msg, :message_id),
@@ -117,7 +117,7 @@ defmodule Sequin.Aws.SNS do
      Error.service(service: :aws_sns, message: "Error from AWS: #{message} (status=#{status_code})", details: message)}
   end
 
-  defp is_fifo?(topic_arn) do
+  defp fifo?(topic_arn) do
     String.ends_with?(topic_arn, ".fifo")
   end
 end

lib/sequin/consumers/function.ex

@@ -82,7 +82,7 @@ defmodule Sequin.Consumers.Function do
   end
 
   def where_id_or_name(query \\ base_query(), id_or_name) do
-    if Sequin.String.is_uuid?(id_or_name) do
+    if Sequin.String.uuid?(id_or_name) do
       where_id(query, id_or_name)
     else
       where_name(query, id_or_name)

lib/sequin/consumers/http_endpoint.ex

@@ -137,7 +137,7 @@ defmodule Sequin.Consumers.HttpEndpoint do
   end
 
   def where_id_or_name(query \\ base_query(), id_or_name) do
-    if Sequin.String.is_uuid?(id_or_name) do
+    if Sequin.String.uuid?(id_or_name) do
       where_id(query, id_or_name)
     else
       where_name(query, id_or_name)

lib/sequin/consumers/sink_consumer.ex

@@ -297,7 +297,7 @@ defmodule Sequin.Consumers.SinkConsumer do
   end
 
   def where_id_or_name(query \\ base_query(), id_or_name) do
-    if Sequin.String.is_uuid?(id_or_name) do
+    if Sequin.String.uuid?(id_or_name) do
       where_id(query, id_or_name)
     else
       where_name(query, id_or_name)

lib/sequin/databases/databases.ex

@@ -439,7 +439,7 @@ defmodule Sequin.Databases do
 
   def test_maybe_replica(%PostgresDatabase{} = db, db_primary) do
     cond do
-      not is_physical_replica?(db) ->
+      not physical_replica?(db) ->
         :ok
 
       is_nil(db_primary) ->
@@ -563,8 +563,8 @@ defmodule Sequin.Databases do
     end
   end
 
-  @spec is_physical_replica?(%PostgresDatabase{}) :: boolean()
-  def is_physical_replica?(%PostgresDatabase{} = db) do
+  @spec physical_replica?(%PostgresDatabase{}) :: boolean()
+  def physical_replica?(%PostgresDatabase{} = db) do
     with_uncached_connection(db, fn conn ->
       query = """
         SELECT pg_is_in_recovery() AS is_physical_replica

lib/sequin/databases/postgres_database.ex

@@ -142,7 +142,7 @@ defmodule Sequin.Databases.PostgresDatabase do
   end
 
   def where_id_or_name(query \\ base_query(), id_or_name) do
-    if Sequin.String.is_uuid?(id_or_name) do
+    if Sequin.String.uuid?(id_or_name) do
       where_id(query, id_or_name)
     else
       where_name(query, id_or_name)

lib/sequin/databases/postgres_database_table.ex

@@ -36,7 +36,7 @@ defmodule Sequin.Databases.PostgresDatabaseTable do
   end
 
   def default_group_column_attnums(%__MODULE__{} = table) do
-    if Postgres.is_event_table?(table) do
+    if Postgres.event_table?(table) do
       Enum.map(["source_database_id", "source_table_oid", "record_pk"], fn col_name ->
         column = Sequin.Enum.find!(table.columns, &(&1.name == col_name))
         column.attnum

lib/sequin/functions/minielixir.ex

@@ -157,7 +157,7 @@ defmodule Sequin.Functions.MiniElixir do
   end
 
   defp ensure_code_is_loaded(id) do
-    unless is_code_loaded(id) do
+    unless code_loaded?(id) do
       __MODULE__
       |> Agent.get_and_update(fn state ->
         try do
@@ -179,7 +179,7 @@ defmodule Sequin.Functions.MiniElixir do
     module_name_from_id(id)
   end
 
-  defp is_code_loaded(id) do
+  defp code_loaded?(id) do
     with {:ok, mod} <- module_name_from_id(id),
          {:file, _} <- :code.is_loaded(mod) do
       true
@@ -189,7 +189,7 @@ defmodule Sequin.Functions.MiniElixir do
   end
 
   defp recreate(id) do
-    with false <- is_code_loaded(id),
+    with false <- code_loaded?(id),
          {:ok, %Function{} = function} <- Consumers.get_function(id) do
       create(function.id, function.function.code)
     end

lib/sequin/postgres/postgres.ex

@@ -42,8 +42,8 @@ defmodule Sequin.Postgres do
   @doc """
   Checks if the given table is an event table by verifying it has all the required columns.
   """
-  @spec is_event_table?(PostgresDatabaseTable.t()) :: boolean()
-  def is_event_table?(%PostgresDatabaseTable{} = table) do
+  @spec event_table?(PostgresDatabaseTable.t()) :: boolean()
+  def event_table?(%PostgresDatabaseTable{} = table) do
     required_column_names = MapSet.new(@event_table_columns, & &1.name)
     table_column_names = MapSet.new(table.columns, & &1.name)
     MapSet.subset?(required_column_names, table_column_names)
@@ -58,7 +58,7 @@ defmodule Sequin.Postgres do
   """
   @spec event_table_version(PostgresDatabaseTable.t()) :: {:ok, :v0 | :"v3.28.25"} | {:error, Error.t()}
   def event_table_version(%PostgresDatabaseTable{} = table) do
-    if is_event_table?(table) do
+    if event_table?(table) do
       has_transaction_annotations = Enum.any?(table.columns, &(&1.name == "transaction_annotations"))
       if has_transaction_annotations, do: {:ok, :"v3.28.25"}, else: {:ok, :v0}
     else
@@ -269,7 +269,7 @@ defmodule Sequin.Postgres do
 
   # Helper function to cast values using Ecto's type system
   def cast_value(value, "uuid") do
-    if Sequin.String.is_uuid?(value) do
+    if Sequin.String.uuid?(value) do
       Sequin.String.string_to_binary!(value)
     else
       value