chore: update Pallas to v0.19.0-alpha.1 (txpipe#610)

Cargo.toml

@@ -12,17 +12,15 @@ authors = ["Santiago Carmuega <[email protected]>"]
 
 
 [dependencies]
-# pallas = "0.19.0-alpha.0"
+pallas = "0.19.0-alpha.1"
 # pallas = { path = "../pallas/pallas" }
-pallas = { git = "https://github.com/txpipe/pallas" }
+# pallas = { git = "https://github.com/txpipe/pallas" }
 
 gasket = { version = "^0.4", features = ["derive"] }
 # gasket = { path = "../../construkts/gasket-rs/gasket", features = ["derive"] }
 # gasket = { git = "https://github.com/construkts/gasket-rs.git", features = ["derive"] }
 
-utxorpc-spec-ledger = "1.0.0-alpha.0"
-# utxorpc-spec-ledger = { path = "../../utxorpc/spec/ledger/gen/rust" }
-# utxorpc-spec-ledger = { git = "https://github.com/utxorpc/spec.git" }
+utxorpc = { version = "1.0.0-alpha.1" }
 
 hex = "0.4.3"
 net2 = "0.2.37"

src/bin/oura/console.rs

@@ -177,7 +177,7 @@ pub fn initialize(mode: &Option<Mode>) {
  if !matches!(mode, Some(Mode::Tui)) {
  tracing::subscriber::set_global_default(
  tracing_subscriber::FmtSubscriber::builder()
- .with_max_level(tracing::Level::TRACE)
+ .with_max_level(tracing::Level::DEBUG)
  .finish(),
  )
  .unwrap();

src/filters/legacy_v1/crawl.rs

@@ -59,8 +59,10 @@ impl EventWriter<'_> {
  ..EventContext::default()
  });
 
- for asset in output.assets() {
- child.append_from(OutputAssetRecord::from(&asset))?;
+ for policy in output.non_ada_assets() {
+ for asset in policy.assets() {
+ child.append_from(OutputAssetRecord::from(&asset))?;
+ }
  }
 
  if let Some(MintedDatumOption::Data(datum)) = &output.datum() {
@@ -135,8 +137,10 @@ impl EventWriter<'_> {
  }
 
  // crawl mints
- for asset in tx.mints() {
- self.append_from(self.to_mint_record(&asset))?;
+ for policy in tx.mints() {
+ for asset in policy.assets() {
+ self.append_from(self.to_mint_record(&asset))?;
+ }
  }
 
  self.crawl_metadata(tx)?;

src/filters/legacy_v1/map.rs

@@ -85,10 +85,10 @@ impl From<&MultiEraInput<'_>> for TxInputRecord {
 impl From<&MultiEraAsset<'_>> for OutputAssetRecord {
  fn from(value: &MultiEraAsset<'_>) -> Self {
  Self {
- policy: value.policy().map(ToString::to_string).unwrap_or_default(),
- asset: value.name().map(|x| x.to_hex()).unwrap_or_default(),
+ policy: value.policy().to_string(),
+ asset: value.name().to_hex(),
  asset_ascii: value.to_ascii_name(),
- amount: value.coin() as u64,
+ amount: value.output_coin().unwrap_or_default(),
  }
  }
 }
@@ -146,7 +146,8 @@ impl EventWriter<'_> {
  assets: output
  .non_ada_assets()
  .iter()
- .map(|x| OutputAssetRecord::from(x))
+ .flat_map(|x| x.assets())
+ .map(|x| OutputAssetRecord::from(&x))
  .collect::<Vec<_>>()
  .into(),
  datum_hash: match &output.datum() {
@@ -197,7 +198,12 @@ impl EventWriter<'_> {
 
  record.input_count = inputs.len();
 
- let mints: Vec<_> = tx.mints().iter().map(|x| self.to_mint_record(x)).collect();
+ let mints: Vec<_> = tx
+ .mints()
+ .iter()
+ .flat_map(|x| x.assets())
+ .map(|x| self.to_mint_record(&x))
+ .collect();
 
  record.mint_count = mints.len();
 
@@ -331,9 +337,9 @@ impl EventWriter<'_> {
 
  pub fn to_mint_record(&self, asset: &MultiEraAsset) -> MintRecord {
  MintRecord {
- policy: asset.policy().map(|x| x.to_string()).unwrap_or_default(),
- asset: asset.name().map(hex::encode).unwrap_or_default(),
- quantity: asset.coin(),
+ policy: asset.policy().to_string(),
+ asset: hex::encode(asset.name()),
+ quantity: asset.mint_coin().unwrap_or_default(),
  }
  }