--	voicemail.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 default values
	min_digits = 1;
	max_digits = 8;
	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

--answer the session
	if (session:ready()) then
		session:answer();
	end

--get session variables
	context = session:getVariable("context");
	sounds_dir = session:getVariable("sounds_dir");
	domain_name = session:getVariable("domain_name");
	uuid = session:getVariable("uuid");
	voicemail_id = session:getVariable("voicemail_id");
	voicemail_action = session:getVariable("voicemail_action");
	base_dir = session:getVariable("base_dir");
	destination_number = session:getVariable("destination_number");
	caller_id_name = session:getVariable("caller_id_name");
	caller_id_number = session:getVariable("caller_id_number");

--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 domain_uuid
	domain_uuid = session:getVariable("domain_uuid");
	if (domain_uuid == nil) then
		--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", "[xml_handler] SQL: " .. sql .. "\n");
				end
				status = dbh:query(sql, function(rows)
					domain_uuid = rows["domain_uuid"];
				end);
			end
	end
	domain_uuid = string.lower(domain_uuid);

--set the voicemail_dir
	voicemail_dir = base_dir.."/storage/voicemail/default/"..domain_name;
	freeswitch.consoleLog("notice", "[voicemail] voicemail_dir: " .. voicemail_dir .. "\n");

--check if a file exists
	function file_exists(name)
		local f=io.open(name,"r")
		if f~=nil then io.close(f) return true else return false end
	end

--check the voicemail password
	function check_password(voicemail_id)
		--please enter your id followed by pound
			if (not voicemail_id) then
				voicemail_id = macro(session, "voicemail_id", 5000, '');
				freeswitch.consoleLog("notice", "[voicemail] voicemail id: " .. voicemail_id .. "\n");
			end
		--get the voicemail settings from the database
			if (voicemail_id ~= nil) then
				sql = [[SELECT * FROM v_voicemails
					WHERE domain_uuid = ']] .. domain_uuid ..[['
					AND voicemail_id = ']] .. voicemail_id ..[['
					AND voicemail_enabled = 'true' ]];
				if (debug["sql"]) then
					freeswitch.consoleLog("notice", "[voicemail] SQL: " .. sql .. "\n");
				end
				status = dbh:query(sql, function(row)
					voicemail_password = row["voicemail_password"];
				end);
			end
		--please enter your password followed by pound
			password = macro(session, "voicemail_password", 5000, '');
		--compare the password from the database with the password provided by the user
			if (voicemail_password ~= password) then
				--incorrect password
				macro(session, "password_not_valid", 2000, '');
				if (session:ready()) then
					check_password(voicemail_id);
				end
			end
	end

--check the voicemail password
	function change_password(voicemail_id)
		--please enter your password followed by pound
			password = macro(session, "password_new", 5000, '');
		--update the voicemail password
			sql = [[UPDATE v_voicemails
				set voicemail_password = ']] .. password ..[['
				WHERE domain_uuid = ']] .. domain_uuid ..[['
				AND voicemail_id = ']] .. voicemail_id ..[['
				AND voicemail_enabled = 'true' ]];
			if (debug["sql"]) then
				freeswitch.consoleLog("notice", "[voicemail] SQL: " .. sql .. "\n");
			end
			status = dbh:query(sql, function(row)
				voicemail_password = row["voicemail_password"];
			end);
		--you password has been changed
			macro(session, "password_changed", 5000, '');
		--advanced menu
			advanced();
	end

--define on_dtmf
	function on_dtmf(s, type, obj, arg)
		if (arg) then
			freeswitch.console_log("info", "\ntype: " .. type .. "\n" .. "arg: " .. arg .. "\n");
		else
			freeswitch.console_log("info", "\ntype: " .. type .. "\n");
		end

		if (type == "dtmf") then
			freeswitch.console_log("info", "\ndigit: [" .. obj['digit'] .. "]\nduration: [" .. obj['duration'] .. "]\n"); 
		else
			freeswitch.console_log("info", obj:serialize("xml"));
		end
	end
	--session:setInputCallback("on_dtmf", "");

--define the macro function
	function macro(session, name, max_timeout, param)
		--Please enter your id followed by
			if (name == "voicemail_id") then
				actions = {}
				table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-enter_id.wav"});
				table.insert(actions, {app="playAndGetDigits",data="digits/pound.wav"});
			end
		 --Please enter your id followed by
			if (name == "voicemail_password") then
				actions = {}
				table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-enter_pass.wav"});
				table.insert(actions, {app="playAndGetDigits",data="digits/pound.wav"});
			end
		--the person at extension 101 is not available record your message at the tone press any key or stop talking to end the recording
			if (name == "record_message") then
				actions = {}
				table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-person.wav"});
				--pronounce the voicemail_id
				table.insert(actions, {app="say.number.pronounced",data=voicemail_id});
				table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-not_available.wav"});
				table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-record_message.wav"});
			end
		--You have zero new messages
			if (name == "new_messages") then
				actions = {}
				table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-you_have.wav"});
				table.insert(actions, {app="playAndGetDigits",data="digits/"..param..".wav"});
				table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-new.wav"});
				if (param == "1") then
					table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-message.wav"});
				else
					table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-messages.wav"});
				end
			end
		--You have zero saved messages
			if (name == "saved_messages") then
				actions = {}
				table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-you_have.wav"});
				table.insert(actions, {app="playAndGetDigits",data="digits/"..param..".wav"});
				table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-saved.wav"});
				if (param == "1") then
					table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-message.wav"});
				else
					table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-messages.wav"});
				end
			end
		--To listen to new messages press 1
			if (name == "listen_to_new_messages") then
				actions = {}
				table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-listen_new.wav"});
				table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-press.wav"});
				table.insert(actions, {app="playAndGetDigits",data="digits/1.wav"});
			end
		--To listen to saved messages press 2
			if (name == "listen_to_saved_messages") then
				actions = {}
				table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-listen_saved.wav"});
				table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-press.wav"});
				table.insert(actions, {app="playAndGetDigits",data="digits/2.wav"});
			end

		--For advanced options press 5
			if (name == "advanced") then
				actions = {}
				table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-advanced.wav"});
				table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-press.wav"});
				table.insert(actions, {app="playAndGetDigits",data="digits/5.wav"});
			end
		--Advanced Options Menu
			--To record a greeting press 1
				if (name == "to_record_greeting") then
					actions = {}
					table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-to_record_greeting.wav"});
					table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-press.wav"});
					table.insert(actions, {app="playAndGetDigits",data="digits/1.wav"});
				end
				--Choose a greeting between 1 and 9
					if (name == "choose_greeting_choose") then
						actions = {}
						table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-choose_greeting_choose.wav"});
					end
				--Greeting invalid value
					if (name == "choose_greeting_fail") then
						actions = {}
						table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-choose_greeting_fail.wav"});
					end
				--recording your greeting at the tone press any key or stop talking to end the recording
					if (name == "record_greeting") then
						actions = {}
						table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-record_greeting.wav"});
					end
			--To choose greeting press 2
				if (name == "choose_greeting") then
					actions = {}
					table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-choose_greeting.wav"});
					table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-press.wav"});
					table.insert(actions, {app="playAndGetDigits",data="digits/2.wav"});
				end
				--Choose a greeting between 1 and 9
					--if (name == "choose_greeting_choose") then
					--	actions = {}
					--	table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-choose_greeting_choose"});
					--end
				--Invalid greeting number
					--if (name == "choose_greeting_fail") then
					--	actions = {}
					--	table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-choose_greeting_fail"});
					--end
			--To record your name 3
				if (name == "record_name") then
					actions = {}
					table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-record_name2.wav"});
					table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-press.wav"});
					table.insert(actions, {app="playAndGetDigits",data="digits/3.wav"});
				end
			--To change your password press 6
				if (name == "change_password") then
					actions = {}
					table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-change_password.wav"});
					table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-press.wav"});
					table.insert(actions, {app="playAndGetDigits",data="digits/6.wav"});
				end
			--For the main menu press 0
				if (name == "main_menu") then
					actions = {}
					table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-main_menu.wav"});
					table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-press.wav"});
					table.insert(actions, {app="playAndGetDigits",data="digits/0.wav"});
				end
		--To exit press #
			if (name == "to_exit_press") then
				actions = {}
				table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-to_exit.wav"});
				table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-press.wav"});
				table.insert(actions, {app="playAndGetDigits",data="digits/pound.wav"});
			end
		--Additional Macros
			--Please enter your new password then press the # key #
				if (name == "password_new") then
					actions = {}
					table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-enter_new_pin.wav"});
				end
			--Your password has been changed
				if (name == "password_changed") then
					actions = {}
					table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-password_has_been_changed.wav"});
				end
			--Login Incorrect
				--if (name == "password_not_valid") then
				--	actions = {}
				--	table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-password_not_valid.wav"});
				--end
			--Login Incorrect
				if (name == "password_not_valid") then
					actions = {}
					table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-fail_auth.wav"});
				end
			--Too many failed attempts
				if (name == "too_many_failed_attempts") then
					actions = {}
					table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-abort.wav"});
				end
			--Message number
				if (name == "message_number") then
					actions = {}
					table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-message_number.wav"});
				end
			--To listen to the recording press 1
				if (name == "listen_to_recording") then
					actions = {}
					table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-listen_to_recording.wav"});
					table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-press.wav"});
					table.insert(actions, {app="playAndGetDigits",data="digits/1.wav"});
				end
			--To save the recording press 2
				if (name == "save_recording") then
					actions = {}
					table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-save_recording.wav"});
					table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-press.wav"});
					table.insert(actions, {app="playAndGetDigits",data="digits/2.wav"});
				end
			--To delete the recording press 7
				if (name == "delete_recording") then
					actions = {}
					table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-delete_recording.wav"});
					table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-press.wav"});
					table.insert(actions, {app="playAndGetDigits",data="digits/7.wav"});
				end
			--To return the call now press 5
				if (name == "return_call") then
					actions = {}
					table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-return_call.wav"});
					table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-press.wav"});
					table.insert(actions, {app="playAndGetDigits",data="digits/5.wav"});
				end
			--To forward this message press 8
				if (name == "forward_message") then
					actions = {}
					table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-zzz.wav"});
					table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-press.wav"});
					table.insert(actions, {app="playAndGetDigits",data="digits/8.wav"});
				end
				--To add an introduction to this message press 1
					--if (name == "add_prefix_to_message") then
					--	actions = {}
					--	table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-zzz.wav"});
					--	table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-press.wav"});
					--	table.insert(actions, {app="playAndGetDigits",data="digits/1.wav"});
					--end
				--To send this message now press 2
					--if (name == "send_message") then
					--	actions = {}
					--	table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-zzz.wav"});
					--	table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-press.wav"});
					--	table.insert(actions, {app="playAndGetDigits",data="digits/2.wav"});
					--end
					--please enter the extension to send this message to followed by #
						--if (name == "send_message_to_extension") then
						--	actions = {}
						--	table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-zzz.wav"});
						--end
			--Message saved
				if (name == "message_saved") then
					actions = {}
					table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-message.wav"})
					table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-saved.wav"})
				end
		--if actions table exists then process it
			if (actions) then
				--set default values
					dtmf_digits = '';
					tries = 1;
					timeout = 100;
					max_digits = 10;
				--loop through the action and data
					for key, row in pairs(actions) do
						freeswitch.consoleLog("notice", "[directory] app: " .. row.app .. " data: " .. row.data .. "\n");
						if (string.len(dtmf_digits) == 0) then
							if (row.app == "playback") then
								session:execute(row.app, sounds_dir.."/"..default_language.."/"..default_dialect.."/"..default_voice.."/"..row.data);
							elseif (row.app == "playAndGetDigits") then
								--playAndGetDigits <min> <max> <tries> <timeout> <terminators> <file> <invalid_file> <var_name> <regexp> <digit_timeout>
								if (not file_exists(sounds_dir.."/"..default_language.."/"..default_dialect.."/"..default_voice.."/"..row.data)) then
									dtmf_digits = session:playAndGetDigits(min_digits, max_digits, tries, timeout, "#", sounds_dir.."/"..default_language.."/"..default_dialect.."/"..default_voice.."/"..row.data, "", "\\d+", max_timeout);
								else
									dtmf_digits = session:playAndGetDigits(min_digits, max_digits, tries, timeout, "#", row.data, "", "\\d+", max_timeout);
								end
							elseif (row.app == "say.number.pronounced") then
								session:say(row.data, "en", "number", "pronounced");
							else
								session:execute(row.app, row.data);
							end
						end
					end
					if (string.len(dtmf_digits) == 0) then
						dtmf_digits = session:getDigits(max_digits, "#", max_timeout);
					else
						dtmf_digits = dtmf_digits .. session:getDigits(max_digits, "#", max_timeout);
					end
				--return dtmf the digits
					return dtmf_digits;
			else
				--no dtmf digits to return
					return '';
			end
	end

--get the voicemail settings from the database
	if (voicemail_id ~= nil) then
		sql = [[SELECT * FROM v_voicemails
			WHERE domain_uuid = ']] .. domain_uuid ..[['
			AND voicemail_id = ']] .. voicemail_id ..[['
			AND voicemail_enabled = 'true' ]];
		if (debug["sql"]) then
			freeswitch.consoleLog("notice", "[voicemail] SQL: " .. sql .. "\n");
		end
		status = dbh:query(sql, function(row)
			voicemail_uuid = row["voicemail_uuid"];
			voicemail_password = row["voicemail_password"];
			greeting_id = row["greeting_id"];
			voicemail_mail_to = row["voicemail_mail_to"];
			voicemail_attach_file = row["voicemail_attach_file"];
			voicemail_local_after_email = row["voicemail_local_after_email"];
		end);
	end

--leave a voicemail
	if (voicemail_action == "save") then

		--voicemail prompt
--			if (greeting_id) then
				--play the greeting
--			else
				--if there is no greeting then play digits of the voicemail_id
				result = macro(session, "record_message", 200);
--			end

		--set the epoch
			start_epoch = os.time();
			freeswitch.consoleLog("notice", "[voicemail] start epoch: " .. start_epoch .. "\n");

		--save the recording
			-- syntax is session:recordFile(file_name, max_len_secs, silence_threshold, silence_secs)
			max_len_seconds = 30;
			silence_threshold = 30;
			silence_seconds = 5;
			result = session:recordFile(voicemail_dir.."/"..voicemail_id.."/msg_"..uuid..".wav", max_len_seconds, silence_threshold, silence_seconds);
			--session:execute("record", voicemail_dir.."/"..uuid.." 180 200");

		--set the message waiting event
			local event = freeswitch.Event("message_waiting");
			event:addHeader("MWI-Messages-Waiting", "yes");
			event:addHeader("MWI-Message-Account", "sip:"..voicemail_id.."@"..domain_name);
			event:fire();

		--set the epoch
			stop_epoch = os.time();
			freeswitch.consoleLog("notice", "[voicemail] start epoch: " .. stop_epoch .. "\n");

		--calculate the message length
			message_length = stop_epoch - start_epoch;
			freeswitch.consoleLog("notice", "[voicemail] message length: " .. message_length .. "\n");

		--send the email with the voicemail recording attached
			if (string.len(voicemail_mail_to) > 3) then
				message = [[<font face=arial>
				<b>Message From "]]..caller_id_name..[[" <A HREF="tel:]]..caller_id_number..[[">]]..caller_id_number..[[</A></b><br>
				<hr noshade size=1>
				Created: ]]..os.date("%d %b %Y", start_epoch)..[[<br>
				Duration: ]]..message_length..[[<br>
				Account: ]]..voicemail_id..[[@]]..domain_name..[[<br>
				</font>]];
				if (voicemail_attach_file == "true") then
					freeswitch.email("",
					"",
					"To: "..voicemail_mail_to.."\nFrom: "..voicemail_mail_to.."\nSubject: Voicemail from "..caller_id_name.." <"..caller_id_number.."> "..message_length,
					message,
					voicemail_dir.."/"..voicemail_id.."/msg_"..uuid..".wav"
					);
				else
					freeswitch.email("",
						"",
						"To: "..voicemail_mail_to.."\nFrom: "..voicemail_mail_to.."\nSubject: Voicemail from "..caller_id_name.." <"..caller_id_number.."> "..message_length,
						message
					);
				end
			end

		--save the message to the voicemail messages
			local sql = {}
			table.insert(sql, "INSERT INTO v_voicemail_messages ");
			table.insert(sql, "(");
			table.insert(sql, "voicemail_message_uuid, ");
			table.insert(sql, "domain_uuid, ");
			table.insert(sql, "voicemail_uuid, ");
			table.insert(sql, "created_epoch, ");
			table.insert(sql, "caller_id_name, ");
			table.insert(sql, "caller_id_number, ");
			table.insert(sql, "message_length ");
			--table.insert(sql, "message_status, ");
			--table.insert(sql, "message_priority, ");
			table.insert(sql, ") ");
			table.insert(sql, "VALUES ");
			table.insert(sql, "( ");
			table.insert(sql, "'".. uuid .."', ");
			table.insert(sql, "'".. domain_uuid .."', ");
			table.insert(sql, "'".. voicemail_uuid .."', ");
			table.insert(sql, "'".. start_epoch .."', ");
			table.insert(sql, "'".. caller_id_name .."', ");
			table.insert(sql, "'".. caller_id_number .."', ");
			table.insert(sql, "'".. message_length .."' ");
			--table.insert(sql, "'".. message_status .."', ");
			--table.insert(sql, "'".. message_priority .."' ");
			table.insert(sql, ") ");
			if (voicemail_local_after_email == "true") then
				sql = table.concat(sql, "\n");
			end
			if (debug["sql"]) then
				freeswitch.consoleLog("notice", "[voicemail] SQL: " .. sql .. "\n");
			end
			dbh:query(sql);

		--local after email is false so delete the recording file
			if (voicemail_local_after_email == "false") then
				os.remove(voicemail_dir.."/"..voicemail_id.."/msg_"..uuid..".wav");
			end
	end

function main_menu ()
	--new voicemail count
		if (voicemail_id ~= nil) then
			sql = [[SELECT count(*) as new_messages FROM v_voicemail_messages
				WHERE domain_uuid = ']] .. domain_uuid ..[['
				AND voicemail_uuid = ']] .. voicemail_uuid ..[['
				AND (message_status is null or message_status = '') ]];
			if (debug["sql"]) then
				freeswitch.consoleLog("notice", "[voicemail] SQL: " .. sql .. "\n");
			end
			status = dbh:query(sql, function(row)
				new_messages = row["new_messages"];
			end);
		end
		dtmf_digits = macro(session, "new_messages", 200, new_messages);
	--saved voicemail count
		if (string.len(dtmf_digits) == 0) then
			if (voicemail_id ~= nil) then
				sql = [[SELECT count(*) as saved_messages FROM v_voicemail_messages
					WHERE domain_uuid = ']] .. domain_uuid ..[['
					AND voicemail_uuid = ']] .. voicemail_uuid ..[['
					AND message_status = 'saved' ]];
				if (debug["sql"]) then
					freeswitch.consoleLog("notice", "[voicemail] SQL: " .. sql .. "\n");
				end
				status = dbh:query(sql, function(row)
					saved_messages = row["saved_messages"];
				end);
			end
			dtmf_digits = macro(session, "saved_messages", 200, saved_messages);
		end
	--to listen to new message
		if (string.len(dtmf_digits) == 0) then
			dtmf_digits = macro(session, "listen_to_new_messages", 200, '');
		end
	--to listen to saved message
		if (string.len(dtmf_digits) == 0) then
			dtmf_digits = macro(session, "listen_to_saved_messages", 200, '');
		end
	--for advanced options
		if (string.len(dtmf_digits) == 0) then
			dtmf_digits = macro(session, "advanced", 200, '');
		end
	--to exit press #
		if (string.len(dtmf_digits) == 0) then
			dtmf_digits = macro(session, "to_exit_press", 5000, '');
		end
	--process the dtmf
		if (dtmf_digits == "1") then
			menu_messages("new");
		elseif (dtmf_digits == "2") then
			menu_messages("saved");
		elseif (dtmf_digits == "5") then
			advanced();
		elseif (dtmf_digits == "#") then
			session:hangup();
		else
			if (session:ready()) then
				main_menu();
			end
		end
end

function listen_to_recording (message_number, uuid, created_epoch, caller_id_name, caller_id_number)

	--set the display
		api = freeswitch.API();
		reply = api:executeString("uuid_display "..session:get_uuid().." "..caller_id_number);
	--say the message number
		dtmf_digits = macro(session, "message_number", 200, '');
	--say the number
		session:say(message_number, "en", "NUMBER", "pronounced");
	--say the message date
		session:say(created_epoch, "en", "CURRENT_DATE_TIME", "pronounced");
	--play the message
		if (string.len(dtmf_digits) == 0) then
			dtmf_digits = session:playAndGetDigits(min_digits, max_digits, tries, timeout, "#", voicemail_dir.."/"..voicemail_id.."/msg_"..uuid..".wav", "", "\\d+", max_timeout);
		end
	--to listen to the recording press 1
		if (string.len(dtmf_digits) == 0) then
			dtmf_digits = macro(session, "listen_to_recording", 200, '');
		end
	--to save the recording press 2
		if (string.len(dtmf_digits) == 0) then
			dtmf_digits = macro(session, "save_recording", 200, '');
		end
	--to delete the recording press 7
		if (string.len(dtmf_digits) == 0) then
			dtmf_digits = macro(session, "delete_recording", 200, '');
		end
	--to return the call now press 5
		if (string.len(dtmf_digits) == 0) then
			dtmf_digits = macro(session, "return_call", 200, '');
		end
	--to forward this message press 8
		--to add an introduction to this message press 1
		--to send this message now 2
			--please enter the extension to send this message to followed by #
	--process the dtmf
		if (dtmf_digits == "1") then
			listen_to_recording(message_number, uuid, created_epoch, caller_id_name, caller_id_number);
		elseif (dtmf_digits == "2") then
			message_saved(uuid);
			macro(session, "message_saved", 200, '');
		elseif (dtmf_digits == "7") then
			delete_recording(uuid);
		elseif (dtmf_digits == "5") then
			return_call(caller_id_number);
		else
			--message_saved();
		end
end

function message_saved(uuid)
	--delete from the database
		sql = [[UPDATE v_voicemail_messages SET message_status = 'saved'
			WHERE domain_uuid = ']] .. domain_uuid ..[['
			AND voicemail_message_uuid = ']] .. uuid ..[[']];
		if (debug["sql"]) then
			freeswitch.consoleLog("notice", "[voicemail] SQL: " .. sql .. "\n");
		end
		dbh:query(sql);
end

function delete_recording(uuid)
	--delete the file
		os.remove(voicemail_dir.."/"..voicemail_id.."/msg_"..uuid..".wav");
	--delete from the database
		sql = [[DELETE FROM v_voicemail_messages
			WHERE domain_uuid = ']] .. domain_uuid ..[['
			AND voicemail_message_uuid = ']] .. uuid ..[[']];
		if (debug["sql"]) then
			freeswitch.consoleLog("notice", "[voicemail] SQL: " .. sql .. "\n");
		end
		dbh:query(sql);
end

function return_call(destination)
	session:transfer(destination, "XML", context);
end

function menu_messages (message_status)
	--set default values
		max_timeout = 2000;
		min_digits = 1;
		max_digits = 1;
		tries =1;
		timeout = 2000;
	--set the message number
		message_number = 0;
	--message_status new,saved
		if (voicemail_id ~= nil) then
			sql = [[SELECT * FROM v_voicemail_messages
				WHERE domain_uuid = ']] .. domain_uuid ..[['
				AND voicemail_uuid = ']] .. voicemail_uuid ..[[']]
			if (message_status == "new") then
				sql = sql .. [[AND (message_status is null or message_status = '') ]];
			elseif (message_status == "saved") then
				sql = sql .. [[AND message_status = 'saved' ]];
			end
			if (debug["sql"]) then
				freeswitch.consoleLog("notice", "[voicemail] SQL: " .. sql .. "\n");
			end
			status = dbh:query(sql, function(row)
				--get the values from the database
					--row["voicemail_message_uuid"];
					--row["created_epoch"];
					--row["caller_id_name"];
					--row["caller_id_number"];
					--row["message_length"];
					--row["message_status"];
					--row["message_priority"];
				--increment the message count
					message_number = message_number + 1;
				--listen to the message
					freeswitch.consoleLog("notice", message_number.." "..string.lower(row["voicemail_message_uuid"]).." "..row["created_epoch"]);
					listen_to_recording(message_number, string.lower(row["voicemail_message_uuid"]), row["created_epoch"], row["caller_id_name"], row["caller_id_number"]);
			end);
		end

	--voicemail count if zero new messages set the mwi to no
		if (voicemail_id ~= nil) then
			sql = [[SELECT count(*) as new_messages FROM v_voicemail_messages
				WHERE domain_uuid = ']] .. domain_uuid ..[['
				AND voicemail_uuid = ']] .. voicemail_uuid ..[['
				AND (message_status is null or message_status = '') ]];
			if (debug["sql"]) then
				freeswitch.consoleLog("notice", "[voicemail] SQL: " .. sql .. "\n");
			end
			status = dbh:query(sql, function(row)
				if (row["new_messages"] == "0") then
					--send the message waiting event
					local event = freeswitch.Event("message_waiting");
					event:addHeader("MWI-Messages-Waiting", "no");
					event:addHeader("MWI-Message-Account", "sip:"..voicemail_id.."@"..domain_name);
					event:fire();
				end
			end);
		end

	--set the display
		api = freeswitch.API();
		reply = api:executeString("uuid_display "..session:get_uuid().." "..destination_number);

	--send back to the main menu
		main_menu();
end

function advanced ()
	--To record a greeting press 1
		dtmf_digits = macro(session, "to_record_greeting", 200, '');
	--To choose greeting press 2
		if (string.len(dtmf_digits) == 0) then
			dtmf_digits = macro(session, "choose_greeting", 200, '');
		end
	--To record your name 3
		if (string.len(dtmf_digits) == 0) then
			dtmf_digits = macro(session, "record_name", 200, '');
		end
	--To change your password press 6
		if (string.len(dtmf_digits) == 0) then
			dtmf_digits = macro(session, "change_password", 200, '');
		end
	--For the main menu press 0
		if (string.len(dtmf_digits) == 0) then
			dtmf_digits = macro(session, "main_menu", 5000, '');
		end
	--process the dtmf
		if (dtmf_digits == "1") then
			--To record a greeting press 1
			record_greeting();
		elseif (dtmf_digits == "2") then
			--To choose greeting press 2
			choose_greeting();
		elseif (dtmf_digits == "3") then
			--To record your name 3
			record_name();
		elseif (dtmf_digits == "6") then
			--To change your password press 6
			change_password(voicemail_id);
		elseif (dtmf_digits == "0") then
			--For the main menu press 0
			main_menu();
		else
			if (session:ready()) then
				advanced();
			end
		end
end

--check voicemail
	if (voicemail_action == "check") then
		--check the voicemail password
		check_password(voicemail_id);
		main_menu();
	end

--notes
	--record the video
		--records audio only
			--session:recordFile(file_name, max_len_secs, silence_threshold, silence_secs);
			--result = session:execute("set", "enable_file_write_buffering=false");
			--session:recordFile("/tmp/recording.fsv", 200, 200, 200);
		--records audio and video
			--result = session:execute("record_fsv", "file.fsv");
			--freeswitch.consoleLog("notice", "[voicemail] SQL: " .. result .. "\n");

	--play the video recording
		--plays the video
			--result = session:execute("play_fsv", "/tmp/recording.fsv");
		--plays the file but without the video
			--dtmf = session:playAndGetDigits(min_digits, max_digits, max_tries, digit_timeout, "#", "/tmp/recording.fsv", "", "\\d+");
		--freeswitch.consoleLog("notice", "[voicemail] SQL: " .. result .. "\n");

	--callback (works with DTMF)
		--http://wiki.freeswitch.org/wiki/Mod_fsv
		--session:recordFile(file_name, max_len_secs, silence_threshold, silence_secs) 
		--session:sayPhrase(macro_name [,macro_data] [,language]);
		--session:sayPhrase("voicemail_menu", "1:2:3:#", "en");
		--session:streamFile("directory/dir-to_select_entry.wav"); --works with setInputCallback
		--session:say("12345", "en", "number", "pronounced");
		--speak
			--session:set_tts_parms("flite", "kal");
			--session:speak("Please say the name of the person you're trying to contact");

	--callback (execute and executeString does not work with DTMF)
		--session:execute(api_string);
		--session:executeString("playback "..mySound);

	--uuid_video_refresh
		--uuid_video_refresh,<uuid>,Send video refresh.,mod_commands
		--may be used to clear video buffer before using record_fsv