use crate::{InnerDb, SimDb, TimeLimited};
use signet_evm::{signet_precompiles, EvmNeedsTx, OrderDetector, SignetLayered};
use signet_types::constants::SignetSystemConstants;
use std::{marker::PhantomData, sync::Arc, time::Instant};
use trevm::{
db::TryCachingDb,
helpers::Ctx,
inspectors::{Layered, TimeLimit},
revm::{
context::{BlockEnv, CfgEnv},
database::{Cache, CacheDB},
inspector::{Inspector, NoOpInspector},
DatabaseRef,
},
Block, Cfg, TrevmBuilder,
};
#[derive(Debug)]
pub struct HostEnv<Db, Insp = NoOpInspector> {
db: InnerDb<Db>,
constants: SignetSystemConstants,
cfg: CfgEnv,
block: BlockEnv,
_pd: PhantomData<fn() -> Insp>,
}
impl<Db, Insp> Clone for HostEnv<Db, Insp> {
fn clone(&self) -> Self {
Self {
db: self.db.clone(),
constants: self.constants.clone(),
cfg: self.cfg.clone(),
block: self.block.clone(),
_pd: PhantomData,
}
}
}
impl<Db, Insp> HostEnv<Db, Insp> {
pub fn new<C, B>(db: Db, constants: SignetSystemConstants, cfg_ref: &C, block_ref: &B) -> Self
where
C: Cfg,
B: Block,
{
let mut cfg = CfgEnv::default();
cfg_ref.fill_cfg_env(&mut cfg);
let mut block = BlockEnv::default();
block_ref.fill_block_env(&mut block);
Self { db: Arc::new(CacheDB::new(db)), constants, cfg, block, _pd: PhantomData }
}
pub const fn db(&self) -> &InnerDb<Db> {
&self.db
}
pub const fn db_mut(&mut self) -> &mut InnerDb<Db> {
&mut self.db
}
pub const fn constants(&self) -> &SignetSystemConstants {
&self.constants
}
pub const fn cfg(&self) -> &CfgEnv {
&self.cfg
}
pub const fn cfg_mut(&mut self) -> &mut CfgEnv {
&mut self.cfg
}
pub const fn block(&self) -> &BlockEnv {
&self.block
}
pub const fn block_mut(&mut self) -> &mut BlockEnv {
&mut self.block
}
}
impl<Db, Insp> HostEnv<Db, Insp>
where
Db: DatabaseRef + Send + Sync,
Insp: Inspector<Ctx<SimDb<Db>>> + Default + Sync,
{
pub fn sim_db(&self) -> crate::SimDb<Db> {
crate::SimDb::new(self.db.clone())
}
pub fn create_evm(
&self,
finish_by: Instant,
) -> EvmNeedsTx<crate::SimDb<Db>, TimeLimited<Insp>> {
let db = self.sim_db();
let inspector = Layered::new(TimeLimit::new(finish_by - Instant::now()), Insp::default());
let inspector =
SignetLayered::new(inspector, OrderDetector::for_host(self.constants.clone()));
TrevmBuilder::new()
.with_db(db)
.with_insp(inspector)
.with_precompiles(signet_precompiles())
.build_trevm()
.fill_cfg(&self.cfg)
.fill_block(&self.block)
}
}
impl<Db, Insp> HostEnv<Db, Insp>
where
Db: DatabaseRef,
Insp: Inspector<Ctx<SimDb<Db>>> + Default + Sync,
{
pub fn accept_cache(
&mut self,
cache: Cache,
) -> Result<(), <InnerDb<Db> as TryCachingDb>::Error> {
self.db_mut().try_extend(cache)
}
pub fn accept_cache_ref(
&mut self,
cache: &Cache,
) -> Result<(), <InnerDb<Db> as TryCachingDb>::Error> {
self.db_mut().try_extend_ref(cache)
}
}