2013-05-08 13:39:08 +00:00
|
|
|
/*
|
2013-04-22 14:58:53 +00:00
|
|
|
* 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
|
|
|
|
*
|
2013-05-08 13:39:08 +00:00
|
|
|
* \brief /api-docs/endpoints.{format} implementation- Endpoint resources
|
2013-04-22 14:58:53 +00:00
|
|
|
*
|
|
|
|
* \author David M. Lee, II <dlee@digium.com>
|
|
|
|
*/
|
|
|
|
|
|
|
|
#include "asterisk.h"
|
|
|
|
|
|
|
|
ASTERISK_FILE_VERSION(__FILE__, "$Revision$")
|
|
|
|
|
|
|
|
#include "resource_endpoints.h"
|
|
|
|
|
2013-05-08 13:39:08 +00:00
|
|
|
#include "asterisk/astobj2.h"
|
|
|
|
#include "asterisk/stasis.h"
|
|
|
|
#include "asterisk/stasis_endpoints.h"
|
|
|
|
|
2013-07-27 23:11:02 +00:00
|
|
|
void ast_ari_get_endpoints(struct ast_variable *headers,
|
2013-05-08 13:39:08 +00:00
|
|
|
struct ast_get_endpoints_args *args,
|
2013-07-27 23:11:02 +00:00
|
|
|
struct ast_ari_response *response)
|
2013-05-08 13:39:08 +00:00
|
|
|
{
|
2013-08-01 13:49:34 +00:00
|
|
|
RAII_VAR(struct stasis_cache *, cache, NULL, ao2_cleanup);
|
2013-05-08 13:39:08 +00:00
|
|
|
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;
|
|
|
|
|
2013-08-01 13:49:34 +00:00
|
|
|
cache = ast_endpoint_cache();
|
|
|
|
if (!cache) {
|
2013-07-27 23:11:02 +00:00
|
|
|
ast_ari_response_error(
|
2013-05-08 13:39:08 +00:00
|
|
|
response, 500, "Internal Server Error",
|
|
|
|
"Message bus not initialized");
|
|
|
|
return;
|
|
|
|
}
|
2013-08-01 13:49:34 +00:00
|
|
|
ao2_ref(cache, +1);
|
2013-05-08 13:39:08 +00:00
|
|
|
|
2013-08-01 13:49:34 +00:00
|
|
|
snapshots = stasis_cache_dump(cache, ast_endpoint_snapshot_type());
|
2013-05-08 13:39:08 +00:00
|
|
|
if (!snapshots) {
|
2013-07-27 23:11:02 +00:00
|
|
|
ast_ari_response_alloc_failed(response);
|
2013-05-08 13:39:08 +00:00
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
json = ast_json_array_create();
|
|
|
|
if (!json) {
|
2013-07-27 23:11:02 +00:00
|
|
|
ast_ari_response_alloc_failed(response);
|
2013-05-08 13:39:08 +00:00
|
|
|
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) {
|
2013-07-27 23:11:02 +00:00
|
|
|
ast_ari_response_alloc_failed(response);
|
2013-05-08 13:39:08 +00:00
|
|
|
return;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
ao2_iterator_destroy(&i);
|
|
|
|
|
2013-07-27 23:11:02 +00:00
|
|
|
ast_ari_response_ok(response, ast_json_ref(json));
|
2013-05-08 13:39:08 +00:00
|
|
|
}
|
2013-07-27 23:11:02 +00:00
|
|
|
void ast_ari_get_endpoints_by_tech(struct ast_variable *headers,
|
2013-05-08 13:39:08 +00:00
|
|
|
struct ast_get_endpoints_by_tech_args *args,
|
2013-07-27 23:11:02 +00:00
|
|
|
struct ast_ari_response *response)
|
2013-04-22 14:58:53 +00:00
|
|
|
{
|
2013-08-01 13:49:34 +00:00
|
|
|
RAII_VAR(struct stasis_cache *, cache, NULL, ao2_cleanup);
|
2013-05-08 13:39:08 +00:00
|
|
|
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 */
|
|
|
|
|
2013-08-01 13:49:34 +00:00
|
|
|
cache = ast_endpoint_cache();
|
|
|
|
if (!cache) {
|
2013-07-27 23:11:02 +00:00
|
|
|
ast_ari_response_error(
|
2013-05-08 13:39:08 +00:00
|
|
|
response, 500, "Internal Server Error",
|
|
|
|
"Message bus not initialized");
|
|
|
|
return;
|
|
|
|
}
|
2013-08-01 13:49:34 +00:00
|
|
|
ao2_ref(cache, +1);
|
2013-05-08 13:39:08 +00:00
|
|
|
|
2013-08-01 13:49:34 +00:00
|
|
|
snapshots = stasis_cache_dump(cache, ast_endpoint_snapshot_type());
|
2013-05-08 13:39:08 +00:00
|
|
|
if (!snapshots) {
|
2013-07-27 23:11:02 +00:00
|
|
|
ast_ari_response_alloc_failed(response);
|
2013-05-08 13:39:08 +00:00
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
json = ast_json_array_create();
|
|
|
|
if (!json) {
|
2013-07-27 23:11:02 +00:00
|
|
|
ast_ari_response_alloc_failed(response);
|
2013-05-08 13:39:08 +00:00
|
|
|
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) {
|
2013-07-27 23:11:02 +00:00
|
|
|
ast_ari_response_alloc_failed(response);
|
2013-05-08 13:39:08 +00:00
|
|
|
return;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
ao2_iterator_destroy(&i);
|
|
|
|
|
2013-07-27 23:11:02 +00:00
|
|
|
ast_ari_response_ok(response, ast_json_ref(json));
|
2013-04-22 14:58:53 +00:00
|
|
|
}
|
2013-07-27 23:11:02 +00:00
|
|
|
void ast_ari_get_endpoint(struct ast_variable *headers,
|
2013-05-08 13:39:08 +00:00
|
|
|
struct ast_get_endpoint_args *args,
|
2013-07-27 23:11:02 +00:00
|
|
|
struct ast_ari_response *response)
|
2013-04-22 14:58:53 +00:00
|
|
|
{
|
2013-05-08 13:39:08 +00:00
|
|
|
RAII_VAR(struct ast_json *, json, NULL, ast_json_unref);
|
|
|
|
RAII_VAR(struct ast_endpoint_snapshot *, snapshot, NULL, ao2_cleanup);
|
|
|
|
|
2013-06-13 11:02:16 +00:00
|
|
|
snapshot = ast_endpoint_latest_snapshot(args->tech, args->resource, 0);
|
2013-05-08 13:39:08 +00:00
|
|
|
if (!snapshot) {
|
2013-07-27 23:11:02 +00:00
|
|
|
ast_ari_response_error(response, 404, "Not Found",
|
2013-05-08 13:39:08 +00:00
|
|
|
"Endpoint not found");
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
|
|
|
json = ast_endpoint_snapshot_to_json(snapshot);
|
|
|
|
if (!json) {
|
2013-07-27 23:11:02 +00:00
|
|
|
ast_ari_response_alloc_failed(response);
|
2013-05-08 13:39:08 +00:00
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
2013-07-27 23:11:02 +00:00
|
|
|
ast_ari_response_ok(response, ast_json_ref(json));
|
2013-04-22 14:58:53 +00:00
|
|
|
}
|