golang怎么解析solana的pool信息 | 登链社区

5 golang怎么解析solana的pool信息

回答问题即可获得 5 贡献值，回答被采纳后即可获得 9 学分。

使用golang解析pool信息，但是获取的信息为空，有没有好心人解答下
```golang
type PoolState struct {
	// Bump to identify PDA
	Bump      [1]uint8
	AmmConfig ag_solanago.PublicKey
	Owner     ag_solanago.PublicKey

// Token pair of the pool, where token_mint_0 address < token_mint_1 address
	TokenMint0 ag_solanago.PublicKey
	TokenMint1 ag_solanago.PublicKey

// Token pair vault
	TokenVault0 ag_solanago.PublicKey
	TokenVault1 ag_solanago.PublicKey

// observation account key
	ObservationKey ag_solanago.PublicKey

// mint0 and mint1 decimals
	MintDecimals0 uint8
	MintDecimals1 uint8

// The minimum number of ticks between initialized ticks
	TickSpacing uint16

// The currently in range liquidity available to the pool.
	Liquidity ag_binary.Uint128

// The current price of the pool as a sqrt(token_1/token_0) Q64.64 value
	SqrtPriceX64 ag_binary.Uint128

// The current tick of the pool, i.e. according to the last tick transition that was run.
	TickCurrent int32

// the most-recently updated index of the observations array
	ObservationIndex          uint16
	ObservationUpdateDuration uint16

// The fee growth as a Q64.64 number, i.e. fees of token_0 and token_1 collected per
	// unit of liquidity for the entire life of the pool.
	FeeGrowthGlobal0X64 ag_binary.Uint128
	FeeGrowthGlobal1X64 ag_binary.Uint128

// The amounts of token_0 and token_1 that are owed to the protocol.
	ProtocolFeesToken0 uint64
	ProtocolFeesToken1 uint64

// The amounts in and out of swap token_0 and token_1
	SwapInAmountToken0  ag_binary.Uint128
	SwapOutAmountToken1 ag_binary.Uint128
	SwapInAmountToken1  ag_binary.Uint128
	SwapOutAmountToken0 ag_binary.Uint128

// Bitwise representation of the state of the pool
	// bit0, 1: disable open position and increase liquidity, 0: normal
	// bit1, 1: disable decrease liquidity, 0: normal
	// bit2, 1: disable collect fee, 0: normal
	// bit3, 1: disable collect reward, 0: normal
	// bit4, 1: disable swap, 0: normal
	Status uint8

// Leave blank for future use
	Padding     [7]uint8
	RewardInfos [3]RewardInfo

// Packed initialized tick array state
	TickArrayBitmap [16]uint64

// except protocol_fee and fund_fee
	TotalFeesToken0 uint64

// except protocol_fee and fund_fee
	TotalFeesClaimedToken0 uint64
	TotalFeesToken1        uint64
	TotalFeesClaimedToken1 uint64
	FundFeesToken0         uint64
	FundFeesToken1         uint64
	OpenTime               uint64
	Padding1               [25]uint64
	Padding2               [32]uint64
}

func (this *PairInfo) GetPoolState(ctx context.Context, poolAddress solana.PublicKey) {
	var pool amm_v3.PoolState
	//var polls interface{}
	account, err := SolanaRpcClient.GetAccountInfoWithOpts(context.TODO(),
		poolAddress,
		&rpc.GetAccountInfoOpts{
			Encoding:   solana.EncodingJSONParsed,
			Commitment: rpc.CommitmentFinalized,
		},
	)
	fmt.Println(err)
	dataPos := account.GetBinary()

json.Unmarshal(dataPos, &pool)
	borshDec := bin.NewBorshDecoder(dataPos)
	borshDec.Decode(&pool)
	//log.Println(wpData)
	util.JsonLogInfo(pool)
}

```

使用golang解析pool信息，但是获取的信息为空，有没有好心人解答下

type PoolState struct {
    // Bump to identify PDA
    Bump      [1]uint8
    AmmConfig ag_solanago.PublicKey
    Owner     ag_solanago.PublicKey

    // Token pair of the pool, where token_mint_0 address &lt; token_mint_1 address
    TokenMint0 ag_solanago.PublicKey
    TokenMint1 ag_solanago.PublicKey

    // Token pair vault
    TokenVault0 ag_solanago.PublicKey
    TokenVault1 ag_solanago.PublicKey

    // observation account key
    ObservationKey ag_solanago.PublicKey

    // mint0 and mint1 decimals
    MintDecimals0 uint8
    MintDecimals1 uint8

    // The minimum number of ticks between initialized ticks
    TickSpacing uint16

    // The currently in range liquidity available to the pool.
    Liquidity ag_binary.Uint128

    // The current price of the pool as a sqrt(token_1/token_0) Q64.64 value
    SqrtPriceX64 ag_binary.Uint128

    // The current tick of the pool, i.e. according to the last tick transition that was run.
    TickCurrent int32

    // the most-recently updated index of the observations array
    ObservationIndex          uint16
    ObservationUpdateDuration uint16

    // The fee growth as a Q64.64 number, i.e. fees of token_0 and token_1 collected per
    // unit of liquidity for the entire life of the pool.
    FeeGrowthGlobal0X64 ag_binary.Uint128
    FeeGrowthGlobal1X64 ag_binary.Uint128

    // The amounts of token_0 and token_1 that are owed to the protocol.
    ProtocolFeesToken0 uint64
    ProtocolFeesToken1 uint64

    // The amounts in and out of swap token_0 and token_1
    SwapInAmountToken0  ag_binary.Uint128
    SwapOutAmountToken1 ag_binary.Uint128
    SwapInAmountToken1  ag_binary.Uint128
    SwapOutAmountToken0 ag_binary.Uint128

    // Bitwise representation of the state of the pool
    // bit0, 1: disable open position and increase liquidity, 0: normal
    // bit1, 1: disable decrease liquidity, 0: normal
    // bit2, 1: disable collect fee, 0: normal
    // bit3, 1: disable collect reward, 0: normal
    // bit4, 1: disable swap, 0: normal
    Status uint8

    // Leave blank for future use
    Padding     [7]uint8
    RewardInfos [3]RewardInfo

    // Packed initialized tick array state
    TickArrayBitmap [16]uint64

    // except protocol_fee and fund_fee
    TotalFeesToken0 uint64

    // except protocol_fee and fund_fee
    TotalFeesClaimedToken0 uint64
    TotalFeesToken1        uint64
    TotalFeesClaimedToken1 uint64
    FundFeesToken0         uint64
    FundFeesToken1         uint64
    OpenTime               uint64
    Padding1               [25]uint64
    Padding2               [32]uint64
}

func (this *PairInfo) GetPoolState(ctx context.Context, poolAddress solana.PublicKey) {
    var pool amm_v3.PoolState
    //var polls interface{}
    account, err := SolanaRpcClient.GetAccountInfoWithOpts(context.TODO(),
        poolAddress,
        &rpc.GetAccountInfoOpts{
            Encoding:   solana.EncodingJSONParsed,
            Commitment: rpc.CommitmentFinalized,
        },
    )
    fmt.Println(err)
    dataPos := account.GetBinary()

    json.Unmarshal(dataPos, &pool)
    borshDec := bin.NewBorshDecoder(dataPos)
    borshDec.Decode(&pool)
    //log.Println(wpData)
    util.JsonLogInfo(pool)
}

0 条评论

默认排序时间排序

2 个回答

Wade - Footprint Analytics CTO 2024-05-22 18:40

　擅长：数据分析,GameFi,NFT

NPC.李括 2天前

在使用 Go 语言解析 Solana 上的池信息时，如果获取的信息为空，可能是由于几个常见问题导致的。以下是一些排查步骤和解决方案，帮助你找到问题所在。

1. 检查账户信息
首先，确保你能够成功获取到账户信息。你可以在 GetAccountInfoWithOpts 方法中添加错误处理，确保 account 不为 nil：

`go`

```
if err != nil {
    log.Fatalf("Failed to get account info: %v", err)
}
if account == nil {
    log.Fatalf("Account is nil for pool address: %s", poolAddress.String())
}

```
2. 检查账户数据
确保从账户获取的数据不是空的。你可以在调用 GetBinary() 之后，检查 dataPos 的长度：

`go`

```
dataPos := account.GetBinary()
if len(dataPos) == 0 {
    log.Fatalf("Account data is empty for pool address: %s", poolAddress.String())
}

```
3. 解析数据
你在代码中同时使用了 json.Unmarshal 和 Borsh 解码。这可能导致混淆，因为根据 Solana 的协议，池的状态通常是以 Borsh 序列化格式存储的。如果使用 Borsh 解码，你不需要 JSON 解码。

确保你只使用 Borsh 解码：

`go`

```
borshDec := bin.NewBorshDecoder(dataPos)
err = borshDec.Decode(&pool)
if err != nil {
    log.Fatalf("Failed to decode pool data: %v", err)
}

```
4. 结构体定义
确保 PoolState 的结构体定义与 Solana 上存储的数据结构完全一致。检查以下几点：

字段的顺序是否正确。
字段的类型是否与原始数据匹配。
是否有任何遗漏的字段。

5. 调试输出
在解码之前和之后，添加一些调试输出，查看数据的内容：

`go`

```
fmt.Printf("Raw data: %x\n", dataPos) // 打印原始数据

```

6. 使用正确的库和版本
确保你使用的 Borsh 库和 Solana SDK 版本与链上数据的格式兼容。库的更新可能会引入不兼容的更改。

7. 确认池地址的有效性
检查提供的 poolAddress 是否是一个有效的池地址，并且该地址确实存在于链上。你可以使用 Solana Explorer 来验证。

8. 完整代码示例
以下是一个整合上述建议的代码示例：

`go`

```
func (this *PairInfo) GetPoolState(ctx context.Context, poolAddress solana.PublicKey) {
    var pool amm_v3.PoolState
    
    account, err := SolanaRpcClient.GetAccountInfoWithOpts(ctx, poolAddress, &rpc.GetAccountInfoOpts{
        Encoding:   solana.EncodingBinary, // 确保使用二进制编码
        Commitment: rpc.CommitmentFinalized,
    })
    if err != nil {
        log.Fatalf("Failed to get account info: %v", err)
    }
    if account == nil {
        log.Fatalf("Account is nil for pool address: %s", poolAddress.String())
    }

dataPos := account.GetBinary()
    if len(dataPos) == 0 {
        log.Fatalf("Account data is empty for pool address: %s", poolAddress.String())
    }

// 只有 Borsh 解码
    borshDec := bin.NewBorshDecoder(dataPos)
    err = borshDec.Decode(&pool)
    if err != nil {
        log.Fatalf("Failed to decode pool data: %v", err)
    }

// 输出池状态以供调试
    util.JsonLogInfo(pool)
}

```