Sulkta-OSS/pallas
3
0
Fork 0
Code Issues 1 Pull requests 4 Projects Releases Packages Wiki Activity Actions

chore(interop): update u5c spec to v0.8.0 (#493)

Browse source
This commit is contained in:
Santiago Carmuega 2024-07-28 19:48:43 -03:00 • committed by GitHub
parent ad1a5e3c2e
commit 46dff24c3e
4 changed files with 1318 additions and 468 deletions
Download patch file Download diff file Expand all files Collapse all files

2
pallas-network/src/miniprotocols/blockfetch/server.rs
View file

@ -176,7 +176,7 @@ impl Server {
/// # Arguments /// # Arguments
/// ///
/// * `blocks` - Ordered list of block bodies corresponding to the client's /// * `blocks` - Ordered list of block bodies corresponding to the client's
/// requested range. /// requested range.
pub async fn send_block_range(&mut self, blocks: Vec<Body>) -> Result<(), ServerError> { pub async fn send_block_range(&mut self, blocks: Vec<Body>) -> Result<(), ServerError> {
if blocks.is_empty() { if blocks.is_empty() {
self.send_no_blocks().await self.send_no_blocks().await

2
pallas-utxorpc/Cargo.toml
View file

@ -16,7 +16,7 @@ pallas-primitives = { version = "=0.29.0", path = "../pallas-primitives" }
pallas-codec = { version = "=0.29.0", path = "../pallas-codec" } pallas-codec = { version = "=0.29.0", path = "../pallas-codec" }
pallas-crypto = { version = "=0.29.0", path = "../pallas-crypto" } pallas-crypto = { version = "=0.29.0", path = "../pallas-crypto" }
utxorpc-spec = { version = "0.7.0" } utxorpc-spec = { version = "0.8.0" }
[dev-dependencies] [dev-dependencies]
hex = "0.4.3" hex = "0.4.3"

39
pallas-utxorpc/src/lib.rs
View file

@ -50,7 +50,7 @@ impl<C: LedgerContext> Mapper<C> {
pub fn map_redeemer(&self, x: &trv::MultiEraRedeemer) -> u5c::Redeemer { pub fn map_redeemer(&self, x: &trv::MultiEraRedeemer) -> u5c::Redeemer {
u5c::Redeemer { u5c::Redeemer {
purpose: self.map_purpose(&x.tag()).into(), purpose: self.map_purpose(&x.tag()).into(),
datum: self.map_plutus_datum(x.data()).into(), payload: self.map_plutus_datum(x.data()).into(),
} }
} }
@ -112,6 +112,24 @@ impl<C: LedgerContext> Mapper<C> {
} }
} }
pub fn map_tx_datum(&self, x: &trv::MultiEraOutput) -> u5c::Datum {
u5c::Datum {
hash: match x.datum() {
Some(babbage::PseudoDatumOption::Data(x)) => x.original_hash().to_vec().into(),
Some(babbage::PseudoDatumOption::Hash(x)) => x.to_vec().into(),
_ => vec![].into(),
},
payload: match x.datum() {
Some(babbage::PseudoDatumOption::Data(x)) => self.map_plutus_datum(&x.0).into(),
_ => None,
},
original_cbor: match x.datum() {
Some(babbage::PseudoDatumOption::Data(x)) => x.raw_cbor().to_vec().into(),
_ => vec![].into(),
},
}
}
pub fn map_tx_output(&self, x: &trv::MultiEraOutput) -> u5c::TxOutput { pub fn map_tx_output(&self, x: &trv::MultiEraOutput) -> u5c::TxOutput {
u5c::TxOutput { u5c::TxOutput {
address: x.address().map(|a| a.to_vec()).unwrap_or_default().into(), address: x.address().map(|a| a.to_vec()).unwrap_or_default().into(),
@ -124,15 +142,7 @@ impl<C: LedgerContext> Mapper<C> {
.iter() .iter()
.map(|x| self.map_policy_assets(x)) .map(|x| self.map_policy_assets(x))
.collect(), .collect(),
datum: match x.datum() { datum: self.map_tx_datum(x).into(),
Some(babbage::PseudoDatumOption::Data(x)) => self.map_plutus_datum(&x.0).into(),
_ => None,
},
datum_hash: match x.datum() {
Some(babbage::PseudoDatumOption::Data(x)) => x.original_hash().to_vec().into(),
Some(babbage::PseudoDatumOption::Hash(x)) => x.to_vec().into(),
_ => vec![].into(),
},
script: match x.script_ref() { script: match x.script_ref() {
Some(conway::PseudoScript::NativeScript(x)) => u5c::Script { Some(conway::PseudoScript::NativeScript(x)) => u5c::Script {
script: u5c::script::Script::Native(Self::map_native_script(&x)).into(), /* */ script: u5c::script::Script::Native(Self::map_native_script(&x)).into(), /* */
@ -669,6 +679,15 @@ mod tests {
let cbor = hex::decode(block_str).unwrap(); let cbor = hex::decode(block_str).unwrap();
let block = pallas_traverse::MultiEraBlock::decode(&cbor).unwrap(); let block = pallas_traverse::MultiEraBlock::decode(&cbor).unwrap();
let current = serde_json::json!(mapper.map_block(&block)); let current = serde_json::json!(mapper.map_block(&block));
// un-comment the following to generate a new snapshot
// std::fs::write(
// "new_snapshot.json",
// serde_json::to_string_pretty(&current).unwrap(),
// )
// .unwrap();
let expected: serde_json::Value = serde_json::from_str(&json_str).unwrap(); let expected: serde_json::Value = serde_json::from_str(&json_str).unwrap();
assert_eq!(expected, current) assert_eq!(expected, current)

1741
test_data/u5c1.json
View file

File diff suppressed because it is too large Load diff