Packages

ecto_cqs

0.1.8
0.6.0 0.5.0 0.4.1 0.4.0 0.3.2 0.3.1 0.3.0 0.2.0 0.1.9 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

CQS library for Ecto

HexDocs

Current section

Files

Jump to
Readme
18 Versions
2 Dependencies
Dependants
Files
Activity
ecto_cqs lib ecto_cqs helpers.ex
Raw

lib/ecto_cqs/helpers.ex 

defmodule EctoCQS.Helpers do

  def schema(opts) do

    opts

    |> Keyword.fetch!(:schema)

    |> Macro.expand(__ENV__)

  end



  def repo(opts) do

    case opts[:repo] do

      nil -> repo_from_schema(schema(opts))

      _ -> Macro.expand(opts[:repo], __ENV__)

    end

  end



  def now(precision \\ :second) do

    {:ok, now} = DateTime.now("Etc/UTC")

    DateTime.truncate(now, precision)

  end



  def timestamps(precision) do

    now = now(precision)

    %{inserted_at: now, updated_at: now}

  end



  defp repo_from_schema(schema) do

    schema

    |> Module.split()

    |> Enum.take(1)

    |> Kernel.++(["Repo"])

    |> Module.safe_concat()

  end

end