mirror of
https://github.com/fusionpbx/fusionpbx.git
synced 2026-01-06 03:33:49 +00:00
Remove mkdir (#6169)
* Remove mkdir * Delete app/scripts/resources/scripts/app/messages/resources directory * Use curl instead of system curl. * Update file_cache.lua
This commit is contained in:
FusionPBX
@@ -1,335 +0,0 @@
|
||||
--
|
||||
-- Version: MPL 1.1
|
||||
--
|
||||
-- The contents of this file are subject to the Mozilla Public License Version
|
||||
-- 1.1 (the "License"); you may not use this file except in compliance with
|
||||
-- the License. You may obtain a copy of the License at
|
||||
-- http://www.mozilla.org/MPL/
|
||||
--
|
||||
-- Software distributed under the License is distributed on an "AS IS" basis,
|
||||
-- WITHOUT WARRANTY OF ANY KIND, either express or implied. See the License
|
||||
-- for the specific language governing rights and limitations under the
|
||||
-- License.
|
||||
--
|
||||
-- The Original Code is FusionPBX
|
||||
--
|
||||
-- The Initial Developer of the Original Code is
|
||||
-- Mark J Crane <markjcrane@fusionpbx.com>
|
||||
-- Copyright (C) 2018
|
||||
|
||||
|
||||
-- Start the script
|
||||
-- <!-- Subscribe to events -->
|
||||
-- <hook event="CUSTOM" subclass="SMS::SEND_MESSAGE" script="app/messages/resources/events.lua"/>
|
||||
|
||||
--prepare the api object
|
||||
api = freeswitch.API();
|
||||
|
||||
--define the functions
|
||||
require "resources.functions.trim";
|
||||
require "resources.functions.explode";
|
||||
require "resources.functions.base64";
|
||||
|
||||
--include the database class
|
||||
local Database = require "resources.functions.database";
|
||||
|
||||
--set debug
|
||||
debug["sql"] = false;
|
||||
|
||||
--get the events
|
||||
--serialize the data for the console
|
||||
--freeswitch.consoleLog("notice","[events] " .. event:serialize("xml") .. "\n");
|
||||
--freeswitch.consoleLog("notice","[evnts] " .. event:serialize("json") .. "\n");
|
||||
|
||||
--intialize settings
|
||||
--from_user = '';
|
||||
|
||||
--get the event variables
|
||||
uuid = event:getHeader("Core-UUID");
|
||||
from_user = event:getHeader("from_user");
|
||||
from_host = event:getHeader("from_host");
|
||||
to_user = event:getHeader("to_user");
|
||||
to_host = event:getHeader("to_host");
|
||||
content_type = event:getHeader("type");
|
||||
message_text = event:getBody();
|
||||
|
||||
--set required variables
|
||||
if (from_user ~= nil and from_host ~= nil) then
|
||||
message_from = from_user .. '@' .. from_host;
|
||||
end
|
||||
if (to_user ~= nil and to_host ~= nil) then
|
||||
message_to = to_user .. '@' .. to_host;
|
||||
end
|
||||
message_type = 'message';
|
||||
|
||||
--connect to the database
|
||||
dbh = Database.new('system');
|
||||
|
||||
--exits the script if we didn't connect properly
|
||||
assert(dbh:connected());
|
||||
|
||||
--set debug
|
||||
debug["sql"] = true;
|
||||
|
||||
--include json library
|
||||
local json
|
||||
if (debug["sql"]) then
|
||||
json = require "resources.functions.lunajson"
|
||||
end
|
||||
|
||||
--check if the from user exits
|
||||
if (from_user ~= nil and from_host ~= nil) then
|
||||
cmd = "user_exists id ".. from_user .." "..from_host;
|
||||
freeswitch.consoleLog("notice", "[messages][from] user exists " .. cmd .. "\n");
|
||||
from_user_exists = api:executeString(cmd);
|
||||
else
|
||||
from_user_exists = 'false';
|
||||
end
|
||||
|
||||
--check if the to user exits
|
||||
if (to_user ~= nil and to_host ~= nil) then
|
||||
cmd = "user_exists id ".. to_user .." "..to_host;
|
||||
freeswitch.consoleLog("notice", "[messages][to] user exists " .. cmd .. "\n");
|
||||
to_user_exists = api:executeString(cmd);
|
||||
else
|
||||
to_user_exists = 'false';
|
||||
end
|
||||
|
||||
--add the message
|
||||
if (from_user_exists == 'true') then
|
||||
--set the direction
|
||||
message_direction = 'send';
|
||||
|
||||
--get the from user_uuid
|
||||
cmd = "user_data ".. from_user .."@"..from_host.." var domain_uuid";
|
||||
domain_uuid = trim(api:executeString(cmd));
|
||||
|
||||
--get the from user_uuid
|
||||
cmd = "user_data ".. from_user .."@"..from_host.." var user_uuid";
|
||||
user_uuid = trim(api:executeString(cmd));
|
||||
|
||||
--get the from contact_uuid
|
||||
cmd = "user_data ".. to_user .."@"..to_host.." var contact_uuid";
|
||||
contact_uuid = trim(api:executeString(cmd));
|
||||
|
||||
--create a new uuid and add it to the uuid list
|
||||
message_uuid = api:executeString("create_uuid");
|
||||
|
||||
--sql statement
|
||||
sql = "INSERT INTO v_messages ";
|
||||
sql = sql .."( ";
|
||||
sql = sql .."domain_uuid, ";
|
||||
sql = sql .."message_uuid, ";
|
||||
sql = sql .."user_uuid, ";
|
||||
if (contact_uuid ~= null and string.len(contact_uuid) > 0) then
|
||||
sql = sql .."contact_uuid, ";
|
||||
end
|
||||
sql = sql .."message_direction, ";
|
||||
sql = sql .."message_date, ";
|
||||
sql = sql .."message_type, ";
|
||||
if (message_from ~= null and string.len(message_from) > 0) then
|
||||
sql = sql .."message_from, ";
|
||||
end
|
||||
sql = sql .."message_to, ";
|
||||
sql = sql .."message_text ";
|
||||
sql = sql ..") ";
|
||||
sql = sql .."VALUES ( ";
|
||||
sql = sql ..":domain_uuid, ";
|
||||
sql = sql ..":message_uuid, ";
|
||||
sql = sql ..":user_uuid, ";
|
||||
if (contact_uuid ~= null and string.len(contact_uuid) > 0) then
|
||||
sql = sql ..":contact_uuid, ";
|
||||
end
|
||||
sql = sql ..":message_direction, ";
|
||||
sql = sql .."now(), ";
|
||||
sql = sql ..":message_type, ";
|
||||
if (message_from ~= null and string.len(message_from) > 0) then
|
||||
sql = sql ..":message_from, ";
|
||||
end
|
||||
sql = sql ..":message_to, ";
|
||||
sql = sql ..":message_text ";
|
||||
sql = sql ..") ";
|
||||
|
||||
--set the parameters
|
||||
local params= {}
|
||||
params['domain_uuid'] = domain_uuid;
|
||||
params['message_uuid'] = message_uuid;
|
||||
params['user_uuid'] = user_uuid;
|
||||
if (contact_uuid ~= null and string.len(contact_uuid) > 0) then
|
||||
params['contact_uuid'] = contact_uuid;
|
||||
end
|
||||
params['message_direction'] = message_direction;
|
||||
params['message_type'] = message_type;
|
||||
if (message_from ~= null) then
|
||||
params['message_from'] = message_from;
|
||||
end
|
||||
params['message_to'] = message_to;
|
||||
params['message_text'] = message_text;
|
||||
|
||||
--show debug info
|
||||
if (debug["sql"]) then
|
||||
freeswitch.consoleLog("notice", "[call_center] SQL: " .. sql .. "; params:" .. json.encode(params) .. "\n");
|
||||
end
|
||||
|
||||
--run the query
|
||||
dbh:query(sql, params);
|
||||
end
|
||||
if (to_user_exists == 'true') then
|
||||
--sql statement
|
||||
sql = "INSERT INTO v_messages ";
|
||||
sql = sql .."( ";
|
||||
sql = sql .."domain_uuid, ";
|
||||
sql = sql .."message_uuid, ";
|
||||
sql = sql .."user_uuid, ";
|
||||
if (contact_uuid ~= null and string.len(contact_uuid) > 0) then
|
||||
sql = sql .."contact_uuid, ";
|
||||
end
|
||||
sql = sql .."message_direction, ";
|
||||
sql = sql .."message_date, ";
|
||||
sql = sql .."message_type, ";
|
||||
if (message_from ~= null and string.len(message_from) > 0) then
|
||||
sql = sql .."message_from, ";
|
||||
end
|
||||
sql = sql .."message_to, ";
|
||||
sql = sql .."message_text ";
|
||||
sql = sql ..") ";
|
||||
sql = sql .."VALUES ( ";
|
||||
sql = sql ..":domain_uuid, ";
|
||||
sql = sql ..":message_uuid, ";
|
||||
sql = sql ..":user_uuid, ";
|
||||
if (contact_uuid ~= null and string.len(contact_uuid) > 0) then
|
||||
sql = sql ..":contact_uuid, ";
|
||||
end
|
||||
sql = sql ..":message_direction, ";
|
||||
sql = sql .."now(), ";
|
||||
sql = sql ..":message_type, ";
|
||||
if (message_from ~= null and string.len(message_from) > 0) then
|
||||
sql = sql ..":message_from, ";
|
||||
end
|
||||
sql = sql ..":message_to, ";
|
||||
sql = sql ..":message_text ";
|
||||
sql = sql ..") ";
|
||||
|
||||
--set the direction
|
||||
message_direction = 'receive';
|
||||
|
||||
--get the from user_uuid
|
||||
cmd = "user_data ".. to_user .."@"..to_host.." var domain_uuid";
|
||||
domain_uuid = trim(api:executeString(cmd));
|
||||
|
||||
--get the from user_uuid
|
||||
cmd = "user_data ".. to_user .."@"..to_host.." var user_uuid";
|
||||
user_uuid = trim(api:executeString(cmd));
|
||||
|
||||
--get the from contact_uuid
|
||||
cmd = "user_data ".. to_user .."@"..to_host.." var contact_uuid";
|
||||
contact_uuid = trim(api:executeString(cmd));
|
||||
|
||||
--create a new uuid and add it to the uuid list
|
||||
message_uuid = api:executeString("create_uuid");
|
||||
|
||||
--set the parameters
|
||||
local params= {}
|
||||
params['domain_uuid'] = domain_uuid;
|
||||
params['message_uuid'] = message_uuid;
|
||||
params['user_uuid'] = user_uuid;
|
||||
if (contact_uuid ~= null and string.len(message_from) > 0) then
|
||||
params['contact_uuid'] = contact_uuid;
|
||||
end
|
||||
params['message_direction'] = message_direction;
|
||||
params['message_type'] = message_type;
|
||||
params['message_from'] = message_from;
|
||||
params['message_to'] = message_to;
|
||||
params['message_text'] = message_text;
|
||||
|
||||
--show debug info
|
||||
if (debug["sql"]) then
|
||||
freeswitch.consoleLog("notice", "[call_center] SQL: " .. sql .. "; params:" .. json.encode(params) .. "\n");
|
||||
end
|
||||
|
||||
--run the query
|
||||
dbh:query(sql, params);
|
||||
|
||||
else
|
||||
|
||||
--get setttings needed to send the message
|
||||
require "resources.functions.settings";
|
||||
settings = settings(domain_uuid);
|
||||
if (settings['message'] ~= nil) then
|
||||
http_method = '';
|
||||
if (settings['message']['http_method'] ~= nil) then
|
||||
if (settings['message']['http_method']['text'] ~= nil) then
|
||||
http_method = settings['message']['http_method']['text'];
|
||||
end
|
||||
end
|
||||
|
||||
http_content_type = '';
|
||||
if (settings['message']['http_content_type'] ~= nil) then
|
||||
if (settings['message']['http_content_type']['text'] ~= nil) then
|
||||
http_content_type = settings['message']['http_content_type']['text'];
|
||||
end
|
||||
end
|
||||
|
||||
http_destination = '';
|
||||
if (settings['message']['http_destination'] ~= nil) then
|
||||
if (settings['message']['http_destination']['text'] ~= nil) then
|
||||
http_destination = settings['message']['http_destination']['text'];
|
||||
end
|
||||
end
|
||||
|
||||
http_auth_enabled = 'false';
|
||||
if (settings['message']['http_auth_enabled'] ~= nil) then
|
||||
if (settings['message']['http_auth_enabled']['boolean'] ~= nil) then
|
||||
http_auth_enabled = settings['message']['http_auth_enabled']['boolean'];
|
||||
end
|
||||
end
|
||||
|
||||
http_auth_type = '';
|
||||
if (settings['message']['http_auth_type'] ~= nil) then
|
||||
if (settings['message']['http_auth_type']['text'] ~= nil) then
|
||||
http_auth_type = settings['message']['http_auth_type']['text'];
|
||||
end
|
||||
end
|
||||
|
||||
http_auth_user = '';
|
||||
if (settings['message']['http_auth_user'] ~= nil) then
|
||||
if (settings['message']['http_auth_user']['text'] ~= nil) then
|
||||
http_auth_user = settings['message']['http_auth_user']['text'];
|
||||
end
|
||||
end
|
||||
|
||||
http_auth_password = '';
|
||||
if (settings['message']['http_auth_password'] ~= nil) then
|
||||
if (settings['message']['http_auth_password']['text'] ~= nil) then
|
||||
http_auth_password = settings['message']['http_auth_password']['text'];
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
--get the sip user outbound_caller_id
|
||||
if (from_user ~= nil and from_host ~= nil) then
|
||||
cmd = "user_data ".. from_user .."@"..from_host.." var outbound_caller_id_number";
|
||||
from = trim(api:executeString(cmd));
|
||||
else
|
||||
from = '';
|
||||
end
|
||||
|
||||
--replace variables for their value
|
||||
http_destination = http_destination:gsub("${from}", from);
|
||||
|
||||
--send to the provider using curl
|
||||
if (to_user ~= nil) then
|
||||
cmd = [[curl ]].. http_destination ..[[ ]]
|
||||
cmd = cmd .. [[-H "Content-Type: ]]..http_content_type..[[" ]];
|
||||
if (http_auth_type == 'basic') then
|
||||
cmd = cmd .. [[-H "Authorization: Basic ]]..base64.encode(http_auth_user..":"..http_auth_password)..[[" ]];
|
||||
end
|
||||
cmd = cmd .. [[-d '{"to":"]]..to_user..[[","text":"]]..message_text..[["}']]
|
||||
result = api:executeString("system "..cmd);
|
||||
--status = os.execute (cmd);
|
||||
|
||||
--debug - log the command
|
||||
freeswitch.consoleLog("notice", "[message] " .. cmd.. "\n");
|
||||
end
|
||||
|
||||
end
|
||||
@@ -1,73 +0,0 @@
|
||||
-- FusionPBX
|
||||
-- Version: MPL 1.1
|
||||
|
||||
-- The contents of this file are subject to the Mozilla Public License Version
|
||||
-- 1.1 (the "License"); you may not use this file except in compliance with
|
||||
-- the License. You may obtain a copy of the License at
|
||||
-- http://www.mozilla.org/MPL/
|
||||
|
||||
-- Software distributed under the License is distributed on an "AS IS" basis,
|
||||
-- WITHOUT WARRANTY OF ANY KIND, either express or implied. See the License
|
||||
-- for the specific language governing rights and limitations under the
|
||||
-- License.
|
||||
|
||||
-- The Original Code is FusionPBX
|
||||
|
||||
-- The Initial Developer of the Original Code is
|
||||
-- Mark J Crane <markjcrane@fusionpbx.com>
|
||||
-- Portions created by the Initial Developer are Copyright (C) 2018
|
||||
-- the Initial Developer. All Rights Reserved.
|
||||
|
||||
--get the argv values
|
||||
script_name = argv[0];
|
||||
message_from = argv[1];
|
||||
message_to = argv[2];
|
||||
message_text = argv[3];
|
||||
|
||||
--send a message to the console
|
||||
freeswitch.consoleLog("NOTICE",[[[message] from ]]..message_from);
|
||||
freeswitch.consoleLog("NOTICE",[[[message] to ]] .. message_to);
|
||||
freeswitch.consoleLog("NOTICE",[[[message] from ]]..message_text);
|
||||
|
||||
--connect to the database
|
||||
--local Database = require "resources.functions.database";
|
||||
--dbh = Database.new('system');
|
||||
|
||||
--include functions
|
||||
require "resources.functions.trim";
|
||||
require "resources.functions.explode";
|
||||
--require "resources.functions.file_exists";
|
||||
|
||||
--create the api object
|
||||
api = freeswitch.API();
|
||||
|
||||
--get the domain name for the destination
|
||||
array = explode('@', message_to);
|
||||
domain_name = array[2];
|
||||
freeswitch.consoleLog("NOTICE",[[[message] domain_name ]]..domain_name);
|
||||
|
||||
--get the sip profile name
|
||||
local sofia_contact = trim(api:executeString("sofia_contact */"..message_to));
|
||||
local array = explode("/", sofia_contact);
|
||||
local sip_profile = array[2];
|
||||
|
||||
--send the sms message
|
||||
local event = freeswitch.Event("CUSTOM", "SMS::SEND_MESSAGE");
|
||||
event:addHeader("proto", "sip");
|
||||
event:addHeader("dest_proto", "sip");
|
||||
event:addHeader("from", message_from);
|
||||
event:addHeader("from_full", "sip:"..message_from);
|
||||
event:addHeader("to", message_to);
|
||||
event:addHeader("subject", "sip:"..message_to);
|
||||
--event:addHeader("type", "text/html");
|
||||
event:addHeader("type", "text/plain");
|
||||
event:addHeader("hint", "the hint");
|
||||
event:addHeader("replying", "true");
|
||||
event:addHeader("sip_profile", sip_profile);
|
||||
event:addBody(message_text);
|
||||
|
||||
--send info to the console
|
||||
freeswitch.consoleLog("info", event:serialize());
|
||||
|
||||
--send the event
|
||||
event:fire();
|
||||
@@ -79,7 +79,8 @@
|
||||
if (row.method == "curl") then
|
||||
api_command_argument = api_command_argument:gsub(" ", "%%20");
|
||||
url = [[http://]]..row.username..[[:]]..row.password..[[@]]..row.hostname..[[:]]..row.port..[[/webapi/luarun?app/servers/resources/clear_cache.lua%20]]..api_command_argument;
|
||||
api:executeString("system curl " .. url );
|
||||
api = freeswitch.API();
|
||||
get_response = api:execute("curl", url);
|
||||
freeswitch.consoleLog("INFO", "[notice] curl ".. url .. " \n");
|
||||
end
|
||||
end
|
||||
|
||||
@@ -537,7 +537,6 @@
|
||||
if (storage_path == "http_cache") then
|
||||
result = session:recordFile(storage_path.."/"..voicemail_id.."/msg_"..uuid.."."..vm_message_ext, message_max_length, message_silence_threshold, message_silence_seconds);
|
||||
else
|
||||
mkdir(voicemail_dir.."/"..voicemail_id);
|
||||
if (vm_message_ext == "mp3") then
|
||||
shout_exists = trim(api:execute("module_exists", "mod_shout"));
|
||||
if (shout_exists == "true" and transcribe_enabled == "false") or (shout_exists == "true" and transcribe_enabled == "true" and voicemail_transcription_enabled ~= "true") then
|
||||
|
||||
Reference in New Issue
Block a user