Asterisk - fi, é falta de educação
Olá queridos leitores deste maravilhoso recurso. Por tradição, sou um leitor de habr de longa data, mas só agora decidi fazer um post. O que, de fato, o levou a escrever? Honestamente, eu não me conheço. Ou os artigos desenhados sobre o desempenho do FreeSWITCH / Yate / 3CX / etc em comparação com o Asterisk, ou os problemas reais e reais da arquitetura deste último, ou, talvez, o desejo de fazer algo único.
E, surpreendentemente, no primeiro caso, como regra, eles comparam suave e quente, por assim dizer, FreeSWITCH / Yate / etc e FreePBX. Sim, FreePBX. Este não é um erro de digitação. E é interessante que em todas as comparações geralmente há um Asterisco na configuração padrão. Bem, você sabe, essa configuração é carregada com todos os módulos disponíveis, a curva dialplan (o FreePBX meio que contribui) e um monte de outros vieses. Quanto às feridas genéricas do Asterisk - sim, objetivamente sua carruagem e carrinho pequeno.
O que fazer com tudo isso? Quebre estereótipos e conserte o trauma do nascimento. Isso é o que faremos.
Cruzamos um ouriço com uma cobra
Muitos dos novatos ficam desconfortáveis olhando para a sintaxe para descrever o plano de discagem no Asterisk, e alguns justificam seriamente a escolha de outro servidor de telefonia pela necessidade de escrever o plano de discagem na forma em que está por padrão. Por exemplo, remover XML multilinha é o máximo do conforto. Sim, é possível usar LUA / AEL, o que é bom. Mas, pessoalmente, eu classificaria isso como uma desvantagem, e em particular em relação ao pbx_lua.
, — . , . , , , , , .., .. , , . – , .
, Asterisk' pbx_lua, Yate , FreeSWITCH , "overhead" . , , , . :
- Asterisk, . ARI , , 12- . , - 1.8/1.6, 1.4, .
- Lua — , . , , .
- Lunapark — github', voip-.
Lunapark . , AMI- FastAGI, . , ARI AGI AMI .
: ? Asterisk REST Interface, ! . , ARI : , , , "" , WebSockets , , , XML/JSON — . , , , . — . — - , .
? FastAGI-, , pbx_lua . Asterisk’ , FastAGI- AMI-. , FastAGI-, , , NewChannel. ARI, , stasis' ARI .
Lunapark , . "shared data". , . — , , - .
?
— ? , , . , . .
:
[test]
exten => _XXX/102,1,Hangup()
exten => _XXX,1,Dial(SIP/${EXTEN})
, 102. , , extended CallerID . , , CallerIDName , , regexp, . , , , :
[test]
exten => _XXX/102,1,Hangup()
; CallerIDName
exten => _XXX,1,ExecIf($[ "${CALLERID(name)}" == "Vasya" ]?Hangup())
;
exten => _XXX,n,ExecIf($[ "${CHANNEL(state)}" != "Ring" ]?Hangup())
;
exten => _XXX,n,ExecIf($[ "${CUT(CUT(CHANNEL,-,1),/,2)}" == "333" ]?Hangup())
exten => _XXX,n,Dial(SIP/${EXTEN})
, , Hangup', extensions.conf Goto, GoSub, Macro , , Local.
— .
:
${Exten}:match('%d%d%d')
and
(
${CallerIDNum}:match('201') or
${CallerIDName}:match('Vasya') or
${State}:lower() ~= 'ring' or
${Channel}:match('^[^/]+/([^%-]+)') == '333'
) => Hangup();
${Exten}:match('%d%d%d') => Dial {callee = ('SIP/%s'):format(${Exten})};
, , . , regexp' , , , .
, .
Lunapark pbx_lua. . ${...}
, ('...')
. .
, :
-- Exten = 123
-- Sate = Ring
-- CallerIDNum = 100
-- CallerIDName = Test
-- Channel = SIP/100-00000012c
if ('123'):match('%d%d%d') and
(
('100'):match('201') or
('Test'):match('Vasya') or
('Ring'):lower() ~= 'ring' or
('SIP/100-00000012c'):match('^[^/]+/([^%-]+)') == '333'
) then
Hangup()
end
if ('123'):match('%d%d%d') then
Dial {callee = ('SIP/%s'):format(('123'))}
end
fmt syntax :
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
, . — , . routes.
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
: Lunapark . — Lunapark handler'. , FastAGI- AMI .
, AMI — , AMI-, AMI . , extensions.conf.
[default]
exten => _[hit],1,NoOp()
exten => _.,n,Wait(5)
exten => _.,1,AGI(agi://127.0.0.1/${EXTEN}${IF($[ "X${PRMS}" != "X" ]?"?${PRMS}")})
Wait(5) FastAGI-, , Redirect default ${EXTEN}.
, Lunapark', FastAGI-.
-- 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
-- , , FastAGI
local step
-- FatsAGI
local count = 0
--
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
}
, , , . , . , . , , , ..
, . — , redirect . , , FastAGI-. Lunapark UserEvent FastAGI- — . default , , PRMS.
, redirect' handler, AGI . Hangup() Dial(). .
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
, —
, . ?
- , ;
- VoIP-. Queue, , asterisk';
- , VoIP-, asterisk' Mediahub, VoIP- ;
- a capacidade de usar uma linguagem de script bastante simples, extensível e muito flexível para criar aplicativos VoIP;
- ampliou as possibilidades de integração com sistemas externos de aplicações VoIP.
Como qualquer um, mas ainda gosto de tudo.
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