forked from dmitrymomot/solana-go-sdk
-
Notifications
You must be signed in to change notification settings - Fork 0
/
rpc_get_account_info.go
110 lines (98 loc) · 3.29 KB
/
rpc_get_account_info.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
package client
import (
"context"
"encoding/base64"
"fmt"
"github.com/EntySquare/solana-go-sdk/common"
"github.com/EntySquare/solana-go-sdk/rpc"
)
type AccountInfo struct {
Lamports uint64
Owner common.PublicKey
Executable bool
RentEpoch uint64
Data []byte
}
func convertAccountInfo(v rpc.AccountInfo) (AccountInfo, error) {
if v == (rpc.AccountInfo{}) {
return AccountInfo{}, nil
}
data, ok := v.Data.([]any)
if !ok {
return AccountInfo{}, fmt.Errorf("failed to cast raw response to []any")
}
if data[1] != string(rpc.AccountEncodingBase64) {
return AccountInfo{}, fmt.Errorf("return value should be base64 encoded")
}
rawData, err := base64.StdEncoding.DecodeString(data[0].(string))
if err != nil {
return AccountInfo{}, fmt.Errorf("failed to base64 decode data")
}
return AccountInfo{
Lamports: v.Lamports,
Owner: common.PublicKeyFromString(v.Owner),
Executable: v.Executable,
RentEpoch: v.RentEpoch,
Data: rawData,
}, nil
}
type GetAccountInfoConfig struct {
Commitment rpc.Commitment
DataSlice *rpc.DataSlice
}
func (c GetAccountInfoConfig) toRpc() rpc.GetAccountInfoConfig {
return rpc.GetAccountInfoConfig{
Encoding: rpc.AccountEncodingBase64,
Commitment: c.Commitment,
DataSlice: c.DataSlice,
}
}
// GetAccountInfo return account's info
func (c *Client) GetAccountInfo(ctx context.Context, base58Addr string) (AccountInfo, error) {
return process(
func() (rpc.JsonRpcResponse[rpc.ValueWithContext[rpc.AccountInfo]], error) {
return c.RpcClient.GetAccountInfoWithConfig(ctx, base58Addr, GetAccountInfoConfig{}.toRpc())
},
convertGetAccountInfo,
)
}
// GetAccountInfoWithConfig return account's info
func (c *Client) GetAccountInfoWithConfig(ctx context.Context, base58Addr string, cfg GetAccountInfoConfig) (AccountInfo, error) {
return process(
func() (rpc.JsonRpcResponse[rpc.ValueWithContext[rpc.AccountInfo]], error) {
return c.RpcClient.GetAccountInfoWithConfig(ctx, base58Addr, cfg.toRpc())
},
convertGetAccountInfo,
)
}
// GetAccountInfoAndContext return account's info
func (c *Client) GetAccountInfoAndContext(ctx context.Context, base58Addr string) (rpc.ValueWithContext[AccountInfo], error) {
return process(
func() (rpc.JsonRpcResponse[rpc.ValueWithContext[rpc.AccountInfo]], error) {
return c.RpcClient.GetAccountInfoWithConfig(ctx, base58Addr, GetAccountInfoConfig{}.toRpc())
},
convertGetAccountInfoAndContext,
)
}
// GetAccountInfoAndContextWithConfig return account's info
func (c *Client) GetAccountInfoAndContextWithConfig(ctx context.Context, base58Addr string, cfg GetAccountInfoConfig) (rpc.ValueWithContext[AccountInfo], error) {
return process(
func() (rpc.JsonRpcResponse[rpc.ValueWithContext[rpc.AccountInfo]], error) {
return c.RpcClient.GetAccountInfoWithConfig(ctx, base58Addr, cfg.toRpc())
},
convertGetAccountInfoAndContext,
)
}
func convertGetAccountInfo(v rpc.ValueWithContext[rpc.AccountInfo]) (AccountInfo, error) {
return convertAccountInfo(v.Value)
}
func convertGetAccountInfoAndContext(v rpc.ValueWithContext[rpc.AccountInfo]) (rpc.ValueWithContext[AccountInfo], error) {
accountInfo, err := convertGetAccountInfo(v)
if err != nil {
return rpc.ValueWithContext[AccountInfo]{}, err
}
return rpc.ValueWithContext[AccountInfo]{
Context: v.Context,
Value: accountInfo,
}, nil
}