version: bump version number

Multiple multicommand methods were double-awaiting tasks - first via
asyncio.gather() with return_exceptions=True, then calling .result() on
the same tasks. This caused ConnectionResetError and other exceptions
when connections were lost.

Changed to properly use the results from gather() instead of calling
.result() on completed tasks, preventing exceptions from being raised
after they were already caught.

Fixed in:
- pyasic/rpc/base.py:144 - RPC _send_split_multicommand
- pyasic/web/espminer.py:79 - ESPMiner multicommand
- pyasic/web/auradine.py:149 - Auradine multicommand

.pre-commit-config.yaml

@@ -5,13 +5,13 @@ ci:
     - generate-docs
 repos:
 -   repo: https://github.com/python-poetry/poetry
-    rev: 2.1.2
+    rev: 2.2.1
     hooks:
       - id: poetry-check
       - id: poetry-lock
       - id: poetry-install
 -   repo: https://github.com/pre-commit/pre-commit-hooks
-    rev: v5.0.0
+    rev: v6.0.0
     hooks:
     -   id: trailing-whitespace
     -   id: check-yaml
@@ -23,7 +23,7 @@ repos:
         exclude: ^mkdocs\.yml$
     -   id: check-added-large-files
 -   repo: https://github.com/psf/black
-    rev: 25.1.0
+    rev: 25.9.0
     hooks:
     -   id: black
 -   repo: https://github.com/pycqa/isort

docs/miners/avalonminer/Q.md

@@ -0,0 +1,16 @@
+# pyasic
+## Q Models
+
+## Avalon Q Home (Stock)
+
+- [ ] Shutdowns
+- [ ] Power Modes
+- [ ] Setpoints
+- [ ] Presets
+
+::: pyasic.miners.avalonminer.cgminer.Q.Q.CGMinerAvalonQHome
+    handler: python
+    options:
+        show_root_heading: false
+        heading_level: 0
+

docs/miners/goldshell/Byte.md

@@ -1,5 +1,5 @@
 # pyasic
-## Byte Models
+## byte Models
 
 ## Byte (Stock)
 
@@ -8,7 +8,7 @@
 - [ ] Setpoints
 - [ ] Presets
 
-::: pyasic.miners.goldshell.bfgminer.Byte.Byte.GoldshellByte
+::: pyasic.miners.goldshell.bfgminer.byte.byte.GoldshellByte
     handler: python
     options:
         show_root_heading: false

docs/miners/goldshell/mini_doge.md

@@ -0,0 +1,16 @@
+# pyasic
+## mini_doge Models
+
+## Mini Doge (Stock)
+
+- [ ] Shutdowns
+- [ ] Power Modes
+- [ ] Setpoints
+- [ ] Presets
+
+::: pyasic.miners.goldshell.bfgminer.mini_doge.mini_doge.GoldshellMiniDoge
+    handler: python
+    options:
+        show_root_heading: false
+        heading_level: 0
+

docs/miners/iceriver/ALX.md

@@ -0,0 +1,16 @@
+# pyasic
+## ALX Models
+
+## AL3 (Stock)
+
+- [ ] Shutdowns
+- [ ] Power Modes
+- [ ] Setpoints
+- [ ] Presets
+
+::: pyasic.miners.iceriver.iceminer.ALX.AL3.IceRiverAL3
+    handler: python
+    options:
+        show_root_heading: false
+        heading_level: 0
+

docs/miners/supported_types.md

@@ -603,12 +603,6 @@ details {
 <details>
 <summary>Stock Firmware Goldshells:</summary>
     <ul>
-        <details>
-            <summary>Mini Doge Series:</summary>
-                <ul>
-                    <li><a href="../goldshell/MiniDoge#mini-doge-stock">Mini Doge (Stock)</a></li>
-                </ul>
-        </details>
         <details>
             <summary>X5 Series:</summary>
                 <ul>
@@ -631,9 +625,15 @@ details {
                 </ul>
         </details>
         <details>
-            <summary>Byte Series:</summary>
+            <summary>byte Series:</summary>
                 <ul>
-                    <li><a href="../goldshell/Byte#byte-stock">Byte (Stock)</a></li>
+                    <li><a href="../goldshell/byte#byte-stock">Byte (Stock)</a></li>
+                </ul>
+        </details>
+        <details>
+            <summary>mini_doge Series:</summary>
+                <ul>
+                    <li><a href="../goldshell/mini_doge#mini-doge-stock">Mini Doge (Stock)</a></li>
                 </ul>
         </details>
     </ul>

pyasic/data/__init__.py

@@ -83,6 +83,7 @@ class MinerData(BaseModel):
 
     # about
     device_info: DeviceInfo | None = None
+    serial_number: str | None = None
     mac: str | None = None
     api_ver: str | None = None
     fw_ver: str | None = None

pyasic/miners/backends/antminer.py

@@ -39,6 +39,10 @@ from pyasic.web.antminer import AntminerModernWebAPI, AntminerOldWebAPI
 
 ANTMINER_MODERN_DATA_LOC = DataLocations(
     **{
+        str(DataOptions.SERIAL_NUMBER): DataFunction(
+            "_get_serial_number",
+            [WebAPICommand("web_get_system_info", "get_system_info")],
+        ),
         str(DataOptions.MAC): DataFunction(
             "_get_mac",
             [WebAPICommand("web_get_system_info", "get_system_info")],
@@ -360,6 +364,21 @@ class AntminerModern(BMMiner):
             except LookupError:
                 pass
 
+    async def _get_serial_number(
+        self, web_get_system_info: dict = None
+    ) -> Optional[str]:
+        if web_get_system_info is None:
+            try:
+                web_get_system_info = await self.web.get_system_info()
+            except APIError:
+                pass
+
+        if web_get_system_info is not None:
+            try:
+                return web_get_system_info["serinum"]
+            except LookupError:
+                pass
+
     async def set_static_ip(
         self,
         ip: str,

pyasic/miners/base.py

@@ -209,6 +209,14 @@ class MinerProtocol(Protocol):
     ### DATA GATHERING FUNCTIONS (get_{some_data}) ###
     ##################################################
 
+    async def get_serial_number(self) -> Optional[str]:
+        """Get the serial number of the miner and return it as a string.
+
+        Returns:
+            A string representing the serial number of the miner.
+        """
+        return await self._get_serial_number()
+
     async def get_mac(self) -> Optional[str]:
         """Get the MAC address of the miner and return it as a string.
 
@@ -379,6 +387,9 @@ class MinerProtocol(Protocol):
         """
         return await self._get_pools()
 
+    async def _get_serial_number(self) -> Optional[str]:
+        pass
+
     async def _get_mac(self) -> Optional[str]:
         pass
 

pyasic/miners/data.py

@@ -20,6 +20,7 @@ from typing import List, Union
 
 
 class DataOptions(Enum):
+    SERIAL_NUMBER = "serial_number"
     MAC = "mac"
     API_VERSION = "api_ver"
     FW_VERSION = "fw_ver"

pyasic/rpc/base.py

@@ -136,17 +136,16 @@ class BaseMinerRPCAPI:
                 self.send_command(cmd, allow_warning=allow_warning)
             )
 
-        await asyncio.gather(*[tasks[cmd] for cmd in tasks], return_exceptions=True)
+        results = await asyncio.gather(
+            *[tasks[cmd] for cmd in tasks], return_exceptions=True
+        )
 
         data = {}
-        for cmd in tasks:
-            try:
-                result = tasks[cmd].result()
+        for cmd, result in zip(tasks.keys(), results):
+            if not isinstance(result, (APIError, Exception)):
                 if result is None or result == {}:
                     result = {}
                 data[cmd] = [result]
-            except APIError:
-                pass
 
         return data
 
@@ -253,10 +252,10 @@ If you are sure you want to use this command please use API.send_command("{comma
         # some json from the API returns with a null byte (\x00) on the end
         if data.endswith(b"\x00"):
             # handle the null byte
-            str_data = data.decode("utf-8")[:-1]
+            str_data = data.decode("utf-8", errors="replace")[:-1]
         else:
             # no null byte
-            str_data = data.decode("utf-8")
+            str_data = data.decode("utf-8", errors="replace")
         # fix an error with a btminer return having an extra comma that breaks json.loads()
         str_data = str_data.replace(",}", "}")
         # fix an error with a btminer return having a newline that breaks json.loads()

pyasic/rpc/btminer.py

@@ -252,13 +252,13 @@ class BTMinerRPCAPI(BaseMinerRPCAPI):
         except APIError as e:
             if not e.message == "can't access write cmd":
                 raise
-        try:
-            await self.open_api()
-        except Exception as e:
-            raise APIError("Failed to open whatsminer API.") from e
-        return await self._send_privileged_command(
-            command=command, ignore_errors=ignore_errors, timeout=timeout, **kwargs
-        )
+        # try:
+        #     await self.open_api()
+        # except Exception as e:
+        #     raise APIError("Failed to open whatsminer API.") from e
+        # return await self._send_privileged_command(
+        #     command=command, ignore_errors=ignore_errors, timeout=timeout, **kwargs
+        # )
 
     async def _send_privileged_command(
         self,
@@ -293,6 +293,7 @@ class BTMinerRPCAPI(BaseMinerRPCAPI):
 
         try:
             data = parse_btminer_priviledge_data(self.token, data)
+            print(data)
         except Exception as e:
             logging.info(f"{str(self.ip)}: {e}")
 
@@ -1109,6 +1110,7 @@ class BTMinerV3RPCAPI(BaseMinerRPCAPI):
         super().__init__(ip, port, api_ver=api_ver)
 
         self.salt = None
+        self.pwd = "super"
 
     async def multicommand(self, *commands: str, allow_warning: bool = True) -> dict:
         """Creates and sends multiple commands as one command to the miner.
@@ -1141,9 +1143,11 @@ class BTMinerV3RPCAPI(BaseMinerRPCAPI):
             token_hashed = bytearray(
                 base64.b64encode(hashlib.sha256(token_str.encode("utf-8")).digest())
             )
-            token_hashed[8] = 0
+            b_arr = bytearray(token_hashed)
+            b_arr[8] = 0
+            str_token = b_arr.split(b"\x00")[0].decode("utf-8")
             cmd["account"] = "super"
-            cmd["token"] = token_hashed.decode("ascii")
+            cmd["token"] = str_token
 
         # send the command
         ser = json.dumps(cmd).encode("utf-8")

pyasic/web/auradine.py

@@ -141,17 +141,16 @@ class AuradineWebAPI(BaseWebAPI):
                 self.send_command(cmd, allow_warning=allow_warning)
             )
 
-        await asyncio.gather(*[tasks[cmd] for cmd in tasks], return_exceptions=True)
+        results = await asyncio.gather(
+            *[tasks[cmd] for cmd in tasks], return_exceptions=True
+        )
 
         data = {"multicommand": True}
-        for cmd in tasks:
-            try:
-                result = tasks[cmd].result()
+        for cmd, result in zip(tasks.keys(), results):
+            if not isinstance(result, (APIError, Exception)):
                 if result is None or result == {}:
                     result = {}
                 data[cmd] = result
-            except APIError:
-                pass
 
         return data
 

pyasic/web/braiins_os/boser.py

@@ -84,13 +84,13 @@ class BOSerWebAPI(BaseWebAPI):
             except AttributeError:
                 pass
 
-        await asyncio.gather(*[t for t in tasks.values()], return_exceptions=True)
+        results = await asyncio.gather(
+            *[t for t in tasks.values()], return_exceptions=True
+        )
 
-        for cmd in tasks:
-            try:
-                result[cmd] = await tasks[cmd]
-            except (GRPCError, APIError, ConnectionError):
-                pass
+        for cmd, task_result in zip(tasks.keys(), results):
+            if not isinstance(task_result, (GRPCError, APIError, ConnectionError)):
+                result[cmd] = task_result
 
         return result
 

pyasic/web/espminer.py

@@ -71,17 +71,16 @@ class ESPMinerWebAPI(BaseWebAPI):
                 self.send_command(cmd, allow_warning=allow_warning)
             )
 
-        await asyncio.gather(*[tasks[cmd] for cmd in tasks], return_exceptions=True)
+        results = await asyncio.gather(
+            *[tasks[cmd] for cmd in tasks], return_exceptions=True
+        )
 
         data = {"multicommand": True}
-        for cmd in tasks:
-            try:
-                result = tasks[cmd].result()
+        for cmd, result in zip(tasks.keys(), results):
+            if not isinstance(result, (APIError, Exception)):
                 if result is None or result == {}:
                     result = {}
                 data[cmd] = result
-            except APIError:
-                pass
 
         return data
 

pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "pyasic"
-version = "0.76.6"
+version = "0.77.0"
 
 description = "A simplified and standardized interface for Bitcoin ASICs."
 authors = [{name = "UpstreamData", email = "brett@upstreamdata.ca"}]

tests/miners_tests/__init__.py

@@ -92,6 +92,7 @@ class MinersTest(unittest.TestCase):
                 "hashrate",
                 "hostname",
                 "is_mining",
+                "serial_number",
                 "mac",
                 "expected_hashrate",
                 "uptime",