47 lines
1.5 KiB
Elixir
47 lines
1.5 KiB
Elixir
defmodule Scopes.CSysTest do
|
|
use ExUnit.Case, async: true
|
|
@moduletag timeout: 5000
|
|
|
|
alias Scopes.CSys
|
|
alias Scopes.CSys.Environ
|
|
alias Scopes.CSys.Program
|
|
alias Scopes.Shape
|
|
|
|
def receive_select(head) do
|
|
assert_receive {^head, info}
|
|
{head, info}
|
|
end
|
|
|
|
def receive_data(head \\ [:csys, :data]) do
|
|
Shape.data(receive_select(head))
|
|
end
|
|
|
|
def neg_only() do
|
|
fn msg -> if Shape.data(msg)[:value] < 0, do: msg end
|
|
end
|
|
|
|
describe "basic:" do
|
|
test "minimal-neural-net" do
|
|
_env = Environ.setup(Program.prepare_basic())
|
|
zero = receive_data([:csys, :created]).new
|
|
CSys.send_value(zero, "Hello Zero!")
|
|
assert "Hello Zero!" = receive_data().value
|
|
CSys.send_message(zero, [:csys, :create, :pred], %{op: neg_only()})
|
|
new1 = receive_data([:csys, :created]).new
|
|
CSys.send_message(new1, [:csys, :create, :succ], %{op: CSys.data_only()})
|
|
new2 = receive_data([:csys, :created]).new
|
|
Process.sleep(1)
|
|
CSys.send_value(new1, "Hello New1!")
|
|
assert "Hello New1!" = receive_data().value
|
|
CSys.send_message(new2, [:csys, :create, :pred])
|
|
new3 = receive_data([:csys, :created]).new
|
|
CSys.send_message(new3, [:csys, :connect], %{target: zero})
|
|
Process.sleep(1)
|
|
CSys.send_value(new3, "Hello New3!")
|
|
assert "Hello New3!" = receive_data().value
|
|
assert "Hello New3!" = receive_data().value
|
|
Process.sleep(50)
|
|
refute_received msg, "unhandled message(s): #{inspect(msg)}"
|
|
end
|
|
end
|
|
end
|