added better handling to the RequestConsumer for network failures

straders_sdk/request_consumer.py

@@ -4,6 +4,7 @@
 from time import sleep
 import requests
 from queue import PriorityQueue
+import logging
 
 # this consumer should be a singleton.
 # it will have a priority queue of special request objects
@@ -25,6 +26,7 @@ def __init__(self, auto_start=True) -> None:
             return
         self.queue = PriorityQueue()
         self.stop_flag = False
+        self.logger = logging.getLogger("RequestConsumer")
         self._consumer_thread = Thread(
             target=self._consume_until_stopped, daemon=auto_start
         )
@@ -56,7 +58,14 @@ def _consume_until_stopped(self):
                     package.response = self._session.send(package.request)
 
                 except Exception as e:
-                    print(e)
+                    package.priority = 0
+                    self.queue.put((0, package))
+                    self.logger.warning(
+                        "Request failed, retrying in 30 seconds - reason %s", e
+                    )
+                    sleep(30)
+                    continue
+
                 if package.response.status_code != 429:
                     package.event.set()
                     print(

straders_sdk/utils.py

@@ -244,6 +244,8 @@ def sleep_until_ready(ship: "Ship"):
 
 def waypoint_slicer(waypoint_symbol: str) -> str:
     "returns the system symbol from a waypoint symbol"
+    if "-" not in waypoint_symbol:
+        return waypoint_symbol
     if not waypoint_symbol:
         return None
     pieces = waypoint_symbol.split("-")