From 40ebc2773fca35026ba1f60c113d287fd604579c Mon Sep 17 00:00:00 2001
From: Ryan Heideman <ryandh@outlook.com>
Date: Thu, 1 May 2025 14:07:58 -0700
Subject: [PATCH] Retry and Timeout Changes for espminer (#340)

* Retry and Timeout Fixes for espminer

* Build check fix
---
 pyasic/web/espminer.py | 54 ++++++++++++++++++++++--------------------
 1 file changed, 28 insertions(+), 26 deletions(-)

diff --git a/pyasic/web/espminer.py b/pyasic/web/espminer.py
index eba87192..aa33ffb9 100644
--- a/pyasic/web/espminer.py
+++ b/pyasic/web/espminer.py
@@ -20,34 +20,36 @@ class ESPMinerWebAPI(BaseWebAPI):
         **parameters: Any,
     ) -> dict:
         url = f"http://{self.ip}:{self.port}/api/{command}"
-        try:
-            async with httpx.AsyncClient(
-                transport=settings.transport(),
-            ) as client:
-                if parameters.get("post", False):
-                    parameters.pop("post")
-                    data = await client.post(
-                        url,
-                        timeout=settings.get("api_function_timeout", 3),
-                        json=parameters,
-                    )
-                elif parameters.get("patch", False):
-                    parameters.pop("patch")
-                    data = await client.patch(
-                        url,
-                        timeout=settings.get("api_function_timeout", 3),
-                        json=parameters,
-                    )
-                else:
-                    data = await client.get(url)
-        except httpx.HTTPError:
-            pass
-        else:
-            if data.status_code == 200:
+        async with httpx.AsyncClient(transport=settings.transport()) as client:
+            for _ in range(settings.get("get_data_retries", 1)):
                 try:
-                    return data.json()
-                except json.decoder.JSONDecodeError:
+                    if parameters.get("post", False):
+                        parameters.pop("post")
+                        data = await client.post(
+                            url,
+                            timeout=settings.get("api_function_timeout", 3),
+                            json=parameters,
+                        )
+                    elif parameters.get("patch", False):
+                        parameters.pop("patch")
+                        data = await client.patch(
+                            url,
+                            timeout=settings.get("api_function_timeout", 3),
+                            json=parameters,
+                        )
+                    else:
+                        data = await client.get(
+                            url,
+                            timeout=settings.get("api_function_timeout", 5),
+                        )
+                except httpx.HTTPError:
                     pass
+                else:
+                    if data.status_code == 200:
+                        try:
+                            return data.json()
+                        except json.decoder.JSONDecodeError:
+                            pass
 
     async def multicommand(
         self, *commands: str, ignore_errors: bool = False, allow_warning: bool = True