chore: remove aleo and radix diffs

Author: troykessler

rust/main/Cargo.lock

@@ -50,4 +50,3 @@ indexmap = "2.0"
 rand_chacha = { version = "0.3.0" }
 sodiumbox = "0.1.0"
 base64.workspace = true
-bech32.workspace = true

rust/main/chains/hyperlane-aleo/Cargo.toml

@@ -4,7 +4,7 @@ use async_trait::async_trait;
 
 use hyperlane_core::{
     ChainResult, ContractLocator, HyperlaneChain, HyperlaneContract, HyperlaneDomain,
-    HyperlaneProvider, Indexed, Indexer, LogMeta, SequenceAwareIndexer, H256,
+    HyperlaneProvider, Indexed, Indexer, LogMeta, SequenceAwareIndexer, H256, H512,
 };
 
 use crate::provider::{AleoClient, BaseHttpClient};
@@ -97,6 +97,25 @@ impl<C: AleoClient> Indexer<H256> for AleoDeliveryIndexer<C> {
     async fn get_finalized_block_number(&self) -> ChainResult<u32> {
         AleoIndexer::get_finalized_block_number(self).await
     }
+
+    /// Fetch list of logs emitted in a transaction with the given hash.
+    async fn fetch_logs_by_tx_hash(
+        &self,
+        tx_hash: H512,
+    ) -> ChainResult<Vec<(Indexed<H256>, LogMeta)>> {
+        let logs = AleoIndexer::fetch_logs_by_tx_hash(self, tx_hash).await?;
+        Ok(logs
+            .into_iter()
+            .map(|(indexed, meta)| {
+                let id = aleo_hash_to_h256(indexed.inner());
+                let mut update = Indexed::new(id);
+                if let Some(sequence) = indexed.sequence {
+                    update = update.with_sequence(sequence);
+                };
+                (update, meta)
+            })
+            .collect())
+    }
 }
 
 #[async_trait]

rust/main/chains/hyperlane-aleo/src/indexer/delivery.rs

@@ -5,6 +5,7 @@ use async_trait::async_trait;
 use hyperlane_core::{
     ChainResult, ContractLocator, HyperlaneChain, HyperlaneContract, HyperlaneDomain,
     HyperlaneMessage, HyperlaneProvider, Indexed, Indexer, LogMeta, SequenceAwareIndexer, H256,
+    H512,
 };
 
 use crate::{
@@ -87,6 +88,14 @@ impl<C: AleoClient> Indexer<HyperlaneMessage> for AleoDispatchIndexer<C> {
     async fn get_finalized_block_number(&self) -> ChainResult<u32> {
         AleoIndexer::get_finalized_block_number(self).await
     }
+
+    /// Fetch list of logs emitted in a transaction with the given hash.
+    async fn fetch_logs_by_tx_hash(
+        &self,
+        tx_hash: H512,
+    ) -> ChainResult<Vec<(Indexed<HyperlaneMessage>, LogMeta)>> {
+        AleoIndexer::fetch_logs_by_tx_hash(self, tx_hash).await
+    }
 }
 
 #[async_trait]

rust/main/chains/hyperlane-aleo/src/indexer/dispatch.rs

@@ -3,7 +3,7 @@ use std::ops::RangeInclusive;
 use async_trait::async_trait;
 
 use hyperlane_core::{
-    ChainResult, ContractLocator, Indexed, Indexer, LogMeta, SequenceAwareIndexer, H256,
+    ChainResult, ContractLocator, Indexed, Indexer, LogMeta, SequenceAwareIndexer, H256, H512,
 };
 
 use crate::{encode_component_address, parse_process_id_event, ConnectionConf, RadixProvider};
@@ -52,6 +52,25 @@ impl Indexer<H256> for RadixDeliveryIndexer {
     async fn get_finalized_block_number(&self) -> ChainResult<u32> {
         Ok(self.provider.get_state_version(None).await?.try_into()?)
     }
+
+    async fn fetch_logs_by_tx_hash(
+        &self,
+        tx_hash: H512,
+    ) -> ChainResult<Vec<(Indexed<H256>, LogMeta)>> {
+        let events = self
+            .provider
+            .fetch_logs_by_hash(&self.address, &tx_hash, parse_process_id_event)
+            .await?;
+        let result = events
+            .into_iter()
+            .map(|(event, meta)| {
+                let id: H256 = event.message_id.into();
+                let sequence = event.sequence;
+                (Indexed::new(id).with_sequence(sequence), meta)
+            })
+            .collect();
+        Ok(result)
+    }
 }
 
 #[async_trait]

rust/main/chains/hyperlane-radix/src/indexer/delivery.rs

@@ -3,7 +3,8 @@ use std::ops::RangeInclusive;
 use async_trait::async_trait;
 
 use hyperlane_core::{
-    ChainResult, ContractLocator, HyperlaneMessage, Indexed, Indexer, LogMeta, SequenceAwareIndexer,
+    ChainResult, ContractLocator, HyperlaneMessage, Indexed, Indexer, LogMeta,
+    SequenceAwareIndexer, H512,
 };
 
 use crate::{encode_component_address, parse_dispatch_event, ConnectionConf, RadixProvider};
@@ -52,6 +53,25 @@ impl Indexer<HyperlaneMessage> for RadixDispatchIndexer {
     async fn get_finalized_block_number(&self) -> ChainResult<u32> {
         Ok(self.provider.get_state_version(None).await?.try_into()?)
     }
+
+    async fn fetch_logs_by_tx_hash(
+        &self,
+        tx_hash: H512,
+    ) -> ChainResult<Vec<(Indexed<HyperlaneMessage>, LogMeta)>> {
+        let events = self
+            .provider
+            .fetch_logs_by_hash(&self.address, &tx_hash, parse_dispatch_event)
+            .await?;
+        let result = events
+            .into_iter()
+            .map(|(event, meta)| {
+                let message: HyperlaneMessage = event.message.into();
+                let sequence = event.sequence;
+                (Indexed::new(message).with_sequence(sequence), meta)
+            })
+            .collect();
+        Ok(result)
+    }
 }
 
 #[async_trait]