Add simple pytest tests

pytest.ini

@@ -0,0 +1,3 @@
+[pytest]
+testpaths =
+    tests

tests/test_messages.py

@@ -0,0 +1,126 @@
+
+from oxenmq import OxenMQ, Message, LogLevel, AuthLevel, Address
+import random
+import string
+from datetime import datetime, timedelta
+import time
+import pytest
+
+
+def echo(m: Message):
+    return 'Hi!', m.data()
+
+
+def ohce(m: Message):
+    return [bytes(reversed(x)) for x in reversed(m.data())], '!iH'
+
+
+@pytest.fixture(autouse=True)
+def zmq_address():
+    import os
+    sock = './' + ''.join(random.choices(string.ascii_letters, k=20)) + '.sock'
+    addr = 'ipc://' + sock
+    yield addr
+    os.remove(sock)
+
+
+def make_omqs(zmq_addr, start=True):
+    omq1 = OxenMQ(log_level=LogLevel.trace)
+
+    addr = Address(zmq_addr, omq1.pubkey)
+
+    omq1.listen(addr.zmq_address, curve=True)
+
+    omq1.add_category('cat', AuthLevel.none) \
+        .add_request_command('echo', echo) \
+        .add_request_command('ohce', ohce)
+
+    omq2 = OxenMQ(log_level=LogLevel.trace)
+
+    if start:
+        omq1.start()
+        omq2.start()
+
+    return omq1, omq2, addr
+
+
+def test_requests(zmq_address):
+    omq1, omq2, addr = make_omqs(zmq_address)
+
+    reply1, reply2 = None, None
+
+    def on_reply1(r):
+        nonlocal reply1
+        reply1 = [x.tobytes().decode() for x in r]
+
+    def on_reply2(r):
+        nonlocal reply2
+        reply2 = [x.tobytes().decode() for x in r]
+
+    c1 = omq2.connect_remote(addr)
+    omq2.request(c1, 'cat.echo', 'fee', 'fi', 'fo', 'fum', on_reply=on_reply1)
+    omq2.request(c1, 'cat.ohce', 'fee', 'fi', 'fo', 'fum', on_reply=on_reply2)
+
+    timeout = datetime.now() + timedelta(seconds=0.5)
+    while None in (reply1, reply2) and datetime.now() < timeout:
+        time.sleep(0.01)
+
+    assert reply1 == ['Hi!', 'fee', 'fi', 'fo', 'fum']
+    assert reply2 == ['muf', 'of', 'if', 'eef', '!iH']
+
+
+def test_request_future(zmq_address):
+    omq1, omq2, addr = make_omqs(zmq_address)
+    c1 = omq2.connect_remote(addr)
+
+    reply3 = [x.decode() for x in omq2.request_future(c1, 'cat.echo', 'xyz').get()]
+    assert reply3 == ['Hi!', 'xyz']
+
+
+def test_commands(zmq_address):
+    omq1, omq2, addr = make_omqs(zmq_address, start=False)
+
+    val1, val2, val3 = None, None, None
+    defer = None
+
+    def cmd1(m):
+        nonlocal val1
+        val1 = ['CMD1 got'] + m.data()
+        m.back("x.x", "asdf", b'\x00\x01\x02', "jkl;")
+
+    def cmd2(m):
+        nonlocal val2, defer
+        val2 = ['CMD2 got'] + m.data()
+        defer = m.later()
+
+    def cmd_later(m):
+        nonlocal defer, val3
+        val3 = ['CMD-later got'] + m.data()
+
+    omq1.add_category("x", AuthLevel.none) \
+        .add_command("y", cmd1) \
+        .add_command("z", cmd_later)
+
+    omq2.add_category("x", AuthLevel.none) \
+        .add_command("x", cmd2)
+
+    omq1.start()
+    omq2.start()
+    c1 = omq2.connect_remote(addr)
+    omq2.send(c1, 'x.y', b'\0', 'M', 'G')
+
+    timeout = datetime.now() + timedelta(seconds=0.5)
+    while None in (val1, val2) and datetime.now() < timeout:
+        time.sleep(0.01)
+
+    assert val1 == ['CMD1 got', b'\0', b'M', b'G']
+    assert val2 == ['CMD2 got', b'asdf', b'\0\1\2', b'jkl;']
+    assert val3 is None
+    assert defer is not None
+
+    defer.back("x.z", "cool")
+    timeout = datetime.now() + timedelta(seconds=0.5)
+    while val3 is None and datetime.now() < timeout:
+        time.sleep(0.01)
+    assert val3 == ['CMD-later got', b'cool']
+