97 lines
3.3 KiB
Lua
97 lines
3.3 KiB
Lua
--description
|
|
--monitor custom memcache event and clear memcache on remote servers
|
|
--protect xmlrpc using a firewall on the server to limit access by ip address
|
|
|
|
--dependencies
|
|
--install mod_curl freeswitch module
|
|
--uncomment mod_curl from modules.conf when compiling freeswitch
|
|
--xmlrpc
|
|
--open port xmlrpc port for other master server IP addresses
|
|
--change the password for xmlrpc in system -> settings
|
|
--conf/autoload_configs/lua.conf.xml
|
|
-- <param name="startup-script" value="app/server/resources/memcache.lua"/>
|
|
--iptables
|
|
-- /sbin/iptables -I INPUT -j ACCEPT -p tcp --dport 8080 -s x.x.x.x/32
|
|
-- ubuntu: service iptables-persistent save
|
|
|
|
--define the servers running freeswitch do not include local
|
|
--[[
|
|
#put this in local.lua
|
|
servers = {}
|
|
x = 0;
|
|
servers[x] = {}
|
|
servers[x]['method'] = "curl";
|
|
servers[x]['username'] = "freeswitch";
|
|
servers[x]['password'] = "freeswitch";
|
|
servers[x]['hostname'] = "x.x.x.x";
|
|
servers[x]['port'] = "8080";
|
|
x = x + 1;
|
|
servers[x] = {}
|
|
servers[x]['method'] = "curl";
|
|
servers[x]['username'] = "freeswitch";
|
|
servers[x]['password'] = "freeswitch";
|
|
servers[x]['hostname'] = "x.x.x.x";
|
|
servers[x]['port'] = "8080";
|
|
]]
|
|
|
|
--includes config.lua which will include local.lua if it exists
|
|
require "resources.functions.config"
|
|
|
|
--subscribe to the events
|
|
--events = freeswitch.EventConsumer("all");
|
|
events = freeswitch.EventConsumer("CUSTOM");
|
|
|
|
--define trim
|
|
function trim (s)
|
|
return (string.gsub(s, "^%s*(.-)%s*$", "%1"))
|
|
end
|
|
|
|
--prepare the api object
|
|
api = freeswitch.API();
|
|
|
|
--get the events
|
|
for event in (function() return events:pop(1) end) do
|
|
--serialize the data for the console
|
|
--freeswitch.consoleLog("notice","event:" .. event:serialize("xml") .. "\n");
|
|
--freeswitch.consoleLog("notice","event:" .. event:serialize("json") .. "\n");
|
|
|
|
--get the uuid
|
|
local api_command = event:getHeader("API-Command");
|
|
if (api_command ~= nil) then
|
|
api_command = trim(api_command);
|
|
freeswitch.consoleLog("NOTICE","api_command: "..api_command .. "\n");
|
|
end
|
|
if (api_command == "memcache") then
|
|
memcache_updated = false;
|
|
local api_command_argument = event:getHeader("API-Command-Argument");
|
|
if (api_command_argument ~= nil) then
|
|
api_command_argument = trim(api_command_argument);
|
|
end
|
|
if (api_command_argument ~= nil) then
|
|
if (api_command_argument == "flush") then
|
|
memcache_updated = true
|
|
end
|
|
if (string.sub(api_command_argument, 0, 6) == "delete") then
|
|
memcache_updated = true
|
|
end
|
|
if (memcache_updated) then
|
|
for key,row in pairs(servers) do
|
|
if (row.method == "ssh") then
|
|
api_command_argument = api_command_argument:gsub("%%20", " ");
|
|
cmd = [[ssh ]]..row.username..[[@]]..row.hostname..[[ "fs_cli -x 'memcache ]]..api_command_argument..[['"]];
|
|
freeswitch.consoleLog("INFO", "[notice] command: ".. cmd .. "\n");
|
|
os.execute(cmd);
|
|
end
|
|
if (row.method == "curl") then
|
|
api_command_argument = api_command_argument:gsub(" ", "%%20");
|
|
url = [[http://]]..row.username..[[:]]..row.password..[[@]]..row.hostname..[[:]]..row.port..[[/webapi/memcache?]]..api_command_argument;
|
|
os.execute("curl "..url);
|
|
freeswitch.consoleLog("INFO", "[notice] curl ".. url .. " \n");
|
|
end
|
|
end
|
|
end
|
|
|
|
end
|
|
end
|
|
end
|