opex62541

defmodule ClientMonitoredItemsTest do
  use ExUnit.Case

  alias OpcUA.{NodeId, Server, QualifiedName, Client}

  setup do
    {:ok, pid} = Server.start_link()
    :ok = Server.set_default_config(pid)
    :ok = Server.set_port(pid, 4005)
    {:ok, ns_index} = Server.add_namespace(pid, "Room")

    # Object Node
    requested_new_node_id =
      NodeId.new(ns_index: ns_index, identifier_type: "string", identifier: "R1_TS1_VendorName")

    parent_node_id = NodeId.new(ns_index: 0, identifier_type: "integer", identifier: 85)
    reference_type_node_id = NodeId.new(ns_index: 0, identifier_type: "integer", identifier: 35)
    browse_name = QualifiedName.new(ns_index: ns_index, name: "Temperature sensor")
    type_definition = NodeId.new(ns_index: 0, identifier_type: "integer", identifier: 58)

    :ok = Server.add_object_node(pid,
      requested_new_node_id: requested_new_node_id,
      parent_node_id: parent_node_id,
      reference_type_node_id: reference_type_node_id,
      browse_name: browse_name,
      type_definition: type_definition
    )

    # Variable Node
    requested_new_node_id =
      NodeId.new(ns_index: ns_index, identifier_type: "string", identifier: "R1_TS1_Temperature")

    parent_node_id =
      NodeId.new(ns_index: ns_index, identifier_type: "string", identifier: "R1_TS1_VendorName")

    reference_type_node_id = NodeId.new(ns_index: 0, identifier_type: "integer", identifier: 47)
    browse_name = QualifiedName.new(ns_index: ns_index, name: "Temperature")
    type_definition = NodeId.new(ns_index: 0, identifier_type: "integer", identifier: 63)

    :ok = Server.add_variable_node(pid,
      requested_new_node_id: requested_new_node_id,
      parent_node_id: parent_node_id,
      reference_type_node_id: reference_type_node_id,
      browse_name: browse_name,
      type_definition: type_definition
    )

    :ok = Server.write_node_access_level(pid, requested_new_node_id, 3)
    {:ok, 1} = Server.add_monitored_item(pid, monitored_item: requested_new_node_id, sampling_time: 1000.0)

    requested_new_node_id =
      NodeId.new(ns_index: ns_index, identifier_type: "string", identifier: "R1_TS1_Volts")

    parent_node_id =
      NodeId.new(ns_index: ns_index, identifier_type: "string", identifier: "R1_TS1_VendorName")

    reference_type_node_id = NodeId.new(ns_index: 0, identifier_type: "integer", identifier: 47)
    browse_name = QualifiedName.new(ns_index: ns_index, name: "Volts")
    type_definition = NodeId.new(ns_index: 0, identifier_type: "integer", identifier: 63)

    :ok = Server.add_variable_node(pid,
      requested_new_node_id: requested_new_node_id,
      parent_node_id: parent_node_id,
      reference_type_node_id: reference_type_node_id,
      browse_name: browse_name,
      type_definition: type_definition
    )

    :ok = Server.write_node_access_level(pid, requested_new_node_id, 3)
    {:ok, 2} = Server.add_monitored_item(pid, monitored_item: requested_new_node_id, sampling_time: 1000.0)

    :ok = Server.start(pid)

    {:ok, c_pid} = Client.start_link()
    :ok = Client.set_config(c_pid)
    :ok = Client.connect_by_url(c_pid, url: "opc.tcp://localhost:4005/")

    %{c_pid: c_pid, ns_index: ns_index}
  end

  test "Add & delete a Subscription & Monitored Item", state do

    node_id_1 = NodeId.new(ns_index: state.ns_index, identifier_type: "string", identifier: "R1_TS1_Temperature")
    node_id_2 = NodeId.new(ns_index: state.ns_index, identifier_type: "string", identifier: "R1_TS1_Volts")

    assert {:ok, 1} == Client.add_subscription(state.c_pid)

    assert {:ok, 1} == Client.add_monitored_item(state.c_pid, monitored_item: node_id_1, subscription_id: 1)
    assert {:ok, 2} == Client.add_monitored_item(state.c_pid, monitored_item: node_id_2, subscription_id: 1)

    assert :ok == Client.write_node_value(state.c_pid, node_id_1, 10, 103103.0)
    c_response = Client.read_node_value(state.c_pid, node_id_1)
    assert c_response == {:ok, 103103.0}

    assert :ok == Client.write_node_value(state.c_pid, node_id_2, 10, 104104.0)
    c_response = Client.read_node_value(state.c_pid, node_id_2)
    assert c_response == {:ok, 104104.0}

    Process.sleep(550)

    assert :ok == Client.write_node_value(state.c_pid, node_id_1, 10, 103.0)
    c_response = Client.read_node_value(state.c_pid, node_id_1)
    assert c_response == {:ok, 103.0}

    assert :ok == Client.write_node_value(state.c_pid, node_id_2, 10, 104104.0)
    c_response = Client.read_node_value(state.c_pid, node_id_2)
    assert c_response == {:ok, 104104.0}

    Process.sleep(550)

    assert :ok == Client.delete_monitored_item(state.c_pid, monitored_item_id: 1, subscription_id: 1)

    assert :ok == Client.delete_subscription(state.c_pid, 1)

    assert :ok == Client.write_node_value(state.c_pid, node_id_1, 10, 103.0)
    c_response = Client.read_node_value(state.c_pid, node_id_1)
    assert c_response == {:ok, 103.0}

    assert :ok == Client.write_node_value(state.c_pid, node_id_2, 10, 104104.0)
    c_response = Client.read_node_value(state.c_pid, node_id_2)
    assert c_response == {:ok, 104104.0}

    assert_receive({%OpcUA.NodeId{identifier: "R1_TS1_Temperature", identifier_type: 1, ns_index: 2}, 103103.0}, 5000)

    # Updated data
    assert_receive({:data, 1, 1, 103103.0}, 5000)
    assert_receive({:data, 1, 2, 104104.0}, 5000)
    assert_receive({:data, 1, 1, 103.0}, 5000)
    # Subscription deleted
    assert_receive({:delete, 1}, 1000)
    # Monitored Item deleted
    assert_receive({:delete, 1, 1}, 1000)
    #refute receive
    refute_received({:data, 1, 2, 104104.0})
  end
end