Remove substreams support

Cargo.toml

@@ -7,7 +7,6 @@ members = [
     "chain/common",
     "chain/ethereum",
     "chain/near",
-    "chain/substreams",
     "gnd",
     "graphql",
     "node",
@@ -21,9 +20,6 @@ members = [
     "server/metrics",
     "store/postgres",
     "store/test-store",
-    "substreams/substreams-head-tracker",
-    "substreams/substreams-trigger-filter",
-    "substreams/trigger-filters",
     "graph",
     "tests",
     "graph/derive",

chain/ethereum/examples/firehose.rs

@@ -38,7 +38,6 @@ async fn main() -> Result<(), Error> {
         false,
         SubgraphLimit::Unlimited,
         metrics,
-        false,
     ));
 
     loop {

chain/ethereum/src/chain.rs

@@ -16,9 +16,7 @@ use graph::prelude::{
     retry, BlockHash, ComponentLoggerConfig, ElasticComponentLoggerConfig, EthereumBlock,
     EthereumCallCache, LightEthereumBlock, LightEthereumBlockExt, MetricsRegistry, StoreError,
 };
-use graph::schema::InputSchema;
 use graph::slog::{debug, error, trace, warn};
-use graph::substreams::Clock;
 use graph::{
     blockchain::{
         block_stream::{
@@ -114,18 +112,6 @@ impl BlockStreamBuilder<Chain> for EthereumStreamBuilder {
         )))
     }
 
-    async fn build_substreams(
-        &self,
-        _chain: &Chain,
-        _schema: InputSchema,
-        _deployment: DeploymentLocator,
-        _block_cursor: FirehoseCursor,
-        _subgraph_current_block: Option<BlockPtr>,
-        _filter: Arc<<Chain as Blockchain>::TriggerFilter>,
-    ) -> Result<Box<dyn BlockStream<Chain>>> {
-        unimplemented!()
-    }
-
     async fn build_subgraph_block_stream(
         &self,
         chain: &Chain,
@@ -1159,16 +1145,6 @@ impl BlockStreamMapper<Chain> for FirehoseMapper {
             .await
             .map_err(BlockStreamError::from)
     }
-
-    async fn handle_substreams_block(
-        &self,
-        _logger: &Logger,
-        _clock: Clock,
-        _cursor: FirehoseCursor,
-        _block: Vec<u8>,
-    ) -> Result<BlockStreamEvent<Chain>, BlockStreamError> {
-        unimplemented!()
-    }
 }
 
 #[async_trait]

chain/near/Cargo.toml

@@ -19,5 +19,4 @@ graph-runtime-derive = { path = "../../runtime/derive" }
 
 [dev-dependencies]
 diesel = { workspace = true }
-trigger-filters.path = "../../substreams/trigger-filters"
-tokio = { workspace = true }
+tokio = { workspace = true }

chain/near/build.rs

@@ -3,9 +3,6 @@ fn main() {
     tonic_build::configure()
         .out_dir("src/protobuf")
         .extern_path(".sf.near.codec.v1", "crate::codec::pbcodec")
-        .compile_protos(
-            &["proto/near.proto", "proto/substreams-triggers.proto"],
-            &["proto"],
-        )
+        .compile_protos(&["proto/near.proto"], &["proto"])
         .expect("Failed to compile Firehose NEAR proto(s)");
 }