Getting Invalid Account Size for pyth_sdk_solana::state::SolanaPriceAccount, which differs from pyth_solana_receiver_sdk::price_update::PriceUpdateV2

[DJPoland]

I have the following Rust code:

let sol_usd_price_feed = Pubkey::from_str("H6ARHf6YXhGYeQfUzQNGk6rDNnLBQKrenN712K4AQJEG")?;
let account = rpc_client.get_account(&sol_usd_price_feed)?;
let price_account: &pyth_sdk_solana::state::SolanaPriceAccount = load_price_account(&account.data)?;

println!("{:?}", price_account);

Yet the data I am getting is possibly stale? Payload is the following:

GenericPriceAccount { magic: 2712847316, ver: 2, atype: 3, size: 3312, ptype: Price, expo: -8, num: 0, num_qt: 1, last_slot: 281687928, valid_slot: 299058481, ema_price: Rational { val: 12068220500, numer: 888720031, denom: 7364134588 }, ema_conf: Rational { val: 13079402, numer: 963184796, denom: 7364134588 }, timestamp: 1730534
860, min_pub: 255, drv2: 0, drv3: 50, drv4: 0, prod: ALP8SdU9oARYVLgLR7LrqMNCYBnhtnQz1cj6bwgwQmgj, next: 11111111111111111111111111111111, prev_slot: 281687928, prev_price: 11923378000, prev_conf: 16676631, prev_timestamp: 1722852532, agg: PriceInfo { price: 11923378000, conf: 16676631, status: Unknown, corp_act: NoCorpAct, pub_s
lot: 299058484 }, comp: [PriceComp { publisher: 11111111111111111111111111111111, agg: PriceInfo { price: 0, conf: 0, status: Unknown, corp_act: NoCorpAct, pub_slot: 0 }, latest: PriceInfo { price: 0, conf: 0, status: Unknown, corp_act: NoCorpAct, pub_slot: 0 } }, PriceComp { publisher: 11111111111111111111111111111111, agg: Pric
eInfo { price: 0, conf: 0, status: Unknown, corp_act: NoCorpAct, pub_slot: 0 }, latest: PriceInfo { price: 0, conf: 0, status: Unknown, corp_act: NoCorpAct, pub_slot: 0 } }, PriceComp { publisher: 11111111111111111111111111111111, agg: PriceInfo { price: 0, conf: 0, status: Unknown, corp_act: NoCorpAct, pub_slot: 0 }, latest: Pri
ceInfo { price: 0, conf: 0, status: Unknown, corp_act: NoCorpAct, pub_slot: 0 } }, PriceComp { publisher: 11111111111111111111111111111111, agg: PriceInfo { price: 0, conf: 0, status: Unknown, corp_act: NoCorpAct, pub_slot: 0 }, latest: PriceInfo { price: 0, conf: 0, status: Unknown, corp_act: NoCorpAct, pub_slot: 0 } }, PriceCom
p { publisher: 11111111111111111111111111111111, agg: PriceInfo { price: 0, conf: 0, status: Unknown, corp_act: NoCorpAct, pub_slot: 0 }, latest: PriceInfo { price: 0, conf: 0, status: Unknown, corp_act: NoCorpAct, pub_slot: 0 } }, PriceComp { publisher: 11111111111111111111111111111111, agg: PriceInfo { price: 0, conf: 0, status

I am referencing the sol/usd price feed from https://www.pyth.network/price-feeds/crypto-sol-usd, yet for some reason the data that is being fetched from H6ARHf6YXhGYeQfUzQNGk6rDNnLBQKrenN712K4AQJEG pubkey has a price of 12068220500 which I would assume would be something like 15910708767 as price today is ~$159. My guess is that pubkey is incorrect, or load_price_account is doing something wrong with solana accounts of that sort.

[kanekoshoyu]

I'm also having the same problem, I am using 7UVimffxr9ow1uXYxsr4LHAcV58mLzhmwaeKvJ1pjLiE as from https://docs.pyth.network/price-feeds/sponsored-feeds/solana

the size of data doesn't match the structure, the slice looks like below and it does hint a bit like 248, 255, 255, 255 being -8 for exponents

[34, 241, 35, 99, 157, 126, 244, 205, 96, 49, 71, 4, 52, 13, 237, 223, 55, 31, 212, 36, 114, 20, 143, 36, 142, 157, 26, 109, 26, 94, 178, 172, 58, 205, 139, 127, 213, 214, 178, 67, 1, 239, 13, 139, 111, 218, 44, 235, 164, 29, 161, 93, 64, 149, 209, 218, 57, 42, 13, 47, 142, 208, 198, 199, 188, 15, 76, 250, 200, 194, 128, 181, 109, 73, 22, 210, 129, 3, 0, 0, 0, 5, 33, 129, 0, 0, 0, 0, 0, 248, 255, 255, 255, 94, 83, 81, 104, 0, 0, 0, 0, 94, 83, 81, 104, 0, 0, 0, 0, 220, 198, 47, 132, 3, 0, 0, 0, 235, 233, 124, 0, 0, 0, 0, 0, 135, 146, 180, 20, 0, 0, 0, 0, 0]

[kanekoshoyu]

I found a fix, posted as below. the messages (account info) that we are getting is PriceUpdateV2, which has a size of 134 including the anchor message discriminator. the nicest way to deserialize is to use AccountDeserialize trait.

use crate::adapter::geyser_client::{self, GeyserSimpleClient, request_by_account};
use crate::port::solana_price_stream::SolUsdPriceStreamPort;
use anchor_lang::AccountDeserialize;
use pyth_solana_receiver_sdk::price_update::PriceUpdateV2;
use std::pin::Pin;
use tokio_stream::Stream;
use tokio_stream::StreamExt;
use yellowstone_grpc_proto::geyser::subscribe_update::UpdateOneof;
pub struct PythSolUsdPriceStream {
    client: GeyserSimpleClient,
}

impl PythSolUsdPriceStream {
    pub async fn new(url: &str, key: &str) -> anyhow::Result<Self> {
        let client = geyser_client::geyser_client(url, key).await?;
        Ok(Self { client })
    }
}

pub fn price_to_f64(price: i64, expo: i32) -> f64 {
    price as f64 * 10f64.powi(expo)
}

/// sponsored SOL-USD price feed
const PYTH_ACCOUNT_ID: &str = "7UVimffxr9ow1uXYxsr4LHAcV58mLzhmwaeKvJ1pjLiE";

impl SolUsdPriceStreamPort for PythSolUsdPriceStream {
    fn stream(mut self) -> Pin<Box<dyn Stream<Item = f64> + Send>> {
        // sponsored SOL-USD price feed
        let request = request_by_account("pyth_sol_usd", PYTH_ACCOUNT_ID);
        let stream = async_stream::stream! {
            let (_, mut updates) = self.client.subscribe_with_request(Some(request)).await.unwrap();
            while let Some(Ok(update)) = updates.next().await {
                if let Some(UpdateOneof::Account(account)) = update.update_oneof {
                    if let Some(account_info) = account.account {
                        let price = PriceUpdateV2::try_deserialize(&mut account_info.data.as_slice()).expect("failed parsing price feed");
                        let price = price_to_f64(price.price_message.price, price.price_message.exponent);
                        yield price;
                    }
                }
            }
        };

        Box::pin(stream)
    }
}

#[cfg(test)]
mod tests {
    use dotenvy::dotenv;

    #[tokio::test]
    async fn test_pyth_price_stream() {
        use super::*;
        dotenv().expect("failed loading env");

        let url = std::env::var("GEYSER_API_URL").expect("API_URL not found in .env");
        let key = std::env::var("GEYSER_API_KEY").expect("API_KEY not found in .env");

        let stream = PythSolUsdPriceStream::new(&url, &key)
            .await
            .expect("failed to initialize");

        let mut stream = stream.stream();
        if let Some(i) = stream.next().await {
            print!("{i}");
        } else {
            panic!("failed to obtain stream");
        }
    }
}

[DJPoland]

Ah, that makes sense! The size of the structure did seem off. I wonder why "pyth_sdk_solana::state::SolanaPriceAccount" differs from "pyth_solana_receiver_sdk::price_update::PriceUpdateV2". I also couldn't find a struct in the whole pyth_sdk_solana crate that aligns with PriceUpdateV2's size. Somewhat annoying to use the "pyth_solana_receiver_sdk" crate for this as its primary use case is for on-chain programs.

[kanekoshoyu]

yeah I was using chatgpt to get things started and I fell into the exact same error. I agree that the differences in the use of pyth_sdk_rs pyth-sdk-solana pyth_solana_receiver_sdk is quite unclear.