add example from obsolete repository's test

msgpack-rpc/msgpack-rpc@9b0fe02

Author: TAKANO Mitsuhiro

example/echoserver.py

@@ -0,0 +1,51 @@
+#!/usr/bin/env python
+# coding: utf-8
+
+"""Echo service.
+This server doesn't use msgpackrpc.server.
+"""
+
+import SocketServer
+from msgpack import packs, Unpacker
+
+class EchoHandler(SocketServer.BaseRequestHandler):
+
+    def handle(self):
+        unpacker = Unpacker()
+
+        while 1:
+            data = self.request.recv(4096)
+            if len(data) == 0:
+                break
+            unpacker.feed(data)
+            for msg in unpacker:
+                print msg
+                assert len(msg) == 4
+                assert msg[0] == 0
+                assert msg[2] == "echo"
+                sdata = packs((1, msg[1], None, msg[-1]))
+                self.request.sendall(sdata)
+
+def serve_background(server, daemon=False):
+    import threading
+    t = threading.Thread(target=server.serve_forever)
+    t.setDaemon(daemon)
+    t.start()
+
+def serve(daemon=False):
+    """Serve echo server in background on localhost.
+    This returns (server, port). port is number in integer.
+
+    To stop, use ``server.shutdown()``
+    """
+    for port in xrange(9000, 10000):
+        try:
+            server = SocketServer.TCPServer(('localhost', port), EchoHandler)
+            serve_background(server, daemon)
+            return server, port
+        except Exception:
+            pass
+
+if __name__ == '__main__':
+    port = serve(False)
+    print "Serving on localhost:%d\n" % (port,)

example/test_client.py

@@ -0,0 +1,34 @@
+#!/usr/bin/env python
+# coding: utf-8
+
+from msgpackrpc.client import *
+from msgpackrpc.transport import tcp
+
+import echoserver
+
+SERVER = PORT = None
+
+def setup():
+    global SERVER, PORT
+    SERVER, PORT = echoserver.serve()
+
+def teardown():
+    global SERVER, PORT
+    SERVER.shutdown()
+    SERVER = PORT = None
+
+def test_client():
+    client = Client(tcp.TCPTransport, ('localhost', PORT), {})
+
+    f1 = client.send_request('echo', 'foo')
+    f2 = client.send_request('echo', 'bar')
+    f3 = client.send_request('echo', 'baz')
+
+    assert f2.result() == 'bar'
+    assert f1.result() == 'foo'
+    assert f3.result() == 'baz'
+
+if __name__ == '__main__':
+    setup()
+    test_client()
+    teardown()