mod_voicemail: Add vm_fsdb_msg_forward api call

diff --git a/src/mod/applications/mod_voicemail/mod_voicemail.c b/src/mod/applications/mod_voicemail/mod_voicemail.c
index aa87d592465191580f872fa8a792c32f2e9d1968..8ebc3ae2b07670c6c6baaaf5022b9f14034da302 100644 (file)
--- a/src/mod/applications/mod_voicemail/mod_voicemail.c
+++ b/src/mod/applications/mod_voicemail/mod_voicemail.c
@@ -1337,6 +1337,50 @@ static void message_count(vm_profile_t *profile, const char *id_in, const char *
        }
 }
 
+/* TODO Port this as switch_ core function */
+switch_status_t vm_merge_media_files(const char** inputs, const char *output) {
+       switch_status_t status = SWITCH_STATUS_SUCCESS;
+       switch_file_handle_t fh_output = { 0 };
+       int channels = 1;
+       int rate = 8000; /* TODO Make this configurable */
+       int j = 0;
+
+       if (switch_core_file_open(&fh_output, output, channels, rate, SWITCH_FILE_FLAG_WRITE | SWITCH_FILE_DATA_SHORT, NULL) != SWITCH_STATUS_SUCCESS) {
+               switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Couldn't open %s\n", output);
+               goto end;
+       }
+
+       for (j = 0; inputs[j] != NULL && j < 128 && status == SWITCH_STATUS_SUCCESS; j++) {
+               switch_file_handle_t fh_input = { 0 };
+               char buf[2048];
+               switch_size_t len = sizeof(buf) / 2;
+
+               if (switch_core_file_open(&fh_input, inputs[j], channels, rate, SWITCH_FILE_FLAG_READ | SWITCH_FILE_DATA_SHORT, NULL) != SWITCH_STATUS_SUCCESS) {
+                       switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Couldn't open %s\n", inputs[j]);
+                       status = SWITCH_STATUS_GENERR;
+                       break;
+               }
+
+               while (switch_core_file_read(&fh_input, buf, &len) == SWITCH_STATUS_SUCCESS) {
+                       if (switch_core_file_write(&fh_output, buf, &len) != SWITCH_STATUS_SUCCESS) {
+                               switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Write error\n");
+                               status = SWITCH_STATUS_GENERR;
+                               break;
+                       }
+               }
+
+               if (fh_input.file_interface) {
+                       switch_core_file_close(&fh_input);
+               }
+       }
+
+       if (fh_output.file_interface) {
+               switch_core_file_close(&fh_output);
+       }
+end:
+       return status;
+}
+
 #define VM_STARTSAMPLES 1024 * 32
 
 static char *vm_merge_file(switch_core_session_t *session, vm_profile_t *profile, const char *announce, const char *orig)
@@ -5165,6 +5209,112 @@ done:
        return SWITCH_STATUS_SUCCESS;
 }
 
+#define VM_FSDB_MSG_FORWARD_USAGE "<profile> <domain> <user> <uuid> <dst_domain> <dst_user> [prepend_file_location]"
+SWITCH_STANDARD_API(vm_fsdb_msg_forward_function)
+{
+       const char *id = NULL, *domain = NULL, *profile_name = NULL, *uuid = NULL, *dst_domain = NULL, *dst_id = NULL, *prepend_file_path = NULL;
+       vm_profile_t *profile = NULL;
+       char *argv[7] = { 0 };
+       char *mycmd = NULL;
+       msg_get_callback_t cbt = { 0 };
+       char *sql;
+       switch_memory_pool_t *pool;
+
+       switch_core_new_memory_pool(&pool);
+
+       if (!zstr(cmd)) {
+               mycmd = switch_core_strdup(pool, cmd);
+               switch_separate_string(mycmd, ' ', argv, (sizeof(argv) / sizeof(argv[0])));
+       }
+
+       if (argv[0])
+               profile_name = argv[0];
+       if (argv[1])
+               domain = argv[1];
+       if (argv[2])
+               id = argv[2];
+       if (argv[3])
+               uuid = argv[3];
+       if (argv[4])
+               dst_domain = argv[4];
+       if (argv[5])
+               dst_id = argv[5];
+       if (argv[6])
+               prepend_file_path = argv[6];
+
+       if (!profile_name || !domain || !id || !uuid || !dst_domain || !dst_id) {
+               stream->write_function(stream, "-ERR Missing Arguments\n");
+               goto done;
+       }
+
+       if (!(profile = get_profile(profile_name))) {
+               stream->write_function(stream, "-ERR Profile not found\n");
+               goto done;
+       } else {
+               const char *file_path = NULL;
+               sql = switch_mprintf("SELECT * FROM voicemail_msgs WHERE username = '%q' AND domain = '%q' AND uuid = '%q' ORDER BY read_flags, created_epoch", id, domain, uuid);
+               memset(&cbt, 0, sizeof(cbt));
+               switch_event_create(&cbt.my_params, SWITCH_EVENT_REQUEST_PARAMS);
+               vm_execute_sql_callback(profile, profile->mutex, sql, message_get_callback, &cbt);
+               switch_safe_free(sql);
+               file_path = switch_event_get_header(cbt.my_params, "VM-Message-File-Path");
+               if (file_path && switch_file_exists(file_path, pool) == SWITCH_STATUS_SUCCESS) {
+                       const char *new_file_path = file_path;
+                       const char *cmd = NULL;
+
+
+                       if (prepend_file_path && switch_file_exists(prepend_file_path, pool) == SWITCH_STATUS_SUCCESS) {
+                               switch_uuid_t tmp_uuid;
+                               char tmp_uuid_str[SWITCH_UUID_FORMATTED_LENGTH + 1];
+                               const char *test[3] = { NULL };
+                               test[0] = prepend_file_path;
+                               test[1] = file_path;
+
+                               switch_uuid_get(&tmp_uuid);
+                               switch_uuid_format(tmp_uuid_str, &tmp_uuid);
+
+                               new_file_path = switch_core_sprintf(pool, "%s%smsg_%s.wav", SWITCH_GLOBAL_dirs.temp_dir, SWITCH_PATH_SEPARATOR, tmp_uuid_str);
+                               
+                               if (vm_merge_media_files(test, new_file_path) != SWITCH_STATUS_SUCCESS) {
+                                       stream->write_function(stream, "-ERR Error Merging the file\n");
+                                       switch_event_destroy(&cbt.my_params);
+                                       profile_rwunlock(profile);
+                                       goto done;
+                               }
+
+                       }
+                       cmd = switch_core_sprintf(pool, "%s@%s %s %s '%s'", dst_id, dst_domain, new_file_path, switch_event_get_header(cbt.my_params, "VM-Message-Caller-Number"), switch_event_get_header(cbt.my_params, "VM-Message-Caller-Name"));
+                       if (voicemail_inject(cmd, NULL) == SWITCH_STATUS_SUCCESS) {
+                               switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_NOTICE, "Sent Carbon Copy to %s@%s\n", dst_id, dst_domain);
+                       } else {
+                               switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Failed to Carbon Copy to %s@%s\n", dst_id, dst_domain);
+                               stream->write_function(stream, "-ERR Error Forwarding Message\n");
+                               switch_event_destroy(&cbt.my_params);
+                               profile_rwunlock(profile);
+                               goto done;
+                       }
+                       if (new_file_path != file_path) {
+                               /* TODO UNLINK new-file-path */
+                       }
+               } else {
+                       stream->write_function(stream, "-ERR Cannot find source msg to forward: %s\n", file_path);
+                       switch_event_destroy(&cbt.my_params);
+                       profile_rwunlock(profile);
+                       goto done;
+               }
+
+               switch_event_destroy(&cbt.my_params);
+
+               profile_rwunlock(profile);
+       }
+       stream->write_function(stream, "-OK\n");
+done:
+       switch_core_destroy_memory_pool(&pool);
+
+
+       return SWITCH_STATUS_SUCCESS;
+}
+
 #define VM_FSDB_MSG_GET_USAGE "<format> <profile> <domain> <user> <uuid>"
 SWITCH_STANDARD_API(vm_fsdb_msg_get_function)
 {
@@ -5348,6 +5498,7 @@ SWITCH_MODULE_LOAD_FUNCTION(mod_voicemail_load)
        SWITCH_ADD_API(commands_api_interface, "vm_fsdb_msg_undelete", "vm_fsdb_msg_undelete", vm_fsdb_msg_undelete_function, VM_FSDB_MSG_UNDELETE_USAGE);
        SWITCH_ADD_API(commands_api_interface, "vm_fsdb_msg_purge", "vm_fsdb_msg_purge", vm_fsdb_msg_purge_function, VM_FSDB_MSG_PURGE_USAGE);
        SWITCH_ADD_API(commands_api_interface, "vm_fsdb_msg_save", "vm_fsdb_msg_save", vm_fsdb_msg_save_function, VM_FSDB_MSG_SAVE_USAGE);
+       SWITCH_ADD_API(commands_api_interface, "vm_fsdb_msg_forward", "vm_fsdb_msg_forward", vm_fsdb_msg_forward_function, VM_FSDB_MSG_FORWARD_USAGE);
 
        /* Preferences */
        SWITCH_ADD_API(commands_api_interface, "vm_fsdb_pref_greeting_set", "vm_fsdb_pref_greeting_set", vm_fsdb_pref_greeting_set_function, VM_FSDB_PREF_GREETING_SET_USAGE);