add some examples

Author: 2dav

README.md

@@ -28,7 +28,23 @@ Options:
 отправляет клиенту номер порта для приёма асинхронных сообщений коннектора(data port) и ожидает 
 подключение на этом порту. Цикл приёма/отправки начинается после подключения на data port.
 
-См. [client.py](examples/client.py) для примера клиентского приложения.
+### Примеры
+Запустите сервер
+```bash
+> txcproxy.exe -d <path/to/txmlconnector.dll>
+
+Сервер запущен на 127.0.0.1:4242
+```
+Примеры в директории [examples](examples/) демонстрируют установку связи с сервером и 
+особенности использования.
+> python examples/simple.py
+
+Базовый пример использования, после подключения к серверу отправляет не требующую авторизации команду
+и ожидает ответ коннектора.
+
+> python examples/connect.py <LOGIN> <PASSWORD>
+
+Пример подключения к серверу Transaq(требуются логин и пароль).
 
 ### Альтернативы
 - [novikovag/TXCProxy](https://github.com/novikovag/TXCProxy) `C` 

examples/client.py examples/connect.pyexamples/client.py renamed to examples/connect.py

@@ -1,31 +1,27 @@
 #!/bin/python
 import socket
+import sys
 from threading import Thread
 
+if len(sys.argv) < 3:
+    print("Run as \npython connect.py <LOGIN> <PASSWORD>")
+    sys.exit(0)
+
 addr = socket.gethostbyname("127.0.0.1")
 port = 4242
 
-connect_cmd = b"""<command id="connect">
-  <login></login>
-  <password></password>
-  <milliseconds>true</milliseconds>
-  <autopos>false</autopos>
-  <rqdelay>10</rqdelay>
-  <host>tr1.finam.ru</host>
-  <port>3900</port>
-</command>\0"""
-
-print("connecting to proxy server")
+# 0. Connect to the server
+print("connecting to %s:%x" % (addr, port))
 cmd = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
 cmd.connect((addr, port))
 
-# 1. Receive data port 
+# 1. Receive 'data port' 
 r = cmd.recv(32)
 dp = int.from_bytes(r, "little")
 print("< ", dp)
 
-# 2. Connect to data port 
-print("connecting to data stream")
+# 2. Connect to 'data port'
+print("connecting to %s:%x" % (addr, dp))
 rcv = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
 rcv.connect((addr, dp))
 
@@ -35,11 +31,21 @@ def rcv_print_loop(rcv):
         if len(b) == 0:
             break
         else:
-            print(b)
+            print("rx: ", b)
 
 Thread(target=rcv_print_loop, args=(rcv, )).start()
 
+
 # 3. Send command
-print("sending 'connect' command")
-cmd.sendall(connect_cmd)
+login, password = sys.argv[-2:]
+
+connect_cmd = """<command id="connect">
+  <login>%s</login>
+  <password>%s</password>
+  <host>tr1.finam.ru</host>
+  <port>3900</port>
+</command>\0""" % (login, password)
+
+cmd.sendall(connect_cmd.encode('utf-8'))
 print("< ", cmd.recv(256))
+

examples/simple.py

@@ -0,0 +1,42 @@
+#!/bin/python
+import socket
+import time
+from threading import Thread
+
+addr = socket.gethostbyname("127.0.0.1")
+port = 4242
+
+# 0. Connect to the server
+print("connecting to %s:%x" % (addr, port))
+cmd = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+cmd.connect((addr, port))
+
+# 1. Receive 'data port' 
+r = cmd.recv(32)
+dp = int.from_bytes(r, "little")
+print("< ", dp)
+
+# 2. Connect to 'data port'
+print("connecting to %s:%x" % (addr, dp))
+rcv = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+rcv.connect((addr, dp))
+
+def rcv_print_loop(rcv):
+    while True:
+        b = rcv.recv(1 << 20).decode()
+        if len(b) == 0:
+            break
+        else:
+            print("data: ", b)
+
+Thread(target=rcv_print_loop, args=(rcv, )).start()
+
+
+# 3. Send command
+conn_ver = b"""<command id = \"get_connector_version\"/>\0"""
+while True:
+    cmd.sendall(conn_ver)
+    print("resp: ", cmd.recv(256))
+    time.sleep(2)
+
+