add stake_record unstake_record grpc call method

api/l3staking/api_v1.py

@@ -69,3 +69,39 @@ def get_node_detail(request):
     if staking_node is None:
         return error_json("Do not exist node", 4000)
     return ok_json(staking_node.as_dict())
+
+
+# @check_api_token
+def get_l2_stake_record(request):
+    params = json.loads(request.body.decode())
+    staker_address = params.get('staker_address', "0x")
+    strategy = params.get('strategy', "0x")
+    page = params.get('page', 1)
+    page_size = params.get('page_size', 10)
+    appChainClient = AppChainClient()
+    l2_stake_record = appChainClient.l2_stake_record(
+        staker_address=staker_address,
+        strategy=strategy,
+        page=page,
+        page_size=page_size
+    )
+    print(l2_stake_record)
+    return ok_json(l2_stake_record)
+
+
+# @check_api_token
+def get_l2_unstake_record(request):
+    params = json.loads(request.body.decode())
+    staker_address = params.get('staker_address', "0x")
+    strategy = params.get('strategy', "0x")
+    page = params.get('page', 1)
+    page_size = params.get('page_size', 10)
+    appChainClient = AppChainClient()
+    l2_unstake_record = appChainClient.l2_unstake_record(
+        staker_address=staker_address,
+        strategy=strategy,
+        page=page,
+        page_size=page_size
+    )
+    print(l2_unstake_record)
+    return ok_json(l2_unstake_record)

api/urls.py

@@ -71,7 +71,9 @@
 from api.l3staking.api_v1 import (
     get_staking_chains,
     get_staking_node_list,
-    get_node_detail
+    get_node_detail,
+    get_l2_stake_record,
+    get_l2_unstake_record
 )
 
 
@@ -141,4 +143,6 @@
     path(r'get_staking_chains', get_staking_chains, name='get_staking_chains'),
     path(r'get_staking_node_list', get_staking_node_list, name='get_staking_node_list'),
     path(r'get_node_detail', get_node_detail, name='get_node_detail'),
+    path(r'get_l2_stake_record', get_l2_stake_record, name='get_l2_stake_record'),
+    path(r'get_l2_unstake_record', get_l2_unstake_record, name='get_l2_unstake_record'),
 ]

services/appchain_client.py

@@ -30,3 +30,21 @@ def l2_staker_reward_amount(self, chain_id: str, staker_address: str, strategy:
                 strategy=strategy
             )
         )
+    def l2_stake_record(self, staker_address: str, strategy: str,page: int,page_size: int, consumer_token: str = None) -> appchain_pb2.L2StakerRewardsAmountResponse:
+        return self.stub.L2StakeRecord(
+            appchain_pb2.L2StakeRecordRequest(
+                staker_address=staker_address,
+                strategy=strategy,
+                page=page,
+                page_size=page_size
+            )
+        )
+    def l2_unstake_record(self, staker_address: str, strategy: str,page: int,page_size: int, consumer_token: str = None) -> appchain_pb2.L2StakerRewardsAmountResponse:
+        return self.stub.L2UnStakeRecord(
+            appchain_pb2.L2UnStakeRecordRequest(
+                staker_address=staker_address,
+                strategy=strategy,
+                page=page,
+                page_size=page_size
+            )
+        )