better logging when connecting

src/rithmic/config/credentials.py

@@ -20,6 +20,9 @@ class RithmicEnvironment(enum.Enum):
     RITHMIC_PAPER_TRADING = 'RITHMIC_PAPER_TRADING'
     RITHMIC_LIVE = 'RITHMIC_LIVE'
 
+    def __repr__(self):
+        return self.value
+
 
 def _get_config_file(environment: RithmicEnvironment):
     try:

src/rithmic/interfaces/base.py

@@ -37,11 +37,13 @@ def _setup_ssl_context():
 
 class RithmicBaseApi(metaclass=ABCMeta):
     infra_type = None
+    api_type = None
 
     def __init__(self, env: RithmicEnvironment = None, callback_manager: CallbackManager = None,
                  auto_connect: bool = True, loop: AbstractEventLoop = None):
         self.ws = None
         credentials = get_rithmic_credentials(env)
+        self.env = env
         self.uri = credentials['uri']
         self.user = credentials['user']
         self.pw = credentials['pw']
@@ -145,7 +147,11 @@ def setup_ssl_context(self):
     def connect_and_login(self):
         ws = self._get_websocket_connection()
         self.ws = ws
-        return self._log_into_rithmic()
+        log_in_details = self._log_into_rithmic()
+        logger.info('Connected to {0} as User {1} on {2} ({3})'.format(
+            self.api_type, self.user, self.system_name, self.env
+        ))
+        return log_in_details
 
     def _get_websocket_connection(self):
         future = asyncio.run_coroutine_threadsafe(self.get_websocket_connection(), self.loop)

src/rithmic/interfaces/history/history_api.py

@@ -12,6 +12,7 @@
 from rithmic.interfaces.base import RithmicBaseApi
 from rithmic.protocol_buffers import request_login_pb2, request_tick_bar_replay_pb2, response_tick_bar_replay_pb2
 from rithmic.tools.general import set_index_no_name, is_datetime_utc
+from rithmic.tools.meta import ApiType
 from rithmic.tools.pyrithmic_exceptions import ReferenceDataUnavailableException, DownloadErrorException
 from rithmic.tools.pyrithmic_logger import logger, configure_logging
 
@@ -101,6 +102,7 @@ class RithmicHistoryApi(RithmicBaseApi):
     Rithmic History API For the HISTORY PLANT to download historical tick data for security/exchange combinations
     """
     infra_type = request_login_pb2.RequestLogin.SysInfraType.HISTORY_PLANT
+    api_type = ApiType.HISTORY
 
     def __init__(self, env: RithmicEnvironment = None, callback_manager: CallbackManager = None,
                  auto_connect: bool = True, loop=None):

src/rithmic/interfaces/order/order_api.py

@@ -23,6 +23,7 @@
     request_modify_order_pb2, request_update_target_bracket_level_pb2,
 )
 from rithmic.tools.general import dict_destructure, get_utc_now
+from rithmic.tools.meta import ApiType
 from rithmic.tools.pyrithmic_exceptions import (
     NoValidTradingAccountException, NoValidTradeRouteException, NoTradingConfigException, WebsocketClosedException,
 )
@@ -53,6 +54,7 @@ class RithmicOrderApi(RithmicBaseApi):
     Rithmic Order API For the ORDER PLANT to submit orders, cancel orders, modify orders and receive fills
     """
     infra_type = request_login_pb2.RequestLogin.SysInfraType.ORDER_PLANT
+    api_type = ApiType.ORDER
 
     def __init__(self, env: RithmicEnvironment = None, callback_manager: CallbackManager = None, loop=None,
                  auto_connect: bool = True, recovered_status_manager: StatusManager = None):
@@ -108,6 +110,7 @@ def connect_and_login(self) -> None:
         logged_in = super(RithmicOrderApi, self).connect_and_login()
         future = asyncio.run_coroutine_threadsafe(self._get_login_info(), loop=self.loop)
         log_in_details = future.result()
+        logger.info('Order API Extended Login Details => {0}'.format(log_in_details))
         self._set_log_in_details(log_in_details)
         self._run_update_subscription()
 

src/rithmic/interfaces/ticker/ticker_api.py

@@ -12,6 +12,7 @@
 from rithmic.protocol_buffers.last_trade_pb2 import LastTrade
 from rithmic.protocol_buffers.response_front_month_contract_pb2 import ResponseFrontMonthContract
 from rithmic.tools.general import dict_destructure, set_index_no_name
+from rithmic.tools.meta import ApiType
 from rithmic.tools.pyrithmic_exceptions import WebsocketClosedException, MissingCustomCallback
 from rithmic.tools.pyrithmic_logger import logger, configure_logging
 
@@ -113,6 +114,7 @@ class RithmicTickerApi(RithmicBaseApi):
     Rithmic Ticker API For the TICKER PLANT to stream live tick data
     """
     infra_type = request_login_pb2.RequestLogin.SysInfraType.TICKER_PLANT
+    api_type = ApiType.TICKER
 
     def __init__(self, env: RithmicEnvironment = None, callback_manager: CallbackManager = None,
                  auto_connect: bool = True, loop=None, periodic_sync_interval_seconds: float = 0.1):

src/rithmic/tools/meta.py

@@ -0,0 +1,10 @@
+import enum
+
+
+class ApiType(enum.Enum):
+    ORDER = 'ORDER'
+    TICKER = 'TICKER'
+    HISTORY = 'HISTORY'
+
+    def __repr__(self):
+        return self.value