wanderer/lib/wanderer_app/api/character.ex

defmodule WandererApp.Api.Character do
  @moduledoc false

  use Ash.Resource,
    domain: WandererApp.Api,
    data_layer: AshPostgres.DataLayer,
    extensions: [AshCloak]

  postgres do
    repo(WandererApp.Repo)
    table("character_v1")
  end

  code_interface do
    define(:create, action: :create)
    define(:read, action: :read)
    define(:search_by_name, action: :search_by_name)
    define(:assign_user, action: :assign)
    define(:update, action: :update)
    define(:update_online, action: :update_online)
    define(:update_location, action: :update_location)
    define(:update_ship, action: :update_ship)
    define(:update_corporation, action: :update_corporation)
    define(:update_alliance, action: :update_alliance)
    define(:update_wallet_balance, action: :update_wallet_balance)
    define(:mark_as_deleted, action: :mark_as_deleted)

    define(:by_id,
      get_by: [:id],
      action: :read
    )

    define(:by_eve_id,
      get_by: [:eve_id],
      action: :read
    )

    define(:active_by_user,
      action: :active_by_user
    )
  end

  actions do
    default_accept [
      :eve_id,
      :name,
      :access_token,
      :refresh_token,
      :expires_at,
      :scopes
    ]

    defaults [:create, :read, :destroy]

    create :link do
      accept([:eve_id, :name, :user_id])
    end

    read :search_by_name do
      argument :name, :string, allow_nil?: true

      filter expr(contains(string_downcase(name), string_downcase(^arg(:name))))
    end

    read :active_by_user do
      argument(:user_id, :uuid, allow_nil?: false)
      filter(expr(user_id == ^arg(:user_id) and deleted == false))
    end

    read :available_by_map do
      argument(:map_id, :uuid, allow_nil?: false)
      filter(expr(user_id == ^arg(:user_id) and deleted == false))
    end

    update :assign do
      accept []
      require_atomic? false

      argument :user_id, :uuid do
        allow_nil? false
      end

      change manage_relationship(:user_id, :user, type: :append_and_remove)
    end

    update :update do
      require_atomic? false
      accept([:access_token, :refresh_token, :expires_at, :scopes])

      change(set_attribute(:deleted, false))
    end

    update :mark_as_deleted do
      accept([])

      change(atomic_update(:deleted, true))
      change(atomic_update(:user_id, nil))
    end

    update :update_online do
      accept([:online])
    end

    update :update_location do
      require_atomic? false

      accept([:solar_system_id, :structure_id, :station_id])
    end

    update :update_ship do
      require_atomic? false

      accept([:ship, :ship_name])
    end

    update :update_corporation do
      require_atomic? false

      accept([:corporation_id, :corporation_name, :corporation_ticker, :alliance_id])
    end

    update :update_alliance do
      require_atomic? false

      accept([:alliance_id, :alliance_name, :alliance_ticker])
    end

    update :update_wallet_balance do
      require_atomic? false

      accept([:eve_wallet_balance])
    end
  end

  cloak do
    vault(WandererApp.Vault)

    attributes([
      :eve_wallet_balance,
      :location,
      :ship,
      :solar_system_id,
      :structure_id,
      :station_id,
      :access_token,
      :refresh_token
    ])

    decrypt_by_default([
      :location,
      :ship,
      :solar_system_id,
      :structure_id,
      :station_id,
      :access_token,
      :refresh_token
    ])
  end

  attributes do
    uuid_primary_key :id

    attribute :eve_id, :string do
      allow_nil? false
    end

    attribute :name, :string do
      allow_nil? false
    end

    attribute :online, :boolean do
      default(false)
      allow_nil?(true)
    end

    attribute :deleted, :boolean do
      default(false)
      allow_nil?(true)
    end

    attribute :scopes, :string
    attribute :character_owner_hash, :string
    attribute :access_token, :string
    attribute :refresh_token, :string
    attribute :token_type, :string
    attribute :expires_at, :integer
    attribute :location, :string
    attribute :solar_system_id, :integer
    attribute :structure_id, :integer
    attribute :station_id, :integer
    attribute :ship, :integer
    attribute :ship_name, :string
    attribute :corporation_id, :integer
    attribute :corporation_name, :string
    attribute :corporation_ticker, :string
    attribute :alliance_id, :integer
    attribute :alliance_name, :string
    attribute :alliance_ticker, :string
    attribute :eve_wallet_balance, :float

    create_timestamp(:inserted_at)
    update_timestamp(:updated_at)
  end

  relationships do
    belongs_to :user, WandererApp.Api.User do
      attribute_writable? true
    end
  end

  identities do
    identity :unique_eve_id, [:eve_id]
  end
end