Обезличенные сделки. Подписка/отписка

-- Скрипт проверки корректности получения данных обезличенных сделок.
-- Терминал запускается вместе со скриптом ДО начала сессии.
-- Таблица обезличенных сделок не открыта
-- Тикера нет в Таблице текущих торгов.
--
ticker="MAGN"
status,t_status=0,0
old_size=0
n=0
is_run=true
SessionDate=""
function main()
   message("Script's start local time: "..os.date("%d-%b-%Y %X"))
   SessionDate=getTradeDate().date
   message("Session date "..SessionDate)
   ParamRequest(p_classcode,ticker,"TRADINGSTATUS")
   --
   while is_run==true do
      if SessionDate~=getTradeDate().date and status==1 then -- новая сессия
         SessionDate=getTradeDate().date
         message("New session date "..SessionDate)
         n=0
      end
      t_status=tonumber(getParamEx2("TQBR",ticker, "TRADINGSTATUS").param_value) -- текущий статус
      if status~=t_status then -- изменение статуса сессии
         status=t_status
         if status==3 or status==1 then
            if not ds or type(ds)~="table" then
               ds,error_desc=CreateDataSource("TQBR", ticker, INTERVAL_TICK)
               if error_desc~=nil and error_desc~="" then message(" Source error==>" .. error_desc) end
               local nn=0
               while ds:Size()<5 and nn<100 do
               sleep(100) nn=nn+1
               end
               ds:SetEmptyCallback()
               message(os.date(" %X").." Ready. Session status:"..tostring(status).." Data size:"..tostring(ds:Size()))
               while n<10 and status==1 do
                  local size=ds:Size()
                  if size~=old_size then
                     message(tostring(n)..os.date(" %X").." Get data. Session status:"..tostring(status).." Data size:"..tostring(ds:Size()))
                     old_size=size
                     n=n+1
                  end
                  sleep(50)
               end
            end
         end
      end
      sleep(100)
   end
end

function OnStop(stop_flag)
   message("Script's stop local time(MSK-1): "..os.date("%d-%b-%Y %X"))
   if ds then ds:Close() end
   is_run=false
end

function main()
   message("Script's start local time: "..os.date("%d-%b-%Y %X"))
   SessionDate=getTradeDate().date
   message("Session date "..SessionDate)
   ParamRequest(p_classcode,ticker,"TRADINGSTATUS")
   --
   while is_run==true do
      t_status=tonumber(getParamEx2("TQBR",ticker, "TRADINGSTATUS").param_value) -- текущий статус
      if status~=t_status then -- изменение статуса сессии
         status=t_status
         if status==3 or status==1 then
            if not ds or type(ds)~="table" then
               ds,error_desc=CreateDataSource("TQBR", ticker, INTERVAL_TICK)
               if error_desc~=nil and error_desc~="" then message(" Source error==>" .. error_desc) end
               local nn=0
               while ds:Size()<5 and nn<100 do
               sleep(100) nn=nn+1
               end
               ds:SetEmptyCallback()
               message(os.date(" %X").." Ready. Session status:"..tostring(status).." Data size:"..tostring(ds:Size()))
            end
            while n<10 and status==1 do
               local size=ds:Size()
               if size~=old_size then
                  message(tostring(n)..os.date(" %X").." Get data. Session status:"..tostring(status).." Data size:"..tostring(ds:Size()))
                  old_size=size
                  n=n+1
               end
               sleep(50)
            end
         end
      end
      sleep(100)
   end
end