Merge pull request #127 from FreeOpcUa/dev

small fixes

docs/index.rst

@@ -33,8 +33,11 @@ Contents:
    client
    node
    subscription
-   errors
-   ua
+   opcua
+
+All:
+
+   modules
 
 Indices and tables
 ==================

docs/modules.rst

+opcua
+=====
+
+.. toctree::
+   :maxdepth: 4
+
+   opcua

docs/opcua.client.rst

+opcua.client package
+====================
+
+Submodules
+----------
+
+opcua.client.client module
+--------------------------
+
+.. automodule:: opcua.client.client
+    :members:
+    :undoc-members:
+    :show-inheritance:
+
+opcua.client.ua_client module
+-----------------------------
+
+.. automodule:: opcua.client.ua_client
+    :members:
+    :undoc-members:
+    :show-inheritance:
+
+
+Module contents
+---------------
+
+.. automodule:: opcua.client
+    :members:
+    :undoc-members:
+    :show-inheritance:

docs/opcua.common.rst

+opcua.common package
+====================
+
+Submodules
+----------
+
+opcua.common.event module
+-------------------------
+
+.. automodule:: opcua.common.event
+    :members:
+    :undoc-members:
+    :show-inheritance:
+
+opcua.common.instanciate module
+-------------------------------
+
+.. automodule:: opcua.common.instanciate
+    :members:
+    :undoc-members:
+    :show-inheritance:
+
+opcua.common.manage_nodes module
+--------------------------------
+
+.. automodule:: opcua.common.manage_nodes
+    :members:
+    :undoc-members:
+    :show-inheritance:
+
+opcua.common.methods module
+---------------------------
+
+.. automodule:: opcua.common.methods
+    :members:
+    :undoc-members:
+    :show-inheritance:
+
+opcua.common.node module
+------------------------
+
+.. automodule:: opcua.common.node
+    :members:
+    :undoc-members:
+    :show-inheritance:
+
+opcua.common.subscription module
+--------------------------------
+
+.. automodule:: opcua.common.subscription
+    :members:
+    :undoc-members:
+    :show-inheritance:
+
+opcua.common.uaerrors module
+----------------------------
+
+.. automodule:: opcua.common.uaerrors
+    :members:
+    :undoc-members:
+    :show-inheritance:
+
+opcua.common.utils module
+-------------------------
+
+.. automodule:: opcua.common.utils
+    :members:
+    :undoc-members:
+    :show-inheritance:
+
+opcua.common.xmlimporter module
+-------------------------------
+
+.. automodule:: opcua.common.xmlimporter
+    :members:
+    :undoc-members:
+    :show-inheritance:
+
+opcua.common.xmlparser module
+-----------------------------
+
+.. automodule:: opcua.common.xmlparser
+    :members:
+    :undoc-members:
+    :show-inheritance:
+
+
+Module contents
+---------------
+
+.. automodule:: opcua.common
+    :members:
+    :undoc-members:
+    :show-inheritance:

docs/opcua.crypto.rst

+opcua.crypto package
+====================
+
+Submodules
+----------
+
+opcua.crypto.security_policies module
+-------------------------------------
+
+.. automodule:: opcua.crypto.security_policies
+    :members:
+    :undoc-members:
+    :show-inheritance:
+
+opcua.crypto.uacrypto module
+----------------------------
+
+.. automodule:: opcua.crypto.uacrypto
+    :members:
+    :undoc-members:
+    :show-inheritance:
+
+
+Module contents
+---------------
+
+.. automodule:: opcua.crypto
+    :members:
+    :undoc-members:
+    :show-inheritance:

docs/opcua.rst

+opcua package
+=============
+
+Subpackages
+-----------
+
+.. toctree::
+
+    opcua.client
+    opcua.common
+    opcua.crypto
+    opcua.server
+    opcua.ua
+
+Submodules
+----------
+
+opcua.tools module
+------------------
+
+.. automodule:: opcua.tools
+    :members:
+    :undoc-members:
+    :show-inheritance:
+
+
+Module contents
+---------------
+
+.. automodule:: opcua
+    :members:
+    :undoc-members:
+    :show-inheritance:

docs/opcua.server.rst

+opcua.server package
+====================
+
+Subpackages
+-----------
+
+.. toctree::
+
+    opcua.server.standard_address_space
+
+Submodules
+----------
+
+opcua.server.address_space module
+---------------------------------
+
+.. automodule:: opcua.server.address_space
+    :members:
+    :undoc-members:
+    :show-inheritance:
+
+opcua.server.binary_server module
+---------------------------------
+
+.. automodule:: opcua.server.binary_server
+    :members:
+    :undoc-members:
+    :show-inheritance:
+
+opcua.server.binary_server_asyncio module
+-----------------------------------------
+
+.. automodule:: opcua.server.binary_server_asyncio
+    :members:
+    :undoc-members:
+    :show-inheritance:
+
+opcua.server.internal_server module
+-----------------------------------
+
+.. automodule:: opcua.server.internal_server
+    :members:
+    :undoc-members:
+    :show-inheritance:
+
+opcua.server.internal_subscription module
+-----------------------------------------
+
+.. automodule:: opcua.server.internal_subscription
+    :members:
+    :undoc-members:
+    :show-inheritance:
+
+opcua.server.server module
+--------------------------
+
+.. automodule:: opcua.server.server
+    :members:
+    :undoc-members:
+    :show-inheritance:
+
+opcua.server.subscription_service module
+----------------------------------------
+
+.. automodule:: opcua.server.subscription_service
+    :members:
+    :undoc-members:
+    :show-inheritance:
+
+opcua.server.uaprocessor module
+-------------------------------
+
+.. automodule:: opcua.server.uaprocessor
+    :members:
+    :undoc-members:
+    :show-inheritance:
+
+opcua.server.users module
+-------------------------
+
+.. automodule:: opcua.server.users
+    :members:
+    :undoc-members:
+    :show-inheritance:
+
+
+Module contents
+---------------
+
+.. automodule:: opcua.server
+    :members:
+    :undoc-members:
+    :show-inheritance:

docs/opcua.server.standard_address_space.rst

+opcua.server.standard_address_space package
+===========================================
+
+Submodules
+----------
+
+opcua.server.standard_address_space.standard_address_space module
+-----------------------------------------------------------------
+
+.. automodule:: opcua.server.standard_address_space.standard_address_space
+    :members:
+    :undoc-members:
+    :show-inheritance:
+
+opcua.server.standard_address_space.standard_address_space_part10 module
+------------------------------------------------------------------------
+
+.. automodule:: opcua.server.standard_address_space.standard_address_space_part10
+    :members:
+    :undoc-members:
+    :show-inheritance:
+
+opcua.server.standard_address_space.standard_address_space_part11 module
+------------------------------------------------------------------------
+
+.. automodule:: opcua.server.standard_address_space.standard_address_space_part11
+    :members:
+    :undoc-members:
+    :show-inheritance:
+
+opcua.server.standard_address_space.standard_address_space_part13 module
+------------------------------------------------------------------------
+
+.. automodule:: opcua.server.standard_address_space.standard_address_space_part13
+    :members:
+    :undoc-members:
+    :show-inheritance:
+
+opcua.server.standard_address_space.standard_address_space_part3 module
+-----------------------------------------------------------------------
+
+.. automodule:: opcua.server.standard_address_space.standard_address_space_part3
+    :members:
+    :undoc-members:
+    :show-inheritance:
+
+opcua.server.standard_address_space.standard_address_space_part4 module
+-----------------------------------------------------------------------
+
+.. automodule:: opcua.server.standard_address_space.standard_address_space_part4
+    :members:
+    :undoc-members:
+    :show-inheritance:
+
+opcua.server.standard_address_space.standard_address_space_part5 module
+-----------------------------------------------------------------------
+
+.. automodule:: opcua.server.standard_address_space.standard_address_space_part5
+    :members:
+    :undoc-members:
+    :show-inheritance:
+
+opcua.server.standard_address_space.standard_address_space_part8 module
+-----------------------------------------------------------------------
+
+.. automodule:: opcua.server.standard_address_space.standard_address_space_part8
+    :members:
+    :undoc-members:
+    :show-inheritance:
+
+opcua.server.standard_address_space.standard_address_space_part9 module
+-----------------------------------------------------------------------
+
+.. automodule:: opcua.server.standard_address_space.standard_address_space_part9
+    :members:
+    :undoc-members:
+    :show-inheritance:
+
+
+Module contents
+---------------
+
+.. automodule:: opcua.server.standard_address_space
+    :members:
+    :undoc-members:
+    :show-inheritance:

docs/opcua.ua.rst

+opcua.ua package
+================
+
+Submodules
+----------
+
+opcua.ua.attribute_ids module
+-----------------------------
+
+.. automodule:: opcua.ua.attribute_ids
+    :members:
+    :undoc-members:
+    :show-inheritance:
+
+opcua.ua.extension_objects module
+---------------------------------
+
+.. automodule:: opcua.ua.extension_objects
+    :members:
+    :undoc-members:
+    :show-inheritance:
+
+opcua.ua.object_ids module
+--------------------------
+
+.. automodule:: opcua.ua.object_ids
+    :members:
+    :undoc-members:
+    :show-inheritance:
+
+opcua.ua.status_codes module
+----------------------------
+
+.. automodule:: opcua.ua.status_codes
+    :members:
+    :undoc-members:
+    :show-inheritance:
+
+opcua.ua.uaprotocol_auto module
+-------------------------------
+
+.. automodule:: opcua.ua.uaprotocol_auto
+    :members:
+    :undoc-members:
+    :show-inheritance:
+
+opcua.ua.uaprotocol_hand module
+-------------------------------
+
+.. automodule:: opcua.ua.uaprotocol_hand
+    :members:
+    :undoc-members:
+    :show-inheritance:
+
+opcua.ua.uatypes module
+-----------------------
+
+.. automodule:: opcua.ua.uatypes
+    :members:
+    :undoc-members:
+    :show-inheritance:
+
+
+Module contents
+---------------
+
+.. automodule:: opcua.ua
+    :members:
+    :undoc-members:
+    :show-inheritance:

docs/ua.rst

-
-UA Structures and Enums
-=========================================
-
-All the structures and enums are to be found under opcua.ua
-
-.. automodule:: opcua.ua.uatypes
-   :members:
-
-.. automodule:: opcua.ua.uaprotocol_hand
-   :members:
-
-.. automodule:: opcua.ua.uaprotocol_auto
-   :members:
-
-
-
-

opcua/ua/uatypes.py

@@ -15,6 +15,7 @@ if sys.version_info.major > 2:
 from opcua.ua import status_codes
 from opcua.common.uaerrors import UaError
 from opcua.common.uaerrors import UaStatusCodeError
+from opcua.common.uaerrors import UaStringParsingError
 
 
 logger = logging.getLogger('opcua.uaprotocol')
@@ -371,6 +372,8 @@ class NodeId(FrozenClass):
         self.NamespaceUri = ""
         self.ServerIndex = 0
         self._freeze = True
+        if not isinstance(self.NamespaceIndex, int):
+            raise UaError("NamespaceIndex must be an int")
         if self.Identifier is None:
             self.Identifier = 0
             self.NodeIdType = NodeIdType.TwoByte
@@ -399,6 +402,13 @@ class NodeId(FrozenClass):
 
     @staticmethod
     def from_string(string):
+        try:
+            return NodeId._from_string(string)
+        except ValueError as ex:
+            raise UaStringParsingError("Error parsing string {}".format(string), ex)
+
+    @staticmethod
+    def _from_string(string):
         l = string.split(";")
         identifier = None
         namespace = 0
@@ -408,7 +418,7 @@ class NodeId(FrozenClass):
         for el in l:
             if not el:
                 continue
-            k, v = el.split("=")
+            k, v = el.split("=", 1)
             k = k.strip()
             v = v.strip()
             if k == "ns":
@@ -430,7 +440,7 @@ class NodeId(FrozenClass):
             elif k == "nsu":
                 nsu = v
         if identifier is None:
-            raise UaError("Could not parse nodeid string: " + string)
+            raise UaStringParsingError("Could not find identifier in string: " + string)
         nodeid = NodeId(identifier, namespace, ntype)
         nodeid.NamespaceUri = nsu
         nodeid.ServerIndex = srv
@@ -572,11 +582,15 @@ class QualifiedName(FrozenClass):
     @staticmethod
     def from_string(string):
         if ":" in string:
+            try:
                 idx, name = string.split(":", 1)
+                idx = int(idx)
+            except (TypeError, ValueError) as ex:
+                raise UaStringParsingError("Error parsing string {}".format(string), ex)
         else:
             idx = 0
             name = string
-        return QualifiedName(name, int(idx))
+        return QualifiedName(name, idx)
 
     def to_binary(self):
         packet = []

tests/test_opclab_internet.sh

+python3 test_server.py opc.tcp://opcua.demo-this.com:51210/UA/SampleServer

tests/tests.py

-#! /usr/bin/env python
-# coding: utf-8
+import unittest
+import logging
 import sys
 sys.path.insert(0, "..")
 sys.path.insert(0, ".")
-import subprocess
-import time
-import logging
-import math
-import io
-from datetime import datetime, timedelta
-import unittest
-from concurrent.futures import Future
-from threading import Lock
-
-from opcua import ua
-from opcua import Client
-from opcua import Server
-from opcua import uamethod
-from opcua import Event
-from opcua.ua import ObjectIds
-from opcua.ua import AttributeIds
-from opcua.ua import extensionobject_from_binary
-from opcua.ua import extensionobject_to_binary
-from opcua.ua.uatypes import flatten, get_shape, reshape
-
-port_num1 = 48510
-port_num2 = 48530
-port_discovery = 48550
-
-
-class SubHandler():
-
-    '''
-        Dummy subscription client
-    '''
-
-    def datachange_notification(self, node, val, data):
-        pass
-
-    def event_notification(self, event):
-        pass
-
-
-class MySubHandlerDeprecated():
-
-    '''
-    More advanced subscription client using Future, so we can wait for events in tests
-    '''
-
-    def __init__(self):
-        self.future = Future()
-
-    def reset(self):
-        self.future = Future()
-
-    def data_change(self, handle, node, val, attr):
-        self.future.set_result((handle, node, val, attr))
-
-    def event(self, handle, event):
-        self.future.set_result((handle, event))
-
-class MySubHandler():
-
-    '''
-    More advanced subscription client using Future, so we can wait for events in tests
-    '''
-
-    def __init__(self):
-        self.future = Future()
-
-    def reset(self):
-        self.future = Future()
-
-    def datachange_notification(self, node, val, data):
-        self.future.set_result((node, val, data))
-
-    def event_notification(self, event):
-        self.future.set_result(event)
-
-
-class MySubHandler2():
-    def __init__(self):
-        self.results = [] 
-
-    def datachange_notification(self, node, val, data):
-        self.results.append((node, val))
-
-    def event_notification(self, event):
-        self.results.append(event)
-
-
-class Unit(unittest.TestCase):
-
-    '''
-    Simple unit test that do not need to setup a server or a client
-    '''
-
-    def test_variant_dimensions(self):
-        l = [[[1.0, 1.0, 1.0, 1.0], [2.0, 2.0, 2.0, 2.0], [3.0, 3.0, 3.0, 3.0]],[[5.0, 5.0, 5.0, 5.0], [7.0, 8.0, 9.0, 01.0], [1.0, 1.0, 1.0, 1.0]]]
-        v = ua.Variant(l)
-        self.assertEqual(v.Dimensions, [2, 3, 4])
-        v2 = ua.Variant.from_binary(ua.utils.Buffer(v.to_binary()))
-        self.assertEqual(v, v2)
-        self.assertEqual(v.Dimensions, v2.Dimensions)
-        
-        # very special case
-        l = [[[], [], []], [[], [], []]]
-        v = ua.Variant(l, ua.VariantType.UInt32)
-        self.assertEqual(v.Dimensions, [2, 3, 0])
-        v2 = ua.Variant.from_binary(ua.utils.Buffer(v.to_binary()))
-        self.assertEqual(v.Dimensions, v2.Dimensions)
-        self.assertEqual(v, v2)
-
-    def test_flatten(self):
-        l = [[[1.0, 1.0, 1.0, 1.0], [1.0, 1.0, 1.0, 1.0], [1.0, 1.0, 1.0, 1.0]],[[1.0, 1.0, 1.0, 1.0], [1.0, 1.0, 1.0, 1.0], [1.0, 1.0, 1.0, 1.0]]]
-        l2 = flatten(l)
-        dims = get_shape(l)
-        self.assertEqual(dims, [2, 3, 4])
-        self.assertNotEqual(l, l2)
-
-        l3 = reshape(l2, (2,3,4))
-        self.assertEqual(l, l3)
-
-
-        l = [[[], [], []], [[], [], []]]
-        l2 = flatten(l)
-        dims = get_shape(l)
-        self.assertEqual(dims, [2, 3, 0])
-
-        l = [1, 2, 3, 4]
-        l2 = flatten(l)
-        dims = get_shape(l)
-        self.assertEqual(dims, [4])
-        self.assertEqual(l, l2)
-
-    def test_custom_variant(self):
-        with self.assertRaises(ua.UaError):
-            v = ua.Variant(b"ljsdfljds", ua.VariantTypeCustom(89))
-        v = ua.Variant(b"ljsdfljds", ua.VariantTypeCustom(61))
-        v2 = ua.Variant.from_binary(ua.utils.Buffer(v.to_binary()))
-        self.assertEqual(v.VariantType, v2.VariantType)
-        self.assertEqual(v, v2)
-
-
-    def test_custom_variant_array(self):
-        v = ua.Variant([b"ljsdfljds", b"lkjsdljksdf"], ua.VariantTypeCustom(40))
-        v2 = ua.Variant.from_binary(ua.utils.Buffer(v.to_binary()))
-        self.assertEqual(v.VariantType, v2.VariantType)
-        self.assertEqual(v, v2)
-
-    def test_guid(self):
-        g = ua.Guid()
-        sc = ua.StatusCode()
-
-    def test_nodeid(self):
-        nid = ua.NodeId()
-        self.assertEqual(nid.NodeIdType, ua.NodeIdType.TwoByte)
-        nid = ua.NodeId(446, 3, ua.NodeIdType.FourByte)
-        self.assertEqual(nid.NodeIdType, ua.NodeIdType.FourByte)
-        d = nid.to_binary()
-        new_nid = nid.from_binary(io.BytesIO(d))
-        self.assertEqual(new_nid, nid)
-        self.assertEqual(new_nid.NodeIdType, ua.NodeIdType.FourByte)
-        self.assertEqual(new_nid.Identifier, 446)
-        self.assertEqual(new_nid.NamespaceIndex, 3)
-
-        tb = ua.TwoByteNodeId(53)
-        fb = ua.FourByteNodeId(53)
-        n = ua.NumericNodeId(53)
-        n1 = ua.NumericNodeId(53, 0)
-        s = ua.StringNodeId(53, 0)  # should we raise an exception???
-        s1 = ua.StringNodeId("53", 0)
-        bs = ua.ByteStringNodeId(b"53", 0)
-        gid = ua.Guid()
-        g = ua.ByteStringNodeId(gid, 0)
-        guid = ua.GuidNodeId(gid)
-        self.assertEqual(tb, fb)
-        self.assertEqual(tb, n)
-        self.assertEqual(tb, n1)
-        self.assertEqual(n1, fb)
-        self.assertNotEqual(n1, s)
-        self.assertNotEqual(s, bs)
-        self.assertNotEqual(s, g)
-        self.assertNotEqual(g, guid)
-        self.assertEqual(tb, ua.NodeId.from_binary(ua.utils.Buffer(tb.to_binary())))
-        self.assertEqual(fb, ua.NodeId.from_binary(ua.utils.Buffer(fb.to_binary())))
-        self.assertEqual(n, ua.NodeId.from_binary(ua.utils.Buffer(n.to_binary())))
-        self.assertEqual(s1, ua.NodeId.from_binary(ua.utils.Buffer(s1.to_binary())))
-        self.assertEqual(bs, ua.NodeId.from_binary(ua.utils.Buffer(bs.to_binary())))
-        self.assertEqual(guid, ua.NodeId.from_binary(ua.utils.Buffer(guid.to_binary())))
-
-    def test_nodeid_string(self):
-        nid0 = ua.NodeId(45)
-        self.assertEqual(nid0, ua.NodeId.from_string("i=45"))
-        self.assertEqual(nid0, ua.NodeId.from_string("ns=0;i=45"))
-        nid = ua.NodeId(45, 10)
-        self.assertEqual(nid, ua.NodeId.from_string("i=45; ns=10"))
-        self.assertNotEqual(nid, ua.NodeId.from_string("i=45; ns=11"))
-        self.assertNotEqual(nid, ua.NodeId.from_string("i=5; ns=10"))
-        # not sure the next one is correct...
-        self.assertEqual(nid, ua.NodeId.from_string("i=45; ns=10; srv=serverid"))
-
-    def test_expandednodeid(self):
-        nid = ua.ExpandedNodeId()
-        self.assertEqual(nid.NodeIdType, ua.NodeIdType.TwoByte)
-        nid2 = ua.ExpandedNodeId.from_binary(ua.utils.Buffer(nid.to_binary()))
-        self.assertEqual(nid, nid2)
-
-    def test_extension_object(self):
-        obj = ua.UserNameIdentityToken()
-        obj.UserName = "admin"
-        obj.Password = b"pass"
-        obj2 = ua.extensionobject_from_binary(ua.utils.Buffer(extensionobject_to_binary(obj)))
-        self.assertEqual(type(obj), type(obj2))
-        self.assertEqual(obj.UserName, obj2.UserName)
-        self.assertEqual(obj.Password, obj2.Password)
-        v1 = ua.Variant(obj)
-        v2 = ua.Variant.from_binary(ua.utils.Buffer(v1.to_binary()))
-        self.assertEqual(type(v1), type(v2))
-        self.assertEqual(v1.VariantType, v2.VariantType)
-
-    def test_unknown_extension_object(self):
-        obj = ua.ExtensionObject()
-        obj.Body = b'example of data in custom format'
-        obj.TypeId = ua.NodeId.from_string('ns=3;i=42')
-        data = ua.utils.Buffer(extensionobject_to_binary(obj))
-        obj2 = ua.extensionobject_from_binary(data)
-        self.assertEqual(type(obj2), ua.ExtensionObject)
-        self.assertEqual(obj2.TypeId, obj.TypeId)
-        self.assertEqual(obj2.Body, b'example of data in custom format')
-
-    def test_datetime(self):
-        now = datetime.utcnow()
-        epch = ua.datetime_to_win_epoch(now)
-        dt = ua.win_epoch_to_datetime(epch)
-        self.assertEqual(now, dt)
-
-        # python's datetime has a range from Jan 1, 0001 to the end of year 9999
-        # windows' filetime has a range from Jan 1, 1601 to approx. year 30828
-        # let's test an overlapping range [Jan 1, 1601 - Dec 31, 9999]
-        dt = datetime(1601, 1, 1)
-        self.assertEqual(ua.win_epoch_to_datetime(ua.datetime_to_win_epoch(dt)), dt)
-        dt = datetime(9999, 12, 31, 23, 59, 59)
-        self.assertEqual(ua.win_epoch_to_datetime(ua.datetime_to_win_epoch(dt)), dt)
-
-        epch = 128930364000001000
-        dt = ua.win_epoch_to_datetime(epch)
-        epch2 = ua.datetime_to_win_epoch(dt)
-        self.assertEqual(epch, epch2)
-
-        epch = 0
-        self.assertEqual(ua.datetime_to_win_epoch(ua.win_epoch_to_datetime(epch)), epch)
-
-    def test_equal_nodeid(self):
-        nid1 = ua.NodeId(999, 2)
-        nid2 = ua.NodeId(999, 2)
-        self.assertTrue(nid1 == nid2)
-        self.assertTrue(id(nid1) != id(nid2))
-
-    def test_zero_nodeid(self):
-        self.assertEqual(ua.NodeId(), ua.NodeId(0, 0))
-        self.assertEqual(ua.NodeId(), ua.NodeId.from_string('ns=0;i=0;'))
-
-    def test_string_nodeid(self):
-        nid = ua.NodeId('titi', 1)
-        self.assertEqual(nid.NamespaceIndex, 1)
-        self.assertEqual(nid.Identifier, 'titi')
-        self.assertEqual(nid.NodeIdType, ua.NodeIdType.String)
-
-    def test_unicode_string_nodeid(self):
-        nid = ua.NodeId('hëllò', 1)
-        self.assertEqual(nid.NamespaceIndex, 1)
-        self.assertEqual(nid.Identifier, 'hëllò')
-        self.assertEqual(nid.NodeIdType, ua.NodeIdType.String)
-        d = nid.to_binary()
-        new_nid = nid.from_binary(io.BytesIO(d))
-        self.assertEqual(new_nid, nid)
-        self.assertEqual(new_nid.Identifier, 'hëllò')
-        self.assertEqual(new_nid.NodeIdType, ua.NodeIdType.String)
-
-    def test_numeric_nodeid(self):
-        nid = ua.NodeId(999, 2)
-        self.assertEqual(nid.NamespaceIndex, 2)
-        self.assertEqual(nid.Identifier, 999)
-        self.assertEqual(nid.NodeIdType, ua.NodeIdType.Numeric)
-
-    def test_qualifiedstring_nodeid(self):
-        nid = ua.NodeId.from_string('ns=2;s=PLC1.Manufacturer;')
-        self.assertEqual(nid.NamespaceIndex, 2)
-        self.assertEqual(nid.Identifier, 'PLC1.Manufacturer')
-
-    def test_strrepr_nodeid(self):
-        nid = ua.NodeId.from_string('ns=2;s=PLC1.Manufacturer;')
-        self.assertEqual(nid.to_string(), 'ns=2;s=PLC1.Manufacturer')
-        #self.assertEqual(repr(nid), 'ns=2;s=PLC1.Manufacturer;')
-
-    def test_qualified_name(self):
-        qn = ua.QualifiedName('qname', 2)
-        self.assertEqual(qn.NamespaceIndex, 2)
-        self.assertEqual(qn.Name, 'qname')
-        self.assertEqual(qn.to_string(), '2:qname')
-
-    def test_datavalue(self):
-        dv = ua.DataValue(123)
-        self.assertEqual(dv.Value, ua.Variant(123))
-        self.assertEqual(type(dv.Value), ua.Variant)
-        dv = ua.DataValue('abc')
-        self.assertEqual(dv.Value, ua.Variant('abc'))
-        now = datetime.utcnow()
-        dv.SourceTimestamp = now
-
-    def test_variant(self):
-        dv = ua.Variant(True, ua.VariantType.Boolean)
-        self.assertEqual(dv.Value, True)
-        self.assertEqual(type(dv.Value), bool)
-        now = datetime.utcnow()
-        v = ua.Variant(now)
-        self.assertEqual(v.Value, now)
-        self.assertEqual(v.VariantType, ua.VariantType.DateTime)
-        v2 = ua.Variant.from_binary(ua.utils.Buffer(v.to_binary()))
-        self.assertEqual(v.Value, v2.Value)
-        self.assertEqual(v.VariantType, v2.VariantType)
-        # commonity method:
-        self.assertEqual(v, ua.Variant(v))
-
-    def test_variant_array(self):
-        v = ua.Variant([1, 2, 3, 4, 5])
-        self.assertEqual(v.Value[1], 2)
-        # self.assertEqual(v.VarianType, ua.VariantType.Int64) # we do not care, we should aonly test for sutff that matter
-        v2 = ua.Variant.from_binary(ua.utils.Buffer(v.to_binary()))
-        self.assertEqual(v.Value, v2.Value)
-        self.assertEqual(v.VariantType, v2.VariantType)
-
-        now = datetime.utcnow()
-        v = ua.Variant([now])
-        self.assertEqual(v.Value[0], now)
-        self.assertEqual(v.VariantType, ua.VariantType.DateTime)
-        v2 = ua.Variant.from_binary(ua.utils.Buffer(v.to_binary()))
-        self.assertEqual(v.Value, v2.Value)
-        self.assertEqual(v.VariantType, v2.VariantType)
-
-    def test_variant_array_dim(self):
-        v = ua.Variant([1, 2, 3, 4, 5, 6], dimensions = [2, 3])
-        self.assertEqual(v.Value[1], 2)
-        v2 = ua.Variant.from_binary(ua.utils.Buffer(v.to_binary()))
-        self.assertEqual(reshape(v.Value, (2,3)), v2.Value)
-        self.assertEqual(v.VariantType, v2.VariantType)
-        self.assertEqual(v.Dimensions, v2.Dimensions)
-        self.assertEqual(v2.Dimensions, [2, 3])
-
-    def test_text(self):
-        t1 = ua.LocalizedText('Root')
-        t2 = ua.LocalizedText('Root')
-        t3 = ua.LocalizedText('root')
-        self.assertEqual(t1, t2)
-        self.assertNotEqual(t1, t3)
-        t4 = ua.LocalizedText.from_binary(ua.utils.Buffer(t1.to_binary()))
-        self.assertEqual(t1, t4)
-
-    def test_message_chunk(self):
-        pol = ua.SecurityPolicy()
-        chunks = ua.MessageChunk.message_to_chunks(pol, b'123', 65536)
-        self.assertEqual(len(chunks), 1)
-        seq = 0
-        for chunk in chunks:
-            seq += 1
-            chunk.SequenceHeader.SequenceNumber = seq
-        chunk2 = ua.MessageChunk.from_binary(pol, ua.utils.Buffer(chunks[0].to_binary()))
-        self.assertEqual(chunks[0].to_binary(), chunk2.to_binary())
-
-        # for policy None, MessageChunk overhead is 12+4+8 = 24 bytes
-        # Let's pack 11 bytes into 28-byte chunks. The message must be split as 4+4+3
-        chunks = ua.MessageChunk.message_to_chunks(pol, b'12345678901', 28)
-        self.assertEqual(len(chunks), 3)
-        self.assertEqual(chunks[0].Body, b'1234')
-        self.assertEqual(chunks[1].Body, b'5678')
-        self.assertEqual(chunks[2].Body, b'901')
-        for chunk in chunks:
-            seq += 1
-            chunk.SequenceHeader.SequenceNumber = seq
-            self.assertTrue(len(chunk.to_binary()) <= 28)
-
-
-class CommonTests(object):
-
-    '''
-    Tests that will be run twice. Once on server side and once on
-    client side since we have been carefull to have the exact
-    same api on server and client side
-    '''
-    # jyst to avoid editor warnings
-    opc = None
-
-    def test_find_servers(self):
-        servers = self.opc.find_servers()
-        # FIXME : finish
-
-    def test_delete_nodes(self):
-        obj = self.opc.get_objects_node()
-        fold = obj.add_folder(2, "FolderToDelete")
-        var = fold.add_variable(2, "VarToDelete", 9.1)
-        childs = fold.get_children()
-        self.assertIn(var, childs)
-        self.opc.delete_nodes([var])
-        with self.assertRaises(ua.UaStatusCodeError):
-            var.set_value(7.8)
-        with self.assertRaises(ua.UaStatusCodeError):
-            obj.get_child(["2:FolderToDelete", "2:VarToDelete"])
-        childs = fold.get_children()
-        self.assertNotIn(var, childs)
-
-    def test_delete_nodes_recursive(self):
-        obj = self.opc.get_objects_node()
-        fold = obj.add_folder(2, "FolderToDeleteR")
-        var = fold.add_variable(2, "VarToDeleteR", 9.1)
-        self.opc.delete_nodes([fold, var])
-        with self.assertRaises(ua.UaStatusCodeError):
-            var.set_value(7.8)
-        with self.assertRaises(ua.UaStatusCodeError):
-            obj.get_child(["2:FolderToDelete", "2:VarToDelete"])
-
-    def test_delete_nodes_recursive2(self):
-        obj = self.opc.get_objects_node()
-        fold = obj.add_folder(2, "FolderToDeleteRoot")
-        nfold = fold
-        mynodes = []
-        for i in range(7):
-            nfold = fold.add_folder(2, "FolderToDeleteRoot")
-            var = fold.add_variable(2, "VarToDeleteR", 9.1)
-            var = fold.add_property(2, "ProToDeleteR", 9.1)
-            prop = fold.add_property(2, "ProToDeleteR", 9.1)
-            o = fold.add_object(3, "ObjToDeleteR")
-            mynodes.append(nfold)
-            mynodes.append(var)
-            mynodes.append(prop)
-            mynodes.append(o)
-        self.opc.delete_nodes([fold], recursive=True)
-        for node in mynodes:
-            with self.assertRaises(ua.UaStatusCodeError):
-                node.get_browse_name()
-
-    def test_server_node(self):
-        node = self.opc.get_server_node()
-        self.assertEqual(ua.QualifiedName('Server', 0), node.get_browse_name())
-
-    def test_root(self):
-        root = self.opc.get_root_node()
-        self.assertEqual(ua.QualifiedName('Root', 0), root.get_browse_name())
-        self.assertEqual(ua.LocalizedText('Root'), root.get_display_name())
-        nid = ua.NodeId(84, 0)
-        self.assertEqual(nid, root.nodeid)
-
-    def test_objects(self):
-        objects = self.opc.get_objects_node()
-        self.assertEqual(ua.QualifiedName('Objects', 0), objects.get_browse_name())
-        nid = ua.NodeId(85, 0)
-        self.assertEqual(nid, objects.nodeid)
-
-    def test_browse(self):
-        objects = self.opc.get_objects_node()
-        obj = objects.add_object(4, "browsetest")
-        folder = obj.add_folder(4, "folder")
-        prop = obj.add_property(4, "property", 1)
-        prop2 = obj.add_property(4, "property2", 2)
-        var = obj.add_variable(4, "variable", 3)
-        obj2 = obj.add_object(4, "obj")
-        alle = obj.get_children()
-        self.assertTrue(prop in alle)
-        self.assertTrue(prop2 in alle)
-        self.assertTrue(var in alle)
-        self.assertTrue(folder in alle)
-        self.assertFalse(obj in alle)
-        props = obj.get_children(refs=ObjectIds.HasProperty)
-        self.assertTrue(prop in props)
-        self.assertTrue(prop2 in props)
-        self.assertFalse(var in props)
-        self.assertFalse(folder in props)
-        all_vars = obj.get_children(nodeclassmask=ua.NodeClass.Variable)
-        self.assertTrue(prop in all_vars)
-        self.assertTrue(var in all_vars)
-        all_objs = obj.get_children(nodeclassmask=ua.NodeClass.Object)
-        self.assertTrue(folder in all_objs)
-        self.assertTrue(obj2 in all_objs)
-        self.assertFalse(var in all_objs)
-
-    def test_browsename_with_spaces(self):
-        o = self.opc.get_objects_node()
-        v = o.add_variable(3, 'BNVariable with spaces and %&+?/', 1.3)
-        v2 = o.get_child("3:BNVariable with spaces and %&+?/")
-        self.assertEqual(v, v2)
-
-    def test_create_delete_subscription(self):
-        o = self.opc.get_objects_node()
-        v = o.add_variable(3, 'SubscriptionVariable', [1, 2, 3])
-        sub = self.opc.create_subscription(100, sclt)
-        handle = sub.subscribe_data_change(v)
-        time.sleep(0.1)
-        sub.unsubscribe(handle)
-        sub.delete()
-
-    def test_subscribe_events(self):
-        sub = self.opc.create_subscription(100, sclt)
-        handle = sub.subscribe_events()
-        time.sleep(0.1)
-        sub.unsubscribe(handle)
-        sub.delete()
-
-    def test_subscribe_events_to_wrong_node(self):
-        sub = self.opc.create_subscription(100, sclt)
-        with self.assertRaises(ua.UaStatusCodeError):
-            handle = sub.subscribe_events(self.opc.get_node("i=85"))
-        o = self.opc.get_objects_node()
-        v = o.add_variable(3, 'VariableNoEventNofierAttribute', 4)
-        with self.assertRaises(ua.UaStatusCodeError):
-            handle = sub.subscribe_events(v)
-        sub.delete()
-
-    def test_events_deprecated(self):
-        msclt = MySubHandlerDeprecated()
-        sub = self.opc.create_subscription(100, msclt)
-        handle = sub.subscribe_events()
-
-        ev = Event(self.srv.iserver.isession)
-        msg = b"this is my msg "
-        ev.Message.Text = msg
-        tid = datetime.utcnow()
-        ev.Time = tid
-        ev.Severity = 500
-        ev.trigger()
-
-        clthandle, ev = msclt.future.result()
-        self.assertIsNot(ev, None)  # we did not receive event
-        self.assertEqual(ev.Message.Text, msg)
-        #self.assertEqual(msclt.ev.Time, tid)
-        self.assertEqual(ev.Severity, 500)
-        self.assertEqual(ev.SourceNode, self.opc.get_server_node().nodeid)
-
-        # time.sleep(0.1)
-        sub.unsubscribe(handle)
-        sub.delete()
-
-    def test_events(self):
-        msclt = MySubHandler()
-        sub = self.opc.create_subscription(100, msclt)
-        handle = sub.subscribe_events()
-
-        ev = Event(self.srv.iserver.isession)
-        msg = b"this is my msg "
-        ev.Message.Text = msg
-        tid = datetime.utcnow()
-        ev.Time = tid
-        ev.Severity = 500
-        ev.trigger()
-
-        ev = msclt.future.result()
-        self.assertIsNot(ev, None)  # we did not receive event
-        self.assertEqual(ev.Message.Text, msg)
-        #self.assertEqual(msclt.ev.Time, tid)
-        self.assertEqual(ev.Severity, 500)
-        self.assertEqual(ev.SourceNode, self.opc.get_server_node().nodeid)
-
-        # time.sleep(0.1)
-        sub.unsubscribe(handle)
-        sub.delete()
-
-    def test_non_existing_path(self):
-        root = self.opc.get_root_node()
-        with self.assertRaises(ua.UaStatusCodeError):
-            server_time_node = root.get_child(['0:Objects', '0:Server', '0:nonexistingnode'])
-
-    def test_bad_attribute(self):
-        root = self.opc.get_root_node()
-        with self.assertRaises(ua.UaStatusCodeError):
-            root.set_value(99)
-
-    def test_get_node_by_nodeid(self):
-        root = self.opc.get_root_node()
-        server_time_node = root.get_child(['0:Objects', '0:Server', '0:ServerStatus', '0:CurrentTime'])
-        correct = self.opc.get_node(ua.NodeId(ua.ObjectIds.Server_ServerStatus_CurrentTime))
-        self.assertEqual(server_time_node, correct)
-
-    def test_datetime_read(self):
-        time_node = self.opc.get_node(ua.NodeId(ua.ObjectIds.Server_ServerStatus_CurrentTime))
-        dt = time_node.get_value()
-        utcnow = datetime.utcnow()
-        delta = utcnow - dt
-        self.assertTrue(delta < timedelta(seconds=1))
-
-    def test_datetime_write(self):
-        time_node = self.opc.get_node(ua.NodeId(ua.ObjectIds.Server_ServerStatus_CurrentTime))
-        now = datetime.utcnow()
-        objects = self.opc.get_objects_node()
-        v1 = objects.add_variable(4, "test_datetime", now)
-        tid = v1.get_value()
-        self.assertEqual(now, tid)
-
-
-    def test_variant_array_dim(self):
-        objects = self.opc.get_objects_node()
-        l = [[[1.0, 1.0, 1.0, 1.0], [2.0, 2.0, 2.0, 2.0], [3.0, 3.0, 3.0, 3.0]],[[5.0, 5.0, 5.0, 5.0], [7.0, 8.0, 9.0, 01.0], [1.0, 1.0, 1.0, 1.0]]]
-        v = objects.add_variable(3, 'variableWithDims', l)
-        v2 = v.get_value()
-        self.assertEqual(v2, l)
-        dv = v.get_data_value()
-        self.assertEqual(dv.Value.Dimensions, [2,3,4])
-
-        l = [[[], [], []], [[], [], []]]
-        variant = ua.Variant(l, ua.VariantType.UInt32)
-        v = objects.add_variable(3, 'variableWithDimsEmpty', variant)
-        v2 = v.get_value()
-        self.assertEqual(v2, l)
-        dv = v.get_data_value()
-        self.assertEqual(dv.Value.Dimensions, [2,3,0])
-
-
-
-
-    def test_add_numeric_variable(self):
-        objects = self.opc.get_objects_node()
-        v = objects.add_variable('ns=3;i=888;', '3:numericnodefromstring', 99)
-        nid = ua.NodeId(888, 3)
-        qn = ua.QualifiedName('numericnodefromstring', 3)
-        self.assertEqual(nid, v.nodeid)
-        self.assertEqual(qn, v.get_browse_name())
-
-    def test_add_string_variable(self):
-        objects = self.opc.get_objects_node()
-        v = objects.add_variable('ns=3;s=stringid;', '3:stringnodefromstring', [68])
-        nid = ua.NodeId('stringid', 3)
-        qn = ua.QualifiedName('stringnodefromstring', 3)
-        self.assertEqual(nid, v.nodeid)
-        self.assertEqual(qn, v.get_browse_name())
-
-    def test_utf8(self):
-        objects = self.opc.get_objects_node()
-        utf_string = "æøå@%&"
-        bn = ua.QualifiedName(utf_string, 3) 
-        nid = ua.NodeId("æølå", 3)
-        val = "æøå"
-        v = objects.add_variable(nid, bn, val)
-        self.assertEqual(nid, v.nodeid)
-        val2 = v.get_value()
-        self.assertEqual(val, val2)
-        bn2 = v.get_browse_name()
-        self.assertEqual(bn, bn2)
-
-    def test_null_variable(self):
-        objects = self.opc.get_objects_node()
-        var = objects.add_variable(3, 'nullstring', "a string")
-        var.set_value(None)
-        val = var.get_value()
-        self.assertEqual(val, None)
-        var.set_value("")
-        val = var.get_value()
-        self.assertNotEqual(val, None)
-        self.assertEqual(val, "")
-
-    def test_variable_data_type(self):
-        objects = self.opc.get_objects_node()
-        var = objects.add_variable(3, 'stringfordatatype', "a string")
-        val = var.get_data_type()
-        self.assertEqual(val, ua.NodeId(ua.ObjectIds.String))
-        var = objects.add_variable(3, 'stringarrayfordatatype', ["a", "b"])
-        val = var.get_data_type()
-        self.assertEqual(val, ua.NodeId(ua.ObjectIds.String))
-
-    def test_add_string_array_variable(self):
-        objects = self.opc.get_objects_node()
-        v = objects.add_variable('ns=3;s=stringarrayid;', '9:stringarray', ['l', 'b'])
-        nid = ua.NodeId('stringarrayid', 3)
-        qn = ua.QualifiedName('stringarray', 9)
-        self.assertEqual(nid, v.nodeid)
-        self.assertEqual(qn, v.get_browse_name())
-        val = v.get_value()
-        self.assertEqual(['l', 'b'], val)
-
-    def test_add_numeric_node(self):
-        objects = self.opc.get_objects_node()
-        nid = ua.NodeId(9999, 3)
-        qn = ua.QualifiedName('AddNodeVar1', 3)
-        v1 = objects.add_variable(nid, qn, 0)
-        self.assertEqual(nid, v1.nodeid)
-        self.assertEqual(qn, v1.get_browse_name())
-
-    def test_add_string_node(self):
-        objects = self.opc.get_objects_node()
-        qn = ua.QualifiedName('AddNodeVar2', 3)
-        nid = ua.NodeId('AddNodeVar2Id', 3)
-        v2 = objects.add_variable(nid, qn, 0)
-        self.assertEqual(nid, v2.nodeid)
-        self.assertEqual(qn, v2.get_browse_name())
-
-    def test_add_find_node_(self):
-        objects = self.opc.get_objects_node()
-        o = objects.add_object('ns=2;i=101;', '2:AddFindObject')
-        o2 = objects.get_child('2:AddFindObject')
-        self.assertEqual(o, o2)
-
-    def test_node_path(self):
-        objects = self.opc.get_objects_node()
-        o = objects.add_object('ns=2;i=105;', '2:NodePathObject')
-        root = self.opc.get_root_node()
-        o2 = root.get_child(['0:Objects', '2:NodePathObject'])
-        self.assertEqual(o, o2)
-
-    def test_add_read_node(self):
-        objects = self.opc.get_objects_node()
-        o = objects.add_object('ns=2;i=102;', '2:AddReadObject')
-        nid = ua.NodeId(102, 2)
-        self.assertEqual(o.nodeid, nid)
-        qn = ua.QualifiedName('AddReadObject', 2)
-        self.assertEqual(o.get_browse_name(), qn)
-
-    def test_simple_value(self):
-        o = self.opc.get_objects_node()
-        v = o.add_variable(3, 'VariableTestValue', 4.32)
-        val = v.get_value()
-        self.assertEqual(4.32, val)
-
-    def test_add_exception(self):
-        objects = self.opc.get_objects_node()
-        o = objects.add_object('ns=2;i=103;', '2:AddReadObject')
-        with self.assertRaises(ua.UaStatusCodeError):
-            o2 = objects.add_object('ns=2;i=103;', '2:AddReadObject')
-
-    def test_negative_value(self):
-        o = self.opc.get_objects_node()
-        v = o.add_variable(3, 'VariableNegativeValue', 4)
-        v.set_value(-4.54)
-        val = v.get_value()
-        self.assertEqual(-4.54, val)
-
-    def test_read_server_state(self):
-        statenode = self.opc.get_node(ua.NodeId(ua.ObjectIds.Server_ServerStatus_State))
-        state = statenode.get_value()
-        self.assertEqual(state, 0)
-
-    def test_bad_node(self):
-        bad = self.opc.get_node(ua.NodeId(999, 999))
-        with self.assertRaises(ua.UaStatusCodeError):
-            bad.get_browse_name()
-        with self.assertRaises(ua.UaStatusCodeError):
-            bad.set_value(89)
-        with self.assertRaises(ua.UaStatusCodeError):
-            bad.add_object(0, "0:myobj")
-        with self.assertRaises(ua.UaStatusCodeError):
-            bad.get_child("0:myobj")
-
-    def test_value(self):
-        o = self.opc.get_objects_node()
-        var = ua.Variant(1.98, ua.VariantType.Double)
-        v = o.add_variable(3, 'VariableValue', var)
-        val = v.get_value()
-        self.assertEqual(1.98, val)
-
-        dvar = ua.DataValue(var)
-        dv = v.get_data_value()
-        self.assertEqual(ua.DataValue, type(dv))
-        self.assertEqual(dvar.Value, dv.Value)
-        self.assertEqual(dvar.Value, var)
-
-    def test_set_value(self):
-        o = self.opc.get_objects_node()
-        var = ua.Variant(1.98, ua.VariantType.Double)
-        dvar = ua.DataValue(var)
-        v = o.add_variable(3, 'VariableValue', var)
-        v.set_value(var.Value)
-        v1 = v.get_value()
-        self.assertEqual(v1, var.Value)
-        v.set_value(var)
-        v2 = v.get_value()
-        self.assertEqual(v2, var.Value)
-        v.set_data_value(dvar)
-        v3 = v.get_data_value()
-        self.assertEqual(v3.Value, dvar.Value)
-
-    def test_array_value(self):
-        o = self.opc.get_objects_node()
-        v = o.add_variable(3, 'VariableArrayValue', [1, 2, 3])
-        val = v.get_value()
-        self.assertEqual([1, 2, 3], val)
-
-    def test_bool_variable(self):
-        o = self.opc.get_objects_node()
-        v = o.add_variable(3, 'BoolVariable', True)
-        dt = v.get_data_type()
-        self.assertEqual(dt, ua.TwoByteNodeId(ua.ObjectIds.Boolean))
-        val = v.get_value()
-        self.assertEqual(True, val)
-        v.set_value(False)
-        val = v.get_value()
-        self.assertEqual(False, val)
-
-    def test_array_size_one_value(self):
-        o = self.opc.get_objects_node()
-        v = o.add_variable(3, 'VariableArrayValue', [1, 2, 3])
-        v.set_value([1])
-        val = v.get_value()
-        self.assertEqual([1], val)
-
-    def test_subscription_failure(self):
-        msclt = MySubHandler()
-        o = self.opc.get_objects_node()
-        sub = self.opc.create_subscription(100, msclt)
-        with self.assertRaises(ua.UaStatusCodeError):
-            handle1 = sub.subscribe_data_change(o) # we can only subscribe to variables so this should fail
-        sub.delete()
-
-    def test_subscription_overload(self):
-        nb = 10
-        msclt = MySubHandler()
-        o = self.opc.get_objects_node()
-        sub = self.opc.create_subscription(1, msclt)
-        variables = []
-        subs = []
-        for i in range(nb):
-            v = o.add_variable(3, 'SubscriptionVariableOverload' + str(i), 99)
-            variables.append(v)
-        for i in range(nb):
-            sub.subscribe_data_change(variables)
-        for i in range(nb):
-            for j in range(nb):
-                variables[i].set_value(j)
-            s = self.opc.create_subscription(1, msclt)
-            s.subscribe_data_change(variables)
-            subs.append(s)
-            sub.subscribe_data_change(variables[i])
-        for i in range(nb):
-            for j in range(nb):
-                variables[i].set_value(j)
-        sub.delete()
-        for s in subs:
-            s.delete()
-
-    def test_subscription_overload_simple(self):
-        nb = 10
-        msclt = MySubHandler()
-        o = self.opc.get_objects_node()
-        sub = self.opc.create_subscription(1, msclt)
-        variables = [o.add_variable(3, 'SubVarOverload' + str(i), i) for i in range(nb)]
-        for i in range(nb):
-            sub.subscribe_data_change(variables)
-        sub.delete()
-
-    def test_subscription_data_change_depcrecated(self):
-        '''
-        test subscriptions. This is far too complicated for
-        a unittest but, setting up subscriptions requires a lot
-        of code, so when we first set it up, it is best
-        to test as many things as possible
-        '''
-        msclt = MySubHandlerDeprecated()
-
-        o = self.opc.get_objects_node()
-
-        # subscribe to a variable
-        startv1 = [1, 2, 3]
-        v1 = o.add_variable(3, 'SubscriptionVariableDeprecatedV1', startv1)
-        sub = self.opc.create_subscription(100, msclt)
-        handle1 = sub.subscribe_data_change(v1)
-
-        # Now check we get the start value
-        clthandle, node, val, attr = msclt.future.result()
-        self.assertEqual(val, startv1)
-        self.assertEqual(node, v1)
-
-        msclt.reset()  # reset future object
-
-        # modify v1 and check we get value
-        v1.set_value([5])
-        clthandle, node, val, attr = msclt.future.result()
-
-        self.assertEqual(node, v1)
-        self.assertEqual(val, [5])
-
-        with self.assertRaises(ua.UaStatusCodeError):
-            sub.unsubscribe(999)  # non existing handle
-        sub.unsubscribe(handle1)
-        with self.assertRaises(ua.UaStatusCodeError):
-            sub.unsubscribe(handle1)  # second try should fail
-        sub.delete()
-        with self.assertRaises(ua.UaStatusCodeError):
-            sub.unsubscribe(handle1)  # sub does not exist anymore
-
-    def test_subscription_data_change(self):
-        '''
-        test subscriptions. This is far too complicated for
-        a unittest but, setting up subscriptions requires a lot
-        of code, so when we first set it up, it is best
-        to test as many things as possible
-        '''
-        msclt = MySubHandler()
-
-        o = self.opc.get_objects_node()
-
-        # subscribe to a variable
-        startv1 = [1, 2, 3]
-        v1 = o.add_variable(3, 'SubscriptionVariableV1', startv1)
-        sub = self.opc.create_subscription(100, msclt)
-        handle1 = sub.subscribe_data_change(v1)
-
-        # Now check we get the start value
-        node, val, data = msclt.future.result()
-        self.assertEqual(val, startv1)
-        self.assertEqual(node, v1)
-
-        msclt.reset()  # reset future object
-
-        # modify v1 and check we get value
-        v1.set_value([5])
-        node, val, data = msclt.future.result()
-
-        self.assertEqual(node, v1)
-        self.assertEqual(val, [5])
-
-        with self.assertRaises(ua.UaStatusCodeError):
-            sub.unsubscribe(999)  # non existing handle
-        sub.unsubscribe(handle1)
-        with self.assertRaises(ua.UaStatusCodeError):
-            sub.unsubscribe(handle1)  # second try should fail
-        sub.delete()
-        with self.assertRaises(ua.UaStatusCodeError):
-            sub.unsubscribe(handle1)  # sub does not exist anymore
-
-
-    def test_subscription_data_change_bool(self):
-        '''
-        test subscriptions. This is far too complicated for
-        a unittest but, setting up subscriptions requires a lot
-        of code, so when we first set it up, it is best
-        to test as many things as possible
-        '''
-        msclt = MySubHandler()
-
-        o = self.opc.get_objects_node()
-
-        # subscribe to a variable
-        startv1 = True 
-        v1 = o.add_variable(3, 'SubscriptionVariableBool', startv1)
-        sub = self.opc.create_subscription(100, msclt)
-        handle1 = sub.subscribe_data_change(v1)
-
-        # Now check we get the start value
-        node, val, data = msclt.future.result()
-        self.assertEqual(val, startv1)
-        self.assertEqual(node, v1)
-
-        msclt.reset()  # reset future object
-
-        # modify v1 and check we get value
-        v1.set_value(False)
-        node, val, data = msclt.future.result()
-        self.assertEqual(node, v1)
-        self.assertEqual(val, False)
-
-        sub.delete() # should delete our monitoreditem too
-
-    def test_subscription_data_change_many(self):
-        '''
-        test subscriptions. This is far too complicated for
-        a unittest but, setting up subscriptions requires a lot
-        of code, so when we first set it up, it is best
-        to test as many things as possible
-        '''
-        msclt = MySubHandler2()
-        o = self.opc.get_objects_node()
-
-        startv1 = True 
-        v1 = o.add_variable(3, 'SubscriptionVariableMany1', startv1)
-        startv2 = [1.22, 1.65] 
-        v2 = o.add_variable(3, 'SubscriptionVariableMany2', startv2)
-
-        sub = self.opc.create_subscription(100, msclt)
-        handle1, handle2 = sub.subscribe_data_change([v1, v2])
-
-        # Now check we get the start values
-        nodes = [v1, v2]
-       
-        count = 0
-        while not len(msclt.results) > 1:
-            count += 1
-            time.sleep(0.1)
-            if count > 100:
-                self.fail("Did not get result from subscription")
-        for node, val in msclt.results:
-            self.assertIn(node, nodes)
-            nodes.remove(node)
-            if node == v1:
-                self.assertEqual(startv1, val)
-            elif node == v2:
-                self.assertEqual(startv2, val)
-            else:
-                self.fail("Error node {} is neither {} nor {}".format(node, v1, v2))
-
-        sub.delete() 
-
-    def test_subscribe_server_time(self):
-        msclt = MySubHandler()
-
-        server_time_node = self.opc.get_node(ua.NodeId(ua.ObjectIds.Server_ServerStatus_CurrentTime))
-
-        sub = self.opc.create_subscription(200, msclt)
-        handle = sub.subscribe_data_change(server_time_node)
-
-        node, val, data = msclt.future.result()
-        self.assertEqual(node, server_time_node)
-        delta = datetime.utcnow() - val
-        self.assertTrue(delta < timedelta(seconds=2))
-
-        sub.unsubscribe(handle)
-        sub.delete()
-
-    def test_use_namespace(self):
-        idx = self.opc.get_namespace_index("urn:freeopcua:python:server")
-        self.assertEqual(idx, 1)
-        root = self.opc.get_root_node()
-        myvar = root.add_variable(idx, 'var_in_custom_namespace', [5])
-        myid = myvar.nodeid
-        self.assertEqual(idx, myid.NamespaceIndex)
-
-    def test_method(self):
-        o = self.opc.get_objects_node()
-        m = o.get_child("2:ServerMethod")
-        result = o.call_method("2:ServerMethod", 2.1)
-        self.assertEqual(result, 4.2)
-        with self.assertRaises(ua.UaStatusCodeError):
-            # FIXME: we should raise a more precise exception
-            result = o.call_method("2:ServerMethod", 2.1, 89, 9)
-        with self.assertRaises(ua.UaStatusCodeError):
-            result = o.call_method(ua.NodeId(999), 2.1)  # non existing method
-
-    def test_method_array(self):
-        o = self.opc.get_objects_node()
-        m = o.get_child("2:ServerMethodArray")
-        result = o.call_method(m, "sin", ua.Variant(math.pi))
-        self.assertTrue(result < 0.01)
-
-    def test_method_array2(self):
-        o = self.opc.get_objects_node()
-        m = o.get_child("2:ServerMethodArray2")
-        result = o.call_method(m, [1.1, 3.4, 9])
-        self.assertEqual(result, [2.2, 6.8, 18])
-
-    def test_add_nodes(self):
-        objects = self.opc.get_objects_node()
-        f = objects.add_folder(3, 'MyFolder')
-        v = f.add_variable(3, 'MyVariable', 6)
-        p = f.add_property(3, 'MyProperty', 10)
-        childs = f.get_children()
-        self.assertTrue(v in childs)
-        self.assertTrue(p in childs)
-
-    def test_get_endpoints(self):
-        endpoints = self.opc.get_endpoints()
-        self.assertTrue(len(endpoints) > 0)
-        self.assertTrue(endpoints[0].EndpointUrl.startswith("opc.tcp://"))
-
-
-def add_server_methods(srv):
-    @uamethod
-    def func(parent, value):
-        return value * 2
-
-    o = srv.get_objects_node()
-    v = o.add_method(ua.NodeId("ServerMethod", 2), ua.QualifiedName('ServerMethod', 2), func, [ua.VariantType.Int64], [ua.VariantType.Int64])
-
-    @uamethod
-    def func2(parent, methodname, value):
-        return math.sin(value)
-
-    o = srv.get_objects_node()
-    v = o.add_method(ua.NodeId("ServerMethodArray", 2), ua.QualifiedName('ServerMethodArray', 2), func2, [ua.VariantType.String, ua.VariantType.Int64], [ua.VariantType.Int64])
-
-    @uamethod
-    def func3(parent, mylist):
-        return [i * 2 for i in mylist]
-
-    o = srv.get_objects_node()
-    v = o.add_method(ua.NodeId("ServerMethodArray2", 2), ua.QualifiedName('ServerMethodArray2', 2), func3, [ua.VariantType.Int64], [ua.VariantType.Int64])
-
-class AdminTestClient(unittest.TestCase, CommonTests):
-
-    '''
-    Run common tests on client side
-    Of course we need a server so we start a server in another
-    process using python Process module
-    Tests that can only be run on client side must be defined here
-    '''
-    @classmethod
-    def setUpClass(self):
-        # start our own server
-        self.srv = Server()
-        self.srv.set_endpoint('opc.tcp://localhost:%d' % port_num1)
-        add_server_methods(self.srv)
-        self.srv.start()
-
-        # start admin client
-        self.clt = Client('opc.tcp://admin@localhost:%d' % port_num1)
-        self.clt.connect()
-        self.opc = self.clt
-
-        # start anonymous client
-        self.ro_clt = Client('opc.tcp://localhost:%d' % port_num1)
-        self.ro_clt.connect()
-
-
-
-    @classmethod
-    def tearDownClass(self):
-        #stop our clients
-        self.ro_clt.disconnect()
-        self.clt.disconnect()
-        # stop the server 
-        self.srv.stop()
-
-    def test_service_fault(self):
-        request = ua.ReadRequest()
-        request.TypeId = ua.FourByteNodeId(999)  # bad type!
-        with self.assertRaises(ua.UaStatusCodeError):
-            self.clt.uaclient._uasocket.send_request(request)
-
-    def test_objects_anonymous(self):
-        objects = self.ro_clt.get_objects_node()
-        with self.assertRaises(ua.UaStatusCodeError):
-            objects.set_attribute(ua.AttributeIds.WriteMask, ua.DataValue(999))
-        with self.assertRaises(ua.UaStatusCodeError):
-            f = objects.add_folder(3, 'MyFolder')
-
-    def test_folder_anonymous(self):
-        objects = self.clt.get_objects_node()
-        f = objects.add_folder(3, 'MyFolderRO')
-        f_ro = self.ro_clt.get_node(f.nodeid)
-        self.assertEqual(f, f_ro)
-        with self.assertRaises(ua.UaStatusCodeError):
-            f2 = f_ro.add_folder(3, 'MyFolder2')
-
-    def test_variable_anonymous(self):
-        objects = self.clt.get_objects_node()
-        v = objects.add_variable(3, 'MyROVariable', 6)
-        v.set_value(4) #this should work
-        v_ro = self.ro_clt.get_node(v.nodeid)
-        with self.assertRaises(ua.UaStatusCodeError):
-            v_ro.set_value(2)
-        self.assertEqual(v_ro.get_value(), 4)
-        v.set_writable(True)
-        v_ro.set_value(2) #now it should work
-        self.assertEqual(v_ro.get_value(), 2)
-        v.set_writable(False)
-        with self.assertRaises(ua.UaStatusCodeError):
-            v_ro.set_value(9)
-        self.assertEqual(v_ro.get_value(), 2)
-
-
-class TestCmdLines(unittest.TestCase):
-
-    '''
-    Test command lines
-    '''
-    @classmethod
-    def setUpClass(self):
-        self.srv = Server()
-        self.srv_url = 'opc.tcp://localhost:%d' % port_num2
-        self.srv.set_endpoint(self.srv_url)
-        objects = self.srv.get_objects_node()
-        obj = objects.add_object(4, "directory")
-        var = obj.add_variable(4, "variable", 1.999)
-        var2 = obj.add_variable(4, "variable2", 1.777)
-        var2.set_writable()
-        self.srv.start()
-
-    def test_uals(self):
-        s = subprocess.check_output(["python", "tools/uals", "--url", self.srv_url])
-        self.assertIn(b"i=85", s)
-        self.assertNotIn(b"i=89", s)
-        self.assertNotIn(b"1.999", s)
-        s = subprocess.check_output(["python", "tools/uals", "--url", self.srv_url, "-d", "3"])
-        self.assertIn(b"1.999", s)
-
-    def test_uaread(self):
-        s = subprocess.check_output(["python", "tools/uaread", "--url", self.srv_url, "--path", "0:Objects,4:directory,4:variable"])
-        self.assertIn(b"1.999", s)
-
-    def test_uawrite(self):
-        s = subprocess.check_output(["python", "tools/uawrite", "--url", self.srv_url, "--path", "0:Objects,4:directory,4:variable2", "1.789"])
-        s = subprocess.check_output(["python", "tools/uaread", "--url", self.srv_url, "--path", "0:Objects,4:directory,4:variable2"])
-        self.assertIn(b"1.789", s)
-        self.assertNotIn(b"1.999", s)
-
-    def test_uadiscover(self):
-        s = subprocess.check_output(["python", "tools/uadiscover", "--url", self.srv_url])
-        self.assertIn(b"opc.tcp://localhost", s)
-        self.assertIn(b"FreeOpcUa", s)
-        self.assertIn(b"urn:freeopcua:python:server", s)
-
-    @classmethod
-    def tearDownClass(self):
-        self.srv.stop()
-
-
-class TestServer(unittest.TestCase, CommonTests):
-
-    '''
-    Run common tests on server side
-    Tests that can only be run on server side must be defined here
-    '''
-    @classmethod
-    def setUpClass(self):
-        self.srv = Server()
-        self.srv.set_endpoint('opc.tcp://localhost:%d' % port_num2)
-        add_server_methods(self.srv)
-        self.srv.start()
-        self.opc = self.srv
-        self.discovery = Server()
-        self.discovery.set_application_uri("urn:freeopcua:python:discovery")
-        self.discovery.set_endpoint('opc.tcp://localhost:%d' % port_discovery)
-        self.discovery.start()
-
-    @classmethod
-    def tearDownClass(self):
-        self.srv.stop()
-        self.discovery.stop()
-
-    def test_discovery(self):
-        client = Client(self.discovery.endpoint.geturl())
-        client.connect()
-        try:
-            servers = client.find_servers()
-            new_app_uri = "urn:freeopcua:python:server:test_discovery"
-            self.srv.application_uri = new_app_uri
-            self.srv.register_to_discovery(self.discovery.endpoint.geturl(), 0)
-            time.sleep(0.1) # let server register registration
-            new_servers = client.find_servers()
-            self.assertEqual(len(new_servers) - len(servers) , 1)
-            self.assertFalse(new_app_uri in [s.ApplicationUri for s in servers])
-            self.assertTrue(new_app_uri in [s.ApplicationUri for s in new_servers])
-        finally:
-            client.disconnect()
-    
-    def test_find_servers2(self):
-        client = Client(self.discovery.endpoint.geturl())
-        client.connect()
-        try:
-            servers = client.find_servers()
-            new_app_uri1 = "urn:freeopcua:python:server:test_discovery1"
-            self.srv.application_uri = new_app_uri1
-            self.srv.register_to_discovery(self.discovery.endpoint.geturl(), period=0)
-            new_app_uri2 = "urn:freeopcua:python:test_discovery2"
-            self.srv.application_uri = new_app_uri2
-            self.srv.register_to_discovery(self.discovery.endpoint.geturl(), period=0)
-            time.sleep(0.1) # let server register registration
-            new_servers = client.find_servers()
-            self.assertEqual(len(new_servers) - len(servers) , 2)
-            self.assertFalse(new_app_uri1 in [s.ApplicationUri for s in servers])
-            self.assertFalse(new_app_uri2 in [s.ApplicationUri for s in servers])
-            self.assertTrue(new_app_uri1 in [s.ApplicationUri for s in new_servers])
-            self.assertTrue(new_app_uri2 in [s.ApplicationUri for s in new_servers])
-            # now do a query with filer
-            new_servers = client.find_servers(["urn:freeopcua:python:server"])
-            self.assertEqual(len(new_servers) - len(servers) , 0)
-            self.assertTrue(new_app_uri1 in [s.ApplicationUri for s in new_servers])
-            self.assertFalse(new_app_uri2 in [s.ApplicationUri for s in new_servers])
-            # now do a query with filer
-            new_servers = client.find_servers(["urn:freeopcua:python"])
-            self.assertEqual(len(new_servers) - len(servers) , 2)
-            self.assertTrue(new_app_uri1 in [s.ApplicationUri for s in new_servers])
-            self.assertTrue(new_app_uri2 in [s.ApplicationUri for s in new_servers])
-        finally:
-            client.disconnect()
-
-
-    """
-    # not sure if this test is necessary, and there is a lot repetition with previous test
-    def test_discovery_server_side(self):
-        servers = self.discovery.find_servers()
-        self.assertEqual(len(servers), 1)
-        self.srv.register_to_discovery(self.discovery.endpoint.geturl(), 1)
-        time.sleep(1) # let server register registration
-        servers = self.discovery.find_servers()
-        print("SERVERS 2", servers)
-        self.assertEqual(len(servers), 2)
-    """
-    #def test_register_server2(self):
-        #servers = self.opc.register_server()
-
-    def test_register_namespace(self):
-        uri = 'http://mycustom.Namespace.com'
-        idx1 = self.opc.register_namespace(uri)
-        idx2 = self.opc.get_namespace_index(uri)
-        self.assertEqual(idx1, idx2)
-
-    def test_register_use_namespace(self):
-        uri = 'http://my_very_custom.Namespace.com'
-        idx = self.opc.register_namespace(uri)
-        root = self.opc.get_root_node()
-        myvar = root.add_variable(idx, 'var_in_custom_namespace', [5])
-        myid = myvar.nodeid
-        self.assertEqual(idx, myid.NamespaceIndex)
 
-    def test_server_method(self):
-        def func(parent, variant):
-            variant.Value *= 2
-            return [variant]
-        o = self.opc.get_objects_node()
-        v = o.add_method(3, 'Method1', func, [ua.VariantType.Int64], [ua.VariantType.Int64])
-        result = o.call_method(v, ua.Variant(2.1))
-        self.assertEqual(result, 4.2)
 
-    def test_xml_import(self):
-        self.srv.import_xml("tests/custom_nodes.xml")
-        o = self.opc.get_objects_node()
-        v = o.get_child(["MyXMLFolder", "MyXMLObject", "MyXMLVariable"])
-        val = v.get_value()
-        self.assertEqual(val, "StringValue")
 
+from tests_cmd_lines import TestCmdLines
+from tests_server import TestServer
+from tests_client import TestClient
+from tests_unit import Unit
 
 
 if __name__ == '__main__':
-    logging.basicConfig(level=logging.WARN)
+    logging.basicConfig(level=logging.WARNING)
 
-    sclt = SubHandler()
     unittest.main(verbosity=3)

tests/tests_client.py

+import unittest
+
+from opcua import Client
+from opcua import Server
+from opcua import ua
+
+from tests_common import CommonTests, add_server_methods
+
+port_num1 = 48510
+
+
+class TestClient(unittest.TestCase, CommonTests):
+
+    '''
+    Run common tests on client side
+    Of course we need a server so we start a server in another
+    process using python Process module
+    Tests that can only be run on client side must be defined here
+    '''
+    @classmethod
+    def setUpClass(self):
+        # start our own server
+        self.srv = Server()
+        self.srv.set_endpoint('opc.tcp://localhost:%d' % port_num1)
+        add_server_methods(self.srv)
+        self.srv.start()
+
+        # start admin client
+        self.clt = Client('opc.tcp://admin@localhost:%d' % port_num1)
+        self.clt.connect()
+        self.opc = self.clt
+
+        # start anonymous client
+        self.ro_clt = Client('opc.tcp://localhost:%d' % port_num1)
+        self.ro_clt.connect()
+
+
+
+    @classmethod
+    def tearDownClass(self):
+        #stop our clients
+        self.ro_clt.disconnect()
+        self.clt.disconnect()
+        # stop the server 
+        self.srv.stop()
+
+    def test_service_fault(self):
+        request = ua.ReadRequest()
+        request.TypeId = ua.FourByteNodeId(999)  # bad type!
+        with self.assertRaises(ua.UaStatusCodeError):
+            self.clt.uaclient._uasocket.send_request(request)
+
+    def test_objects_anonymous(self):
+        objects = self.ro_clt.get_objects_node()
+        with self.assertRaises(ua.UaStatusCodeError):
+            objects.set_attribute(ua.AttributeIds.WriteMask, ua.DataValue(999))
+        with self.assertRaises(ua.UaStatusCodeError):
+            f = objects.add_folder(3, 'MyFolder')
+
+    def test_folder_anonymous(self):
+        objects = self.clt.get_objects_node()
+        f = objects.add_folder(3, 'MyFolderRO')
+        f_ro = self.ro_clt.get_node(f.nodeid)
+        self.assertEqual(f, f_ro)
+        with self.assertRaises(ua.UaStatusCodeError):
+            f2 = f_ro.add_folder(3, 'MyFolder2')
+
+    def test_variable_anonymous(self):
+        objects = self.clt.get_objects_node()
+        v = objects.add_variable(3, 'MyROVariable', 6)
+        v.set_value(4) #this should work
+        v_ro = self.ro_clt.get_node(v.nodeid)
+        with self.assertRaises(ua.UaStatusCodeError):
+            v_ro.set_value(2)
+        self.assertEqual(v_ro.get_value(), 4)
+        v.set_writable(True)
+        v_ro.set_value(2) #now it should work
+        self.assertEqual(v_ro.get_value(), 2)
+        v.set_writable(False)
+        with self.assertRaises(ua.UaStatusCodeError):
+            v_ro.set_value(9)
+        self.assertEqual(v_ro.get_value(), 2)
+
+

tests/tests_cmd_lines.py

+import unittest
+import subprocess
+
+from opcua import Server
+
+
+port_num = 48530
+
+
+class TestCmdLines(unittest.TestCase):
+
+    '''
+    Test command lines
+    '''
+    @classmethod
+    def setUpClass(self):
+        self.srv = Server()
+        self.srv_url = 'opc.tcp://localhost:%d' % port_num
+        self.srv.set_endpoint(self.srv_url)
+        objects = self.srv.get_objects_node()
+        obj = objects.add_object(4, "directory")
+        var = obj.add_variable(4, "variable", 1.999)
+        var2 = obj.add_variable(4, "variable2", 1.777)
+        var2.set_writable()
+        self.srv.start()
+
+    def test_uals(self):
+        s = subprocess.check_output(["python", "tools/uals", "--url", self.srv_url])
+        self.assertIn(b"i=85", s)
+        self.assertNotIn(b"i=89", s)
+        self.assertNotIn(b"1.999", s)
+        s = subprocess.check_output(["python", "tools/uals", "--url", self.srv_url, "-d", "3"])
+        self.assertIn(b"1.999", s)
+
+    def test_uaread(self):
+        s = subprocess.check_output(["python", "tools/uaread", "--url", self.srv_url, "--path", "0:Objects,4:directory,4:variable"])
+        self.assertIn(b"1.999", s)
+
+    def test_uawrite(self):
+        s = subprocess.check_output(["python", "tools/uawrite", "--url", self.srv_url, "--path", "0:Objects,4:directory,4:variable2", "1.789"])
+        s = subprocess.check_output(["python", "tools/uaread", "--url", self.srv_url, "--path", "0:Objects,4:directory,4:variable2"])
+        self.assertIn(b"1.789", s)
+        self.assertNotIn(b"1.999", s)
+
+    def test_uadiscover(self):
+        s = subprocess.check_output(["python", "tools/uadiscover", "--url", self.srv_url])
+        self.assertIn(b"opc.tcp://localhost", s)
+        self.assertIn(b"FreeOpcUa", s)
+        self.assertIn(b"urn:freeopcua:python:server", s)
+
+    @classmethod
+    def tearDownClass(self):
+        self.srv.stop()
+
+

tests/tests_common.py

+# encoding: utf-8
+from concurrent.futures import Future
+import time
+from datetime import datetime
+from datetime import timedelta
+import math
+
+from opcua import ua
+from opcua import Event
+from opcua import uamethod
+from opcua import Event
+
+
+def add_server_methods(srv):
+    @uamethod
+    def func(parent, value):
+        return value * 2
+
+    o = srv.get_objects_node()
+    v = o.add_method(ua.NodeId("ServerMethod", 2), ua.QualifiedName('ServerMethod', 2), func, [ua.VariantType.Int64], [ua.VariantType.Int64])
+
+    @uamethod
+    def func2(parent, methodname, value):
+        return math.sin(value)
+
+    o = srv.get_objects_node()
+    v = o.add_method(ua.NodeId("ServerMethodArray", 2), ua.QualifiedName('ServerMethodArray', 2), func2, [ua.VariantType.String, ua.VariantType.Int64], [ua.VariantType.Int64])
+
+    @uamethod
+    def func3(parent, mylist):
+        return [i * 2 for i in mylist]
+
+    o = srv.get_objects_node()
+    v = o.add_method(ua.NodeId("ServerMethodArray2", 2), ua.QualifiedName('ServerMethodArray2', 2), func3, [ua.VariantType.Int64], [ua.VariantType.Int64])
+
+
+class SubHandler():
+
+    '''
+        Dummy subscription client
+    '''
+
+    def datachange_notification(self, node, val, data):
+        pass
+
+    def event_notification(self, event):
+        pass
+
+
+class MySubHandlerDeprecated():
+
+    '''
+    More advanced subscription client using Future, so we can wait for events in tests
+    '''
+
+    def __init__(self):
+        self.future = Future()
+
+    def reset(self):
+        self.future = Future()
+
+    def data_change(self, handle, node, val, attr):
+        self.future.set_result((handle, node, val, attr))
+
+    def event(self, handle, event):
+        self.future.set_result((handle, event))
+
+class MySubHandler():
+
+    '''
+    More advanced subscription client using Future, so we can wait for events in tests
+    '''
+
+    def __init__(self):
+        self.future = Future()
+
+    def reset(self):
+        self.future = Future()
+
+    def datachange_notification(self, node, val, data):
+        self.future.set_result((node, val, data))
+
+    def event_notification(self, event):
+        self.future.set_result(event)
+
+
+class MySubHandler2():
+    def __init__(self):
+        self.results = [] 
+
+    def datachange_notification(self, node, val, data):
+        self.results.append((node, val))
+
+    def event_notification(self, event):
+        self.results.append(event)
+
+
+
+
+class CommonTests(object):
+
+    '''
+    Tests that will be run twice. Once on server side and once on
+    client side since we have been carefull to have the exact
+    same api on server and client side
+    '''
+    # jyst to avoid editor warnings
+    opc = None
+
+    def test_find_servers(self):
+        servers = self.opc.find_servers()
+        # FIXME : finish
+
+    def test_delete_nodes(self):
+        obj = self.opc.get_objects_node()
+        fold = obj.add_folder(2, "FolderToDelete")
+        var = fold.add_variable(2, "VarToDelete", 9.1)
+        childs = fold.get_children()
+        self.assertIn(var, childs)
+        self.opc.delete_nodes([var])
+        with self.assertRaises(ua.UaStatusCodeError):
+            var.set_value(7.8)
+        with self.assertRaises(ua.UaStatusCodeError):
+            obj.get_child(["2:FolderToDelete", "2:VarToDelete"])
+        childs = fold.get_children()
+        self.assertNotIn(var, childs)
+
+    def test_delete_nodes_recursive(self):
+        obj = self.opc.get_objects_node()
+        fold = obj.add_folder(2, "FolderToDeleteR")
+        var = fold.add_variable(2, "VarToDeleteR", 9.1)
+        self.opc.delete_nodes([fold, var])
+        with self.assertRaises(ua.UaStatusCodeError):
+            var.set_value(7.8)
+        with self.assertRaises(ua.UaStatusCodeError):
+            obj.get_child(["2:FolderToDelete", "2:VarToDelete"])
+
+    def test_delete_nodes_recursive2(self):
+        obj = self.opc.get_objects_node()
+        fold = obj.add_folder(2, "FolderToDeleteRoot")
+        nfold = fold
+        mynodes = []
+        for i in range(7):
+            nfold = fold.add_folder(2, "FolderToDeleteRoot")
+            var = fold.add_variable(2, "VarToDeleteR", 9.1)
+            var = fold.add_property(2, "ProToDeleteR", 9.1)
+            prop = fold.add_property(2, "ProToDeleteR", 9.1)
+            o = fold.add_object(3, "ObjToDeleteR")
+            mynodes.append(nfold)
+            mynodes.append(var)
+            mynodes.append(prop)
+            mynodes.append(o)
+        self.opc.delete_nodes([fold], recursive=True)
+        for node in mynodes:
+            with self.assertRaises(ua.UaStatusCodeError):
+                node.get_browse_name()
+
+    def test_server_node(self):
+        node = self.opc.get_server_node()
+        self.assertEqual(ua.QualifiedName('Server', 0), node.get_browse_name())
+
+    def test_root(self):
+        root = self.opc.get_root_node()
+        self.assertEqual(ua.QualifiedName('Root', 0), root.get_browse_name())
+        self.assertEqual(ua.LocalizedText('Root'), root.get_display_name())
+        nid = ua.NodeId(84, 0)
+        self.assertEqual(nid, root.nodeid)
+
+    def test_objects(self):
+        objects = self.opc.get_objects_node()
+        self.assertEqual(ua.QualifiedName('Objects', 0), objects.get_browse_name())
+        nid = ua.NodeId(85, 0)
+        self.assertEqual(nid, objects.nodeid)
+
+    def test_browse(self):
+        objects = self.opc.get_objects_node()
+        obj = objects.add_object(4, "browsetest")
+        folder = obj.add_folder(4, "folder")
+        prop = obj.add_property(4, "property", 1)
+        prop2 = obj.add_property(4, "property2", 2)
+        var = obj.add_variable(4, "variable", 3)
+        obj2 = obj.add_object(4, "obj")
+        alle = obj.get_children()
+        self.assertTrue(prop in alle)
+        self.assertTrue(prop2 in alle)
+        self.assertTrue(var in alle)
+        self.assertTrue(folder in alle)
+        self.assertFalse(obj in alle)
+        props = obj.get_children(refs=ua.ObjectIds.HasProperty)
+        self.assertTrue(prop in props)
+        self.assertTrue(prop2 in props)
+        self.assertFalse(var in props)
+        self.assertFalse(folder in props)
+        all_vars = obj.get_children(nodeclassmask=ua.NodeClass.Variable)
+        self.assertTrue(prop in all_vars)
+        self.assertTrue(var in all_vars)
+        all_objs = obj.get_children(nodeclassmask=ua.NodeClass.Object)
+        self.assertTrue(folder in all_objs)
+        self.assertTrue(obj2 in all_objs)
+        self.assertFalse(var in all_objs)
+
+    def test_browsename_with_spaces(self):
+        o = self.opc.get_objects_node()
+        v = o.add_variable(3, 'BNVariable with spaces and %&+?/', 1.3)
+        v2 = o.get_child("3:BNVariable with spaces and %&+?/")
+        self.assertEqual(v, v2)
+
+    def test_create_delete_subscription(self):
+        o = self.opc.get_objects_node()
+        v = o.add_variable(3, 'SubscriptionVariable', [1, 2, 3])
+        sub = self.opc.create_subscription(100, MySubHandler())
+        handle = sub.subscribe_data_change(v)
+        time.sleep(0.1)
+        sub.unsubscribe(handle)
+        sub.delete()
+
+    def test_subscribe_events(self):
+        sub = self.opc.create_subscription(100, MySubHandler())
+        handle = sub.subscribe_events()
+        time.sleep(0.1)
+        sub.unsubscribe(handle)
+        sub.delete()
+
+    def test_subscribe_events_to_wrong_node(self):
+        sub = self.opc.create_subscription(100, MySubHandler())
+        with self.assertRaises(ua.UaStatusCodeError):
+            handle = sub.subscribe_events(self.opc.get_node("i=85"))
+        o = self.opc.get_objects_node()
+        v = o.add_variable(3, 'VariableNoEventNofierAttribute', 4)
+        with self.assertRaises(ua.UaStatusCodeError):
+            handle = sub.subscribe_events(v)
+        sub.delete()
+
+    def test_events_deprecated(self):
+        msclt = MySubHandlerDeprecated()
+        sub = self.opc.create_subscription(100, msclt)
+        handle = sub.subscribe_events()
+
+        ev = Event(self.srv.iserver.isession)
+        msg = b"this is my msg "
+        ev.Message.Text = msg
+        tid = datetime.utcnow()
+        ev.Time = tid
+        ev.Severity = 500
+        ev.trigger()
+
+        clthandle, ev = msclt.future.result()
+        self.assertIsNot(ev, None)  # we did not receive event
+        self.assertEqual(ev.Message.Text, msg)
+        #self.assertEqual(msclt.ev.Time, tid)
+        self.assertEqual(ev.Severity, 500)
+        self.assertEqual(ev.SourceNode, self.opc.get_server_node().nodeid)
+
+        # time.sleep(0.1)
+        sub.unsubscribe(handle)
+        sub.delete()
+
+    def test_events(self):
+        msclt = MySubHandler()
+        sub = self.opc.create_subscription(100, msclt)
+        handle = sub.subscribe_events()
+
+        ev = Event(self.srv.iserver.isession)
+        msg = b"this is my msg "
+        ev.Message.Text = msg
+        tid = datetime.utcnow()
+        ev.Time = tid
+        ev.Severity = 500
+        ev.trigger()
+
+        ev = msclt.future.result()
+        self.assertIsNot(ev, None)  # we did not receive event
+        self.assertEqual(ev.Message.Text, msg)
+        #self.assertEqual(msclt.ev.Time, tid)
+        self.assertEqual(ev.Severity, 500)
+        self.assertEqual(ev.SourceNode, self.opc.get_server_node().nodeid)
+
+        # time.sleep(0.1)
+        sub.unsubscribe(handle)
+        sub.delete()
+
+    def test_non_existing_path(self):
+        root = self.opc.get_root_node()
+        with self.assertRaises(ua.UaStatusCodeError):
+            server_time_node = root.get_child(['0:Objects', '0:Server', '0:nonexistingnode'])
+
+    def test_bad_attribute(self):
+        root = self.opc.get_root_node()
+        with self.assertRaises(ua.UaStatusCodeError):
+            root.set_value(99)
+
+    def test_get_node_by_nodeid(self):
+        root = self.opc.get_root_node()
+        server_time_node = root.get_child(['0:Objects', '0:Server', '0:ServerStatus', '0:CurrentTime'])
+        correct = self.opc.get_node(ua.NodeId(ua.ObjectIds.Server_ServerStatus_CurrentTime))
+        self.assertEqual(server_time_node, correct)
+
+    def test_datetime_read(self):
+        time_node = self.opc.get_node(ua.NodeId(ua.ObjectIds.Server_ServerStatus_CurrentTime))
+        dt = time_node.get_value()
+        utcnow = datetime.utcnow()
+        delta = utcnow - dt
+        self.assertTrue(delta < timedelta(seconds=1))
+
+    def test_datetime_write(self):
+        time_node = self.opc.get_node(ua.NodeId(ua.ObjectIds.Server_ServerStatus_CurrentTime))
+        now = datetime.utcnow()
+        objects = self.opc.get_objects_node()
+        v1 = objects.add_variable(4, "test_datetime", now)
+        tid = v1.get_value()
+        self.assertEqual(now, tid)
+
+
+    def test_variant_array_dim(self):
+        objects = self.opc.get_objects_node()
+        l = [[[1.0, 1.0, 1.0, 1.0], [2.0, 2.0, 2.0, 2.0], [3.0, 3.0, 3.0, 3.0]],[[5.0, 5.0, 5.0, 5.0], [7.0, 8.0, 9.0, 01.0], [1.0, 1.0, 1.0, 1.0]]]
+        v = objects.add_variable(3, 'variableWithDims', l)
+        v2 = v.get_value()
+        self.assertEqual(v2, l)
+        dv = v.get_data_value()
+        self.assertEqual(dv.Value.Dimensions, [2,3,4])
+
+        l = [[[], [], []], [[], [], []]]
+        variant = ua.Variant(l, ua.VariantType.UInt32)
+        v = objects.add_variable(3, 'variableWithDimsEmpty', variant)
+        v2 = v.get_value()
+        self.assertEqual(v2, l)
+        dv = v.get_data_value()
+        self.assertEqual(dv.Value.Dimensions, [2,3,0])
+
+
+
+
+    def test_add_numeric_variable(self):
+        objects = self.opc.get_objects_node()
+        v = objects.add_variable('ns=3;i=888;', '3:numericnodefromstring', 99)
+        nid = ua.NodeId(888, 3)
+        qn = ua.QualifiedName('numericnodefromstring', 3)
+        self.assertEqual(nid, v.nodeid)
+        self.assertEqual(qn, v.get_browse_name())
+
+    def test_add_string_variable(self):
+        objects = self.opc.get_objects_node()
+        v = objects.add_variable('ns=3;s=stringid;', '3:stringnodefromstring', [68])
+        nid = ua.NodeId('stringid', 3)
+        qn = ua.QualifiedName('stringnodefromstring', 3)
+        self.assertEqual(nid, v.nodeid)
+        self.assertEqual(qn, v.get_browse_name())
+
+    def test_utf8(self):
+        objects = self.opc.get_objects_node()
+        utf_string = "æøå@%&"
+        bn = ua.QualifiedName(utf_string, 3) 
+        nid = ua.NodeId("æølå", 3)
+        val = "æøå"
+        v = objects.add_variable(nid, bn, val)
+        self.assertEqual(nid, v.nodeid)
+        val2 = v.get_value()
+        self.assertEqual(val, val2)
+        bn2 = v.get_browse_name()
+        self.assertEqual(bn, bn2)
+
+    def test_null_variable(self):
+        objects = self.opc.get_objects_node()
+        var = objects.add_variable(3, 'nullstring', "a string")
+        var.set_value(None)
+        val = var.get_value()
+        self.assertEqual(val, None)
+        var.set_value("")
+        val = var.get_value()
+        self.assertNotEqual(val, None)
+        self.assertEqual(val, "")
+
+    def test_variable_data_type(self):
+        objects = self.opc.get_objects_node()
+        var = objects.add_variable(3, 'stringfordatatype', "a string")
+        val = var.get_data_type()
+        self.assertEqual(val, ua.NodeId(ua.ObjectIds.String))
+        var = objects.add_variable(3, 'stringarrayfordatatype', ["a", "b"])
+        val = var.get_data_type()
+        self.assertEqual(val, ua.NodeId(ua.ObjectIds.String))
+
+    def test_add_string_array_variable(self):
+        objects = self.opc.get_objects_node()
+        v = objects.add_variable('ns=3;s=stringarrayid;', '9:stringarray', ['l', 'b'])
+        nid = ua.NodeId('stringarrayid', 3)
+        qn = ua.QualifiedName('stringarray', 9)
+        self.assertEqual(nid, v.nodeid)
+        self.assertEqual(qn, v.get_browse_name())
+        val = v.get_value()
+        self.assertEqual(['l', 'b'], val)
+
+    def test_add_numeric_node(self):
+        objects = self.opc.get_objects_node()
+        nid = ua.NodeId(9999, 3)
+        qn = ua.QualifiedName('AddNodeVar1', 3)
+        v1 = objects.add_variable(nid, qn, 0)
+        self.assertEqual(nid, v1.nodeid)
+        self.assertEqual(qn, v1.get_browse_name())
+
+    def test_add_string_node(self):
+        objects = self.opc.get_objects_node()
+        qn = ua.QualifiedName('AddNodeVar2', 3)
+        nid = ua.NodeId('AddNodeVar2Id', 3)
+        v2 = objects.add_variable(nid, qn, 0)
+        self.assertEqual(nid, v2.nodeid)
+        self.assertEqual(qn, v2.get_browse_name())
+
+    def test_add_find_node_(self):
+        objects = self.opc.get_objects_node()
+        o = objects.add_object('ns=2;i=101;', '2:AddFindObject')
+        o2 = objects.get_child('2:AddFindObject')
+        self.assertEqual(o, o2)
+
+    def test_node_path(self):
+        objects = self.opc.get_objects_node()
+        o = objects.add_object('ns=2;i=105;', '2:NodePathObject')
+        root = self.opc.get_root_node()
+        o2 = root.get_child(['0:Objects', '2:NodePathObject'])
+        self.assertEqual(o, o2)
+
+    def test_add_read_node(self):
+        objects = self.opc.get_objects_node()
+        o = objects.add_object('ns=2;i=102;', '2:AddReadObject')
+        nid = ua.NodeId(102, 2)
+        self.assertEqual(o.nodeid, nid)
+        qn = ua.QualifiedName('AddReadObject', 2)
+        self.assertEqual(o.get_browse_name(), qn)
+
+    def test_simple_value(self):
+        o = self.opc.get_objects_node()
+        v = o.add_variable(3, 'VariableTestValue', 4.32)
+        val = v.get_value()
+        self.assertEqual(4.32, val)
+
+    def test_add_exception(self):
+        objects = self.opc.get_objects_node()
+        o = objects.add_object('ns=2;i=103;', '2:AddReadObject')
+        with self.assertRaises(ua.UaStatusCodeError):
+            o2 = objects.add_object('ns=2;i=103;', '2:AddReadObject')
+
+    def test_negative_value(self):
+        o = self.opc.get_objects_node()
+        v = o.add_variable(3, 'VariableNegativeValue', 4)
+        v.set_value(-4.54)
+        val = v.get_value()
+        self.assertEqual(-4.54, val)
+
+    def test_read_server_state(self):
+        statenode = self.opc.get_node(ua.NodeId(ua.ObjectIds.Server_ServerStatus_State))
+        state = statenode.get_value()
+        self.assertEqual(state, 0)
+
+    def test_bad_node(self):
+        bad = self.opc.get_node(ua.NodeId(999, 999))
+        with self.assertRaises(ua.UaStatusCodeError):
+            bad.get_browse_name()
+        with self.assertRaises(ua.UaStatusCodeError):
+            bad.set_value(89)
+        with self.assertRaises(ua.UaStatusCodeError):
+            bad.add_object(0, "0:myobj")
+        with self.assertRaises(ua.UaStatusCodeError):
+            bad.get_child("0:myobj")
+
+    def test_value(self):
+        o = self.opc.get_objects_node()
+        var = ua.Variant(1.98, ua.VariantType.Double)
+        v = o.add_variable(3, 'VariableValue', var)
+        val = v.get_value()
+        self.assertEqual(1.98, val)
+
+        dvar = ua.DataValue(var)
+        dv = v.get_data_value()
+        self.assertEqual(ua.DataValue, type(dv))
+        self.assertEqual(dvar.Value, dv.Value)
+        self.assertEqual(dvar.Value, var)
+
+    def test_set_value(self):
+        o = self.opc.get_objects_node()
+        var = ua.Variant(1.98, ua.VariantType.Double)
+        dvar = ua.DataValue(var)
+        v = o.add_variable(3, 'VariableValue', var)
+        v.set_value(var.Value)
+        v1 = v.get_value()
+        self.assertEqual(v1, var.Value)
+        v.set_value(var)
+        v2 = v.get_value()
+        self.assertEqual(v2, var.Value)
+        v.set_data_value(dvar)
+        v3 = v.get_data_value()
+        self.assertEqual(v3.Value, dvar.Value)
+
+    def test_array_value(self):
+        o = self.opc.get_objects_node()
+        v = o.add_variable(3, 'VariableArrayValue', [1, 2, 3])
+        val = v.get_value()
+        self.assertEqual([1, 2, 3], val)
+
+    def test_bool_variable(self):
+        o = self.opc.get_objects_node()
+        v = o.add_variable(3, 'BoolVariable', True)
+        dt = v.get_data_type()
+        self.assertEqual(dt, ua.TwoByteNodeId(ua.ObjectIds.Boolean))
+        val = v.get_value()
+        self.assertEqual(True, val)
+        v.set_value(False)
+        val = v.get_value()
+        self.assertEqual(False, val)
+
+    def test_array_size_one_value(self):
+        o = self.opc.get_objects_node()
+        v = o.add_variable(3, 'VariableArrayValue', [1, 2, 3])
+        v.set_value([1])
+        val = v.get_value()
+        self.assertEqual([1], val)
+
+    def test_subscription_failure(self):
+        msclt = MySubHandler()
+        o = self.opc.get_objects_node()
+        sub = self.opc.create_subscription(100, msclt)
+        with self.assertRaises(ua.UaStatusCodeError):
+            handle1 = sub.subscribe_data_change(o) # we can only subscribe to variables so this should fail
+        sub.delete()
+
+    def test_subscription_overload(self):
+        nb = 10
+        msclt = MySubHandler()
+        o = self.opc.get_objects_node()
+        sub = self.opc.create_subscription(1, msclt)
+        variables = []
+        subs = []
+        for i in range(nb):
+            v = o.add_variable(3, 'SubscriptionVariableOverload' + str(i), 99)
+            variables.append(v)
+        for i in range(nb):
+            sub.subscribe_data_change(variables)
+        for i in range(nb):
+            for j in range(nb):
+                variables[i].set_value(j)
+            s = self.opc.create_subscription(1, msclt)
+            s.subscribe_data_change(variables)
+            subs.append(s)
+            sub.subscribe_data_change(variables[i])
+        for i in range(nb):
+            for j in range(nb):
+                variables[i].set_value(j)
+        sub.delete()
+        for s in subs:
+            s.delete()
+
+    def test_subscription_overload_simple(self):
+        nb = 10
+        msclt = MySubHandler()
+        o = self.opc.get_objects_node()
+        sub = self.opc.create_subscription(1, msclt)
+        variables = [o.add_variable(3, 'SubVarOverload' + str(i), i) for i in range(nb)]
+        for i in range(nb):
+            sub.subscribe_data_change(variables)
+        sub.delete()
+
+    def test_subscription_data_change_depcrecated(self):
+        '''
+        test subscriptions. This is far too complicated for
+        a unittest but, setting up subscriptions requires a lot
+        of code, so when we first set it up, it is best
+        to test as many things as possible
+        '''
+        msclt = MySubHandlerDeprecated()
+
+        o = self.opc.get_objects_node()
+
+        # subscribe to a variable
+        startv1 = [1, 2, 3]
+        v1 = o.add_variable(3, 'SubscriptionVariableDeprecatedV1', startv1)
+        sub = self.opc.create_subscription(100, msclt)
+        handle1 = sub.subscribe_data_change(v1)
+
+        # Now check we get the start value
+        clthandle, node, val, attr = msclt.future.result()
+        self.assertEqual(val, startv1)
+        self.assertEqual(node, v1)
+
+        msclt.reset()  # reset future object
+
+        # modify v1 and check we get value
+        v1.set_value([5])
+        clthandle, node, val, attr = msclt.future.result()
+
+        self.assertEqual(node, v1)
+        self.assertEqual(val, [5])
+
+        with self.assertRaises(ua.UaStatusCodeError):
+            sub.unsubscribe(999)  # non existing handle
+        sub.unsubscribe(handle1)
+        with self.assertRaises(ua.UaStatusCodeError):
+            sub.unsubscribe(handle1)  # second try should fail
+        sub.delete()
+        with self.assertRaises(ua.UaStatusCodeError):
+            sub.unsubscribe(handle1)  # sub does not exist anymore
+
+    def test_subscription_data_change(self):
+        '''
+        test subscriptions. This is far too complicated for
+        a unittest but, setting up subscriptions requires a lot
+        of code, so when we first set it up, it is best
+        to test as many things as possible
+        '''
+        msclt = MySubHandler()
+
+        o = self.opc.get_objects_node()
+
+        # subscribe to a variable
+        startv1 = [1, 2, 3]
+        v1 = o.add_variable(3, 'SubscriptionVariableV1', startv1)
+        sub = self.opc.create_subscription(100, msclt)
+        handle1 = sub.subscribe_data_change(v1)
+
+        # Now check we get the start value
+        node, val, data = msclt.future.result()
+        self.assertEqual(val, startv1)
+        self.assertEqual(node, v1)
+
+        msclt.reset()  # reset future object
+
+        # modify v1 and check we get value
+        v1.set_value([5])
+        node, val, data = msclt.future.result()
+
+        self.assertEqual(node, v1)
+        self.assertEqual(val, [5])
+
+        with self.assertRaises(ua.UaStatusCodeError):
+            sub.unsubscribe(999)  # non existing handle
+        sub.unsubscribe(handle1)
+        with self.assertRaises(ua.UaStatusCodeError):
+            sub.unsubscribe(handle1)  # second try should fail
+        sub.delete()
+        with self.assertRaises(ua.UaStatusCodeError):
+            sub.unsubscribe(handle1)  # sub does not exist anymore
+
+
+    def test_subscription_data_change_bool(self):
+        '''
+        test subscriptions. This is far too complicated for
+        a unittest but, setting up subscriptions requires a lot
+        of code, so when we first set it up, it is best
+        to test as many things as possible
+        '''
+        msclt = MySubHandler()
+
+        o = self.opc.get_objects_node()
+
+        # subscribe to a variable
+        startv1 = True 
+        v1 = o.add_variable(3, 'SubscriptionVariableBool', startv1)
+        sub = self.opc.create_subscription(100, msclt)
+        handle1 = sub.subscribe_data_change(v1)
+
+        # Now check we get the start value
+        node, val, data = msclt.future.result()
+        self.assertEqual(val, startv1)
+        self.assertEqual(node, v1)
+
+        msclt.reset()  # reset future object
+
+        # modify v1 and check we get value
+        v1.set_value(False)
+        node, val, data = msclt.future.result()
+        self.assertEqual(node, v1)
+        self.assertEqual(val, False)
+
+        sub.delete() # should delete our monitoreditem too
+
+    def test_subscription_data_change_many(self):
+        '''
+        test subscriptions. This is far too complicated for
+        a unittest but, setting up subscriptions requires a lot
+        of code, so when we first set it up, it is best
+        to test as many things as possible
+        '''
+        msclt = MySubHandler2()
+        o = self.opc.get_objects_node()
+
+        startv1 = True 
+        v1 = o.add_variable(3, 'SubscriptionVariableMany1', startv1)
+        startv2 = [1.22, 1.65] 
+        v2 = o.add_variable(3, 'SubscriptionVariableMany2', startv2)
+
+        sub = self.opc.create_subscription(100, msclt)
+        handle1, handle2 = sub.subscribe_data_change([v1, v2])
+
+        # Now check we get the start values
+        nodes = [v1, v2]
+       
+        count = 0
+        while not len(msclt.results) > 1:
+            count += 1
+            time.sleep(0.1)
+            if count > 100:
+                self.fail("Did not get result from subscription")
+        for node, val in msclt.results:
+            self.assertIn(node, nodes)
+            nodes.remove(node)
+            if node == v1:
+                self.assertEqual(startv1, val)
+            elif node == v2:
+                self.assertEqual(startv2, val)
+            else:
+                self.fail("Error node {} is neither {} nor {}".format(node, v1, v2))
+
+        sub.delete() 
+
+    def test_subscribe_server_time(self):
+        msclt = MySubHandler()
+
+        server_time_node = self.opc.get_node(ua.NodeId(ua.ObjectIds.Server_ServerStatus_CurrentTime))
+
+        sub = self.opc.create_subscription(200, msclt)
+        handle = sub.subscribe_data_change(server_time_node)
+
+        node, val, data = msclt.future.result()
+        self.assertEqual(node, server_time_node)
+        delta = datetime.utcnow() - val
+        self.assertTrue(delta < timedelta(seconds=2))
+
+        sub.unsubscribe(handle)
+        sub.delete()
+
+    def test_use_namespace(self):
+        idx = self.opc.get_namespace_index("urn:freeopcua:python:server")
+        self.assertEqual(idx, 1)
+        root = self.opc.get_root_node()
+        myvar = root.add_variable(idx, 'var_in_custom_namespace', [5])
+        myid = myvar.nodeid
+        self.assertEqual(idx, myid.NamespaceIndex)
+
+    def test_method(self):
+        o = self.opc.get_objects_node()
+        m = o.get_child("2:ServerMethod")
+        result = o.call_method("2:ServerMethod", 2.1)
+        self.assertEqual(result, 4.2)
+        with self.assertRaises(ua.UaStatusCodeError):
+            # FIXME: we should raise a more precise exception
+            result = o.call_method("2:ServerMethod", 2.1, 89, 9)
+        with self.assertRaises(ua.UaStatusCodeError):
+            result = o.call_method(ua.NodeId(999), 2.1)  # non existing method
+
+    def test_method_array(self):
+        o = self.opc.get_objects_node()
+        m = o.get_child("2:ServerMethodArray")
+        result = o.call_method(m, "sin", ua.Variant(math.pi))
+        self.assertTrue(result < 0.01)
+
+    def test_method_array2(self):
+        o = self.opc.get_objects_node()
+        m = o.get_child("2:ServerMethodArray2")
+        result = o.call_method(m, [1.1, 3.4, 9])
+        self.assertEqual(result, [2.2, 6.8, 18])
+
+    def test_add_nodes(self):
+        objects = self.opc.get_objects_node()
+        f = objects.add_folder(3, 'MyFolder')
+        v = f.add_variable(3, 'MyVariable', 6)
+        p = f.add_property(3, 'MyProperty', 10)
+        childs = f.get_children()
+        self.assertTrue(v in childs)
+        self.assertTrue(p in childs)
+
+    def test_get_endpoints(self):
+        endpoints = self.opc.get_endpoints()
+        self.assertTrue(len(endpoints) > 0)
+        self.assertTrue(endpoints[0].EndpointUrl.startswith("opc.tcp://"))
+
+

tests/tests_server.py

+import unittest
+from tests_common import CommonTests, add_server_methods
+import time
+
+from opcua import Server
+from opcua import Client
+from opcua import ua
+
+
+port_num = 485140
+port_discovery = 48550
+
+
+class TestServer(unittest.TestCase, CommonTests):
+
+    '''
+    Run common tests on server side
+    Tests that can only be run on server side must be defined here
+    '''
+    @classmethod
+    def setUpClass(self):
+        self.srv = Server()
+        self.srv.set_endpoint('opc.tcp://localhost:%d' % port_num)
+        add_server_methods(self.srv)
+        self.srv.start()
+        self.opc = self.srv
+        self.discovery = Server()
+        self.discovery.set_application_uri("urn:freeopcua:python:discovery")
+        self.discovery.set_endpoint('opc.tcp://localhost:%d' % port_discovery)
+        self.discovery.start()
+
+    @classmethod
+    def tearDownClass(self):
+        self.srv.stop()
+        self.discovery.stop()
+
+    def test_discovery(self):
+        client = Client(self.discovery.endpoint.geturl())
+        client.connect()
+        try:
+            servers = client.find_servers()
+            new_app_uri = "urn:freeopcua:python:server:test_discovery"
+            self.srv.application_uri = new_app_uri
+            self.srv.register_to_discovery(self.discovery.endpoint.geturl(), 0)
+            time.sleep(0.1) # let server register registration
+            new_servers = client.find_servers()
+            self.assertEqual(len(new_servers) - len(servers) , 1)
+            self.assertFalse(new_app_uri in [s.ApplicationUri for s in servers])
+            self.assertTrue(new_app_uri in [s.ApplicationUri for s in new_servers])
+        finally:
+            client.disconnect()
+    
+    def test_find_servers2(self):
+        client = Client(self.discovery.endpoint.geturl())
+        client.connect()
+        try:
+            servers = client.find_servers()
+            new_app_uri1 = "urn:freeopcua:python:server:test_discovery1"
+            self.srv.application_uri = new_app_uri1
+            self.srv.register_to_discovery(self.discovery.endpoint.geturl(), period=0)
+            new_app_uri2 = "urn:freeopcua:python:test_discovery2"
+            self.srv.application_uri = new_app_uri2
+            self.srv.register_to_discovery(self.discovery.endpoint.geturl(), period=0)
+            time.sleep(0.1) # let server register registration
+            new_servers = client.find_servers()
+            self.assertEqual(len(new_servers) - len(servers) , 2)
+            self.assertFalse(new_app_uri1 in [s.ApplicationUri for s in servers])
+            self.assertFalse(new_app_uri2 in [s.ApplicationUri for s in servers])
+            self.assertTrue(new_app_uri1 in [s.ApplicationUri for s in new_servers])
+            self.assertTrue(new_app_uri2 in [s.ApplicationUri for s in new_servers])
+            # now do a query with filer
+            new_servers = client.find_servers(["urn:freeopcua:python:server"])
+            self.assertEqual(len(new_servers) - len(servers) , 0)
+            self.assertTrue(new_app_uri1 in [s.ApplicationUri for s in new_servers])
+            self.assertFalse(new_app_uri2 in [s.ApplicationUri for s in new_servers])
+            # now do a query with filer
+            new_servers = client.find_servers(["urn:freeopcua:python"])
+            self.assertEqual(len(new_servers) - len(servers) , 2)
+            self.assertTrue(new_app_uri1 in [s.ApplicationUri for s in new_servers])
+            self.assertTrue(new_app_uri2 in [s.ApplicationUri for s in new_servers])
+        finally:
+            client.disconnect()
+
+
+    """
+    # not sure if this test is necessary, and there is a lot repetition with previous test
+    def test_discovery_server_side(self):
+        servers = self.discovery.find_servers()
+        self.assertEqual(len(servers), 1)
+        self.srv.register_to_discovery(self.discovery.endpoint.geturl(), 1)
+        time.sleep(1) # let server register registration
+        servers = self.discovery.find_servers()
+        print("SERVERS 2", servers)
+        self.assertEqual(len(servers), 2)
+    """
+    #def test_register_server2(self):
+        #servers = self.opc.register_server()
+
+    def test_register_namespace(self):
+        uri = 'http://mycustom.Namespace.com'
+        idx1 = self.opc.register_namespace(uri)
+        idx2 = self.opc.get_namespace_index(uri)
+        self.assertEqual(idx1, idx2)
+
+    def test_register_use_namespace(self):
+        uri = 'http://my_very_custom.Namespace.com'
+        idx = self.opc.register_namespace(uri)
+        root = self.opc.get_root_node()
+        myvar = root.add_variable(idx, 'var_in_custom_namespace', [5])
+        myid = myvar.nodeid
+        self.assertEqual(idx, myid.NamespaceIndex)
+
+    def test_server_method(self):
+        def func(parent, variant):
+            variant.Value *= 2
+            return [variant]
+        o = self.opc.get_objects_node()
+        v = o.add_method(3, 'Method1', func, [ua.VariantType.Int64], [ua.VariantType.Int64])
+        result = o.call_method(v, ua.Variant(2.1))
+        self.assertEqual(result, 4.2)
+
+    def test_xml_import(self):
+        self.srv.import_xml("tests/custom_nodes.xml")
+        o = self.opc.get_objects_node()
+        v = o.get_child(["MyXMLFolder", "MyXMLObject", "MyXMLVariable"])
+        val = v.get_value()
+        self.assertEqual(val, "StringValue")
+
+
+

tests/tests_unit.py

+# encoding: utf-8
+#! /usr/bin/env python
+import logging
+import io
+from datetime import datetime
+import unittest
+
+from opcua import ua
+from opcua.ua import extensionobject_from_binary
+from opcua.ua import extensionobject_to_binary
+from opcua.ua.uatypes import flatten, get_shape, reshape
+
+
+
+class Unit(unittest.TestCase):
+
+    '''
+    Simple unit test that do not need to setup a server or a client
+    '''
+
+    def test_variant_dimensions(self):
+        l = [[[1.0, 1.0, 1.0, 1.0], [2.0, 2.0, 2.0, 2.0], [3.0, 3.0, 3.0, 3.0]],[[5.0, 5.0, 5.0, 5.0], [7.0, 8.0, 9.0, 01.0], [1.0, 1.0, 1.0, 1.0]]]
+        v = ua.Variant(l)
+        self.assertEqual(v.Dimensions, [2, 3, 4])
+        v2 = ua.Variant.from_binary(ua.utils.Buffer(v.to_binary()))
+        self.assertEqual(v, v2)
+        self.assertEqual(v.Dimensions, v2.Dimensions)
+        
+        # very special case
+        l = [[[], [], []], [[], [], []]]
+        v = ua.Variant(l, ua.VariantType.UInt32)
+        self.assertEqual(v.Dimensions, [2, 3, 0])
+        v2 = ua.Variant.from_binary(ua.utils.Buffer(v.to_binary()))
+        self.assertEqual(v.Dimensions, v2.Dimensions)
+        self.assertEqual(v, v2)
+
+    def test_flatten(self):
+        l = [[[1.0, 1.0, 1.0, 1.0], [1.0, 1.0, 1.0, 1.0], [1.0, 1.0, 1.0, 1.0]],[[1.0, 1.0, 1.0, 1.0], [1.0, 1.0, 1.0, 1.0], [1.0, 1.0, 1.0, 1.0]]]
+        l2 = flatten(l)
+        dims = get_shape(l)
+        self.assertEqual(dims, [2, 3, 4])
+        self.assertNotEqual(l, l2)
+
+        l3 = reshape(l2, (2,3,4))
+        self.assertEqual(l, l3)
+
+
+        l = [[[], [], []], [[], [], []]]
+        l2 = flatten(l)
+        dims = get_shape(l)
+        self.assertEqual(dims, [2, 3, 0])
+
+        l = [1, 2, 3, 4]
+        l2 = flatten(l)
+        dims = get_shape(l)
+        self.assertEqual(dims, [4])
+        self.assertEqual(l, l2)
+
+    def test_custom_variant(self):
+        with self.assertRaises(ua.UaError):
+            v = ua.Variant(b"ljsdfljds", ua.VariantTypeCustom(89))
+        v = ua.Variant(b"ljsdfljds", ua.VariantTypeCustom(61))
+        v2 = ua.Variant.from_binary(ua.utils.Buffer(v.to_binary()))
+        self.assertEqual(v.VariantType, v2.VariantType)
+        self.assertEqual(v, v2)
+
+
+    def test_custom_variant_array(self):
+        v = ua.Variant([b"ljsdfljds", b"lkjsdljksdf"], ua.VariantTypeCustom(40))
+        v2 = ua.Variant.from_binary(ua.utils.Buffer(v.to_binary()))
+        self.assertEqual(v.VariantType, v2.VariantType)
+        self.assertEqual(v, v2)
+
+    def test_guid(self):
+        g = ua.Guid()
+        sc = ua.StatusCode()
+
+    def test_nodeid(self):
+        nid = ua.NodeId()
+        self.assertEqual(nid.NodeIdType, ua.NodeIdType.TwoByte)
+        nid = ua.NodeId(446, 3, ua.NodeIdType.FourByte)
+        self.assertEqual(nid.NodeIdType, ua.NodeIdType.FourByte)
+        d = nid.to_binary()
+        new_nid = nid.from_binary(io.BytesIO(d))
+        self.assertEqual(new_nid, nid)
+        self.assertEqual(new_nid.NodeIdType, ua.NodeIdType.FourByte)
+        self.assertEqual(new_nid.Identifier, 446)
+        self.assertEqual(new_nid.NamespaceIndex, 3)
+
+        tb = ua.TwoByteNodeId(53)
+        fb = ua.FourByteNodeId(53)
+        n = ua.NumericNodeId(53)
+        n1 = ua.NumericNodeId(53, 0)
+        s = ua.StringNodeId(53, 0)  # should we raise an exception???
+        s1 = ua.StringNodeId("53", 0)
+        bs = ua.ByteStringNodeId(b"53", 0)
+        gid = ua.Guid()
+        g = ua.ByteStringNodeId(gid, 0)
+        guid = ua.GuidNodeId(gid)
+        self.assertEqual(tb, fb)
+        self.assertEqual(tb, n)
+        self.assertEqual(tb, n1)
+        self.assertEqual(n1, fb)
+        self.assertNotEqual(n1, s)
+        self.assertNotEqual(s, bs)
+        self.assertNotEqual(s, g)
+        self.assertNotEqual(g, guid)
+        self.assertEqual(tb, ua.NodeId.from_binary(ua.utils.Buffer(tb.to_binary())))
+        self.assertEqual(fb, ua.NodeId.from_binary(ua.utils.Buffer(fb.to_binary())))
+        self.assertEqual(n, ua.NodeId.from_binary(ua.utils.Buffer(n.to_binary())))
+        self.assertEqual(s1, ua.NodeId.from_binary(ua.utils.Buffer(s1.to_binary())))
+        self.assertEqual(bs, ua.NodeId.from_binary(ua.utils.Buffer(bs.to_binary())))
+        self.assertEqual(guid, ua.NodeId.from_binary(ua.utils.Buffer(guid.to_binary())))
+
+    def test_nodeid_string(self):
+        nid0 = ua.NodeId(45)
+        self.assertEqual(nid0, ua.NodeId.from_string("i=45"))
+        self.assertEqual(nid0, ua.NodeId.from_string("ns=0;i=45"))
+        nid = ua.NodeId(45, 10)
+        self.assertEqual(nid, ua.NodeId.from_string("i=45; ns=10"))
+        self.assertNotEqual(nid, ua.NodeId.from_string("i=45; ns=11"))
+        self.assertNotEqual(nid, ua.NodeId.from_string("i=5; ns=10"))
+        # not sure the next one is correct...
+        self.assertEqual(nid, ua.NodeId.from_string("i=45; ns=10; srv=serverid"))
+        
+        nid1 = ua.NodeId("myid.mynodeid", 7)
+        self.assertEqual(nid1, ua.NodeId.from_string("ns=7; s=myid.mynodeid"))
+        with self.assertRaises(ua.UaError):
+            nid1 = ua.NodeId(7, "myid.mynodeid")
+
+    def test_bad_string(self):
+        with self.assertRaises(ua.UaStringParsingError):
+            ua.NodeId.from_string("ns=r;s=yu")
+        with self.assertRaises(ua.UaStringParsingError):
+            ua.NodeId.from_string("i=r;ns=1")
+        with self.assertRaises(ua.UaStringParsingError):
+            ua.NodeId.from_string("ns=1")
+        with self.assertRaises(ua.UaError):
+            ua.QualifiedName.from_string("i:yu")
+        with self.assertRaises(ua.UaError):
+            ua.QualifiedName.from_string("i:::yu")
+
+
+    def test_expandednodeid(self):
+        nid = ua.ExpandedNodeId()
+        self.assertEqual(nid.NodeIdType, ua.NodeIdType.TwoByte)
+        nid2 = ua.ExpandedNodeId.from_binary(ua.utils.Buffer(nid.to_binary()))
+        self.assertEqual(nid, nid2)
+
+    def test_extension_object(self):
+        obj = ua.UserNameIdentityToken()
+        obj.UserName = "admin"
+        obj.Password = b"pass"
+        obj2 = ua.extensionobject_from_binary(ua.utils.Buffer(extensionobject_to_binary(obj)))
+        self.assertEqual(type(obj), type(obj2))
+        self.assertEqual(obj.UserName, obj2.UserName)
+        self.assertEqual(obj.Password, obj2.Password)
+        v1 = ua.Variant(obj)
+        v2 = ua.Variant.from_binary(ua.utils.Buffer(v1.to_binary()))
+        self.assertEqual(type(v1), type(v2))
+        self.assertEqual(v1.VariantType, v2.VariantType)
+
+    def test_unknown_extension_object(self):
+        obj = ua.ExtensionObject()
+        obj.Body = b'example of data in custom format'
+        obj.TypeId = ua.NodeId.from_string('ns=3;i=42')
+        data = ua.utils.Buffer(extensionobject_to_binary(obj))
+        obj2 = ua.extensionobject_from_binary(data)
+        self.assertEqual(type(obj2), ua.ExtensionObject)
+        self.assertEqual(obj2.TypeId, obj.TypeId)
+        self.assertEqual(obj2.Body, b'example of data in custom format')
+
+    def test_datetime(self):
+        now = datetime.utcnow()
+        epch = ua.datetime_to_win_epoch(now)
+        dt = ua.win_epoch_to_datetime(epch)
+        self.assertEqual(now, dt)
+
+        # python's datetime has a range from Jan 1, 0001 to the end of year 9999
+        # windows' filetime has a range from Jan 1, 1601 to approx. year 30828
+        # let's test an overlapping range [Jan 1, 1601 - Dec 31, 9999]
+        dt = datetime(1601, 1, 1)
+        self.assertEqual(ua.win_epoch_to_datetime(ua.datetime_to_win_epoch(dt)), dt)
+        dt = datetime(9999, 12, 31, 23, 59, 59)
+        self.assertEqual(ua.win_epoch_to_datetime(ua.datetime_to_win_epoch(dt)), dt)
+
+        epch = 128930364000001000
+        dt = ua.win_epoch_to_datetime(epch)
+        epch2 = ua.datetime_to_win_epoch(dt)
+        self.assertEqual(epch, epch2)
+
+        epch = 0
+        self.assertEqual(ua.datetime_to_win_epoch(ua.win_epoch_to_datetime(epch)), epch)
+
+    def test_equal_nodeid(self):
+        nid1 = ua.NodeId(999, 2)
+        nid2 = ua.NodeId(999, 2)
+        self.assertTrue(nid1 == nid2)
+        self.assertTrue(id(nid1) != id(nid2))
+
+    def test_zero_nodeid(self):
+        self.assertEqual(ua.NodeId(), ua.NodeId(0, 0))
+        self.assertEqual(ua.NodeId(), ua.NodeId.from_string('ns=0;i=0;'))
+
+    def test_string_nodeid(self):
+        nid = ua.NodeId('titi', 1)
+        self.assertEqual(nid.NamespaceIndex, 1)
+        self.assertEqual(nid.Identifier, 'titi')
+        self.assertEqual(nid.NodeIdType, ua.NodeIdType.String)
+
+    def test_unicode_string_nodeid(self):
+        nid = ua.NodeId('hëllò', 1)
+        self.assertEqual(nid.NamespaceIndex, 1)
+        self.assertEqual(nid.Identifier, 'hëllò')
+        self.assertEqual(nid.NodeIdType, ua.NodeIdType.String)
+        d = nid.to_binary()
+        new_nid = nid.from_binary(io.BytesIO(d))
+        self.assertEqual(new_nid, nid)
+        self.assertEqual(new_nid.Identifier, 'hëllò')
+        self.assertEqual(new_nid.NodeIdType, ua.NodeIdType.String)
+
+    def test_numeric_nodeid(self):
+        nid = ua.NodeId(999, 2)
+        self.assertEqual(nid.NamespaceIndex, 2)
+        self.assertEqual(nid.Identifier, 999)
+        self.assertEqual(nid.NodeIdType, ua.NodeIdType.Numeric)
+
+    def test_qualifiedstring_nodeid(self):
+        nid = ua.NodeId.from_string('ns=2;s=PLC1.Manufacturer;')
+        self.assertEqual(nid.NamespaceIndex, 2)
+        self.assertEqual(nid.Identifier, 'PLC1.Manufacturer')
+
+    def test_strrepr_nodeid(self):
+        nid = ua.NodeId.from_string('ns=2;s=PLC1.Manufacturer;')
+        self.assertEqual(nid.to_string(), 'ns=2;s=PLC1.Manufacturer')
+        #self.assertEqual(repr(nid), 'ns=2;s=PLC1.Manufacturer;')
+
+    def test_qualified_name(self):
+        qn = ua.QualifiedName('qname', 2)
+        self.assertEqual(qn.NamespaceIndex, 2)
+        self.assertEqual(qn.Name, 'qname')
+        self.assertEqual(qn.to_string(), '2:qname')
+
+    def test_datavalue(self):
+        dv = ua.DataValue(123)
+        self.assertEqual(dv.Value, ua.Variant(123))
+        self.assertEqual(type(dv.Value), ua.Variant)
+        dv = ua.DataValue('abc')
+        self.assertEqual(dv.Value, ua.Variant('abc'))
+        now = datetime.utcnow()
+        dv.SourceTimestamp = now
+
+    def test_variant(self):
+        dv = ua.Variant(True, ua.VariantType.Boolean)
+        self.assertEqual(dv.Value, True)
+        self.assertEqual(type(dv.Value), bool)
+        now = datetime.utcnow()
+        v = ua.Variant(now)
+        self.assertEqual(v.Value, now)
+        self.assertEqual(v.VariantType, ua.VariantType.DateTime)
+        v2 = ua.Variant.from_binary(ua.utils.Buffer(v.to_binary()))
+        self.assertEqual(v.Value, v2.Value)
+        self.assertEqual(v.VariantType, v2.VariantType)
+        # commonity method:
+        self.assertEqual(v, ua.Variant(v))
+
+    def test_variant_array(self):
+        v = ua.Variant([1, 2, 3, 4, 5])
+        self.assertEqual(v.Value[1], 2)
+        # self.assertEqual(v.VarianType, ua.VariantType.Int64) # we do not care, we should aonly test for sutff that matter
+        v2 = ua.Variant.from_binary(ua.utils.Buffer(v.to_binary()))
+        self.assertEqual(v.Value, v2.Value)
+        self.assertEqual(v.VariantType, v2.VariantType)
+
+        now = datetime.utcnow()
+        v = ua.Variant([now])
+        self.assertEqual(v.Value[0], now)
+        self.assertEqual(v.VariantType, ua.VariantType.DateTime)
+        v2 = ua.Variant.from_binary(ua.utils.Buffer(v.to_binary()))
+        self.assertEqual(v.Value, v2.Value)
+        self.assertEqual(v.VariantType, v2.VariantType)
+
+    def test_variant_array_dim(self):
+        v = ua.Variant([1, 2, 3, 4, 5, 6], dimensions = [2, 3])
+        self.assertEqual(v.Value[1], 2)
+        v2 = ua.Variant.from_binary(ua.utils.Buffer(v.to_binary()))
+        self.assertEqual(reshape(v.Value, (2,3)), v2.Value)
+        self.assertEqual(v.VariantType, v2.VariantType)
+        self.assertEqual(v.Dimensions, v2.Dimensions)
+        self.assertEqual(v2.Dimensions, [2, 3])
+
+    def test_text(self):
+        t1 = ua.LocalizedText('Root')
+        t2 = ua.LocalizedText('Root')
+        t3 = ua.LocalizedText('root')
+        self.assertEqual(t1, t2)
+        self.assertNotEqual(t1, t3)
+        t4 = ua.LocalizedText.from_binary(ua.utils.Buffer(t1.to_binary()))
+        self.assertEqual(t1, t4)
+
+    def test_message_chunk(self):
+        pol = ua.SecurityPolicy()
+        chunks = ua.MessageChunk.message_to_chunks(pol, b'123', 65536)
+        self.assertEqual(len(chunks), 1)
+        seq = 0
+        for chunk in chunks:
+            seq += 1
+            chunk.SequenceHeader.SequenceNumber = seq
+        chunk2 = ua.MessageChunk.from_binary(pol, ua.utils.Buffer(chunks[0].to_binary()))
+        self.assertEqual(chunks[0].to_binary(), chunk2.to_binary())
+
+        # for policy None, MessageChunk overhead is 12+4+8 = 24 bytes
+        # Let's pack 11 bytes into 28-byte chunks. The message must be split as 4+4+3
+        chunks = ua.MessageChunk.message_to_chunks(pol, b'12345678901', 28)
+        self.assertEqual(len(chunks), 3)
+        self.assertEqual(chunks[0].Body, b'1234')
+        self.assertEqual(chunks[1].Body, b'5678')
+        self.assertEqual(chunks[2].Body, b'901')
+        for chunk in chunks:
+            seq += 1
+            chunk.SequenceHeader.SequenceNumber = seq
+            self.assertTrue(len(chunk.to_binary()) <= 28)
+
+
+if __name__ == '__main__':
+    logging.basicConfig(level=logging.WARN)
+
+    sclt = SubHandler()
+    unittest.main(verbosity=3)