version: bump version number

pyasic/miners/_backends/bosminer.py

@@ -68,20 +68,23 @@ class BOSMiner(BaseMiner):
 
     async def send_graphql_query(self, query) -> Union[dict, None]:
         url = f"http://{self.ip}/graphql"
-        async with httpx.AsyncClient() as client:
-            _auth = await client.post(
-                url,
-                json={
-                    "query": 'mutation{auth{login(username:"'
-                    + self.uname
-                    + '", password:"'
-                    + self.pwd
-                    + '"){__typename}}}'
-                },
-            )
-            d = await client.post(url, json={"query": query})
-        if d.status_code == 200:
-            return d.json()
+        try:
+            async with httpx.AsyncClient() as client:
+                _auth = await client.post(
+                    url,
+                    json={
+                        "query": 'mutation{auth{login(username:"'
+                        + self.uname
+                        + '", password:"'
+                        + self.pwd
+                        + '"){__typename}}}'
+                    },
+                )
+                d = await client.post(url, json={"query": query})
+            if d.status_code == 200:
+                return d.json()
+        except httpx.ReadError:
+            return None
         return None
 
     async def fault_light_on(self) -> bool:
@@ -276,8 +279,11 @@ class BOSMiner(BaseMiner):
             return self.light
         # get light through GraphQL
         if data := await self.send_graphql_query("{bos {faultLight}}"):
-            self.light = data["data"]["bos"]["faultLight"]
-            return self.light
+            try:
+                self.light = data["data"]["bos"]["faultLight"]
+                return self.light
+            except (TypeError, KeyError, ValueError, IndexError):
+                pass
 
         # get light via ssh if that fails (10x slower)
         data = (
@@ -548,54 +554,116 @@ class BOSMiner(BaseMiner):
 
         data.mac = await self.get_mac()
         data.model = await self.get_model()
-        data.hostname = query_data["bos"]["hostname"]
-        data.hashrate = round(
-            query_data["bosminer"]["info"]["workSolver"]["realHashrate"]["mhs1M"]
-            / 1000000,
-            2,
-        )
+        if query_data.get("bos"):
+            if query_data["bos"].get("hostname"):
+                data.hostname = query_data["bos"]["hostname"]
 
-        boards = query_data["bosminer"]["info"]["workSolver"]["childSolvers"]
-        offset = 6 if int(boards[0]["name"]) in [6, 7, 8] else int(boards[0]["name"])
-        for hb in boards:
-            _id = int(hb["name"]) - offset
-
-            board = data.hashboards[_id]
-            board.hashrate = round(hb["realHashrate"]["mhs1M"] / 1000000, 2)
-            board.temp = round(hb["temperatures"][0]["degreesC"])
-            board.chip_temp = round(hb["temperatures"][1]["degreesC"])
-            board.chips = hb["hwDetails"]["chips"]
-            board.missing = False
-
-            if hb["tuner"]["statusMessages"][0] not in [
-                "Stable",
-                "Testing performance profile",
-                "Tuning individual chips"
-            ]:
-                data.errors.append(
-                    BraiinsOSError(f"Slot {_id} {hb['tuner']['statusMessages'][0]}")
+        try:
+            if query_data["bosminer"]["info"]["workSolver"]["realHashrate"].get("mhs1M"):
+                data.hashrate = round(
+                    query_data["bosminer"]["info"]["workSolver"]["realHashrate"]["mhs1M"]
+                    / 1000000,
+                    2,
                 )
+        except (TypeError, KeyError, ValueError, IndexError):
+            pass
+
+        boards = None
+        if query_data.get("bosminer"):
+            if query_data["bosminer"].get("info"):
+                if query_data["bosminer"]["info"].get("workSolver"):
+                    boards = query_data["bosminer"]["info"]["workSolver"].get("childSolvers")
+        if boards:
+            offset = 6 if int(boards[0]["name"]) in [6, 7, 8] else int(boards[0]["name"])
+            for hb in boards:
+                _id = int(hb["name"]) - offset
+
+                board = data.hashboards[_id]
+                board.hashrate = round(hb["realHashrate"]["mhs1M"] / 1000000, 2)
+                temps = hb["temperatures"]
+                try:
+                    if len(temps) > 0:
+                        board.temp = round(hb["temperatures"][0]["degreesC"])
+                    if len(temps) > 1:
+                        board.chip_temp = round(hb["temperatures"][1]["degreesC"])
+                except (TypeError, KeyError, ValueError, IndexError):
+                    pass
+                details = hb.get("hwDetails")
+                if details:
+                    if chips := details["chips"]:
+                        board.chips = chips
+                board.missing = False
+
+                tuner = hb.get("tuner")
+                if tuner:
+                    if msg := tuner.get("statusMessages"):
+                        if len(msg) > 0:
+                            if hb["tuner"]["statusMessages"][0] not in [
+                                "Stable",
+                                "Testing performance profile",
+                                "Tuning individual chips"
+                            ]:
+                                data.errors.append(
+                                    BraiinsOSError(f"Slot {_id} {hb['tuner']['statusMessages'][0]}")
+                                )
+        try:
+            data.wattage = query_data["bosminer"]["info"]["workSolver"]["power"]["approxConsumptionW"]
+        except (TypeError, KeyError, ValueError, IndexError):
+            pass
+        try:
+            data.wattage_limit = query_data["bosminer"]["info"]["workSolver"]["power"]["limitW"]
+        except (TypeError, KeyError, ValueError, IndexError):
+            pass
 
-        data.wattage = query_data["bosminer"]["info"]["workSolver"]["power"]["approxConsumptionW"]
-        data.wattage_limit = query_data["bosminer"]["info"]["workSolver"]["power"]["limitW"]
 
         for n in range(self.fan_count):
-            setattr(data, f"fan_{n - 1}", query_data["bosminer"]["info"]["fans"][n]["rpm"])
+            try:
+                setattr(data, f"fan_{n + 1}", query_data["bosminer"]["info"]["fans"][n]["rpm"])
+            except (TypeError, KeyError, ValueError, IndexError):
+                pass
 
-        groups = query_data["bosminer"]["config"]["groups"]
-        if len(groups) == 1:
-            data.pool_1_user = groups[0]["pools"][0]["user"]
-            data.pool_1_url = groups[0]["pools"][0]["url"]
-            data.pool_2_user = groups[0]["pools"][1]["user"]
-            data.pool_2_url = groups[0]["pools"][1]["url"]
-            data.quota = 0
-        else:
-            data.pool_1_user = groups[0]["pools"][0]["user"]
-            data.pool_1_url = groups[0]["pools"][0]["url"]
-            data.pool_2_user = groups[1]["pools"][0]["user"]
-            data.pool_2_url = groups[1]["pools"][0]["url"]
-            if groups[0]["strategy"].get("quota"):
-                data.quota = groups[0]["strategy"]["quota"] + "/" + groups[1]["strategy"]["quota"]
+        groups = None
+        if query_data.get("bosminer"):
+            if query_data["bosminer"].get("config"):
+                groups = query_data["bosminer"]["config"].get("groups")
+        if groups:
+            if len(groups) == 1:
+                try:
+                    data.pool_1_user = groups[0]["pools"][0]["user"]
+                except (TypeError, KeyError, ValueError, IndexError):
+                    pass
+                try:
+                    data.pool_1_url = groups[0]["pools"][0]["url"]
+                except (TypeError, KeyError, ValueError, IndexError):
+                    pass
+                try:
+                    data.pool_2_user = groups[0]["pools"][1]["user"]
+                except (TypeError, KeyError, ValueError, IndexError):
+                    pass
+                try:
+                    data.pool_2_url = groups[0]["pools"][1]["url"]
+                except (TypeError, KeyError, ValueError, IndexError):
+                    pass
+                data.quota = 0
+            else:
+                try:
+                    data.pool_1_user = groups[0]["pools"][0]["user"]
+                except (TypeError, KeyError, ValueError, IndexError):
+                    pass
+                try:
+                    data.pool_1_url = groups[0]["pools"][0]["url"]
+                except (TypeError, KeyError, ValueError, IndexError):
+                    pass
+                try:
+                    data.pool_2_user = groups[1]["pools"][0]["user"]
+                except (TypeError, KeyError, ValueError, IndexError):
+                    pass
+                try:
+                    data.pool_2_url = groups[1]["pools"][0]["url"]
+                except (TypeError, KeyError, ValueError, IndexError):
+                    pass
+                if groups[0]["strategy"].get("quota"):
+                    data.quota = groups[0]["strategy"]["quota"] + "/" + groups[1]["strategy"]["quota"]
 
         data.fault_light = await self.check_light()
 

pyasic/miners/miner_factory.py

@@ -337,7 +337,6 @@ class MinerFactory(metaclass=Singleton):
                     break
             except asyncio.TimeoutError:
                 logging.warning(f"{ip}: Get Miner Timed Out")
-
         miner = self._select_miner_from_classes(ip, model, api, ver)
 
         # save the miner to the cache at its IP if its not unknown
@@ -435,8 +434,9 @@ class MinerFactory(metaclass=Singleton):
         if devdetails:
             if devdetails == {"Msg": "Disconnected"}:
                 model = await self.__get_model_from_graphql(ip)
-                api = "BOSMiner+"
-                return model, api, ver
+                if model:
+                    api = "BOSMiner+"
+                    return model, api, ver
 
             for _devdetails_key in ["Model", "Driver"]:
                 try:
@@ -538,8 +538,6 @@ class MinerFactory(metaclass=Singleton):
     async def __get_devdetails_and_version(
         self, ip
     ) -> Tuple[Union[dict, None], Union[dict, None]]:
-        return {"Msg": "Disconnected"}, None
-
         version = None
         try:
             # get device details and version data
@@ -606,7 +604,7 @@ class MinerFactory(metaclass=Singleton):
         async with httpx.AsyncClient() as client:
             d = await client.post(url, json={"query": "{bosminer {info{modelName}}}"})
         if d.status_code == 200:
-            model = d.json()["data"]["bosminer"]["info"]["modelName"].upper()
+            model = (d.json()["data"]["bosminer"]["info"]["modelName"]).upper()
         return model
 
     @staticmethod

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "pyasic"
-version = "0.21.0"
+version = "0.21.8"
 description = "A set of modules for interfacing with many common types of ASIC bitcoin miners, using both their API and SSH."
 authors = ["UpstreamData <brett@upstreamdata.ca>"]
 repository = "https://github.com/UpstreamData/pyasic"