build(deps): bump tonic-build from 0.8.4 to 0.11.0

Cargo.toml

@@ -29,17 +29,17 @@ diesel-derive-enum = { version = "2.1.0", features = ["postgres"] }
 diesel_derives = "2.1.4"
 diesel-dynamic-schema = "0.2.1"
 diesel_migrations = "2.1.0"
-prost = "0.11.9"
-prost-types = "0.11.9"
+prost = "0.12.6"
+prost-types = "0.12.6"
 serde = { version = "1.0.126", features = ["rc"] }
 serde_derive = "1.0.125"
 serde_json = { version = "1.0", features = ["arbitrary_precision"] }
 serde_regex = "1.1.0"
 serde_yaml = "0.9.21"
 sqlparser = "0.46.0"
 syn = { version = "2.0.65", features = ["full"] }
-tonic = { version = "0.8.3", features = ["tls-roots", "gzip"] }
-tonic-build = { version = "0.8.4", features = ["prost"] }
+tonic = { version = "0.11.0", features = ["tls-roots", "gzip"] }
+tonic-build = { version = "0.11.0", features = ["prost"] }
 wasmtime = "15.0.1"
 wasmparser = "0.118.1"
 clap = { version = "4.5.4", features = ["derive", "env"] }

chain/arweave/src/chain.rs

@@ -311,7 +311,7 @@ impl FirehoseMapperTrait<Chain> for FirehoseMapper {
         logger: &Logger,
         response: &firehose::Response,
     ) -> Result<BlockStreamEvent<Chain>, FirehoseError> {
-        let step = ForkStep::from_i32(response.step).unwrap_or_else(|| {
+        let step = ForkStep::try_from(response.step).unwrap_or_else(|_| {
             panic!(
                 "unknown step i32 value {}, maybe you forgot update & re-regenerate the protobuf definitions?",
                 response.step

chain/arweave/src/protobuf/sf.arweave.r#type.v1.rs

@@ -1,3 +1,4 @@
+// This file is @generated by prost-build.
 #[allow(clippy::derive_partial_eq_without_eq)]
 #[derive(Clone, PartialEq, ::prost::Message)]
 pub struct BigInt {

chain/cosmos/src/chain.rs

@@ -3,6 +3,7 @@ use graph::blockchain::{BlockIngestor, NoopDecoderHook};
 use graph::env::EnvVars;
 use graph::prelude::MetricsRegistry;
 use graph::substreams::Clock;
+use std::convert::TryFrom;
 use std::sync::Arc;
 
 use graph::blockchain::block_stream::{BlockStreamError, BlockStreamMapper, FirehoseCursor};
@@ -381,7 +382,7 @@ impl FirehoseMapperTrait<Chain> for FirehoseMapper {
         logger: &Logger,
         response: &firehose::Response,
     ) -> Result<BlockStreamEvent<Chain>, FirehoseError> {
-        let step = ForkStep::from_i32(response.step).unwrap_or_else(|| {
+        let step = ForkStep::try_from(response.step).unwrap_or_else(|_| {
             panic!(
                 "unknown step i32 value {}, maybe you forgot update & re-regenerate the protobuf definitions?",
                 response.step

chain/cosmos/src/protobuf/sf.cosmos.r#type.v1.rs

@@ -1,3 +1,4 @@
+// This file is @generated by prost-build.
 #[graph_runtime_derive::generate_asc_type(
     __required__{header:Header,
     result_begin_block:ResponseBeginBlock,

chain/ethereum/src/chain.rs

@@ -852,7 +852,7 @@ impl FirehoseMapperTrait<Chain> for FirehoseMapper {
         logger: &Logger,
         response: &firehose::Response,
     ) -> Result<BlockStreamEvent<Chain>, FirehoseError> {
-        let step = ForkStep::from_i32(response.step).unwrap_or_else(|| {
+        let step = ForkStep::try_from(response.step).unwrap_or_else(|_| {
             panic!(
                 "unknown step i32 value {}, maybe you forgot update & re-regenerate the protobuf definitions?",
                 response.step

chain/ethereum/src/codec.rs

@@ -92,8 +92,8 @@ impl TryInto<web3::types::Call> for Call {
                 .map_or_else(|| U256::from(0), |v| v.into()),
             gas: U256::from(self.gas_limit),
             input: Bytes::from(self.input.clone()),
-            call_type: CallType::from_i32(self.call_type)
-                .ok_or_else(|| format_err!("invalid call type: {}", self.call_type,))?
+            call_type: CallType::try_from(self.call_type)
+                .map_err(|_| graph::anyhow::anyhow!("invalid call type: {}", self.call_type))?
                 .into(),
         })
     }
@@ -300,13 +300,14 @@ impl TryInto<EthereumBlockWithCalls> for &Block {
                                     match t.calls.len() {
                                         0 => None,
                                         _ => {
-                                            match CallType::from_i32(t.calls[0].call_type)
-                                                .ok_or_else(|| {
-                                                    format_err!(
+                                            match CallType::try_from(t.calls[0].call_type).map_err(
+                                                |_| {
+                                                    graph::anyhow::anyhow!(
                                                         "invalid call type: {}",
                                                         t.calls[0].call_type,
                                                     )
-                                                })? {
+                                                },
+                                            )? {
                                                 CallType::Create => {
                                                     Some(t.calls[0].address.try_decode_proto(
                                                         "transaction contract address",
@@ -322,9 +323,9 @@ impl TryInto<EthereumBlockWithCalls> for &Block {
                                     .iter()
                                     .map(|l| LogAt::new(l, self, t).try_into())
                                     .collect::<Result<Vec<_>, Error>>()?,
-                                status: TransactionTraceStatus::from_i32(t.status)
-                                    .ok_or_else(|| {
-                                        format_err!(
+                                status: TransactionTraceStatus::try_from(t.status)
+                                    .map_err(|_| {
+                                        graph::anyhow::anyhow!(
                                             "invalid transaction trace status: {}",
                                             t.status
                                         )
@@ -533,7 +534,7 @@ fn get_to_address(trace: &TransactionTrace) -> Result<Option<H160>, Error> {
     // Try to detect contract creation transactions, which have no 'to' address
     let is_contract_creation = trace.to.len() == 0
         || trace.calls.get(0).map_or(false, |call| {
-            CallType::from_i32(call.call_type)
+            CallType::try_from(call.call_type)
                 .map_or(false, |call_type| call_type == CallType::Create)
         });
 

chain/ethereum/src/protobuf/sf.ethereum.r#type.v2.rs

@@ -1,3 +1,4 @@
+// This file is @generated by prost-build.
 #[allow(clippy::derive_partial_eq_without_eq)]
 #[derive(Clone, PartialEq, ::prost::Message)]
 pub struct Block {
@@ -369,8 +370,8 @@ pub struct Log {
     /// that emitted the log has been reverted by the chain.
     ///
     /// Currently, there is two locations where a Log can be obtained:
-    /// - block.transaction_traces\[].receipt.logs[\]
-    /// - block.transaction_traces\[].calls[].logs[\]
+    /// - block.transaction_traces\[\].receipt.logs\[\]
+    /// - block.transaction_traces\[\].calls\[\].logs\[\]
     ///
     /// In the `receipt` case, the logs will be populated only when the call
     /// that emitted them has not been reverted by the chain and when in this

chain/near/src/chain.rs

@@ -488,7 +488,7 @@ impl FirehoseMapperTrait<Chain> for FirehoseMapper {
         logger: &Logger,
         response: &firehose::Response,
     ) -> Result<BlockStreamEvent<Chain>, FirehoseError> {
-        let step = ForkStep::from_i32(response.step).unwrap_or_else(|| {
+        let step = ForkStep::try_from(response.step).unwrap_or_else(|_| {
             panic!(
                 "unknown step i32 value {}, maybe you forgot update & re-regenerate the protobuf definitions?",
                 response.step

chain/near/src/protobuf/receipts.v1.rs

@@ -1,3 +1,4 @@
+// This file is @generated by prost-build.
 #[allow(clippy::derive_partial_eq_without_eq)]
 #[derive(Clone, PartialEq, ::prost::Message)]
 pub struct BlockAndReceipts {

chain/starknet/src/chain.rs

@@ -251,7 +251,7 @@ impl FirehoseMapperTrait<Chain> for FirehoseMapper {
         logger: &Logger,
         response: &firehose::Response,
     ) -> Result<BlockStreamEvent<Chain>, FirehoseError> {
-        let step = ForkStep::from_i32(response.step).unwrap_or_else(|| {
+        let step = ForkStep::try_from(response.step).unwrap_or_else(|_| {
             panic!(
                 "unknown step i32 value {}, maybe you forgot update & re-regenerate the protobuf definitions?",
                 response.step

chain/starknet/src/protobuf/zklend.starknet.r#type.v1.rs

@@ -1,3 +1,4 @@
+// This file is @generated by prost-build.
 #[allow(clippy::derive_partial_eq_without_eq)]
 #[derive(Clone, PartialEq, ::prost::Message)]
 pub struct Block {

chain/starknet/src/runtime/abi.rs

@@ -35,7 +35,7 @@ impl ToAscObj<AscTransaction> for codec::Transaction {
         Ok(AscTransaction {
             r#type: asc_new(
                 heap,
-                &codec::TransactionType::from_i32(self.r#type)
+                &codec::TransactionType::try_from(self.r#type)
                     .expect("invalid TransactionType value"),
                 gas,
             )?,

chain/substreams/src/protobuf/substreams.entity.v1.rs

@@ -1,3 +1,4 @@
+// This file is @generated by prost-build.
 #[allow(clippy::derive_partial_eq_without_eq)]
 #[derive(Clone, PartialEq, ::prost::Message)]
 pub struct EntityChanges {

graph/src/blockchain/firehose_block_ingestor.rs

@@ -104,7 +104,7 @@ where
         while let Some(message) = stream.next().await {
             match message {
                 Ok(v) => {
-                    let step = ForkStep::from_i32(v.step)
+                    let step = ForkStep::try_from(v.step)
                         .expect("Fork step should always match to known value");
 
                     let result = match step {

graph/src/firehose/sf.cosmos.transform.v1.rs

@@ -1,3 +1,4 @@
+// This file is @generated by prost-build.
 #[allow(clippy::derive_partial_eq_without_eq)]
 #[derive(Clone, PartialEq, ::prost::Message)]
 pub struct EventTypeFilter {

graph/src/firehose/sf.ethereum.transform.v1.rs

@@ -1,3 +1,4 @@
+// This file is @generated by prost-build.
 /// CombinedFilter is a combination of "LogFilters" and "CallToFilters"
 ///
 /// It transforms the requested stream in two ways: