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