diff options
author | Kinsey Moore <kmoore@digium.com> | 2013-07-27 23:11:02 +0000 |
---|---|---|
committer | Kinsey Moore <kmoore@digium.com> | 2013-07-27 23:11:02 +0000 |
commit | d8956f690e7fe2d3b7799c16d0d44bbcbe25d83f (patch) | |
tree | 437bcde14739627193195953a5f8742eaa216333 /res/stasis_http/resource_endpoints.c | |
parent | fc05248bd1158d587d2339c56ed27be57d333d86 (diff) |
Rename everything Stasis-HTTP to ARI
This renames all files and API calls from several variants of
Stasis-HTTP to ARI including:
* Stasis-HTTP -> ARI
* STASIS_HTTP -> ARI
* stasis_http -> ari (ast_ari for global symbols, file names as well)
* stasis http -> ARI
Review: https://reviewboard.asterisk.org/r/2706/
(closes issue ASTERISK-22136)
git-svn-id: https://origsvn.digium.com/svn/asterisk/trunk@395603 65c4cc65-6c06-0410-ace0-fbb531ad65f3
Diffstat (limited to 'res/stasis_http/resource_endpoints.c')
-rw-r--r-- | res/stasis_http/resource_endpoints.c | 157 |
1 files changed, 0 insertions, 157 deletions
diff --git a/res/stasis_http/resource_endpoints.c b/res/stasis_http/resource_endpoints.c deleted file mode 100644 index 306413d75..000000000 --- a/res/stasis_http/resource_endpoints.c +++ /dev/null @@ -1,157 +0,0 @@ -/* - * Asterisk -- An open source telephony toolkit. - * - * Copyright (C) 2012 - 2013, Digium, Inc. - * - * David M. Lee, II <dlee@digium.com> - * - * See http://www.asterisk.org for more information about - * the Asterisk project. Please do not directly contact - * any of the maintainers of this project for assistance; - * the project provides a web site, mailing lists and IRC - * channels for your use. - * - * This program is free software, distributed under the terms of - * the GNU General Public License Version 2. See the LICENSE file - * at the top of the source tree. - */ - -/*! \file - * - * \brief /api-docs/endpoints.{format} implementation- Endpoint resources - * - * \author David M. Lee, II <dlee@digium.com> - */ - -#include "asterisk.h" - -ASTERISK_FILE_VERSION(__FILE__, "$Revision$") - -#include "resource_endpoints.h" - -#include "asterisk/astobj2.h" -#include "asterisk/stasis.h" -#include "asterisk/stasis_endpoints.h" - -void stasis_http_get_endpoints(struct ast_variable *headers, - struct ast_get_endpoints_args *args, - struct stasis_http_response *response) -{ - RAII_VAR(struct stasis_caching_topic *, caching_topic, NULL, ao2_cleanup); - RAII_VAR(struct ao2_container *, snapshots, NULL, ao2_cleanup); - RAII_VAR(struct ast_json *, json, NULL, ast_json_unref); - struct ao2_iterator i; - void *obj; - - caching_topic = ast_endpoint_topic_all_cached(); - if (!caching_topic) { - stasis_http_response_error( - response, 500, "Internal Server Error", - "Message bus not initialized"); - return; - } - ao2_ref(caching_topic, +1); - - snapshots = stasis_cache_dump(caching_topic, ast_endpoint_snapshot_type()); - if (!snapshots) { - stasis_http_response_alloc_failed(response); - return; - } - - json = ast_json_array_create(); - if (!json) { - stasis_http_response_alloc_failed(response); - return; - } - - i = ao2_iterator_init(snapshots, 0); - while ((obj = ao2_iterator_next(&i))) { - RAII_VAR(struct stasis_message *, msg, obj, ao2_cleanup); - struct ast_endpoint_snapshot *snapshot = stasis_message_data(msg); - int r = ast_json_array_append( - json, ast_endpoint_snapshot_to_json(snapshot)); - if (r != 0) { - stasis_http_response_alloc_failed(response); - return; - } - } - ao2_iterator_destroy(&i); - - stasis_http_response_ok(response, ast_json_ref(json)); -} -void stasis_http_get_endpoints_by_tech(struct ast_variable *headers, - struct ast_get_endpoints_by_tech_args *args, - struct stasis_http_response *response) -{ - RAII_VAR(struct stasis_caching_topic *, caching_topic, NULL, ao2_cleanup); - RAII_VAR(struct ao2_container *, snapshots, NULL, ao2_cleanup); - RAII_VAR(struct ast_json *, json, NULL, ast_json_unref); - struct ao2_iterator i; - void *obj; - - /* TODO - if tech isn't a recognized type of endpoint, it should 404 */ - - caching_topic = ast_endpoint_topic_all_cached(); - if (!caching_topic) { - stasis_http_response_error( - response, 500, "Internal Server Error", - "Message bus not initialized"); - return; - } - ao2_ref(caching_topic, +1); - - snapshots = stasis_cache_dump(caching_topic, ast_endpoint_snapshot_type()); - if (!snapshots) { - stasis_http_response_alloc_failed(response); - return; - } - - json = ast_json_array_create(); - if (!json) { - stasis_http_response_alloc_failed(response); - return; - } - - i = ao2_iterator_init(snapshots, 0); - while ((obj = ao2_iterator_next(&i))) { - RAII_VAR(struct stasis_message *, msg, obj, ao2_cleanup); - struct ast_endpoint_snapshot *snapshot = stasis_message_data(msg); - int r; - - if (strcmp(args->tech, snapshot->tech) != 0) { - continue; - } - - r = ast_json_array_append( - json, ast_endpoint_snapshot_to_json(snapshot)); - if (r != 0) { - stasis_http_response_alloc_failed(response); - return; - } - } - ao2_iterator_destroy(&i); - - stasis_http_response_ok(response, ast_json_ref(json)); -} -void stasis_http_get_endpoint(struct ast_variable *headers, - struct ast_get_endpoint_args *args, - struct stasis_http_response *response) -{ - RAII_VAR(struct ast_json *, json, NULL, ast_json_unref); - RAII_VAR(struct ast_endpoint_snapshot *, snapshot, NULL, ao2_cleanup); - - snapshot = ast_endpoint_latest_snapshot(args->tech, args->resource, 0); - if (!snapshot) { - stasis_http_response_error(response, 404, "Not Found", - "Endpoint not found"); - return; - } - - json = ast_endpoint_snapshot_to_json(snapshot); - if (!json) { - stasis_http_response_alloc_failed(response); - return; - } - - stasis_http_response_ok(response, ast_json_ref(json)); -} |