mirror of
https://github.com/asterisk/asterisk.git
synced 2025-10-24 05:38:11 +00:00
ari: Add a copy operation for stored recordings
This patch adds a new operation for stored recordings, copy. It takes an
existing stored recording and makes a copy of it in the same directory
or a relative directory under the stored recording directory.
/ari/recordings/stored/{recordingName}/copy?destinationRecordingName={copy_name}
This is particularly useful for voicemail-esque applications, which may need to
copy or move recordings around a directory structure.
Review: https://reviewboard.asterisk.org/r/3768/
ASTERISK-24036 #close
Reported by: Sam Galarneau
Tested by: Sam Galarneau
........
Merged revisions 419021 from http://svn.asterisk.org/svn/asterisk/branches/12
git-svn-id: https://origsvn.digium.com/svn/asterisk/trunk@419022 65c4cc65-6c06-0410-ace0-fbb531ad65f3
This commit is contained in:
@@ -96,6 +96,79 @@ void ast_ari_recordings_get_stored(struct ast_variable *headers,
|
||||
ast_ari_response_ok(response, json);
|
||||
}
|
||||
|
||||
void ast_ari_recordings_copy_stored(struct ast_variable *headers,
|
||||
struct ast_ari_recordings_copy_stored_args *args,
|
||||
struct ast_ari_response *response)
|
||||
{
|
||||
RAII_VAR(struct stasis_app_stored_recording *, src_recording, NULL,
|
||||
ao2_cleanup);
|
||||
RAII_VAR(struct stasis_app_stored_recording *, dst_recording, NULL,
|
||||
ao2_cleanup);
|
||||
struct ast_json *json;
|
||||
int res;
|
||||
|
||||
src_recording = stasis_app_stored_recording_find_by_name(
|
||||
args->recording_name);
|
||||
if (src_recording == NULL) {
|
||||
ast_ari_response_error(response, 404, "Not Found",
|
||||
"Recording not found");
|
||||
return;
|
||||
}
|
||||
|
||||
dst_recording = stasis_app_stored_recording_find_by_name(
|
||||
args->destination_recording_name);
|
||||
if (dst_recording) {
|
||||
ast_ari_response_error(response, 409, "Conflict",
|
||||
"A recording with the same name already exists on the system");
|
||||
return;
|
||||
}
|
||||
|
||||
/* See if we got our name rejected */
|
||||
switch (errno) {
|
||||
case EINVAL:
|
||||
ast_ari_response_error(response, 400, "Bad request",
|
||||
"Invalid destination recording name");
|
||||
return;
|
||||
case EACCES:
|
||||
ast_ari_response_error(response, 403, "Forbidden",
|
||||
"Destination file path is forbidden");
|
||||
return;
|
||||
default:
|
||||
break;
|
||||
}
|
||||
|
||||
res = stasis_app_stored_recording_copy(src_recording,
|
||||
args->destination_recording_name, &dst_recording);
|
||||
if (res) {
|
||||
switch (errno) {
|
||||
case EACCES:
|
||||
case EPERM:
|
||||
ast_ari_response_error(response, 500,
|
||||
"Internal Server Error",
|
||||
"Copy failed");
|
||||
break;
|
||||
default:
|
||||
ast_log(LOG_WARNING,
|
||||
"Unexpected error copying recording %s to %s: %s\n",
|
||||
args->recording_name, args->destination_recording_name, strerror(errno));
|
||||
ast_ari_response_error(response, 500,
|
||||
"Internal Server Error",
|
||||
"Copy failed");
|
||||
break;
|
||||
}
|
||||
return;
|
||||
}
|
||||
|
||||
json = stasis_app_stored_recording_to_json(dst_recording);
|
||||
if (json == NULL) {
|
||||
ast_ari_response_error(response, 500,
|
||||
"Internal Server Error", "Error building response");
|
||||
return;
|
||||
}
|
||||
|
||||
ast_ari_response_ok(response, json);
|
||||
}
|
||||
|
||||
void ast_ari_recordings_delete_stored(struct ast_variable *headers,
|
||||
struct ast_ari_recordings_delete_stored_args *args,
|
||||
struct ast_ari_response *response)
|
||||
|
||||
@@ -76,6 +76,32 @@ struct ast_ari_recordings_delete_stored_args {
|
||||
* \param[out] response HTTP response
|
||||
*/
|
||||
void ast_ari_recordings_delete_stored(struct ast_variable *headers, struct ast_ari_recordings_delete_stored_args *args, struct ast_ari_response *response);
|
||||
/*! Argument struct for ast_ari_recordings_copy_stored() */
|
||||
struct ast_ari_recordings_copy_stored_args {
|
||||
/*! The name of the recording to copy */
|
||||
const char *recording_name;
|
||||
/*! The destination name of the recording */
|
||||
const char *destination_recording_name;
|
||||
};
|
||||
/*!
|
||||
* \brief Body parsing function for /recordings/stored/{recordingName}/copy.
|
||||
* \param body The JSON body from which to parse parameters.
|
||||
* \param[out] args The args structure to parse into.
|
||||
* \retval zero on success
|
||||
* \retval non-zero on failure
|
||||
*/
|
||||
int ast_ari_recordings_copy_stored_parse_body(
|
||||
struct ast_json *body,
|
||||
struct ast_ari_recordings_copy_stored_args *args);
|
||||
|
||||
/*!
|
||||
* \brief Copy a stored recording.
|
||||
*
|
||||
* \param headers HTTP headers
|
||||
* \param args Swagger parameters
|
||||
* \param[out] response HTTP response
|
||||
*/
|
||||
void ast_ari_recordings_copy_stored(struct ast_variable *headers, struct ast_ari_recordings_copy_stored_args *args, struct ast_ari_response *response);
|
||||
/*! Argument struct for ast_ari_recordings_get_live() */
|
||||
struct ast_ari_recordings_get_live_args {
|
||||
/*! The name of the recording */
|
||||
|
||||
Reference in New Issue
Block a user