--
-- Подсчёт количества событий, произошедших за последние несколько секунд.
-- При регистрации очередного события в массив событий добавляется новый элемент с указанием текущего момента времени.
-- При подсчёте числа событий учитываются только те события, которые произошли не более чем указанное количество
-- секунд назад, а остальные события удаляются из массива.
--

local EventsCounter = {}

local function systime()
    local d = os.sysdate()
    local mcs = d.mcs or 0
    d.ms = nil
    d.mcs = nil
    return os.time(d) + mcs * 0.000001
end

--- Конструктор.
-- @param self объект
-- @param interval количество секунд, на протяжении которых отслеживаются события
-- @param bump максимальное количество секунд, на протяжении которого событие занимает очередь без регистрации
local function new(self, interval, bump)
    local object = {
        interval = interval,
      bump = bump,
        events = {},
    }
    setmetatable(object, self)
    self.__index = self
    return object
end

EventsCounter.new = new

--- Зарегистрировать событие.
-- @param self объект
local function registerEvent(self, trans_id)
    self.events[trans_id] = systime()
end

EventsCounter.registerEvent = registerEvent

--- Запомнить событие до его регистрации
-- @param self объект
local function preRegisterEvent(self, trans_id)
    self.events[trans_id] = systime() + self.bump
end

EventsCounter.preRegisterEvent = preRegisterEvent

--- Узнать, сколько событий произошло за последние несколько секунд.
-- @param self объект
-- @return количество событий, произошедших за последние несколько секунд
local function getCount(self)
    local now = systime()
    local count = 0
    local remove = {}
    for id, time in pairs(self.events) do
        if now - time <= self.interval then
            count = count + 1
        else
            remove[id] = true
        end
    end
    for id, _ in pairs(remove) do
        self.events[id] = nil
    end
    return count
end

EventsCounter.getCount = getCount


return EventsCounter

local EventsCounter = require("EventsCounter")

local eventsCounter = EventsCounter:new(1.0, 30.0)

function myTransactionSend(transaction)
-- Перед отправкой транзакции проверяем количество событий и притормаживаем, если надо
  while eventsCounter:getCount() >= 50 do
    sleep(10)
  end

-- Ваш код, который отсылает заявку
  sendTransaction()

  eventsCounter:preRegisterEvent(tonumber(transaction.TRANS_ID))
end

-- ответ на отправку транзакции
function OnTransReply(trans_reply)
  eventsCounter:registerEvent(transReply.trans_id)
end

while eventsCounter:getCount() > 45 do
    sleep(10)
end

--
-- Подсчёт количества событий, произошедших за последние несколько секунд.
-- При регистрации очередного события в массив событий добавляется новый элемент с указанием текущего момента времени.
-- При подсчёте числа событий учитываются только те события, которые произошли не более чем указанное количество
-- секунд назад, а остальные события удаляются из массива.
--

local EventsCounter = {}

local function systime()
    local d = os.sysdate()
    local mcs = d.mcs or 0
    d.ms = nil
    d.mcs = nil
    return os.time(d) + mcs * 0.000001
end

--- Конструктор.
-- @param self объект
-- @param interval количество секунд, на протяжении которых отслеживаются события
local function new(self, interval)
    local object = {
        interval = interval,
        id = 0,
        events = {},
    }
    setmetatable(object, self)
    self.__index = self
    return object
end

EventsCounter.new = new

--- Зарегистрировать событие.
-- @param self объект
local function registerEvent(self)
    self.id = self.id + 1
    self.events[self.id] = systime()
end

EventsCounter.registerEvent = registerEvent

--- Узнать, сколько событий произошло за последние несколько секунд.
-- @param self объект
-- @return количество событий, произошедших за последние несколько секунд
local function getCount(self)
    local now = systime()
    local count = 0
    local remove = {}
    for id, time in pairs(self.events) do
        if now - time <= self.interval then
            count = count + 1
        else
            remove[id] = true
        end
    end
    for id, _ in pairs(remove) do
        self.events[id] = nil
    end
    return count
end

EventsCounter.getCount = getCount

return EventsCounter

local EventsCounter = require("EventsCounter")

local eventsCounter = EventsCounter:new(1)

-- Перед отправкой транзакции проверяем количество событий и притормаживаем, если надо
while eventsCounter:getCount() > 40 do
    sleep(10)
end
-- Ваш код, который отсылает заявку
sendTransaction()
--
eventsCounter:registerEvent()

-- отправка траназакции квику
function router:processTransaction(transaction, tJson)
  trace("info", "NEW TRANSACTION: " .. tJson)
  local ok = sendTransaction(transaction)
  if ok ~= "" then
     -- код, чтобы обработать ошибку
  end  
end

function killAllOrders(table_mask)
    -- данная функция отправит транзакции на отмену АКТИВНЫХ заявок соответствующим фильтру указанному как входящий параметр table_mask
    -- список всех возможных параметров  : ACCOUNT,CLASSCODE,SECCODE,OPERATION,CLIENT_CODE,COMMENT
    -- если вызвать функцию с параметром nil - снимутся ВСЕ активные заявки
    local i,key,val,result_num=0,0,0,0
    local tokill=true
    local row={}
    local result_str=""

    for i=0,getNumberOf("orders")-1,1 do
        row=getItem("orders",i)
        tokill=false
        if orderflags2table(row.flags).active then
            tokill=true
            if table_mask~=nil then
                for key,val in pairs(table_mask) do
                    if string_lower(key)=='comment' then
                        if string_find(string_lower(row.brokerref),string_lower(val))==nil then    tokill=false break end
                    else
                        if row[string_lower(key)]~=val then tokill=false    break end
                    end
                end
            end
        end
        if tokill then
            res,ms=killOrder(tostring(row.order_num),row[securityfiledname],row.class_code)
            result_num=result_num+1
            if res then
                result_str=result_str..row.order_num..","
            else
                result_str=result_str.."!"..row.order_num..","
            end
        end
    end
    return true,"QL.killAllOrders(): Sended "..result_num.." transactions. order_nums:"..result_str
end