fusionpbx/resources/install/scripts/app/provision/index.lua

--	Part of FusionPBX
--	Copyright (C) 2015 Mark J Crane <markjcrane@fusionpbx.com>
--	All rights reserved.
--
--	Redistribution and use in source and binary forms, with or without
--	modification, are permitted provided that the following conditions are met:
--
--	1. Redistributions of source code must retain the above copyright notice,
--	  this list of conditions and the following disclaimer.
--
--	2. Redistributions in binary form must reproduce the above copyright
--	  notice, this list of conditions and the following disclaimer in the
--	  documentation and/or other materials provided with the distribution.
--
--	THIS SOFTWARE IS PROVIDED ''AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES,
--	INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY
--	AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE
--	AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY,
--	OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
--	SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
--	INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
--	CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
--	ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
--	POSSIBILITY OF SUCH DAMAGE.

--set the debug options
	debug["sql"] = false;

--define the explode function
	require "resources.functions.explode";

--set the defaults
	max_tries = 3;
	digit_timeout = 5000;
	max_retries = 3;
	tries = 0;
	profile = "internal";

--connect to the database
	require "resources.functions.database_handle";
	dbh = database_handle('system');

--answer
	session:answer();

--sleep
	session:sleep(500);

--get the domain_uuid
	domain_uuid = session:getVariable("domain_uuid");

--get the action
	action = session:getVariable("action");

--set the sounds path for the language, dialect and voice
	default_language = session:getVariable("default_language");
	default_dialect = session:getVariable("default_dialect");
	default_voice = session:getVariable("default_voice");
	if (not default_language) then default_language = 'en'; end
	if (not default_dialect) then default_dialect = 'us'; end
	if (not default_voice) then default_voice = 'callie'; end

--get the user id
	min_digits = 2;
	max_digits = 20;
	user_id = session:playAndGetDigits(min_digits, max_digits, max_tries, digit_timeout, "#", "phrase:voicemail_enter_id:#", "", "\\d+");
	--user_id = session:playAndGetDigits(min_digits, max_digits, max_tries, digit_timeout, "#", sounds_dir.."/"..default_language.."/"..default_dialect.."/"..default_voice.."/ivr/ivr-please_enter_extension_followed_by_pound.wav", "", "\\d+");

--get the user password
	min_digits = 2;
	max_digits = 20;
	password = session:playAndGetDigits(min_digits, max_digits, max_tries, digit_timeout, "#", "phrase:voicemail_enter_pass:#", "", "\\d+");
	--password = session:playAndGetDigits(min_digits, max_digits, max_tries, digit_timeout, "#", sounds_dir.."/"..default_language.."/"..default_dialect.."/"..default_voice.."/ivr/ivr-please_enter_pin_followed_by_pound.wav", "", "\\d+");

--get the user and domain name from the user argv user@domain
	sip_from_uri = session:getVariable("sip_from_uri");
	user_table = explode("@",sip_from_uri);
	user = user_table[1];
	domain = user_table[2];

--show the phone that will be overridden
	freeswitch.consoleLog("NOTICE", "[provision] sip_from_uri: ".. sip_from_uri .. "\n");
	freeswitch.consoleLog("NOTICE", "[provision] user: ".. user .. "\n");
	freeswitch.consoleLog("NOTICE", "[provision] domain: ".. domain .. "\n");

--get the device uuid for the phone that will have its configuration overridden
	sql = [[SELECT * FROM v_device_lines ]];
	sql = sql .. [[WHERE user_id = ']] .. user .. [[' ]];
	sql = sql .. [[AND server_address = ']]..domain..[[' ]];
	sql = sql .. [[AND domain_uuid = ']]..domain_uuid..[[' ]];
	if (debug["sql"]) then
		freeswitch.consoleLog("NOTICE", "[provision] sql: ".. sql .. "\n");
	end
	dbh:query(sql, function(row)
		--get device uuid
			device_uuid = row.device_uuid;
			freeswitch.consoleLog("NOTICE", "[provision] device_uuid: ".. device_uuid .. "\n");
	end);

--get the alternate device uuid using the device username and password
	authorized = 'false';
	if (user_id ~= '' and password ~= '') then
		sql = [[SELECT * FROM v_devices ]];
		sql = sql .. [[WHERE device_username = ']]..user_id..[[' ]];
		sql = sql .. [[AND device_password = ']]..password..[[' ]]
		sql = sql .. [[AND domain_uuid = ']]..domain_uuid..[[' ]];
		if (debug["sql"]) then
			freeswitch.consoleLog("NOTICE", "[provision] sql: ".. sql .. "\n");
		end
		dbh:query(sql, function(row)
			--get the alternate device_uuid
				device_uuid_alternate = row.device_uuid;
				freeswitch.consoleLog("NOTICE", "[provision] alternate device_uuid: ".. device_uuid_alternate .. "\n");
			--authorize the user
				authorized = 'true';
		end);
	end

--authentication failed
	if (authorized == 'false') then
		result = session:streamFile(sounds_dir.."/"..default_language.."/"..default_dialect.."/"..default_voice.."/voicemail/vm-fail_auth.wav");
	end 

--remove the previous device and send a sync command to it
	if (authorized == 'true' and action == "login") then
		sql = [[SELECT * FROM v_device_lines ]];
		sql = sql .. [[WHERE device_uuid = ']]..device_uuid_alternate..[[' ]];
		sql = sql .. [[AND domain_uuid = ']]..domain_uuid..[[' ]];
		if (debug["sql"]) then
			freeswitch.consoleLog("NOTICE", "[provision] sql: ".. sql .. "\n");
		end
		dbh:query(sql, function(row)
			--remove the previous alternate device uuid
				sql = [[UPDATE v_devices SET device_uuid_alternate = null ]];
				sql = sql .. [[WHERE device_uuid_alternate = ']]..device_uuid_alternate..[[' ]];
				sql = sql .. [[AND domain_uuid = ']]..domain_uuid..[[' ]];
				if (debug["sql"]) then
					--freeswitch.consoleLog("NOTICE", "[provision] sql: ".. sql .. "\n");
				end
				dbh:query(sql);
			--send a sync command to the previous device
				--create the event notify object
					local event = freeswitch.Event('NOTIFY');
				--add the headers
					event:addHeader('profile', profile);
					event:addHeader('user', row.user_id);
					event:addHeader('host', row.server_address);
					event:addHeader('content-type', 'application/simple-message-summary');
				--check sync
					event:addHeader('event-string', 'check-sync;reboot=false');
				--send the event
					event:fire();
		end);
	end

--add the override to the device uuid (login)
	if (authorized == 'true' and action == "login") then
		if (device_uuid_alternate ~= nil) then
			--send a hangup
				session:hangup();
			--add the new alternate
				sql = [[UPDATE v_devices SET device_uuid_alternate = ']]..device_uuid_alternate..[[']];
				sql = sql .. [[WHERE device_uuid = ']]..device_uuid..[[' ]];
				sql = sql .. [[AND domain_uuid = ']]..domain_uuid..[[' ]];
				if (debug["sql"]) then
					freeswitch.consoleLog("NOTICE", "[provision] sql: ".. sql .. "\n");
				end
				dbh:query(sql);
		end
	end

--remove the override to the device uuid (logout)
	if (authorized == 'true' and action == "logout") then
		if (device_uuid_alternate ~= nil) then
			sql = [[UPDATE v_devices SET device_uuid_alternate = null ]];
			sql = sql .. [[WHERE device_uuid_alternate = ']]..device_uuid..[[' ]];
			sql = sql .. [[AND domain_uuid = ']]..domain_uuid..[[' ]];
			if (debug["sql"]) then
				freeswitch.consoleLog("NOTICE", "[provision] sql: ".. sql .. "\n");
			end
			dbh:query(sql);
		end
	end

--found the device send a sync command
	if (authorized == 'true') then
		--send a hangup
			session:hangup();
		--create the event notify object
			local event = freeswitch.Event('NOTIFY');
		--add the headers
			event:addHeader('profile', profile);
			event:addHeader('user', user);
			event:addHeader('host', domain);
			event:addHeader('content-type', 'application/simple-message-summary');
		--check sync
			event:addHeader('event-string', 'check-sync;reboot=false');
		--send the event
			event:fire();
	end