delinquents

Author: bgm-malbeclabs

crates/slack-notifier/src/validator_debt.rs

@@ -66,11 +66,8 @@ pub async fn post_finalized_distribution_to_slack(
 }
 
 pub async fn post_debt_collection_to_slack(
-    total_transactions: usize,
     total_success: usize,
-    total_amount_collected: u64,
     insufficient_funds: usize,
-    total_debt: u64,
     already_paid: usize,
     dz_epoch: u64,
     filepath: Option<String>,
@@ -85,19 +82,14 @@ pub async fn post_debt_collection_to_slack(
 
     let table_header = vec![
         "DoubleZero Epoch".to_string(),
-        "Total Amount Collected".to_string(),
         "Successful Transactions".to_string(),
-        "Total Attempted Transactions".to_string(),
         "Insufficient Funds".to_string(),
         "Already Paid".to_string(),
     ];
 
     let table_values = vec![
         dz_epoch.to_string(),
-        total_amount_collected.to_string(),
         total_success.to_string(),
-        total_debt.to_string(),
-        total_transactions.to_string(),
         insufficient_funds.to_string(),
         already_paid.to_string(),
     ];

crates/solana-cli/src/command/revenue_distribution/relay/mod.rs

@@ -97,11 +97,8 @@ async fn execute_pay_solana_validator_debt(
     };
     if let Some(ExportFormat::Slack) = export {
         validator_debt::post_debt_collection_to_slack(
-            tx_results.total_transactions_attempted,
             tx_results.successful_transactions,
-            tx_results.total_amount_collected,
             tx_results.insufficient_funds,
-            tx_results.total_debt,
             tx_results.already_paid,
             epoch,
             filename,

scheduler/config/config.exs

@@ -2,7 +2,7 @@ import Config
 
 config :scheduler, Scheduler.Scheduler,
   jobs: [
-    # {"0 */2 * * *", {Scheduler.Worker.PayDebt, :start_link, []}},
-    # {"*/2 * * * *", {Scheduler.Worker.InitializeDistribution, :start_link, []}},
-    # {"30 */2 * * *", {Scheduler.Worker.CalculateDistribution, :start_link, []}}
+    {"0 */2 * * *", {Scheduler.Worker.PayDebt, :start_link, []}},
+    {"*/2 * * * *", {Scheduler.Worker.InitializeDistribution, :start_link, []}},
+    {"30 */2 * * *", {Scheduler.Worker.CalculateDistribution, :start_link, []}}
   ]

scheduler/lib/scheduler/worker/pay_debt.ex

@@ -39,7 +39,7 @@ defmodule Scheduler.Worker.PayDebt do
 
       debt ->
         debt = Scheduler.ValidatorDebt.DebtCollection.process_debt(debt)
-        epoch_debt = %{debt | epoch: state.current_epoch} #%{state.current_epoch => debt}
+        epoch_debt = %{debt | epoch: state.current_epoch}
         total_debt = [epoch_debt | state.total_debt]
         dbg(length(total_debt))
         Logger.info("completed epoch #{state.current_epoch}")
@@ -60,7 +60,6 @@ defmodule Scheduler.Worker.PayDebt do
 
   defp genesis_epoch do
     Application.get_env(:scheduler, :genesis_epoch)
-    # 55
   end
 
   defp ledger_rpc do

scheduler/mix.exs

@@ -7,12 +7,6 @@ defmodule Scheduler.MixProject do
       version: "0.1.0",
       elixir: "~> 1.18",
       start_permanent: Mix.env() == :prod,
-      # compilers: [:rustler] ++ Mix.compilers(),
-      rustler_crates: [
-        scheduler_doublezero: [
-          mode: if(Mix.env() == :prod, do: :release, else: :debug)
-        ]
-      ],
       deps: deps()
     ]
   end

scheduler/native/scheduler_doublezero/src/lib.rs

@@ -11,8 +11,7 @@ use doublezero_solana_validator_debt::{
     transaction::{DebtCollectionResult, DebtCollectionResults, Transaction},
     worker,
 };
-use rustler::Error as NifError;
-use rustler::NifStruct;
+use rustler::{Error as NifError, NifStruct};
 use slack_notifier::validator_debt;
 use solana_sdk::signature::Keypair;