defmodule MuxWrapper.EmbeddedSchema.LiveStream do
  @moduledoc false

  use Ecto.Schema

  import Ecto.Changeset

  alias MuxWrapper.EmbeddedSchema.Playback
  alias MuxWrapper.Type.UnixEpoch

  @primary_key false
  embedded_schema do
    field(:id, :string)
    field(:new_asset_settings, :map)
    embeds_many(:playback_ids, Playback, on_replace: :delete)
    field(:reconnect_window, :integer)
    field(:status, :string)
    field(:stream_key, :string)
    field(:recent_asset_ids, {:array, :string})
    # The time at which the event was created. Time value is represented in ISO 8601 format.
    field(:created_at, UnixEpoch)
  end

  @doc false
  @all_fields ~w(id new_asset_settings reconnect_window status stream_key created_at recent_asset_ids)a
  def changeset(%__MODULE__{} = struct, params) do
    struct
    |> cast(params, @all_fields)
    |> cast_embed(:playback_ids, with: &Playback.changeset/2)
  end

  def cast(%__MODULE__{} = struct, params \\ %{}) do
    struct
    |> cast(params, @all_fields)
    |> cast_embed(:playback_ids, with: &Playback.changeset/2)
    |> apply_changes
  end

  @privacy %{
    public: "public",
    private: "signed"
  }

  def public do
    %{playback_policy: @privacy.public, new_asset_settings: %{playback_policy: @privacy.public}}
  end

  def private do
    %{playback_policy: @privacy.private, new_asset_settings: %{playback_policy: @privacy.private}}
  end
end