defmodule Ecto.Entity.Update do
  defmacro __using__(_) do
    quote do

      @doc """
      Updates a table record by ID

      ## Example
            iex> Person.update(1, %{first_name: "Kamaro"})
            iex> {:ok,
                  %Person{
                    __meta__: #Ecto.Schema.Metadata<:loaded, "people">,
                    id: 1,
                    first_name: "Kamaro",
                    last_name: "Yundt",
                    age: 7
                  }}
      """
      def update(id, %{} = attrs) when is_integer(id) and is_map(attrs) do
        find(id) |> update_schema(attrs)
      end
      def update!(id, %{} = attrs) when is_integer(id) and is_map(attrs) do
        find(id) |> update_schema!(attrs)
      end

      @doc """
        Update an entity by the schema.
        ## Examples
            iex(1)> person = Person.find(1)
                    %Person{
                      __meta__: #Ecto.Schema.Metadata<:loaded, "people">,
                      id: 1,
                      first_name: "Weber",
                      last_name: "Ok 2",
                      age: 7
                    }
                    iex(2)> Person.update(person, %{first_name: "Kamaro"})
                    {:ok,
                    %Person{
                      __meta__: #Ecto.Schema.Metadata<:loaded, "people">,
                      id: 1,
                      first_name: "Kamaro",
                      last_name: "Ok 2",
                      age: 7
                    }}
      """
      def update(entity, attrs) when is_map(entity) and is_map(attrs) do
        update_schema(entity, attrs)
      end
      def update!(entity, attrs) when is_map(entity) and is_map(attrs) do
        update_schema!(entity, attrs)
      end
      @doc """
      Update many entries that matches a specific query

      # Example
        iex> Person.not_in_ids(1) |> Person.update_many([first_name: "Kamaro Paul"])
        {:ok, %{update_all: {2, nil}}}
      """
      def update_many(query, attrs) when is_list(attrs) do
        Ecto.Multi.new()
        |> Ecto.Multi.update_all(:update_all, query, set: put_updated_at(attrs))
        |> get_repo().transaction()
      end

      @doc false
      defp update_schema(entity, attrs) do
        __MODULE__.changeset(entity, attrs)
        |> get_repo().update()
        |> __MODULE__.maybe_broadcast_event("updated")
      end
      defp update_schema!(entity, attrs) do
        __MODULE__.changeset(entity, attrs)
        |> get_repo().update!()
        |> __MODULE__.maybe_broadcast_event("updated")
      end
    end
  end
end