Use threads to speed up connectivity check

CHANGELOG.md

@@ -11,6 +11,7 @@
 - Hide CDPR Goodie Pack Content
 - Add notifications on successful download and installation of games (thanks to orende)
 - Add category filtering dialog for game library (thanks to orende)
+- Parallelize api.can_connect function with threads, futures (thanks to orende)
 
 **1.2.2**
 - Fix progress bar not showing up for downloads

minigalaxy/api.py

@@ -4,6 +4,7 @@
 from urllib.parse import urlencode
 import requests
 import xml.etree.ElementTree as ET
+from concurrent.futures import ThreadPoolExecutor, as_completed
 
 from requests import Session
 
@@ -29,6 +30,7 @@ def __init__(self, config: Config, session: Session):
         self.debug = os.environ.get("MG_DEBUG")
         self.active_token = False
         self.active_token_expiration_time = time.time()
+        self.conn_check_thpool = ThreadPoolExecutor(max_workers=2)
 
     # use a method to authenticate, based on the information we have
     # Returns an empty string if no information was entered
@@ -248,12 +250,24 @@ def can_connect(self) -> bool:
             "https://embed.gog.com",
             "https://auth.gog.com",
         ]
-        for url in urls:
+        threads = []
+
+        def make_request(url_to_check: str):
             try:
-                self.session.get(url, timeout=5)
+                self.session.get(url_to_check, timeout=5)
+                return True
             except requests.exceptions.ConnectionError:
                 return False
-        return True
+
+        for url in urls:
+            threads.append(self.conn_check_thpool.submit(make_request, url))
+
+        results = []
+        for thread in as_completed(threads):
+            if thread.cancelled():
+                return False
+            results += [thread.result()]
+        return all(results)
 
     # Make a request with the active token
     def __request(self, url: str = None, params: dict = None) -> dict:

minigalaxy/ui/window.py

@@ -73,10 +73,14 @@ def __init__(self, config: Config, api: 'Api', download_manager: DownloadManager
         self.make_directories()
 
         # Interact with the API
+        logger.debug("Checking API connectivity...")
         self.offline = not self.api.can_connect()
+        logger.debug("Done checking API connectivity, status: %s", "offline" if self.offline else "online")
         if not self.offline:
             try:
+                logger.debug("Authenticating...")
                 self.__authenticate()
+                logger.debug("Authenticated as: %s", self.api.get_user_info())
                 self.HeaderBar.set_subtitle(self.api.get_user_info())
             except Exception:
                 logger.warn("Starting in offline mode after receiving exception", exc_info=1)