tornadocontrib/web3-proxy
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add cost for txpool_content and some unimplemented methods

Browse Source
This commit is contained in:
Bryan Stitt 2023-09-12 21:44:23 -07:00
parent eda5e123c8
commit c7c2497238
1 changed files with 28 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
web3_proxy/src/compute_units.rs
View File

@ -7,7 +7,7 @@
//! TODO: script that queries influx and calculates observed relative costs //! TODO: script that queries influx and calculates observed relative costs
use migration::sea_orm::prelude::Decimal; use migration::sea_orm::prelude::Decimal;
use std::str::FromStr; use std::{ops::Add, str::FromStr};
use tracing::{instrument, trace, warn}; use tracing::{instrument, trace, warn};
pub fn default_usd_per_cu(chain_id: u64) -> Decimal { pub fn default_usd_per_cu(chain_id: u64) -> Decimal {
@ -22,6 +22,17 @@ pub fn default_usd_per_cu(chain_id: u64) -> Decimal {
#[derive(Debug)] #[derive(Debug)]
pub struct ComputeUnit(Decimal); pub struct ComputeUnit(Decimal);
impl<T> Add<T> for ComputeUnit
where
T: Into<Decimal>,
{
type Output = Self;
fn add(self, rhs: T) -> Self::Output {
Self(self.0 + rhs.into())
}
}
impl ComputeUnit { impl ComputeUnit {
/// costs can vary widely depending on method and chain /// costs can vary widely depending on method and chain
#[instrument(level = "trace")] #[instrument(level = "trace")]
@ -92,9 +103,18 @@ impl ComputeUnit {
(_, "eth_getUserOperationByHash") => 17, (_, "eth_getUserOperationByHash") => 17,
(_, "eth_getUserOperationReceipt") => 15, (_, "eth_getUserOperationReceipt") => 15,
(_, "eth_maxPriorityFeePerGas") => 10, (_, "eth_maxPriorityFeePerGas") => 10,
(_, "eth_newBlockFilter") => 20, (_, "eth_newBlockFilter") => {
(_, "eth_newFilter") => 20, // TODO: 20
(_, "eth_newPendingTransactionFilter") => 20, return Self::unimplemented();
}
(_, "eth_newFilter") => {
// TODO: 20
return Self::unimplemented();
}
(_, "eth_newPendingTransactionFilter") => {
// TODO: 20
return Self::unimplemented();
}
(_, "eth_pollSubscriptions") => { (_, "eth_pollSubscriptions") => {
return Self::unimplemented(); return Self::unimplemented();
} }
@ -118,6 +138,9 @@ impl ComputeUnit {
(_, "trace_replayBlockTransactions") => 2983, (_, "trace_replayBlockTransactions") => 2983,
(_, "trace_replayTransaction") => 2983, (_, "trace_replayTransaction") => 2983,
(_, "trace_transaction") => 26, (_, "trace_transaction") => 26,
(_, "txpool_content") => {
return Self::subscription_response(response_bytes) + 1000;
}
(_, "invalid_method") => 100, (_, "invalid_method") => 100,
(_, "web3_clientVersion") => 15, (_, "web3_clientVersion") => 15,
(_, "web3_bundlerVersion") => 15, (_, "web3_bundlerVersion") => 15,
@ -152,6 +175,7 @@ impl ComputeUnit {
/// notifications and subscription responses cost per-byte /// notifications and subscription responses cost per-byte
#[instrument(level = "trace")] #[instrument(level = "trace")]
pub fn subscription_response<D: Into<Decimal> + std::fmt::Debug>(num_bytes: D) -> Self { pub fn subscription_response<D: Into<Decimal> + std::fmt::Debug>(num_bytes: D) -> Self {
// TODO: get multiplier from config
let cu = num_bytes.into() * Decimal::new(4, 2); let cu = num_bytes.into() * Decimal::new(4, 2);
Self(cu) Self(cu)