Add logging

Author: MDUYN

finterion/finterion.py

@@ -1,6 +1,10 @@
+import logging
 from finterion import services, ClientException, OrderSide
 
 
+logger = logging.getLogger("finterion")
+
+
 class Finterion:
 
     def __init__(self, api_key, base_url=None):
@@ -10,8 +14,13 @@ def __init__(self, api_key, base_url=None):
         if self.base_url is None:
             self.base_url = "https://api.finterion.com/algs"
 
+        logger.info(f"Setup Finterion client with base url {self.base_url}")
         self.ping()
         self.algorithm = self.get_algorithm_model()
+        logger.info(
+            f"Running algorithm {self.algorithm.get_name()} in "
+            f"environment {self.algorithm.get_environment()}"
+        )
 
     def ping(self):
         return services.ping(self.api_key, base_url=self.base_url)

finterion/services.py

@@ -9,7 +9,7 @@
     create_order_url
 from finterion.exceptions import ClientException
 
-logger = logging.getLogger(__name__)
+logger = logging.getLogger("finterion")
 
 
 def handle_response(response):
@@ -21,6 +21,7 @@ def handle_response(response):
     if response.status_code == 401:
         raise ClientException("Unauthorized, check your API key")
     elif response.status_code == 400:
+        logger.error("Service call failed")
         data = response.json()
         logger.error(data)
 
@@ -36,18 +37,21 @@ def handle_response(response):
 
 
 def ping(api_key, base_url):
+    logger.info("Pinging finterion platform")
     url = get_ping_url(base_url)
     response = requests.get(url, headers={"XApiKey": api_key})
     return handle_response(response)
 
 
 def get_algorithm_model(api_key, base_url):
+    logger.info("Getting algorithm model")
     url = get_algorithm_url(base_url)
     response = requests.get(url, headers={"XApiKey": api_key})
     return handle_response(response)
 
 
 def get_orders(api_key, query_params, base_url):
+    logger.info("Getting orders")
     url = get_list_orders_url(base_url)
     response = requests.get(
         url, headers={"XApiKey": api_key}, params=query_params
@@ -56,19 +60,22 @@ def get_orders(api_key, query_params, base_url):
 
 
 def get_order(api_key, order_id, base_url):
+    logger.info("Getting order")
     url = get_retrieve_order_url(base_url, order_id)
     response = requests.get(url, headers={"XApiKey": api_key})
     return handle_response(response)
 
 
 def create_order(api_key, data, base_url):
+    logger.info("Creating order")
     url = create_order_url(base_url)
     headers = {"XApiKey": api_key, "Content-Type": "application/json"}
     response = requests.post(url, headers=headers, data=json.dumps(data))
     return handle_response(response)
 
 
 def get_positions(api_key, query_params, base_url):
+    logger.info("Getting positions")
     url = get_list_positions_url(base_url)
     response = requests.get(
         url, headers={"XApiKey": api_key}, params=query_params
@@ -77,12 +84,14 @@ def get_positions(api_key, query_params, base_url):
 
 
 def get_position(api_key, position_id, base_url):
+    logger.info("Getting position")
     url = get_retrieve_position_url(base_url, position_id)
     response = requests.get(url, headers={"XApiKey": api_key})
     return handle_response(response)
 
 
 def get_portfolio(api_key, base_url):
+    logger.info("Getting portfolio")
     url = get_retrieve_portfolio_url(base_url)
     response = requests.get(url, headers={"XApiKey": api_key})
     return handle_response(response)