local class = "TQBR"
local sec = "SBER"

local run = true
function OnStop()
  run = nil
end

function OnConnected()
  message("OnConnected")
end

function main()
  while isConnected() ~= 1 and run do sleep(1) end
  local ds, err = CreateDataSource(class, sec, INTERVAL_M1)
  if ds then
    message("OK")
    ds:SetEmptyCallback()
  else
    message(err, 3)
    return
  end
  for i = 1, 1000 do
    sleep(600)
    if not run then break end
  end
  message(string.format("size: %u", ds:Size()))
  ds:Close()
end

local run = true
function OnStop()
  run = nil
end

function main()
  while isConnected() ~= 1 and run do sleep(1) end
  local n = 0
  local m = 0
  local sources = {}
  local list = ""
  for sec in getClassSecurities(class):gmatch("([^,]+)") do
    if not run then break end
    local ds, err = CreateDataSource(class, sec, INTERVAL_M1)
    if ds then
      ds:SetEmptyCallback()
      n = n + 1
      sources[n] = {ds, sec}
      list = list .. sec .. ","
    else
      message(string.format("Failed to create data source: %s\n%s %s", err, class, sec))
      m = m + 1
    end
  end
  message(string.format("OK: %u, ERROR: %u\n%s", n, m, list))
  while n > 0 and run do
    for i = n, 1, -1 do
      local source = sources[i]
      local size = source[1]:Size()
      if size > 0 then
        n = n - 1
        message(string.format("%s: %u\n%u", source[2], size, n))
        source[1]:Close()
        table.remove(sources, i)
      end
    end
    sleep(500)
  end
end