Получение данных из таблицы текущих торгов

json = require("lib.json")
socket = require("lib.socket")
cfg = require("config")

function string.starts(String,Start)
   return string.sub(String,1,string.len(Start))==Start
end

function hasOption (tab, val)
    for index, value in ipairs(tab) do
        if string.starts(val, value) then
            return true
        end
    end

    return false
end

function OnInit(script) 
   isRun = true
   connected = false
   InstrumentsQueue = {}
end

function OnParam(class_code, sec_code)
   if cfg.classes:find(class_code) ~= nil then
      if (class_code == "SPBOPT" and hasOption(cfg.optionFilter, sec_code) == false) then
         return
      end

      local data = {}
      data["market"] = getParamEx(class_code, sec_code, "CLASS_CODE")
      data["ticker"] = getParamEx(class_code, sec_code, "CODE")
                -- кусь --
      table.sinsert(InstrumentsQueue, data)
   end
end

function OnStop()
   isRun = false
   client:close()
   return 3000
end

function connect()
   if connected == false then
      client = socket.connect(cfg.server.host, cfg.server.port)
      if client == nil then
         message("Error connecting to socket server")
         sleep(5000)
      else
         connected = true
         message("Connected to socket server")
      end
   end
end


function main()
   while isRun do 
   connect()
   if #InstrumentsQueue > 0 and connected then
      local data = InstrumentsQueue[1]
      local jsonData = json.encode({type = "instrument", value = data})
      local status, msg = client:send(jsonData .. "\r\n")
      
      if status ~= nil then
         table.sremove(InstrumentsQueue, 1)
      else
         message("Error sending data to socket server #" .. msg)
         if msg == "closed" then
            message("Disconnected from socket server")
            client:close()
            connected = false
         end
      end
   else
      sleep(50)
   end
   end
end