defmodule Memex.Pipelines.Step do @moduledoc """ Represents a step taken while executing a pipeline """ use Ecto.Schema import Ecto.Changeset alias Ecto.{Changeset, UUID} alias Memex.{Accounts.User, Contexts.Context} alias Memex.Pipelines.{Pipeline, StepContext} @primary_key {:id, :binary_id, autogenerate: true} @foreign_key_type :binary_id schema "steps" do field :title, :string field :content, :string field :position, :integer belongs_to :pipeline, Pipeline belongs_to :user, User many_to_many :contexts, Context, join_through: StepContext timestamps() end @type t :: %__MODULE__{ title: String.t(), content: String.t(), position: non_neg_integer(), pipeline: Pipeline.t() | Ecto.Association.NotLoaded.t(), pipeline_id: Pipeline.id(), user: User.t() | Ecto.Association.NotLoaded.t(), user_id: User.id(), inserted_at: NaiveDateTime.t(), updated_at: NaiveDateTime.t() } @type id :: UUID.t() @type changeset :: Changeset.t(t()) @doc false @spec create_changeset(attrs :: map(), position :: non_neg_integer(), Pipeline.t(), User.t()) :: changeset() def create_changeset(attrs, position, %Pipeline{id: pipeline_id, user_id: user_id}, %User{ id: user_id }) do %__MODULE__{} |> cast(attrs, [:title, :content]) |> change(pipeline_id: pipeline_id, user_id: user_id, position: position) |> validate_required([:title, :content, :user_id, :position]) end @spec update_changeset(t(), attrs :: map(), position :: non_neg_integer(), User.t()) :: changeset() def update_changeset( %{user_id: user_id} = step, attrs, position, %User{id: user_id} ) do step |> cast(attrs, [:title, :content]) |> change(position: position) |> validate_required([:title, :content, :user_id, :position]) end end