Asterisk - The Open Source Telephony Project GIT-master-0bf3178
Data Structures | Functions | Variables
app_dtmfstore.c File Reference

Technology independent asynchronous DTMF collection. More...

#include "asterisk.h"
#include "asterisk/module.h"
#include "asterisk/channel.h"
#include "asterisk/pbx.h"
#include "asterisk/framehook.h"
#include "asterisk/app.h"
#include "asterisk/conversions.h"
Include dependency graph for app_dtmfstore.c:

Go to the source code of this file.

Data Structures

struct  dtmf_store_data
 Private data structure used with the function's datastore. More...
 

Functions

 AST_MODULE_INFO_STANDARD_EXTENDED (ASTERISK_GPL_KEY, "Technology independent async DTMF storage")
 
static void datastore_destroy_cb (void *data)
 
static struct ast_framedtmf_store_framehook (struct ast_channel *chan, struct ast_frame *f, enum ast_framehook_event event, void *data)
 Frame hook that is called to intercept digit/undigit. More...
 
static int dtmfstore_exec (struct ast_channel *chan, const char *appdata)
 
static int load_module (void)
 
static int remove_dtmf_store (struct ast_channel *chan)
 
static int unload_module (void)
 

Variables

static char * app = "StoreDTMF"
 
static const struct ast_datastore_info dtmf_store_datastore
 The channel datastore the function uses to store state. More...
 

Detailed Description

Technology independent asynchronous DTMF collection.

Author
Naveen Albert aster.nosp@m.isk@.nosp@m.phrea.nosp@m.knet.nosp@m..org

Definition in file app_dtmfstore.c.

Function Documentation

◆ AST_MODULE_INFO_STANDARD_EXTENDED()

AST_MODULE_INFO_STANDARD_EXTENDED ( ASTERISK_GPL_KEY  ,
"Technology independent async DTMF storage"   
)

◆ datastore_destroy_cb()

static void datastore_destroy_cb ( void *  data)
static

Definition at line 90 of file app_dtmfstore.c.

90 {
91 struct dtmf_store_data *d;
92 d = data;
93 if (d) {
94 if (d->rx_var) {
95 ast_free(d->rx_var);
96 }
97 if (d->tx_var) {
98 ast_free(d->tx_var);
99 }
100 ast_free(data);
101 }
102}
#define ast_free(a)
Definition: astmm.h:180
Private data structure used with the function's datastore.
Definition: app_dtmfstore.c:83
static struct test_val d

References ast_free, and d.

◆ dtmf_store_framehook()

static struct ast_frame * dtmf_store_framehook ( struct ast_channel chan,
struct ast_frame f,
enum ast_framehook_event  event,
void *  data 
)
static

Frame hook that is called to intercept digit/undigit.

Definition at line 142 of file app_dtmfstore.c.

144{
145 char currentdata[512];
146 char varnamesub[64];
147 char *varname = NULL;
148 struct dtmf_store_data *framedata = data;
149 int len;
150
151 if (!f || !framedata) {
152 return f;
153 }
154
156 return f;
157 }
158
159 if (f->frametype != AST_FRAME_DTMF_END) {
160 return f;
161 }
162
163 /* If this is DTMF then store the digits */
164 if (event == AST_FRAMEHOOK_EVENT_READ && framedata->rx_var) { /* coming from source */
165 varname = framedata->rx_var;
166 } else if (event == AST_FRAMEHOOK_EVENT_WRITE && framedata->tx_var) { /* going to source */
167 varname = framedata->tx_var;
168 }
169
170 if (!varname) {
171 return f;
172 }
173
174 sprintf(varnamesub, "${%s}", varname);
175 pbx_substitute_variables_helper(chan, varnamesub, currentdata, 511);
176 /* pbx_builtin_getvar_helper works for regular vars but not CDR vars */
177 if (ast_strlen_zero(currentdata)) { /* var doesn't exist yet */
178 ast_debug(3, "Creating new digit store: %s\n", varname);
179 }
180 len = strlen(currentdata);
181 if (framedata->maxdigits > 0 && len >= framedata->maxdigits) {
182 ast_debug(3, "Reached digit limit: %d\n", framedata->maxdigits);
183 remove_dtmf_store(chan); /* reached max digit count, stop now */
184 return f;
185 } else {
186 char newdata[len + 2]; /* one more char + terminator */
187 if (len > 0) {
188 ast_copy_string(newdata, currentdata, len + 2);
189 }
190 newdata[len] = (unsigned) f->subclass.integer;
191 newdata[len + 1] = '\0';
192 ast_debug(3, "Appending to digit store: now %s\n", newdata);
193 pbx_builtin_setvar_helper(chan, varname, newdata);
194 }
195 return f;
196}
static int remove_dtmf_store(struct ast_channel *chan)
@ AST_FRAMEHOOK_EVENT_WRITE
Definition: framehook.h:153
@ AST_FRAMEHOOK_EVENT_READ
Definition: framehook.h:152
static int len(struct ast_channel *chan, const char *cmd, char *data, char *buf, size_t buflen)
@ AST_FRAME_DTMF_END
#define ast_debug(level,...)
Log a DEBUG message.
int pbx_builtin_setvar_helper(struct ast_channel *chan, const char *name, const char *value)
Add a variable to the channel variable stack, removing the most recently set value for the same name.
void pbx_substitute_variables_helper(struct ast_channel *c, const char *cp1, char *cp2, int count)
Definition: ael_main.c:211
#define NULL
Definition: resample.c:96
static force_inline int attribute_pure ast_strlen_zero(const char *s)
Definition: strings.h:65
void ast_copy_string(char *dst, const char *src, size_t size)
Size-limited null-terminating string copy.
Definition: strings.h:425
struct ast_frame_subclass subclass
enum ast_frame_type frametype
Definition: astman.c:222

References ast_copy_string(), ast_debug, AST_FRAME_DTMF_END, AST_FRAMEHOOK_EVENT_READ, AST_FRAMEHOOK_EVENT_WRITE, ast_strlen_zero(), ast_frame::frametype, ast_frame_subclass::integer, len(), dtmf_store_data::maxdigits, NULL, pbx_builtin_setvar_helper(), pbx_substitute_variables_helper(), remove_dtmf_store(), dtmf_store_data::rx_var, ast_frame::subclass, and dtmf_store_data::tx_var.

Referenced by dtmfstore_exec().

◆ dtmfstore_exec()

static int dtmfstore_exec ( struct ast_channel chan,
const char *  appdata 
)
static

Definition at line 199 of file app_dtmfstore.c.

200{
201 struct ast_datastore *datastore;
202 struct dtmf_store_data *data;
203 static struct ast_framehook_interface digit_framehook_interface = {
205 .event_cb = dtmf_store_framehook,
206 .disable_inheritance = 1,
207 };
208 char *parse = ast_strdupa(appdata);
211 AST_APP_ARG(varname);
212 AST_APP_ARG(maxdigits);
213 );
214 SCOPED_CHANNELLOCK(chan_lock, chan);
216
217 if (ast_strlen_zero(appdata)) {
218 ast_log(AST_LOG_WARNING, "StoreDTMF requires an argument\n");
219 return -1;
220 }
221
222 if (!strcasecmp(args.direction, "remove")) {
223 return remove_dtmf_store(chan);
224 }
225
227 if (datastore) {
228 ast_log(AST_LOG_WARNING, "StoreDTMF already set on '%s'\n",
229 ast_channel_name(chan));
230 return 0;
231 }
232
234 if (!datastore) {
235 return -1;
236 }
237
238 data = ast_calloc(1, sizeof(*data));
239 if (!data) {
240 ast_datastore_free(datastore);
241 return -1;
242 }
243
244 digit_framehook_interface.data = data;
245
246 data->rx_var = NULL;
247 data->tx_var = NULL;
248 data->maxdigits = 0;
249
250 if (!strcasecmp(args.direction, "tx")) {
251 data->tx_var = ast_strdup(args.varname);
252 } else if (!strcasecmp(args.direction, "rx")) {
253 data->rx_var = ast_strdup(args.varname);
254 } else {
255 ast_log(LOG_ERROR, "Direction must be either RX or TX\n");
256 return -1;
257 }
258
259 if (!ast_strlen_zero(args.maxdigits)) {
260 if (ast_str_to_int(args.maxdigits,&(data->maxdigits))) {
261 ast_log(LOG_ERROR, "Invalid integer: %s\n", args.maxdigits);
262 return -1;
263 }
264 if (data->maxdigits < 0) {
265 ast_log(LOG_ERROR, "Invalid natural number: %d\n", data->maxdigits);
266 return -1;
267 } else if (data->maxdigits == 0) {
268 ast_log(LOG_WARNING, "No maximum digit count set\n");
269 }
270 }
271
272 data->framehook_id = ast_framehook_attach(chan, &digit_framehook_interface);
273 if (data->framehook_id < 0) {
274 ast_log(AST_LOG_WARNING, "Failed to attach StoreDTMF framehook to '%s'\n",
275 ast_channel_name(chan));
276 ast_datastore_free(datastore);
277 ast_free(data);
278 return -1;
279 }
280 datastore->data = data;
281
282 ast_channel_datastore_add(chan, datastore);
283
284 return 0;
285}
static const struct ast_datastore_info dtmf_store_datastore
The channel datastore the function uses to store state.
static struct ast_frame * dtmf_store_framehook(struct ast_channel *chan, struct ast_frame *f, enum ast_framehook_event event, void *data)
Frame hook that is called to intercept digit/undigit.
#define ast_strdup(str)
A wrapper for strdup()
Definition: astmm.h:241
#define ast_strdupa(s)
duplicate a string in memory from the stack
Definition: astmm.h:298
#define ast_calloc(num, len)
A wrapper for calloc()
Definition: astmm.h:202
#define ast_log
Definition: astobj2.c:42
const char * ast_channel_name(const struct ast_channel *chan)
int ast_channel_datastore_add(struct ast_channel *chan, struct ast_datastore *datastore)
Add a datastore to a channel.
Definition: channel.c:2404
struct ast_datastore * ast_channel_datastore_find(struct ast_channel *chan, const struct ast_datastore_info *info, const char *uid)
Find a datastore on a channel.
Definition: channel.c:2418
int ast_str_to_int(const char *str, int *res)
Convert the given string to a signed integer.
Definition: conversions.c:44
#define ast_datastore_alloc(info, uid)
Definition: datastore.h:85
int ast_datastore_free(struct ast_datastore *datastore)
Free a data store object.
Definition: datastore.c:68
int ast_framehook_attach(struct ast_channel *chan, struct ast_framehook_interface *i)
Attach an framehook onto a channel for frame interception.
Definition: framehook.c:132
#define AST_FRAMEHOOK_INTERFACE_VERSION
Definition: framehook.h:227
direction
#define AST_APP_ARG(name)
Define an application argument.
#define AST_DECLARE_APP_ARGS(name, arglist)
Declare a structure to hold an application's arguments.
#define AST_STANDARD_APP_ARGS(args, parse)
Performs the 'standard' argument separation process for an application.
#define AST_LOG_WARNING
#define LOG_ERROR
#define LOG_WARNING
#define SCOPED_CHANNELLOCK(varname, chan)
scoped lock specialization for channels.
Definition: lock.h:619
Structure for a data store object.
Definition: datastore.h:64
void * data
Definition: datastore.h:66
const char * args

References args, AST_APP_ARG, ast_calloc, ast_channel_datastore_add(), ast_channel_datastore_find(), ast_channel_name(), ast_datastore_alloc, ast_datastore_free(), AST_DECLARE_APP_ARGS, ast_framehook_attach(), AST_FRAMEHOOK_INTERFACE_VERSION, ast_free, ast_log, AST_LOG_WARNING, AST_STANDARD_APP_ARGS, ast_str_to_int(), ast_strdup, ast_strdupa, ast_strlen_zero(), ast_datastore::data, ast_framehook_interface::data, dtmf_store_datastore, dtmf_store_framehook(), LOG_ERROR, LOG_WARNING, NULL, remove_dtmf_store(), SCOPED_CHANNELLOCK, and ast_framehook_interface::version.

Referenced by load_module().

◆ load_module()

static int load_module ( void  )
static

Definition at line 292 of file app_dtmfstore.c.

293{
295}
static char * app
Definition: app_dtmfstore.c:80
static int dtmfstore_exec(struct ast_channel *chan, const char *appdata)
#define ast_register_application_xml(app, execute)
Register an application using XML documentation.
Definition: module.h:640

References app, ast_register_application_xml, and dtmfstore_exec().

◆ remove_dtmf_store()

static int remove_dtmf_store ( struct ast_channel chan)
static

Definition at line 111 of file app_dtmfstore.c.

112{
113 struct ast_datastore *datastore = NULL;
114 struct dtmf_store_data *data;
115 SCOPED_CHANNELLOCK(chan_lock, chan);
116
118 if (!datastore) {
119 ast_log(AST_LOG_WARNING, "Cannot remove StoreDTMF from %s: StoreDTMF not currently enabled\n",
120 ast_channel_name(chan));
121 return -1;
122 }
123 data = datastore->data;
124
125 if (ast_framehook_detach(chan, data->framehook_id)) {
126 ast_log(AST_LOG_WARNING, "Failed to remove StoreDTMF framehook from channel %s\n",
127 ast_channel_name(chan));
128 return -1;
129 }
130
131 if (ast_channel_datastore_remove(chan, datastore)) {
132 ast_log(AST_LOG_WARNING, "Failed to remove StoreDTMF datastore from channel %s\n",
133 ast_channel_name(chan));
134 return -1;
135 }
136 ast_datastore_free(datastore);
137
138 return 0;
139}
int ast_channel_datastore_remove(struct ast_channel *chan, struct ast_datastore *datastore)
Remove a datastore from a channel.
Definition: channel.c:2413
int ast_framehook_detach(struct ast_channel *chan, int framehook_id)
Detach an framehook from a channel.
Definition: framehook.c:177

References ast_channel_datastore_find(), ast_channel_datastore_remove(), ast_channel_name(), ast_datastore_free(), ast_framehook_detach(), ast_log, AST_LOG_WARNING, ast_datastore::data, dtmf_store_datastore, dtmf_store_data::framehook_id, NULL, and SCOPED_CHANNELLOCK.

Referenced by dtmf_store_framehook(), and dtmfstore_exec().

◆ unload_module()

static int unload_module ( void  )
static

Definition at line 287 of file app_dtmfstore.c.

288{
290}
int ast_unregister_application(const char *app)
Unregister an application.
Definition: pbx_app.c:392

References app, and ast_unregister_application().

Variable Documentation

◆ app

char* app = "StoreDTMF"
static

Definition at line 80 of file app_dtmfstore.c.

Referenced by load_module(), and unload_module().

◆ dtmf_store_datastore

const struct ast_datastore_info dtmf_store_datastore
static
Initial value:
= {
.type = "dtmf_store",
}
static void datastore_destroy_cb(void *data)
Definition: app_dtmfstore.c:90

The channel datastore the function uses to store state.

Definition at line 105 of file app_dtmfstore.c.

Referenced by dtmfstore_exec(), and remove_dtmf_store().