#![allow(
clippy::all,
clippy::pedantic,
clippy::nursery,
clippy::expect_used,
clippy::unwrap_used,
clippy::indexing_slicing,
clippy::allow_attributes,
clippy::allow_attributes_without_reason,
clippy::mem_forget,
unfulfilled_lint_expectations,
unexpected_cfgs,
unused_imports
)]
use borsh::BorshDeserialize;
use borsh::BorshSerialize;
use solana_address::Address;
#[derive(BorshSerialize, BorshDeserialize, Clone, Debug, Eq, PartialEq)]
#[cfg_attr(feature = "serde", derive(serde::Serialize, serde::Deserialize))]
#[cfg_attr(feature = "serde", serde(rename_all = "camelCase"))]
pub struct RewardAccrual {
pub discriminator: [u8; 8],
pub version: u8,
pub bump: u8,
#[cfg_attr(
feature = "serde",
serde(with = "serde_with::As::<serde_with::DisplayFromStr>")
)]
pub quote_mint: Address,
#[cfg_attr(
feature = "serde",
serde(with = "serde_with::As::<serde_with::DisplayFromStr>")
)]
pub acc_per_token: u128,
#[cfg_attr(
feature = "serde",
serde(with = "serde_with::As::<serde_with::DisplayFromStr>")
)]
pub total_deposited: u64,
#[cfg_attr(
feature = "serde",
serde(with = "serde_with::As::<serde_with::Bytes>")
)]
pub reserved: [u8; 64],
}
pub const REWARD_ACCRUAL_DISCRIMINATOR: [u8; 8] =
[158, 244, 116, 30, 227, 132, 105, 182];
impl RewardAccrual {
pub const LEN: usize = 130;
#[inline(always)]
pub fn from_bytes(data: &[u8]) -> Result<Self, std::io::Error> {
if data.get(..REWARD_ACCRUAL_DISCRIMINATOR.len())
!= Some(&REWARD_ACCRUAL_DISCRIMINATOR[..])
{
return Err(std::io::Error::new(
std::io::ErrorKind::InvalidData,
"invalid account discriminator",
));
}
let mut data = data;
Self::deserialize(&mut data)
}
}
impl<'a> TryFrom<&solana_program::account_info::AccountInfo<'a>>
for RewardAccrual
{
type Error = std::io::Error;
fn try_from(
account_info: &solana_program::account_info::AccountInfo<'a>,
) -> Result<Self, Self::Error> {
if account_info.owner != &crate::dex::generated::SEND_DEX_ID {
return Err(std::io::Error::new(
std::io::ErrorKind::InvalidData,
"invalid account owner",
));
}
let data: &[u8] = &(*account_info.data).borrow();
Self::from_bytes(data)
}
}
#[cfg(feature = "fetch")]
pub fn fetch_reward_accrual(
rpc: &solana_rpc_client::rpc_client::RpcClient,
address: &solana_address::Address,
) -> Result<
crate::dex::generated::shared::DecodedAccount<RewardAccrual>,
std::io::Error,
> {
let accounts = fetch_all_reward_accrual(rpc, &[*address])?;
Ok(accounts[0].clone())
}
#[cfg(feature = "fetch")]
pub fn fetch_all_reward_accrual(
rpc: &solana_rpc_client::rpc_client::RpcClient,
addresses: &[solana_address::Address],
) -> Result<
Vec<crate::dex::generated::shared::DecodedAccount<RewardAccrual>>,
std::io::Error,
> {
let accounts = rpc
.get_multiple_accounts(addresses)
.map_err(|e| std::io::Error::other(e.to_string()))?;
let mut decoded_accounts: Vec<
crate::dex::generated::shared::DecodedAccount<RewardAccrual>,
> = Vec::new();
for i in 0..addresses.len() {
let address = addresses[i];
let account = accounts[i].as_ref().ok_or(std::io::Error::other(
format!("Account not found: {address}"),
))?;
if account.owner != crate::dex::generated::SEND_DEX_ID {
return Err(std::io::Error::other(format!(
"Invalid owner for account: {address}"
)));
}
let data = RewardAccrual::from_bytes(&account.data)?;
decoded_accounts.push(crate::dex::generated::shared::DecodedAccount {
address,
account: account.clone(),
data,
});
}
Ok(decoded_accounts)
}
#[cfg(feature = "fetch")]
pub fn fetch_maybe_reward_accrual(
rpc: &solana_rpc_client::rpc_client::RpcClient,
address: &solana_address::Address,
) -> Result<
crate::dex::generated::shared::MaybeAccount<RewardAccrual>,
std::io::Error,
> {
let accounts = fetch_all_maybe_reward_accrual(rpc, &[*address])?;
Ok(accounts[0].clone())
}
#[cfg(feature = "fetch")]
pub fn fetch_all_maybe_reward_accrual(
rpc: &solana_rpc_client::rpc_client::RpcClient,
addresses: &[solana_address::Address],
) -> Result<
Vec<crate::dex::generated::shared::MaybeAccount<RewardAccrual>>,
std::io::Error,
> {
let accounts = rpc
.get_multiple_accounts(addresses)
.map_err(|e| std::io::Error::other(e.to_string()))?;
let mut decoded_accounts: Vec<
crate::dex::generated::shared::MaybeAccount<RewardAccrual>,
> = Vec::new();
for i in 0..addresses.len() {
let address = addresses[i];
if let Some(account) = accounts[i].as_ref() {
if account.owner != crate::dex::generated::SEND_DEX_ID {
return Err(std::io::Error::other(format!(
"Invalid owner for account: {address}"
)));
}
let data = RewardAccrual::from_bytes(&account.data)?;
decoded_accounts.push(
crate::dex::generated::shared::MaybeAccount::Exists(
crate::dex::generated::shared::DecodedAccount {
address,
account: account.clone(),
data,
},
),
);
} else {
decoded_accounts.push(
crate::dex::generated::shared::MaybeAccount::NotFound(address),
);
}
}
Ok(decoded_accounts)
}
#[cfg(feature = "anchor")]
impl anchor_lang::AccountDeserialize for RewardAccrual {
fn try_deserialize(buf: &mut &[u8]) -> anchor_lang::Result<Self> {
if buf.len() < REWARD_ACCRUAL_DISCRIMINATOR.len()
|| buf[..REWARD_ACCRUAL_DISCRIMINATOR.len()]
!= REWARD_ACCRUAL_DISCRIMINATOR[..]
{
return Err(
anchor_lang::error::ErrorCode::AccountDiscriminatorMismatch
.into(),
);
}
Self::try_deserialize_unchecked(buf)
}
fn try_deserialize_unchecked(buf: &mut &[u8]) -> anchor_lang::Result<Self> {
Ok(Self::deserialize(buf)?)
}
}
#[cfg(feature = "anchor")]
impl anchor_lang::AccountSerialize for RewardAccrual {}
#[cfg(feature = "anchor")]
impl anchor_lang::Owner for RewardAccrual {
fn owner() -> anchor_lang::solana_program::pubkey::Pubkey {
anchor_lang::solana_program::pubkey::Pubkey::from(
crate::dex::generated::SEND_DEX_ID.to_bytes(),
)
}
}
#[cfg(feature = "anchor-idl-build")]
impl anchor_lang::IdlBuild for RewardAccrual {}
#[cfg(feature = "anchor-idl-build")]
impl anchor_lang::Discriminator for RewardAccrual {
const DISCRIMINATOR: &[u8] = &REWARD_ACCRUAL_DISCRIMINATOR;
}