async fix for sync requests call in abstraction

Author: Muntasib-creator

Framework/Utilities/RequestFormatter.py

@@ -1,6 +1,6 @@
 # -- coding: utf-8 --
 # -- coding: cp1252 --
-
+import asyncio
 from . import ConfigModule
 import os
 import requests
@@ -182,6 +182,14 @@ def request(*args, **kwargs):
 
     return session.request(*args, **kwargs)
 
+# async wrapper
+async def async_request(*args, **kwargs):
+    """
+    Runs the blocking request() in a worker thread
+    so the event loop is not blocked.
+    """
+    return await asyncio.to_thread(request, *args, **kwargs)
+
 
 def Post(resource_path, payload=None, **kwargs):
     renew_token_with_expiry_check()

Framework/deploy_handler/long_poll_handler.py

@@ -265,7 +265,7 @@ async def run(self, host: str) -> None:
 
             try:
                 reconnect = True
-                resp = RequestFormatter.request("get", host, timeout=70)
+                resp = await RequestFormatter.async_request("get", host, timeout=70)
                 if resp is None:
                     break
 

Framework/install_handler/long_poll_handler.py

@@ -339,7 +339,7 @@ async def run(self) -> None:
                     f"d/nodes/install/node/listen?node_id={read_node_id()}"
                 )
 
-                resp = resp = RequestFormatter.request("get", host, timeout=70)
+                resp = await RequestFormatter.async_request("get", host, timeout=70)
 
                 if not resp.ok:
                     if debug:
@@ -368,5 +368,5 @@ async def run(self) -> None:
                     print("[installer] RETRYING...")
                 await asyncio.sleep(random.randint(1, 3))
 
-            self.running = False
-            print("[installer] Stopped running")
+        self.running = False
+        print("[installer] Stopped running")

Framework/install_handler/utils.py

@@ -60,7 +60,7 @@ async def send_response(data=None) -> None:
 
         for _ in range(3):
             try:
-                resp = RequestFormatter.request("post", host, json=data, timeout=70)
+                resp = await RequestFormatter.request("post", host, json=data, timeout=70)
                 if debug: 
                     print(f"[installer] Response status: {resp.status_code}")
                     print(f"[installer] Response content: {resp.content}")