modbux

ExUnit.start()

defmodule TestHelper do
  use ExUnit.Case
  alias Modbux.Request
  alias Modbux.Response
  alias Modbux.Model
  alias Modbux.Rtu
  alias Modbux.Tcp
  alias Modbux.Tcp.Client
  alias Modbux.Tcp.Server

  def pp1(cmd, req, res, val, model) do
    assert req == Request.pack(cmd)
    assert cmd == Request.parse(req)
    assert {{:ok, val}, model} == Model.apply(model, cmd)
    assert res == Response.pack(cmd, val)
    assert val == Response.parse(cmd, res)
    # length predition
    assert byte_size(res) == Response.length(cmd)
    assert byte_size(req) == Request.length(cmd)
    # rtu
    rtu_req = Rtu.pack_req(cmd)
    assert cmd == Rtu.parse_req(rtu_req)
    rtu_res = Rtu.pack_res(cmd, val)
    assert val == Rtu.parse_res(cmd, rtu_res)
    assert byte_size(rtu_res) == Rtu.res_len(cmd)
    assert byte_size(rtu_req) == Rtu.req_len(cmd)
    # tcp
    tcp_req = Tcp.pack_req(cmd, 1)
    assert {cmd, 1} == Tcp.parse_req(tcp_req)
    tcp_res = Tcp.pack_res(cmd, val, 1)
    assert val == Tcp.parse_res(cmd, tcp_res, 1)
    assert byte_size(tcp_res) == Tcp.res_len(cmd)
    assert byte_size(tcp_req) == Tcp.req_len(cmd)
    # master
    Server.start_link(model: model, port: 2002)
    {:ok, master_pid} = Client.start_link(tcp_port: 2002, ip: {127, 0, 0, 1})
    Client.connect(master_pid)

    for _ <- 0..10 do
      Client.request(master_pid, cmd)
      assert {:ok, val} == Client.confirmation(master_pid)
    end
  end

  def pp2(cmd, req, res, model0, model1) do
    assert req == Request.pack(cmd)
    assert cmd == Request.parse(req)
    assert {{:ok, nil}, model1} == Model.apply(model0, cmd)
    assert res == Response.pack(cmd, nil)
    assert nil == Response.parse(cmd, res)
    # length predition
    assert byte_size(res) == Response.length(cmd)
    # rtu
    rtu_req = Rtu.pack_req(cmd)
    assert cmd == Rtu.parse_req(rtu_req)
    rtu_res = Rtu.pack_res(cmd, nil)
    assert nil == Rtu.parse_res(cmd, rtu_res)
    assert byte_size(rtu_res) == Rtu.res_len(cmd)
    # tcp
    tcp_req = Tcp.pack_req(cmd, 1)
    assert {cmd, 1} == Tcp.parse_req(tcp_req)
    tcp_res = Tcp.pack_res(cmd, nil, 1)
    assert nil == Tcp.parse_res(cmd, tcp_res, 1)
    assert byte_size(tcp_res) == Tcp.res_len(cmd)
    # master
    Server.start_link(model: model0, port: 2001)
    {:ok, master_pid} = Client.start_link(tcp_port: 2001, ip: {127, 0, 0, 1})
    Client.connect(master_pid)

    for _ <- 0..10 do
      Client.request(master_pid, cmd)
      assert :ok == Client.confirmation(master_pid)
    end
  end
end