kanekoshoyu/kucoin_arbitrage

chance/order counter not being updated

Opened this issue · 1 comments

[2023-10-23 17:53:13][INFO][kucoin_arbitrage::broker::gatekeeper::kucoin] time_sent: SystemTime { tv_sec: 1698076393, tv_nsec: 843016101 }
[2023-10-23 17:53:13][ERROR][kucoin_arbitrage::broker::order::kucoin] ErrorMessage { msg: "global timer [order_placement_broadcast] is not found" }
[2023-10-23 17:53:13][INFO][kucoin_arbitrage::broker::order::kucoin] order placement
LimitOrder { id: "MhESL0T33wphLG8OvQS4evTEWFa-oZrAbDPCi7H0", order_type: Limit, side: Buy, symbol: "BCH-USDT", amount: "0.40740000000000004", price: "245.44" }
[2023-10-23 17:53:17][INFO][chaiwala::report::counter] Broadcast channel data rate
[2023-10-23 17:53:17][INFO][chaiwala::report::counter] orderbook : 25482 points ( 5096mps)
[2023-10-23 17:53:17][INFO][chaiwala::report::counter] best_price: 2589 points ( 517mps)
[2023-10-23 17:53:17][INFO][chaiwala::report::counter] chance : 0 points ( 0mps)
[2023-10-23 17:53:17][INFO][chaiwala::report::counter] order : 0 points ( 0mps)
[2023-10-23 17:53:17][INFO][chaiwala::report::counter] orderchange: 0 points ( 0mps)

solved by just adding the below:

    taskpool_monitor.spawn(task_monitor_channel_mps(
        tx_chance.subscribe(),
        cx_chance.clone(),
    ));
    taskpool_monitor.spawn(task_monitor_channel_mps(
        tx_order.subscribe(),
        cx_order.clone(),
    ));
    taskpool_monitor.spawn(task_monitor_channel_mps(
        tx_orderchange.subscribe(),
        cx_orderchange.clone(),
    ));