.iex.exs

IEx.configure(inspect: [limit: :infinity])

alias TM.Mercury.Utils
alias TM.Mercury.Protocol.{Command, Opcode, Parameter, Region}
alias TM.Mercury.{Reader, Reader.Config, ReadPlan, SimpleReadPlan, StopTriggerReadPlan, Tag, Tag.Protocol, Transport}

defmodule Helpers do
  require Logger

  def dump_erl(beam_file_path) do
    {:ok , {_, [{:abstract_code, {_, ast}}]}} = :beam_lib.chunks(to_charlist(beam_file_path), [:abstract_code])
    IO.puts :erl_prettypr.format(:erl_syntax.form_list(ast))
  end

  def print_tags_sync({:ok, tags}) do
    now = DateTime.utc_now |> to_string
    Enum.each(tags, fn t -> IO.puts "#{now} #{format_epc(t)} #{t[:rssi]}" end)
  end

  def print_tags_sync({:tm_mercury, :tags, tags}) do
    print_tags_sync({:ok, tags})
  end

  def format_epc(tag) do
    Utils.format_epc_as_string(tag)
  end

  def start_async_test(opts) do
    Logger.configure(level: :info)

    device = Keyword.get(opts, :device, "/dev/ttyACM0")
    on_time_ms = Keyword.get(opts, :on_time_ms, 100)
    off_time_ms = Keyword.get(opts, :off_time_ms, 400)
    power = Keyword.get(opts, :power, 2000)
    rate_limit = Keyword.get(opts, :rate_limit, :infinity)
    antennas = Keyword.get(opts, :antennas, {1,1})

    reader =
      case Reader.start_link(device) do
        {:ok, pid} -> pid
        {:error, {:already_started, pid}} -> pid
      end

    :ok = Reader.set_read_tx_power(reader, power)

    rp = %SimpleReadPlan{antennas: antennas}

    {:ok, listener} = Task.start_link(&print_tags_async/0)
    Reader.read_async_start(reader, listener, on_time_ms, off_time_ms, rp, rate_limit)
    reader
  end

  def stop_async(pid) do
    Reader.read_async_stop(pid)
  end

  def print_tags_async do
    receive do
      msg ->
        print_tags_sync(msg)
    end
    print_tags_async()
  end
end