Packages

ecto_foundationdb

0.7.2
0.7.6 0.7.5 0.7.4 0.7.3 0.7.2 0.7.1 0.7.0 0.6.2 0.6.1 0.6.0 0.5.1 0.5.0 0.4.0 0.3.1 0.3.0 0.2.1 0.2.0 0.1.2 0.1.1 0.1.0

FoundationDB adapter for Ecto

HexDocs

Current section

Files

Jump to
Readme
20 Versions
5 Dependencies
Dependants
Files
Activity
ecto_foundationdb lib ecto_foundationdb sync many.ex
Raw

lib/ecto_foundationdb/sync/many.ex 

defmodule EctoFoundationDB.Sync.Many do

  @moduledoc false

  @enforce_keys [:label, :schema, :ids]

  defstruct @enforce_keys



  alias EctoFoundationDB.Sync.IdList



  def do_reads(repo, schema, current_idlist, new_ids) do

    current_idmap = for(%{id: id} <- current_idlist, do: {id, true}) |> Enum.into(%{})

    new_idmap = for(id <- new_ids, do: {id, true}) |> Enum.into(%{})

    updates = Map.intersect(current_idmap, new_idmap)

    removes = Map.take(current_idmap, Map.keys(new_idmap))



    futures =

      Enum.map(new_ids, fn id ->

        if Map.has_key?(updates, id) do

          IdList.Markup.keep(id)

        else

          repo.async_get(schema, id)

        end

      end)



    {futures, Map.keys(removes)}

  end

end