%{
  "bolt_sips": {:hex, :bolt_sips, "2.0.9", "5c796ac187c51b3b60ebeae705619644b053d4a32580cbc3c40678ff9fc81410", [:mix], [{:calendar, "~> 0.17.2", [hex: :calendar, repo: "hexpm", optional: false]}, {:db_connection, "~> 2.2", [hex: :db_connection, repo: "hexpm", optional: false]}, {:jason, "~> 1.2", [hex: :jason, repo: "hexpm", optional: false]}, {:poison, "~> 3.1", [hex: :poison, repo: "hexpm", optional: false]}], "hexpm", "4a1568f438d2f277bfd7ac0aa8dcb4e365bb0c8b7f751d5e010afc80e24bf29e"},
  "calendar": {:hex, :calendar, "0.17.6", "ec291cb2e4ba499c2e8c0ef5f4ace974e2f9d02ae9e807e711a9b0c7850b9aee", [:mix], [{:tzdata, "~> 0.5.20 or ~> 0.1.201603 or ~> 1.0", [hex: :tzdata, repo: "hexpm", optional: false]}], "hexpm", "738d0e17a93c2ccfe4ddc707bdc8e672e9074c8569498483feb1c4530fb91b2b"},
  "certifi": {:hex, :certifi, "2.5.3", "70bdd7e7188c804f3a30ee0e7c99655bc35d8ac41c23e12325f36ab449b70651", [:rebar3], [{:parse_trans, "~>3.3", [hex: :parse_trans, repo: "hexpm", optional: false]}], "hexpm", "ed516acb3929b101208a9d700062d520f3953da3b6b918d866106ffa980e1c10"},
  "connection": {:hex, :connection, "1.1.0", "ff2a49c4b75b6fb3e674bfc5536451607270aac754ffd1bdfe175abe4a6d7a68", [:mix], [], "hexpm", "722c1eb0a418fbe91ba7bd59a47e28008a189d47e37e0e7bb85585a016b2869c"},
  "db_connection": {:hex, :db_connection, "2.3.1", "4c9f3ed1ef37471cbdd2762d6655be11e38193904d9c5c1c9389f1b891a3088e", [:mix], [{:connection, "~> 1.0", [hex: :connection, repo: "hexpm", optional: false]}], "hexpm", "abaab61780dde30301d840417890bd9f74131041afd02174cf4e10635b3a63f5"},
  "hackney": {:hex, :hackney, "1.17.0", "717ea195fd2f898d9fe9f1ce0afcc2621a41ecfe137fae57e7fe6e9484b9aa99", [:rebar3], [{:certifi, "~>2.5", [hex: :certifi, repo: "hexpm", optional: false]}, {:idna, "~>6.1.0", [hex: :idna, repo: "hexpm", optional: false]}, {:metrics, "~>1.0.0", [hex: :metrics, repo: "hexpm", optional: false]}, {:mimerl, "~>1.1", [hex: :mimerl, repo: "hexpm", optional: false]}, {:parse_trans, "~>3.3", [hex: :parse_trans, repo: "hexpm", optional: false]}, {:ssl_verify_fun, "~>1.1.0", [hex: :ssl_verify_fun, repo: "hexpm", optional: false]}, {:unicode_util_compat, "~>0.7.0", [hex: :unicode_util_compat, repo: "hexpm", optional: false]}], "hexpm", "64c22225f1ea8855f584720c0e5b3cd14095703af1c9fbc845ba042811dc671c"},
  "idna": {:hex, :idna, "6.1.1", "8a63070e9f7d0c62eb9d9fcb360a7de382448200fbbd1b106cc96d3d8099df8d", [:rebar3], [{:unicode_util_compat, "~>0.7.0", [hex: :unicode_util_compat, repo: "hexpm", optional: false]}], "hexpm", "92376eb7894412ed19ac475e4a86f7b413c1b9fbb5bd16dccd57934157944cea"},
  "jason": {:hex, :jason, "1.2.2", "ba43e3f2709fd1aa1dce90aaabfd039d000469c05c56f0b8e31978e03fa39052", [:mix], [{:decimal, "~> 1.0 or ~> 2.0", [hex: :decimal, repo: "hexpm", optional: true]}], "hexpm", "18a228f5f0058ee183f29f9eae0805c6e59d61c3b006760668d8d18ff0d12179"},
  "metrics": {:hex, :metrics, "1.0.1", "25f094dea2cda98213cecc3aeff09e940299d950904393b2a29d191c346a8486", [:rebar3], [], "hexpm", "69b09adddc4f74a40716ae54d140f93beb0fb8978d8636eaded0c31b6f099f16"},
  "mimerl": {:hex, :mimerl, "1.2.0", "67e2d3f571088d5cfd3e550c383094b47159f3eee8ffa08e64106cdf5e981be3", [:rebar3], [], "hexpm", "f278585650aa581986264638ebf698f8bb19df297f66ad91b18910dfc6e19323"},
  "parse_trans": {:hex, :parse_trans, "3.3.1", "16328ab840cc09919bd10dab29e431da3af9e9e7e7e6f0089dd5a2d2820011d8", [:rebar3], [], "hexpm", "07cd9577885f56362d414e8c4c4e6bdf10d43a8767abb92d24cbe8b24c54888b"},
  "poison": {:hex, :poison, "3.1.0", "d9eb636610e096f86f25d9a46f35a9facac35609a7591b3be3326e99a0484665", [:mix], [], "hexpm", "fec8660eb7733ee4117b85f55799fd3833eb769a6df71ccf8903e8dc5447cfce"},
  "ssl_verify_fun": {:hex, :ssl_verify_fun, "1.1.6", "cf344f5692c82d2cd7554f5ec8fd961548d4fd09e7d22f5b62482e5aeaebd4b0", [:make, :mix, :rebar3], [], "hexpm", "bdb0d2471f453c88ff3908e7686f86f9be327d065cc1ec16fa4540197ea04680"},
  "tzdata": {:hex, :tzdata, "1.1.0", "72f5babaa9390d0f131465c8702fa76da0919e37ba32baa90d93c583301a8359", [:mix], [{:hackney, "~> 1.17", [hex: :hackney, repo: "hexpm", optional: false]}], "hexpm", "18f453739b48d3dc5bcf0e8906d2dc112bb40baafe2c707596d89f3c8dd14034"},
  "unicode_util_compat": {:hex, :unicode_util_compat, "0.7.0", "bc84380c9ab48177092f43ac89e4dfa2c6d62b40b8bd132b1059ecc7232f9a78", [:rebar3], [], "hexpm", "25eee6d67df61960cf6a794239566599b09e17e668d3700247bc498638152521"},
}

    []

    [
      {:bolt_sips, "~> 2.0"}
    ]

  @moduledoc """
  Documentation for `Esperantisto`.
  """
  @doc """
  Hello world.
  ## Examples
      iex> Esperantisto.hello()
      :world
  """
  def hello do
    :world

  def process_books() do
    Esperantisto.Text.iter_files()
    |> Task.async_stream(Esperantisto.Saver, :start, [], timeout: 30000)
    |> Stream.run()

defmodule Esperantisto.Saver do
  alias Esperantisto.DB
  defmodule State do
    defstruct [:book_id]
  end
  def start(stream) do
    stream
    |> Stream.scan(%State{}, &save/2)
    |> Stream.run()
  end
  defp save({:title, title}, acc) do
    book_id = DB.create_book(title)
    %State{acc | book_id: book_id}
  end
  defp save({:author, author}, acc) do
    DB.set_author(acc.book_id, author)
    acc
  end
  defp save({:sentence, sentence}, acc) do
    DB.save_sentence(acc.book_id, sentence)
    acc
  end
end

defmodule Esperantisto.DB do
  def create_book(title) do
    results =
      Bolt.Sips.query!(
        Bolt.Sips.conn(),
        """
        MERGE (book:Book {title: $title})
        RETURN id(book) as book_id
        """,
        %{title: title}
      )
    [id] = results["book_id"]
    id
  end
  def set_author(book_id, author) do
    Bolt.Sips.query!(
      Bolt.Sips.conn(),
      """
      MATCH (book)
      WHERE id(book) = $id
      SET book.author = $author
      """,
      %{id: book_id, author: author}
    )
  end
  def save_sentence(book_id, sentence) do
    Bolt.Sips.query!(
      Bolt.Sips.conn(),
      """
      MATCH (book)
      WHERE id(book) = $id
      WITH book
      MERGE (book) -[:HAVE_SENTENCE]-> (sentence:Sentence {text: $sentence})
      RETURN sentence
      """,
      %{id: book_id, sentence: sentence},
      timeout: 25000
    )
  end
end

  # See https://hexdocs.pm/elixir/Application.html
  # for more information on OTP Applications

      # Starts a worker by calling: Esperantisto.Worker.start_link(arg)
      # {Esperantisto.Worker, arg}

      Bolt.Sips

    # See https://hexdocs.pm/elixir/Supervisor.html
    # for other strategies and supported options

import Config
config :bolt_sips, Bolt,
  url: "bolt://neo4j:test@localhost",
  pool_size: 16,
  timeout: 15000