gmsol-store 0.5.0

GMX-Solana is an extension of GMX on the Solana blockchain.
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

use anchor_lang::prelude::*;

use gmsol_utils::price::{Decimal, Price};

use crate::{states::TokenConfig, CoreError};

/// The Chainlink Program.
pub struct Chainlink;

impl Id for Chainlink {
    fn id() -> Pubkey {
        chainlink_solana::ID
    }
}

impl Chainlink {
    /// Check and get latest chainlink price from data feed.
    pub(crate) fn check_and_get_chainlink_price<'info>(
        clock: &Clock,
        chainlink_program: &impl ToAccountInfo<'info>,
        token_config: &TokenConfig,
        feed: &AccountInfo<'info>,
    ) -> Result<(u64, i64, Price)> {
        let chainlink_program = chainlink_program.to_account_info();
        let round = chainlink_solana::latest_round_data(chainlink_program.clone(), feed.clone())?;
        let decimals = chainlink_solana::decimals(chainlink_program, feed.clone())?;
        Self::check_and_get_price_from_round(clock, &round, decimals, token_config)
    }

    /// Check and get price from the round data.
    fn check_and_get_price_from_round(
        clock: &Clock,
        round: &chainlink_solana::Round,
        decimals: u8,
        token_config: &TokenConfig,
    ) -> Result<(u64, i64, Price)> {
        let chainlink_solana::Round {
            answer, timestamp, ..
        } = round;
        require_gt!(*answer, 0, CoreError::InvalidPriceFeedPrice);
        let timestamp = *timestamp as i64;
        let current = clock.unix_timestamp;
        if current > timestamp && current - timestamp > token_config.heartbeat_duration().into() {
            return err!(CoreError::PriceFeedNotUpdated);
        }
        let price = Decimal::try_from_price(
            *answer as u128,
            decimals,
            token_config.token_decimals(),
            token_config.precision(),
        )
        .map_err(|_| error!(CoreError::InvalidPriceFeedPrice))?;
        Ok((
            round.slot,
            timestamp,
            Price {
                min: price,
                max: price,
            },
        ))
    }
}