bsoneach

defmodule Mix.Tasks.CountEach do
  use Mix.Task
  alias BSONEach
  alias CounterAgent

  @moduledoc """
  This module defines a task that uses ```BSONEach.each(&IO.inspect/1)```
  to read bson file and increment counter on each document.

  ## Examples

      $ mix print_each test.bson
  """

  @shortdoc "Parse a BSON fixture and increment counter on each document via BSONEach.each."

  def run(args) do
    [path] = args

    CounterAgent.new

    path
    |> File.open!([:read, :binary, :raw, :read_ahead])
    |> BSONEach.each(&CounterAgent.click(&1))
    |> File.close

    IO.inspect "Done parsing " <> Integer.to_string(CounterAgent.get) <> " documents."
  end
end