Sload pre cache (#322)

* chore: add rwlock cache

* lint: type "simplification"

* chore: create a slot cache at initialization

* chore: lint

* fix: add missing file back into sqlx

src/eth/storage/postgres/queries/select_slot_cache.sql

@@ -0,0 +1,7 @@
+SELECT
+    idx as "index: _",
+    value as "value: _",
+    account_address as "address: _",
+    creation_block as "block: _"
+FROM account_slots
+WHERE creation_block >= $1;

src/infra/postgres.rs

@@ -6,6 +6,7 @@ use std::time::Duration;
 
 use anyhow::anyhow;
 use sqlx::postgres::PgPoolOptions;
+use sqlx::types::BigDecimal;
 use sqlx::PgPool;
 use tokio::sync::RwLock;
 
@@ -42,13 +43,26 @@ impl Postgres {
             })?;
 
         let postgres = Self {
-            connection_pool,
-            sload_cache: Arc::new(RwLock::new(HashMap::new())),
+            connection_pool: connection_pool.clone(),
+            sload_cache: Arc::new(RwLock::new(Self::new_sload_cache(connection_pool).await?)),
         };
 
         Ok(postgres)
     }
 
+    async fn new_sload_cache(connection_pool: PgPool) -> anyhow::Result<HashMap<(Address, SlotIndex), (SlotValue, BlockNumber)>> {
+        let raw_sload = sqlx::query_file_as!(SlotCache, "src/eth/storage/postgres/queries/select_slot_cache.sql", BigDecimal::from(0))
+            .fetch_optional(&connection_pool)
+            .await?;
+        let mut sload_cache = HashMap::new();
+
+        raw_sload.into_iter().for_each(|s| {
+            sload_cache.insert((s.address, s.index), (s.value, s.block));
+        });
+
+        Ok(sload_cache)
+    }
+
     /// Starts a new database transaction.
     pub async fn start_transaction(&self) -> anyhow::Result<sqlx::Transaction<'_, sqlx::Postgres>> {
         tracing::debug!("starting postgres transaction");
@@ -67,3 +81,10 @@ impl Postgres {
         }
     }
 }
+
+struct SlotCache {
+    pub index: SlotIndex,
+    pub value: SlotValue,
+    pub address: Address,
+    pub block: BlockNumber,
+}