修改pubkey的bug

api/node.py

@@ -31,23 +31,23 @@ async def subscribe(
 ):
     try:
         int(bind_node.pub_key)
-    except Exception as e:
         raise RequestInvalidParamsError()
-    node_detail = await beacon_service.get_validator(index_or_pubkey=bind_node.pub_key)
-    db_data = BaseNode(**bind_node.dict(), index=node_detail.validator_index)
-    # 限制staking基金才可绑定节点
+    except Exception as e:
+        node_detail = await beacon_service.get_validator(index_or_pubkey=bind_node.pub_key)
+        db_data = BaseNode(**bind_node.dict(), index=node_detail.validator_index)
+        # 限制staking基金才可绑定节点
 
-    query = {'id': bind_node.fund_id, 'user_id': user.id, 'fund_type': FundType.staking,
-             f"nodes.{bind_node.pub_key}": {'$exists': False}}
+        query = {'id': bind_node.fund_id, 'user_id': user.id, 'fund_type': FundType.staking,
+                 f"nodes.{bind_node.pub_key}": {'$exists': False}}
 
-    update = {"$set": {f"nodes.{bind_node.pub_key}": db_data.dict()}}
-    res = await fund_collect.update_one(
-        query,
-        update
-    )
-    if res.raw_result['nModified'] == 0:
-        raise ExistDataError(message='节点已存在')
-    return BaseResponse(data='绑定成功')
+        update = {"$set": {f"nodes.{bind_node.pub_key}": db_data.dict()}}
+        res = await fund_collect.update_one(
+            query,
+            update
+        )
+        if res.raw_result['nModified'] == 0:
+            raise ExistDataError(message='节点已存在')
+        return BaseResponse(data='绑定成功')
 
 
 @router.delete('/', response_model=BaseResponse, summary='解绑节点', description='解绑节点')
@@ -78,14 +78,14 @@ async def get_node_info(
 ):
     try:
         int(pub_key)
-    except Exception as e:
         raise RequestInvalidParamsError()
-    query = {'id': fund_id, 'user_id': user.id, 'fund_type': FundType.staking, f"nodes.{pub_key}": {"$exists": True}}
-    fund = await fund_collect.find_one(query)
-    assert fund, NotFundError('未绑定该节点')
-    validator_detail = await beacon_service.get_validator(pub_key)
-    response = Response[Validator](data=validator_detail)
-    return response
+    except Exception as e:
+        query = {'id': fund_id, 'user_id': user.id, 'fund_type': FundType.staking, f"nodes.{pub_key}": {"$exists": True}}
+        fund = await fund_collect.find_one(query)
+        assert fund, NotFundError('未绑定该节点')
+        validator_detail = await beacon_service.get_validator(pub_key)
+        response = Response[Validator](data=validator_detail)
+        return response
 
 
 @router.get(
@@ -101,14 +101,14 @@ async def get_node_deposit(
 ):
     try:
         int(pub_key)
-    except Exception as e:
         raise RequestInvalidParamsError()
-    query = {'id': fund_id, 'user_id': user.id, 'fund_type': FundType.staking, f"nodes.{pub_key}": {"$exists": True}}
-    fund = await fund_collect.find_one(query)
-    assert fund, NotFundError('未绑定该节点')
-    validator_deposit_list = await beacon_service.get_validator_deposit(pub_key)
-    response = Response[List[ValidatorDeposit]](data=validator_deposit_list)
-    return response
+    except Exception as e:
+        query = {'id': fund_id, 'user_id': user.id, 'fund_type': FundType.staking, f"nodes.{pub_key}": {"$exists": True}}
+        fund = await fund_collect.find_one(query)
+        assert fund, NotFundError('未绑定该节点')
+        validator_deposit_list = await beacon_service.get_validator_deposit(pub_key)
+        response = Response[List[ValidatorDeposit]](data=validator_deposit_list)
+        return response
 
 
 @router.get(
@@ -125,18 +125,18 @@ async def get_node_blocks(
 ):
     try:
         int(pub_key)
-    except Exception as e:
         raise RequestInvalidParamsError()
-    start = (page.page - 1) * page.page_size
-    query = {'id': fund_id, 'user_id': user.id, 'fund_type': FundType.staking, f"nodes.{pub_key}": {"$exists": True}}
-    fund = await fund_collect.find_one(query)
-    assert fund, NotFundError('未绑定该节点')
-    validator_blocks = await beacon_service.get_validator_blocks(
-        index=fund["nodes"][pub_key]["index"],
-        start=start,
-        length=page.page_size
-    )
-    return PageResponse[ValidatorBlock](data=validator_blocks.data, **page.dict(), total=validator_blocks.total)
+    except Exception as e:
+        start = (page.page - 1) * page.page_size
+        query = {'id': fund_id, 'user_id': user.id, 'fund_type': FundType.staking, f"nodes.{pub_key}": {"$exists": True}}
+        fund = await fund_collect.find_one(query)
+        assert fund, NotFundError('未绑定该节点')
+        validator_blocks = await beacon_service.get_validator_blocks(
+            index=fund["nodes"][pub_key]["index"],
+            start=start,
+            length=page.page_size
+        )
+        return PageResponse[ValidatorBlock](data=validator_blocks.data, **page.dict(), total=validator_blocks.total)
 
 
 @router.get(
@@ -152,15 +152,15 @@ async def get_node_income(
 ):
     try:
         int(pub_key)
-    except Exception as e:
         raise RequestInvalidParamsError()
-    query = {'id': fund_id, 'user_id': user.id, 'fund_type': FundType.staking, f"nodes.{pub_key}": {"$exists": True}}
-    fund = await fund_collect.find_one(query)
-    assert fund, NotFundError('未绑定该节点')
-    validator_income_list = await beacon_service.get_validator_income(index_or_pubkey=pub_key)
-    assert validator_income_list, NotFundError()
-    response = Response[ValidatorIncome](data=validator_income_list[0])
-    return response
+    except Exception as e:
+        query = {'id': fund_id, 'user_id': user.id, 'fund_type': FundType.staking, f"nodes.{pub_key}": {"$exists": True}}
+        fund = await fund_collect.find_one(query)
+        assert fund, NotFundError('未绑定该节点')
+        validator_income_list = await beacon_service.get_validator_income(index_or_pubkey=pub_key)
+        assert validator_income_list, NotFundError()
+        response = Response[ValidatorIncome](data=validator_income_list[0])
+        return response
 
 
 @router.get("/epoch/{epoch}/", response_model=Response[Epoch], summary="查询epoch", description="")