curl plugin for portable configuration engine More...

#include "asterisk.h"
#include <curl/curl.h>
#include "asterisk/file.h"
#include "asterisk/channel.h"
#include "asterisk/pbx.h"
#include "asterisk/config.h"
#include "asterisk/module.h"
#include "asterisk/lock.h"
#include "asterisk/utils.h"
#include "asterisk/threadstorage.h"

Include dependency graph for res_config_curl.c:

Go to the source code of this file.

Functions
static void	__init_query_buf (void)

static void	__init_result_buf (void)

static void	__reg_module (void)

static void	__unreg_module (void)

struct ast_module *	AST_MODULE_SELF_SYM (void)

static struct ast_config *	config_curl (const char url, const char unused, const char file, struct ast_config cfg, struct ast_flags flags, const char sugg_incl, const char who_asked)

static int	destroy_curl (const char url, const char unused, const char keyfield, const char lookup, const struct ast_variable *fields)
	Execute an DELETE query. More...

static int	load_module (void)

static struct ast_variable *	realtime_curl (const char url, const char unused, const struct ast_variable *fields)
	Execute a curl query and return ast_variable list. More...

static struct ast_config *	realtime_multi_curl (const char url, const char unused, const struct ast_variable *fields)
	Excute an Select query and return ast_config list. More...

static int	reload_module (void)

static int	require_curl (const char url, const char unused, va_list ap)

static int	store_curl (const char url, const char unused, const struct ast_variable *fields)
	Execute an INSERT query. More...

static int	unload_module (void)

static int	update2_curl (const char url, const char unused, const struct ast_variable lookup_fields, const struct ast_variable update_fields)

static int	update_curl (const char url, const char unused, const char keyfield, const char lookup, const struct ast_variable *fields)
	Execute an UPDATE query. More...

Variables
static struct ast_module_info	__mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_LOAD_ORDER , .description = "Realtime Curl configuration" , .key = "This paragraph is copyright (c) 2006 by Digium, Inc. \In order for your module to load, it must return this \key via a function called \"key\". Any code which \includes this paragraph must be licensed under the GNU \General Public License version 2 or later (at your \option). In addition to Digium's general reservations \of rights, Digium expressly reserves the right to \allow other parties to license this paragraph under \different terms. Any use of Digium, Inc. trademarks or \logos (including \"Asterisk\" or \"Digium\") without \express written permission of Digium, Inc. is prohibited.\n" , .buildopt_sum = "30ef0c93b36035ec78c9cfd712d36d9b" , .support_level = AST_MODULE_SUPPORT_CORE, .load = load_module, .unload = unload_module, .reload = reload_module, .load_pri = AST_MODPRI_REALTIME_DRIVER, .requires = "extconfig,res_curl,func_curl", }

static const struct ast_module_info *	ast_module_info = &__mod_info

static struct ast_config_engine	curl_engine

static struct ast_threadstorage	query_buf = { .once = PTHREAD_ONCE_INIT , .key_init = __init_query_buf , .custom_init = NULL , }

static struct ast_threadstorage	result_buf = { .once = PTHREAD_ONCE_INIT , .key_init = __init_result_buf , .custom_init = NULL , }

Detailed Description

curl plugin for portable configuration engine

Author: Tilghman Lesher res_c.nosp@m.onfi.nosp@m.g_cur.nosp@m.l_v1.nosp@m.@the-.nosp@m.tilg.nosp@m.hman..nosp@m.com

Depends on the CURL library - http://curl.haxx.se/

Definition in file res_config_curl.c.

Function Documentation

◆ __init_query_buf()

static void __init_query_buf ( void )

static

Definition at line 49 of file res_config_curl.c.

62 {

◆ __init_result_buf()

static void __init_result_buf ( void )

static

Definition at line 50 of file res_config_curl.c.

62 {

◆ __reg_module()

static void __reg_module ( void )

static

Definition at line 659 of file res_config_curl.c.

◆ __unreg_module()

static void __unreg_module ( void )

static

Definition at line 659 of file res_config_curl.c.

◆ AST_MODULE_SELF_SYM()

struct ast_module* AST_MODULE_SELF_SYM ( void )

Definition at line 659 of file res_config_curl.c.

◆ config_curl()

static struct ast_config* config_curl	(	const char *	url,
		const char *	unused,
		const char *	file,
		struct ast_config *	cfg,
		struct ast_flags	flags,
		const char *	sugg_incl,
		const char *	who_asked
	)

static

Definition at line 515 of file res_config_curl.c.

References ast_category_append(), ast_category_new_dynamic, ast_config_get_current_category(), ast_config_internal_load(), ast_custom_function_find(), ast_log, ast_str_buffer(), ast_str_set(), ast_str_substitute_variables(), ast_str_thread_get(), ast_strlen_zero, ast_uri_decode(), ast_uri_encode(), ast_uri_http, ast_variable_append(), ast_variable_new, buf1, LOG_ERROR, NULL, query_buf, result_buf, S_OR, and strsep().

 {
    struct ast_str *query, *buffer;
    char buf1[200];
    char *stringp, *line, *pair, *key;
    int last_cat_metric = -1, cat_metric = -1;
    struct ast_category *cat = NULL;
    char *cur_cat = "";
    char *category = "", *var_name = "", *var_val = "";
    struct ast_flags loader_flags = { 0 };
 
    if (!ast_custom_function_find("CURL")) {
       ast_log(LOG_ERROR, "func_curl.so must be loaded in order to use res_config_curl.so!!\n");
       return NULL;
    }
 
    if (!(query = ast_str_thread_get(&query_buf, 100))) {
       return NULL;
    }
 
    if (!(buffer = ast_str_thread_get(&result_buf, 16))) {
       return NULL;
    }
 
    ast_uri_encode(file, buf1, sizeof(buf1), ast_uri_http);
    ast_str_set(&query, 0, "${CURL(%s/static?file=%s)}", url, buf1);
 
    /* Do the CURL query */
    ast_str_substitute_variables(&buffer, 0, NULL, ast_str_buffer(query));
 
    /* Line oriented output */
    stringp = ast_str_buffer(buffer);
    cat = ast_config_get_current_category(cfg);
 
    while ((line = strsep(&stringp, "\r\n"))) {
       if (ast_strlen_zero(line)) {
          continue;
       }
 
       while ((pair = strsep(&line, "&"))) {
          key = strsep(&pair, "=");
          ast_uri_decode(key, ast_uri_http);
          if (pair) {
             ast_uri_decode(pair, ast_uri_http);
          }
 
          if (!strcasecmp(key, "category")) {
             category = S_OR(pair, "");
          } else if (!strcasecmp(key, "var_name")) {
             var_name = S_OR(pair, "");
          } else if (!strcasecmp(key, "var_val")) {
             var_val = S_OR(pair, "");
          } else if (!strcasecmp(key, "cat_metric")) {
             cat_metric = pair ? atoi(pair) : 0;
          }
       }
 
       if (!strcmp(var_name, "#include")) {
          if (!ast_config_internal_load(var_val, cfg, loader_flags, "", who_asked))
             return NULL;
       }
 
       if (!cat || strcmp(category, cur_cat) || last_cat_metric != cat_metric) {
          cat = ast_category_new_dynamic(category);
          if (!cat) {
             break;
          }
          cur_cat = category;
          last_cat_metric = cat_metric;
          ast_category_append(cfg, cat);
       }
       ast_variable_append(cat, ast_variable_new(var_name, var_val, ""));
    }
 
    return cfg;
 }

◆ destroy_curl()

static int destroy_curl	(	const char *	url,
		const char *	unused,
		const char *	keyfield,
		const char *	lookup,
		const struct ast_variable *	fields
	)

static

Execute an DELETE query.

Parameters

url
unused
keyfield	where clause field
lookup	value of field for where clause
fields	list containing one or more field/value set(s)

Delete a row from a database table, prepare the sql statement using keyfield and lookup control the number of records to change. Additional params to match rows are stored in ap list. Sub-in the values to the prepared statement and execute it.

Return values

number	of rows affected
-1	on failure

Definition at line 415 of file res_config_curl.c.

References ast_custom_function_find(), ast_log, ast_str_append(), ast_str_buffer(), ast_str_set(), ast_str_substitute_variables(), ast_str_thread_get(), ast_uri_encode(), ast_uri_http, buf1, buf2, LOG_ERROR, ast_variable::name, ast_variable::next, NULL, query_buf, result_buf, and ast_variable::value.

 {
    struct ast_str *query, *buffer;
    char buf1[200], buf2[200];
    const struct ast_variable *field;
    char *stringp;
    int start = 1, rowcount = -1;
 
    if (!ast_custom_function_find("CURL")) {
       ast_log(LOG_ERROR, "func_curl.so must be loaded in order to use res_config_curl.so!!\n");
       return -1;
    }
 
    if (!(query = ast_str_thread_get(&query_buf, 1000))) {
       return -1;
    }
 
    if (!(buffer = ast_str_thread_get(&result_buf, 16))) {
       return -1;
    }
 
    ast_uri_encode(keyfield, buf1, sizeof(buf1), ast_uri_http);
    ast_uri_encode(lookup, buf2, sizeof(buf2), ast_uri_http);
    ast_str_set(&query, 0, "${CURL(%s/destroy,%s=%s&", url, buf1, buf2);
 
    for (field = fields; field; field = field->next) {
       ast_uri_encode(field->name, buf1, sizeof(buf1), ast_uri_http);
       ast_uri_encode(field->value, buf2, sizeof(buf2), ast_uri_http);
       ast_str_append(&query, 0, "%s%s=%s", !start ? "&" : "", buf1, buf2);
       start = 0;
    }
 
    ast_str_append(&query, 0, ")}");
    ast_str_substitute_variables(&buffer, 0, NULL, ast_str_buffer(query));
 
    /* Line oriented output */
    stringp = ast_str_buffer(buffer);
    while (*stringp <= ' ') {
       stringp++;
    }
    sscanf(stringp, "%30d", &rowcount);
 
    if (rowcount >= 0) {
       return (int)rowcount;
    }
 
    return -1;
 }

◆ load_module()

static int load_module ( void )

static

Definition at line 643 of file res_config_curl.c.

References ast_config_engine_register(), AST_MODFLAG_LOAD_ORDER, AST_MODPRI_REALTIME_DRIVER, AST_MODULE_INFO(), AST_MODULE_SUPPORT_CORE, ASTERISK_GPL_KEY, reload(), reload_module(), and unload_module().

 {
    reload_module();
 
    ast_config_engine_register(&curl_engine);
 
    return 0;
 }

◆ realtime_curl()

static struct ast_variable* realtime_curl	(	const char *	url,
		const char *	unused,
		const struct ast_variable *	fields
	)

static

Execute a curl query and return ast_variable list.

Parameters

url	The base URL from which to retrieve data
unused	Not currently used
fields	list containing one or more field/operator/value set.

Return values

var	on success
NULL	on failure

Definition at line 61 of file res_config_curl.c.

References ast_custom_function_find(), ast_log, ast_str_append(), ast_str_buffer(), ast_str_set(), ast_str_substitute_variables(), ast_str_thread_get(), ast_strlen_zero, ast_uri_decode(), ast_uri_encode(), ast_uri_http, ast_variable_new, buf1, buf2, LOG_ERROR, ast_variable::name, ast_variable::next, NULL, query_buf, result_buf, S_OR, strsep(), ast_variable::value, and var.

 {
    struct ast_str *query, *buffer;
    char buf1[256], buf2[256];
    const struct ast_variable *field;
    char *stringp, *pair, *key;
    unsigned int start = 1;
    struct ast_variable *var = NULL, *prev = NULL;
 
    if (!ast_custom_function_find("CURL")) {
       ast_log(LOG_ERROR, "func_curl.so must be loaded in order to use res_config_curl.so!!\n");
       return NULL;
    }
 
    if (!(query = ast_str_thread_get(&query_buf, 16))) {
       return NULL;
    }
 
    if (!(buffer = ast_str_thread_get(&result_buf, 16))) {
       return NULL;
    }
 
    ast_str_set(&query, 0, "${CURL(%s/single,", url);
 
    for (field = fields; field; field = field->next) {
       ast_uri_encode(field->name, buf1, sizeof(buf1), ast_uri_http);
       ast_uri_encode(field->value, buf2, sizeof(buf2), ast_uri_http);
       ast_str_append(&query, 0, "%s%s=%s", !start ? "&" : "", buf1, buf2);
       start = 0;
    }
 
    ast_str_append(&query, 0, ")}");
    ast_str_substitute_variables(&buffer, 0, NULL, ast_str_buffer(query));
 
    /* Remove any trailing newline characters */
    if ((stringp = strchr(ast_str_buffer(buffer), '\r')) || (stringp = strchr(ast_str_buffer(buffer), '\n'))) {
       *stringp = '\0';
    }
 
    stringp = ast_str_buffer(buffer);
    while ((pair = strsep(&stringp, "&"))) {
       key = strsep(&pair, "=");
       ast_uri_decode(key, ast_uri_http);
       if (pair) {
          ast_uri_decode(pair, ast_uri_http);
       }
 
       if (!ast_strlen_zero(key)) {
          if (prev) {
             prev->next = ast_variable_new(key, S_OR(pair, ""), "");
             if (prev->next) {
                prev = prev->next;
             }
          } else {
             prev = var = ast_variable_new(key, S_OR(pair, ""), "");
          }
       }
    }
 
    return var;
 }

◆ realtime_multi_curl()

static struct ast_config* realtime_multi_curl	(	const char *	url,
		const char *	unused,
		const struct ast_variable *	fields
	)

static

Excute an Select query and return ast_config list.

Parameters

url
unused
fields	list containing one or more field/operator/value set.

Return values

struct	ast_config pointer on success
NULL	on failure

Definition at line 132 of file res_config_curl.c.

References ast_category_append(), ast_category_new_anonymous, ast_category_rename(), ast_config_new(), ast_custom_function_find(), ast_free, ast_log, ast_str_append(), ast_str_buffer(), ast_str_set(), ast_str_substitute_variables(), ast_str_thread_get(), ast_strdup, ast_strlen_zero, ast_uri_decode(), ast_uri_encode(), ast_uri_http, ast_variable_append(), ast_variable_new, buf1, buf2, LOG_ERROR, ast_variable::name, ast_variable::next, NULL, query_buf, result_buf, S_OR, strsep(), ast_variable::value, and var.

 {
    struct ast_str *query, *buffer;
    char buf1[256], buf2[256];
    const struct ast_variable *field;
    char *stringp, *line, *pair, *key, *initfield = NULL;
    int start = 1;
    struct ast_variable *var = NULL;
    struct ast_config *cfg = NULL;
    struct ast_category *cat = NULL;
 
    if (!ast_custom_function_find("CURL")) {
       ast_log(LOG_ERROR, "func_curl.so must be loaded in order to use res_config_curl.so!!\n");
       return NULL;
    }
 
    if (!(query = ast_str_thread_get(&query_buf, 16))) {
       return NULL;
    }
 
    if (!(buffer = ast_str_thread_get(&result_buf, 16))) {
       return NULL;
    }
 
    ast_str_set(&query, 0, "${CURL(%s/multi,", url);
 
    for (field = fields; field; field = field->next) {
       if (start) {
          char *op;
          initfield = ast_strdup(field->name);
          if ((op = strchr(initfield, ' ')))
             *op = '\0';
       }
       ast_uri_encode(field->name, buf1, sizeof(buf1), ast_uri_http);
       ast_uri_encode(field->value, buf2, sizeof(buf2), ast_uri_http);
       ast_str_append(&query, 0, "%s%s=%s", !start ? "&" : "", buf1, buf2);
       start = 0;
    }
 
    ast_str_append(&query, 0, ")}");
 
    /* Do the CURL query */
    ast_str_substitute_variables(&buffer, 0, NULL, ast_str_buffer(query));
 
    if (!(cfg = ast_config_new())) {
       ast_free(initfield);
       return NULL;
    }
 
    /* Line oriented output */
    stringp = ast_str_buffer(buffer);
    while ((line = strsep(&stringp, "\r\n"))) {
       if (ast_strlen_zero(line)) {
          continue;
       }
 
       cat = ast_category_new_anonymous();
       if (!cat) {
          continue;
       }
 
       while ((pair = strsep(&line, "&"))) {
          key = strsep(&pair, "=");
          ast_uri_decode(key, ast_uri_http);
          if (pair) {
             ast_uri_decode(pair, ast_uri_http);
          }
 
          if (!strcasecmp(key, initfield) && pair) {
             ast_category_rename(cat, pair);
          }
 
          if (!ast_strlen_zero(key)) {
             var = ast_variable_new(key, S_OR(pair, ""), "");
             ast_variable_append(cat, var);
          }
       }
       ast_category_append(cfg, cat);
    }
 
    ast_free(initfield);
 
    return cfg;
 }

◆ reload_module()

static int reload_module ( void )

static

Definition at line 604 of file res_config_curl.c.

References ast_config_destroy(), ast_config_load, ast_log, ast_variable_browse(), CONFIG_FLAG_NOREALTIME, CONFIG_STATUS_FILEINVALID, LOG_WARNING, name, ast_variable::name, ast_variable::next, NULL, pbx_builtin_setvar_helper(), ast_variable::value, and var.

Referenced by load_module().

 {
    struct ast_flags flags = { CONFIG_FLAG_NOREALTIME };
    struct ast_config *cfg;
    struct ast_variable *var;
 
    if (!(cfg = ast_config_load("res_curl.conf", flags))) {
       return 0;
    } else if (cfg == CONFIG_STATUS_FILEINVALID) {
       ast_log(LOG_WARNING, "res_curl.conf could not be parsed!\n");
       return 0;
    }
 
    if (!(var = ast_variable_browse(cfg, "globals")) && !(var = ast_variable_browse(cfg, "global")) && !(var = ast_variable_browse(cfg, "general"))) {
       ast_log(LOG_WARNING, "[globals] not found in res_curl.conf\n");
       ast_config_destroy(cfg);
       return 0;
    }
 
    for (; var; var = var->next) {
       if (strncmp(var->name, "CURLOPT(", 8)) {
          char name[256];
          snprintf(name, sizeof(name), "CURLOPT(%s)", var->name);
          pbx_builtin_setvar_helper(NULL, name, var->value);
       } else {
          pbx_builtin_setvar_helper(NULL, var->name, var->value);
       }
    }
    ast_config_destroy(cfg);
    return 0;
 }

◆ require_curl()

static int require_curl	(	const char *	url,
		const char *	unused,
		va_list	ap
	)

static

Definition at line 464 of file res_config_curl.c.

References ast_custom_function_find(), ast_log, ast_str_append(), ast_str_buffer(), ast_str_set(), ast_str_substitute_variables(), ast_str_thread_get(), ast_uri_encode(), ast_uri_http, LOG_ERROR, NULL, query_buf, result_buf, RQ_CHAR, RQ_DATE, RQ_DATETIME, RQ_FLOAT, RQ_INTEGER1, RQ_INTEGER2, RQ_INTEGER3, RQ_INTEGER4, RQ_INTEGER8, RQ_UINTEGER1, RQ_UINTEGER2, RQ_UINTEGER3, RQ_UINTEGER4, RQ_UINTEGER8, and type.

 {
    struct ast_str *query, *buffer;
    char *elm, field[256];
    int type, size, i = 0;
 
    if (!ast_custom_function_find("CURL")) {
       ast_log(LOG_ERROR, "func_curl.so must be loaded in order to use res_config_curl.so!!\n");
       return -1;
    }
 
    if (!(query = ast_str_thread_get(&query_buf, 100))) {
       return -1;
    }
 
    if (!(buffer = ast_str_thread_get(&result_buf, 16))) {
       return -1;
    }
 
    ast_str_set(&query, 0, "${CURL(%s/require,", url);
 
    while ((elm = va_arg(ap, char *))) {
       type = va_arg(ap, require_type);
       size = va_arg(ap, int);
       ast_uri_encode(elm, field, sizeof(field), ast_uri_http);
       ast_str_append(&query, 0, "%s%s=%s%%3A%d",
          i > 0 ? "&" : "",
          field,
          type == RQ_CHAR ? "char" :
          type == RQ_INTEGER1 ? "integer1" :
          type == RQ_UINTEGER1 ? "uinteger1" :
          type == RQ_INTEGER2 ? "integer2" :
          type == RQ_UINTEGER2 ? "uinteger2" :
          type == RQ_INTEGER3 ? "integer3" :
          type == RQ_UINTEGER3 ? "uinteger3" :
          type == RQ_INTEGER4 ? "integer4" :
          type == RQ_UINTEGER4 ? "uinteger4" :
          type == RQ_INTEGER8 ? "integer8" :
          type == RQ_UINTEGER8 ? "uinteger8" :
          type == RQ_DATE ? "date" :
          type == RQ_DATETIME ? "datetime" :
          type == RQ_FLOAT ? "float" :
          "unknown", size);
       i++;
    }
 
    ast_str_append(&query, 0, ")}");
    ast_str_substitute_variables(&buffer, 0, NULL, ast_str_buffer(query));
    return atoi(ast_str_buffer(buffer));
 }

◆ store_curl()

static int store_curl	(	const char *	url,
		const char *	unused,
		const struct ast_variable *	fields
	)

static

Execute an INSERT query.

Parameters

url
unused
fields	list containing one or more field/value set(s)

Insert a new record into database table, prepare the sql statement. All values to be changed are stored in ap list. Sub-in the values to the prepared statement and execute it.

Return values

number	of rows affected
-1	on failure

Definition at line 354 of file res_config_curl.c.

References ast_custom_function_find(), ast_log, ast_str_append(), ast_str_buffer(), ast_str_set(), ast_str_substitute_variables(), ast_str_thread_get(), ast_uri_encode(), ast_uri_http, buf1, buf2, LOG_ERROR, ast_variable::name, ast_variable::next, NULL, query_buf, result_buf, and ast_variable::value.

 {
    struct ast_str *query, *buffer;
    char buf1[256], buf2[256];
    const struct ast_variable *field;
    char *stringp;
    int start = 1, rowcount = -1;
 
    if (!ast_custom_function_find("CURL")) {
       ast_log(LOG_ERROR, "func_curl.so must be loaded in order to use res_config_curl.so!!\n");
       return -1;
    }
 
    if (!(query = ast_str_thread_get(&query_buf, 1000))) {
       return -1;
    }
 
    if (!(buffer = ast_str_thread_get(&result_buf, 16))) {
       return -1;
    }
 
    ast_str_set(&query, 0, "${CURL(%s/store,", url);
 
    for (field = fields; field; field = field->next) {
       ast_uri_encode(field->name, buf1, sizeof(buf1), ast_uri_http);
       ast_uri_encode(field->value, buf2, sizeof(buf2), ast_uri_http);
       ast_str_append(&query, 0, "%s%s=%s", !start ? "&" : "", buf1, buf2);
       start = 0;
    }
 
    ast_str_append(&query, 0, ")}");
    ast_str_substitute_variables(&buffer, 0, NULL, ast_str_buffer(query));
 
    stringp = ast_str_buffer(buffer);
    while (*stringp <= ' ') {
       stringp++;
    }
    sscanf(stringp, "%30d", &rowcount);
 
    if (rowcount >= 0) {
       return rowcount;
    }
 
    return -1;
 }

◆ unload_module()

static int unload_module ( void )

static

Definition at line 636 of file res_config_curl.c.

References ast_config_engine_deregister().

Referenced by load_module().

 {
    ast_config_engine_deregister(&curl_engine);
 
    return 0;
 }

◆ update2_curl()

static int update2_curl	(	const char *	url,
		const char *	unused,
		const struct ast_variable *	lookup_fields,
		const struct ast_variable *	update_fields
	)

static

Definition at line 281 of file res_config_curl.c.

References ast_custom_function_find(), ast_log, ast_str_append(), ast_str_buffer(), ast_str_set(), ast_str_substitute_variables(), ast_str_thread_get(), ast_uri_encode(), ast_uri_http, buf1, buf2, LOG_ERROR, ast_variable::name, ast_variable::next, NULL, query_buf, result_buf, and ast_variable::value.

 {
    struct ast_str *query, *buffer;
    char buf1[200], buf2[200];
    const struct ast_variable *field;
    char *stringp;
    unsigned int start = 1;
    int rowcount = -1;
 
    if (!ast_custom_function_find("CURL")) {
       ast_log(LOG_ERROR, "func_curl.so must be loaded in order to use res_config_curl.so!!\n");
       return -1;
    }
 
    if (!(query = ast_str_thread_get(&query_buf, 1000)))
       return -1;
 
    if (!(buffer = ast_str_thread_get(&result_buf, 16))) {
       return -1;
    }
 
    ast_str_set(&query, 0, "${CURL(%s/update?", url);
 
    for (field = lookup_fields; field; field = field->next) {
       ast_uri_encode(field->name, buf1, sizeof(buf1), ast_uri_http);
       ast_uri_encode(field->value, buf2, sizeof(buf2), ast_uri_http);
       ast_str_append(&query, 0, "%s%s=%s", !start ? "" : "&", buf1, buf2);
       start = 0;
    }
    ast_str_append(&query, 0, ",");
    start = 1;
 
    for (field = update_fields; field; field = field->next) {
       ast_uri_encode(field->name, buf1, sizeof(buf1), ast_uri_http);
       ast_uri_encode(field->value, buf2, sizeof(buf2), ast_uri_http);
       ast_str_append(&query, 0, "%s%s=%s", !start ? "" : "&", buf1, buf2);
       start = 0;
    }
 
    ast_str_append(&query, 0, ")}");
    /* Proxies work, by setting CURLOPT options in the [globals] section of
     * extensions.conf.  Unfortunately, this means preloading pbx_config.so
     * so that they have an opportunity to be set prior to startup realtime
     * queries. */
    ast_str_substitute_variables(&buffer, 0, NULL, ast_str_buffer(query));
 
    /* Line oriented output */
    stringp = ast_str_buffer(buffer);
    while (*stringp <= ' ') {
       stringp++;
    }
    sscanf(stringp, "%30d", &rowcount);
 
    if (rowcount >= 0) {
       return (int)rowcount;
    }
 
    return -1;
 }

◆ update_curl()

static int update_curl	(	const char *	url,
		const char *	unused,
		const char *	keyfield,
		const char *	lookup,
		const struct ast_variable *	fields
	)

static

Execute an UPDATE query.

Parameters

url
unused
keyfield	where clause field
lookup	value of field for where clause
fields	list containing one or more field/value set(s).

Update a database table, prepare the sql statement using keyfield and lookup control the number of records to change. All values to be changed are stored in ap list. Sub-in the values to the prepared statement and execute it.

Return values

number	of rows affected
-1	on failure

Definition at line 232 of file res_config_curl.c.

References ast_custom_function_find(), ast_log, ast_str_append(), ast_str_buffer(), ast_str_set(), ast_str_substitute_variables(), ast_str_thread_get(), ast_uri_encode(), ast_uri_http, buf1, buf2, LOG_ERROR, ast_variable::name, ast_variable::next, NULL, query_buf, result_buf, and ast_variable::value.

 {
    struct ast_str *query, *buffer;
    char buf1[256], buf2[256];
    const struct ast_variable *field;
    char *stringp;
    int start = 1, rowcount = -1;
 
    if (!ast_custom_function_find("CURL")) {
       ast_log(LOG_ERROR, "func_curl.so must be loaded in order to use res_config_curl.so!!\n");
       return -1;
    }
 
    if (!(query = ast_str_thread_get(&query_buf, 16))) {
       return -1;
    }
 
    if (!(buffer = ast_str_thread_get(&result_buf, 16))) {
       return -1;
    }
 
    ast_uri_encode(keyfield, buf1, sizeof(buf1), ast_uri_http);
    ast_uri_encode(lookup, buf2, sizeof(buf2), ast_uri_http);
    ast_str_set(&query, 0, "${CURL(%s/update?%s=%s,", url, buf1, buf2);
 
    for (field = fields; field; field = field->next) {
       ast_uri_encode(field->name, buf1, sizeof(buf1), ast_uri_http);
       ast_uri_encode(field->value, buf2, sizeof(buf2), ast_uri_http);
       ast_str_append(&query, 0, "%s%s=%s", !start ? "&" : "", buf1, buf2);
       start = 0;
    }
 
    ast_str_append(&query, 0, ")}");
    ast_str_substitute_variables(&buffer, 0, NULL, ast_str_buffer(query));
 
    /* Line oriented output */
    stringp = ast_str_buffer(buffer);
    while (*stringp <= ' ') {
       stringp++;
    }
    sscanf(stringp, "%30d", &rowcount);
 
    if (rowcount >= 0) {
       return (int)rowcount;
    }
 
    return -1;
 }

Variable Documentation

◆ __mod_info

struct ast_module_info __mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_LOAD_ORDER , .description = "Realtime Curl configuration" , .key = "This paragraph is copyright (c) 2006 by Digium, Inc. \In order for your module to load, it must return this \key via a function called \"key\". Any code which \includes this paragraph must be licensed under the GNU \General Public License version 2 or later (at your \option). In addition to Digium's general reservations \of rights, Digium expressly reserves the right to \allow other parties to license this paragraph under \different terms. Any use of Digium, Inc. trademarks or \logos (including \"Asterisk\" or \"Digium\") without \express written permission of Digium, Inc. is prohibited.\n" , .buildopt_sum = "30ef0c93b36035ec78c9cfd712d36d9b" , .support_level = AST_MODULE_SUPPORT_CORE, .load = load_module, .unload = unload_module, .reload = reload_module, .load_pri = AST_MODPRI_REALTIME_DRIVER, .requires = "extconfig,res_curl,func_curl", }

static

Definition at line 659 of file res_config_curl.c.

◆ ast_module_info

const struct ast_module_info* ast_module_info = &__mod_info

static

Definition at line 659 of file res_config_curl.c.

◆ curl_engine

struct ast_config_engine curl_engine

static

Definition at line 592 of file res_config_curl.c.

◆ query_buf

struct ast_threadstorage query_buf = { .once = PTHREAD_ONCE_INIT , .key_init = __init_query_buf , .custom_init = NULL , }

static

Definition at line 49 of file res_config_curl.c.

Referenced by config_curl(), destroy_curl(), realtime_curl(), realtime_multi_curl(), require_curl(), store_curl(), update2_curl(), and update_curl().

◆ result_buf

struct ast_threadstorage result_buf = { .once = PTHREAD_ONCE_INIT , .key_init = __init_result_buf , .custom_init = NULL , }

static

Definition at line 50 of file res_config_curl.c.

Referenced by config_curl(), destroy_curl(), realtime_curl(), realtime_multi_curl(), require_curl(), store_curl(), update2_curl(), and update_curl().

Functions

Variables

Detailed Description

Function Documentation

◆ __init_query_buf()

◆ __init_result_buf()

◆ __reg_module()

◆ __unreg_module()

◆ AST_MODULE_SELF_SYM()

◆ config_curl()

◆ destroy_curl()

◆ load_module()

◆ realtime_curl()

◆ realtime_multi_curl()

◆ reload_module()

◆ require_curl()

◆ store_curl()

◆ unload_module()

◆ update2_curl()

◆ update_curl()

Variable Documentation

◆ __mod_info

◆ ast_module_info

◆ curl_engine

◆ query_buf

◆ result_buf