app_stasis.c File Reference

Stasis dialplan application. More...

#include "asterisk.h"
#include "asterisk/app.h"
#include "asterisk/ari.h"
#include "asterisk/module.h"
#include "asterisk/pbx.h"
#include "asterisk/stasis.h"
#include "asterisk/stasis_app_impl.h"

Include dependency graph for app_stasis.c:

Go to the source code of this file.

Macros
#define	MAX_ARGS   128
	Maximum number of arguments for the Stasis dialplan application.

Functions
static void	__reg_module (void)
static void	__unreg_module (void)
static int	app_exec (struct ast_channel *chan, const char *data)
	Stasis dialplan application callback.
struct ast_module *	AST_MODULE_SELF_SYM (void)
static int	load_module (void)
static int	unload_module (void)

Variables
static struct ast_module_info	__mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_DEFAULT , .description = "Stasis dialplan application" , .key = ASTERISK_GPL_KEY , .buildopt_sum = AST_BUILDOPT_SUM, .support_level = AST_MODULE_SUPPORT_CORE, .load = load_module, .unload = unload_module, .requires = "res_stasis,res_ari", }
static const struct ast_module_info *	ast_module_info = &__mod_info
static const char *	stasis = "Stasis"
	Dialplan application name.

Detailed Description

Stasis dialplan application.

Author

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

Definition in file app_stasis.c.

Macro Definition Documentation

MAX_ARGS

#define MAX_ARGS   128

Maximum number of arguments for the Stasis dialplan application.

Definition at line 82 of file app_stasis.c.

Function Documentation

__reg_module()

static void __reg_module ( void  )

static

Definition at line 169 of file app_stasis.c.

__unreg_module()

static void __unreg_module ( void  )

static

Definition at line 169 of file app_stasis.c.

app_exec()

static int app_exec ( struct ast_channel *  chan, const char *  data  )

static

Stasis dialplan application callback.

Definition at line 88 of file app_stasis.c.

{
    char *parse = NULL;
    char *connection_id;
    int ret = -1;
 
    AST_DECLARE_APP_ARGS(args,
        AST_APP_ARG(app_name);
        AST_APP_ARG(app_argv)[MAX_ARGS];
    );
 
    ast_assert(chan != NULL);
    ast_assert(data != NULL);
 
    pbx_builtin_setvar_helper(chan, "STASISSTATUS", "");
 
    /* parse the arguments */
    parse = ast_strdupa(data);
    AST_STANDARD_APP_ARGS(args, parse);
 
    if (args.argc < 1) {
        ast_log(LOG_WARNING, "Stasis app_name argument missing\n");
        goto done;
    }
 
    if (stasis_app_is_registered(args.app_name)) {
        ast_debug(3, "%s: App '%s' is already registered\n",
            ast_channel_name(chan), args.app_name);
        ret = stasis_app_exec(chan, args.app_name, args.argc - 1, args.app_argv);
        goto done;
    }
    ast_debug(3, "%s: App '%s' is NOT already registered\n",
        ast_channel_name(chan), args.app_name);
 
    /*
     * The app isn't registered so we need to see if we have a
     * per-call outbound websocket config we can use.
     * connection_id will be freed by ast_ari_close_per_call_websocket().
     */
    connection_id = ast_ari_create_per_call_websocket(args.app_name, chan);
    if (ast_strlen_zero(connection_id)) {
        ast_log(LOG_WARNING,
            "%s: Stasis app '%s' doesn't exist\n",
            ast_channel_name(chan), args.app_name);
        goto done;
    }
 
    ret = stasis_app_exec(chan, connection_id, args.argc - 1, args.app_argv);
    ast_ari_close_per_call_websocket(connection_id);
 
done:
    if (ret) {
        /* set ret to 0 so pbx_core doesnt hangup the channel */
        if (!ast_check_hangup(chan)) {
            ret = 0;
        } else {
            ret = -1;
        }
        pbx_builtin_setvar_helper(chan, "STASISSTATUS", "FAILED");
    } else {
        pbx_builtin_setvar_helper(chan, "STASISSTATUS", "SUCCESS");
    }
 
    return ret;
}

References app_name(), args, AST_APP_ARG, ast_ari_close_per_call_websocket(), ast_ari_create_per_call_websocket(), ast_assert, ast_channel_name(), ast_check_hangup(), ast_debug, AST_DECLARE_APP_ARGS, ast_log, AST_STANDARD_APP_ARGS, ast_strdupa, ast_strlen_zero(), done, LOG_WARNING, MAX_ARGS, NULL, pbx_builtin_setvar_helper(), stasis_app_exec(), and stasis_app_is_registered().

AST_MODULE_SELF_SYM()

struct ast_module * AST_MODULE_SELF_SYM

(

void

)

Definition at line 169 of file app_stasis.c.

load_module()

static int load_module ( void  )

static

Definition at line 154 of file app_stasis.c.

{
    return ast_register_application_xml(stasis, app_exec);
}

References app_exec, ast_register_application_xml, and stasis.

unload_module()

static int unload_module ( void  )

static

Definition at line 159 of file app_stasis.c.

{
    return ast_unregister_application(stasis);
}

References ast_unregister_application(), and stasis.

Variable Documentation

__mod_info

struct ast_module_info __mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_DEFAULT , .description = "Stasis dialplan application" , .key = ASTERISK_GPL_KEY , .buildopt_sum = AST_BUILDOPT_SUM, .support_level = AST_MODULE_SUPPORT_CORE, .load = load_module, .unload = unload_module, .requires = "res_stasis,res_ari", }

static

Definition at line 169 of file app_stasis.c.

ast_module_info

const struct ast_module_info* ast_module_info = &__mod_info

static

Definition at line 169 of file app_stasis.c.

stasis

const char* stasis = "Stasis"

static

Dialplan application name.

Definition at line 85 of file app_stasis.c.

Referenced by ast_bridge_publish_blind_transfer(), load_module(), and unload_module().