diff --git a/includes/install/scripts/voicemail.lua b/includes/install/scripts/voicemail.lua index 9aaf46a4b5..902d342c74 100644 --- a/includes/install/scripts/voicemail.lua +++ b/includes/install/scripts/voicemail.lua @@ -89,7 +89,7 @@ --set the voicemail_dir voicemail_dir = base_dir.."/storage/voicemail/default/"..domain_name; - freeswitch.consoleLog("notice", "[voicemail] voicemail_dir: " .. voicemail_dir .. "\n"); + --freeswitch.consoleLog("notice", "[voicemail] voicemail_dir: " .. voicemail_dir .. "\n"); --check if a file exists function file_exists(name) @@ -112,71 +112,77 @@ --get the voicemail id function get_voicemail_id() - id = macro(session, "voicemail_id", 5000, ''); - if (string.len(id) == 0) then + voicemail_id = macro(session, "voicemail_id", 5000, ''); + if (string.len(voicemail_id) == 0) then if (session:ready()) then - id = get_voicemail_id(); + voicemail_id = get_voicemail_id(); end - else - return id; end + return voicemail_id; end --check the voicemail password function check_password(voicemail_id) - --please enter your id followed by pound - if (not voicemail_id) then - voicemail_id = get_voicemail_id(); - 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 + if (session:ready()) then + --please enter your id followed by pound + if (voicemail_id) then + --do nothing + else + voicemail_id = get_voicemail_id(); + --freeswitch.consoleLog("notice", "[voicemail] voicemail id: " .. voicemail_id .. "\n"); + end + + --get the voicemail settings from the database + if (voicemail_id) 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 = string.lower(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 + --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", 1000, ''); + if (session:ready()) then + check_password(voicemail_id); + end + end + end + end + +--check the voicemail password + function change_password(voicemail_id) + if (session:ready()) then + --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_uuid = string.lower(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 - --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", 1000, ''); - 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 - dbh:query(sql); - --has been changed to - macro(session, "password_changed", 3000, password); - --advanced menu - advanced(); + dbh:query(sql); + --has been changed to + macro(session, "password_changed", 3000, password); + --advanced menu + advanced(); + end end --define on_dtmf @@ -197,312 +203,313 @@ --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 == "person_not_available_record_message") then - actions = {} - table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-person.wav"}); - --pronounce the voicemail_id - table.insert(actions, {app="say.number.iterated",data=voicemail_id}); - table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-not_available.wav"}); - end - --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-record_message.wav"}); - table.insert(actions, {app="tone_stream",data="L=1;%(1000, 0, 640)"}); - end - --to listen to the recording press 1 - if (name == "to_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 == "to_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 rerecord press 3 - if (name == "to_rerecord") then - actions = {} - table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-rerecord.wav"}); - table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-press.wav"}); - table.insert(actions, {app="playAndGetDigits",data="digits/3.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 + if (session:ready()) then + --Please enter your id followed by + if (name == "voicemail_id") 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"}); + table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-enter_id.wav"}); + table.insert(actions, {app="playAndGetDigits",data="digits/pound.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 - --Record 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"}); - table.insert(actions, {app="tone_stream",data="L=1;%(1000, 0, 640)"}); - end - --To choose greeting press 2 - if (name == "choose_greeting") then + --Please enter your id followed by + if (name == "voicemail_password") 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"}); + table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-enter_pass.wav"}); + table.insert(actions, {app="playAndGetDigits",data="digits/pound.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 - --press 1 to listen to the recording - --press 2 to save the recording - --message saved - --press 3 to re-record - --Invalid greeting number - --if (name == "choose_greeting_fail") then - -- actions = {} - -- table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-choose_greeting_fail.wav"}); - --end - --Greeting 1 selected - if (name == "greeting_selected") then - actions = {} - table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-greeting.wav"}); - table.insert(actions, {app="playAndGetDigits",data="digits/"..param..".wav"}); - table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-selected.wav"}); - end - - --To record your name 3 - if (name == "to_record_name") then + --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 == "person_not_available_record_message") 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"}); + table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-person.wav"}); + --pronounce the voicemail_id + table.insert(actions, {app="say.number.iterated",data=voicemail_id}); + table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-not_available.wav"}); end - --At the tone please record your name press any key or stop talking to end the recording - if (name == "record_name") then + --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-record_name1.wav"}); + table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-record_message.wav"}); table.insert(actions, {app="tone_stream",data="L=1;%(1000, 0, 640)"}); 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/star.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 - --Has been changed to - if (name == "password_changed") then - actions = {} - table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-has_been_changed_to.wav"}); - table.insert(actions, {app="say.number.iterated",data=param}); - 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 + --to listen to the recording press 1 + if (name == "to_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 + --to save the recording press 2 + if (name == "to_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 + --to rerecord press 3 + if (name == "to_rerecord") then actions = {} - table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-delete_recording.wav"}); + table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-rerecord.wav"}); table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-press.wav"}); - table.insert(actions, {app="playAndGetDigits",data="digits/7.wav"}); + table.insert(actions, {app="playAndGetDigits",data="digits/3.wav"}); end - --Message deleted - if (name == "message_deleted") then - table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-message.wav"}); - table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-deleted.wav"}); - end - --To return the call now press 5 - if (name == "return_call") then + --You have zero new messages + if (name == "new_messages") then actions = {} - table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-return_call.wav"}); + 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 - --To forward this message press 8 - if (name == "to_forward_message") then - actions = {} - table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-to_forward.wav"}); - table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-press.wav"}); - table.insert(actions, {app="playAndGetDigits",data="digits/8.wav"}); - end - --Please enter the extension to forward this message to followed by # - if (name == "forward_enter_extension") then - actions = {} - table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-forward_enter_ext.wav"}); - table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-followed_by_pound.wav"}); - end - --To forward this recording to your email press 9 - if (name == "forward_to_email") then - actions = {} - table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-forward_to_email.wav"}); - table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-press.wav"}); - table.insert(actions, {app="playAndGetDigits",data="digits/9.wav"}); - end - --Emailed - if (name == "emailed") then - actions = {} - table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-emailed.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 - --Your recording is below the minimal acceptable length, please try again. - if (name == "too_small") then - actions = {} - table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-too-small.wav"}); - end - --Goodbye - if (name == "goodbye") then - actions = {} - table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-goodbye.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 + --Record 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"}); + table.insert(actions, {app="tone_stream",data="L=1;%(1000, 0, 640)"}); + 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.wav"}); + --end + --press 1 to listen to the recording + --press 2 to save the recording + --message saved + --press 3 to re-record + --Invalid greeting number + --if (name == "choose_greeting_fail") then + -- actions = {} + -- table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-choose_greeting_fail.wav"}); + --end + --Greeting 1 selected + if (name == "greeting_selected") then + actions = {} + table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-greeting.wav"}); + table.insert(actions, {app="playAndGetDigits",data="digits/"..param..".wav"}); + table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-selected.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 == "tone_stream") then + --To record your name 3 + if (name == "to_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 + --At the tone please record your name press any key or stop talking to end the recording + if (name == "record_name") then + actions = {} + table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-record_name1.wav"}); + table.insert(actions, {app="tone_stream",data="L=1;%(1000, 0, 640)"}); + 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/star.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 + --Has been changed to + if (name == "password_changed") then + actions = {} + table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-has_been_changed_to.wav"}); + table.insert(actions, {app="say.number.iterated",data=param}); + 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 + --Message deleted + if (name == "message_deleted") then + table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-message.wav"}); + table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-deleted.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 == "to_forward_message") then + actions = {} + table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-to_forward.wav"}); + table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-press.wav"}); + table.insert(actions, {app="playAndGetDigits",data="digits/8.wav"}); + end + --Please enter the extension to forward this message to followed by # + if (name == "forward_enter_extension") then + actions = {} + table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-forward_enter_ext.wav"}); + table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-followed_by_pound.wav"}); + end + --To forward this recording to your email press 9 + if (name == "forward_to_email") then + actions = {} + table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-forward_to_email.wav"}); + table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-press.wav"}); + table.insert(actions, {app="playAndGetDigits",data="digits/9.wav"}); + end + --Emailed + if (name == "emailed") then + actions = {} + table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-emailed.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 + --Your recording is below the minimal acceptable length, please try again. + if (name == "too_small") then + actions = {} + table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-too-small.wav"}); + end + --Goodbye + if (name == "goodbye") then + actions = {} + table.insert(actions, {app="playAndGetDigits",data="voicemail/vm-goodbye.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", "[voicemail] 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 == "tone_stream") then session:execute("playback", "tone_stream://"..row.data); elseif (row.app == "playAndGetDigits") then --playAndGetDigits @@ -531,43 +538,781 @@ --no dtmf digits to return return ''; end + end end --get the voicemail settings if (voicemail_id ~= nil) then - --get the information from the database - 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 = string.lower(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); - --set default values - if (string.len(voicemail_local_after_email) == 0) then - voicemail_local_after_email = "true"; - end - if (string.len(voicemail_attach_file) == 0) then - voicemail_attach_file = "true"; - end + if (session:ready()) then + --get the information from the database + 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 = string.lower(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); + --set default values + if (string.len(voicemail_local_after_email) == 0) then + voicemail_local_after_email = "true"; + end + if (string.len(voicemail_attach_file) == 0) then + voicemail_attach_file = "true"; + end + end end --save the recording function record_message() - --record your message at the tone press any key or stop talking to end the recording - result = macro(session, "record_message", 100); + if (session:ready()) then + --record your message at the tone press any key or stop talking to end the recording + result = macro(session, "record_message", 100); - --start epoch - start_epoch = os.time(); - freeswitch.consoleLog("notice", "[voicemail] start epoch: " .. start_epoch .. "\n"); + --start 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; + os.execute("mkdir -p " .. voicemail_dir.."/"..voicemail_id); + 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"); + + --stop epoch + stop_epoch = os.time(); + freeswitch.consoleLog("notice", "[voicemail] start epoch: " .. stop_epoch .. "\n"); + + --calculate the message length + message_length = stop_epoch - start_epoch; + message_length_formatted = format_seconds(message_length); + freeswitch.consoleLog("notice", "[voicemail] message length: " .. message_length .. "\n"); + + --if the recording is below the minmal length then re-record the message + if (message_length < 4) then + if (session:ready()) then + --your recording is below the minimal acceptable length, please try again + macro(session, "too_small", 100); + --record your message at the tone + record_message(); + end + end + + --record menu 1 listen to the recording, 2 save the recording, 3 re-record + record_menu(); + end + end + +--record message menu + function record_menu() + if (session:ready()) then + --clear the dtmf digits variable + dtmf_digits = ''; + --to listen to the recording press 1 + if (string.len(dtmf_digits) == 0) then + dtmf_digits = macro(session, "to_listen_to_recording", 100, ''); + end + --to save the recording press 2 + if (string.len(dtmf_digits) == 0) then + dtmf_digits = macro(session, "to_save_recording", 100, ''); + end + --to re-record press 3 + if (string.len(dtmf_digits) == 0) then + dtmf_digits = macro(session, "to_rerecord", 3000, ''); + end + --process the dtmf + if (dtmf_digits == "1") then + --listen to the recording + dtmf_digits = session:playAndGetDigits(min_digits, max_digits, tries, timeout, "#", voicemail_dir.."/"..voicemail_id.."/msg_"..uuid..".wav", "", "\\d+", 1000); + --record menu 1 listen to the recording, 2 save the recording, 3 re-record + record_menu(); + elseif (dtmf_digits == "2") then + --save the message + macro(session, "message_saved", 100, ''); + macro(session, "goodbye", 100, ''); + --hangup the call + session:hangup(); + elseif (dtmf_digits == "3") then + --rerecord the message + record_message(); + elseif (dtmf_digits == "*") then + --hangup + macro(session, "goodbye", 100, ''); + session:hangup(); + else + if (session:ready()) then + record_menu(); + end + end + end + end + +--define a function to send email + function send_email(uuid) + if (session:ready()) then + --get voicemail message details + sql = [[SELECT * 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 + status = dbh:query(sql, function(row) + --get the values from the database + --uuid = row["voicemail_message_uuid"]; + --created_epoch = row["created_epoch"]; + caller_id_name = row["caller_id_name"]; + caller_id_number = row["caller_id_number"]; + message_length = row["message_length"]; + --message_status = row["message_status"]; + --message_priority = row["message_priority"]; + end); + + --calculate the message length + message_length_formatted = format_seconds(message_length); + freeswitch.consoleLog("notice", "[voicemail] message length: " .. message_length .. "\n"); + + --send the email + message = [[ + Message From "]]..caller_id_name..[[" ]]..caller_id_number..[[
+
+ Created: ]]..os.date("%A, %d %b %Y %I:%M %p", start_epoch)..[[
+ Duration: ]]..message_length_formatted..[[
+ Account: ]]..voicemail_id..[[@]]..domain_name..[[
+ ]]; + 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_formatted, + 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_formatted, + message + ); + end + end + end + +--define a function to forward a message to an extension + function forward_to_extension(uuid) + if (session:ready()) then + --get voicemail message details + sql = [[SELECT * 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 + status = dbh:query(sql, function(row) + --get the values from the database + created_epoch = row["created_epoch"]; + caller_id_name = row["caller_id_name"]; + caller_id_number = row["caller_id_number"]; + message_length = row["message_length"]; + message_status = row["message_status"]; + message_priority = row["message_priority"]; + end); + + --request the forward_voicemail_id + forward_voicemail_id = macro(session, "forward_enter_extension", 7000, ''); + if (string.len(forward_voicemail_id) == 0) then + forward_voicemail_id = macro(session, "forward_enter_extension", 7000, ''); + end + if (string.len(forward_voicemail_id) == 0) then + forward_voicemail_id = macro(session, "forward_enter_extension", 7000, ''); + end + + --get the voicemail settings using the voicemail_uuid + sql = [[SELECT * FROM v_voicemails + WHERE domain_uuid = ']] .. domain_uuid ..[[' + AND voicemail_id = ']] .. forward_voicemail_id ..[[' + AND voicemail_enabled = 'true' ]]; + if (debug["sql"]) then + freeswitch.consoleLog("notice", "[voicemail] SQL: " .. sql .. "\n"); + end + status = dbh:query(sql, function(row) + forward_voicemail_uuid = string.lower(row["voicemail_uuid"]); + forward_voicemail_mail_to = row["voicemail_mail_to"]; + forward_voicemail_attach_file = row["voicemail_attach_file"]; + forward_voicemail_local_after_email = row["voicemail_local_after_email"]; + end); + + --set default values + if (string.len(forward_voicemail_attach_file) == 0) then + forward_voicemail_attach_file = "true"; + end + if (string.len(forward_voicemail_local_after_email) == 0) then + forward_voicemail_local_after_email = "true"; + 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, "'".. forward_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, ") "); + 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); + + --set the message waiting event + local event = freeswitch.Event("message_waiting"); + event:addHeader("MWI-Messages-Waiting", "yes"); + event:addHeader("MWI-Message-Account", "sip:"..forward_voicemail_id.."@"..domain_name); + event:fire(); + + --local after email is true so copy the recording file + if (voicemail_local_after_email == "true") then + os.execute("mkdir -p " .. voicemail_dir.."/"..forward_voicemail_id); + os.execute("cp "..voicemail_dir.."/"..voicemail_id.."/msg_"..uuid..".wav "..voicemail_dir.."/"..forward_voicemail_id.."/msg_"..uuid..".wav"); + end + + --send the email with the voicemail recording attached + if (string.len(forward_voicemail_mail_to) > 3) then + send_email(uuid); + end + end + end + +--leave a voicemail + if (voicemail_action == "save") then + if (session:ready()) then + --voicemail prompt + if (string.len(greeting_id) > 0) then + --play the greeting + session:streamFile(voicemail_dir.."/"..voicemail_id.."/greeting_"..greeting_id..".wav"); + else + --if there is no greeting then play digits of the voicemail_id + result = macro(session, "person_not_available_record_message", 100); + end + + --save the recording + record_message(); + + --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); + + --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(); + + --send the email with the voicemail recording attached + if (string.len(voicemail_mail_to) > 3) then + send_email(uuid); + end + + --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 + end + +function main_menu () + if (voicemail_uuid) then + --clear the value + dtmf_digits = ''; + --new voicemail count + 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); + dtmf_digits = macro(session, "new_messages", 100, new_messages); + --saved voicemail count + if (string.len(dtmf_digits) == 0) 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); + dtmf_digits = macro(session, "saved_messages", 100, saved_messages); + end + --to listen to new message + if (string.len(dtmf_digits) == 0) then + dtmf_digits = macro(session, "listen_to_new_messages", 100, ''); + end + --to listen to saved message + if (string.len(dtmf_digits) == 0) then + dtmf_digits = macro(session, "listen_to_saved_messages", 100, ''); + end + --for advanced options + if (string.len(dtmf_digits) == 0) then + dtmf_digits = macro(session, "advanced", 100, ''); + end + --to exit press # + if (string.len(dtmf_digits) == 0) then + dtmf_digits = macro(session, "to_exit_press", 3000, ''); + 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 == "0") then + session:transfer("0", "XML", context); + elseif (dtmf_digits == "*") then + macro(session, "goodbye", 100, ''); + session:hangup(); + else + if (session:ready()) then + main_menu(); + end + end + end +end + +function listen_to_recording (message_number, uuid, created_epoch, caller_id_name, caller_id_number) + if (session:ready()) then + --clear the value + dtmf_digits = ''; + --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", 100, ''); + --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", 100, ''); + end + --to save the recording press 2 + if (string.len(dtmf_digits) == 0) then + dtmf_digits = macro(session, "save_recording", 100, ''); + end + --to return the call now press 5 + if (string.len(dtmf_digits) == 0) then + dtmf_digits = macro(session, "return_call", 100, ''); + end + --to delete the recording press 7 + if (string.len(dtmf_digits) == 0) then + dtmf_digits = macro(session, "delete_recording", 100, ''); + end + --to forward this message press 8 + if (string.len(dtmf_digits) == 0) then + dtmf_digits = macro(session, "to_forward_message", 100, ''); + end + --to forward this recording to your email press 9 + if (string.len(dtmf_digits) == 0) then + dtmf_digits = macro(session, "forward_to_email", 100, ''); + end + --wait for more digits + if (string.len(dtmf_digits) == 0) then + dtmf_digits = session:getDigits(max_digits, "#", 3000); + end + --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", 100, ''); + elseif (dtmf_digits == "5") then + return_call(caller_id_number); + elseif (dtmf_digits == "7") then + delete_recording(uuid); + elseif (dtmf_digits == "8") then + forward_to_extension(uuid); + macro(session, "message_saved", 100, ''); + elseif (dtmf_digits == "9") then + send_email(uuid); + macro(session, "emailed", 100); + elseif (dtmf_digits == "*") then + main_menu(); + elseif (dtmf_digits == "0") then + session:transfer("0", "XML", context); + else + message_saved(uuid); + macro(session, "message_saved", 100, ''); + end + end +end + +--voicemail count if zero new messages set the mwi to no + function message_waiting() + if (session:ready()) then + 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(); + else + --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(); + end + end); + end + end + end + +--delete the recording + function delete_recording(uuid) + if (session:ready()) then + --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); + --message deleted + macro(session, "message_deleted", 100, ''); + --check the message waiting status + message_waiting(); + end + end + +--save the message + function message_saved(uuid) + if (session:ready()) then + --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); + --check the message waiting status + message_waiting(); + end + end + +--return the call + function return_call(destination) + if (session:ready()) then + --check the message waiting status + message_waiting(); + --transfer the call + session:transfer(destination, "XML", context); + end + end + +function menu_messages (message_status) + if (session:ready()) then + --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 + if (session:ready()) then + 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); + 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 +end + +function advanced () + if (session:ready()) then + --To record a greeting press 1 + dtmf_digits = macro(session, "to_record_greeting", 100, ''); + --To choose greeting press 2 + if (string.len(dtmf_digits) == 0) then + dtmf_digits = macro(session, "choose_greeting", 100, ''); + end + --To record your name 3 + if (string.len(dtmf_digits) == 0) then + dtmf_digits = macro(session, "to_record_name", 100, ''); + end + --To change your password press 6 + if (string.len(dtmf_digits) == 0) then + dtmf_digits = macro(session, "change_password", 100, ''); + 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 +end + +function record_greeting() + if (session:ready()) then + --Choose a greeting between 1 and 9 + greeting_id = macro(session, "choose_greeting_choose", 5000, ''); + + --validate the greeting_id + if (greeting_id == "1" + or greeting_id == "2" + or greeting_id == "3" + or greeting_id == "4" + or greeting_id == "5" + or greeting_id == "6" + or greeting_id == "7" + or greeting_id == "8" + or greeting_id == "9") then + + --record your greeting at the tone press any key or stop talking to end the recording + macro(session, "record_greeting", 100, ''); + + --record the greeting + max_len_seconds = 30; + silence_threshold = 30; + silence_seconds = 5; + os.execute("mkdir -p " .. voicemail_dir.."/"..voicemail_id); + -- syntax is session:recordFile(file_name, max_len_secs, silence_threshold, silence_secs) + result = session:recordFile(voicemail_dir.."/"..voicemail_id.."/greeting_"..greeting_id..".wav", max_len_seconds, silence_threshold, silence_seconds); + --session:execute("record", voicemail_dir.."/"..uuid.." 180 200"); + + --advanced menu + advanced(); + else + --invalid greeting_id + greeting_id = macro(session, "choose_greeting_fail", 100, ''); + + --send back to choose the greeting + if (session:ready()) then + record_greeting(); + end + end + end +end + +function choose_greeting() + if (session:ready()) then + --select the greeting + greeting_id = macro(session, "choose_greeting_choose", 5000, ''); + + --check to see if the greeting file exists + if (not file_exists(voicemail_dir.."/"..voicemail_id.."/greeting_"..greeting_id..".wav")) then + --invalid greeting_id file does not exist + greeting_id = "invalid"; + end + + --validate the greeting_id + if (greeting_id == "0" + or greeting_id == "1" + or greeting_id == "2" + or greeting_id == "3" + or greeting_id == "4" + or greeting_id == "5" + or greeting_id == "6" + or greeting_id == "7" + or greeting_id == "8" + or greeting_id == "9") then + + --valid greeting_id update the database + if (greeting_id == "0") then + sql = [[UPDATE v_voicemails SET greeting_id = null ]]; + else + sql = [[UPDATE v_voicemails SET greeting_id = ']]..greeting_id..[[' ]]; + end + sql = sql ..[[WHERE domain_uuid = ']] .. domain_uuid ..[[' ]] + sql = sql ..[[AND voicemail_uuid = ']] .. voicemail_uuid ..[[' ]]; + if (debug["sql"]) then + freeswitch.consoleLog("notice", "[voicemail] SQL: " .. sql .. "\n"); + end + dbh:query(sql); + + --play the greeting + session:streamFile(voicemail_dir.."/"..voicemail_id.."/greeting_"..greeting_id..".wav"); + + --greeting selected + macro(session, "greeting_selected", 100, greeting_id); + + --advanced menu + advanced(); + else + --invalid greeting_id + greeting_id = macro(session, "choose_greeting_fail", 100, ''); + + --send back to choose the greeting + if (session:ready()) then + choose_greeting(); + end + end + + --advanced menu + advanced(); + end +end + +function record_name() + if (session:ready()) then + --play the name record + macro(session, "record_name", 100, ''); --save the recording -- syntax is session:recordFile(file_name, max_len_secs, silence_threshold, silence_secs) @@ -575,726 +1320,27 @@ silence_threshold = 30; silence_seconds = 5; os.execute("mkdir -p " .. voicemail_dir.."/"..voicemail_id); - result = session:recordFile(voicemail_dir.."/"..voicemail_id.."/msg_"..uuid..".wav", max_len_seconds, silence_threshold, silence_seconds); + result = session:recordFile(voicemail_dir.."/"..voicemail_id.."/recorded_name.wav", max_len_seconds, silence_threshold, silence_seconds); --session:execute("record", voicemail_dir.."/"..uuid.." 180 200"); - --stop epoch - stop_epoch = os.time(); - freeswitch.consoleLog("notice", "[voicemail] start epoch: " .. stop_epoch .. "\n"); + --play the greeting + session:streamFile(voicemail_dir.."/"..voicemail_id.."/recorded_name.wav"); - --calculate the message length - message_length = stop_epoch - start_epoch; - message_length_formatted = format_seconds(message_length); - freeswitch.consoleLog("notice", "[voicemail] message length: " .. message_length .. "\n"); + --message saved + macro(session, "message_saved", 100, ''); - --if the recording is below the minmal length then re-record the message - if (message_length < 4) then - if (session:ready()) then - --your recording is below the minimal acceptable length, please try again - macro(session, "too_small", 100); - --record your message at the tone - record_message(); - end - end - - --record menu 1 listen to the recording, 2 save the recording, 3 re-record - record_menu(); - end - ---record message menu - function record_menu() - --clear the dtmf digits variable - dtmf_digits = ''; - --to listen to the recording press 1 - if (string.len(dtmf_digits) == 0) then - dtmf_digits = macro(session, "to_listen_to_recording", 100, ''); - end - --to save the recording press 2 - if (string.len(dtmf_digits) == 0) then - dtmf_digits = macro(session, "to_save_recording", 100, ''); - end - --to re-record press 3 - if (string.len(dtmf_digits) == 0) then - dtmf_digits = macro(session, "to_rerecord", 3000, ''); - end - --process the dtmf - if (dtmf_digits == "1") then - --listen to the recording - dtmf_digits = session:playAndGetDigits(min_digits, max_digits, tries, timeout, "#", voicemail_dir.."/"..voicemail_id.."/msg_"..uuid..".wav", "", "\\d+", 1000); - --record menu 1 listen to the recording, 2 save the recording, 3 re-record - record_menu(); - elseif (dtmf_digits == "2") then - --save the message - macro(session, "message_saved", 100, ''); - macro(session, "goodbye", 100, ''); - --hangup the call - session:hangup(); - elseif (dtmf_digits == "3") then - --rerecord the message - record_message(); - elseif (dtmf_digits == "*") then - --hangup - macro(session, "goodbye", 100, ''); - session:hangup(); - else - if (session:ready()) then - record_menu(); - end - end - end - ---define a function to send email - function send_email(uuid) - --get voicemail message details - sql = [[SELECT * 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 - status = dbh:query(sql, function(row) - --get the values from the database - --uuid = row["voicemail_message_uuid"]; - --created_epoch = row["created_epoch"]; - caller_id_name = row["caller_id_name"]; - caller_id_number = row["caller_id_number"]; - message_length = row["message_length"]; - --message_status = row["message_status"]; - --message_priority = row["message_priority"]; - end); - - --calculate the message length - message_length_formatted = format_seconds(message_length); - freeswitch.consoleLog("notice", "[voicemail] message length: " .. message_length .. "\n"); - - --send the email - message = [[ - Message From "]]..caller_id_name..[[" ]]..caller_id_number..[[
-
- Created: ]]..os.date("%A, %d %b %Y %I:%M %p", start_epoch)..[[
- Duration: ]]..message_length_formatted..[[
- Account: ]]..voicemail_id..[[@]]..domain_name..[[
- ]]; - 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_formatted, - 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_formatted, - message - ); - end - end - ---define a function to forward a message to an extension - function forward_to_extension(uuid) - --get voicemail message details - sql = [[SELECT * 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 - status = dbh:query(sql, function(row) - --get the values from the database - created_epoch = row["created_epoch"]; - caller_id_name = row["caller_id_name"]; - caller_id_number = row["caller_id_number"]; - message_length = row["message_length"]; - message_status = row["message_status"]; - message_priority = row["message_priority"]; - end); - - --request the forward_voicemail_id - forward_voicemail_id = macro(session, "forward_enter_extension", 7000, ''); - if (string.len(forward_voicemail_id) == 0) then - forward_voicemail_id = macro(session, "forward_enter_extension", 7000, ''); - end - if (string.len(forward_voicemail_id) == 0) then - forward_voicemail_id = macro(session, "forward_enter_extension", 7000, ''); - end - - --get the voicemail settings using the voicemail_uuid - sql = [[SELECT * FROM v_voicemails - WHERE domain_uuid = ']] .. domain_uuid ..[[' - AND voicemail_id = ']] .. forward_voicemail_id ..[[' - AND voicemail_enabled = 'true' ]]; - if (debug["sql"]) then - freeswitch.consoleLog("notice", "[voicemail] SQL: " .. sql .. "\n"); - end - status = dbh:query(sql, function(row) - forward_voicemail_uuid = string.lower(row["voicemail_uuid"]); - forward_voicemail_mail_to = row["voicemail_mail_to"]; - forward_voicemail_attach_file = row["voicemail_attach_file"]; - forward_voicemail_local_after_email = row["voicemail_local_after_email"]; - end); - - --set default values - if (string.len(forward_voicemail_attach_file) == 0) then - forward_voicemail_attach_file = "true"; - end - if (string.len(forward_voicemail_local_after_email) == 0) then - forward_voicemail_local_after_email = "true"; - 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, "'".. forward_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, ") "); - 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); - - --set the message waiting event - local event = freeswitch.Event("message_waiting"); - event:addHeader("MWI-Messages-Waiting", "yes"); - event:addHeader("MWI-Message-Account", "sip:"..forward_voicemail_id.."@"..domain_name); - event:fire(); - - --local after email is true so copy the recording file - if (voicemail_local_after_email == "true") then - os.execute("mkdir -p " .. voicemail_dir.."/"..forward_voicemail_id); - os.execute("cp "..voicemail_dir.."/"..voicemail_id.."/msg_"..uuid..".wav "..voicemail_dir.."/"..forward_voicemail_id.."/msg_"..uuid..".wav"); - end - - --send the email with the voicemail recording attached - if (string.len(forward_voicemail_mail_to) > 3) then - send_email(uuid); - end - end - ---leave a voicemail - if (voicemail_action == "save") then - - --voicemail prompt - if (string.len(greeting_id) > 0) then - --play the greeting - session:streamFile(voicemail_dir.."/"..voicemail_id.."/greeting_"..greeting_id..".wav"); - else - --if there is no greeting then play digits of the voicemail_id - result = macro(session, "person_not_available_record_message", 100); - end - - --save the recording - record_message(); - - --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); - - --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(); - - --send the email with the voicemail recording attached - if (string.len(voicemail_mail_to) > 3) then - send_email(uuid); - end - - --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 - 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); - dtmf_digits = macro(session, "new_messages", 100, new_messages); - --saved voicemail count - if (string.len(dtmf_digits) == 0) 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); - dtmf_digits = macro(session, "saved_messages", 100, saved_messages); - end - --to listen to new message - if (string.len(dtmf_digits) == 0) then - dtmf_digits = macro(session, "listen_to_new_messages", 100, ''); - end - --to listen to saved message - if (string.len(dtmf_digits) == 0) then - dtmf_digits = macro(session, "listen_to_saved_messages", 100, ''); - end - --for advanced options - if (string.len(dtmf_digits) == 0) then - dtmf_digits = macro(session, "advanced", 100, ''); - end - --to exit press # - if (string.len(dtmf_digits) == 0) then - dtmf_digits = macro(session, "to_exit_press", 3000, ''); - 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 menu advanced(); - elseif (dtmf_digits == "0") then - session:transfer("0", "XML", context); - elseif (dtmf_digits == "*") then - macro(session, "goodbye", 100, ''); - 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", 100, ''); - --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", 100, ''); - end - --to save the recording press 2 - if (string.len(dtmf_digits) == 0) then - dtmf_digits = macro(session, "save_recording", 100, ''); - end - --to return the call now press 5 - if (string.len(dtmf_digits) == 0) then - dtmf_digits = macro(session, "return_call", 100, ''); - end - --to delete the recording press 7 - if (string.len(dtmf_digits) == 0) then - dtmf_digits = macro(session, "delete_recording", 100, ''); - end - --to forward this message press 8 - if (string.len(dtmf_digits) == 0) then - dtmf_digits = macro(session, "to_forward_message", 100, ''); - end - --to forward this recording to your email press 9 - if (string.len(dtmf_digits) == 0) then - dtmf_digits = macro(session, "forward_to_email", 100, ''); - end - --wait for more digits - if (string.len(dtmf_digits) == 0) then - dtmf_digits = session:getDigits(max_digits, "#", 3000); - end - --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", 100, ''); - elseif (dtmf_digits == "5") then - return_call(caller_id_number); - elseif (dtmf_digits == "7") then - delete_recording(uuid); - elseif (dtmf_digits == "8") then - forward_to_extension(uuid); - macro(session, "message_saved", 100, ''); - elseif (dtmf_digits == "9") then - send_email(uuid); - macro(session, "emailed", 100); - elseif (dtmf_digits == "*") then - main_menu(); - elseif (dtmf_digits == "0") then - session:transfer("0", "XML", context); - else - message_saved(uuid); - macro(session, "message_saved", 100, ''); - end -end - ---voicemail count if zero new messages set the mwi to no - function message_waiting() - 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(); - else - --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(); - end - end); - end end - ---delete the recording - 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); - --message deleted - macro(session, "message_deleted", 100, ''); - --check the message waiting status - message_waiting(); - end - ---save the message - 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); - --check the message waiting status - message_waiting(); - end - ---return the call - function return_call(destination) - --check the message waiting status - message_waiting(); - --transfer the call - 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 - if (session:ready()) then - 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); - 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", 100, ''); - --To choose greeting press 2 - if (string.len(dtmf_digits) == 0) then - dtmf_digits = macro(session, "choose_greeting", 100, ''); - end - --To record your name 3 - if (string.len(dtmf_digits) == 0) then - dtmf_digits = macro(session, "to_record_name", 100, ''); - end - --To change your password press 6 - if (string.len(dtmf_digits) == 0) then - dtmf_digits = macro(session, "change_password", 100, ''); - 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 - -function record_greeting() - --Choose a greeting between 1 and 9 - greeting_id = macro(session, "choose_greeting_choose", 5000, ''); - - --validate the greeting_id - if (greeting_id == "1" - or greeting_id == "2" - or greeting_id == "3" - or greeting_id == "4" - or greeting_id == "5" - or greeting_id == "6" - or greeting_id == "7" - or greeting_id == "8" - or greeting_id == "9") then - - --record your greeting at the tone press any key or stop talking to end the recording - macro(session, "record_greeting", 100, ''); - - --record the greeting - max_len_seconds = 30; - silence_threshold = 30; - silence_seconds = 5; - os.execute("mkdir -p " .. voicemail_dir.."/"..voicemail_id); - -- syntax is session:recordFile(file_name, max_len_secs, silence_threshold, silence_secs) - result = session:recordFile(voicemail_dir.."/"..voicemail_id.."/greeting_"..greeting_id..".wav", max_len_seconds, silence_threshold, silence_seconds); - --session:execute("record", voicemail_dir.."/"..uuid.." 180 200"); - - --advanced menu - advanced(); - else - --invalid greeting_id - greeting_id = macro(session, "choose_greeting_fail", 100, ''); - - --send back to choose the greeting - if (session:ready()) then - record_greeting(); - end - end -end - -function choose_greeting() - --select the greeting - greeting_id = macro(session, "choose_greeting_choose", 5000, ''); - - --check to see if the greeting file exists - if (not file_exists(voicemail_dir.."/"..voicemail_id.."/greeting_"..greeting_id..".wav")) then - --invalid greeting_id file does not exist - greeting_id = "invalid"; - end - - --validate the greeting_id - if (greeting_id == "0" - or greeting_id == "1" - or greeting_id == "2" - or greeting_id == "3" - or greeting_id == "4" - or greeting_id == "5" - or greeting_id == "6" - or greeting_id == "7" - or greeting_id == "8" - or greeting_id == "9") then - - --valid greeting_id update the database - if (greeting_id == "0") then - sql = [[UPDATE v_voicemails SET greeting_id = null ]]; - else - sql = [[UPDATE v_voicemails SET greeting_id = ']]..greeting_id..[[' ]]; - end - sql = sql ..[[WHERE domain_uuid = ']] .. domain_uuid ..[[' ]] - sql = sql ..[[AND voicemail_uuid = ']] .. voicemail_uuid ..[[' ]]; - if (debug["sql"]) then - freeswitch.consoleLog("notice", "[voicemail] SQL: " .. sql .. "\n"); - end - dbh:query(sql); - - --play the greeting - session:streamFile(voicemail_dir.."/"..voicemail_id.."/greeting_"..greeting_id..".wav"); - - --greeting selected - macro(session, "greeting_selected", 100, greeting_id); - - --advanced menu - advanced(); - else - --invalid greeting_id - greeting_id = macro(session, "choose_greeting_fail", 100, ''); - - --send back to choose the greeting - if (session:ready()) then - choose_greeting(); - end - end - - --advanced menu - advanced(); -end - -function record_name() - --play the name record - macro(session, "record_name", 100, ''); - - --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; - os.execute("mkdir -p " .. voicemail_dir.."/"..voicemail_id); - result = session:recordFile(voicemail_dir.."/"..voicemail_id.."/recorded_name.wav", max_len_seconds, silence_threshold, silence_seconds); - --session:execute("record", voicemail_dir.."/"..uuid.." 180 200"); - - --play the greeting - session:streamFile(voicemail_dir.."/"..voicemail_id.."/recorded_name.wav"); - - --message saved - macro(session, "message_saved", 100, ''); - - --advanced menu - advanced(); end --check voicemail if (voicemail_action == "check") then - --check the voicemail password - check_password(voicemail_id); - main_menu(); + if (session:ready()) then + --check the voicemail password + check_password(voicemail_id); + main_menu(); + end end --notes