kucoin_arbitrage 0.0.8

Event-Driven Kucoin Arbitrage Framework in Async Rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34

use crate::event::chance::ChanceEvent;
use crate::event::order::OrderEvent;
use tokio::sync::broadcast::{Receiver, Sender};

// TODO implement when all_taker_btc_usdt is done

/// Broker that accepts chances, then outputs actual orders based on other limiting factors
/// Gate Keeper
/// - Amount of money left in the account
/// - transaction formatted to tradeable digits
/// - 45 orders per 3 seconds
/// - 200 active order at once
pub async fn task_gatekeep_chances(
    mut receiver: Receiver<ChanceEvent>,
    mut _sender: Sender<OrderEvent>,
) -> Result<(), kucoin_api::failure::Error> {
    loop {
        let status = receiver.recv().await;
        if status.is_err() {
            log::error!("task_gatekeep_chances error {:?}", status.err().unwrap());
            continue;
        }
        let event = status.unwrap();
        match event {
            ChanceEvent::AllTaker(actions) => {
                log::info!("All Taker Chance found!\n{actions:?}");
                // TODO conduct profit maximization here

                // TODO push to order manager
            }
            ChanceEvent::MakerTakerTaker(_actions) => {}
        }
    }
}