Port changes from #178

dcSpark · Mar 19, 2024 · 7e3982d · 7e3982d
1 parent a5237f9
commit 7e3982d
Show file tree

Hide file tree

Showing 4 changed files with 12 additions and 6 deletions.
diff --git a/indexer/entity/src/block.rs b/indexer/entity/src/block.rs
@@ -12,6 +12,11 @@ pub struct Model {
     pub epoch: i32,
     pub slot: i32,
     pub payload: Option<Vec<u8>>,
+    /**
+     * tx_count is useful to skip empty blocks during pagination
+     * We cache tx_count here even though you can derive this number by doing a join of Block<>Transaction
+     * Since caching it is a relatively small amount of data for better performance
+     */
     pub tx_count: i32,
 }
 

diff --git a/indexer/tasks/src/byron/byron_txs.rs b/indexer/tasks/src/byron/byron_txs.rs
@@ -1,5 +1,6 @@
 use crate::{dsl::task_macro::*, era_common::transactions_from_hashes, utils::blake2b256};
 use cml_core::serialization::ToBytes;
+use cml_crypto::RawBytesEncoding;
 use cml_multi_era::byron::block::ByronBlock;
 use cml_multi_era::MultiEraBlock;
 use entity::sea_orm::Set;
@@ -48,7 +49,7 @@ async fn handle_tx(
                 .body
                 .tx_payload
                 .iter()
-                .map(|tx| <[u8; 32]>::from(tx.byron_tx.hash()).to_vec())
+                .map(|tx| tx.byron_tx.hash().to_raw_bytes().to_vec())
                 .collect::<Vec<Vec<u8>>>(),
             _ => vec![],
         };
@@ -70,7 +71,7 @@ async fn handle_tx(
             };
 
             TransactionActiveModel {
-                hash: Set(<[u8; 32]>::from(tx.byron_tx.hash()).to_vec()),
+                hash: Set(tx.byron_tx.hash().to_raw_bytes().to_vec()),
                 block_id: Set(database_block.id),
                 tx_index: Set(idx as i32),
                 payload: Set(tx_payload),

diff --git a/indexer/tasks/src/multiera/multiera_metadata.rs b/indexer/tasks/src/multiera/multiera_metadata.rs
@@ -1,5 +1,4 @@
-use cml_chain::auxdata::metadata::Metadata;
-use cml_chain::auxdata::AuxiliaryData;
+use cml_chain::auxdata::{AuxiliaryData, Metadata};
 use cml_core::serialization::Serialize;
 use std::collections::BTreeMap;
 

diff --git a/indexer/tasks/src/multiera/multiera_txs.rs b/indexer/tasks/src/multiera/multiera_txs.rs
@@ -1,4 +1,5 @@
 use cml_core::serialization::Serialize;
+use cml_crypto::RawBytesEncoding;
 use std::collections::{BTreeSet, HashSet};
 
 use super::multiera_block::MultieraBlockTask;
@@ -45,7 +46,7 @@ async fn handle_tx(
                 .1
                 .transaction_bodies()
                 .iter()
-                .map(|tx_body| <[u8; 32]>::from(tx_body.hash()).to_vec())
+                .map(|tx_body| tx_body.hash().to_raw_bytes().to_vec())
                 .collect::<Vec<_>>()
                 .as_slice(),
         )
@@ -72,7 +73,7 @@ async fn handle_tx(
                 vec![]
             };
             TransactionActiveModel {
-                hash: Set(<[u8; 32]>::from(tx.hash()).to_vec()),
+                hash: Set(tx.hash().to_raw_bytes().to_vec()),
                 block_id: Set(database_block.id),
                 tx_index: Set(idx as i32),
                 payload: Set(tx_payload),