fix(publisher): Allow healthcheck while awaiting relayer node sync (#347

)

crates/fuel-streams-publisher/src/publisher/blocks_streams.rs

@@ -327,6 +327,7 @@ mod tests {
             fn blocks_subscription(&self) -> broadcast::Receiver<FuelCoreImporterResult>;
             async fn start(&self) -> anyhow::Result<()>;
             fn is_started(&self) -> bool;
+            async fn await_synced_at_least_once(&self) -> anyhow::Result<()>;
             async fn stop(&self);
             fn base_asset_id(&self) -> &FuelCoreAssetId;
             fn chain_id(&self) -> &FuelCoreChainId;

crates/fuel-streams-publisher/src/publisher/fuel_core_like.rs

@@ -34,6 +34,7 @@ pub type OffchainDatabase = GenericDatabase<
 pub trait FuelCoreLike: Sync + Send {
     async fn start(&self) -> anyhow::Result<()>;
     fn is_started(&self) -> bool;
+    async fn await_synced_at_least_once(&self) -> anyhow::Result<()>;
     async fn stop(&self);
 
     fn base_asset_id(&self) -> &FuelCoreAssetId;
@@ -163,8 +164,6 @@ impl FuelCore {
         let fuel_service =
             fuel_core_bin::cli::run::get_service(command).await?;
 
-        fuel_service.await_relayer_synced().await?;
-
         let fuel_core: Self = fuel_service.into();
 
         Ok(fuel_core.arc())
@@ -183,10 +182,13 @@ impl FuelCoreLike for FuelCore {
 
         Ok(())
     }
-
     fn is_started(&self) -> bool {
         self.fuel_service.state().started()
     }
+    async fn await_synced_at_least_once(&self) -> anyhow::Result<()> {
+        self.fuel_service.await_relayer_synced().await?;
+        Ok(())
+    }
 
     async fn stop(&self) {
         if matches!(

crates/fuel-streams-publisher/src/publisher/mod.rs

@@ -54,6 +54,11 @@ impl Publisher {
         })
     }
 
+    pub fn is_healthy(&self) -> bool {
+        // TODO: Update this condition to include more health checks
+        self.fuel_core.is_started() && self.nats_client.is_connected()
+    }
+
     #[cfg(feature = "test-helpers")]
     pub async fn default(
         nats_client: &NatsClient,
@@ -99,6 +104,12 @@ impl Publisher {
         &self,
         shutdown_token: ShutdownToken,
     ) -> anyhow::Result<()> {
+        tracing::info!("Awaiting FuelCore Sync...");
+
+        self.fuel_core.await_synced_at_least_once().await?;
+
+        tracing::info!("FuelCore has synced successfully!");
+
         tracing::info!("Publishing started...");
 
         let mut blocks_stream = build_blocks_stream(

crates/fuel-streams-publisher/src/server/state.rs

@@ -77,13 +77,7 @@ impl ServerState {
 
 impl ServerState {
     pub fn is_healthy(&self) -> bool {
-        if !self.publisher.fuel_core.is_started() {
-            return false;
-        }
-        if !self.publisher.nats_client.is_connected() {
-            return false;
-        }
-        true
+        self.publisher.is_healthy()
     }
 
     pub async fn get_health(&self) -> HealthResponse {

tests/tests/publisher.rs

@@ -53,6 +53,9 @@ impl FuelCoreLike for TestFuelCore {
     fn is_started(&self) -> bool {
         true
     }
+    async fn await_synced_at_least_once(&self) -> anyhow::Result<()> {
+        Ok(())
+    }
     async fn stop(&self) {}
 
     async fn await_offchain_db_sync(