Skip to content
This repository has been archived by the owner on Jan 22, 2025. It is now read-only.

Commit

Permalink
Respect options.show_rewards in UiTransactionStatusMeta
Browse files Browse the repository at this point in the history
  • Loading branch information
Tyera Eulberg committed Sep 7, 2022
1 parent 4308c30 commit 6fcdff6
Showing 1 changed file with 19 additions and 12 deletions.
31 changes: 19 additions & 12 deletions transaction-status/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -358,7 +358,7 @@ impl From<&LoadedAddresses> for UiLoadedAddresses {
}

impl UiTransactionStatusMeta {
fn parse(meta: TransactionStatusMeta, static_keys: &[Pubkey]) -> Self {
fn parse(meta: TransactionStatusMeta, static_keys: &[Pubkey], show_rewards: bool) -> Self {
let account_keys = AccountKeys::new(static_keys, Some(&meta.loaded_addresses));
Self {
err: meta.status.clone().err(),
Expand All @@ -378,16 +378,14 @@ impl UiTransactionStatusMeta {
post_token_balances: meta
.post_token_balances
.map(|balance| balance.into_iter().map(Into::into).collect()),
rewards: meta.rewards,
rewards: if show_rewards { meta.rewards } else { None },
loaded_addresses: None,
return_data: meta.return_data,
compute_units_consumed: meta.compute_units_consumed,
}
}
}

impl From<TransactionStatusMeta> for UiTransactionStatusMeta {
fn from(meta: TransactionStatusMeta) -> Self {
fn from(meta: TransactionStatusMeta, show_rewards: bool) -> Self {
Self {
err: meta.status.clone().err(),
status: meta.status,
Expand All @@ -404,7 +402,7 @@ impl From<TransactionStatusMeta> for UiTransactionStatusMeta {
post_token_balances: meta
.post_token_balances
.map(|balance| balance.into_iter().map(Into::into).collect()),
rewards: meta.rewards,
rewards: if show_rewards { meta.rewards } else { None },
loaded_addresses: Some(UiLoadedAddresses::from(&meta.loaded_addresses)),
return_data: meta.return_data,
compute_units_consumed: meta.compute_units_consumed,
Expand Down Expand Up @@ -540,7 +538,11 @@ impl ConfirmedBlock {
self.transactions
.into_iter()
.map(|tx_with_meta| {
tx_with_meta.encode(encoding, options.max_supported_transaction_version)
tx_with_meta.encode(
encoding,
options.max_supported_transaction_version,
options.show_rewards,
)
})
.collect::<Result<Vec<_>, _>>()?,
),
Expand Down Expand Up @@ -659,6 +661,7 @@ impl TransactionWithStatusMeta {
self,
encoding: UiTransactionEncoding,
max_supported_transaction_version: Option<u8>,
show_rewards: bool,
) -> Result<EncodedTransactionWithStatusMeta, EncodeError> {
match self {
Self::MissingMetadata(ref transaction) => Ok(EncodedTransactionWithStatusMeta {
Expand All @@ -667,7 +670,7 @@ impl TransactionWithStatusMeta {
meta: None,
}),
Self::Complete(tx_with_meta) => {
tx_with_meta.encode(encoding, max_supported_transaction_version)
tx_with_meta.encode(encoding, max_supported_transaction_version, show_rewards)
}
}
}
Expand All @@ -685,6 +688,7 @@ impl VersionedTransactionWithStatusMeta {
self,
encoding: UiTransactionEncoding,
max_supported_transaction_version: Option<u8>,
show_rewards: bool,
) -> Result<EncodedTransactionWithStatusMeta, EncodeError> {
let version = match (
max_supported_transaction_version,
Expand All @@ -711,8 +715,9 @@ impl VersionedTransactionWithStatusMeta {
UiTransactionEncoding::JsonParsed => UiTransactionStatusMeta::parse(
self.meta,
self.transaction.message.static_account_keys(),
show_rewards,
),
_ => UiTransactionStatusMeta::from(self.meta),
_ => UiTransactionStatusMeta::from(self.meta, show_rewards),
}),
version,
})
Expand Down Expand Up @@ -757,9 +762,11 @@ impl ConfirmedTransactionWithStatusMeta {
) -> Result<EncodedConfirmedTransactionWithStatusMeta, EncodeError> {
Ok(EncodedConfirmedTransactionWithStatusMeta {
slot: self.slot,
transaction: self
.tx_with_meta
.encode(encoding, max_supported_transaction_version)?,
transaction: self.tx_with_meta.encode(
encoding,
max_supported_transaction_version,
true,
)?,
block_time: self.block_time,
})
}
Expand Down

0 comments on commit 6fcdff6

Please sign in to comment.