mirror of
https://github.com/asterisk/asterisk.git
synced 2025-09-03 03:20:57 +00:00
64aeb20724
This commit adds the ability to make ARI REST requests over the same
websocket used to receive events.
For full details on how to use the new capability, visit...
https://docs.asterisk.org/Configuration/Interfaces/Asterisk-REST-Interface-ARI/ARI-REST-over-WebSocket/
Changes:
* Added utilities to http.c:
* ast_get_http_method_from_string().
* ast_http_parse_post_form().
* Added utilities to json.c:
* ast_json_nvp_array_to_ast_variables().
* ast_variables_to_json_nvp_array().
* Added definitions for new events to carry REST responses.
* Created res/ari/ari_websocket_requests.c to house the new request handlers.
* Moved non-event specific code out of res/ari/resource_events.c into
res/ari/ari_websockets.c
* Refactored res/res_ari.c to move non-http code out of ast_ari_callback()
(which is http specific) and into ast_ari_invoke() so it can be shared
between both the http and websocket transports.
UpgradeNote: This commit adds the ability to make ARI REST requests over the same
websocket used to receive events.
See https://docs.asterisk.org/Configuration/Interfaces/Asterisk-REST-Interface-ARI/ARI-REST-over-WebSocket/
(cherry picked from commit 6bc055416b)
97 lines
3.2 KiB
C
97 lines
3.2 KiB
C
/*
|
|
* Asterisk -- An open source telephony toolkit.
|
|
*
|
|
* Copyright (C) 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.
|
|
*/
|
|
|
|
#ifndef ARI_WEBSOCKETS_H_
|
|
#define ARI_WEBSOCKETS_H_
|
|
|
|
/*! \file
|
|
*
|
|
* \brief Internal API's for websockets.
|
|
* \author David M. Lee, II <dlee@digium.com>
|
|
*/
|
|
|
|
#include "asterisk/http.h"
|
|
#include "asterisk/json.h"
|
|
#include "asterisk/vector.h"
|
|
|
|
struct ast_ari_events_event_websocket_args;
|
|
|
|
/* Forward-declare websocket structs. This avoids including http_websocket.h,
|
|
* which causes optional_api stuff to happen, which makes optional_api more
|
|
* difficult to debug. */
|
|
|
|
//struct ast_websocket_server;
|
|
struct ast_websocket;
|
|
|
|
struct ari_ws_session {
|
|
struct ast_websocket *ast_ws_session; /*!< The parent websocket session. */
|
|
int (*validator)(struct ast_json *); /*!< The message validator. */
|
|
struct ao2_container *websocket_apps; /*!< List of Stasis apps registered to
|
|
the websocket session. */
|
|
AST_VECTOR(, struct ast_json *) message_queue; /*!< Container for holding delayed messages. */
|
|
char *app_name; /*!< The name of the Stasis application. */
|
|
char session_id[]; /*!< The id for the websocket session. */
|
|
};
|
|
|
|
/*!
|
|
* \internal
|
|
* \brief Send a JSON event to a websocket.
|
|
*
|
|
* \param ari_ws_session ARI websocket session
|
|
* \param app_name Application name
|
|
* \param message JSON message
|
|
* \param debug_app Debug flag for application
|
|
*/
|
|
void ari_websocket_send_event(struct ari_ws_session *ari_ws_session,
|
|
const char *app_name, struct ast_json *message, int debug_app);
|
|
|
|
/*!
|
|
* \internal
|
|
* \brief Process an ARI REST over Websocket request
|
|
*
|
|
* \param ari_ws_session ARI websocket session
|
|
* \param remote_addr Remote address for log messages
|
|
* \param upgrade_headers HTTP headers from the upgrade request
|
|
* \param app_name Application name
|
|
* \param msg JSON Request message
|
|
* \retval 0 on success, -1 on failure
|
|
*/
|
|
int ari_websocket_process_request(struct ari_ws_session *ast_ws_session,
|
|
const char *remote_addr, struct ast_variable *upgrade_headers,
|
|
const char *app_name, struct ast_json *msg);
|
|
|
|
/*!
|
|
* \brief Wrapper for invoking the websocket code for an incoming connection.
|
|
*
|
|
* \param ws_server WebSocket server to invoke.
|
|
* \param ser HTTP session.
|
|
* \param uri Requested URI.
|
|
* \param method Requested HTTP method.
|
|
* \param get_params Parsed query parameters.
|
|
* \param headers Parsed HTTP headers.
|
|
*/
|
|
void ari_handle_websocket(struct ast_tcptls_session_instance *ser,
|
|
const char *uri, enum ast_http_method method,
|
|
struct ast_variable *get_params,
|
|
struct ast_variable *headers);
|
|
|
|
int ari_websocket_unload_module(void);
|
|
int ari_websocket_load_module(void);
|
|
|
|
#endif /* ARI_WEBSOCKETS_H_ */
|