certusone
/
solana_exporter
mirror of https://github.com/certusone/solana_exporter.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

working on inflation rewards

This commit is contained in:
Matt Johnstone 2024-10-06 16:52:18 +02:00
parent 789f8ac792
commit 68a3a29280
No known key found for this signature in database
GPG Key ID: BE985FBB9BE7D3BB
3 changed files with 36 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
cmd/solana_exporter/exporter_test.go
View File

@ -61,6 +61,11 @@ var (
},
Range: rpc.BlockProductionRange{FirstSlot: 1000, LastSlot: 2000},
}
staticInflationRewards = []rpc.InflationReward{
{Amount: 1000, EffectiveSlot: 166598, Epoch: 27, PostBalance: 2000},
{Amount: 2000, EffectiveSlot: 166598, Epoch: 27, PostBalance: 4000},
{Amount: 3000, EffectiveSlot: 166598, Epoch: 27, PostBalance: 6000},
}
staticVoteAccounts = rpc.VoteAccounts{
Current: []rpc.VoteAccount{
{
@ -147,6 +152,13 @@ func (c *staticRPCClient) GetBalance(ctx context.Context, address string) (float
return balances[address], nil
}
//goland:noinspection GoUnusedParameter
func (c *staticRPCClient) GetInflationReward(
ctx context.Context, addresses []string, commitment rpc.Commitment, epoch *int64, minContextSlot *int64,
) ([]rpc.InflationReward, error) {
return staticInflationRewards, nil
}
/*
===== DYNAMIC CLIENT =====:
*/
@ -321,6 +333,13 @@ func (c *dynamicRPCClient) GetBalance(ctx context.Context, address string) (floa
return balances[address], nil
}
//goland:noinspection GoUnusedParameter
func (c *dynamicRPCClient) GetInflationReward(
ctx context.Context, addresses []string, commitment rpc.Commitment, epoch *int64, minContextSlot *int64,
) ([]rpc.InflationReward, error) {
return staticInflationRewards, nil
}
/*
===== OTHER TEST UTILITIES =====:
*/

23
pkg/rpc/client.go
View File

@ -10,8 +10,6 @@ import (
"net/http"
)
const LamportsInSol = 1_000_000_000
type (
Client struct {
httpClient http.Client
@ -67,6 +65,12 @@ type Provider interface {
// GetBalance returns the SOL balance of the account at the provided address
GetBalance(ctx context.Context, address string) (float64, error)
// GetInflationReward returns the inflation rewards (in lamports) awarded to the given addresses (vote accounts)
// during the given epoch.
GetInflationReward(
ctx context.Context, addresses []string, commitment Commitment, epoch *int64, minContextSlot *int64,
) ([]InflationReward, error)
}
func (c Commitment) MarshalJSON() ([]byte, error) {
@ -74,6 +78,8 @@ func (c Commitment) MarshalJSON() ([]byte, error) {
}
const (
// LamportsInSol is the number of lamports in 1 SOL (a billion)
LamportsInSol = 1_000_000_000
// CommitmentFinalized level offers the highest level of certainty for a transaction on the Solana blockchain.
// A transaction is considered “Finalized” when it is included in a block that has been confirmed by a
// supermajority of the stake, and at least 31 additional confirmed blocks have been built on top of it.
@ -222,13 +228,10 @@ func (c *Client) GetBalance(ctx context.Context, address string) (float64, error
}
func (c *Client) GetInflationReward(
ctx context.Context, addresses []string, commitment *Commitment, epoch *int64, minContextSlot *int64,
) (*InflationReward, error) {
ctx context.Context, addresses []string, commitment Commitment, epoch *int64, minContextSlot *int64,
) ([]InflationReward, error) {
// format params:
config := make(map[string]any)
if commitment != nil {
config["commitment"] = *commitment
}
config := map[string]any{"commitment": string(commitment)}
if epoch != nil {
config["epoch"] = *epoch
}
@ -236,9 +239,9 @@ func (c *Client) GetInflationReward(
config["minContextSlot"] = *minContextSlot
}
var resp response[InflationReward]
var resp response[[]InflationReward]
if err := c.getResponse(ctx, "getInflationReward", []any{addresses, config}, &resp); err != nil {
return nil, err
}
return &resp.Result, nil
return resp.Result, nil
}

3
pkg/rpc/responses.go
View File

@ -7,8 +7,10 @@ import (
type (
response[T any] struct {
jsonrpc string
Result T `json:"result"`
Error rpcError `json:"error"`
Id int `json:"id"`
}
contextualResult[T any] struct {
@ -69,7 +71,6 @@ type (
EffectiveSlot int64 `json:"effectiveSlot"`
Epoch int64 `json:"epoch"`
PostBalance int64 `json:"postBalance"`
Commission uint8 `json:"commission"`
}
)