membrane_rtc_engine_timescaledb

defmodule Membrane.RTC.Engine.TimescaleDB.Migrations.V01 do
  @moduledoc false

  @behaviour Membrane.RTC.Engine.TimescaleDB.Migration

  use Ecto.Migration

  @impl true
  def up() do
    create table(:peers_metrics) do
      add :peer_id, :string, null: false
      add :room_id, :string, null: false
      add :"ice.binding_requests_received", :integer
      add :"ice.binding_responses_sent", :integer
      add :"ice.bytes_received", :integer
      add :"ice.bytes_sent", :integer
      add :"ice.packets_received", :integer
      add :"ice.packets_sent", :integer

      timestamps type: :utc_datetime_usec, updated_at: false
    end

    create index(:peers_metrics, [:inserted_at])
    create index(:peers_metrics, [:peer_id])
    create index(:peers_metrics, [:inserted_at, :peer_id])

    flush()

    create table(:tracks_metrics) do
      add :track_id, :string, null: false

      add :peer_metrics_id,
          references(:peers_metrics, on_delete: :delete_all, on_update: :update_all)

      add :peer_id, :string
      add :"inbound-rtp.encoding", :string
      add :"inbound-rtp.ssrc", :string
      add :"inbound-rtp.bytes_received", :integer
      add :"inbound-rtp.keyframe_request_sent", :integer
      add :"inbound-rtp.packets", :integer
      add :"inbound-rtp.frames", :integer
      add :"inbound-rtp.keyframes", :integer

      timestamps type: :utc_datetime_usec, updated_at: false
    end

    create index(:tracks_metrics, [:inserted_at])
    create index(:tracks_metrics, [:track_id])
    create index(:tracks_metrics, [:inserted_at, :track_id])

    :ok
  end

  @impl true
  def down() do
    drop index(:tracks_metrics, [:inserted_at])
    drop index(:tracks_metrics, [:track_id])
    drop index(:tracks_metrics, [:inserted_at, :track_id])
    drop table(:tracks_metrics)

    drop index(:peers_metrics, [:inserted_at])
    drop index(:peers_metrics, [:peer_id])
    drop index(:peers_metrics, [:inserted_at, :peer_id])
    drop table(:peers_metrics)
    :ok
  end
end