Packages

step_flow

1.7.2-rc0
1.9.0-rc2 1.9.0-rc1 1.9.0-rc0 1.8.2 1.8.1 1.8.1-rc8 1.8.1-rc7 1.8.1-rc6 1.8.1-rc5 1.8.1-rc4 1.8.1-rc3 1.8.1-rc2 1.8.1-rc1 1.8.1-rc0 1.8.0 1.8.0-rc3 1.8.0-rc2 1.8.0-rc1 1.8.0-rc0 1.7.3 1.7.3-rc4 1.7.3-rc3 1.7.3-rc2 1.7.3-rc1 1.7.3-rc0 1.7.2 1.7.2-rc4 1.7.2-rc3 1.7.2-rc2 1.7.2-rc1 1.7.2-rc0 1.7.1 1.7.0 1.7.0-rc1 1.7.0-rc0 1.6.1 1.6.1-rc1 1.6.1-rc0 1.6.0 1.6.0-rc9 1.6.0-rc8 1.6.0-rc7 1.6.0-rc6 1.6.0-rc5 1.6.0-rc4 1.6.0-rc3 1.6.0-rc20 1.6.0-rc2 1.6.0-rc19 1.6.0-rc18 1.6.0-rc17 1.6.0-rc16 1.6.0-rc15 1.6.0-rc14 1.6.0-rc13 1.6.0-rc12 1.6.0-rc11 1.6.0-rc10 1.6.0-rc1 1.5.0 1.5.0-rc1 1.4.2-rc2 1.4.2-rc1 1.4.1 1.4.1-rc1 1.4.0 1.4.0-rc4 1.4.0-rc3 1.4.0-rc2 1.4.0-rc1 1.3.1 1.3.0 1.3.0-rc 1.2.0 1.1.0 1.0.0 1.0.0-rc9 1.0.0-rc8 1.0.0-rc7 1.0.0-rc6 1.0.0-rc5 1.0.0-rc1 0.2.13 0.2.12 0.2.11 0.2.10 0.2.9 0.2.8 0.2.7 0.2.6 0.2.5 0.2.4 0.2.3 0.2.2 0.2.1 0.2.0 0.1.8 0.1.7 0.1.6 0.1.5 0.1.4 0.1.3 0.1.2 0.1.1 0.1.0 0.0.24 0.0.23 0.0.22 0.0.21 0.0.20 0.0.19 0.0.18 0.0.17 0.0.16 0.0.15 0.0.14 0.0.13 0.0.12 0.0.11 0.0.10 0.0.9 0.0.8 0.0.7 0.0.6 0.0.4 0.0.3 0.0.2 0.0.1

Step flow manager for Elixir applications

HexDocs

Current section

Files

Jump to
Readme
128 Versions
23 Dependencies
Dependants
Files
Activity
step_flow lib step_flow models updates update.ex
Raw

lib/step_flow/models/updates/update.ex 

defmodule StepFlow.Updates.Update do

  use Ecto.Schema

  import Ecto.Changeset

  alias StepFlow.Jobs.Job

  alias StepFlow.Updates.Update



  @moduledoc false



  schema "step_flow_updates" do

    field(:datetime, :utc_datetime)

    field(:parameters, {:array, :map})

    belongs_to(:job, Job, foreign_key: :job_id)



    timestamps()

  end



  @doc false

  def changeset(%Update{} = update, attrs) do

    update

    |> cast(attrs, [:datetime, :job_id, :parameters])

    |> foreign_key_constraint(:job_id)

    |> validate_required([:datetime, :job_id, :parameters])

  end



  @doc """

  Returns the last updated update of a list of updates.

  """

  def get_last_update(update) when is_list(update) do

    update

    |> Enum.sort(fn update_1, update_2 ->

      case NaiveDateTime.compare(update_1.updated_at, update_2.updated_at) do

        :lt -> true

        :gt -> false

        :eq -> update_1.id < update_2.id

      end

    end)

    |> List.last()

  end



  def get_last_update(%Update{} = update), do: update

  def get_last_update(_update), do: nil

end