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

* build(deps): bump tonic-build from 0.8.4 to 0.11.0 Bumps [tonic-build](https://github.com/hyperium/tonic) from 0.8.4 to 0.11.0. - [Changelog](https://github.com/hyperium/tonic/blob/master/CHANGELOG.md) - [Commits](hyperium/tonic@v0.8.4...v0.11.0) --- updated-dependencies: - dependency-name: tonic-build dependency-type: direct:production update-type: version-update:semver-minor ... Signed-off-by: dependabot[bot] <support@github.com> * update deprecated methods --------- Signed-off-by: dependabot[bot] <support@github.com> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> Co-authored-by: Filipe Azevedo <filipe@azevedo.io>
graphprotocol · May 28, 2024 · 5b64936 · 5b64936
1 parent 5c5e4fa
commit 5b64936
Show file tree

Hide file tree

Showing 24 changed files with 456 additions and 174 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/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"] }

diff --git a/chain/arweave/src/chain.rs b/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

diff --git a/chain/arweave/src/protobuf/sf.arweave.r#type.v1.rs b/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 {

diff --git a/chain/cosmos/src/chain.rs b/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

diff --git a/chain/cosmos/src/protobuf/sf.cosmos.r#type.v1.rs b/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,

diff --git a/chain/ethereum/src/chain.rs b/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

diff --git a/chain/ethereum/src/codec.rs b/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)
         });
 

diff --git a/chain/ethereum/src/protobuf/sf.ethereum.r#type.v2.rs b/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

diff --git a/chain/near/src/chain.rs b/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

diff --git a/chain/near/src/protobuf/receipts.v1.rs b/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 {

diff --git a/chain/starknet/src/chain.rs b/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

diff --git a/chain/starknet/src/protobuf/zklend.starknet.r#type.v1.rs b/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 {

diff --git a/chain/starknet/src/runtime/abi.rs b/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,
             )?,

diff --git a/chain/substreams/src/protobuf/substreams.entity.v1.rs b/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 {

diff --git a/graph/src/blockchain/firehose_block_ingestor.rs b/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 {

diff --git a/graph/src/firehose/sf.cosmos.transform.v1.rs b/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 {

diff --git a/graph/src/firehose/sf.ethereum.transform.v1.rs b/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: