PostgreSQL CEL logger. More...

#include "asterisk.h"
#include <libpq-fe.h>
#include "asterisk/config.h"
#include "asterisk/options.h"
#include "asterisk/channel.h"
#include "asterisk/cel.h"
#include "asterisk/module.h"
#include "asterisk/logger.h"

Include dependency graph for cel_pgsql.c:

Go to the source code of this file.

Data Structures
struct	columns

struct	psql_columns

Macros
#define	CEL_SHOW_USERDEF_DEFAULT 0
	show_user_def is off by default More...

#define	DATE_FORMAT "%Y-%m-%d %T.%6q"

#define	LENGTHEN_BUF(size, var_sql)

#define	LENGTHEN_BUF1(size) LENGTHEN_BUF(size, sql);

#define	LENGTHEN_BUF2(size) LENGTHEN_BUF(size, sql2);

#define	PGSQL_BACKEND_NAME "CEL PGSQL backend"

#define	PGSQL_MIN_VERSION_SCHEMA 70300

#define	SEP (first ? "" : ",")

Functions
static void	__reg_module (void)

static void	__unreg_module (void)

struct ast_module *	AST_MODULE_SELF_SYM (void)

static int	load_module (void)

static int	my_load_module (int reload)

static int	my_unload_module (void)

static void	pgsql_log (struct ast_event *event)

static void	pgsql_reconnect (void)

static int	process_my_load_module (struct ast_config *cfg)

static int	reload (void)

static int	unload_module (void)

Variables
static struct ast_module_info	__mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_LOAD_ORDER , .description = "PostgreSQL CEL Backend" , .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 = AST_BUILDOPT_SUM, .support_level = AST_MODULE_SUPPORT_EXTENDED, .load = load_module, .unload = unload_module, .reload = reload, .load_pri = AST_MODPRI_CDR_DRIVER, .requires = "cel", }

static const struct ast_module_info *	ast_module_info = &__mod_info

static unsigned char	cel_show_user_def

static char *	config = "cel_pgsql.conf"

static PGconn *	conn = NULL

static int	connected = 0

static int	maxsize = 512

static int	maxsize2 = 512

static char *	pgappname

static char *	pgdbname

static char *	pgdbport

static char *	pgdbuser

static char *	pghostname

static char *	pgpassword

static ast_mutex_t	pgsql_lock = { PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP , NULL, {1, 0} }

static struct psql_columns	psql_columns = { .first = NULL, .last = NULL, .lock = { PTHREAD_RWLOCK_INITIALIZER , NULL, {1, 0} } , }

static PGresult *	result = NULL

static char *	schema

static char *	table

static int	usegmtime = 0

Detailed Description

PostgreSQL CEL logger.

Author: Steve Murphy murf@.nosp@m.digi.nosp@m.um.co.nosp@m.m PostgreSQL http://www.postgresql.org/

Definition in file cel_pgsql.c.

Macro Definition Documentation

◆ CEL_SHOW_USERDEF_DEFAULT

#define CEL_SHOW_USERDEF_DEFAULT 0

show_user_def is off by default

Definition at line 76 of file cel_pgsql.c.

◆ DATE_FORMAT

#define DATE_FORMAT "%Y-%m-%d %T.%6q"

Definition at line 53 of file cel_pgsql.c.

◆ LENGTHEN_BUF

#define LENGTHEN_BUF	(	size,
		var_sql
	)

Definition at line 97 of file cel_pgsql.c.

◆ LENGTHEN_BUF1

#define LENGTHEN_BUF1 ( size ) LENGTHEN_BUF(size, sql);

Definition at line 111 of file cel_pgsql.c.

◆ LENGTHEN_BUF2

#define LENGTHEN_BUF2 ( size ) LENGTHEN_BUF(size, sql2);

Definition at line 113 of file cel_pgsql.c.

◆ PGSQL_BACKEND_NAME

#define PGSQL_BACKEND_NAME "CEL PGSQL backend"

Definition at line 55 of file cel_pgsql.c.

◆ PGSQL_MIN_VERSION_SCHEMA

#define PGSQL_MIN_VERSION_SCHEMA 70300

Definition at line 57 of file cel_pgsql.c.

◆ SEP

#define SEP (first ? "" : ",")

Function Documentation

◆ __reg_module()

static void __reg_module ( void )

static

Definition at line 709 of file cel_pgsql.c.

◆ __unreg_module()

static void __unreg_module ( void )

static

Definition at line 709 of file cel_pgsql.c.

◆ AST_MODULE_SELF_SYM()

struct ast_module * AST_MODULE_SELF_SYM ( void )

Definition at line 709 of file cel_pgsql.c.

◆ load_module()

static int load_module ( void )

static

Definition at line 692 of file cel_pgsql.c.

{
    return my_load_module(0);
}

References my_load_module().

◆ my_load_module()

static int my_load_module ( int reload )

static

Definition at line 665 of file cel_pgsql.c.

{
    struct ast_config *cfg;
    struct ast_flags config_flags = { reload ? CONFIG_FLAG_FILEUNCHANGED : 0 };
 
    if ((cfg = ast_config_load(config, config_flags)) == NULL || cfg == CONFIG_STATUS_FILEINVALID) {
        ast_log(LOG_WARNING, "Unable to load config for PostgreSQL CEL's: %s\n", config);
        return AST_MODULE_LOAD_DECLINE;
    } else if (cfg == CONFIG_STATUS_FILEUNCHANGED) {
        return AST_MODULE_LOAD_SUCCESS;
    }
 
    if (reload) {
        my_unload_module();
    }
 
    process_my_load_module(cfg);
    ast_config_destroy(cfg);
 
    if (ast_cel_backend_register(PGSQL_BACKEND_NAME, pgsql_log)) {
        ast_log(LOG_WARNING, "Unable to subscribe to CEL events for pgsql\n");
        return AST_MODULE_LOAD_DECLINE;
    }
 
    return AST_MODULE_LOAD_SUCCESS;
}

References ast_cel_backend_register(), ast_config_destroy(), ast_config_load, ast_log, AST_MODULE_LOAD_DECLINE, AST_MODULE_LOAD_SUCCESS, config, CONFIG_FLAG_FILEUNCHANGED, CONFIG_STATUS_FILEINVALID, CONFIG_STATUS_FILEUNCHANGED, LOG_WARNING, my_unload_module(), NULL, PGSQL_BACKEND_NAME, pgsql_log(), process_my_load_module(), and reload().

Referenced by load_module(), and reload().

◆ my_unload_module()

static int my_unload_module ( void )

static

Definition at line 400 of file cel_pgsql.c.

{
    struct columns *current;
 
    ast_cel_backend_unregister(PGSQL_BACKEND_NAME);
    AST_RWLIST_WRLOCK(&psql_columns);
    if (conn) {
        PQfinish(conn);
        conn = NULL;
    }
    if (pghostname) {
        ast_free(pghostname);
        pghostname = NULL;
    }
    if (pgdbname) {
        ast_free(pgdbname);
        pgdbname = NULL;
    }
    if (pgdbuser) {
        ast_free(pgdbuser);
        pgdbuser = NULL;
    }
    if (pgpassword) {
        ast_free(pgpassword);
        pgpassword = NULL;
    }
    if (pgappname) {
        ast_free(pgappname);
        pgappname = NULL;
    }
    if (pgdbport) {
        ast_free(pgdbport);
        pgdbport = NULL;
    }
    if (table) {
        ast_free(table);
        table = NULL;
    }
    if (schema) {
        ast_free(schema);
        schema = NULL;
    }
    while ((current = AST_RWLIST_REMOVE_HEAD(&psql_columns, list))) {
        ast_free(current);
    }
    AST_RWLIST_UNLOCK(&psql_columns);
    return 0;
}

References ast_cel_backend_unregister(), ast_free, AST_RWLIST_REMOVE_HEAD, AST_RWLIST_UNLOCK, AST_RWLIST_WRLOCK, conn, current, columns::list, NULL, pgappname, pgdbname, pgdbport, pgdbuser, pghostname, pgpassword, PGSQL_BACKEND_NAME, schema, and table.

Referenced by my_load_module(), and unload_module().

◆ pgsql_log()

static void pgsql_log ( struct ast_event * event )

static

Definition at line 145 of file cel_pgsql.c.

{
    struct ast_tm tm;
    char timestr[128];
    char *pgerror;
    struct ast_cel_event_record record = {
        .version = AST_CEL_EVENT_RECORD_VERSION,
    };
 
    if (ast_cel_fill_record(event, &record)) {
        return;
    }
 
    ast_mutex_lock(&pgsql_lock);
 
    ast_localtime(&record.event_time, &tm, usegmtime ? "GMT" : NULL);
    ast_strftime(timestr, sizeof(timestr), DATE_FORMAT, &tm);
 
    if ((!connected) && pghostname && pgdbuser && pgpassword && pgdbname) {
        pgsql_reconnect();
        if (PQstatus(conn) != CONNECTION_BAD) {
            connected = 1;
        } else {
            pgerror = PQerrorMessage(conn);
            ast_log(LOG_ERROR, "cel_pgsql: Unable to connect to database server %s.  Calls will not be logged!\n", pghostname);
            ast_log(LOG_ERROR, "cel_pgsql: Reason: %s\n", pgerror);
            PQfinish(conn);
            conn = NULL;
        }
    }
    if (connected) {
        struct columns *cur;
        struct ast_str *sql = ast_str_create(maxsize), *sql2 = ast_str_create(maxsize2);
        char buf[257];
        char *escapebuf = NULL;
        const char *value;
        int first = 1;
        size_t bufsize = 513;
 
        escapebuf = ast_malloc(bufsize);
        if (!escapebuf || !sql || !sql2) {
            goto ast_log_cleanup;
        }
 
        ast_str_set(&sql, 0, "INSERT INTO %s (", table);
        ast_str_set(&sql2, 0, " VALUES (");
 
#define SEP (first ? "" : ",")
 
        AST_RWLIST_RDLOCK(&psql_columns);
        AST_RWLIST_TRAVERSE(&psql_columns, cur, list) {
            LENGTHEN_BUF1(strlen(cur->name) + 2);
            ast_str_append(&sql, 0, "%s\"%s\"", SEP, cur->name);
 
            if (strcmp(cur->name, "eventtime") == 0) {
                if (strncmp(cur->type, "int", 3) == 0) {
                    LENGTHEN_BUF2(13);
                    ast_str_append(&sql2, 0, "%s%ld", SEP, (long) record.event_time.tv_sec);
                } else if (strncmp(cur->type, "float", 5) == 0) {
                    LENGTHEN_BUF2(31);
                    ast_str_append(&sql2, 0, "%s%f",
                        SEP,
                        (double) record.event_time.tv_sec +
                        (double) record.event_time.tv_usec / 1000000.0);
                } else {
                    /* char, hopefully */
                    LENGTHEN_BUF2(31);
                    ast_localtime(&record.event_time, &tm, usegmtime ? "GMT" : NULL);
                    ast_strftime(buf, sizeof(buf), DATE_FORMAT, &tm);
                    ast_str_append(&sql2, 0, "%s'%s'", SEP, buf);
                }
            } else if (strcmp(cur->name, "eventtype") == 0) {
                if (cur->type[0] == 'i') {
                    /* Get integer, no need to escape anything */
                    LENGTHEN_BUF2(5);
                    ast_str_append(&sql2, 0, "%s%d", SEP, (int) record.event_type);
                } else if (strncmp(cur->type, "float", 5) == 0) {
                    LENGTHEN_BUF2(31);
                    ast_str_append(&sql2, 0, "%s%f", SEP, (double) record.event_type);
                } else {
                    /* Char field, probably */
                    const char *event_name;
 
                    event_name = (!cel_show_user_def
                        && record.event_type == AST_CEL_USER_DEFINED)
                        ? record.user_defined_name : record.event_name;
                    LENGTHEN_BUF2(strlen(event_name) + 1);
                    ast_str_append(&sql2, 0, "%s'%s'", SEP, event_name);
                }
            } else if (strcmp(cur->name, "amaflags") == 0) {
                if (strncmp(cur->type, "int", 3) == 0) {
                    /* Integer, no need to escape anything */
                    LENGTHEN_BUF2(13);
                    ast_str_append(&sql2, 0, "%s%u", SEP, record.amaflag);
                } else {
                    /* Although this is a char field, there are no special characters in the values for these fields */
                    LENGTHEN_BUF2(31);
                    ast_str_append(&sql2, 0, "%s'%u'", SEP, record.amaflag);
                }
            } else {
                /* Arbitrary field, could be anything */
                if (strcmp(cur->name, "userdeftype") == 0) {
                    value = record.user_defined_name;
                } else if (strcmp(cur->name, "cid_name") == 0) {
                    value = record.caller_id_name;
                } else if (strcmp(cur->name, "cid_num") == 0) {
                    value = record.caller_id_num;
                } else if (strcmp(cur->name, "cid_ani") == 0) {
                    value = record.caller_id_ani;
                } else if (strcmp(cur->name, "cid_rdnis") == 0) {
                    value = record.caller_id_rdnis;
                } else if (strcmp(cur->name, "cid_dnid") == 0) {
                    value = record.caller_id_dnid;
                } else if (strcmp(cur->name, "exten") == 0) {
                    value = record.extension;
                } else if (strcmp(cur->name, "context") == 0) {
                    value = record.context;
                } else if (strcmp(cur->name, "channame") == 0) {
                    value = record.channel_name;
                } else if (strcmp(cur->name, "appname") == 0) {
                    value = record.application_name;
                } else if (strcmp(cur->name, "appdata") == 0) {
                    value = record.application_data;
                } else if (strcmp(cur->name, "accountcode") == 0) {
                    value = record.account_code;
                } else if (strcmp(cur->name, "peeraccount") == 0) {
                    value = record.peer_account;
                } else if (strcmp(cur->name, "uniqueid") == 0) {
                    value = record.unique_id;
                } else if (strcmp(cur->name, "linkedid") == 0) {
                    value = record.linked_id;
                } else if (strcmp(cur->name, "userfield") == 0) {
                    value = record.user_field;
                } else if (strcmp(cur->name, "peer") == 0) {
                    value = record.peer;
                } else if (strcmp(cur->name, "extra") == 0) {
                    value = record.extra;
                } else {
                    value = NULL;
                }
 
                if (value == NULL) {
                    ast_str_append(&sql2, 0, "%sDEFAULT", SEP);
                } else if (strncmp(cur->type, "int", 3) == 0) {
                    long long whatever;
                    if (value && sscanf(value, "%30lld", &whatever) == 1) {
                        LENGTHEN_BUF2(26);
                        ast_str_append(&sql2, 0, "%s%lld", SEP, whatever);
                    } else {
                        LENGTHEN_BUF2(2);
                        ast_str_append(&sql2, 0, "%s0", SEP);
                    }
                } else if (strncmp(cur->type, "float", 5) == 0) {
                    long double whatever;
                    if (value && sscanf(value, "%30Lf", &whatever) == 1) {
                        LENGTHEN_BUF2(51);
                        ast_str_append(&sql2, 0, "%s%30Lf", SEP, whatever);
                    } else {
                        LENGTHEN_BUF2(2);
                        ast_str_append(&sql2, 0, "%s0", SEP);
                    }
                    /* XXX Might want to handle dates, times, and other misc fields here XXX */
                } else {
                    if (value) {
                        size_t required_size = strlen(value) * 2 + 1;
 
                        /* If our argument size exceeds our buffer, grow it,
                         * as PQescapeStringConn() expects the buffer to be
                         * adequitely sized and does *NOT* do size checking.
                         */
                        if (required_size > bufsize) {
                            char *tmpbuf = ast_realloc(escapebuf, required_size);
 
                            if (!tmpbuf) {
                                AST_RWLIST_UNLOCK(&psql_columns);
                                goto ast_log_cleanup;
                            }
 
                            escapebuf = tmpbuf;
                            bufsize = required_size;
                        }
                        PQescapeStringConn(conn, escapebuf, value, strlen(value), NULL);
                    } else {
                        escapebuf[0] = '\0';
                    }
                    LENGTHEN_BUF2(strlen(escapebuf) + 3);
                    ast_str_append(&sql2, 0, "%s'%s'", SEP, escapebuf);
                }
            }
            first = 0;
        }
        AST_RWLIST_UNLOCK(&psql_columns);
        LENGTHEN_BUF1(ast_str_strlen(sql2) + 2);
        ast_str_append(&sql, 0, ")%s)", ast_str_buffer(sql2));
 
        ast_debug(3, "Inserting a CEL record: [%s].\n", ast_str_buffer(sql));
        /* Test to be sure we're still connected... */
        /* If we're connected, and connection is working, good. */
        /* Otherwise, attempt reconnect.  If it fails... sorry... */
        if (PQstatus(conn) == CONNECTION_OK) {
            connected = 1;
        } else {
            ast_log(LOG_WARNING, "Connection was lost... attempting to reconnect.\n");
            PQreset(conn);
            if (PQstatus(conn) == CONNECTION_OK) {
                ast_log(LOG_NOTICE, "Connection reestablished.\n");
                connected = 1;
            } else {
                pgerror = PQerrorMessage(conn);
                ast_log(LOG_ERROR, "Unable to reconnect to database server %s. Calls will not be logged!\n", pghostname);
                ast_log(LOG_ERROR, "Reason: %s\n", pgerror);
                PQfinish(conn);
                conn = NULL;
                connected = 0;
                goto ast_log_cleanup;
            }
        }
        result = PQexec(conn, ast_str_buffer(sql));
        if (PQresultStatus(result) != PGRES_COMMAND_OK) {
            pgerror = PQresultErrorMessage(result);
            ast_log(LOG_WARNING, "Failed to insert call detail record into database!\n");
            ast_log(LOG_WARNING, "Reason: %s\n", pgerror);
            ast_log(LOG_WARNING, "Connection may have been lost... attempting to reconnect.\n");
            PQreset(conn);
            if (PQstatus(conn) == CONNECTION_OK) {
                ast_log(LOG_NOTICE, "Connection reestablished.\n");
                connected = 1;
                PQclear(result);
                result = PQexec(conn, ast_str_buffer(sql));
                if (PQresultStatus(result) != PGRES_COMMAND_OK) {
                    pgerror = PQresultErrorMessage(result);
                    ast_log(LOG_ERROR, "HARD ERROR!  Attempted reconnection failed.  DROPPING CALL RECORD!\n");
                    ast_log(LOG_ERROR, "Reason: %s\n", pgerror);
                }
            }
        }
        PQclear(result);
 
        /* Next time, just allocate buffers that are that big to start with. */
        if (ast_str_strlen(sql) > maxsize) {
            maxsize = ast_str_strlen(sql);
        }
        if (ast_str_strlen(sql2) > maxsize2) {
            maxsize2 = ast_str_strlen(sql2);
        }
 
ast_log_cleanup:
        ast_free(sql);
        ast_free(sql2);
        ast_free(escapebuf);
    }
 
    ast_mutex_unlock(&pgsql_lock);
}

Referenced by my_load_module().

◆ pgsql_reconnect()

static void pgsql_reconnect ( void )

static

Definition at line 116 of file cel_pgsql.c.

{
    struct ast_str *conn_info = ast_str_create(128);
    if (!conn_info) {
        ast_log(LOG_ERROR, "Failed to allocate memory for connection string.\n");
        return;
    }
 
    if (conn) {
        PQfinish(conn);
        conn = NULL;
    }
 
    ast_str_set(&conn_info, 0, "host=%s port=%s dbname=%s user=%s",
        pghostname, pgdbport, pgdbname, pgdbuser);
 
    if (!ast_strlen_zero(pgappname)) {
        ast_str_append(&conn_info, 0, " application_name=%s", pgappname);
    }
 
    if (!ast_strlen_zero(pgpassword)) {
        ast_str_append(&conn_info, 0, " password=%s", pgpassword);
    }
 
    conn = PQconnectdb(ast_str_buffer(conn_info));
    ast_free(conn_info);
}

References ast_free, ast_log, ast_str_append(), ast_str_buffer(), ast_str_create, ast_str_set(), ast_strlen_zero(), conn, LOG_ERROR, NULL, pgappname, pgdbname, pgdbport, pgdbuser, pghostname, and pgpassword.

Referenced by pgsql_log(), and process_my_load_module().

◆ process_my_load_module()

static int process_my_load_module ( struct ast_config * cfg )

static

Definition at line 454 of file cel_pgsql.c.

{
    struct ast_variable *var;
    char *pgerror;
    const char *tmp;
    PGresult *result;
    struct columns *cur;
 
    if (!(var = ast_variable_browse(cfg, "global"))) {
        ast_log(LOG_WARNING,"CEL pgsql config file missing global section.\n");
        return AST_MODULE_LOAD_DECLINE;
    }
    if (!(tmp = ast_variable_retrieve(cfg,"global","hostname"))) {
        ast_log(LOG_WARNING,"PostgreSQL server hostname not specified.  Assuming unix socket connection\n");
        tmp = "";   /* connect via UNIX-socket by default */
    }
    if (pghostname)
        ast_free(pghostname);
    if (!(pghostname = ast_strdup(tmp))) {
        ast_log(LOG_WARNING,"PostgreSQL Ran out of memory copying host info\n");
        return AST_MODULE_LOAD_DECLINE;
    }
    if (!(tmp = ast_variable_retrieve(cfg, "global", "dbname"))) {
        ast_log(LOG_WARNING,"PostgreSQL database not specified.  Assuming asterisk\n");
        tmp = "asteriskceldb";
    }
    if (pgdbname)
        ast_free(pgdbname);
    if (!(pgdbname = ast_strdup(tmp))) {
        ast_log(LOG_WARNING,"PostgreSQL Ran out of memory copying dbname info\n");
        return AST_MODULE_LOAD_DECLINE;
    }
    if (!(tmp = ast_variable_retrieve(cfg, "global", "user"))) {
        ast_log(LOG_WARNING,"PostgreSQL database user not specified.  Assuming asterisk\n");
        tmp = "asterisk";
    }
    if (pgdbuser)
        ast_free(pgdbuser);
    if (!(pgdbuser = ast_strdup(tmp))) {
        ast_log(LOG_WARNING,"PostgreSQL Ran out of memory copying user info\n");
        return AST_MODULE_LOAD_DECLINE;
    }
    if (!(tmp = ast_variable_retrieve(cfg, "global", "password"))) {
        ast_log(LOG_WARNING, "PostgreSQL database password not specified.  Assuming blank\n");
        tmp = "";
    }
    if (pgpassword)
        ast_free(pgpassword);
    if (!(pgpassword = ast_strdup(tmp))) {
        ast_log(LOG_WARNING,"PostgreSQL Ran out of memory copying password info\n");
        return AST_MODULE_LOAD_DECLINE;
    }
    if (!(tmp = ast_variable_retrieve(cfg, "global", "appname"))) {
        tmp = "";
    }
    if (pgappname) {
        ast_free(pgappname);
    }
    if (!(pgappname = ast_strdup(tmp))) {
        ast_log(LOG_WARNING,"PostgreSQL Ran out of memory copying appname info\n");
        return AST_MODULE_LOAD_DECLINE;
    }
 
    if (!(tmp = ast_variable_retrieve(cfg,"global","port"))) {
        ast_log(LOG_WARNING,"PostgreSQL database port not specified.  Using default 5432.\n");
        tmp = "5432";
    }
    if (pgdbport)
        ast_free(pgdbport);
    if (!(pgdbport = ast_strdup(tmp))) {
        ast_log(LOG_WARNING,"PostgreSQL Ran out of memory copying port info\n");
        return AST_MODULE_LOAD_DECLINE;
    }
    if (!(tmp = ast_variable_retrieve(cfg, "global", "table"))) {
        ast_log(LOG_WARNING,"CEL table not specified.  Assuming cel\n");
        tmp = "cel";
    }
    if (table)
        ast_free(table);
    if (!(table = ast_strdup(tmp))) {
        return AST_MODULE_LOAD_DECLINE;
    }
    cel_show_user_def = CEL_SHOW_USERDEF_DEFAULT;
    if ((tmp = ast_variable_retrieve(cfg, "global", "show_user_defined"))) {
        cel_show_user_def = ast_true(tmp) ? 1 : 0;
    }
    if ((tmp = ast_variable_retrieve(cfg, "global", "usegmtime"))) {
        usegmtime = ast_true(tmp);
    } else {
        usegmtime = 0;
    }
    if (!(tmp = ast_variable_retrieve(cfg, "global", "schema"))) {
        tmp = "";
    }
    if (schema) {
        ast_free(schema);
    }
    if (!(schema = ast_strdup(tmp))) {
        ast_log(LOG_WARNING,"PostgreSQL Ran out of memory copying schema info\n");
        return AST_MODULE_LOAD_DECLINE;
    }
    if (DEBUG_ATLEAST(3)) {
        if (ast_strlen_zero(pghostname)) {
            ast_log(LOG_DEBUG, "cel_pgsql: using default unix socket\n");
        } else {
            ast_log(LOG_DEBUG, "cel_pgsql: got hostname of %s\n", pghostname);
        }
        ast_log(LOG_DEBUG, "cel_pgsql: got port of %s\n", pgdbport);
        ast_log(LOG_DEBUG, "cel_pgsql: got user of %s\n", pgdbuser);
        ast_log(LOG_DEBUG, "cel_pgsql: got dbname of %s\n", pgdbname);
        ast_log(LOG_DEBUG, "cel_pgsql: got password of %s\n", pgpassword);
        ast_log(LOG_DEBUG, "cel_pgsql: got sql table name of %s\n", table);
        ast_log(LOG_DEBUG, "cel_pgsql: got show_user_defined of %s\n",
            cel_show_user_def ? "Yes" : "No");
    }
 
    pgsql_reconnect();
    if (PQstatus(conn) != CONNECTION_BAD) {
        char sqlcmd[768];
        char *fname, *ftype, *flen, *fnotnull, *fdef, *tablename, *tmp_tablename;
        int i, rows, version;
 
        ast_debug(1, "Successfully connected to PostgreSQL database.\n");
        connected = 1;
 
        version = PQserverVersion(conn);
        /* Remove any schema name from the table */
        if ((tmp_tablename = strrchr(table, '.'))) {
            tmp_tablename++;
        } else {
            tmp_tablename = table;
        }
        tablename = ast_alloca(strlen(tmp_tablename) * 2 + 1);
        PQescapeStringConn(conn, tablename, tmp_tablename, strlen(tmp_tablename), NULL);
        if (version >= PGSQL_MIN_VERSION_SCHEMA) {
            char *schemaname;
            int lenschema;
            lenschema = strlen(schema);
            schemaname = ast_alloca(lenschema * 2 + 1);
            PQescapeStringConn(conn, schemaname, schema, lenschema, NULL);
 
            snprintf(sqlcmd, sizeof(sqlcmd),
            "SELECT a.attname, t.typname, a.attlen, a.attnotnull, pg_catalog.pg_get_expr(d.adbin, d.adrelid) adsrc, a.atttypmod "
            "FROM (((pg_catalog.pg_class c INNER JOIN pg_catalog.pg_namespace n ON n.oid = c.relnamespace "
                     "AND c.relname = '%s' AND n.nspname = %s%s%s) "
                   "INNER JOIN pg_catalog.pg_attribute a ON ("
                       "NOT a.attisdropped) AND a.attnum > 0 AND a.attrelid = c.oid) "
                "INNER JOIN pg_catalog.pg_type t ON t.oid = a.atttypid) "
            "LEFT OUTER JOIN pg_attrdef d ON a.atthasdef AND d.adrelid = a.attrelid "
              "AND d.adnum = a.attnum "
            "ORDER BY n.nspname, c.relname, attnum",
                tablename,
                lenschema == 0 ? "" : "'", lenschema == 0 ? "current_schema()" : schemaname, lenschema == 0 ? "" : "'");
        } else {
            snprintf(sqlcmd, sizeof(sqlcmd),
            "SELECT a.attname, t.typname, a.attlen, a.attnotnull, d.adsrc, a.atttypmod "
            "FROM pg_class c, pg_type t, pg_attribute a "
            "LEFT OUTER JOIN pg_attrdef d ON a.atthasdef AND d.adrelid = a.attrelid "
            "AND d.adnum = a.attnum WHERE c.oid = a.attrelid AND a.atttypid = t.oid "
            "AND (a.attnum > 0) AND c.relname = '%s' ORDER BY c.relname, attnum", tablename);
        }
        /* Query the columns */
        result = PQexec(conn, sqlcmd);
        if (PQresultStatus(result) != PGRES_TUPLES_OK) {
            pgerror = PQresultErrorMessage(result);
            ast_log(LOG_ERROR, "Failed to query database columns: %s\n", pgerror);
            PQclear(result);
            unload_module();
            return AST_MODULE_LOAD_DECLINE;
        }
 
        rows = PQntuples(result);
        for (i = 0; i < rows; i++) {
            fname = PQgetvalue(result, i, 0);
            ftype = PQgetvalue(result, i, 1);
            flen = PQgetvalue(result, i, 2);
            fnotnull = PQgetvalue(result, i, 3);
            fdef = PQgetvalue(result, i, 4);
            ast_verb(4, "Found column '%s' of type '%s'\n", fname, ftype);
            cur = ast_calloc(1, sizeof(*cur) + strlen(fname) + strlen(ftype) + 2);
            if (cur) {
                sscanf(flen, "%30d", &cur->len);
                cur->name = (char *)cur + sizeof(*cur);
                cur->type = (char *)cur + sizeof(*cur) + strlen(fname) + 1;
                strcpy(cur->name, fname);
                strcpy(cur->type, ftype);
                if (*fnotnull == 't') {
                    cur->notnull = 1;
                } else {
                    cur->notnull = 0;
                }
                if (!ast_strlen_zero(fdef)) {
                    cur->hasdefault = 1;
                } else {
                    cur->hasdefault = 0;
                }
                AST_RWLIST_INSERT_TAIL(&psql_columns, cur, list);
            }
        }
        PQclear(result);
    } else {
        pgerror = PQerrorMessage(conn);
        ast_log(LOG_ERROR, "cel_pgsql: Unable to connect to database server %s.  CALLS WILL NOT BE LOGGED!!\n", pghostname);
        ast_log(LOG_ERROR, "cel_pgsql: Reason: %s\n", pgerror);
        connected = 0;
        PQfinish(conn);
        conn = NULL;
    }
    return AST_MODULE_LOAD_SUCCESS;
}

References ast_alloca, ast_calloc, ast_debug, ast_free, ast_log, AST_MODULE_LOAD_DECLINE, AST_MODULE_LOAD_SUCCESS, AST_RWLIST_INSERT_TAIL, ast_strdup, ast_strlen_zero(), ast_true(), ast_variable_browse(), ast_variable_retrieve(), ast_verb, cel_show_user_def, CEL_SHOW_USERDEF_DEFAULT, conn, connected, DEBUG_ATLEAST, columns::hasdefault, columns::len, columns::list, LOG_DEBUG, LOG_ERROR, LOG_WARNING, columns::name, columns::notnull, NULL, pgappname, pgdbname, pgdbport, pgdbuser, pghostname, pgpassword, PGSQL_MIN_VERSION_SCHEMA, pgsql_reconnect(), result, schema, table, tmp(), columns::type, unload_module(), usegmtime, var, and version.

Referenced by my_load_module().

◆ reload()

static int reload ( void )

static

Definition at line 697 of file cel_pgsql.c.

{
    return my_load_module(1);
}

References my_load_module().

Referenced by my_load_module().

◆ unload_module()

static int unload_module ( void )

static

Definition at line 449 of file cel_pgsql.c.

{
    return my_unload_module();
}

References my_unload_module().

Referenced by process_my_load_module().

Variable Documentation

◆ __mod_info

struct ast_module_info __mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_LOAD_ORDER , .description = "PostgreSQL CEL Backend" , .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 = AST_BUILDOPT_SUM, .support_level = AST_MODULE_SUPPORT_EXTENDED, .load = load_module, .unload = unload_module, .reload = reload, .load_pri = AST_MODPRI_CDR_DRIVER, .requires = "cel", }

static

Definition at line 709 of file cel_pgsql.c.

◆ ast_module_info

const struct ast_module_info* ast_module_info = &__mod_info

static

Definition at line 709 of file cel_pgsql.c.

◆ cel_show_user_def

unsigned char cel_show_user_def

static

TRUE if we should set the eventtype field to USER_DEFINED on user events.

Definition at line 79 of file cel_pgsql.c.

Referenced by pgsql_log(), and process_my_load_module().

◆ config

char* config = "cel_pgsql.conf"

static

Definition at line 59 of file cel_pgsql.c.

Referenced by my_load_module().

◆ conn

PGconn* conn = NULL

static

Definition at line 83 of file cel_pgsql.c.

Referenced by my_unload_module(), pgsql_log(), pgsql_reconnect(), and process_my_load_module().

◆ connected

int connected = 0

static

Definition at line 70 of file cel_pgsql.c.

Referenced by pgsql_log(), and process_my_load_module().

◆ maxsize

int maxsize = 512

static

Definition at line 72 of file cel_pgsql.c.

Referenced by pgsql_log().

◆ maxsize2

int maxsize2 = 512

static

Definition at line 72 of file cel_pgsql.c.

Referenced by pgsql_log().

◆ pgappname

char* pgappname

static

Definition at line 65 of file cel_pgsql.c.

Referenced by my_unload_module(), pgsql_reconnect(), and process_my_load_module().

◆ pgdbname

char* pgdbname

static

Definition at line 62 of file cel_pgsql.c.

Referenced by my_unload_module(), pgsql_log(), pgsql_reconnect(), and process_my_load_module().

◆ pgdbport

char* pgdbport

static

Definition at line 66 of file cel_pgsql.c.

Referenced by my_unload_module(), pgsql_reconnect(), and process_my_load_module().

◆ pgdbuser

char* pgdbuser

static

Definition at line 63 of file cel_pgsql.c.

Referenced by my_unload_module(), pgsql_log(), pgsql_reconnect(), and process_my_load_module().

◆ pghostname

char* pghostname

static

Definition at line 61 of file cel_pgsql.c.

Referenced by my_unload_module(), pgsql_log(), pgsql_reconnect(), and process_my_load_module().

◆ pgpassword

char* pgpassword

static

Definition at line 64 of file cel_pgsql.c.

Referenced by my_unload_module(), pgsql_log(), pgsql_reconnect(), and process_my_load_module().

◆ pgsql_lock

ast_mutex_t pgsql_lock = { PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP , NULL, {1, 0} }

static

Definition at line 81 of file cel_pgsql.c.

Referenced by pgsql_log().

◆ psql_columns

struct psql_columns psql_columns = { .first = NULL, .last = NULL, .lock = { PTHREAD_RWLOCK_INITIALIZER , NULL, {1, 0} } , }

static

◆ result

PGresult* result = NULL

static

Definition at line 84 of file cel_pgsql.c.

Referenced by __ast_channel_alloc(), __ast_string_field_alloc_space(), __astman_get_header(), _pgsql_exec(), acf_meetme_info(), action_updateconfig(), aeap_transaction_end(), ast_app_parse_timelen(), ast_apply_ha(), ast_build_string(), ast_build_string_va(), ast_channel_publish_varset(), ast_config_internal_load(), ast_config_load2(), ast_db_exists(), ast_dns_resolve(), ast_dns_resolve_ipv6_and_ipv4(), ast_dns_result_free(), ast_dns_result_get_answer(), ast_dns_result_get_bogus(), ast_dns_result_get_canonical(), ast_dns_result_get_lowest_ttl(), ast_dns_result_get_rcode(), ast_dns_result_get_records(), ast_dns_result_get_secure(), ast_dnsmgr_get(), ast_dnsmgr_get_family(), ast_dnsmgr_lookup(), ast_dnsmgr_lookup_cb(), ast_format_cap_get_compatible(), ast_format_cap_get_compatible_format(), ast_format_cap_get_format_framing(), ast_geoloc_civicaddr_validate_varlist(), ast_geoloc_eprofile_to_uri(), ast_geoloc_gml_validate_varlist(), ast_geoloc_validate_result_to_str(), ast_get_encoded_char(), ast_get_encoded_str(), ast_gethostbyname(), ast_msg_has_destination(), ast_parse_arg(), ast_privacy_check(), ast_rtp_instance_available_formats(), ast_sip_str_to_dtmf(), ast_sip_str_to_security_mechanism_type(), ast_sip_will_uri_survive_restart(), ast_sockaddr_apply_netmask(), ast_speech_results_free(), ast_str_substitute_variables_full2(), AST_TEST_DEFINE(), ast_translate_available_formats(), ast_websocket_client_create(), ast_websocket_client_create_with_options(), ast_xml_query(), ast_xml_query_with_namespaces(), astman_verify_session_readpermissions(), astman_verify_session_writepermissions(), blackfilter_cmp_fn(), chan_pjsip_get_codec(), chan_rtp_get_codec(), chat(), check_add_remove_channel(), check_eval(), check_match(), check_translation_path(), cli_complete_registration(), conf_find_bridge_profile(), conf_find_menu_entry_by_sequence(), conf_find_user_profile(), config_module(), config_mysql(), config_pgsql(), configuration_parse_unsigned_integer(), db_get_common(), destroy_pgsql(), detect_callback(), detzcode(), detzcode64(), dial_exec_full(), dns_naptr_sort(), dns_query_recurring_resolution_callback(), dns_srv_sort(), dtmf_to_str(), dundi_lookup(), dundi_lookup_internal(), error(), evaluate_history_entry(), evaluate_like(), fax_detect_framehook(), fax_gateway_attach(), fax_gateway_detect_t38(), fax_gateway_framehook(), fax_gateway_start(), find_result(), find_table(), function_db_keys(), gen_match_to_pattern(), generic_fax_exec(), geoloc_config_cli_reload(), geoloc_config_list_locations(), geoloc_config_list_profiles(), geoloc_config_load(), geoloc_config_show_profiles(), geoloc_location_apply_handler(), geoloc_profile_apply_handler(), getremainingfilelength(), gmtsub(), handle_msg_cb(), handle_results(), handle_speechrecognize(), handle_standard_bridge_enter_message(), handle_updates(), iax2_codec_pref_index(), inform(), internal_dnsmgr_lookup(), invalid_record_test(), launch_ha_netscript(), ldap_loadentry(), lintocodec2_frameout(), lintogsm_frameout(), lintoilbc_frameout(), lintolpc10_frameout(), lintospeex_frameout(), listfilter(), loadresult2str(), localized_config_load(), localized_config_load_with_comments(), localsub(), mallocconcat(), malloccopy(), match_filter(), mwi_thread(), nominal_test(), odbc_datastore_free(), off_nominal_test(), ogg_speex_open(), ogg_vorbis_open(), ooh323_get_codec(), op_func(), P3(), parse_node(), parse_srv(), parsedoublearg(), parsefilearg(), parsefreq(), parseintarg(), parsetime(), parsetimearg(), parsevolarg(), parsevolume(), pgsql_exec(), pgsql_log(), phoneprov_callback(), process_my_load_module(), publish_async_exec_end(), publish_load_message(), publish_reload_message(), radius_log(), read_credentials(), read_mf_digits(), read_packet(), read_sf_digits(), realtime_arguments_to_fields2(), realtime_ldap_base_ap(), realtime_multi_mysql(), realtime_multi_pgsql(), realtime_mysql(), realtime_pgsql(), receivefax_exec(), require_pgsql(), rfcomm_read_and_append_char(), rfcomm_read_and_expect_char(), say(), scan_exec(), sdp_crypto_alloc(), sendfax_exec(), set_id_from_hdr(), sorcery_memory_cache_complete_name(), sorcery_memory_cache_complete_object_name(), sort_result(), speech_grammar(), speech_read(), speech_score(), speech_text(), stasis_message_type_create(), store_pgsql(), t30_phase_e_handler(), test_expected_result(), test_results(), testtime_write(), tmcomp(), transaction_end(), typeof(), tzload(), update2_pgsql(), update_pgsql(), validate_location_info(), wait_exec(), wait_for_answer(), websocket_client_args_create(), websocket_client_create(), and whitefilter_cmp_fn().

◆ schema

char* schema

static

Definition at line 68 of file cel_pgsql.c.

Referenced by load_config(), my_unload_module(), and process_my_load_module().

◆ table

char* table

static

Definition at line 67 of file cel_pgsql.c.

Referenced by my_unload_module(), pgsql_log(), and process_my_load_module().

◆ usegmtime

int usegmtime = 0

static

Definition at line 73 of file cel_pgsql.c.

Referenced by pgsql_log(), and process_my_load_module().

Data Structures

Macros

Functions

Variables

Detailed Description

Macro Definition Documentation

◆ CEL_SHOW_USERDEF_DEFAULT

◆ DATE_FORMAT

◆ LENGTHEN_BUF

◆ LENGTHEN_BUF1

◆ LENGTHEN_BUF2

◆ PGSQL_BACKEND_NAME

◆ PGSQL_MIN_VERSION_SCHEMA

◆ SEP

Function Documentation

◆ __reg_module()

◆ __unreg_module()

◆ AST_MODULE_SELF_SYM()

◆ load_module()

◆ my_load_module()

◆ my_unload_module()

◆ pgsql_log()

◆ pgsql_reconnect()

◆ process_my_load_module()

◆ reload()

◆ unload_module()

Variable Documentation

◆ __mod_info

◆ ast_module_info

◆ cel_show_user_def

◆ config

◆ conn

◆ connected

◆ maxsize

◆ maxsize2

◆ pgappname

◆ pgdbname

◆ pgdbport

◆ pgdbuser

◆ pghostname

◆ pgpassword

◆ pgsql_lock

◆ psql_columns

◆ result

◆ schema

◆ table

◆ usegmtime