backends: updated _get_pools in BOSer

This commit is contained in:
ytemiloluwa
2024-06-19 09:25:35 +01:00
parent eec8f66b81
commit 64265206c2
2 changed files with 3 additions and 18 deletions

View File

@@ -40,8 +40,6 @@ from pyasic.ssh.braiins_os import BOSMinerSSH
from pyasic.web.braiins_os import BOSerWebAPI, BOSMinerWebAPI from pyasic.web.braiins_os import BOSerWebAPI, BOSMinerWebAPI
from pyasic.web.braiins_os.proto.braiins.bos.v1 import SaveAction from pyasic.web.braiins_os.proto.braiins.bos.v1 import SaveAction
from pyasic.data.pools import PoolMetrics from pyasic.data.pools import PoolMetrics
from pyasic.web.braiins_os.boser import _get_pools_Group
from grpclib.client import Channel
BOSMINER_DATA_LOC = DataLocations( BOSMINER_DATA_LOC = DataLocations(
**{ **{
@@ -724,7 +722,7 @@ BOSER_DATA_LOC = DataLocations(
), ),
str(DataOptions.POOLS): DataFunction( str(DataOptions.POOLS): DataFunction(
"_get_pools", "_get_pools",
[RPCAPICommand("grpc_pools", "pools")] [WebAPICommand("grpc_pool_groups", "get_pool_groups")]
) )
} }
) )
@@ -1065,10 +1063,10 @@ class BOSer(BraiinsOSFirmware):
except LookupError: except LookupError:
pass pass
async def _get_pools(channel: Channel, grpc_pools: dict = None) -> List[PoolMetrics]: async def _get_pools(self, grpc_pools: dict = None) -> List[PoolMetrics]:
if grpc_pools is None: if grpc_pools is None:
try: try:
grpc_pools = await _get_pools_Group(channel) grpc_pools = await self.web.get_pool_groups()
except APIError: except APIError:
return [] return []

View File

@@ -30,19 +30,6 @@ from pyasic.web.base import BaseWebAPI
from .proto.braiins.bos import * from .proto.braiins.bos import *
from .proto.braiins.bos.v1 import * from .proto.braiins.bos.v1 import *
from .proto.braiins.bos.v1 import GetPoolGroupsRequest, PoolGroup
from .proto.braiins.bos.v1 import PoolServiceStub
async def _get_pools_Group(channel: Channel) -> List[PoolGroup]:
stub = PoolServiceStub(channel)
request = GetPoolGroupsRequest()
try:
response = await stub.get_pool_groups(request)
except GRPCError as e:
raise APIError(f"gRPC error: {e}")
return response.pool_groups
class BOSMinerGRPCStub( class BOSMinerGRPCStub(
ApiVersionServiceStub, ApiVersionServiceStub,