Current section
Files
Jump to
Current section
Files
priv/replica/migrations/20240129122556_change_status_subscribe.exs
defmodule PresenceEx.Repo.Replica.Migrations.ChangeStatusSubscribe do
use Ecto.Migration
alias PresenceEx.Repo
alias PresenceEx.Utils
def change do
for i <- Utils.all_schema_ids() do
prefix = "public_#{i}"
drop_if_exists table(:status_subscribe, prefix: prefix)
create table(:status_subscribe, prefix: prefix) do
add :subscriber_token, :string, null: false, primary_key: true
add :subscriber_resource, :string, null: false, primary_key: true
add :subscribed_token, :string, null: false, primary_key: true
add :timestamp, :string, null: false
end
create unique_index(:status_subscribe, [:subscriber_token, :subscriber_resource, :subscribed_token], prefix: prefix)
flush()
end
end
end