FusionPBX(Freeswitch) HA sync gateways across servers

There was a little task to do.
Assume, we have several FusionPBX in HA (shared database incl. runtime data is on). On "master managing" server we add a gateway to external profile. To add them on other servers we have to go to each server and push rescan on external profile. Eh... To lazy for this.
We will use script, that will subscribe to CUSTOM sofia::gateway_add and gateway_delete event and run sofia profile external rescan over other servers.
We will do this over xmlrpc, so no need to add ssh keys or so.

"Slave" servers:

• Go to Advanced -> Modules and enable XML RPC module
• Go to Advanced -> Settings on each "slave" server and put common data for XMLRPC connection, like username, pass and port
• Restart mod_xml_rpc on each "slave" server

"Master" server

• Create files /usr/local/freeswitch/scripts/app/gateway_states/resources/gateway_states_add.lua and /usr/local/freeswitch/scripts/app/gateway_states/resources/gateway_states_delete.lua

(I can't get add and delete event work from a single file)

• gateway_states_add.lua

--description

--monitor custom sofia:gateway_* event and run sofia profile external rescan over other servers

--protect xmlrpc using a firewall on the server to limit access by ip address

--iptables

-- /sbin/iptables -I INPUT -j ACCEPT -p tcp --dport 8080 -s x.x.x.x/32

--define the servers running freeswitch do not include local

servers = {}

x = 0;

servers[x] = {}

servers[x]['username'] = "freeswitch";

servers[x]['password'] = "work";

servers[x]['hostname'] = "10.0.0.2";

servers[x]['port'] = "8080";

x = x + 1;

servers[x] = {}

servers[x]['username'] = "freeswitch";

servers[x]['password'] = "work";

servers[x]['hostname'] = "10.0.0.3";

servers[x]['port'] = "8080";

--x = x + 1;

--servers[x] = {}

--servers[x]['username'] = "ccc";

--servers[x]['password'] = "xxxxx";

--servers[x]['hostname'] = "127.0.0.3";

--servers[x]['port'] = "8080";

--subscribe to the events

--events = freeswitch.EventConsumer("all");

events = freeswitch.EventConsumer("CUSTOM", "sofia::gateway_add");

        -- events = freeswitch.EventConsumer("CUSTOM", "sofia::gateway_delete");

        -- Modify line above to get gateway_states_delete.lua

--prepare the api object

api = freeswitch.API();

--get the events

for event in (function() return events:pop(1) end) do

api_command_argument = "profile%20external%20rescan";
  -- event_gateway = event:getHeader("Gateway");
  -- api_command_argument = "profile%20external%20killgw%20"..event_gateway;
  -- Modify line above to get gateway_states_delete.lua

for key,row in pairs(servers) do

url = [[http://]]..row.username..[[:]]..row.password..[[@]]..row.hostname..[[:]]..row.port..[[/webapi/sofia?]]..api_command_argument;

response = api:execute("curl", url);

freeswitch.consoleLog("INFO", "[notice] ".. url .. " "..response.."\n");

end

end

• Modify /usr/local/freeswitch/conf/autoload_configs/lua.conf.xml

    <param name="startup-script" value="app/gateway_states/resources/gateway_states_add.lua"/>

    <param name="startup-script" value="app/gateway_states/resources/gateway_states_delete.lua"/>

• Restart "master" server. At this point, every gateway add or delete will trigger an event, that will go across all our servers and command them pull new config from common database.

This script was modified from memcache.lua, that flushes memcaches over all Fusion servers.