feat: changes

Cargo.toml

@@ -6,7 +6,7 @@ version = "0.1.0"
 edition = "2021"
 
 [dependencies]
-alloy = { version = "0.1.3", features = ["full", "node-bindings", "sol-types", "contract", "transports", "transport-http"] }
+alloy = { version = "0.1.3", features = ["rlp", "node-bindings", "sol-types", "contract", "transports", "transport-http"] }
 tokio = { version = "1.36.0", features = ["full"] }
 revm = "10.0.0"
 octane = { git = "https://github.com/arena-rs/octane" }
@@ -23,6 +23,7 @@ serde_json = "1.0.120"
 futures = "0.3.30"
 rand = "0.8.5"
 rand_distr = "0.4.3"
+bytes = "1.6.1"
 
 [lib]
 doctest = false

src/arbitrageur.rs

@@ -2,14 +2,8 @@ use super::*;
 
 #[derive(Debug, Deserialize, Serialize, Clone)]
 struct Arbitrageur {
-    #[serde(skip)]
-    pub messager: Option<Messager>,
-
-    #[serde(skip)]
-    pub client: Option<Arc<AnvilProvider>>,
-
+    pub base: Base,
     pub deployment: Option<Address>,
-
     pub pool: Option<PoolParams>,
 }
 
@@ -20,8 +14,8 @@ impl Behavior<Message> for Arbitrageur {
         client: Arc<AnvilProvider>,
         messager: Messager,
     ) -> Result<Option<EventStream<Message>>> {
-        self.client = Some(client.clone());
-        self.messager = Some(messager.clone());
+        self.base.client = Some(client.clone());
+        self.base.messager = Some(messager.clone());
 
         let mut stream = messager.clone().stream().unwrap();
 
@@ -41,7 +35,6 @@ impl Behavior<Message> for Arbitrageur {
 
         Ok(Some(messager.clone().stream().unwrap()))
     }
-
     async fn process(&mut self, event: Message) -> Result<ControlFlow> {
         let _query: PriceUpdate = match serde_json::from_str(&event.data) {
             Ok(query) => query,
@@ -51,6 +44,10 @@ impl Behavior<Message> for Arbitrageur {
             }
         };
 
+        let manager = PoolManager::new(self.deployment.unwrap(), self.base.client.clone().unwrap());
+
+        let id = keccak256(&self.pool.clone().unwrap().key.encode());
+
         return Ok(ControlFlow::Continue);
     }
 }

src/lib.rs

@@ -1,7 +1,12 @@
 use std::{fmt::Debug, sync::Arc};
 
-use alloy::primitives::{Address, Bytes, Uint, U256};
+use alloy::{
+    primitives::{keccak256, Address, Bytes, Uint, B256, U256},
+    rlp::Encodable,
+    sol_types::SolCall,
+};
 use anyhow::Result;
+use bytes::BufMut;
 use futures::stream::StreamExt;
 use octane::{
     machine::{Behavior, ControlFlow, EventStream},
@@ -25,6 +30,7 @@ use crate::{
     types::process::{OrnsteinUhlenbeck, StochasticProcess},
     LiquidExchange::LiquidExchangeInstance,
 };
+
 pub mod arbitrageur;
 pub mod bindings;
 pub mod deployer;
@@ -33,6 +39,22 @@ pub mod pool_admin;
 pub mod price_changer;
 pub mod types;
 
+impl PoolKey {
+    fn encode(self) -> Vec<u8> {
+        let mut encoded = Vec::new();
+
+        &self.currency0.encode(&mut encoded);
+        &self.currency1.encode(&mut encoded);
+
+        &U256::from(self.fee).encode(&mut encoded);
+        &U256::from(self.tickSpacing as u32).encode(&mut encoded);
+
+        &self.hooks.encode(&mut encoded);
+
+        encoded
+    }
+}
+
 #[derive(Debug, Default, Deserialize, Serialize, Clone)]
 pub struct Base {
     #[serde(skip)]

src/pool_admin.rs

@@ -6,14 +6,13 @@ use super::*;
 #[derive(Debug, Serialize, Deserialize)]
 pub struct PoolAdmin {
     pub base: Base,
-
     pub deployment: Option<Address>,
 }
 
 #[derive(Debug, Deserialize, Serialize, Clone)]
 pub struct PoolParams {
     #[serde(skip)]
-    key: PoolKey,
+    pub key: PoolKey,
 
     sqrt_price_x96: U256,
     hook_data: Bytes,

src/price_changer.rs

@@ -13,9 +13,7 @@ where
     T: StochasticProcess,
 {
     pub base: Base,
-
     pub process: T,
-
     pub lex: Option<Address>,
 }