xchg_iterator.hpp

Go to the documentation of this file.

 
#pragma once
 
#include "../PriceXchg.hpp"
#include "orders_queue.hpp"
 
namespace tvm { namespace xchg {
 
 
class xchg_iterator {
public:
  xchg_iterator(
    process_queue_state&      state,      
    orders_queue_cached&      orders,     
    uint128                   deal_costs, 
    bool                      sell        
  ) : state_(state), orders_(orders), deal_costs_(deal_costs), sell_(sell) {
  }
 
  bool first_active() {
    while (!orders_.empty() && !state_.overlimit()) {
      OrderInfoXchgWithIdx& ord_idx = orders_.front_with_idx();
      [[maybe_unused]] auto [idx, ord] = ord_idx;
 
      // If the order is expired
      if (!is_active_time(ord.order_finish_time)) {
        state_.on_expired(ord_idx, sell_);
        orders_.pop();
        continue;
      }
      // If the order has not enough evers for processing
      if (ord.account < deal_costs_) {
        state_.on_out_of_evers(ord_idx, sell_);
        orders_.pop();
        continue;
      }
      return true;
    }
    return false;
  }
 
  OrderInfoXchgWithIdx& cur() { return orders_.front_with_idx(); }
 
  OrderInfoXchg& operator*() {
    return cur().second;
  }
 
  void on_deal(uint128 deal_amount, uint128 costs, uint128 lend_spent) {
    auto& ord_idx = cur();
    [[maybe_unused]] auto& [idx, ord] = ord_idx;
    ord.amount -= deal_amount;
    ord.account -= costs;
    ord.lend_amount -= lend_spent;
 
    // If order is done
    if (state_.is_order_done(ord)) {
      state_.on_order_done(ord_idx, sell_);
      orders_.pop();
    // If order is out-of-evers
    } else if (ord.account < deal_costs_) {
      state_.on_out_of_evers(ord_idx, sell_);
      orders_.pop();
    }
  }
 
  void drop_with_ooc() {
    state_.on_out_of_evers(cur(), sell_);
    orders_.pop();
  }
 
  process_queue_state&      state_;      
  orders_queue_cached&      orders_;     
  uint128                   deal_costs_; 
  bool                      sell_;       
};
 
}} // namespace tvm::xchg