change id to be of uuid type

lib/realtime/api/message.ex

@@ -5,7 +5,9 @@ defmodule Realtime.Api.Message do
   use Ecto.Schema
   import Ecto.Changeset
 
+  @primary_key {:id, Ecto.UUID, autogenerate: true}
   @schema_prefix "realtime"
+
   schema "messages" do
     field :topic, :string
     field :extension, Ecto.Enum, values: [:broadcast, :presence]

lib/realtime/tenants/migrations.ex

@@ -60,7 +60,8 @@ defmodule Realtime.Tenants.Migrations do
     UnloggedMessagesTable,
     LoggedMessagesTable,
     FilterDeletePostgresChanges,
-    AddPayloadToMessages
+    AddPayloadToMessages,
+    ChangeMessagesIdType
   }
 
   @migrations [
@@ -111,7 +112,8 @@ defmodule Realtime.Tenants.Migrations do
     {20_240_801_235_015, UnloggedMessagesTable},
     {20_240_805_133_720, LoggedMessagesTable},
     {20_240_827_160_934, FilterDeletePostgresChanges},
-    {20_240_917_170_412, AddPayloadToMessages}
+    {20_240_919_163_303, AddPayloadToMessages},
+    {20_240_919_163_305, ChangeMessagesIdType}
   ]
   defstruct [:tenant_external_id, :settings]
   @spec run_migrations(map()) :: :ok | {:error, any()}

lib/realtime/tenants/repo/migrations/20240917170412_add_payload_to_messages.ex → lib/realtime/tenants/repo/migrations/20240919163303_add_payload_to_messages copy.ex

@@ -8,6 +8,7 @@ defmodule Realtime.Tenants.Migrations.AddPayloadToMessages do
       add_if_not_exists :event, :text
       add_if_not_exists :topic, :text
       add_if_not_exists :private, :boolean, default: true
+
       modify :inserted_at, :utc_datetime, default: fragment("now()")
       modify :updated_at, :utc_datetime, default: fragment("now()")
     end
@@ -25,7 +26,7 @@ defmodule Realtime.Tenants.Migrations.AddPayloadToMessages do
     """
 
     execute """
-    CREATE OR REPLACE FUNCTION realtime.broadcast_changes (topic_name text, event_name text, operation text, table_name text, table_schema text, NEW record, OLD record, level string DEFAULT 'ROW')
+    CREATE OR REPLACE FUNCTION realtime.broadcast_changes (topic_name text, event_name text, operation text, table_name text, table_schema text, NEW record, OLD record, level text DEFAULT 'ROW')
         RETURNS void
         AS $$
     DECLARE

lib/realtime/tenants/repo/migrations/20240919163305_change_messages_id_type.ex

@@ -0,0 +1,16 @@
+defmodule Realtime.Tenants.Migrations.ChangeMessagesIdType do
+  @moduledoc false
+  use Ecto.Migration
+
+  def change do
+    alter table(:messages) do
+      add_if_not_exists :uuid, :binary_id,
+        primary_key: true,
+        default: fragment("gen_random_uuid()")
+
+      remove_if_exists :id, :id
+    end
+
+    rename table(:messages), :uuid, to: :id
+  end
+end

test/support/generators.ex

@@ -88,12 +88,6 @@ defmodule Generators do
       end)
 
       Postgrex.query!(transaction_conn, "TRUNCATE TABLE #{schema}.#{table} CASCADE", [])
-
-      Postgrex.query!(
-        transaction_conn,
-        "ALTER SEQUENCE #{schema}.#{table}_id_seq RESTART WITH 1",
-        []
-      )
     end)
   end