diff options
author | russell <russell@f38db490-d61c-443f-a65b-d21fe96a405b> | 2006-05-25 15:40:38 +0000 |
---|---|---|
committer | russell <russell@f38db490-d61c-443f-a65b-d21fe96a405b> | 2006-05-25 15:40:38 +0000 |
commit | d686e9230bc89035926cd5573e49ce4021ed54f0 (patch) | |
tree | 64190d51d24987e9ba9ffdeb8193a03a4c7e4b16 /funcs/func_db.c | |
parent | 40d58097e96c4278266c9ac545af8ae41d016cb5 (diff) |
add DB_DELETE function for the common case of retrieving and deleting a key in
a single operation (issue #7214, twilson)
git-svn-id: http://svn.digium.com/svn/asterisk/trunk@30241 f38db490-d61c-443f-a65b-d21fe96a405b
Diffstat (limited to 'funcs/func_db.c')
-rw-r--r-- | funcs/func_db.c | 49 |
1 files changed, 49 insertions, 0 deletions
diff --git a/funcs/func_db.c b/funcs/func_db.c index f7439302b..e35859d1a 100644 --- a/funcs/func_db.c +++ b/funcs/func_db.c @@ -159,6 +159,53 @@ static struct ast_custom_function db_exists_function = { .read = function_db_exists, }; +static int function_db_delete(struct ast_channel *chan, char* cmd, + char *parse, char *buf, size_t len) +{ + AST_DECLARE_APP_ARGS(args, + AST_APP_ARG(family); + AST_APP_ARG(key); + ); + + buf[0] = '\0'; + + if (ast_strlen_zero(parse)) { + ast_log(LOG_WARNING, "DB_DELETE requires an argument, DB_DELETE(<family>/<key>)\n"); + return -1; + } + + AST_NONSTANDARD_APP_ARGS(args, parse, '/'); + + if (args.argc < 2) { + ast_log(LOG_WARNING, "DB_DELETE requires an argument, DB_DELETE(<family>/<key>)\n"); + return -1; + } + + if (ast_db_get(args.family, args.key, buf, len - 1)) { + ast_log(LOG_DEBUG, "DB_DELETE: %s/%s not found in database.\n", args.family, args.key); + } else { + if (ast_db_del(args.family, args.key)) { + ast_log(LOG_DEBUG, "DB_DELETE: %s/%s could not be deleted from the database\n", + args.family, args.key); + } + } + pbx_builtin_setvar_helper(chan, "DB_RESULT", buf); + + return 0; +} + + +static struct ast_custom_function db_delete_function = { + .name = "DB_DELETE", + .synopsis = "Return a value from the database and delete it", + .syntax = "DB_DELETE(<family>/<key>)", + .desc = + "This function will retrieve a value from the Asterisk database\n" + " and then remove that key from the database. DB_RESULT\n" + "will be set to the key's value if it exists.\n", + .read = function_db_delete, +}; + static char *tdesc = "Database (astdb) related dialplan functions"; static int unload_module(void *mod) @@ -167,6 +214,7 @@ static int unload_module(void *mod) res |= ast_custom_function_unregister(&db_function); res |= ast_custom_function_unregister(&db_exists_function); + res |= ast_custom_function_unregister(&db_delete_function); return res; } @@ -177,6 +225,7 @@ static int load_module(void *mod) res |= ast_custom_function_register(&db_function); res |= ast_custom_function_register(&db_exists_function); + res |= ast_custom_function_register(&db_delete_function); return res; } |