chore: finish actor renaming

Author: lbkolev

src/actors/fanatic.rs

@@ -23,7 +23,7 @@ use crate::{
             fanatic::{DoSmthWithLiquidationCall, UpdateReservePrice, UpdateReserveUser},
             follower::{SendFanaticAddr, StartListeningForEvents, StartListeningForOraclePrices},
         },
-        Bum,
+        Follower,
     },
     configs::FanaticConfig,
     consts::RAY,
@@ -35,7 +35,7 @@ pub struct Fanatic<P: Provider + Unpin + Clone + 'static> {
     provider: P,
 
     db_addr: Addr<Database>,
-    bum_addr: Addr<Bum<P>>,
+    follower_addr: Addr<Follower<P>>,
     executor_addr: Option<Addr<Executor<P>>>,
 
     pool_contract: contracts::aave_v3::PoolContract::PoolContractInstance<(), P>,
@@ -55,12 +55,15 @@ impl<P: Provider + Unpin + Clone + 'static> Actor for Fanatic<P> {
 
     fn started(&mut self, ctx: &mut Self::Context) {
         let addr = ctx.address();
-        let bum_addr = self.bum_addr.clone();
+        let follower_addr = self.follower_addr.clone();
 
         let fut = async move {
-            bum_addr.send(SendFanaticAddr(addr)).await.unwrap();
-            bum_addr.send(StartListeningForOraclePrices).await.unwrap();
-            bum_addr.send(StartListeningForEvents).await.unwrap();
+            follower_addr.send(SendFanaticAddr(addr)).await.unwrap();
+            follower_addr
+                .send(StartListeningForOraclePrices)
+                .await
+                .unwrap();
+            follower_addr.send(StartListeningForEvents).await.unwrap();
         };
 
         ctx.spawn(fut.into_actor(self));
@@ -186,7 +189,7 @@ impl<P: Provider + Unpin + Clone + 'static> Fanatic<P> {
         Ok(Fanatic {
             provider: config.provider,
             db_addr: config.db_addr,
-            bum_addr: config.bum_addr,
+            follower_addr: config.follower_addr,
             executor_addr: None,
             pool_contract,
             datap_contract,

src/actors/follower.rs

@@ -14,12 +14,12 @@ use crate::{
         },
         Database, Fanatic,
     },
-    configs::BumConfig,
+    configs::FollowerConfig,
     consts::RAY,
 };
 
 #[derive(Debug, Clone)]
-pub struct Bum<P: Provider + Unpin + Clone + 'static> {
+pub struct Follower<P: Provider + Unpin + Clone + 'static> {
     provider: P,
     filter: Filter,
 
@@ -33,23 +33,23 @@ pub struct Bum<P: Provider + Unpin + Clone + 'static> {
     target: String,
 }
 
-impl<P: Provider + Unpin + Clone + 'static> Actor for Bum<P> {
+impl<P: Provider + Unpin + Clone + 'static> Actor for Follower<P> {
     type Context = Context<Self>;
 
     fn started(&mut self, _: &mut Self::Context) {
-        info!("[started] Bum");
+        info!("[started] Follower");
     }
 }
 
-impl<P: Provider + Unpin + Clone + 'static> Handler<SendFanaticAddr<P>> for Bum<P> {
+impl<P: Provider + Unpin + Clone + 'static> Handler<SendFanaticAddr<P>> for Follower<P> {
     type Result = ();
 
     fn handle(&mut self, msg: SendFanaticAddr<P>, _: &mut Context<Self>) -> Self::Result {
         self.fanatic_addr = Some(msg.0);
     }
 }
 
-impl<P: Provider + Unpin + Clone + 'static> Handler<StartListeningForOraclePrices> for Bum<P> {
+impl<P: Provider + Unpin + Clone + 'static> Handler<StartListeningForOraclePrices> for Follower<P> {
     type Result = ();
 
     fn handle(
@@ -61,16 +61,16 @@ impl<P: Provider + Unpin + Clone + 'static> Handler<StartListeningForOraclePrice
     }
 }
 
-impl<P: Provider + Unpin + Clone + 'static> Handler<StartListeningForEvents> for Bum<P> {
+impl<P: Provider + Unpin + Clone + 'static> Handler<StartListeningForEvents> for Follower<P> {
     type Result = ();
 
     fn handle(&mut self, _: StartListeningForEvents, ctx: &mut Context<Self>) -> Self::Result {
         self.listen_events(ctx);
     }
 }
 
-impl<P: Provider + Unpin + Clone + 'static> Bum<P> {
-    pub async fn new(config: BumConfig<P>) -> eyre::Result<Self> {
+impl<P: Provider + Unpin + Clone + 'static> Follower<P> {
+    pub async fn new(config: FollowerConfig<P>) -> eyre::Result<Self> {
         let contracts = config
             .db_addr
             .send(database::GetProtocolContracts(config.target.clone()))

src/actors/mod.rs

@@ -8,4 +8,4 @@ pub mod follower;
 pub use database::Database;
 pub use executor::Executor;
 pub use fanatic::Fanatic;
-pub use follower::Bum;
+pub use follower::Follower;

src/configs.rs

@@ -4,7 +4,7 @@ use actix::Addr;
 use alloy::{primitives::Address, providers::Provider};
 use sqlx::PgPool;
 
-use crate::actors::{Bum, Database, Fanatic};
+use crate::actors::{Database, Fanatic, Follower};
 
 #[derive(Debug, Clone)]
 pub struct Config {
@@ -17,7 +17,7 @@ pub struct Config {
 }
 
 #[derive(Debug, Clone)]
-pub struct BumConfig<P: Provider + Unpin + Clone + 'static> {
+pub struct FollowerConfig<P: Provider + Unpin + Clone + 'static> {
     pub provider: P,
     pub db_addr: Addr<Database>,
     pub target: String,
@@ -36,7 +36,7 @@ pub struct ExecutorConfig<P: Provider + Unpin + Clone + 'static> {
 pub struct FanaticConfig<P: Provider + Unpin + Clone + 'static> {
     pub provider: P,
     pub db_addr: Addr<Database>,
-    pub bum_addr: Addr<Bum<P>>,
+    pub follower_addr: Addr<Follower<P>>,
     pub target: String,
 }
 

src/run.rs

@@ -10,8 +10,8 @@ use sqlx::postgres::PgPoolOptions;
 use tokio::signal::unix::{signal, SignalKind};
 
 use crate::{
-    actors::{Bum, Database, Executor, Fanatic},
-    configs::{BumConfig, Config, DatabaseConfig, ExecutorConfig, FanaticConfig},
+    actors::{Database, Executor, Fanatic, Follower},
+    configs::{Config, DatabaseConfig, ExecutorConfig, FanaticConfig, FollowerConfig},
 };
 
 #[derive(Message)]
@@ -50,21 +50,21 @@ pub async fn run(config: Config) {
     .await
     .start();
 
-    /* Spin up the bum actor */
-    let bum_addr = Bum::new(BumConfig {
+    /* Spin up the follower actor */
+    let follower_addr = Follower::new(FollowerConfig {
         provider: provider_with_wallet.clone(),
         db_addr: db_addr.clone(),
         target: config.target.clone(),
     })
     .await
-    .expect("Unable to initialise Bum actor")
+    .expect("Unable to initialise follower actor")
     .start();
 
     /* Spin up the fanatic actor */
     let fanatic_addr = Fanatic::new(FanaticConfig {
         provider: provider_with_wallet.clone(),
         db_addr: db_addr.clone(),
-        bum_addr: bum_addr.clone(),
+        follower_addr: follower_addr.clone(),
         target: config.target.clone(),
     })
     .await