res/ari/cli.c File Reference

Command line for ARI. More...

#include "asterisk.h"
#include "asterisk/astobj2.h"
#include "asterisk/cli.h"
#include "asterisk/stasis_app.h"
#include "asterisk/uuid.h"
#include "internal.h"
#include "ari_websockets.h"

Include dependency graph for res/ari/cli.c:

Go to the source code of this file.

Macros
#define	DASHES   "----------------------------------------------------------------------"
#define	DASHES   "----------------------------------------------------------------------"

Functions
int	ari_cli_register (void)
	Register CLI commands for ARI. More...
void	ari_cli_unregister (void)
	Unregister CLI commands for ARI. More...
static char *	ari_mkpasswd (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	ari_set_debug (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	ari_show (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	ari_show_app (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	ari_show_apps (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	ari_show_owc (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	ari_show_owcs (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	ari_show_sessions (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	ari_show_user (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	ari_show_users (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	ari_shut_session (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	ari_shut_sessions (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char *	ari_start_owc (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static void	complete_app (struct ao2_container *container, const char *word)
static void	complete_session (struct ao2_container *container, const char *word)
static void	complete_sorcery_object (struct ao2_container *container, const char *word)
static int	show_owc_cb (void *obj, void *arg, int flags)
static int	show_sessions_cb (void *obj, void *arg, int flags)
static int	show_users_cb (void *obj, void *arg, int flags)

Variables
static struct ast_cli_entry	cli_ari []

Detailed Description

Command line for ARI.

Author

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

Definition in file res/ari/cli.c.

Macro Definition Documentation

DASHES [1/2]

#define DASHES   "----------------------------------------------------------------------"

Definition at line 555 of file res/ari/cli.c.

DASHES [2/2]

#define DASHES   "----------------------------------------------------------------------"

Definition at line 555 of file res/ari/cli.c.

Function Documentation

ari_cli_register()

int ari_cli_register

(

void

)

Register CLI commands for ARI.

Returns

0 on success.

Non-zero on error.

Definition at line 699 of file res/ari/cli.c.

                           {
    return ast_cli_register_multiple(cli_ari, ARRAY_LEN(cli_ari));
}

References ARRAY_LEN, ast_cli_register_multiple, and cli_ari.

Referenced by load_module().

ari_cli_unregister()

void ari_cli_unregister

(

void

)

Unregister CLI commands for ARI.

Definition at line 703 of file res/ari/cli.c.

                              {
    ast_cli_unregister_multiple(cli_ari, ARRAY_LEN(cli_ari));
}

References ARRAY_LEN, ast_cli_unregister_multiple(), and cli_ari.

Referenced by unload_module().

ari_mkpasswd()

static char * ari_mkpasswd ( struct ast_cli_entry *  e, int  cmd, struct ast_cli_args *  a  )

static

Definition at line 180 of file res/ari/cli.c.

{
    RAII_VAR(char *, crypted, NULL, ast_free);
 
    switch (cmd) {
    case CLI_INIT:
        e->command = "ari mkpasswd";
        e->usage =
            "Usage: ari mkpasswd <password>\n"
            "       Encrypts a password for use in ari.conf\n"
            "       Be aware that the password will be shown in the\n"
            "       command line history. The mkpasswd shell command\n"
            "       may be preferable.\n"
            ;
        return NULL;
    case CLI_GENERATE:
        return NULL;
    default:
        break;
    }
 
    if (a->argc != 3) {
        return CLI_SHOWUSAGE;
    }
 
    crypted = ast_crypt_encrypt(a->argv[2]);
    if (!crypted) {
        ast_cli(a->fd, "Failed to encrypt password\n");
        return CLI_FAILURE;
    }
 
    ast_cli(a->fd,
        "; Copy the following two lines into ari.conf\n");
    ast_cli(a->fd, "password_format = crypt\n");
    ast_cli(a->fd, "password = %s\n", crypted);
 
    return CLI_SUCCESS;
}

References a, ast_cli(), ast_crypt_encrypt(), ast_free, CLI_FAILURE, CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, ast_cli_entry::command, NULL, RAII_VAR, and ast_cli_entry::usage.

ari_set_debug()

static char * ari_set_debug ( struct ast_cli_entry *  e, int  cmd, struct ast_cli_args *  a  )

static

Definition at line 320 of file res/ari/cli.c.

{
    RAII_VAR(struct ao2_container *, apps, stasis_app_get_all(), ao2_cleanup);
    void *app;
    int debug;
 
    if (!apps) {
        ast_cli(a->fd, "Error getting ARI applications\n");
        return CLI_FAILURE;
    }
 
    switch (cmd) {
    case CLI_INIT:
        e->command = "ari set debug";
        e->usage =
            "Usage: ari set debug <application|all> <on|off>\n"
            "       Enable or disable debugging on a specific application.\n"
            ;
        return NULL;
    case CLI_GENERATE:
        if (a->argc == 3) {
            ast_cli_completion_add(ast_strdup("all"));
            complete_app(apps, a->word);
        } else if (a->argc == 4) {
            ast_cli_completion_add(ast_strdup("on"));
            ast_cli_completion_add(ast_strdup("off"));
        }
        return NULL;
    default:
        break;
    }
 
    if (a->argc != 5) {
        return CLI_SHOWUSAGE;
    }
 
    debug = !strcmp(a->argv[4], "on");
 
    if (!strcmp(a->argv[3], "all")) {
        stasis_app_set_global_debug(debug);
        ast_cli(a->fd, "Debugging on all applications %s\n",
            debug ? "enabled" : "disabled");
        return CLI_SUCCESS;
    }
 
    app = stasis_app_get_by_name(a->argv[3]);
    if (!app) {
        return CLI_FAILURE;
    }
 
    stasis_app_set_debug(app, debug);
    ast_cli(a->fd, "Debugging on '%s' %s\n",
        stasis_app_name(app),
        debug ? "enabled" : "disabled");
 
    ao2_ref(app, -1);
 
    return CLI_SUCCESS;
}

References a, ao2_cleanup, ao2_ref, app, ast_cli(), ast_cli_completion_add(), ast_strdup, CLI_FAILURE, CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, ast_cli_entry::command, complete_app(), debug, NULL, RAII_VAR, stasis_app_get_all(), stasis_app_get_by_name(), stasis_app_name(), stasis_app_set_debug(), stasis_app_set_global_debug(), and ast_cli_entry::usage.

ari_show()

static char * ari_show ( struct ast_cli_entry *  e, int  cmd, struct ast_cli_args *  a  )

static

Definition at line 34 of file res/ari/cli.c.

{
    RAII_VAR(struct ari_conf_general *, general, NULL, ao2_cleanup);
 
    switch (cmd) {
    case CLI_INIT:
        e->command = "ari show status";
        e->usage =
            "Usage: ari show status\n"
            "       Shows all ARI settings\n";
        return NULL;
    case CLI_GENERATE:
        return NULL;
    default:
        break;
    }
 
    if (a->argc != 3) {
        return CLI_SHOWUSAGE;
    }
 
    general = ari_conf_get_general();
 
    if (!general) {
        ast_cli(a->fd, "Error getting ARI configuration\n");
        return CLI_FAILURE;
    }
 
    ast_cli(a->fd, "ARI Status:\n");
    ast_cli(a->fd, "Enabled: %s\n", AST_CLI_YESNO(general->enabled));
    ast_cli(a->fd, "Output format: ");
    if (general->format & AST_JSON_PRETTY) {
        ast_cli(a->fd, "pretty");
    } else {
        ast_cli(a->fd, "compact");
    }
    ast_cli(a->fd, "\n");
    ast_cli(a->fd, "Auth realm: %s\n", general->auth_realm);
    ast_cli(a->fd, "Allowed Origins: %s\n", general->allowed_origins);
    return CLI_SUCCESS;
}

References a, ao2_cleanup, ari_conf_get_general(), ast_cli(), AST_CLI_YESNO, AST_JSON_PRETTY, CLI_FAILURE, CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, ast_cli_entry::command, NULL, RAII_VAR, and ast_cli_entry::usage.

ari_show_app()

static char * ari_show_app ( struct ast_cli_entry *  e, int  cmd, struct ast_cli_args *  a  )

static

Definition at line 279 of file res/ari/cli.c.

{
    void *app;
    RAII_VAR(struct ao2_container *, apps, stasis_app_get_all(), ao2_cleanup);
 
    if (!apps) {
        ast_cli(a->fd, "Error getting ARI applications\n");
        return CLI_FAILURE;
    }
 
    switch (cmd) {
    case CLI_INIT:
        e->command = "ari show app";
        e->usage =
            "Usage: ari show app <application>\n"
            "       Provide detailed information about a registered application.\n"
            ;
        return NULL;
    case CLI_GENERATE:
        complete_app(apps, a->word);
        return NULL;
    default:
        break;
    }
 
    if (a->argc != 4) {
        return CLI_SHOWUSAGE;
    }
 
    app = stasis_app_get_by_name(a->argv[3]);
    if (!app) {
        return CLI_FAILURE;
    }
 
    stasis_app_to_cli(app, a);
 
    ao2_ref(app, -1);
 
    return CLI_SUCCESS;
}

References a, ao2_cleanup, ao2_ref, app, ast_cli(), CLI_FAILURE, CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, ast_cli_entry::command, complete_app(), NULL, RAII_VAR, stasis_app_get_all(), stasis_app_get_by_name(), stasis_app_to_cli(), and ast_cli_entry::usage.

ari_show_apps()

static char * ari_show_apps ( struct ast_cli_entry *  e, int  cmd, struct ast_cli_args *  a  )

static

Definition at line 219 of file res/ari/cli.c.

{
    struct ao2_container *apps;
    struct ao2_iterator it_apps;
    char *app;
 
    switch (cmd) {
    case CLI_INIT:
        e->command = "ari show apps";
        e->usage =
            "Usage: ari show apps\n"
            "       Lists all registered applications.\n"
            ;
        return NULL;
    case CLI_GENERATE:
        return NULL;
    default:
        break;
    }
 
    if (a->argc != 3) {
        return CLI_SHOWUSAGE;
    }
 
    apps = stasis_app_get_all();
    if (!apps) {
        ast_cli(a->fd, "Unable to retrieve registered applications!\n");
        return CLI_FAILURE;
    }
 
    ast_cli(a->fd, "Application Name         \n");
    ast_cli(a->fd, "=========================\n");
    it_apps = ao2_iterator_init(apps, 0);
    while ((app = ao2_iterator_next(&it_apps))) {
        ast_cli(a->fd, "%s\n", app);
        ao2_ref(app, -1);
    }
 
    ao2_iterator_destroy(&it_apps);
    ao2_ref(apps, -1);
 
    return CLI_SUCCESS;
}

References a, ao2_iterator_destroy(), ao2_iterator_init(), ao2_iterator_next, ao2_ref, app, apps, ast_cli(), CLI_FAILURE, CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, ast_cli_entry::command, NULL, stasis_app_get_all(), and ast_cli_entry::usage.

ari_show_owc()

static char * ari_show_owc ( struct ast_cli_entry *  e, int  cmd, struct ast_cli_args *  a  )

static

Definition at line 433 of file res/ari/cli.c.

{
    RAII_VAR(struct ari_conf_outbound_websocket *, owc, NULL, ao2_cleanup);
    RAII_VAR(struct ao2_container *, owcs, ari_conf_get_owcs(), ao2_cleanup);
    const char *id = NULL;
    enum ari_conf_owc_fields invalid_fields;
 
    switch (cmd) {
    case CLI_INIT:
        e->command = "ari show outbound-websocket";
        e->usage =
            "Usage: ari show outbound-websocket <connection id>\n"
            "       Shows a specific ARI outbound websocket\n";
        return NULL;
    case CLI_GENERATE:
        complete_sorcery_object(owcs, a->word);
        return NULL;
    default:
        break;
    }
 
    if (a->argc != 4) {
        return CLI_SHOWUSAGE;
    }
 
    owc = ari_conf_get_owc(a->argv[3]);
    if (!owc) {
        ast_cli(a->fd, "Error getting ARI configuration\n");
        return CLI_FAILURE;
    }
    id = ast_sorcery_object_get_id(owc);
    invalid_fields = ari_conf_owc_get_invalid_fields(id);
 
    ast_cli(a->fd, "[%s] %s\n", id,
        invalid_fields == ARI_OWC_FIELD_NONE ? "" : "**INVALID**");
    ast_cli(a->fd, "uri =                    %s\n", owc->websocket_client->uri);
    ast_cli(a->fd, "protocols =              %s\n", owc->websocket_client->protocols);
    ast_cli(a->fd, "apps =                   %s%s\n", owc->apps,
        invalid_fields & ARI_OWC_FIELD_APPS ? " (invalid)" : "");
    ast_cli(a->fd, "username =               %s\n", owc->websocket_client->username);
    ast_cli(a->fd, "password =               %s\n", S_COR(owc->websocket_client->password, "********", ""));
    ast_cli(a->fd, "local_ari_user =         %s%s\n", owc->local_ari_user,
        invalid_fields & ARI_OWC_FIELD_LOCAL_ARI_USER ? " (invalid)" : "");
    ast_cli(a->fd, "connection_type =        %s\n", ari_websocket_type_to_str(owc->websocket_client->connection_type));
    ast_cli(a->fd, "subscribe_all =          %s\n", AST_CLI_YESNO(owc->subscribe_all));
    ast_cli(a->fd, "connec_timeout =         %d\n", owc->websocket_client->connect_timeout);
    ast_cli(a->fd, "reconnect_attempts =     %d\n", owc->websocket_client->reconnect_attempts);
    ast_cli(a->fd, "reconnect_interval =     %d\n", owc->websocket_client->reconnect_interval);
    ast_cli(a->fd, "tls_enabled =            %s\n", AST_CLI_YESNO(owc->websocket_client->tls_enabled));
    ast_cli(a->fd, "ca_list_file =           %s\n", owc->websocket_client->ca_list_file);
    ast_cli(a->fd, "ca_list_path =           %s\n", owc->websocket_client->ca_list_path);
    ast_cli(a->fd, "cert_file =              %s\n", owc->websocket_client->cert_file);
    ast_cli(a->fd, "priv_key_file =          %s\n", owc->websocket_client->priv_key_file);
    ast_cli(a->fd, "verify_server =          %s\n", AST_CLI_YESNO(owc->websocket_client->verify_server_cert));
    ast_cli(a->fd, "verify_server_hostname = %s\n", AST_CLI_YESNO(owc->websocket_client->verify_server_hostname));
    ast_cli(a->fd, "\n");
 
    return CLI_SUCCESS;
}

References a, ao2_cleanup, ari_conf_get_owc(), ari_conf_get_owcs(), ari_conf_owc_get_invalid_fields(), ARI_OWC_FIELD_APPS, ARI_OWC_FIELD_LOCAL_ARI_USER, ARI_OWC_FIELD_NONE, ari_websocket_type_to_str(), ast_cli(), AST_CLI_YESNO, ast_sorcery_object_get_id(), CLI_FAILURE, CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, ast_cli_entry::command, complete_sorcery_object(), NULL, RAII_VAR, S_COR, and ast_cli_entry::usage.

ari_show_owcs()

static char * ari_show_owcs ( struct ast_cli_entry *  e, int  cmd, struct ast_cli_args *  a  )

static

Definition at line 397 of file res/ari/cli.c.

{
    RAII_VAR(struct ao2_container *, owcs, NULL, ao2_cleanup);
 
    switch (cmd) {
    case CLI_INIT:
        e->command = "ari show outbound-websockets";
        e->usage =
            "Usage: ari show outbound-websockets\n"
            "       Shows all ARI outbound-websockets\n";
        return NULL;
    case CLI_GENERATE:
        return NULL;
    default:
        break;
    }
 
    if (a->argc != 3) {
        return CLI_SHOWUSAGE;
    }
 
    owcs = ari_conf_get_owcs();
    if (!owcs) {
        ast_cli(a->fd, "Error getting ARI configuration\n");
        return CLI_FAILURE;
    }
 
    ast_cli(a->fd, "%-32s %-15s %-32s %-7s %s\n", "Name", "Type", "Apps", "Status", "URI");
    ast_cli(a->fd, "%.*s %.*s %.*s %.*s %.*s\n", 32, DASHES, 15, DASHES, 32, DASHES, 7, DASHES, 64, DASHES);
 
    ao2_callback(owcs, OBJ_NODATA, show_owc_cb, a);
 
    return CLI_SUCCESS;
}

References a, ao2_callback, ao2_cleanup, ari_conf_get_owcs(), ast_cli(), CLI_FAILURE, CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, ast_cli_entry::command, DASHES, NULL, OBJ_NODATA, RAII_VAR, show_owc_cb(), and ast_cli_entry::usage.

ari_show_sessions()

static char * ari_show_sessions ( struct ast_cli_entry *  e, int  cmd, struct ast_cli_args *  a  )

static

Definition at line 556 of file res/ari/cli.c.

{
    RAII_VAR(struct ao2_container *, sessions, NULL, ao2_cleanup);
 
    switch (cmd) {
    case CLI_INIT:
        e->command = "ari show websocket sessions";
        e->usage =
            "Usage: ari show websocket sessions\n"
            "       Shows all ARI websocket sessions\n";
        return NULL;
    case CLI_GENERATE:
        return NULL;
    default:
        break;
    }
 
    if (a->argc != 4) {
        return CLI_SHOWUSAGE;
    }
 
    sessions = ari_websocket_get_sessions();
    if (!sessions) {
        ast_cli(a->fd, "Error getting websocket sessions\n");
        return CLI_FAILURE;
    }
 
    ast_cli(a->fd, "%-*.*s %-15.15s %-32.32s %-5.5s %-16.16s\n",
        AST_UUID_STR_LEN, AST_UUID_STR_LEN,
        "Connection ID",
        "Type",
        "RemoteAddr",
        "State",
        "Apps"
        );
    ast_cli(a->fd, "%-*.*s %-15.15s %-32.32s %-5.5s %-16.16s\n",
        AST_UUID_STR_LEN, AST_UUID_STR_LEN, DASHES, DASHES, DASHES, DASHES, DASHES);
 
    ao2_callback(sessions, OBJ_NODATA, show_sessions_cb, a);
 
    return CLI_SUCCESS;
}

References a, ao2_callback, ao2_cleanup, ari_websocket_get_sessions(), ast_cli(), AST_UUID_STR_LEN, CLI_FAILURE, CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, ast_cli_entry::command, DASHES, NULL, OBJ_NODATA, RAII_VAR, sessions, show_sessions_cb(), and ast_cli_entry::usage.

ari_show_user()

static char * ari_show_user ( struct ast_cli_entry *  e, int  cmd, struct ast_cli_args *  a  )

static

Definition at line 140 of file res/ari/cli.c.

{
    RAII_VAR(struct ari_conf_user *, user, NULL, ao2_cleanup);
    RAII_VAR(struct ao2_container *, users, ari_conf_get_users(), ao2_cleanup);
 
    if (!users) {
        ast_cli(a->fd, "Error getting ARI configuration\n");
        return CLI_FAILURE;
    }
 
    switch (cmd) {
    case CLI_INIT:
        e->command = "ari show user";
        e->usage =
            "Usage: ari show user <username>\n"
            "       Shows a specific ARI user\n";
        return NULL;
    case CLI_GENERATE:
        complete_sorcery_object(users, a->word);
        return NULL;
    default:
        break;
    }
 
    if (a->argc != 4) {
        return CLI_SHOWUSAGE;
    }
 
    user = ari_conf_get_user(a->argv[3]);
    if (!user) {
        ast_cli(a->fd, "User '%s' not found\n", a->argv[3]);
        return CLI_SUCCESS;
    }
 
    ast_cli(a->fd, "Username: %s\n", ast_sorcery_object_get_id(user));
    ast_cli(a->fd, "Read only?: %s\n", AST_CLI_YESNO(user->read_only));
 
    return CLI_SUCCESS;
}

References a, ao2_cleanup, ari_conf_get_user(), ari_conf_get_users(), ast_cli(), AST_CLI_YESNO, ast_sorcery_object_get_id(), CLI_FAILURE, CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, ast_cli_entry::command, complete_sorcery_object(), NULL, RAII_VAR, and ast_cli_entry::usage.

ari_show_users()

static char * ari_show_users ( struct ast_cli_entry *  e, int  cmd, struct ast_cli_args *  a  )

static

Definition at line 87 of file res/ari/cli.c.

{
    RAII_VAR(struct ao2_container *, users, NULL, ao2_cleanup);
 
    switch (cmd) {
    case CLI_INIT:
        e->command = "ari show users";
        e->usage =
            "Usage: ari show users\n"
            "       Shows all ARI users\n";
        return NULL;
    case CLI_GENERATE:
        return NULL;
    default:
        break;
    }
 
    if (a->argc != 3) {
        return CLI_SHOWUSAGE;
    }
 
    users = ari_conf_get_users();
    if (!users) {
        ast_cli(a->fd, "Error getting ARI configuration\n");
        return CLI_FAILURE;
    }
 
    ast_cli(a->fd, "r/o?  Username\n");
    ast_cli(a->fd, "----  --------\n");
 
    ao2_callback(users, OBJ_NODATA, show_users_cb, a);
 
    return CLI_SUCCESS;
}

References a, ao2_callback, ao2_cleanup, ari_conf_get_users(), ast_cli(), CLI_FAILURE, CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, ast_cli_entry::command, NULL, OBJ_NODATA, RAII_VAR, show_users_cb(), and ast_cli_entry::usage.

ari_shut_session()

static char * ari_shut_session ( struct ast_cli_entry *  e, int  cmd, struct ast_cli_args *  a  )

static

Definition at line 643 of file res/ari/cli.c.

{
    RAII_VAR(struct ari_ws_session *, session, NULL, ao2_cleanup);
    RAII_VAR(struct ao2_container *, sessions, ari_websocket_get_sessions(), ao2_cleanup);
 
    if (!sessions) {
        ast_cli(a->fd, "Error getting ARI configuration\n");
        return CLI_FAILURE ;
    }
 
    switch (cmd) {
    case CLI_INIT:
        e->command = "ari shutdown websocket session";
        e->usage =
            "Usage: ari shutdown websocket session <id>\n"
            "       Shuts down ARI websocket session\n";
        return NULL;
    case CLI_GENERATE:
        complete_session(sessions, a->word);
        return NULL;
    default:
        break;
    }
 
    if (a->argc != 5) {
        return CLI_SHOWUSAGE;
    }
 
    session = ari_websocket_get_session(a->argv[4]);
    if (!session) {
        ast_cli(a->fd, "Websocket session '%s' not found\n", a->argv[4]);
        return CLI_FAILURE ;
    }
    ast_cli(a->fd, "Shutting down websocket session '%s'\n", a->argv[4]);
    ari_websocket_shutdown(session);
 
    return CLI_SUCCESS;
}

References a, ao2_cleanup, ari_websocket_get_session(), ari_websocket_get_sessions(), ari_websocket_shutdown(), ast_cli(), CLI_FAILURE, CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, ast_cli_entry::command, complete_session(), NULL, RAII_VAR, session, sessions, and ast_cli_entry::usage.

ari_shut_sessions()

static char * ari_shut_sessions ( struct ast_cli_entry *  e, int  cmd, struct ast_cli_args *  a  )

static

Definition at line 600 of file res/ari/cli.c.

{
 
    switch (cmd) {
    case CLI_INIT:
        e->command = "ari shutdown websocket sessions";
        e->usage =
            "Usage: ari shutdown websocket sessions\n"
            "       Shuts down all ARI websocket sessions\n";
        return NULL;
    case CLI_GENERATE:
        return NULL;
    default:
        break;
    }
 
    if (a->argc != 4) {
        return CLI_SHOWUSAGE;
    }
 
    ast_cli(a->fd, "Shutting down all websocket sessions\n");
    ari_websocket_shutdown_all();
 
    return CLI_SUCCESS;
}

References a, ari_websocket_shutdown_all(), ast_cli(), CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, ast_cli_entry::command, NULL, and ast_cli_entry::usage.

ari_start_owc()

static char * ari_start_owc ( struct ast_cli_entry *  e, int  cmd, struct ast_cli_args *  a  )

static

Definition at line 493 of file res/ari/cli.c.

{
    RAII_VAR(struct ari_conf_outbound_websocket *, owc, NULL, ao2_cleanup);
    RAII_VAR(struct ao2_container *, owcs, ari_conf_get_owcs(), ao2_cleanup);
 
    if (!owcs) {
        ast_cli(a->fd, "Error getting ARI configuration\n");
        return CLI_FAILURE ;
    }
 
    switch (cmd) {
    case CLI_INIT:
        e->command = "ari start outbound-websocket";
        e->usage =
            "Usage: ari start outbound-websocket <connection id>\n"
            "       Starts a specific ARI outbound websocket\n";
        return NULL;
    case CLI_GENERATE:
        complete_sorcery_object(owcs, a->word);
        return NULL;
    default:
        break;
    }
 
    if (a->argc != 4) {
        return CLI_SHOWUSAGE;
    }
 
    owc = ari_conf_get_owc(a->argv[3]);
    if (!owc) {
        ast_cli(a->fd, "Error getting ARI configuration\n");
        return CLI_FAILURE;
    }
    ast_cli(a->fd, "Starting websocket session for outbound-websocket '%s'\n", a->argv[3]);
 
    if (ari_outbound_websocket_start(owc) != 0) {
        ast_cli(a->fd, "Error starting outbound websocket\n");
        return CLI_FAILURE ;
    }
 
    return CLI_SUCCESS;
}

References a, ao2_cleanup, ari_conf_get_owc(), ari_conf_get_owcs(), ari_outbound_websocket_start(), ast_cli(), CLI_FAILURE, CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, ast_cli_entry::command, complete_sorcery_object(), NULL, RAII_VAR, and ast_cli_entry::usage.

complete_app()

static void complete_app ( struct ao2_container *  container, const char *  word  )

static

Definition at line 263 of file res/ari/cli.c.

{
    size_t wordlen = strlen(word);
    void *object;
    struct ao2_iterator i = ao2_iterator_init(container, 0);
 
    while ((object = ao2_iterator_next(&i))) {
        if (!strncasecmp(word, object, wordlen)) {
            ast_cli_completion_add(ast_strdup(object));
        }
        ao2_ref(object, -1);
    }
    ao2_iterator_destroy(&i);
}

References ao2_iterator_destroy(), ao2_iterator_init(), ao2_iterator_next, ao2_ref, ast_cli_completion_add(), ast_strdup, and container.

Referenced by ari_set_debug(), and ari_show_app().

complete_session()

static void complete_session ( struct ao2_container *  container, const char *  word  )

static

Definition at line 627 of file res/ari/cli.c.

{
    size_t wordlen = strlen(word);
    struct ari_ws_session *session;
    struct ao2_iterator i = ao2_iterator_init(container, 0);
 
    while ((session = ao2_iterator_next(&i))) {
        if (!strncasecmp(word, session->session_id, wordlen)) {
            ast_cli_completion_add(ast_strdup(session->session_id));
        }
        ao2_ref(session, -1);
    }
    ao2_iterator_destroy(&i);
}

References ao2_iterator_destroy(), ao2_iterator_init(), ao2_iterator_next, ao2_ref, ast_cli_completion_add(), ast_strdup, container, and session.

Referenced by ari_shut_session().

complete_sorcery_object()

static void complete_sorcery_object ( struct ao2_container *  container, const char *  word  )

static

Definition at line 123 of file res/ari/cli.c.

{
    size_t wordlen = strlen(word);
    void *object;
    struct ao2_iterator i = ao2_iterator_init(container, 0);
 
    while ((object = ao2_iterator_next(&i))) {
        const char *id = ast_sorcery_object_get_id(object);
        if (!strncasecmp(word, id, wordlen)) {
            ast_cli_completion_add(ast_strdup(id));
        }
        ao2_ref(object, -1);
    }
    ao2_iterator_destroy(&i);
}

References ao2_iterator_destroy(), ao2_iterator_init(), ao2_iterator_next, ao2_ref, ast_cli_completion_add(), ast_sorcery_object_get_id(), ast_strdup, and container.

Referenced by ari_show_owc(), ari_show_user(), and ari_start_owc().

show_owc_cb()

static int show_owc_cb ( void *  obj, void *  arg, int  flags  )

static

Definition at line 380 of file res/ari/cli.c.

{
    struct ari_conf_outbound_websocket *owc = obj;
    const char *id = ast_sorcery_object_get_id(owc);
    enum ari_conf_owc_fields invalid_fields = ari_conf_owc_get_invalid_fields(id);
    struct ast_cli_args *a = arg;
 
    ast_cli(a->fd, "%-32s %-15s %-32s %-7s %s\n",
        id,
        ari_websocket_type_to_str(owc->websocket_client->connection_type),
        owc->apps,
        invalid_fields == ARI_OWC_FIELD_NONE ? "valid" : "INVALID",
        owc->websocket_client->uri);
    return 0;
}

References a, ari_conf_outbound_websocket::apps, ari_conf_owc_get_invalid_fields(), ARI_OWC_FIELD_NONE, ari_websocket_type_to_str(), ast_cli(), ast_sorcery_object_get_id(), ast_websocket_client::connection_type, ast_websocket_client::uri, and ari_conf_outbound_websocket::websocket_client.

Referenced by ari_show_owcs().

show_sessions_cb()

static int show_sessions_cb ( void *  obj, void *  arg, int  flags  )

static

Definition at line 536 of file res/ari/cli.c.

{
    struct ari_ws_session *session = obj;
    struct ast_cli_args *a = arg;
    char *apps = ast_vector_string_join(&session->websocket_apps, ",");
 
    ast_cli(a->fd, "%-*s %-15s %-32s %-5s %s\n",
        AST_UUID_STR_LEN,
        session->session_id,
        ari_websocket_type_to_str(session->type),
        S_OR(session->remote_addr, "N/A"),
        session->type == AST_WS_TYPE_CLIENT_PER_CALL_CONFIG
            ? "N/A" : (session->connected ? "Up" : "Down"),
        S_OR(apps, ""));
 
    ast_free(apps);
    return 0;
}

References a, ari_websocket_type_to_str(), ast_cli(), ast_free, AST_UUID_STR_LEN, ast_vector_string_join(), AST_WS_TYPE_CLIENT_PER_CALL_CONFIG, S_OR, and session.

Referenced by ari_show_sessions().

show_users_cb()

static int show_users_cb ( void *  obj, void *  arg, int  flags  )

static

Definition at line 76 of file res/ari/cli.c.

{
    struct ari_conf_user *user = obj;
    struct ast_cli_args *a = arg;
 
    ast_cli(a->fd, "%-4s  %s\n",
        AST_CLI_YESNO(user->read_only),
        ast_sorcery_object_get_id(user));
    return 0;
}

References a, ast_cli(), AST_CLI_YESNO, and ast_sorcery_object_get_id().

Referenced by ari_show_users().

Variable Documentation

cli_ari

struct ast_cli_entry cli_ari[]

static

Definition at line 683 of file res/ari/cli.c.

Referenced by ari_cli_register(), and ari_cli_unregister().