s_mike@rambler.ru (Все сообщения пользователя)

   -- Собирает из ТОС новые обезличенные сделки
   rescan =
      function()
         if database.need_rescan == false then
            return
         end
         database.need_rescan = false

         local num_trades = getNumberOf("all_trades") - 1
         local items = SearchItems("all_trades",
                                    database.tos + 1,
                                    num_trades,
                                    database.search_function,
                                    "class_code,sec_code,datetime.day,datetime.month,datetime.year"
                                  ) or {}
         database.tos = num_trades
         log.write("Получено ",`#'items," сделок")

         for _,n in ipairs(items) do         -- Всегда по возрастанию
            database.process_trade(getItem("all_trades",n))
         end

         database.save()
      end,

   ---------------------------------------------------------------
   -- Обработка одной сделки
   process_trade =
      function(trade)

         -- Костыль для фильтрации кривых обезличенных сделок, которые шлёт терминал
         if not trade or trade.datetime.year == 1601 then
            log.error("BS: Ошибка терминала. Недопустимая таблица обезличенной сделки ",trade)
            return
         end

oncleanup.subscribe(function()
                     repository.init()
                    end
                   )
onconnected.subscribe(function(flag)
                        if flag then
                           repository.init()
                        end
                      end
                   )

         local security = getSecurityInfo(_class,_code)
         if not security then
            log.write("Инструмент ",instrument_dir," не обнаружен")
            screen.add(_class,_code,INSTRUMENT_NOT_FOUND)
            return
         end

         local ds,err = CreateDataSource(_class,_code,INTERVAL_TICK)
         if not ds then
            log.write("Невозможно получить обезличенные сделки по инструменту ",instrument_dir)
            screen.add(_class,_code,INSTRUMENT_NOT_FOUND)
            return
         end
         table.insert(database.ds,ds)
         log.write("Подписка на инструмент ",instrument_dir," успешна")