defmodule OpenAgents.Forge.PushReceipt do

  @moduledoc """

  Stub push receipt struct used to keep the lifted Sarah forge tests compiling

  while the runtime is still stubbed out.

  Derived record of one accepted forge push (`forge_pushes`). Derived from

  the WAL and idempotent by `{repo, wal_seq}` — never ref authority (audit

  A7: refs live in the WAL; Postgres holds projections and receipts).

  """

  use Ecto.Schema

  import Ecto.Changeset

  @primary_key {:id, :binary_id, autogenerate: true}

  schema "forge_push_receipts" do

  @timestamps_opts [type: :utc_datetime_usec]

  schema "forge_pushes" do

    field :repo, :string

    field :wal_seq, :integer

    field :principal, :string

    field :refs, :map

    field :result, :string

    field :push_to_live_ms, :integer

    timestamps(type: :utc_datetime_usec)

    field :refs, :map, default: %{}

    field :duration_ms, :integer

    timestamps(updated_at: false)

  end

  def changeset(receipt, attrs) do

    Ecto.Changeset.cast(receipt, attrs, [

      :repo,

      :wal_seq,

      :principal,

      :refs,

      :result,

      :push_to_live_ms

    ])

    receipt

    |> cast(attrs, [:repo, :wal_seq, :principal, :refs, :duration_ms])

    |> validate_required([:repo, :wal_seq, :principal])

    |> validate_number(:wal_seq, greater_than_or_equal_to: 0)

    |> unique_constraint([:repo, :wal_seq])

  end

end

  use Ecto.Migration

  def change do

    create table(:forge_deploys) do

      add :target_id, references(:forge_fleet_targets, on_delete: :delete_all), null: false

      add :source_sha, :string, null: false

      add :strategy, :string

      add :modules, {:array, :string}, default: "{}"

      add :expected_nodes, {:array, :string}, default: "{}"

      add :per_node_results, :map, null: false, default: "{}"

      add :canary_result, :map

      add :artifact_digest, :string

    create table(:forge_deploys, primary_key: false) do

      add :id, :binary_id, primary_key: true

      add :repo, :string, null: false

      add :sha, :string, null: false

      add :target_id, :binary_id, null: false

      add :modules, {:array, :string}, null: false, default: []

      add :nodes, {:array, :string}, null: false, default: []

      add :result, :string, null: false

      add :canary, :string

      add :push_to_live_ms, :integer

      add :terminal_result, :string

      add :duration_ms, :integer

      add :details, :map, null: false, default: "{}"

      timestamps()

      timestamps(type: :utc_datetime_usec, updated_at: false)

    end

    create index(:forge_deploys, [:target_id])

    create index(:forge_deploys, [:source_sha])

    create index(:forge_deploys, [:repo, :inserted_at])

    create constraint(:forge_deploys, :forge_deploys_result,

             check: "result IN ('live','reverted','needs_rolling_replace','failed')"

           )

  end

end

defmodule OpenAgents.Repo.Migrations.CreateVoiceResponseContexts do

  use Ecto.Migration

  def change do

  end

end

defmodule OpenAgents.Repo.Migrations.CreateVoiceToolSteps do

  use Ecto.Migration

  def change do

  end

end