How to fetch staking amount and claimable rewards

[minukkk]

Discord user ID

minuk

Describe your question in detail.

I staked Aptos tokens into the figment validator(https://figment.io/insights/aptos-staking/).
How can I fetch staked amount and claimable rewards by API / REST API?

What error, if any, are you getting?

No response

What have you tried or looked at? Or how can we reproduce the error?

No response

Which operating system are you using?

Linux (Ubuntu, Fedora, Windows WSL, etc.)

Which SDK or tool are you using? (if any)

Python SDK

Describe your environment or tooling in detail

No response

[minukkk]

Below way, I could fetch initial deposit and rewards after that.

    def get_active_and_pending_inactive_principals(self):
        activities_query = """
        query getDelegatedStakingActivities($delegatorAddress: String!, $pool_address: String!) {
        delegated_staking_activities(
            where: {
            delegator_address: {_eq: $delegatorAddress}
            pool_address: {_eq: $pool_address}
            }
            order_by: {transaction_version: desc}
        ) {
            amount
            event_type
            transaction_version
        }
        }
        """
        endpoint = "https://api.mainnet.aptoslabs.com/v1/graphql"  # Replace with your actual endpoint

        variables = {
            "delegatorAddress": self.account_address,
            "pool_address": self.validator_address
        }
        response = requests.post(endpoint, json={'query': activities_query, 'variables': variables})
        if response.status_code != 200:
            raise Exception(f"Query failed with status code {response.status_code}: {response.text}")
        activities = response.json().get('data', {}).get('delegated_staking_activities', [])

        active_principals = 0
        pending_inactive_principals = 0

        for activity in activities:
            amount = activity['amount']
            event_type = activity['event_type'].split("::")[-1]

            if event_type == 'AddStakeEvent':
                active_principals += amount
            elif event_type == 'UnlockStakeEvent':
                active_principals -= amount
            elif event_type == 'ReactivateStakeEvent':
                active_principals += amount

            # Ensure no negative values
            active_principals = max(active_principals, 0)
            pending_inactive_principals = max(pending_inactive_principals, 0)
        return active_principals, pending_inactive_principals
    
    def get_staking_deposit_and_rewards(self):
        base_url = "https://fullnode.mainnet.aptoslabs.com/v1"

        url = f"{base_url}/view"
        payload = {
            "function": "0x1::delegation_pool::get_stake",
            "type_arguments": [],
            "arguments": [self.validator_address, self.account_address]
        }
        response = requests.post(url, json=payload)
        if response.status_code != 200:
            raise Exception(f"Query failed with status code {response.status_code}: {response.text}")
        stake_data = response.json()
        aptos_now = int(stake_data[0])
        active_principal, _ = self.get_active_and_pending_inactive_principals()
        return active_principal / 100000000, (aptos_now - active_principal) / 100000000