added on_login and on_logout handlers and callbacks

Author: mvberg

openfeed/__init__.py

@@ -8,4 +8,4 @@
 
 from .openfeed_client import OpenfeedClient
 
-VERSION = '1.1.6'
+VERSION = '1.1.7'

openfeed/generated/openfeed_api_pb2.py

@@ -38,6 +38,8 @@ def __init__(self, username, password, server="openfeed.aws.barchart.com", debug
         self.on_connected = None
         self.on_disconnected = None
         self.on_error = None
+        self.on_login = None
+        self.on_logout = None
 
         websocket.enableTrace(self.debug)
 
@@ -229,10 +231,22 @@ def handleLogin(msg):
                 raise Exception("Login has failed: ", msg)
 
             self.token = msg.loginResponse.token
+
+            self.__callback(self.on_login, msg)            
             self.__send_existing_interest()
 
             return msg
 
+        def handleLogout(msg):
+            
+            self.__callback(self.on_logout, msg)
+
+            if msg.logoutResponse.status.result == 115:
+                if self.debug:
+                    print("Logout due to concurrent logins:", msg)
+
+            return msg
+
         def handleHeartbeat(msg):
             self.__notify_heartbeat_listeners(msg)
             return msg
@@ -325,6 +339,7 @@ def handleOHLC(msg):
 
         handlers = {
             "loginResponse": handleLogin,
+            "logoutResponse": handleLogout,
             "heartBeat": handleHeartbeat,
             "exchangeResponse": handleExchangeRequest,
             "subscriptionResponse": handleSubscriptionResponse,
@@ -611,6 +626,8 @@ def handle_heartbeat(msg):
     of_client.on_error = lambda x: print("of-client: something went wrong:", x)
     of_client.on_disconnected = lambda x: print("of-client: disconnected")
     of_client.on_connected = lambda x: print("of-client: connected")
+    of_client.on_login = lambda x: print("of-client: login:", x)
+    of_client.on_logout = lambda x: print("of-client: logout:", x)
 
     # blocking mode
     of_client.start(blocking=False)

openfeed/openfeed_client.py

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "openfeed"
-version = "1.1.6"
+version = "1.1.7"
 description = "Python SDK for Openfeed"
 authors = ["Barchart <[email protected]>"]
 license = "MIT"

pyproject.toml

@@ -17,7 +17,7 @@
 
 setup(
     name='openfeed',
-    version='1.1.6',
+    version='1.1.7',
     author='Barchart',
     author_email='[email protected]',
     license='MIT',