improved miner_factory
This commit is contained in:
3
main.py
3
main.py
@@ -1,13 +1,16 @@
|
|||||||
from network import MinerNetwork
|
from network import MinerNetwork
|
||||||
from miners.bosminer import BOSminer
|
from miners.bosminer import BOSminer
|
||||||
import asyncio
|
import asyncio
|
||||||
|
import datetime
|
||||||
|
|
||||||
|
|
||||||
async def main():
|
async def main():
|
||||||
miner_network = MinerNetwork('192.168.1.1')
|
miner_network = MinerNetwork('192.168.1.1')
|
||||||
data = await miner_network.scan_network_for_miners()
|
data = await miner_network.scan_network_for_miners()
|
||||||
print(data)
|
print(data)
|
||||||
|
start = datetime.datetime.now()
|
||||||
config = await asyncio.gather(*[miner.get_config() for miner in data if isinstance(miner, BOSminer)])
|
config = await asyncio.gather(*[miner.get_config() for miner in data if isinstance(miner, BOSminer)])
|
||||||
|
print(datetime.datetime.now() - start)
|
||||||
print(config)
|
print(config)
|
||||||
|
|
||||||
if __name__ == '__main__':
|
if __name__ == '__main__':
|
||||||
|
|||||||
@@ -13,9 +13,10 @@ class MinerFactory:
|
|||||||
version_data = await self._get_version_data(ip)
|
version_data = await self._get_version_data(ip)
|
||||||
version = None
|
version = None
|
||||||
if version_data:
|
if version_data:
|
||||||
version = list(version_data['VERSION'][0].keys())[0]
|
version = list(version_data['VERSION'][0].keys())
|
||||||
if version:
|
if version:
|
||||||
if version == "BOSminer":
|
print(version_data)
|
||||||
|
if "BOSminer" in version or "BOSminer+" in version:
|
||||||
return BOSminer(str(ip))
|
return BOSminer(str(ip))
|
||||||
elif version == "CGMiner":
|
elif version == "CGMiner":
|
||||||
return CGMiner(str(ip))
|
return CGMiner(str(ip))
|
||||||
|
|||||||
Reference in New Issue
Block a user