graph, chain, runtime: Remove all references to rust-web3 crate

Author: incrypto32

Cargo.lock

@@ -121,7 +121,7 @@ fn is_parity_revert(data: &str) -> bool {
         || data == XDAI_REVERT
 }
 
-/// Checks if the given `web3::Error` corresponds to a Parity / Nethermind style EVM
+/// Checks if the given data corresponds to a Parity / Nethermind style EVM
 /// revert and, if so, tries to extract a human-readable revert reason. Returns `Some`
 /// with the reason when the error is identified as a revert, otherwise `None`.
 fn parity_revert_reason(data: &str) -> String {

chain/ethereum/src/call_helper.rs

@@ -501,8 +501,6 @@ impl<'a> EthereumTransactionData<'a> {
     }
 
     pub fn from(&self) -> &Address {
-        // unwrap: this is always `Some` for txns that have been mined
-        //         (see https://github.com/tomusdrw/rust-web3/pull/407)
         self.tx.inner.signer_ref()
     }
 

chain/ethereum/src/trigger.rs

@@ -94,12 +94,6 @@ parking_lot = "0.12.3"
 itertools = "0.14.0"
 defer = "0.2"
 
-# Our fork contains patches to make some fields optional for Celo and Fantom compatibility.
-# Without the "arbitrary_precision" feature, we get the error `data did not match any variant of untagged enum Response`.
-web3 = { git = "https://github.com/graphprotocol/rust-web3", branch = "graph-patches-onto-0.18", features = [
-    "arbitrary_precision",
-    "test",
-] }
 serde_plain = "1.0.2"
 csv = "1.3.0"
 object_store = { version = "0.12.0", features = ["gcp"] }

graph/Cargo.toml

@@ -244,12 +244,6 @@ pub enum IngestorError {
     Unknown(#[from] Error),
 }
 
-impl From<web3::Error> for IngestorError {
-    fn from(e: web3::Error) -> Self {
-        IngestorError::Unknown(anyhow::anyhow!(e))
-    }
-}
-
 /// The `TriggerFilterWrapper` is a higher-level wrapper around the chain-specific `TriggerFilter`,
 /// enabling subgraph-based trigger filtering for subgraph datasources. This abstraction is necessary
 /// because subgraph filtering operates at a higher level than chain-based filtering. By using this wrapper,

graph/src/blockchain/mod.rs

@@ -118,5 +118,4 @@ cheap_clone_is_copy!(
     &'static str,
     std::time::Duration
 );
-cheap_clone_is_copy!(web3::types::Address);
 cheap_clone_is_copy!(alloy::primitives::Address);

graph/src/cheap_clone.rs

@@ -6,7 +6,6 @@
 use alloy::primitives::B256;
 use alloy::rpc::types::TransactionReceipt;
 
-/// Like web3::types::Receipt, but with fewer fields.
 #[derive(Debug, PartialEq, Eq)]
 pub struct LightTransactionReceipt {
     pub transaction_hash: B256,

graph/src/components/transaction_receipt.rs

@@ -3,7 +3,6 @@ use diesel::pg::PgValue;
 use diesel::serialize::ToSql;
 use hex;
 use serde::{self, Deserialize, Serialize};
-use web3::types::*;
 
 use std::fmt::{self, Display, Formatter};
 use std::ops::Deref;
@@ -58,18 +57,12 @@ impl<'a> From<&'a [u8]> for Bytes {
     }
 }
 
-impl From<Address> for Bytes {
-    fn from(address: Address) -> Bytes {
+impl From<alloy::primitives::Address> for Bytes {
+    fn from(address: alloy::primitives::Address) -> Bytes {
         Bytes::from(address.as_ref())
     }
 }
 
-impl From<web3::types::Bytes> for Bytes {
-    fn from(bytes: web3::types::Bytes) -> Bytes {
-        Bytes::from(bytes.0.as_slice())
-    }
-}
-
 impl From<BlockHash> for Bytes {
     fn from(hash: BlockHash) -> Self {
         Bytes(hash.0)

graph/src/data/store/scalar/bytes.rs

@@ -109,7 +109,6 @@ pub mod prelude {
     pub use tokio;
     pub use toml;
     pub use tonic;
-    pub use web3;
 
     pub type DynTryFuture<'a, Ok = (), Err = Error> =
         Pin<Box<dyn futures03::Future<Output = Result<Ok, Err>> + Send + 'a>>;

graph/src/lib.rs

@@ -4,11 +4,11 @@ use graph::data::store::scalar::Timestamp;
 use graph::data::value::Word;
 use graph::prelude::{BigDecimal, BigInt};
 use graph::runtime::gas::GasCounter;
+use graph::runtime::AscHeap;
 use graph::runtime::{
     asc_get, asc_new, AscIndexId, AscPtr, AscType, AscValue, HostExportError, ToAscObj,
 };
 use graph::{data::store, runtime::DeterministicHostError};
-use graph::{prelude::web3::types as web3, runtime::AscHeap};
 use graph::{
     prelude::{
         alloy::{self, primitives::U256},
@@ -20,38 +20,6 @@ use graph_runtime_derive::AscType;
 
 use crate::asc_abi::class::*;
 
-impl ToAscObj<Uint8Array> for web3::H160 {
-    fn to_asc_obj<H: AscHeap + ?Sized>(
-        &self,
-        heap: &mut H,
-        gas: &GasCounter,
-    ) -> Result<Uint8Array, HostExportError> {
-        self.0.to_asc_obj(heap, gas)
-    }
-}
-
-impl ToAscObj<Uint8Array> for web3::Bytes {
-    fn to_asc_obj<H: AscHeap + ?Sized>(
-        &self,
-        heap: &mut H,
-        gas: &GasCounter,
-    ) -> Result<Uint8Array, HostExportError> {
-        self.0.to_asc_obj(heap, gas)
-    }
-}
-
-impl FromAscObj<Uint8Array> for web3::H160 {
-    fn from_asc_obj<H: AscHeap + ?Sized>(
-        typed_array: Uint8Array,
-        heap: &H,
-        gas: &GasCounter,
-        depth: usize,
-    ) -> Result<Self, DeterministicHostError> {
-        let data = <[u8; 20]>::from_asc_obj(typed_array, heap, gas, depth)?;
-        Ok(Self(data))
-    }
-}
-
 impl FromAscObj<Uint8Array> for alloy::primitives::Address {
     fn from_asc_obj<H: AscHeap + ?Sized>(
         typed_array: Uint8Array,
@@ -96,40 +64,6 @@ impl FromAscObj<Uint8Array> for alloy::primitives::B256 {
     }
 }
 
-// impl FromAscObj<Uint8Array> for web3::H256 {
-//     fn from_asc_obj<H: AscHeap + ?Sized>(
-//         typed_array: Uint8Array,
-//         heap: &H,
-//         gas: &GasCounter,
-//         depth: usize,
-//     ) -> Result<Self, DeterministicHostError> {
-//         let data = <[u8; 32]>::from_asc_obj(typed_array, heap, gas, depth)?;
-//         Ok(Self(data))
-//     }
-// }
-
-// impl ToAscObj<Uint8Array> for web3::H256 {
-//     fn to_asc_obj<H: AscHeap + ?Sized>(
-//         &self,
-//         heap: &mut H,
-//         gas: &GasCounter,
-//     ) -> Result<Uint8Array, HostExportError> {
-//         self.0.to_asc_obj(heap, gas)
-//     }
-// }
-
-impl ToAscObj<AscBigInt> for web3::U128 {
-    fn to_asc_obj<H: AscHeap + ?Sized>(
-        &self,
-        heap: &mut H,
-        gas: &GasCounter,
-    ) -> Result<AscBigInt, HostExportError> {
-        let mut bytes: [u8; 16] = [0; 16];
-        self.to_little_endian(&mut bytes);
-        bytes.to_asc_obj(heap, gas)
-    }
-}
-
 impl ToAscObj<AscBigInt> for BigInt {
     fn to_asc_obj<H: AscHeap + ?Sized>(
         &self,