feat(interop): add ledger context for utxorpc mapping logic (#450)
Co-authored-by: Aleksandar Djuric <aleksandardjuric@alethea.io>
This commit is contained in:
aleksandar
GitHub
parent
525417d660
commit
810088a378
2 changed files with 486 additions and 435 deletions
|
|
@ -14,6 +14,7 @@ authors = ["Santiago Carmuega <santiago@carmuega.me>"]
|
||||||
pallas-traverse = { version = "=0.25.0", path = "../pallas-traverse" }
|
pallas-traverse = { version = "=0.25.0", path = "../pallas-traverse" }
|
||||||
pallas-primitives = { version = "=0.25.0", path = "../pallas-primitives" }
|
pallas-primitives = { version = "=0.25.0", path = "../pallas-primitives" }
|
||||||
pallas-codec = { version = "=0.25.0", path = "../pallas-codec" }
|
pallas-codec = { version = "=0.25.0", path = "../pallas-codec" }
|
||||||
|
pallas-crypto = { version = "=0.25.0", path = "../pallas-crypto" }
|
||||||
|
|
||||||
utxorpc-spec = { version = "0.5.0" }
|
utxorpc-spec = { version = "0.5.0" }
|
||||||
# utxorpc-spec = { path = "../../../utxorpc/spec/gen/rust" }
|
# utxorpc-spec = { path = "../../../utxorpc/spec/gen/rust" }
|
||||||
|
|
|
||||||
|
|
@ -1,6 +1,7 @@
|
||||||
use std::ops::Deref;
|
use std::ops::Deref;
|
||||||
|
|
||||||
use pallas_codec::utils::KeyValuePairs;
|
use pallas_codec::utils::KeyValuePairs;
|
||||||
|
use pallas_crypto::hash::Hash;
|
||||||
use pallas_primitives::{alonzo, babbage, conway};
|
use pallas_primitives::{alonzo, babbage, conway};
|
||||||
use pallas_traverse as trv;
|
use pallas_traverse as trv;
|
||||||
|
|
||||||
|
|
@ -10,484 +11,533 @@ pub use utxorpc_spec::utxorpc::v1alpha as spec;
|
||||||
|
|
||||||
use utxorpc_spec::utxorpc::v1alpha::cardano as u5c;
|
use utxorpc_spec::utxorpc::v1alpha::cardano as u5c;
|
||||||
|
|
||||||
pub fn map_purpose(x: &conway::RedeemerTag) -> u5c::RedeemerPurpose {
|
pub trait Context {
|
||||||
match x {
|
fn get_spent_tx_output<'a>(tx_hash: Hash<32>, index: u32) -> Option<trv::MultiEraOutput<'a>>;
|
||||||
conway::RedeemerTag::Spend => u5c::RedeemerPurpose::Spend,
|
|
||||||
conway::RedeemerTag::Mint => u5c::RedeemerPurpose::Mint,
|
|
||||||
conway::RedeemerTag::Cert => u5c::RedeemerPurpose::Cert,
|
|
||||||
conway::RedeemerTag::Reward => u5c::RedeemerPurpose::Reward,
|
|
||||||
conway::RedeemerTag::Vote => todo!(),
|
|
||||||
conway::RedeemerTag::Propose => todo!(),
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
pub fn map_redeemer(x: &trv::MultiEraRedeemer) -> u5c::Redeemer {
|
pub struct Mapper<C: Context> {
|
||||||
u5c::Redeemer {
|
context: Option<C>,
|
||||||
purpose: map_purpose(&x.tag()).into(),
|
|
||||||
datum: map_plutus_datum(x.data()).into(),
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
pub fn map_tx_input(i: &trv::MultiEraInput, tx: &trv::MultiEraTx) -> u5c::TxInput {
|
impl<C: Context> Mapper<C> {
|
||||||
let redeemers = tx.redeemers();
|
pub fn map_purpose(&self, x: &conway::RedeemerTag) -> u5c::RedeemerPurpose {
|
||||||
|
match x {
|
||||||
let redeemer = redeemers.iter().find(|r| (r.index() as u64) == i.index());
|
conway::RedeemerTag::Spend => u5c::RedeemerPurpose::Spend,
|
||||||
|
conway::RedeemerTag::Mint => u5c::RedeemerPurpose::Mint,
|
||||||
u5c::TxInput {
|
conway::RedeemerTag::Cert => u5c::RedeemerPurpose::Cert,
|
||||||
tx_hash: i.hash().to_vec().into(),
|
conway::RedeemerTag::Reward => u5c::RedeemerPurpose::Reward,
|
||||||
output_index: i.index() as u32,
|
conway::RedeemerTag::Vote => todo!(),
|
||||||
redeemer: redeemer.map(map_redeemer),
|
conway::RedeemerTag::Propose => todo!(),
|
||||||
// TODO: map output data from some context
|
}
|
||||||
as_output: None,
|
|
||||||
}
|
}
|
||||||
}
|
|
||||||
|
|
||||||
pub fn map_tx_output(x: &trv::MultiEraOutput) -> u5c::TxOutput {
|
pub fn map_redeemer(&self, x: &trv::MultiEraRedeemer) -> u5c::Redeemer {
|
||||||
u5c::TxOutput {
|
u5c::Redeemer {
|
||||||
address: x.address().map(|a| a.to_vec()).unwrap_or_default().into(),
|
purpose: self.map_purpose(&x.tag()).into(),
|
||||||
coin: x.lovelace_amount(),
|
datum: self.map_plutus_datum(x.data()).into(),
|
||||||
// TODO: this is wrong, we're crating a new item for each asset even if they share
|
}
|
||||||
// the same policy id. We need to adjust Pallas' interface to make this mapping more
|
}
|
||||||
// ergonomic.
|
|
||||||
assets: x.non_ada_assets().iter().map(map_policy_assets).collect(),
|
pub fn map_tx_input(&self, i: &trv::MultiEraInput, tx: &trv::MultiEraTx) -> u5c::TxInput {
|
||||||
datum: match x.datum() {
|
let redeemers = tx.redeemers();
|
||||||
Some(babbage::PseudoDatumOption::Data(x)) => map_plutus_datum(&x.0).into(),
|
|
||||||
_ => None,
|
let redeemer = redeemers.iter().find(|r| (r.index() as u64) == i.index());
|
||||||
},
|
|
||||||
datum_hash: match x.datum() {
|
let as_output = match &self.context {
|
||||||
Some(babbage::PseudoDatumOption::Data(x)) => x.original_hash().to_vec().into(),
|
Some(_) => {
|
||||||
Some(babbage::PseudoDatumOption::Hash(x)) => x.to_vec().into(),
|
let tx_output = C::get_spent_tx_output(i.hash().clone(), i.index() as u32);
|
||||||
_ => vec![].into(),
|
match tx_output {
|
||||||
},
|
Some(output) => Some(self.map_tx_output(&output)),
|
||||||
script: match x.script_ref() {
|
None => panic!(
|
||||||
Some(conway::PseudoScript::NativeScript(x)) => u5c::Script {
|
"Failed to fetch transaction output for hash: {:?}, index: {}",
|
||||||
script: u5c::script::Script::Native(map_native_script(&x)).into(),
|
i.hash(),
|
||||||
|
i.index()
|
||||||
|
),
|
||||||
|
}
|
||||||
}
|
}
|
||||||
.into(),
|
|
||||||
Some(conway::PseudoScript::PlutusV1Script(x)) => u5c::Script {
|
|
||||||
script: u5c::script::Script::PlutusV1(x.0.to_vec().into()).into(),
|
|
||||||
}
|
|
||||||
.into(),
|
|
||||||
Some(conway::PseudoScript::PlutusV2Script(x)) => u5c::Script {
|
|
||||||
script: u5c::script::Script::PlutusV2(x.0.to_vec().into()).into(),
|
|
||||||
}
|
|
||||||
.into(),
|
|
||||||
Some(conway::PseudoScript::PlutusV3Script(_)) => todo!(),
|
|
||||||
None => None,
|
None => None,
|
||||||
},
|
};
|
||||||
|
|
||||||
|
u5c::TxInput {
|
||||||
|
tx_hash: i.hash().to_vec().into(),
|
||||||
|
output_index: i.index() as u32,
|
||||||
|
redeemer: redeemer.map(|x| self.map_redeemer(x)),
|
||||||
|
as_output,
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
|
||||||
|
|
||||||
pub fn map_stake_credential(x: &babbage::StakeCredential) -> u5c::StakeCredential {
|
pub fn map_tx_output(&self, x: &trv::MultiEraOutput) -> u5c::TxOutput {
|
||||||
let inner = match x {
|
u5c::TxOutput {
|
||||||
babbage::StakeCredential::AddrKeyhash(x) => {
|
address: x.address().map(|a| a.to_vec()).unwrap_or_default().into(),
|
||||||
u5c::stake_credential::StakeCredential::AddrKeyHash(x.to_vec().into())
|
coin: x.lovelace_amount(),
|
||||||
}
|
// TODO: this is wrong, we're crating a new item for each asset even if they share
|
||||||
babbage::StakeCredential::Scripthash(x) => {
|
// the same policy id. We need to adjust Pallas' interface to make this mapping more
|
||||||
u5c::stake_credential::StakeCredential::ScriptHash(x.to_vec().into())
|
// ergonomic.
|
||||||
}
|
assets: x
|
||||||
};
|
.non_ada_assets()
|
||||||
|
.iter()
|
||||||
u5c::StakeCredential {
|
.map(|x| self.map_policy_assets(x))
|
||||||
stake_credential: inner.into(),
|
.collect(),
|
||||||
}
|
datum: match x.datum() {
|
||||||
}
|
Some(babbage::PseudoDatumOption::Data(x)) => self.map_plutus_datum(&x.0).into(),
|
||||||
|
_ => None,
|
||||||
pub fn map_relay(x: &alonzo::Relay) -> u5c::Relay {
|
},
|
||||||
match x {
|
datum_hash: match x.datum() {
|
||||||
babbage::Relay::SingleHostAddr(port, v4, v6) => u5c::Relay {
|
Some(babbage::PseudoDatumOption::Data(x)) => x.original_hash().to_vec().into(),
|
||||||
// ip_v4: v4.map(|x| x.to_vec().into()).into().unwrap_or_default(),
|
Some(babbage::PseudoDatumOption::Hash(x)) => x.to_vec().into(),
|
||||||
ip_v4: Option::from(v4.clone().map(|x| x.to_vec().into())).unwrap_or_default(),
|
_ => vec![].into(),
|
||||||
ip_v6: Option::from(v6.clone().map(|x| x.to_vec().into())).unwrap_or_default(),
|
},
|
||||||
dns_name: String::default(),
|
script: match x.script_ref() {
|
||||||
port: Option::from(port.clone()).unwrap_or_default(),
|
Some(conway::PseudoScript::NativeScript(x)) => u5c::Script {
|
||||||
},
|
script: u5c::script::Script::Native(self.map_native_script(&x)).into(), /* */
|
||||||
babbage::Relay::SingleHostName(port, name) => u5c::Relay {
|
}
|
||||||
ip_v4: Default::default(),
|
|
||||||
ip_v6: Default::default(),
|
|
||||||
dns_name: name.clone(),
|
|
||||||
port: Option::from(port.clone()).unwrap_or_default(),
|
|
||||||
},
|
|
||||||
babbage::Relay::MultiHostName(name) => u5c::Relay {
|
|
||||||
ip_v4: Default::default(),
|
|
||||||
ip_v6: Default::default(),
|
|
||||||
dns_name: name.clone(),
|
|
||||||
port: Default::default(),
|
|
||||||
},
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
pub fn map_cert(x: &trv::MultiEraCert) -> u5c::Certificate {
|
|
||||||
let inner = match x.as_alonzo().unwrap() {
|
|
||||||
babbage::Certificate::StakeRegistration(a) => {
|
|
||||||
u5c::certificate::Certificate::StakeRegistration(map_stake_credential(a))
|
|
||||||
}
|
|
||||||
babbage::Certificate::StakeDeregistration(a) => {
|
|
||||||
u5c::certificate::Certificate::StakeDeregistration(map_stake_credential(a))
|
|
||||||
}
|
|
||||||
babbage::Certificate::StakeDelegation(a, b) => {
|
|
||||||
u5c::certificate::Certificate::StakeDelegation(u5c::StakeDelegationCert {
|
|
||||||
stake_credential: map_stake_credential(a).into(),
|
|
||||||
pool_keyhash: b.to_vec().into(),
|
|
||||||
})
|
|
||||||
}
|
|
||||||
babbage::Certificate::PoolRegistration {
|
|
||||||
operator,
|
|
||||||
vrf_keyhash,
|
|
||||||
pledge,
|
|
||||||
cost,
|
|
||||||
margin,
|
|
||||||
reward_account,
|
|
||||||
pool_owners,
|
|
||||||
relays,
|
|
||||||
pool_metadata,
|
|
||||||
} => u5c::certificate::Certificate::PoolRegistration(u5c::PoolRegistrationCert {
|
|
||||||
operator: operator.to_vec().into(),
|
|
||||||
vrf_keyhash: vrf_keyhash.to_vec().into(),
|
|
||||||
pledge: *pledge,
|
|
||||||
cost: *cost,
|
|
||||||
margin: u5c::RationalNumber {
|
|
||||||
numerator: margin.numerator as i32,
|
|
||||||
denominator: margin.denominator as u32,
|
|
||||||
}
|
|
||||||
.into(),
|
|
||||||
reward_account: reward_account.to_vec().into(),
|
|
||||||
pool_owners: pool_owners.iter().map(|x| x.to_vec().into()).collect(),
|
|
||||||
relays: relays.iter().map(map_relay).collect(),
|
|
||||||
pool_metadata: pool_metadata
|
|
||||||
.clone()
|
|
||||||
.map(|x| u5c::PoolMetadata {
|
|
||||||
url: x.url.clone(),
|
|
||||||
hash: x.hash.to_vec().into(),
|
|
||||||
})
|
|
||||||
.into(),
|
.into(),
|
||||||
}),
|
Some(conway::PseudoScript::PlutusV1Script(x)) => u5c::Script {
|
||||||
babbage::Certificate::PoolRetirement(a, b) => {
|
script: u5c::script::Script::PlutusV1(x.0.to_vec().into()).into(),
|
||||||
u5c::certificate::Certificate::PoolRetirement(u5c::PoolRetirementCert {
|
}
|
||||||
pool_keyhash: a.to_vec().into(),
|
.into(),
|
||||||
epoch: *b,
|
Some(conway::PseudoScript::PlutusV2Script(x)) => u5c::Script {
|
||||||
})
|
script: u5c::script::Script::PlutusV2(x.0.to_vec().into()).into(),
|
||||||
|
}
|
||||||
|
.into(),
|
||||||
|
Some(conway::PseudoScript::PlutusV3Script(_)) => todo!(),
|
||||||
|
None => None,
|
||||||
|
},
|
||||||
}
|
}
|
||||||
babbage::Certificate::GenesisKeyDelegation(a, b, c) => {
|
|
||||||
u5c::certificate::Certificate::GenesisKeyDelegation(u5c::GenesisKeyDelegationCert {
|
|
||||||
genesis_hash: a.to_vec().into(),
|
|
||||||
genesis_delegate_hash: b.to_vec().into(),
|
|
||||||
vrf_keyhash: c.to_vec().into(),
|
|
||||||
})
|
|
||||||
}
|
|
||||||
babbage::Certificate::MoveInstantaneousRewardsCert(a) => {
|
|
||||||
u5c::certificate::Certificate::MirCert(u5c::MirCert {
|
|
||||||
from: match &a.source {
|
|
||||||
babbage::InstantaneousRewardSource::Reserves => u5c::MirSource::Reserves.into(),
|
|
||||||
babbage::InstantaneousRewardSource::Treasury => u5c::MirSource::Treasury.into(),
|
|
||||||
},
|
|
||||||
to: match &a.target {
|
|
||||||
babbage::InstantaneousRewardTarget::StakeCredentials(x) => x
|
|
||||||
.iter()
|
|
||||||
.map(|(k, v)| u5c::MirTarget {
|
|
||||||
stake_credential: map_stake_credential(k).into(),
|
|
||||||
delta_coin: *v,
|
|
||||||
})
|
|
||||||
.collect(),
|
|
||||||
_ => Default::default(),
|
|
||||||
},
|
|
||||||
other_pot: match &a.target {
|
|
||||||
babbage::InstantaneousRewardTarget::OtherAccountingPot(x) => *x,
|
|
||||||
_ => Default::default(),
|
|
||||||
},
|
|
||||||
})
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
u5c::Certificate {
|
|
||||||
certificate: inner.into(),
|
|
||||||
}
|
}
|
||||||
}
|
|
||||||
|
|
||||||
pub fn map_withdrawals(x: &(&[u8], u64)) -> u5c::Withdrawal {
|
pub fn map_stake_credential(&self, x: &babbage::StakeCredential) -> u5c::StakeCredential {
|
||||||
u5c::Withdrawal {
|
let inner = match x {
|
||||||
reward_account: Vec::from(x.0).into(),
|
babbage::StakeCredential::AddrKeyhash(x) => {
|
||||||
coin: x.1,
|
u5c::stake_credential::StakeCredential::AddrKeyHash(x.to_vec().into())
|
||||||
}
|
}
|
||||||
}
|
babbage::StakeCredential::Scripthash(x) => {
|
||||||
|
u5c::stake_credential::StakeCredential::ScriptHash(x.to_vec().into())
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
pub fn map_asset(x: &trv::MultiEraAsset) -> u5c::Asset {
|
u5c::StakeCredential {
|
||||||
u5c::Asset {
|
stake_credential: inner.into(),
|
||||||
name: x.name().to_vec().into(),
|
|
||||||
output_coin: x.output_coin().unwrap_or_default(),
|
|
||||||
mint_coin: x.mint_coin().unwrap_or_default(),
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
pub fn map_policy_assets(x: &trv::MultiEraPolicyAssets) -> u5c::Multiasset {
|
|
||||||
u5c::Multiasset {
|
|
||||||
policy_id: x.policy().to_vec().into(),
|
|
||||||
assets: x.assets().iter().map(map_asset).collect(),
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
pub fn map_vkey_witness(x: &alonzo::VKeyWitness) -> u5c::VKeyWitness {
|
|
||||||
u5c::VKeyWitness {
|
|
||||||
vkey: x.vkey.to_vec().into(),
|
|
||||||
signature: x.signature.to_vec().into(),
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
pub fn map_native_script(x: &alonzo::NativeScript) -> u5c::NativeScript {
|
|
||||||
let inner = match x {
|
|
||||||
babbage::NativeScript::ScriptPubkey(x) => {
|
|
||||||
u5c::native_script::NativeScript::ScriptPubkey(x.to_vec().into())
|
|
||||||
}
|
}
|
||||||
babbage::NativeScript::ScriptAll(x) => {
|
|
||||||
u5c::native_script::NativeScript::ScriptAll(u5c::NativeScriptList {
|
|
||||||
items: x.iter().map(map_native_script).collect(),
|
|
||||||
})
|
|
||||||
}
|
|
||||||
babbage::NativeScript::ScriptAny(x) => {
|
|
||||||
u5c::native_script::NativeScript::ScriptAll(u5c::NativeScriptList {
|
|
||||||
items: x.iter().map(map_native_script).collect(),
|
|
||||||
})
|
|
||||||
}
|
|
||||||
babbage::NativeScript::ScriptNOfK(n, k) => {
|
|
||||||
u5c::native_script::NativeScript::ScriptNOfK(u5c::ScriptNOfK {
|
|
||||||
k: *n,
|
|
||||||
scripts: k.iter().map(map_native_script).collect(),
|
|
||||||
})
|
|
||||||
}
|
|
||||||
babbage::NativeScript::InvalidBefore(s) => {
|
|
||||||
u5c::native_script::NativeScript::InvalidBefore(*s)
|
|
||||||
}
|
|
||||||
babbage::NativeScript::InvalidHereafter(s) => {
|
|
||||||
u5c::native_script::NativeScript::InvalidHereafter(*s)
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
u5c::NativeScript {
|
|
||||||
native_script: inner.into(),
|
|
||||||
}
|
}
|
||||||
}
|
|
||||||
|
|
||||||
fn collect_all_scripts(tx: &trv::MultiEraTx) -> Vec<u5c::Script> {
|
pub fn map_relay(&self, x: &alonzo::Relay) -> u5c::Relay {
|
||||||
let ns = tx
|
match x {
|
||||||
.native_scripts()
|
babbage::Relay::SingleHostAddr(port, v4, v6) => u5c::Relay {
|
||||||
.iter()
|
// ip_v4: v4.map(|x| x.to_vec().into()).into().unwrap_or_default(),
|
||||||
.map(|x| map_native_script(x.deref()))
|
ip_v4: Option::from(v4.clone().map(|x| x.to_vec().into())).unwrap_or_default(),
|
||||||
.map(|x| u5c::Script {
|
ip_v6: Option::from(v6.clone().map(|x| x.to_vec().into())).unwrap_or_default(),
|
||||||
script: u5c::script::Script::Native(x).into(),
|
dns_name: String::default(),
|
||||||
});
|
port: Option::from(port.clone()).unwrap_or_default(),
|
||||||
|
},
|
||||||
let p1 = tx
|
babbage::Relay::SingleHostName(port, name) => u5c::Relay {
|
||||||
.plutus_v1_scripts()
|
ip_v4: Default::default(),
|
||||||
.iter()
|
ip_v6: Default::default(),
|
||||||
.map(|x| x.0.to_vec().into())
|
dns_name: name.clone(),
|
||||||
.map(|x| u5c::Script {
|
port: Option::from(port.clone()).unwrap_or_default(),
|
||||||
script: u5c::script::Script::PlutusV1(x).into(),
|
},
|
||||||
});
|
babbage::Relay::MultiHostName(name) => u5c::Relay {
|
||||||
|
ip_v4: Default::default(),
|
||||||
let p2 = tx
|
ip_v6: Default::default(),
|
||||||
.plutus_v2_scripts()
|
dns_name: name.clone(),
|
||||||
.iter()
|
port: Default::default(),
|
||||||
.map(|x| x.0.to_vec().into())
|
},
|
||||||
.map(|x| u5c::Script {
|
}
|
||||||
script: u5c::script::Script::PlutusV2(x).into(),
|
|
||||||
});
|
|
||||||
|
|
||||||
ns.chain(p1).chain(p2).collect()
|
|
||||||
}
|
|
||||||
|
|
||||||
pub fn map_plutus_constr(x: &alonzo::Constr<alonzo::PlutusData>) -> u5c::Constr {
|
|
||||||
u5c::Constr {
|
|
||||||
tag: x.tag as u32,
|
|
||||||
any_constructor: x.any_constructor.unwrap_or_default(),
|
|
||||||
fields: x.fields.iter().map(map_plutus_datum).collect(),
|
|
||||||
}
|
}
|
||||||
}
|
|
||||||
|
|
||||||
pub fn map_plutus_map(
|
pub fn map_cert(&self, x: &trv::MultiEraCert) -> u5c::Certificate {
|
||||||
x: &KeyValuePairs<alonzo::PlutusData, alonzo::PlutusData>,
|
let inner = match x.as_alonzo().unwrap() {
|
||||||
) -> u5c::PlutusDataMap {
|
babbage::Certificate::StakeRegistration(a) => {
|
||||||
u5c::PlutusDataMap {
|
u5c::certificate::Certificate::StakeRegistration(self.map_stake_credential(a))
|
||||||
pairs: x
|
}
|
||||||
|
babbage::Certificate::StakeDeregistration(a) => {
|
||||||
|
u5c::certificate::Certificate::StakeDeregistration(self.map_stake_credential(a))
|
||||||
|
}
|
||||||
|
babbage::Certificate::StakeDelegation(a, b) => {
|
||||||
|
u5c::certificate::Certificate::StakeDelegation(u5c::StakeDelegationCert {
|
||||||
|
stake_credential: self.map_stake_credential(a).into(),
|
||||||
|
pool_keyhash: b.to_vec().into(),
|
||||||
|
})
|
||||||
|
}
|
||||||
|
babbage::Certificate::PoolRegistration {
|
||||||
|
operator,
|
||||||
|
vrf_keyhash,
|
||||||
|
pledge,
|
||||||
|
cost,
|
||||||
|
margin,
|
||||||
|
reward_account,
|
||||||
|
pool_owners,
|
||||||
|
relays,
|
||||||
|
pool_metadata,
|
||||||
|
} => u5c::certificate::Certificate::PoolRegistration(u5c::PoolRegistrationCert {
|
||||||
|
operator: operator.to_vec().into(),
|
||||||
|
vrf_keyhash: vrf_keyhash.to_vec().into(),
|
||||||
|
pledge: *pledge,
|
||||||
|
cost: *cost,
|
||||||
|
margin: u5c::RationalNumber {
|
||||||
|
numerator: margin.numerator as i32,
|
||||||
|
denominator: margin.denominator as u32,
|
||||||
|
}
|
||||||
|
.into(),
|
||||||
|
reward_account: reward_account.to_vec().into(),
|
||||||
|
pool_owners: pool_owners.iter().map(|x| x.to_vec().into()).collect(),
|
||||||
|
relays: relays.iter().map(|x| self.map_relay(x)).collect(),
|
||||||
|
pool_metadata: pool_metadata
|
||||||
|
.clone()
|
||||||
|
.map(|x| u5c::PoolMetadata {
|
||||||
|
url: x.url.clone(),
|
||||||
|
hash: x.hash.to_vec().into(),
|
||||||
|
})
|
||||||
|
.into(),
|
||||||
|
}),
|
||||||
|
babbage::Certificate::PoolRetirement(a, b) => {
|
||||||
|
u5c::certificate::Certificate::PoolRetirement(u5c::PoolRetirementCert {
|
||||||
|
pool_keyhash: a.to_vec().into(),
|
||||||
|
epoch: *b,
|
||||||
|
})
|
||||||
|
}
|
||||||
|
babbage::Certificate::GenesisKeyDelegation(a, b, c) => {
|
||||||
|
u5c::certificate::Certificate::GenesisKeyDelegation(u5c::GenesisKeyDelegationCert {
|
||||||
|
genesis_hash: a.to_vec().into(),
|
||||||
|
genesis_delegate_hash: b.to_vec().into(),
|
||||||
|
vrf_keyhash: c.to_vec().into(),
|
||||||
|
})
|
||||||
|
}
|
||||||
|
babbage::Certificate::MoveInstantaneousRewardsCert(a) => {
|
||||||
|
u5c::certificate::Certificate::MirCert(u5c::MirCert {
|
||||||
|
from: match &a.source {
|
||||||
|
babbage::InstantaneousRewardSource::Reserves => {
|
||||||
|
u5c::MirSource::Reserves.into()
|
||||||
|
}
|
||||||
|
babbage::InstantaneousRewardSource::Treasury => {
|
||||||
|
u5c::MirSource::Treasury.into()
|
||||||
|
}
|
||||||
|
},
|
||||||
|
to: match &a.target {
|
||||||
|
babbage::InstantaneousRewardTarget::StakeCredentials(x) => x
|
||||||
|
.iter()
|
||||||
|
.map(|(k, v)| u5c::MirTarget {
|
||||||
|
stake_credential: self.map_stake_credential(k).into(),
|
||||||
|
delta_coin: *v,
|
||||||
|
})
|
||||||
|
.collect(),
|
||||||
|
_ => Default::default(),
|
||||||
|
},
|
||||||
|
other_pot: match &a.target {
|
||||||
|
babbage::InstantaneousRewardTarget::OtherAccountingPot(x) => *x,
|
||||||
|
_ => Default::default(),
|
||||||
|
},
|
||||||
|
})
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
u5c::Certificate {
|
||||||
|
certificate: inner.into(),
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
pub fn map_withdrawals(&self, x: &(&[u8], u64)) -> u5c::Withdrawal {
|
||||||
|
u5c::Withdrawal {
|
||||||
|
reward_account: Vec::from(x.0).into(),
|
||||||
|
coin: x.1,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
pub fn map_asset(&self, x: &trv::MultiEraAsset) -> u5c::Asset {
|
||||||
|
u5c::Asset {
|
||||||
|
name: x.name().to_vec().into(),
|
||||||
|
output_coin: x.output_coin().unwrap_or_default(),
|
||||||
|
mint_coin: x.mint_coin().unwrap_or_default(),
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
pub fn map_policy_assets(&self, x: &trv::MultiEraPolicyAssets) -> u5c::Multiasset {
|
||||||
|
u5c::Multiasset {
|
||||||
|
policy_id: x.policy().to_vec().into(),
|
||||||
|
assets: x.assets().iter().map(|x| self.map_asset(x)).collect(),
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
pub fn map_vkey_witness(&self, x: &alonzo::VKeyWitness) -> u5c::VKeyWitness {
|
||||||
|
u5c::VKeyWitness {
|
||||||
|
vkey: x.vkey.to_vec().into(),
|
||||||
|
signature: x.signature.to_vec().into(),
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
pub fn map_native_script(&self, x: &alonzo::NativeScript) -> u5c::NativeScript {
|
||||||
|
let inner = match x {
|
||||||
|
babbage::NativeScript::ScriptPubkey(x) => {
|
||||||
|
u5c::native_script::NativeScript::ScriptPubkey(x.to_vec().into())
|
||||||
|
}
|
||||||
|
babbage::NativeScript::ScriptAll(x) => {
|
||||||
|
u5c::native_script::NativeScript::ScriptAll(u5c::NativeScriptList {
|
||||||
|
items: x.iter().map(|x| self.map_native_script(x)).collect(),
|
||||||
|
})
|
||||||
|
}
|
||||||
|
babbage::NativeScript::ScriptAny(x) => {
|
||||||
|
u5c::native_script::NativeScript::ScriptAll(u5c::NativeScriptList {
|
||||||
|
items: x.iter().map(|x| self.map_native_script(x)).collect(),
|
||||||
|
})
|
||||||
|
}
|
||||||
|
babbage::NativeScript::ScriptNOfK(n, k) => {
|
||||||
|
u5c::native_script::NativeScript::ScriptNOfK(u5c::ScriptNOfK {
|
||||||
|
k: *n,
|
||||||
|
scripts: k.iter().map(|x| self.map_native_script(x)).collect(),
|
||||||
|
})
|
||||||
|
}
|
||||||
|
babbage::NativeScript::InvalidBefore(s) => {
|
||||||
|
u5c::native_script::NativeScript::InvalidBefore(*s)
|
||||||
|
}
|
||||||
|
babbage::NativeScript::InvalidHereafter(s) => {
|
||||||
|
u5c::native_script::NativeScript::InvalidHereafter(*s)
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
u5c::NativeScript {
|
||||||
|
native_script: inner.into(),
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fn collect_all_scripts(&self, tx: &trv::MultiEraTx) -> Vec<u5c::Script> {
|
||||||
|
let ns = tx
|
||||||
|
.native_scripts()
|
||||||
.iter()
|
.iter()
|
||||||
.map(|(k, v)| u5c::PlutusDataPair {
|
.map(|x| self.map_native_script(x.deref()))
|
||||||
key: map_plutus_datum(k).into(),
|
.map(|x| u5c::Script {
|
||||||
value: map_plutus_datum(v).into(),
|
script: u5c::script::Script::Native(x).into(),
|
||||||
})
|
});
|
||||||
.collect(),
|
|
||||||
|
let p1 = tx
|
||||||
|
.plutus_v1_scripts()
|
||||||
|
.iter()
|
||||||
|
.map(|x| x.0.to_vec().into())
|
||||||
|
.map(|x| u5c::Script {
|
||||||
|
script: u5c::script::Script::PlutusV1(x).into(),
|
||||||
|
});
|
||||||
|
|
||||||
|
let p2 = tx
|
||||||
|
.plutus_v2_scripts()
|
||||||
|
.iter()
|
||||||
|
.map(|x| x.0.to_vec().into())
|
||||||
|
.map(|x| u5c::Script {
|
||||||
|
script: u5c::script::Script::PlutusV2(x).into(),
|
||||||
|
});
|
||||||
|
|
||||||
|
ns.chain(p1).chain(p2).collect()
|
||||||
}
|
}
|
||||||
}
|
|
||||||
|
|
||||||
pub fn map_plutus_array(x: &[alonzo::PlutusData]) -> u5c::PlutusDataArray {
|
pub fn map_plutus_constr(&self, x: &alonzo::Constr<alonzo::PlutusData>) -> u5c::Constr {
|
||||||
u5c::PlutusDataArray {
|
u5c::Constr {
|
||||||
items: x.iter().map(map_plutus_datum).collect(),
|
tag: x.tag as u32,
|
||||||
|
any_constructor: x.any_constructor.unwrap_or_default(),
|
||||||
|
fields: x.fields.iter().map(|x| self.map_plutus_datum(x)).collect(),
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
|
||||||
|
|
||||||
pub fn map_plutus_bigint(x: &alonzo::BigInt) -> u5c::BigInt {
|
pub fn map_plutus_map(
|
||||||
let inner = match x {
|
&self,
|
||||||
babbage::BigInt::Int(x) => u5c::big_int::BigInt::Int(i128::from(x.0) as i64),
|
x: &KeyValuePairs<alonzo::PlutusData, alonzo::PlutusData>,
|
||||||
babbage::BigInt::BigUInt(x) => {
|
) -> u5c::PlutusDataMap {
|
||||||
u5c::big_int::BigInt::BigUInt(Vec::<u8>::from(x.clone()).into())
|
u5c::PlutusDataMap {
|
||||||
}
|
|
||||||
babbage::BigInt::BigNInt(x) => {
|
|
||||||
u5c::big_int::BigInt::BigNInt(Vec::<u8>::from(x.clone()).into())
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
u5c::BigInt {
|
|
||||||
big_int: inner.into(),
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
pub fn map_plutus_datum(x: &alonzo::PlutusData) -> u5c::PlutusData {
|
|
||||||
let inner = match x {
|
|
||||||
babbage::PlutusData::Constr(x) => {
|
|
||||||
u5c::plutus_data::PlutusData::Constr(map_plutus_constr(x))
|
|
||||||
}
|
|
||||||
babbage::PlutusData::Map(x) => u5c::plutus_data::PlutusData::Map(map_plutus_map(x)),
|
|
||||||
babbage::PlutusData::Array(x) => u5c::plutus_data::PlutusData::Array(map_plutus_array(x)),
|
|
||||||
babbage::PlutusData::BigInt(x) => {
|
|
||||||
u5c::plutus_data::PlutusData::BigInt(map_plutus_bigint(x))
|
|
||||||
}
|
|
||||||
babbage::PlutusData::BoundedBytes(x) => {
|
|
||||||
u5c::plutus_data::PlutusData::BoundedBytes(x.to_vec().into())
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
u5c::PlutusData {
|
|
||||||
plutus_data: inner.into(),
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
pub fn map_metadatum(x: &alonzo::Metadatum) -> u5c::Metadatum {
|
|
||||||
let inner = match x {
|
|
||||||
babbage::Metadatum::Int(x) => u5c::metadatum::Metadatum::Int(i128::from(x.0) as i64),
|
|
||||||
babbage::Metadatum::Bytes(x) => {
|
|
||||||
u5c::metadatum::Metadatum::Bytes(Vec::<u8>::from(x.clone()).into())
|
|
||||||
}
|
|
||||||
babbage::Metadatum::Text(x) => u5c::metadatum::Metadatum::Text(x.clone()),
|
|
||||||
babbage::Metadatum::Array(x) => u5c::metadatum::Metadatum::Array(u5c::MetadatumArray {
|
|
||||||
items: x.iter().map(map_metadatum).collect(),
|
|
||||||
}),
|
|
||||||
babbage::Metadatum::Map(x) => u5c::metadatum::Metadatum::Map(u5c::MetadatumMap {
|
|
||||||
pairs: x
|
pairs: x
|
||||||
.iter()
|
.iter()
|
||||||
.map(|(k, v)| u5c::MetadatumPair {
|
.map(|(k, v)| u5c::PlutusDataPair {
|
||||||
key: map_metadatum(k).into(),
|
key: self.map_plutus_datum(k).into(),
|
||||||
value: map_metadatum(v).into(),
|
value: self.map_plutus_datum(v).into(),
|
||||||
})
|
})
|
||||||
.collect(),
|
.collect(),
|
||||||
}),
|
}
|
||||||
};
|
|
||||||
|
|
||||||
u5c::Metadatum {
|
|
||||||
metadatum: inner.into(),
|
|
||||||
}
|
}
|
||||||
}
|
|
||||||
|
|
||||||
pub fn map_metadata(label: u64, datum: &alonzo::Metadatum) -> u5c::Metadata {
|
pub fn map_plutus_array(&self, x: &[alonzo::PlutusData]) -> u5c::PlutusDataArray {
|
||||||
u5c::Metadata {
|
u5c::PlutusDataArray {
|
||||||
label,
|
items: x.iter().map(|x| self.map_plutus_datum(x)).collect(),
|
||||||
value: map_metadatum(datum).into(),
|
}
|
||||||
}
|
}
|
||||||
}
|
|
||||||
|
|
||||||
fn collect_all_aux_scripts(tx: &trv::MultiEraTx) -> Vec<u5c::Script> {
|
pub fn map_plutus_bigint(&self, x: &alonzo::BigInt) -> u5c::BigInt {
|
||||||
let ns = tx
|
let inner = match x {
|
||||||
.aux_native_scripts()
|
babbage::BigInt::Int(x) => u5c::big_int::BigInt::Int(i128::from(x.0) as i64),
|
||||||
.iter()
|
babbage::BigInt::BigUInt(x) => {
|
||||||
.map(map_native_script)
|
u5c::big_int::BigInt::BigUInt(Vec::<u8>::from(x.clone()).into())
|
||||||
.map(|x| u5c::Script {
|
}
|
||||||
script: u5c::script::Script::Native(x).into(),
|
babbage::BigInt::BigNInt(x) => {
|
||||||
});
|
u5c::big_int::BigInt::BigNInt(Vec::<u8>::from(x.clone()).into())
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
let p1 = tx
|
u5c::BigInt {
|
||||||
.aux_plutus_v1_scripts()
|
big_int: inner.into(),
|
||||||
.iter()
|
}
|
||||||
.map(|x| x.0.to_vec().into())
|
}
|
||||||
.map(|x| u5c::Script {
|
|
||||||
script: u5c::script::Script::PlutusV1(x).into(),
|
|
||||||
});
|
|
||||||
|
|
||||||
// TODO: check why we don't have plutus v2 aux script, is that a possibility?
|
pub fn map_plutus_datum(&self, x: &alonzo::PlutusData) -> u5c::PlutusData {
|
||||||
|
let inner = match x {
|
||||||
|
babbage::PlutusData::Constr(x) => {
|
||||||
|
u5c::plutus_data::PlutusData::Constr(self.map_plutus_constr(x))
|
||||||
|
}
|
||||||
|
babbage::PlutusData::Map(x) => {
|
||||||
|
u5c::plutus_data::PlutusData::Map(self.map_plutus_map(x))
|
||||||
|
}
|
||||||
|
babbage::PlutusData::Array(x) => {
|
||||||
|
u5c::plutus_data::PlutusData::Array(self.map_plutus_array(x))
|
||||||
|
}
|
||||||
|
babbage::PlutusData::BigInt(x) => {
|
||||||
|
u5c::plutus_data::PlutusData::BigInt(self.map_plutus_bigint(x))
|
||||||
|
}
|
||||||
|
babbage::PlutusData::BoundedBytes(x) => {
|
||||||
|
u5c::plutus_data::PlutusData::BoundedBytes(x.to_vec().into())
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
ns.chain(p1).collect()
|
u5c::PlutusData {
|
||||||
}
|
plutus_data: inner.into(),
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
pub fn map_tx(tx: &trv::MultiEraTx) -> u5c::Tx {
|
pub fn map_metadatum(&self, x: &alonzo::Metadatum) -> u5c::Metadatum {
|
||||||
u5c::Tx {
|
let inner = match x {
|
||||||
hash: tx.hash().to_vec().into(),
|
babbage::Metadatum::Int(x) => u5c::metadatum::Metadatum::Int(i128::from(x.0) as i64),
|
||||||
inputs: tx.inputs().iter().map(|i| map_tx_input(i, tx)).collect(),
|
babbage::Metadatum::Bytes(x) => {
|
||||||
outputs: tx.outputs().iter().map(map_tx_output).collect(),
|
u5c::metadatum::Metadatum::Bytes(Vec::<u8>::from(x.clone()).into())
|
||||||
certificates: tx.certs().iter().map(map_cert).collect(),
|
}
|
||||||
withdrawals: tx
|
babbage::Metadatum::Text(x) => u5c::metadatum::Metadatum::Text(x.clone()),
|
||||||
.withdrawals()
|
babbage::Metadatum::Array(x) => u5c::metadatum::Metadatum::Array(u5c::MetadatumArray {
|
||||||
.collect::<Vec<_>>()
|
items: x.iter().map(|x| self.map_metadatum(x)).collect(),
|
||||||
|
}),
|
||||||
|
babbage::Metadatum::Map(x) => u5c::metadatum::Metadatum::Map(u5c::MetadatumMap {
|
||||||
|
pairs: x
|
||||||
|
.iter()
|
||||||
|
.map(|(k, v)| u5c::MetadatumPair {
|
||||||
|
key: self.map_metadatum(k).into(),
|
||||||
|
value: self.map_metadatum(v).into(),
|
||||||
|
})
|
||||||
|
.collect(),
|
||||||
|
}),
|
||||||
|
};
|
||||||
|
|
||||||
|
u5c::Metadatum {
|
||||||
|
metadatum: inner.into(),
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
pub fn map_metadata(&self, label: u64, datum: &alonzo::Metadatum) -> u5c::Metadata {
|
||||||
|
u5c::Metadata {
|
||||||
|
label,
|
||||||
|
value: self.map_metadatum(datum).into(),
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fn collect_all_aux_scripts(&self, tx: &trv::MultiEraTx) -> Vec<u5c::Script> {
|
||||||
|
let ns = tx
|
||||||
|
.aux_native_scripts()
|
||||||
.iter()
|
.iter()
|
||||||
.map(map_withdrawals)
|
.map(|x| self.map_native_script(x))
|
||||||
.collect(),
|
.map(|x| u5c::Script {
|
||||||
mint: tx.mints().iter().map(map_policy_assets).collect(),
|
script: u5c::script::Script::Native(x).into(),
|
||||||
reference_inputs: tx
|
});
|
||||||
.reference_inputs()
|
|
||||||
|
let p1 = tx
|
||||||
|
.aux_plutus_v1_scripts()
|
||||||
.iter()
|
.iter()
|
||||||
.map(|x| map_tx_input(x, tx))
|
.map(|x| x.0.to_vec().into())
|
||||||
.collect(),
|
.map(|x| u5c::Script {
|
||||||
witnesses: u5c::WitnessSet {
|
script: u5c::script::Script::PlutusV1(x).into(),
|
||||||
vkeywitness: tx.vkey_witnesses().iter().map(map_vkey_witness).collect(),
|
});
|
||||||
script: collect_all_scripts(tx),
|
|
||||||
plutus_datums: tx
|
// TODO: check why we don't have plutus v2 aux script, is that a possibility?
|
||||||
.plutus_data()
|
|
||||||
|
ns.chain(p1).collect()
|
||||||
|
}
|
||||||
|
|
||||||
|
pub fn map_tx(&self, tx: &trv::MultiEraTx) -> u5c::Tx {
|
||||||
|
u5c::Tx {
|
||||||
|
hash: tx.hash().to_vec().into(),
|
||||||
|
inputs: tx
|
||||||
|
.inputs()
|
||||||
.iter()
|
.iter()
|
||||||
.map(|x| map_plutus_datum(x.deref()))
|
.map(|i| self.map_tx_input(i, tx))
|
||||||
.collect(),
|
.collect(),
|
||||||
}
|
outputs: tx.outputs().iter().map(|x| self.map_tx_output(x)).collect(),
|
||||||
.into(),
|
certificates: tx.certs().iter().map(|x| self.map_cert(x)).collect(),
|
||||||
collateral: u5c::Collateral {
|
withdrawals: tx
|
||||||
collateral: tx
|
.withdrawals()
|
||||||
.collateral()
|
|
||||||
.iter()
|
|
||||||
.map(|x| map_tx_input(x, tx))
|
|
||||||
.collect(),
|
|
||||||
collateral_return: tx.collateral_return().map(|x| map_tx_output(&x)),
|
|
||||||
total_collateral: tx.total_collateral().unwrap_or_default(),
|
|
||||||
}
|
|
||||||
.into(),
|
|
||||||
fee: tx.fee().unwrap_or_default(),
|
|
||||||
validity: u5c::TxValidity {
|
|
||||||
start: tx.validity_start().unwrap_or_default(),
|
|
||||||
ttl: tx.ttl().unwrap_or_default(),
|
|
||||||
}
|
|
||||||
.into(),
|
|
||||||
successful: tx.is_valid(),
|
|
||||||
auxiliary: u5c::AuxData {
|
|
||||||
metadata: tx
|
|
||||||
.metadata()
|
|
||||||
.collect::<Vec<_>>()
|
.collect::<Vec<_>>()
|
||||||
.into_iter()
|
.iter()
|
||||||
.map(|(l, d)| map_metadata(l, d))
|
.map(|x| self.map_withdrawals(x))
|
||||||
.collect(),
|
.collect(),
|
||||||
scripts: collect_all_aux_scripts(tx),
|
mint: tx
|
||||||
|
.mints()
|
||||||
|
.iter()
|
||||||
|
.map(|x| self.map_policy_assets(x))
|
||||||
|
.collect(),
|
||||||
|
reference_inputs: tx
|
||||||
|
.reference_inputs()
|
||||||
|
.iter()
|
||||||
|
.map(|x| self.map_tx_input(x, tx))
|
||||||
|
.collect(),
|
||||||
|
witnesses: u5c::WitnessSet {
|
||||||
|
vkeywitness: tx
|
||||||
|
.vkey_witnesses()
|
||||||
|
.iter()
|
||||||
|
.map(|x| self.map_vkey_witness(x))
|
||||||
|
.collect(),
|
||||||
|
script: self.collect_all_scripts(tx),
|
||||||
|
plutus_datums: tx
|
||||||
|
.plutus_data()
|
||||||
|
.iter()
|
||||||
|
.map(|x| self.map_plutus_datum(x.deref()))
|
||||||
|
.collect(),
|
||||||
|
}
|
||||||
|
.into(),
|
||||||
|
collateral: u5c::Collateral {
|
||||||
|
collateral: tx
|
||||||
|
.collateral()
|
||||||
|
.iter()
|
||||||
|
.map(|x| self.map_tx_input(x, tx))
|
||||||
|
.collect(),
|
||||||
|
collateral_return: tx.collateral_return().map(|x| self.map_tx_output(&x)),
|
||||||
|
total_collateral: tx.total_collateral().unwrap_or_default(),
|
||||||
|
}
|
||||||
|
.into(),
|
||||||
|
fee: tx.fee().unwrap_or_default(),
|
||||||
|
validity: u5c::TxValidity {
|
||||||
|
start: tx.validity_start().unwrap_or_default(),
|
||||||
|
ttl: tx.ttl().unwrap_or_default(),
|
||||||
|
}
|
||||||
|
.into(),
|
||||||
|
successful: tx.is_valid(),
|
||||||
|
auxiliary: u5c::AuxData {
|
||||||
|
metadata: tx
|
||||||
|
.metadata()
|
||||||
|
.collect::<Vec<_>>()
|
||||||
|
.into_iter()
|
||||||
|
.map(|(l, d)| self.map_metadata(l, d))
|
||||||
|
.collect(),
|
||||||
|
scripts: self.collect_all_aux_scripts(tx),
|
||||||
|
}
|
||||||
|
.into(),
|
||||||
}
|
}
|
||||||
.into(),
|
}
|
||||||
|
|
||||||
|
pub fn map_block(&self, block: &trv::MultiEraBlock) -> u5c::Block {
|
||||||
|
u5c::Block {
|
||||||
|
header: u5c::BlockHeader {
|
||||||
|
slot: block.slot(),
|
||||||
|
hash: block.hash().to_vec().into(),
|
||||||
|
height: block.number(),
|
||||||
|
}
|
||||||
|
.into(),
|
||||||
|
body: u5c::BlockBody {
|
||||||
|
tx: block.txs().iter().map(|x| self.map_tx(x)).collect(),
|
||||||
|
}
|
||||||
|
.into(),
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
pub fn map_block_cbor(&self, raw: &[u8]) -> u5c::Block {
|
||||||
|
let block = trv::MultiEraBlock::decode(raw).unwrap();
|
||||||
|
self.map_block(&block)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
pub fn map_block(block: &trv::MultiEraBlock) -> u5c::Block {
|
|
||||||
u5c::Block {
|
|
||||||
header: u5c::BlockHeader {
|
|
||||||
slot: block.slot(),
|
|
||||||
hash: block.hash().to_vec().into(),
|
|
||||||
height: block.number(),
|
|
||||||
}
|
|
||||||
.into(),
|
|
||||||
body: u5c::BlockBody {
|
|
||||||
tx: block.txs().iter().map(map_tx).collect(),
|
|
||||||
}
|
|
||||||
.into(),
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
pub fn map_block_cbor(raw: &[u8]) -> u5c::Block {
|
|
||||||
let block = trv::MultiEraBlock::decode(raw).unwrap();
|
|
||||||
map_block(&block)
|
|
||||||
}
|
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue