fix(publisher): fix failing integration tests

FuelLabs · Nov 23, 2024 · 9785d79 · 9785d79
1 parent c2e19c5
commit 9785d79
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 10 deletions.
diff --git a/crates/fuel-streams-core/src/transactions/subjects.rs b/crates/fuel-streams-core/src/transactions/subjects.rs
@@ -134,15 +134,6 @@ pub struct TransactionsSubject {
     pub kind: Option<TransactionKind>,
 }
 
-// impl From<&FuelCoreTransaction> for TransactionsSubject {
-//     fn from(value: &FuelCoreTransaction) -> Self {
-//         let subject = TransactionsSubject::new();
-//         let tx_id = value.cached_id().unwrap();
-//         let kind = TransactionKind::from(value.to_owned());
-//         subject.with_tx_id(Some(tx_id.into())).with_kind(Some(kind))
-//     }
-// }
-
 impl From<&Transaction> for TransactionsSubject {
     fn from(transaction: &Transaction) -> Self {
         let subject = TransactionsSubject::new();

diff --git a/tests/tests/publisher.rs b/tests/tests/publisher.rs
@@ -20,6 +20,7 @@ use tokio::sync::broadcast::{self, Receiver, Sender};
 
 struct TestFuelCore {
     chain_id: ChainId,
+    base_asset_id: AssetId,
     database: CombinedDatabase,
     blocks_broadcaster: Sender<fuel_core_importer::ImporterResult>,
     receipts: Option<Vec<FuelCoreReceipt>>,
@@ -31,6 +32,7 @@ impl TestFuelCore {
     ) -> Self {
         Self {
             chain_id: ChainId::default(),
+            base_asset_id: AssetId::zeroed(),
             database: CombinedDatabase::default(),
             blocks_broadcaster,
             receipts: None,
@@ -54,7 +56,7 @@ impl FuelCoreLike for TestFuelCore {
     async fn stop(&self) {}
 
     fn base_asset_id(&self) -> &AssetId {
-        unimplemented!()
+        &self.base_asset_id
     }
     fn chain_id(&self) -> &ChainId {
         &self.chain_id