os.setlocale("")
local Server = require "modules.Server";
local Logger = require "modules.Logger";
local Utils  = require "modules.Utils";
local Quik   = require "modules.Quik";

local Logger = require "modules.Logger";
local Timer = require("modules.Timer")

local base   = _G;
local math   = math;
local string = string;
local timer = Timer:new()

local logger;
local worker = true



local function GetSecurities(class)
  local sec_list = {}
  local sec_str = getClassSecurities(class)
  local sec_tab = {}
  for security in sec_str:gmatch("[^,]+") do table.insert(sec_tab, security) end
  for index, sec_code in pairs(sec_tab) do
    info = getSecurityInfo (class, sec_code)
    if info then
      sec_list[sec_code] = {}
      sec_list[sec_code]["class_code"] = class
      sec_list[sec_code]["sec_code"] = info["isin_code"]
      sec_list[sec_code]["stock_code"] = info["stock_code"]
    else
      logger: debug('GetSecurities: Not receive info for '..sec_code..', '..class)
    end
  end
  return sec_list
end

local function quotesSubscribe(securities)
  for sec, values in pairs(securities) do
    if not Subscribe_Level_II_Quotes(values["class_code"], values["sec_code"]) then
      logger: warn('quotesSubscribe: Failed subs for '..values["sec_code"]..', class: '..values["class_code"])
    end
  end
  logger: info('quotesSubscribe: Subscribed')
end

local function paramsSubscribe(securities)
  for sec_code, values in pairs(securities) do
    if not ParamRequest(values["class_code"], values["sec_code"], "BID") then
      logger: warn('paramsSubscribe: bid subs failed for '..values["sec_code"]..', class: '..values["class_code"])
    end
    if not ParamRequest(values["class_code"], values["sec_code"], "OFFER") then
      logger: warn('paramsSubscribe: offer subs failed for '..values["sec_code"]..', class: '..values["class_code"])
    end
  end
  logger: info('paramsSubscribe: Subscribed')
end;

function OnQuote(class_code, sec_code)
  if class_code == "F" then
    logger: debug('F')
  end
end;

function OnParam(class_code, sec_code)
  if class_code == "F" then
    logger: debug('F')
  end
end;

function OnInit()
  local scriptPath = getScriptPath();
  logger = Logger: new(scriptPath, "test.log", "testtg.log", dump);
end;

function OnStop()
   worker = false
end;

function OnConnected()
  worker = true
end;

function OnDisconnected()
  worker = false
end;

function main()
  local sec_list = GetSecurities("NYSE_BEST")
  quotesSubscribe(sec_list)
  paramsSubscribe(sec_list)
  local sec_list = GetSecurities("NASDAQ_BEST")
  quotesSubscribe(sec_list)
  paramsSubscribe(sec_list)
  timer:setInterval(60)
  while worker do
    sleep(1)
    if timer:isTimeout() then
      logger: debug("Memory quik used: " .. math.ceil(getInfoParam("MEMORY") / 1024).. "M")
      logger: debug("Memory lua used: " .. math.ceil(collectgarbage("count") / 1024) .. "M")
      timer:setInterval(60)
    end
  end  
end;

2019-06-14 13:17:10.509 INFO  quotesSubscribe: Subscribed
2019-06-14 13:17:13.225 INFO  paramsSubscribe: Subscribed
2019-06-14 13:17:13.652 INFO  quotesSubscribe: Subscribed
2019-06-14 13:17:14.632 INFO  paramsSubscribe: Subscribed
2019-06-14 13:18:14.000 DEBUG Memory quik used: 307M
2019-06-14 13:18:14.000 DEBUG Memory lua used: 1M
2019-06-14 13:19:14.000 DEBUG Memory quik used: 308M
2019-06-14 13:19:14.000 DEBUG Memory lua used: 1M
2019-06-14 13:20:14.000 DEBUG Memory quik used: 310M
2019-06-14 13:20:14.000 DEBUG Memory lua used: 1M
2019-06-14 13:21:14.000 DEBUG Memory quik used: 312M
2019-06-14 13:21:14.000 DEBUG Memory lua used: 1M
2019-06-14 13:22:14.000 DEBUG Memory quik used: 315M
2019-06-14 13:22:14.000 DEBUG Memory lua used: 1M
...
2019-06-14 14:38:14.006 DEBUG Memory lua used: 1M
2019-06-14 14:39:14.000 DEBUG Memory quik used: 916M
2019-06-14 14:39:14.000 DEBUG Memory lua used: 1M
2019-06-14 14:40:14.000 DEBUG Memory quik used: 917M
2019-06-14 14:40:14.000 DEBUG Memory lua used: 1M
2019-06-14 14:41:14.000 DEBUG Memory quik used: 919M
2019-06-14 14:41:14.000 DEBUG Memory lua used: 1M
2019-06-14 14:42:14.000 DEBUG Memory quik used: 921M
2019-06-14 14:42:14.000 DEBUG Memory lua used: 1M