feat(runner): assert spec version v8 (#160)

Author: Larkooo

crates/indexer/engine/src/engine.rs

@@ -3,7 +3,6 @@ use std::fmt::Debug;
 use std::sync::Arc;
 use std::time::Duration;
 
-use dojo_utils::provider as provider_utils;
 use dojo_world::contracts::world::WorldContractReader;
 use lazy_static::lazy_static;
 use starknet::core::types::{Event, TransactionContent};
@@ -152,11 +151,6 @@ impl<P: Provider + Send + Sync + std::fmt::Debug + 'static> Engine<P> {
     }
 
     pub async fn start(&mut self) -> Result<(), Error> {
-        if let Err(e) = provider_utils::health_check_provider(self.provider.clone()).await {
-            error!(target: LOG_TARGET,"Provider health check failed during engine start");
-            return Err(Error::AnyhowError(e));
-        }
-
         let mut fetching_backoff_delay = Duration::from_secs(1);
         let mut processing_backoff_delay = Duration::from_secs(1);
         let max_backoff_delay = Duration::from_secs(60);

crates/indexer/engine/src/error.rs

@@ -5,13 +5,11 @@ pub enum Error {
     #[error(transparent)]
     Fetcher(#[from] torii_indexer_fetcher::Error),
     #[error(transparent)]
-    ProcessError(#[from] ProcessError),
+    Process(#[from] ProcessError),
     #[error(transparent)]
     SqliteError(#[from] torii_sqlite::error::Error),
     #[error(transparent)]
-    ProviderError(#[from] starknet::providers::ProviderError),
-    #[error(transparent)]
-    AnyhowError(#[from] anyhow::Error),
+    Provider(#[from] starknet::providers::ProviderError),
     #[error(transparent)]
     ControllerSync(#[from] torii_sqlite::error::ControllerSyncError),
 }

crates/runner/src/lib.rs

@@ -106,6 +106,14 @@ impl Runner {
         );
         let provider: Arc<_> = JsonRpcClient::new(transport).into();
 
+        // Check provider spec version. We only support v0.8.
+        let spec_version = provider.spec_version().await?;
+        if !spec_version.starts_with("0.8") {
+            return Err(anyhow::anyhow!(
+                "Provider spec version is not supported. Please use a provider that supports v0.8. Got: {spec_version}. You might need to add a `rpc/v0_8` to the end of the URL."
+            ));
+        }
+
         // Verify contracts are deployed
         if self.args.runner.check_contracts {
             let undeployed =