local fmt = function(str, tab)
return (str:gsub('(%${[^}{]+})', function(w)
  local mark = w:sub(3, -2)
  return (mark:gsub('(.+)',function(v)
   local out = tab[v] or v
   return ("('%s')"):format(out)
  end))
end))
end
local syntax = function(str)
return (str:gsub('([^;]+)=>([^;]+)',function(p,r)
  return ([[
   if %s then
    %s
   end
  ]]):format(p,r)
end))
end
local routes = function(...)
  local conf, content = ...
  local f, err = io.open(conf, "r")
  if io.type(f) ~= 'file' then
   log.warn(err)  -- Глобальный LOG объект доступный благодаря Lunapark'у
   return ""
  else
   content = f:read('*all')
  end
  f:close() return content
end
-- Считываем наши правила в переменную rules
local rules = routes('routes.conf')
-- Очищаем все обработчики, причем таким образом очистятся только неименные обработчики событий
-- Это даст возможность не затирать цепочку выполнения при сигналах HUP/QUIT
ami.removeEvents('*')
-- Обработчик события создания нового канала
ami.addEvents {
['newchannel'] = function(e)
  -- Условия, только каналы с набором и каналы с контекстом users
  if (e['Context'] and e['Context']:match('users')) and e['Exten'] then
   local step -- Переменная, указывающая на выполнении, какого FastAGI приложения мы находимся
   local count = 0 -- Будущий порядковый номер FatsAGI приложения в цепочке выполнения
   -- Парсим маршруты для текущего окружения канала
   local code, err = loadstring(syntax(fmt(rules,e)))
   -- В описании маршрутов нет ошибок, двигаемся дальше
   if type(code) == 'function' then
    -- Проксируем будущие FastAGI приложения
    setfenv(code,setmetatable({indexes = {}},{__index = function(t,k)
     -- Вот они последствия кооперативности
     return coroutine.wrap(
      function(...)
       local prms = {} -- Будущие параметры FastAGI приложения
       local owner = t -- Копия окружения
       local event = e -- Копия таблицы event
       local thread = coroutine.running() -- ID текущей сопрограммы
       -- Парсим параметры и приводим к виду URI
       for p,v in pairs({...}) do
        if type(v) == 'table' then
         for key, val in pairs(v) do
          table.insert(prms,("%s=%s"):format(key,val))
         end
        else
         table.insert(prms,("%s=%s"):format(p,v))
        end
       end
       -- Если это не первое FastAGI приложение в цепочке
       if step then
        -- Запоминаем предыдущее перед этим
        local last = ("%s"):format(step)
        -- Добавляем ИМЕННЫЕ обработчики события UserEvent по доп. условиям
        -- И записываем в таблицу indexes(в окружении) их порядковые номера
        -- Именные обработчики требуют последующего удаления самостоятельно
        table.insert(owner['indexes'],ami.addEvent('UserEvent',function(evt)
         -- Ловим событие AGIStatus указывающее на завершение приложения
         -- Если это предыдущее перед нами, пробуждаем сопрограмму
         if (evt['Channel'] and evt['Channel'] == event['Channel'])
               and
          (evt['UserEvent'] and evt['UserEvent']:match('AGIStatus'))
               and
          (evt['Script'] and evt['Script'] == last)
         then
          -- Соответствие порядкового номера нашей сопрограмме
          -- В цепочке может быть вызов одного приложения несколько раз
          -- Это позволит выполнять сопрограммы в порядке их определения
          if owner['indexes'][count] == thread then
           if coroutine.status(thread) ~= 'dead' then
            coroutine.resume(thread)
           end
          end
         end
        end,thread))
        -- Устанавливаем маркер текущего FastAGI приложения
        step = k
        -- Приостанавливаем сопрограмму
        coroutine.yield()
       else -- Здесь обрабатывается первое FastAGI приложение в цепочке
        local index -- Индекс для обработчика Hangup события
        -- Устанавливаем маркер текущего FastAGI приложения
        step = k
        -- Добавляем ИМЕННОЙ обработчик события Hangup для канала
        -- В этом месте подчищаем за собой
        index = ami.addEvent('Hangup',function(evt)
         if evt['Channel'] and evt['Channel'] == event['Channel'] then
          -- Удаляем обработчик событие Hangup по ранее запомненному индексу
          ami.removeEvent('Hangup',index)
          -- Удаляем все обработчики цепочек выполнения по индексу
          for _,v in pairs(owner['indexes']) do
           ami.removeEvent('UserEvent',v)
          end
          -- Делаем приятно сборщику мусора
          owner = nil
         end
        end,thread)
       end
       -- По средствам AMI выставляем переменную для канала и вызова в цепочке
       ami.setvar{
        Value = table.concat(prms,'&'),
        Channel = event['Channel'],
        Variable = 'PRMS'
       }
       -- Перенаправляем канал на AGI-приложение через контекст default
       ami.redirect{
        Exten = k,
        Priority = 1,
        Channel = event['Channel'],
        Context = 'default'
       }
       -- Выставляем индекс приложения
       count = count + 1
      end)
    end}))()
   else
    -- Если что-то пошло не так
    log.warn(err)
   end
  end
end
}
function Hangup(...)
  local app, channel = ... -- В этом отличие от pbx_lua
  app.verbose(('The Channel %s does not match by routing rules'):format(channel.get('CHANNEL')))
  app.hangup()
end
function Dial(...)
  local app, channel = ...
  local leg = app.agi.params['callee'] or ''
  app.verbose(('Trying to make a call from %s to %s'):format(
   channel.get('CALLERID(num)'),
   leg:match('^[^/]+/([^%-]+)'))
  )
  app.dial(leg)
end