fusionpbx/includes/install/scripts/conference_center.lua

--	conference.lua
--	Part of FusionPBX
--	Copyright (C) 2012 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 variables
	flags = "";
	max_tries = 3;
	digit_timeout = 5000;

--include the lua script
	scripts_dir = string.sub(debug.getinfo(1).source,2,string.len(debug.getinfo(1).source)-(string.len(argv[0])+1));
	include = assert(loadfile(scripts_dir .. "/resources/config.lua"));
	include();

--connect to the database
	--ODBC - data source name
		if (dsn_name) then
			dbh = freeswitch.Dbh(dsn_name,dsn_username,dsn_password);
		end
	--FreeSWITCH core db handler
		if (db_type == "sqlite") then
			dbh = freeswitch.Dbh("core:"..db_path.."/"..db_name);
		end

--prepare the api object
	api = freeswitch.API();

--define the session hangup
	function session_hangup_hook()

		--get the uuid
		conference_session_detail_uuid = api:executeString("create_uuid");

		conference_name = session:getVariable("conference_name");
		conference_session_uuid = session:getVariable("conference_uuid");
		conference_recording = session:getVariable("conference_recording");
		conference_moderator = session:getVariable("conference_moderator");
		--start_epoch = session:getVariable("start_epoch");
		end_epoch = os.time();

		freeswitch.consoleLog("NOTICE", "Conference Center: \n");
		freeswitch.consoleLog("NOTICE", "Conference Center: domain_uuid: " .. domain_uuid .. "\n");
		--freeswitch.consoleLog("NOTICE", "Conference Center: domain_name: " .. domain_name .. "\n");
		freeswitch.consoleLog("NOTICE", "Conference Center: meeting_uuid: " .. meeting_uuid .. "\n");
		freeswitch.consoleLog("NOTICE", "Conference Center: conference_name: " .. conference_name .. "\n");
		freeswitch.consoleLog("NOTICE", "Conference Center: conference_uuid: " .. conference_session_uuid .. "\n");
		if (conference_recording) then
			freeswitch.consoleLog("NOTICE", "Conference Center: conference_recording: " .. conference_recording .. "\n");
		end
		freeswitch.consoleLog("NOTICE", "Conference Center: username: " .. username .. "\n");
		freeswitch.consoleLog("NOTICE", "Conference Center: caller_id_name: " .. caller_id_name .. "\n");
		freeswitch.consoleLog("NOTICE", "Conference Center: caller_id_number: " .. caller_id_number .. "\n");
		--freeswitch.consoleLog("NOTICE", "Conference Center: callee_id_name: " .. callee_id_name .. "\n");
		--freeswitch.consoleLog("NOTICE", "Conference Center: callee_id_number: " .. callee_id_number .. "\n");
		--freeswitch.consoleLog("NOTICE", "Conference Center: dialplan: " .. dialplan .. "\n");
		freeswitch.consoleLog("NOTICE", "Conference Center: network_addr: " .. network_addr .. "\n");
		freeswitch.consoleLog("NOTICE", "Conference Center: uuid: " .. uuid .. "\n");
		--freeswitch.consoleLog("NOTICE", "Conference Center: context: " .. context .. "\n");
		--freeswitch.consoleLog("NOTICE", "Conference Center: chan_name: " .. chan_name .. "\n");
		freeswitch.consoleLog("NOTICE", "Conference Center: start_epoch: " .. start_epoch .. "\n");
		freeswitch.consoleLog("NOTICE", "Conference Center: end_epoch: " .. end_epoch .. "\n");

	--get the conference sessions
		sql = [[SELECT count(*) as num_rows 
			FROM v_conference_sessions
			WHERE conference_session_uuid = ']] .. conference_session_uuid ..[[']];
		status = dbh:query(sql, function(row)
			num_rows = string.lower(row["num_rows"]);
		end);
		freeswitch.consoleLog("notice", "[conference] SQL: " .. sql .. " Rows:"..num_rows.."\n");
		if (num_rows == "0") then
			local sql = {}
			table.insert(sql, "INSERT INTO v_conference_sessions ");
			table.insert(sql, "(");
			table.insert(sql, "conference_session_uuid, ");
			table.insert(sql, "domain_uuid, ");
			table.insert(sql, "meeting_uuid, ");
			if (conference_recording) then
				table.insert(sql, "recording, ");
			end
			--if (wait_mod) then
			--	table.insert(sql, "wait_mod, ");
			--end
			table.insert(sql, "start_epoch, ");
			table.insert(sql, "end_epoch ");
			table.insert(sql, ") ");
			table.insert(sql, "VALUES ");
			table.insert(sql, "( ");
			table.insert(sql, "'".. conference_session_uuid .."', ");
			table.insert(sql, "'".. domain_uuid .."', ");
			table.insert(sql, "'".. meeting_uuid .."', ");
			if (conference_recording) then
				table.insert(sql, "'".. conference_recording .."', ");
			end
			--if (wait_mod) then
			--	table.insert(sql, "'".. wait_mod .."', ");
			--end
			table.insert(sql, "'".. start_epoch .."', ");
			table.insert(sql, "'".. end_epoch .."' ");
			table.insert(sql, ") ");
			SQL_STRING = table.concat(sql, "\n");
			dbh:query(SQL_STRING);
			freeswitch.consoleLog("notice", "[conference] SQL: " .. SQL_STRING .. "\n");
		else
			freeswitch.consoleLog("notice", "[conference] number is greater than 0 \n");
		end

		local sql = {}
		table.insert(sql, "INSERT INTO v_conference_session_details ");
		table.insert(sql, "(");
		table.insert(sql, "conference_session_detail_uuid, ");
		table.insert(sql, "domain_uuid, ");
		table.insert(sql, "conference_session_uuid, ");
		table.insert(sql, "meeting_uuid, ");
		table.insert(sql, "username, ");
		table.insert(sql, "caller_id_name, ");
		table.insert(sql, "caller_id_number, ");
		table.insert(sql, "network_addr, ");
		table.insert(sql, "uuid, ");
		if (conference_moderator) then
			table.insert(sql, "moderator, ");
		end
		table.insert(sql, "start_epoch, ");
		table.insert(sql, "end_epoch ");
		table.insert(sql, ") ");
		table.insert(sql, "VALUES ");
		table.insert(sql, "( ");
		table.insert(sql, "'".. conference_session_detail_uuid .."', ");
		table.insert(sql, "'".. domain_uuid .."', ");
		table.insert(sql, "'".. conference_session_uuid .."', ");
		table.insert(sql, "'".. meeting_uuid .."', ");
		table.insert(sql, "'".. username .."', ");
		table.insert(sql, "'".. caller_id_name .."', ");
		table.insert(sql, "'".. caller_id_number .."', ");
		table.insert(sql, "'".. network_addr .."', ");
		table.insert(sql, "'".. uuid .."', ");
		if (conference_moderator) then
			table.insert(sql, "'".. conference_moderator .."', ");
		end
		table.insert(sql, "'".. start_epoch .."', ");
		table.insert(sql, "'".. end_epoch .."' ");
		table.insert(sql, ") ");
		SQL_STRING = table.concat(sql, "\n");
		dbh:query(SQL_STRING);
	end

--make sure the session is ready
if (session:ready()) then
	session:answer();
	session:setHangupHook("session_hangup_hook");
	sounds_dir = session:getVariable("sounds_dir");
	domain_name = session:getVariable("domain_name");
	pin_number = session:getVariable("pin_number");

	--get the domain_uuid
		if (domain_name ~= nil) then
			sql = "SELECT domain_uuid FROM v_domains ";
			sql = sql .. "WHERE domain_name = '" .. domain_name .."' ";
			if (debug["sql"]) then
				freeswitch.consoleLog("notice", "[conference] SQL: " .. sql .. "\n");
			end
			status = dbh:query(sql, function(rows)
				domain_uuid = string.lower(rows["domain_uuid"]);
			end);
		end

	--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 variables
		username = session:getVariable("username");
		caller_id_name = session:getVariable("caller_id_name");
		caller_id_number = session:getVariable("caller_id_number");
		callee_id_name = session:getVariable("callee_id_name");
		callee_id_number = session:getVariable("callee_id_number");
		dialplan = session:getVariable("dialplan");
		network_addr = session:getVariable("network_addr");
		uuid = session:getVariable("uuid");
		--context = session:getVariable("context");
		chan_name = session:getVariable("chan_name");

	--if the pin number is provided then require it
		if (not pin_number) then 
			min_digits = 3;
			max_digits = 12;
			pin_number = session:playAndGetDigits(min_digits, max_digits, max_tries, digit_timeout, "#", "phrase:voicemail_enter_pass:#", "", "\\d+");
		end

	--get the conference sessions
		sql = [[SELECT * FROM v_conference_rooms as s, v_meeting_pins as p
			WHERE s.domain_uuid = ']] .. domain_uuid ..[['
			AND s.meeting_uuid = p.meeting_uuid
			AND p.member_pin = ']] .. pin_number ..[['
			AND enabled = 'true' ]];
		if (debug["sql"]) then
			freeswitch.consoleLog("notice", "[conference] SQL: " .. sql .. "\n");
		end
		status = dbh:query(sql, function(row)
			conference_room_uuid = string.lower(row["conference_room_uuid"]);
			conference_center_uuid = string.lower(row["conference_center_uuid"]);
			meeting_uuid = string.lower(row["meeting_uuid"]);
			max_members = row["max_members"];
			wait_mod = row["wait_mod"];
			member_type = row["member_type"];
			announce = row["announce"];
			enter_sound = row["enter_sound"];
			mute = row["mute"];
			created = row["created"];
			created_by = row["created_by"];
			enabled = row["enabled"];
			description = row["description"];
		end);

	--set the meeting uuid
		session:setVariable("meeting_uuid", meeting_uuid);

	if (conference_center_uuid ~= nil) then
		--set a conference parameter
			--conference <confname> set <parameter_name> <value>

		if (max_members ~= nil) then
			--max members must be 2 or more
			session:execute("set","conference_max_members="..max_members);
		end
		if (mute == "true") then
			flags = flags .. "mute";
		end
		if (enter_sound ~= nil) then
			session:execute("set","conference_enter_sound="..enter_sound);
		else
			session:execute("set","conference_enter_sound=");
		end
		if (exit_sound ~= nil) then
			session:execute("set","conference_exit_sound="..exit_sound);
		end

		--working
			--get number of people in the conference
				--conference Conference-Center-voip.fusionpbx.com get count
			--get number of seconds since the conference started
				--conference Conference-Center-voip.fusionpbx.com get run_time
			if (wait_mod == "true") then
				--flags = flags .. "|wait_mod"; --not working
				--session:execute("conference","Conference-Center-voip.fusionpbx.com(set conference-flags=wait-mod)"); --not working
				conference_profile = "wideband-wait-mod";
			else
				conference_profile = "default";
			end
			if (member_type == "moderator") then
				--set as the moderator
					flags = flags .. "|moderator";
				--when the moderator leaves end the conference
					flags = flags .. "|endconf";
				--set the moderator controls
					session:execute("set","conference_controls=moderator");
			end

		--set the start epoch
			start_epoch = os.time();

		--send the call to the conference
			--session:execute("conference","confname@profilename+[conference pin number]+flags{moderator}");
			cmd = meeting_uuid.."-"..domain_name.."@"..conference_profile.."+flags{".. flags .."}";
			freeswitch.consoleLog("notice", "[conference] ".. cmd .."\n");
			session:execute("conference",cmd);
		--alternative
			--uuid_transfer <uuid> conference:3000@default inline

		--get the conference variables
			conference_name = session:getVariable("conference_name");
			conference_uuid = session:getVariable("conference_uuid");
			conference_recording = session:getVariable("conference_recording");
			freeswitch.consoleLog("NOTICE", "Conference Center: conference_name: 2 " .. conference_name .. "\n");
			freeswitch.consoleLog("NOTICE", "Conference Center: conference_uuid: 2 " .. conference_uuid .. "\n");
			if (conference_recording) then
				freeswitch.consoleLog("NOTICE", "Conference Center: conference_recording: " .. conference_recording .. "\n");
			end

		--freeswitch.consoleLog("notice", "[conference] line: 147\n");
	else
		session:streamFile("phrase:voicemail_fail_auth:#");
		session:hangup("NORMAL_CLEARING");
	end

end