Asterisk - The Open Source Telephony Project GIT-master-f36a736
Data Structures | Macros | Functions
ari_websockets.c File Reference

WebSocket support for RESTful API's. More...

#include "asterisk.h"
#include "asterisk/ari.h"
#include "asterisk/astobj2.h"
#include "asterisk/http_websocket.h"
#include "asterisk/stasis_app.h"
#include "internal.h"
Include dependency graph for ari_websockets.c:

Go to the source code of this file.

Data Structures

struct  ast_ari_websocket_session
 

Macros

#define VALIDATION_FAILED
 

Functions

void ari_handle_websocket (struct ast_websocket_server *ws_server, struct ast_tcptls_session_instance *ser, const char *uri, enum ast_http_method method, struct ast_variable *get_params, struct ast_variable *headers)
 Wrapper for invoking the websocket code for an incoming connection. More...
 
struct ast_ari_websocket_session * ast_ari_websocket_session_create (struct ast_websocket *ws_session, int(*validator)(struct ast_json *))
 Create an ARI WebSocket session. More...
 
struct ast_sockaddr * ast_ari_websocket_session_get_remote_addr (struct ast_ari_websocket_session *session)
 Get the remote address from an ARI WebSocket. More...
 
const char * ast_ari_websocket_session_id (const struct ast_ari_websocket_session *session)
 Get the Session ID for an ARI WebSocket. More...
 
struct ast_json * ast_ari_websocket_session_read (struct ast_ari_websocket_session *session)
 Read a message from an ARI WebSocket. More...
 
int ast_ari_websocket_session_write (struct ast_ari_websocket_session *session, struct ast_json *message)
 Send a message to an ARI WebSocket. More...
 
static int null_validator (struct ast_json *json)
 Validator that always succeeds. More...
 
static void websocket_session_dtor (void *obj)
 

Detailed Description

WebSocket support for RESTful API's.

Author
David M. Lee, II dlee@.nosp@m.digi.nosp@m.um.co.nosp@m.m

Definition in file ari_websockets.c.

Macro Definition Documentation

◆ VALIDATION_FAILED

#define VALIDATION_FAILED
Value:
"{" \
" \"error\": \"InvalidMessage\"," \
" \"message\": \"Message validation failed\"" \
"}"

Definition at line 152 of file ari_websockets.c.

Function Documentation

◆ ari_handle_websocket()

void ari_handle_websocket ( struct ast_websocket_server *  ws_server,
struct ast_tcptls_session_instance *  ser,
const char *  uri,
enum ast_http_method  method,
struct ast_variable *  get_params,
struct ast_variable *  headers 
)

Wrapper for invoking the websocket code for an incoming connection.

Parameters
ws_serverWebSocket server to invoke.
serHTTP session.
uriRequested URI.
methodRequested HTTP method.
get_paramsParsed query parameters.
headersParsed HTTP headers.

Definition at line 191 of file ari_websockets.c.

195{
196 struct ast_http_uri fake_urih = {
197 .data = ws_server,
198 };
199 ast_websocket_uri_cb(ser, &fake_urih, uri, method, get_params,
200 headers);
201}
ast_websocket_uri_cb
int ast_websocket_uri_cb(struct ast_tcptls_session_instance *ser, const struct ast_http_uri *urih, const char *uri, enum ast_http_method method, struct ast_variable *get_vars, struct ast_variable *headers)
Callback suitable for use with a ast_http_uri.
Definition: res_http_websocket.c:790
method
const char * method
Definition: res_pjsip.c:1279
ast_http_uri
Definition of a URI handler.
Definition: http.h:102
ast_http_uri::uri
const char * uri
Definition: http.h:105
ast_http_uri::data
void * data
Definition: http.h:116

References ast_websocket_uri_cb(), ast_http_uri::data, method, and ast_http_uri::uri.

Referenced by ast_ari_invoke().

◆ ast_ari_websocket_session_create()

struct ast_ari_websocket_session * ast_ari_websocket_session_create ( struct ast_websocket *  ws_session,
int(*)(struct ast_json *)  validator 
)

Create an ARI WebSocket session.

If NULL is given for the validator function, no validation will be performed.

Parameters
ws_sessionUnderlying WebSocket session.
validatorFunction to validate outgoing messages.
Returns
New ARI WebSocket session.
Return values
NULLon error.

Definition at line 54 of file ari_websockets.c.

56{
57 RAII_VAR(struct ast_ari_websocket_session *, session, NULL, ao2_cleanup);
58 RAII_VAR(struct ast_ari_conf *, config, ast_ari_config_get(), ao2_cleanup);
59
60 if (ws_session == NULL) {
61 return NULL;
62 }
63
64 if (config == NULL || config->general == NULL) {
65 return NULL;
66 }
67
68 if (validator == NULL) {
69 validator = null_validator;
70 }
71
72 if (ast_websocket_set_nonblock(ws_session) != 0) {
73 ast_log(LOG_ERROR,
74 "ARI web socket failed to set nonblock; closing: %s\n",
75 strerror(errno));
76 return NULL;
77 }
78
79 if (ast_websocket_set_timeout(ws_session, config->general->write_timeout)) {
80 ast_log(LOG_WARNING, "Failed to set write timeout %d on ARI web socket\n",
81 config->general->write_timeout);
82 }
83
84 session = ao2_alloc(sizeof(*session), websocket_session_dtor);
85 if (!session) {
86 return NULL;
87 }
88
89 ao2_ref(ws_session, +1);
90 session->ws_session = ws_session;
91 session->validator = validator;
92
93 ao2_ref(session, +1);
94 return session;
95}
null_validator
static int null_validator(struct ast_json *json)
Validator that always succeeds.
Definition: ari_websockets.c:49
websocket_session_dtor
static void websocket_session_dtor(void *obj)
Definition: ari_websockets.c:38
session
static struct ast_mansession session
ast_log
#define ast_log
Definition: astobj2.c:42
ao2_cleanup
#define ao2_cleanup(obj)
Definition: astobj2.h:1934
ao2_ref
#define ao2_ref(o, delta)
Reference/unreference an object and return the old refcount.
Definition: astobj2.h:459
ao2_alloc
#define ao2_alloc(data_size, destructor_fn)
Definition: astobj2.h:409
config
static const char config[]
Definition: chan_ooh323.c:111
ast_websocket_set_timeout
int ast_websocket_set_timeout(struct ast_websocket *session, int timeout)
Set the timeout on a non-blocking WebSocket session.
Definition: res_http_websocket.c:493
ast_websocket_set_nonblock
int ast_websocket_set_nonblock(struct ast_websocket *session)
Set the socket of a WebSocket session to be non-blocking.
Definition: res_http_websocket.c:486
LOG_ERROR
#define LOG_ERROR
Definition: include/asterisk/logger.h:292
LOG_WARNING
#define LOG_WARNING
Definition: include/asterisk/logger.h:281
errno
int errno
ast_ari_config_get
struct ast_ari_conf * ast_ari_config_get(void)
Get the current ARI configuration.
Definition: res/ari/config.c:227
NULL
#define NULL
Definition: resample.c:96
ast_ari_conf
All configuration options for ARI.
Definition: internal.h:54
ast_ari_websocket_session
Definition: ari_websockets.c:33
RAII_VAR
#define RAII_VAR(vartype, varname, initval, dtor)
Declare a variable that will call a destructor function when it goes out of scope.
Definition: utils.h:941

References ao2_alloc, ao2_cleanup, ao2_ref, ast_ari_config_get(), ast_log, ast_websocket_set_nonblock(), ast_websocket_set_timeout(), config, errno, LOG_ERROR, LOG_WARNING, NULL, null_validator(), RAII_VAR, session, ast_ari_websocket_session::validator, websocket_session_dtor(), and ast_ari_websocket_session::ws_session.

Referenced by ast_ari_events_event_websocket_ws_established_cb().

◆ ast_ari_websocket_session_get_remote_addr()

struct ast_sockaddr * ast_ari_websocket_session_get_remote_addr ( struct ast_ari_websocket_session *  session)

Get the remote address from an ARI WebSocket.

Parameters
sessionSession to write to.
Returns
ast_sockaddr (does not have to be freed)

Definition at line 185 of file ari_websockets.c.

187{
188 return ast_websocket_remote_address(session->ws_session);
189}
ast_websocket_remote_address
struct ast_sockaddr * ast_websocket_remote_address(struct ast_websocket *session)
Get the remote address for a WebSocket connected session.
Definition: res_http_websocket.c:471

References ast_websocket_remote_address(), and session.

Referenced by ast_ari_websocket_session_write(), and stasis_app_message_handler().

◆ ast_ari_websocket_session_id()

const char * ast_ari_websocket_session_id ( const struct ast_ari_websocket_session *  session)

Get the Session ID for an ARI WebSocket.

Parameters
sessionSession to query.
Returns
Session ID.
Return values
NULLon error.

Definition at line 203 of file ari_websockets.c.

205{
206 return ast_websocket_session_id(session->ws_session);
207}
ast_websocket_session_id
const char * ast_websocket_session_id(struct ast_websocket *session)
Get the session ID for a WebSocket session.
Definition: res_http_websocket.c:500

References ast_websocket_session_id(), and session.

Referenced by ast_ari_websocket_events_event_websocket_established().

◆ ast_ari_websocket_session_read()

struct ast_json * ast_ari_websocket_session_read ( struct ast_ari_websocket_session *  session)

Read a message from an ARI WebSocket.

Parameters
sessionSession to read from.
Returns
Message received.
Return values
NULLif WebSocket could not be read.

Definition at line 97 of file ari_websockets.c.

99{
100 RAII_VAR(struct ast_json *, message, NULL, ast_json_unref);
101
102 if (ast_websocket_fd(session->ws_session) < 0) {
103 return NULL;
104 }
105
106 while (!message) {
107 int res;
108 char *payload;
109 uint64_t payload_len;
110 enum ast_websocket_opcode opcode;
111 int fragmented;
112
113 res = ast_wait_for_input(
114 ast_websocket_fd(session->ws_session), -1);
115
116 if (res <= 0) {
117 ast_log(LOG_WARNING, "WebSocket poll error: %s\n",
118 strerror(errno));
119 return NULL;
120 }
121
122 res = ast_websocket_read(session->ws_session, &payload,
123 &payload_len, &opcode, &fragmented);
124
125 if (res != 0) {
126 ast_log(LOG_WARNING, "WebSocket read error: %s\n",
127 strerror(errno));
128 return NULL;
129 }
130
131 switch (opcode) {
132 case AST_WEBSOCKET_OPCODE_CLOSE:
133 ast_debug(1, "WebSocket closed\n");
134 return NULL;
135 case AST_WEBSOCKET_OPCODE_TEXT:
136 message = ast_json_load_buf(payload, payload_len, NULL);
137 if (message == NULL) {
138 ast_log(LOG_WARNING,
139 "WebSocket input failed to parse\n");
140 }
141
142 break;
143 default:
144 /* Ignore all other message types */
145 break;
146 }
147 }
148
149 return ast_json_ref(message);
150}
ast_websocket_read
int ast_websocket_read(struct ast_websocket *session, char **payload, uint64_t *payload_len, enum ast_websocket_opcode *opcode, int *fragmented)
Read a WebSocket frame and handle it.
Definition: res_http_websocket.c:602
ast_websocket_opcode
ast_websocket_opcode
WebSocket operation codes.
Definition: http_websocket.h:51
AST_WEBSOCKET_OPCODE_CLOSE
@ AST_WEBSOCKET_OPCODE_CLOSE
Definition: http_websocket.h:56
AST_WEBSOCKET_OPCODE_TEXT
@ AST_WEBSOCKET_OPCODE_TEXT
Definition: http_websocket.h:52
ast_websocket_fd
int ast_websocket_fd(struct ast_websocket *session)
Get the file descriptor for a WebSocket session.
Definition: res_http_websocket.c:461
ast_debug
#define ast_debug(level,...)
Log a DEBUG message.
Definition: include/asterisk/logger.h:457
ast_json_unref
void ast_json_unref(struct ast_json *value)
Decrease refcount on value. If refcount reaches zero, value is freed.
Definition: json.c:73
ast_json_ref
struct ast_json * ast_json_ref(struct ast_json *value)
Increase refcount on value.
Definition: json.c:67
ast_json_load_buf
struct ast_json * ast_json_load_buf(const char *buffer, size_t buflen, struct ast_json_error *error)
Parse buffer with known length into a JSON object or array.
Definition: json.c:585
ast_json
Abstract JSON element (object, array, string, int, ...).
ast_wait_for_input
int ast_wait_for_input(int fd, int ms)
Definition: utils.c:1698

References ast_debug, ast_json_load_buf(), ast_json_ref(), ast_json_unref(), ast_log, ast_wait_for_input(), ast_websocket_fd(), AST_WEBSOCKET_OPCODE_CLOSE, AST_WEBSOCKET_OPCODE_TEXT, ast_websocket_read(), errno, LOG_WARNING, NULL, RAII_VAR, and session.

Referenced by ast_ari_websocket_events_event_websocket_established().

◆ ast_ari_websocket_session_write()

int ast_ari_websocket_session_write ( struct ast_ari_websocket_session *  session,
struct ast_json *  message 
)

Send a message to an ARI WebSocket.

Parameters
sessionSession to write to.
messageMessage to send.
Return values
0on success.
Non-zeroon error.

Definition at line 158 of file ari_websockets.c.

160{
161 RAII_VAR(char *, str, NULL, ast_json_free);
162
163#ifdef AST_DEVMODE
164 if (!session->validator(message)) {
165 ast_log(LOG_ERROR, "Outgoing message failed validation\n");
166 return ast_websocket_write_string(session->ws_session, VALIDATION_FAILED);
167 }
168#endif
169
170 str = ast_json_dump_string_format(message, ast_ari_json_format());
171
172 if (str == NULL) {
173 ast_log(LOG_ERROR, "Failed to encode JSON object\n");
174 return -1;
175 }
176
177 if (ast_websocket_write_string(session->ws_session, str)) {
178 ast_log(LOG_NOTICE, "Problem occurred during websocket write to %s, websocket closed\n",
179 ast_sockaddr_stringify(ast_ari_websocket_session_get_remote_addr(session)));
180 return -1;
181 }
182 return 0;
183}
str
const char * str
Definition: app_jack.c:147
ast_ari_json_format
enum ast_json_encoding_format ast_ari_json_format(void)
Configured encoding format for JSON output.
Definition: res_ari.c:806
ast_ari_websocket_session_get_remote_addr
struct ast_sockaddr * ast_ari_websocket_session_get_remote_addr(struct ast_ari_websocket_session *session)
Get the remote address from an ARI WebSocket.
Definition: ari_websockets.c:185
VALIDATION_FAILED
#define VALIDATION_FAILED
Definition: ari_websockets.c:152
ast_websocket_write_string
int ast_websocket_write_string(struct ast_websocket *ws, const char *buf)
Construct and transmit a WebSocket frame containing string data.
Definition: res_http_websocket.c:1516
LOG_NOTICE
#define LOG_NOTICE
Definition: include/asterisk/logger.h:270
ast_json_free
void ast_json_free(void *p)
Asterisk's custom JSON allocator. Exposed for use by unit tests.
Definition: json.c:52
ast_json_dump_string_format
char * ast_json_dump_string_format(struct ast_json *root, enum ast_json_encoding_format format)
Encode a JSON value to a string.
Definition: json.c:484
ast_sockaddr_stringify
static char * ast_sockaddr_stringify(const struct ast_sockaddr *addr)
Wrapper around ast_sockaddr_stringify_fmt() with default format.
Definition: netsock2.h:256

References ast_ari_json_format(), ast_ari_websocket_session_get_remote_addr(), ast_json_dump_string_format(), ast_json_free(), ast_log, ast_sockaddr_stringify(), ast_websocket_write_string(), LOG_ERROR, LOG_NOTICE, NULL, RAII_VAR, session, str, and VALIDATION_FAILED.

Referenced by event_session_update_websocket(), and stasis_app_message_handler().

◆ null_validator()

static int null_validator ( struct ast_json *  json)
static

Validator that always succeeds.

Definition at line 49 of file ari_websockets.c.

50{
51 return 1;
52}

Referenced by ast_ari_websocket_session_create().

◆ websocket_session_dtor()

static void websocket_session_dtor ( void *  obj)
static

Definition at line 38 of file ari_websockets.c.

39{
40 struct ast_ari_websocket_session *session = obj;
41
42 ast_websocket_unref(session->ws_session);
43 session->ws_session = NULL;
44}
ast_websocket_unref
void ast_websocket_unref(struct ast_websocket *session)
Decrease the reference count for a WebSocket session.
Definition: res_http_websocket.c:456

References ast_websocket_unref(), NULL, and session.

Referenced by ast_ari_websocket_session_create().

Generated on Wed Dec 18 2024 20:04:38 for Asterisk - The Open Source Telephony Project by doxygen 1.9.4