497ffb5bc0
* Create new BTMiner M6X backend class to represent Whatsminer new M6X generation * Add all new known types of Whatsminer M6X * Ensure all new types are imported in their respective __init__.py * Create all BTMiner API class for known types of new M6X generation * Ensure all new BTMiner API class are imported in __init__.py * Fix erroneous M6X models data * Ensure M6X miners are imported and add them to their MinerTypes dictionary in miner_factory.py
946 lines
33 KiB
Python
946 lines
33 KiB
Python
# ------------------------------------------------------------------------------
|
|
# Copyright 2022 Upstream Data Inc -
|
|
# -
|
|
# Licensed under the Apache License, Version 2.0 (the "License"); -
|
|
# you may not use this file except in compliance with the License. -
|
|
# You may obtain a copy of the License at -
|
|
# -
|
|
# http://www.apache.org/licenses/LICENSE-2.0 -
|
|
# -
|
|
# Unless required by applicable law or agreed to in writing, software -
|
|
# distributed under the License is distributed on an "AS IS" BASIS, -
|
|
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -
|
|
# See the License for the specific language governing permissions and -
|
|
# limitations under the License. -
|
|
# ------------------------------------------------------------------------------
|
|
import asyncio
|
|
import enum
|
|
import ipaddress
|
|
import json
|
|
import re
|
|
from typing import AsyncGenerator, Callable, List, Optional, Tuple, Union
|
|
|
|
import anyio
|
|
import httpx
|
|
|
|
from pyasic import settings
|
|
from pyasic.logger import logger
|
|
from pyasic.miners.antminer import *
|
|
from pyasic.miners.avalonminer import *
|
|
from pyasic.miners.backends import (
|
|
BFGMiner,
|
|
BMMiner,
|
|
BOSMiner,
|
|
BTMiner,
|
|
CGMiner,
|
|
CGMinerAvalon,
|
|
Hiveon,
|
|
LUXMiner,
|
|
VNish,
|
|
ePIC,
|
|
)
|
|
from pyasic.miners.base import AnyMiner
|
|
from pyasic.miners.goldshell import *
|
|
from pyasic.miners.innosilicon import *
|
|
from pyasic.miners.unknown import UnknownMiner
|
|
from pyasic.miners.whatsminer import *
|
|
|
|
|
|
class MinerTypes(enum.Enum):
|
|
ANTMINER = 0
|
|
WHATSMINER = 1
|
|
AVALONMINER = 2
|
|
INNOSILICON = 3
|
|
GOLDSHELL = 4
|
|
BRAIINS_OS = 5
|
|
VNISH = 6
|
|
HIVEON = 7
|
|
LUX_OS = 8
|
|
EPIC = 9
|
|
|
|
|
|
MINER_CLASSES = {
|
|
MinerTypes.ANTMINER: {
|
|
None: BMMiner,
|
|
"ANTMINER D3": CGMinerD3,
|
|
"ANTMINER HS3": BMMinerHS3,
|
|
"ANTMINER L3+": BMMinerL3Plus,
|
|
"ANTMINER DR5": CGMinerDR5,
|
|
"ANTMINER L7": BMMinerL7,
|
|
"ANTMINER E9 PRO": BMMinerE9Pro,
|
|
"ANTMINER S9": BMMinerS9,
|
|
"ANTMINER S9I": BMMinerS9i,
|
|
"ANTMINER S9J": BMMinerS9j,
|
|
"ANTMINER T9": BMMinerT9,
|
|
"ANTMINER Z15": CGMinerZ15,
|
|
"ANTMINER S17": BMMinerS17,
|
|
"ANTMINER S17+": BMMinerS17Plus,
|
|
"ANTMINER S17 PRO": BMMinerS17Pro,
|
|
"ANTMINER S17E": BMMinerS17e,
|
|
"ANTMINER T17": BMMinerT17,
|
|
"ANTMINER T17+": BMMinerT17Plus,
|
|
"ANTMINER T17E": BMMinerT17e,
|
|
"ANTMINER S19": BMMinerS19,
|
|
"ANTMINER S19L": BMMinerS19L,
|
|
"ANTMINER S19 PRO": BMMinerS19Pro,
|
|
"ANTMINER S19J": BMMinerS19j,
|
|
"ANTMINER S19I": BMMinerS19i,
|
|
"ANTMINER S19+": BMMinerS19Plus,
|
|
"ANTMINER S19J88NOPIC": BMMinerS19jNoPIC,
|
|
"ANTMINER S19PRO+": BMMinerS19ProPlus,
|
|
"ANTMINER S19J PRO": BMMinerS19jPro,
|
|
"ANTMINER S19 XP": BMMinerS19XP,
|
|
"ANTMINER S19A": BMMinerS19a,
|
|
"ANTMINER S19A PRO": BMMinerS19aPro,
|
|
"ANTMINER T19": BMMinerT19,
|
|
},
|
|
MinerTypes.WHATSMINER: {
|
|
None: BTMiner,
|
|
"M20V10": BTMinerM20V10,
|
|
"M20SV10": BTMinerM20SV10,
|
|
"M20SV20": BTMinerM20SV20,
|
|
"M20SV30": BTMinerM20SV30,
|
|
"M20PV10": BTMinerM20PV10,
|
|
"M20PV30": BTMinerM20PV30,
|
|
"M20S+V30": BTMinerM20SPlusV30,
|
|
"M21V10": BTMinerM21V10,
|
|
"M21SV20": BTMinerM21SV20,
|
|
"M21SV60": BTMinerM21SV60,
|
|
"M21SV70": BTMinerM21SV70,
|
|
"M21S+V20": BTMinerM21SPlusV20,
|
|
"M29V10": BTMinerM29V10,
|
|
"M30V10": BTMinerM30V10,
|
|
"M30V20": BTMinerM30V20,
|
|
"M30KV10": BTMinerM30KV10,
|
|
"M30LV10": BTMinerM30LV10,
|
|
"M30SV10": BTMinerM30SV10,
|
|
"M30SV20": BTMinerM30SV20,
|
|
"M30SV30": BTMinerM30SV30,
|
|
"M30SV40": BTMinerM30SV40,
|
|
"M30SV50": BTMinerM30SV50,
|
|
"M30SV60": BTMinerM30SV60,
|
|
"M30SV70": BTMinerM30SV70,
|
|
"M30SV80": BTMinerM30SV80,
|
|
"M30SVE10": BTMinerM30SVE10,
|
|
"M30SVE20": BTMinerM30SVE20,
|
|
"M30SVE30": BTMinerM30SVE30,
|
|
"M30SVE40": BTMinerM30SVE40,
|
|
"M30SVE50": BTMinerM30SVE50,
|
|
"M30SVE60": BTMinerM30SVE60,
|
|
"M30SVE70": BTMinerM30SVE70,
|
|
"M30SVF10": BTMinerM30SVF10,
|
|
"M30SVF20": BTMinerM30SVF20,
|
|
"M30SVF30": BTMinerM30SVF30,
|
|
"M30SVG10": BTMinerM30SVG10,
|
|
"M30SVG20": BTMinerM30SVG20,
|
|
"M30SVG30": BTMinerM30SVG30,
|
|
"M30SVG40": BTMinerM30SVG40,
|
|
"M30SVH10": BTMinerM30SVH10,
|
|
"M30SVH20": BTMinerM30SVH20,
|
|
"M30SVH30": BTMinerM30SVH30,
|
|
"M30SVH40": BTMinerM30SVH40,
|
|
"M30SVH50": BTMinerM30SVH50,
|
|
"M30SVH60": BTMinerM30SVH60,
|
|
"M30SVI20": BTMinerM30SVI20,
|
|
"M30S+V10": BTMinerM30SPlusV10,
|
|
"M30S+V20": BTMinerM30SPlusV20,
|
|
"M30S+V30": BTMinerM30SPlusV30,
|
|
"M30S+V40": BTMinerM30SPlusV40,
|
|
"M30S+V50": BTMinerM30SPlusV50,
|
|
"M30S+V60": BTMinerM30SPlusV60,
|
|
"M30S+V70": BTMinerM30SPlusV70,
|
|
"M30S+V80": BTMinerM30SPlusV80,
|
|
"M30S+V90": BTMinerM30SPlusV90,
|
|
"M30S+V100": BTMinerM30SPlusV100,
|
|
"M30S+VE30": BTMinerM30SPlusVE30,
|
|
"M30S+VE40": BTMinerM30SPlusVE40,
|
|
"M30S+VE50": BTMinerM30SPlusVE50,
|
|
"M30S+VE60": BTMinerM30SPlusVE60,
|
|
"M30S+VE70": BTMinerM30SPlusVE70,
|
|
"M30S+VE80": BTMinerM30SPlusVE80,
|
|
"M30S+VE90": BTMinerM30SPlusVE90,
|
|
"M30S+VE100": BTMinerM30SPlusVE100,
|
|
"M30S+VF20": BTMinerM30SPlusVF20,
|
|
"M30S+VF30": BTMinerM30SPlusVF30,
|
|
"M30S+VG20": BTMinerM30SPlusVG20,
|
|
"M30S+VG30": BTMinerM30SPlusVG30,
|
|
"M30S+VG40": BTMinerM30SPlusVG40,
|
|
"M30S+VG50": BTMinerM30SPlusVG50,
|
|
"M30S+VG60": BTMinerM30SPlusVG60,
|
|
"M30S+VH10": BTMinerM30SPlusVH10,
|
|
"M30S+VH20": BTMinerM30SPlusVH20,
|
|
"M30S+VH30": BTMinerM30SPlusVH30,
|
|
"M30S+VH40": BTMinerM30SPlusVH40,
|
|
"M30S+VH50": BTMinerM30SPlusVH50,
|
|
"M30S+VH60": BTMinerM30SPlusVH60,
|
|
"M30S++V10": BTMinerM30SPlusPlusV10,
|
|
"M30S++V20": BTMinerM30SPlusPlusV20,
|
|
"M30S++VE30": BTMinerM30SPlusPlusVE30,
|
|
"M30S++VE40": BTMinerM30SPlusPlusVE40,
|
|
"M30S++VE50": BTMinerM30SPlusPlusVE50,
|
|
"M30S++VF40": BTMinerM30SPlusPlusVF40,
|
|
"M30S++VG30": BTMinerM30SPlusPlusVG30,
|
|
"M30S++VG40": BTMinerM30SPlusPlusVG40,
|
|
"M30S++VG50": BTMinerM30SPlusPlusVG50,
|
|
"M30S++VH10": BTMinerM30SPlusPlusVH10,
|
|
"M30S++VH20": BTMinerM30SPlusPlusVH20,
|
|
"M30S++VH30": BTMinerM30SPlusPlusVH30,
|
|
"M30S++VH40": BTMinerM30SPlusPlusVH40,
|
|
"M30S++VH50": BTMinerM30SPlusPlusVH50,
|
|
"M30S++VH60": BTMinerM30SPlusPlusVH60,
|
|
"M30S++VH70": BTMinerM30SPlusPlusVH70,
|
|
"M30S++VH80": BTMinerM30SPlusPlusVH80,
|
|
"M30S++VH90": BTMinerM30SPlusPlusVH90,
|
|
"M30S++VH100": BTMinerM30SPlusPlusVH100,
|
|
"M30S++VJ20": BTMinerM30SPlusPlusVJ20,
|
|
"M30S++VJ30": BTMinerM30SPlusPlusVJ30,
|
|
"M31V10": BTMinerM31V10,
|
|
"M31V20": BTMinerM31V20,
|
|
"M31HV10": BTMinerM31HV10,
|
|
"M31HV40": BTMinerM31HV40,
|
|
"M31LV10": BTMinerM31LV10,
|
|
"M31SV10": BTMinerM31SV10,
|
|
"M31SV20": BTMinerM31SV20,
|
|
"M31SV30": BTMinerM31SV30,
|
|
"M31SV40": BTMinerM31SV40,
|
|
"M31SV50": BTMinerM31SV50,
|
|
"M31SV60": BTMinerM31SV60,
|
|
"M31SV70": BTMinerM31SV70,
|
|
"M31SV80": BTMinerM31SV80,
|
|
"M31SV90": BTMinerM31SV90,
|
|
"M31SVE10": BTMinerM31SVE10,
|
|
"M31SVE20": BTMinerM31SVE20,
|
|
"M31SVE30": BTMinerM31SVE30,
|
|
"M31SEV10": BTMinerM31SEV10,
|
|
"M31SEV20": BTMinerM31SEV20,
|
|
"M31SEV30": BTMinerM31SEV30,
|
|
"M31S+V10": BTMinerM31SPlusV10,
|
|
"M31S+V20": BTMinerM31SPlusV20,
|
|
"M31S+V30": BTMinerM31SPlusV30,
|
|
"M31S+V40": BTMinerM31SPlusV40,
|
|
"M31S+V50": BTMinerM31SPlusV50,
|
|
"M31S+V60": BTMinerM31SPlusV60,
|
|
"M31S+V80": BTMinerM31SPlusV80,
|
|
"M31S+V90": BTMinerM31SPlusV90,
|
|
"M31S+V100": BTMinerM31SPlusV100,
|
|
"M31S+VE10": BTMinerM31SPlusVE10,
|
|
"M31S+VE20": BTMinerM31SPlusVE20,
|
|
"M31S+VE30": BTMinerM31SPlusVE30,
|
|
"M31S+VE40": BTMinerM31SPlusVE40,
|
|
"M31S+VE50": BTMinerM31SPlusVE50,
|
|
"M31S+VE60": BTMinerM31SPlusVE60,
|
|
"M31S+VE80": BTMinerM31SPlusVE80,
|
|
"M31S+VF20": BTMinerM31SPlusVF20,
|
|
"M31S+VF30": BTMinerM31SPlusVF30,
|
|
"M31S+VG20": BTMinerM31SPlusVG20,
|
|
"M31S+VG30": BTMinerM31SPlusVG30,
|
|
"M32V10": BTMinerM32V10,
|
|
"M32V20": BTMinerM32V20,
|
|
"M33V10": BTMinerM33V10,
|
|
"M33V20": BTMinerM33V20,
|
|
"M33V30": BTMinerM33V30,
|
|
"M33SVG30": BTMinerM33SVG30,
|
|
"M33S+VG20": BTMinerM33SPlusVG20,
|
|
"M33S+VH20": BTMinerM33SPlusVH20,
|
|
"M33S+VH30": BTMinerM33SPlusVH30,
|
|
"M33S++VH20": BTMinerM33SPlusPlusVH20,
|
|
"M33S++VH30": BTMinerM33SPlusPlusVH30,
|
|
"M33S++VG40": BTMinerM33SPlusPlusVG40,
|
|
"M34S+VE10": BTMinerM34SPlusVE10,
|
|
"M36SVE10": BTMinerM36SVE10,
|
|
"M36S+VG30": BTMinerM36SPlusVG30,
|
|
"M36S++VH30": BTMinerM36SPlusPlusVH30,
|
|
"M39V10": BTMinerM39V10,
|
|
"M39V20": BTMinerM39V20,
|
|
"M39V30": BTMinerM39V30,
|
|
"M50VE30": BTMinerM50VE30,
|
|
"M50VG30": BTMinerM50VG30,
|
|
"M50VH10": BTMinerM50VH10,
|
|
"M50VH20": BTMinerM50VH20,
|
|
"M50VH30": BTMinerM50VH30,
|
|
"M50VH40": BTMinerM50VH40,
|
|
"M50VH50": BTMinerM50VH50,
|
|
"M50VH60": BTMinerM50VH60,
|
|
"M50VH70": BTMinerM50VH70,
|
|
"M50VH80": BTMinerM50VH80,
|
|
"M50VJ10": BTMinerM50VJ10,
|
|
"M50VJ20": BTMinerM50VJ20,
|
|
"M50VJ30": BTMinerM50VJ30,
|
|
"M50SVJ10": BTMinerM50SVJ10,
|
|
"M50SVJ20": BTMinerM50SVJ20,
|
|
"M50SVJ30": BTMinerM50SVJ30,
|
|
"M50SVH10": BTMinerM50SVH10,
|
|
"M50SVH20": BTMinerM50SVH20,
|
|
"M50SVH30": BTMinerM50SVH30,
|
|
"M50SVH40": BTMinerM50SVH40,
|
|
"M50SVH50": BTMinerM50SVH50,
|
|
"M50S+VH30": BTMinerM50SPlusVH30,
|
|
"M50S+VH40": BTMinerM50SPlusVH40,
|
|
"M50S+VJ30": BTMinerM50SPlusVJ30,
|
|
"M50S+VK20": BTMinerM50SPlusVK20,
|
|
"M50S++VK10": BTMinerM50SPlusPlusVK10,
|
|
"M50S++VK20": BTMinerM50SPlusPlusVK20,
|
|
"M50S++VK30": BTMinerM50SPlusPlusVK30,
|
|
"M53VH30": BTMinerM53VH30,
|
|
"M53SVH30": BTMinerM53SVH30,
|
|
"M53S+VJ30": BTMinerM53SPlusVJ30,
|
|
"M56VH30": BTMinerM56VH30,
|
|
"M56SVH30": BTMinerM56SVH30,
|
|
"M56S+VJ30": BTMinerM56SPlusVJ30,
|
|
"M59VH30": BTMinerM59VH30,
|
|
"M60VK10": BTMinerM60VK10,
|
|
"M60VK20": BTMinerM60VK20,
|
|
"M60VK30": BTMinerM60VK30,
|
|
"M60VK40": BTMinerM60VK40,
|
|
"M60SVK10": BTMinerM60SVK10,
|
|
"M60SVK20": BTMinerM60SVK20,
|
|
"M60SVK30": BTMinerM60SVK30,
|
|
"M60SVK40": BTMinerM60SVK40,
|
|
"M63VK10": BTMinerM63VK10,
|
|
"M63VK20": BTMinerM63VK20,
|
|
"M63VK30": BTMinerM63VK30,
|
|
"M63SVK10": BTMinerM63SVK10,
|
|
"M63SVK20": BTMinerM63SVK20,
|
|
"M63SVK30": BTMinerM63SVK30,
|
|
"M66VK20": BTMinerM66VK20,
|
|
"M66VK30": BTMinerM66VK30,
|
|
"M66SVK20": BTMinerM66SVK20,
|
|
"M66SVK30": BTMinerM66SVK30,
|
|
"M66SVK40": BTMinerM66SVK40,
|
|
},
|
|
MinerTypes.AVALONMINER: {
|
|
None: CGMinerAvalon,
|
|
"AVALONMINER 721": CGMinerAvalon721,
|
|
"AVALONMINER 741": CGMinerAvalon741,
|
|
"AVALONMINER 761": CGMinerAvalon761,
|
|
"AVALONMINER 821": CGMinerAvalon821,
|
|
"AVALONMINER 841": CGMinerAvalon841,
|
|
"AVALONMINER 851": CGMinerAvalon851,
|
|
"AVALONMINER 921": CGMinerAvalon921,
|
|
"AVALONMINER 1026": CGMinerAvalon1026,
|
|
"AVALONMINER 1047": CGMinerAvalon1047,
|
|
"AVALONMINER 1066": CGMinerAvalon1066,
|
|
"AVALONMINER 1166PRO": CGMinerAvalon1166Pro,
|
|
"AVALONMINER 1246": CGMinerAvalon1246,
|
|
},
|
|
MinerTypes.INNOSILICON: {
|
|
None: CGMiner,
|
|
"T3H+": CGMinerT3HPlus,
|
|
"A10X": CGMinerA10X,
|
|
},
|
|
MinerTypes.GOLDSHELL: {
|
|
None: BFGMiner,
|
|
"GOLDSHELL CK5": BFGMinerCK5,
|
|
"GOLDSHELL HS5": BFGMinerHS5,
|
|
"GOLDSHELL KD5": BFGMinerKD5,
|
|
"GOLDSHELL KDMAX": BFGMinerKDMax,
|
|
},
|
|
MinerTypes.BRAIINS_OS: {
|
|
None: BOSMiner,
|
|
"ANTMINER S9": BOSMinerS9,
|
|
"ANTMINER S17": BOSMinerS17,
|
|
"ANTMINER S17+": BOSMinerS17Plus,
|
|
"ANTMINER S17 PRO": BOSMinerS17Pro,
|
|
"ANTMINER S17E": BOSMinerS17e,
|
|
"ANTMINER T17": BOSMinerT17,
|
|
"ANTMINER T17+": BOSMinerT17Plus,
|
|
"ANTMINER T17E": BOSMinerT17e,
|
|
"ANTMINER S19": BOSMinerS19,
|
|
"ANTMINER S19 PRO": BOSMinerS19Pro,
|
|
"ANTMINER S19J": BOSMinerS19j,
|
|
"ANTMINER S19J88NOPIC": BOSMinerS19jNoPIC,
|
|
"ANTMINER S19J PRO": BOSMinerS19jPro,
|
|
"ANTMINER S19J PRO NOPIC": BOSMinerS19jPro,
|
|
"ANTMINER T19": BOSMinerT19,
|
|
},
|
|
MinerTypes.VNISH: {
|
|
None: VNish,
|
|
"ANTMINER L3+": VnishL3Plus,
|
|
"ANTMINER S17+": VNishS17Plus,
|
|
"ANTMINER S17 PRO": VNishS17Pro,
|
|
"ANTMINER S19": VNishS19,
|
|
"ANTMINER S19NOPIC": VNishS19NoPIC,
|
|
"ANTMINER S19 PRO": VNishS19Pro,
|
|
"ANTMINER S19J": VNishS19j,
|
|
"ANTMINER S19J PRO": VNishS19jPro,
|
|
"ANTMINER S19A": VNishS19a,
|
|
"ANTMINER S19A PRO": VNishS19aPro,
|
|
"ANTMINER T19": VNishT19,
|
|
},
|
|
MinerTypes.EPIC: {
|
|
None: ePIC,
|
|
"ANTMINER S19": ePICS19,
|
|
"ANTMINER S19 PRO": ePICS19Pro,
|
|
"ANTMINER S19J": ePICS19j,
|
|
"ANTMINER S19J PRO": ePICS19jPro,
|
|
"ANTMINER S19J PRO+": ePICS19jProPlus,
|
|
"ANTMINER S19K PRO": ePICS19kPro,
|
|
"ANTMINER S19 XP": ePICS19XP,
|
|
},
|
|
MinerTypes.HIVEON: {
|
|
None: Hiveon,
|
|
"ANTMINER T9": HiveonT9,
|
|
},
|
|
MinerTypes.LUX_OS: {
|
|
None: LUXMiner,
|
|
"ANTMINER S9": LUXMinerS9,
|
|
},
|
|
}
|
|
|
|
|
|
async def concurrent_get_first_result(tasks: list, verification_func: Callable):
|
|
while True:
|
|
await asyncio.sleep(0)
|
|
if len(tasks) == 0:
|
|
return
|
|
for task in tasks:
|
|
if task.done():
|
|
try:
|
|
result = await task
|
|
except asyncio.CancelledError:
|
|
for t in tasks:
|
|
t.cancel()
|
|
raise
|
|
else:
|
|
if not verification_func(result):
|
|
continue
|
|
for t in tasks:
|
|
t.cancel()
|
|
return result
|
|
|
|
|
|
class MinerFactory:
|
|
def __init__(self):
|
|
self.cache = {}
|
|
|
|
def clear_cached_miners(self):
|
|
self.cache = {}
|
|
|
|
async def get_multiple_miners(
|
|
self, ips: List[str], limit: int = 200
|
|
) -> List[AnyMiner]:
|
|
results = []
|
|
|
|
async for miner in self.get_miner_generator(ips, limit):
|
|
results.append(miner)
|
|
|
|
return results
|
|
|
|
async def get_miner_generator(self, ips: list, limit: int = 200) -> AsyncGenerator:
|
|
tasks = []
|
|
semaphore = asyncio.Semaphore(limit)
|
|
|
|
for ip in ips:
|
|
tasks.append(asyncio.create_task(self.get_miner(ip)))
|
|
|
|
for task in tasks:
|
|
async with semaphore:
|
|
result = await task
|
|
if result is not None:
|
|
yield result
|
|
|
|
async def get_miner(self, ip: str):
|
|
ip = str(ip)
|
|
if ip in self.cache:
|
|
return self.cache[ip]
|
|
|
|
miner_type = None
|
|
|
|
for _ in range(settings.get("factory_get_retries", 1)):
|
|
task = asyncio.create_task(self._get_miner_type(ip))
|
|
try:
|
|
miner_type = await asyncio.wait_for(
|
|
task, timeout=settings.get("factory_get_timeout", 3)
|
|
)
|
|
except asyncio.TimeoutError:
|
|
task.cancel()
|
|
else:
|
|
if miner_type is not None:
|
|
break
|
|
|
|
if miner_type is not None:
|
|
miner_model = None
|
|
miner_model_fns = {
|
|
MinerTypes.ANTMINER: self.get_miner_model_antminer,
|
|
MinerTypes.WHATSMINER: self.get_miner_model_whatsminer,
|
|
MinerTypes.AVALONMINER: self.get_miner_model_avalonminer,
|
|
MinerTypes.INNOSILICON: self.get_miner_model_innosilicon,
|
|
MinerTypes.GOLDSHELL: self.get_miner_model_goldshell,
|
|
MinerTypes.BRAIINS_OS: self.get_miner_model_braiins_os,
|
|
MinerTypes.VNISH: self.get_miner_model_vnish,
|
|
MinerTypes.EPIC: self.get_miner_model_epic,
|
|
MinerTypes.HIVEON: self.get_miner_model_hiveon,
|
|
MinerTypes.LUX_OS: self.get_miner_model_luxos,
|
|
}
|
|
fn = miner_model_fns.get(miner_type)
|
|
|
|
if fn is not None:
|
|
task = asyncio.create_task(fn(ip))
|
|
try:
|
|
miner_model = await asyncio.wait_for(
|
|
task, timeout=settings.get("factory_get_timeout", 3)
|
|
)
|
|
except asyncio.TimeoutError:
|
|
task.cancel()
|
|
|
|
boser_enabled = None
|
|
if miner_type == MinerTypes.BRAIINS_OS:
|
|
boser_enabled = await self.get_boser_braiins_os(ip)
|
|
|
|
miner = self._select_miner_from_classes(
|
|
ip,
|
|
miner_type=miner_type,
|
|
miner_model=miner_model,
|
|
boser_enabled=boser_enabled,
|
|
)
|
|
|
|
if miner is not None and not isinstance(miner, UnknownMiner):
|
|
self.cache[ip] = miner
|
|
return miner
|
|
|
|
async def _get_miner_type(self, ip: str):
|
|
tasks = [
|
|
asyncio.create_task(self._get_miner_web(ip)),
|
|
asyncio.create_task(self._get_miner_socket(ip)),
|
|
]
|
|
|
|
return await concurrent_get_first_result(tasks, lambda x: x is not None)
|
|
|
|
async def _get_miner_web(self, ip: str):
|
|
urls = [f"http://{ip}/", f"https://{ip}/"]
|
|
async with httpx.AsyncClient(
|
|
transport=settings.transport(verify=False)
|
|
) as session:
|
|
tasks = [asyncio.create_task(self._web_ping(session, url)) for url in urls]
|
|
|
|
text, resp = await concurrent_get_first_result(
|
|
tasks,
|
|
lambda x: x[0] is not None
|
|
and self._parse_web_type(x[0], x[1]) is not None,
|
|
)
|
|
if text is not None:
|
|
return self._parse_web_type(text, resp)
|
|
|
|
@staticmethod
|
|
async def _web_ping(
|
|
session: httpx.AsyncClient, url: str
|
|
) -> Tuple[Optional[str], Optional[httpx.Response]]:
|
|
try:
|
|
resp = await session.get(url, follow_redirects=True)
|
|
return resp.text, resp
|
|
except (
|
|
httpx.HTTPError,
|
|
asyncio.TimeoutError,
|
|
anyio.EndOfStream,
|
|
anyio.ClosedResourceError,
|
|
):
|
|
pass
|
|
return None, None
|
|
|
|
@staticmethod
|
|
def _parse_web_type(web_text: str, web_resp: httpx.Response) -> MinerTypes:
|
|
if web_resp.status_code == 401 and 'realm="antMiner' in web_resp.headers.get(
|
|
"www-authenticate", ""
|
|
):
|
|
return MinerTypes.ANTMINER
|
|
if len(web_resp.history) > 0:
|
|
history_resp = web_resp.history[0]
|
|
if (
|
|
"/cgi-bin/luci" in web_text
|
|
and history_resp.status_code == 307
|
|
and "https://" in history_resp.headers.get("location", "")
|
|
):
|
|
return MinerTypes.WHATSMINER
|
|
if "Braiins OS" in web_text:
|
|
return MinerTypes.BRAIINS_OS
|
|
if "cloud-box" in web_text:
|
|
return MinerTypes.GOLDSHELL
|
|
if "AnthillOS" in web_text:
|
|
return MinerTypes.VNISH
|
|
if "Miner Web Dashboard" in web_text:
|
|
return MinerTypes.EPIC
|
|
if "Avalon" in web_text:
|
|
return MinerTypes.AVALONMINER
|
|
if "DragonMint" in web_text:
|
|
return MinerTypes.INNOSILICON
|
|
|
|
async def _get_miner_socket(self, ip: str):
|
|
commands = ["version", "devdetails"]
|
|
tasks = [asyncio.create_task(self._socket_ping(ip, cmd)) for cmd in commands]
|
|
|
|
data = await concurrent_get_first_result(
|
|
tasks, lambda x: x is not None and self._parse_socket_type(x) is not None
|
|
)
|
|
if data is not None:
|
|
d = self._parse_socket_type(data)
|
|
return d
|
|
|
|
@staticmethod
|
|
async def _socket_ping(ip: str, cmd: str) -> Optional[str]:
|
|
data = b""
|
|
try:
|
|
reader, writer = await asyncio.wait_for(
|
|
asyncio.open_connection(str(ip), 4028),
|
|
timeout=settings.get("factory_get_timeout", 3),
|
|
)
|
|
except (ConnectionError, OSError, asyncio.TimeoutError):
|
|
return
|
|
|
|
cmd = {"command": cmd}
|
|
|
|
try:
|
|
# send the command
|
|
writer.write(json.dumps(cmd).encode("utf-8"))
|
|
await writer.drain()
|
|
|
|
# loop to receive all the data
|
|
while True:
|
|
try:
|
|
d = await asyncio.wait_for(reader.read(4096), timeout=1)
|
|
if not d:
|
|
break
|
|
data += d
|
|
except asyncio.TimeoutError:
|
|
pass
|
|
except ConnectionResetError:
|
|
return
|
|
except asyncio.CancelledError:
|
|
raise
|
|
except (ConnectionError, OSError):
|
|
return
|
|
finally:
|
|
# Handle cancellation explicitly
|
|
if writer.transport.is_closing():
|
|
writer.transport.close()
|
|
else:
|
|
writer.close()
|
|
try:
|
|
await writer.wait_closed()
|
|
except (ConnectionError, OSError):
|
|
return
|
|
if data:
|
|
return data.decode("utf-8")
|
|
|
|
@staticmethod
|
|
def _parse_socket_type(data: str) -> MinerTypes:
|
|
upper_data = data.upper()
|
|
if "BOSMINER" in upper_data or "BOSER" in upper_data:
|
|
return MinerTypes.BRAIINS_OS
|
|
if "BTMINER" in upper_data or "BITMICRO" in upper_data:
|
|
return MinerTypes.WHATSMINER
|
|
if "VNISH" in upper_data:
|
|
return MinerTypes.VNISH
|
|
if "HIVEON" in upper_data:
|
|
return MinerTypes.HIVEON
|
|
if "LUXMINER" in upper_data:
|
|
return MinerTypes.LUX_OS
|
|
if "ANTMINER" in upper_data and not "DEVDETAILS" in upper_data:
|
|
return MinerTypes.ANTMINER
|
|
if "INTCHAINS_QOMO" in upper_data:
|
|
return MinerTypes.GOLDSHELL
|
|
if "AVALON" in upper_data:
|
|
return MinerTypes.AVALONMINER
|
|
|
|
async def send_web_command(
|
|
self,
|
|
ip: Union[ipaddress.ip_address, str],
|
|
location: str,
|
|
auth: Optional[httpx.DigestAuth] = None,
|
|
) -> Optional[dict]:
|
|
async with httpx.AsyncClient(transport=settings.transport()) as session:
|
|
try:
|
|
data = await session.get(
|
|
f"http://{str(ip)}{location}",
|
|
auth=auth,
|
|
timeout=settings.get("factory_get_timeout", 3),
|
|
)
|
|
except (httpx.HTTPError, asyncio.TimeoutError):
|
|
logger.info(f"{ip}: Web command timeout.")
|
|
return
|
|
if data is None:
|
|
return
|
|
try:
|
|
json_data = data.json()
|
|
except (json.JSONDecodeError, asyncio.TimeoutError):
|
|
try:
|
|
return json.loads(data.text)
|
|
except (json.JSONDecodeError, httpx.HTTPError):
|
|
return
|
|
else:
|
|
return json_data
|
|
|
|
async def send_api_command(
|
|
self, ip: Union[ipaddress.ip_address, str], command: str
|
|
) -> Optional[dict]:
|
|
data = b""
|
|
try:
|
|
reader, writer = await asyncio.open_connection(str(ip), 4028)
|
|
except (ConnectionError, OSError):
|
|
return
|
|
cmd = {"command": command}
|
|
|
|
try:
|
|
# send the command
|
|
writer.write(json.dumps(cmd).encode("utf-8"))
|
|
await writer.drain()
|
|
|
|
# loop to receive all the data
|
|
while True:
|
|
d = await reader.read(4096)
|
|
if not d:
|
|
break
|
|
data += d
|
|
|
|
writer.close()
|
|
await writer.wait_closed()
|
|
except asyncio.CancelledError:
|
|
writer.close()
|
|
await writer.wait_closed()
|
|
return
|
|
except (ConnectionError, OSError):
|
|
return
|
|
if data == b"Socket connect failed: Connection refused\n":
|
|
return
|
|
|
|
data = await self._fix_api_data(data)
|
|
|
|
try:
|
|
data = json.loads(data)
|
|
except json.JSONDecodeError:
|
|
return {}
|
|
|
|
return data
|
|
|
|
@staticmethod
|
|
async def _fix_api_data(data: bytes):
|
|
if data.endswith(b"\x00"):
|
|
str_data = data.decode("utf-8")[:-1]
|
|
else:
|
|
str_data = data.decode("utf-8")
|
|
# 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()
|
|
str_data = str_data.replace("\n", "")
|
|
# fix an error with a bmminer return not having a specific comma that breaks json.loads()
|
|
str_data = str_data.replace("}{", "},{")
|
|
# fix an error with a bmminer return having a specific comma that breaks json.loads()
|
|
str_data = str_data.replace("[,{", "[{")
|
|
# fix an error with a btminer return having a missing comma. (2023-01-06 version)
|
|
str_data = str_data.replace('""temp0', '","temp0')
|
|
# fix an error with Avalonminers returning inf and nan
|
|
str_data = str_data.replace("info", "1nfo")
|
|
str_data = str_data.replace("inf", "0")
|
|
str_data = str_data.replace("1nfo", "info")
|
|
str_data = str_data.replace("nan", "0")
|
|
# fix whatever this garbage from avalonminers is `,"id":1}`
|
|
if str_data.startswith(","):
|
|
str_data = f"{{{str_data[1:]}"
|
|
# try to fix an error with overflowing the recieve buffer
|
|
# this can happen in cases such as bugged btminers returning arbitrary length error info with 100s of errors.
|
|
if not str_data.endswith("}"):
|
|
str_data = ",".join(str_data.split(",")[:-1]) + "}"
|
|
|
|
# fix a really nasty bug with whatsminer API v2.0.4 where they return a list structured like a dict
|
|
if re.search(r"\"error_code\":\[\".+\"\]", str_data):
|
|
str_data = str_data.replace("[", "{").replace("]", "}")
|
|
|
|
return str_data
|
|
|
|
@staticmethod
|
|
def _select_miner_from_classes(
|
|
ip: ipaddress.ip_address,
|
|
miner_model: Union[str, None],
|
|
miner_type: Union[MinerTypes, None],
|
|
boser_enabled: bool = None,
|
|
) -> AnyMiner:
|
|
kwargs = {}
|
|
if boser_enabled is not None:
|
|
kwargs["boser"] = boser_enabled
|
|
try:
|
|
return MINER_CLASSES[miner_type][str(miner_model).upper()](ip, **kwargs)
|
|
except LookupError:
|
|
if miner_type in MINER_CLASSES:
|
|
return MINER_CLASSES[miner_type][None](ip)
|
|
return UnknownMiner(str(ip))
|
|
|
|
async def get_miner_model_antminer(self, ip: str):
|
|
tasks = [
|
|
asyncio.create_task(self._get_model_antminer_web(ip)),
|
|
asyncio.create_task(self._get_model_antminer_sock(ip)),
|
|
]
|
|
|
|
return await concurrent_get_first_result(tasks, lambda x: x is not None)
|
|
|
|
async def _get_model_antminer_web(self, ip: str):
|
|
# last resort, this is slow
|
|
auth = httpx.DigestAuth("root", "root")
|
|
web_json_data = await self.send_web_command(
|
|
ip, "/cgi-bin/get_system_info.cgi", auth=auth
|
|
)
|
|
|
|
try:
|
|
miner_model = web_json_data["minertype"]
|
|
|
|
return miner_model
|
|
except (TypeError, LookupError):
|
|
pass
|
|
|
|
async def _get_model_antminer_sock(self, ip: str):
|
|
sock_json_data = await self.send_api_command(ip, "version")
|
|
try:
|
|
miner_model = sock_json_data["VERSION"][0]["Type"]
|
|
|
|
if " (" in miner_model:
|
|
split_miner_model = miner_model.split(" (")
|
|
miner_model = split_miner_model[0]
|
|
|
|
return miner_model
|
|
except (TypeError, LookupError):
|
|
pass
|
|
|
|
sock_json_data = await self.send_api_command(ip, "stats")
|
|
try:
|
|
miner_model = sock_json_data["STATS"][0]["Type"]
|
|
|
|
if " (" in miner_model:
|
|
split_miner_model = miner_model.split(" (")
|
|
miner_model = split_miner_model[0]
|
|
|
|
return miner_model
|
|
except (TypeError, LookupError):
|
|
pass
|
|
|
|
async def get_miner_model_goldshell(self, ip: str):
|
|
json_data = await self.send_web_command(ip, "/mcb/status")
|
|
|
|
try:
|
|
miner_model = json_data["model"].replace("-", " ")
|
|
|
|
return miner_model
|
|
except (TypeError, LookupError):
|
|
pass
|
|
|
|
async def get_miner_model_whatsminer(self, ip: str):
|
|
sock_json_data = await self.send_api_command(ip, "devdetails")
|
|
try:
|
|
miner_model = sock_json_data["DEVDETAILS"][0]["Model"].replace("_", "")
|
|
miner_model = miner_model[:-1] + "0"
|
|
|
|
return miner_model
|
|
except (TypeError, LookupError):
|
|
pass
|
|
|
|
async def get_miner_model_avalonminer(self, ip: str) -> Optional[str]:
|
|
sock_json_data = await self.send_api_command(ip, "version")
|
|
try:
|
|
miner_model = sock_json_data["VERSION"][0]["PROD"]
|
|
if "-" in miner_model:
|
|
miner_model = miner_model.split("-")[0]
|
|
|
|
return miner_model
|
|
except (TypeError, LookupError):
|
|
pass
|
|
|
|
async def get_miner_model_innosilicon(self, ip: str) -> Optional[str]:
|
|
try:
|
|
async with httpx.AsyncClient(transport=settings.transport()) as session:
|
|
auth_req = await session.post(
|
|
f"http://{ip}/api/auth",
|
|
data={"username": "admin", "password": "admin"},
|
|
)
|
|
auth = auth_req.json()["jwt"]
|
|
|
|
web_data = (
|
|
await session.post(
|
|
f"http://{ip}/api/type",
|
|
headers={"Authorization": "Bearer " + auth},
|
|
data={},
|
|
)
|
|
).json()
|
|
return web_data["type"]
|
|
except (httpx.HTTPError, LookupError):
|
|
pass
|
|
|
|
async def get_miner_model_braiins_os(self, ip: str) -> Optional[str]:
|
|
sock_json_data = await self.send_api_command(ip, "devdetails")
|
|
try:
|
|
miner_model = sock_json_data["DEVDETAILS"][0]["Model"].replace(
|
|
"Bitmain ", ""
|
|
)
|
|
|
|
return miner_model
|
|
except (TypeError, LookupError):
|
|
pass
|
|
|
|
try:
|
|
async with httpx.AsyncClient(transport=settings.transport()) as session:
|
|
d = await session.post(
|
|
f"http://{ip}/graphql",
|
|
json={"query": "{bosminer {info{modelName}}}"},
|
|
)
|
|
if d.status_code == 200:
|
|
json_data = d.json()
|
|
miner_model = json_data["data"]["bosminer"]["info"]["modelName"]
|
|
return miner_model
|
|
except (httpx.HTTPError, LookupError):
|
|
pass
|
|
|
|
async def get_boser_braiins_os(self, ip: str):
|
|
# TODO: refine this check
|
|
try:
|
|
sock_json_data = await self.send_api_command(ip, "version")
|
|
return sock_json_data["STATUS"][0]["Msg"].split(" ")[0].upper() == "BOSER"
|
|
except LookupError:
|
|
# let the bosminer class decide
|
|
return None
|
|
|
|
async def get_miner_model_vnish(self, ip: str) -> Optional[str]:
|
|
sock_json_data = await self.send_api_command(ip, "stats")
|
|
try:
|
|
miner_model = sock_json_data["STATS"][0]["Type"]
|
|
if " (" in miner_model:
|
|
split_miner_model = miner_model.split(" (")
|
|
miner_model = split_miner_model[0]
|
|
|
|
if "(88)" in miner_model:
|
|
miner_model = miner_model.replace("(88)", "NOPIC")
|
|
|
|
if " AML" in miner_model:
|
|
miner_model = miner_model.replace(" AML", "")
|
|
|
|
return miner_model
|
|
except (TypeError, LookupError):
|
|
pass
|
|
|
|
async def get_miner_model_epic(self, ip: str) -> Optional[str]:
|
|
sock_json_data = await self.send_web_command(ip, ":4028/capabilities")
|
|
try:
|
|
miner_model = sock_json_data["Model"]
|
|
return miner_model
|
|
except (TypeError, LookupError):
|
|
pass
|
|
|
|
async def get_miner_model_hiveon(self, ip: str) -> Optional[str]:
|
|
sock_json_data = await self.send_api_command(ip, "version")
|
|
try:
|
|
miner_type = sock_json_data["VERSION"][0]["Type"]
|
|
|
|
return miner_type.replace(" HIVEON", "")
|
|
except (TypeError, LookupError):
|
|
pass
|
|
|
|
async def get_miner_model_luxos(self, ip: str):
|
|
sock_json_data = await self.send_api_command(ip, "version")
|
|
try:
|
|
miner_model = sock_json_data["VERSION"][0]["Type"]
|
|
|
|
if " (" in miner_model:
|
|
split_miner_model = miner_model.split(" (")
|
|
miner_model = split_miner_model[0]
|
|
return miner_model
|
|
except (TypeError, LookupError):
|
|
pass
|
|
|
|
|
|
miner_factory = MinerFactory()
|