Packages

sorcery

0.4.15
0.4.15 0.4.14 0.4.13 0.4.12 0.4.11 0.4.10 0.4.9 0.4.8 0.4.7 0.4.6 0.4.5 0.4.4 0.4.3 0.4.2 0.4.1 0.4.0 0.3.7 0.3.6 0.3.5 0.3.4 0.3.3 0.3.2 0.3.1 0.3.0 0.2.5 0.2.4 0.2.3 0.2.2 0.2.1 0.2.0 0.1.0

A framework which rethinks how data flows, and how we build apps.

HexDocs

Current section

Files

Jump to
Readme
31 Versions
4 Dependencies
Dependants
Files
Activity
sorcery lib services store_adapter ecto query query.ex
Raw

lib/services/store_adapter/ecto/query/query.ex 

defmodule Sorcery.StoreAdapter.Ecto.Query do

  @moduledoc false

  alias Sorcery.ReturnedEntities, as: RE

  alias Ecto.Multi, as: M

  alias Sorcery.StoreAdapter.Ecto.Query.BuildMulti

  import Sorcery.Helpers.Maps



  def run_query(inner_state, wheres, finds) do

    repo = inner_state.args.repo_module



    config = inner_state.config_module.config()

    tk_map = config.schemas

    ctx = %{

      repo: repo, 

      config: config, 

      tk_map: tk_map, 

      finds: finds, 

      wheres: wheres,

      multi: M.new()

    }

    ctx = BuildMulti.build_multi(ctx)

    case repo.transaction(ctx.multi) do

      {:ok, results} -> {:ok, transaction_to_re(results, ctx.wheres)}

      err -> {:error, err}

    end

  end



  # {{{ transaction_to_re

  defp transaction_to_re(transaction, wheres) do

    Enum.reduce(transaction, RE.new(), fn {lvark, li}, re ->

      RE.put_entities(re, "#{lvark}", li)

    end)

    |> add_lvar_tks(wheres)

  end





  defp add_lvar_tks(re, wheres) do

    Enum.reduce(wheres, re, fn %{tk: tk, lvar: lvar}, re ->

      put_in_p(re, [:lvar_tks, "#{lvar}"], tk)

    end)

  end

  # }}}







end