nsinnovations/fusionpbx
2
0
Fork 0
mirror of https://github.com/fusionpbx/fusionpbx.git synced 2025-12-30 00:53:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add record in recordings table no matter what type of storage type is used.

Browse Source
This commit is contained in:
Mark Crane
2015-04-16 14:47:21 +00:00
parent 889c2c803b
commit 1451d2984c
1 changed files with 47 additions and 46 deletions
Download Patch File Download Diff File Expand all files Collapse all files

93
resources/install/scripts/recordings.lua
View File

@@ -139,52 +139,6 @@
f:close();
recording_base64 = base64.encode(file_content);
--delete the previous recording
sql = "delete from v_recordings ";
sql = sql .. "where domain_uuid = '".. domain_uuid .. "' ";
sql = sql .. "and recording_name = '".. recording_name .."'";
dbh:query(sql);
--get a new uuid
recording_uuid = api:execute("create_uuid");
--save the message to the voicemail messages
local array = {}
table.insert(array, "INSERT INTO v_recordings ");
table.insert(array, "(");
table.insert(array, "recording_uuid, ");
table.insert(array, "domain_uuid, ");
table.insert(array, "recording_filename, ");
if (storage_type == "base64") then
table.insert(array, "recording_base64, ");
end
table.insert(array, "recording_name ");
table.insert(array, ") ");
table.insert(array, "VALUES ");
table.insert(array, "( ");
table.insert(array, "'"..recording_uuid.."', ");
table.insert(array, "'"..domain_uuid.."', ");
table.insert(array, "'"..recording_name.."', ");
if (storage_type == "base64") then
table.insert(array, "'"..recording_base64.."', ");
end
table.insert(array, "'"..recording_name.."' ");
table.insert(array, ") ");
sql = table.concat(array, "\n");
if (debug["sql"]) then
freeswitch.consoleLog("notice", "[recording] SQL: " .. sql .. "\n");
end
if (storage_type == "base64") then
array = explode("://", database["system"]);
local luasql = require "luasql.postgres";
local env = assert (luasql.postgres());
local dbh = env:connect(array[2]);
res, serr = dbh:execute(sql);
dbh:close();
env:close();
else
dbh:query(sql);
end
elseif (storage_type == "http_cache") then
freeswitch.consoleLog("notice", "[recordings] ".. storage_type .. " ".. storage_path .."\n");
session:execute("record", storage_path .."/"..recording_name);
@@ -193,6 +147,53 @@
session:execute("record", "'"..recordings_dir.."/"..recording_name.."' 10800 500 500");
end
--delete the previous recording
sql = "delete from v_recordings ";
sql = sql .. "where domain_uuid = '".. domain_uuid .. "' ";
sql = sql .. "and recording_name = '".. recording_name .."'";
dbh:query(sql);
--get a new uuid
recording_uuid = api:execute("create_uuid");
--save the message to the voicemail messages
local array = {}
table.insert(array, "INSERT INTO v_recordings ");
table.insert(array, "(");
table.insert(array, "recording_uuid, ");
table.insert(array, "domain_uuid, ");
table.insert(array, "recording_filename, ");
if (storage_type == "base64") then
table.insert(array, "recording_base64, ");
end
table.insert(array, "recording_name ");
table.insert(array, ") ");
table.insert(array, "VALUES ");
table.insert(array, "( ");
table.insert(array, "'"..recording_uuid.."', ");
table.insert(array, "'"..domain_uuid.."', ");
table.insert(array, "'"..recording_name.."', ");
if (storage_type == "base64") then
table.insert(array, "'"..recording_base64.."', ");
end
table.insert(array, "'"..recording_name.."' ");
table.insert(array, ") ");
sql = table.concat(array, "\n");
if (debug["sql"]) then
freeswitch.consoleLog("notice", "[recording] SQL: " .. sql .. "\n");
end
if (storage_type == "base64") then
array = explode("://", database["system"]);
local luasql = require "luasql.postgres";
local env = assert (luasql.postgres());
local dbh = env:connect(array[2]);
res, serr = dbh:execute(sql);
dbh:close();
env:close();
else
dbh:query(sql);
end
--preview the recording
session:streamFile(recordings_dir.."/"..recording_name);