Add deposit notifier to sys-lend

Author: mvines

src/bin/sys-lend.rs

@@ -19,6 +19,7 @@ use {
     },
     sys::{
         app_version,
+        notifier::*,
         priority_fee::{apply_priority_fee, PriorityFee},
         send_transaction_until_expired,
         token::*,
@@ -125,6 +126,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
     };
 
     let mut wallet_manager = None;
+    let notifier = Notifier::default();
 
     match matches.subcommand() {
         ("deposit", Some(matches)) => {
@@ -190,6 +192,15 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
             if !send_transaction_until_expired(&rpc_client, &transaction, last_valid_block_height) {
                 return Err("Deposit failed".into());
             }
+
+            let msg = format!(
+                "Deposited {} from {} into {}",
+                token.format_amount(deposit_amount),
+                address,
+                pool
+            );
+            notifier.send(&msg).await;
+            println!("{msg}");
         }
         _ => unreachable!(),
     }

src/lib.rs

@@ -7,6 +7,7 @@ pub mod exchange;
 pub mod helius_rpc;
 pub mod kraken_exchange;
 pub mod metrics;
+pub mod notifier;
 pub mod priority_fee;
 pub mod token;
 //pub mod tulip;

src/main.rs

@@ -2,7 +2,6 @@ mod amount;
 mod db;
 mod field_as_string;
 mod get_transaction_balance_change;
-mod notifier;
 mod rpc_client_utils;
 mod stake_spreader;
 
@@ -17,7 +16,6 @@ use {
     console::{style, Style},
     db::*,
     itertools::Itertools,
-    notifier::*,
     rpc_client_utils::get_signature_date,
     rust_decimal::prelude::*,
     separator::FixedPlaceSeparatable,
@@ -50,6 +48,7 @@ use {
         app_version,
         exchange::{self, *},
         metrics::{self, dp, MetricsConfig},
+        notifier::*,
         priority_fee::{apply_priority_fee, PriorityFee},
         send_transaction_until_expired,
         token::*,

src/notifier.rs

@@ -5,15 +5,17 @@ pub struct Notifier {
     slack_webhook: Option<String>,
 }
 
-impl Notifier {
-    pub fn default() -> Self {
+impl Default for Notifier {
+    fn default() -> Self {
         let slack_webhook = env::var("SLACK_WEBHOOK").ok();
         Notifier {
             client: Client::new(),
             slack_webhook,
         }
     }
+}
 
+impl Notifier {
     pub async fn send(&self, msg: &str) {
         if let Some(ref slack_webhook) = self.slack_webhook {
             let data = json!({ "text": msg });

src/stake_spreader.rs

@@ -1,5 +1,5 @@
 use {
-    crate::{db::*, notifier::*, rpc_client_utils::get_signature_date},
+    crate::{db::*, rpc_client_utils::get_signature_date},
     log::*,
     solana_client::{rpc_client::RpcClient, rpc_config::RpcBlockConfig, rpc_custom_error},
     solana_sdk::{
@@ -21,7 +21,7 @@ use {
     },
     solana_transaction_status::Reward,
     std::collections::{BTreeMap, HashMap, HashSet},
-    sys::{send_transaction_until_expired, token::*},
+    sys::{notifier::*, send_transaction_until_expired, token::*},
 };
 
 const MAX_RPC_VOTE_ACCOUNT_INFO_EPOCH_CREDITS_HISTORY: usize = 5; // Remove once Solana 1.15 ships. Ref: https://github.com/solana-labs/solana/pull/28096