From a96606b32934c1b756364fda6e1fb2c4825e54d7 Mon Sep 17 00:00:00 2001 From: Russell Bryant Date: Thu, 25 May 2006 15:40:38 +0000 Subject: add DB_DELETE function for the common case of retrieving and deleting a key in a single operation (issue #7214, twilson) git-svn-id: https://origsvn.digium.com/svn/asterisk/trunk@30241 65c4cc65-6c06-0410-ace0-fbb531ad65f3 --- funcs/func_db.c | 49 +++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 49 insertions(+) (limited to 'funcs/func_db.c') 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(/)\n"); + return -1; + } + + AST_NONSTANDARD_APP_ARGS(args, parse, '/'); + + if (args.argc < 2) { + ast_log(LOG_WARNING, "DB_DELETE requires an argument, DB_DELETE(/)\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(/)", + .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; } -- cgit v1.2.3