summaryrefslogtreecommitdiff
path: root/res/stasis_http/resource_endpoints.c
diff options
context:
space:
mode:
authorKinsey Moore <kmoore@digium.com>2013-07-27 23:11:02 +0000
committerKinsey Moore <kmoore@digium.com>2013-07-27 23:11:02 +0000
commitd8956f690e7fe2d3b7799c16d0d44bbcbe25d83f (patch)
tree437bcde14739627193195953a5f8742eaa216333 /res/stasis_http/resource_endpoints.c
parentfc05248bd1158d587d2339c56ed27be57d333d86 (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.c157
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));
-}