kucoin_arbitrage 0.0.6

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

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() {
            continue;
            // TODO return the error as we want here
            // panic!("{:?}", status.err());
        }
        let event = status.unwrap();
        match event {
            ChanceEvent::AllTaker(_actions) => {}
            ChanceEvent::MakerTakerTaker(_actions) => {}
        }
    }
}