FreeTDS CEL logger http://www.freetds.org/. More...

#include "asterisk.h"
#include <time.h>
#include <math.h>
#include "asterisk/config.h"
#include "asterisk/channel.h"
#include "asterisk/cel.h"
#include "asterisk/module.h"
#include "asterisk/logger.h"
#include <sqlfront.h>
#include <sybdb.h>

Include dependency graph for cel_tds.c:

Go to the source code of this file.

Data Structures
struct	cel_tds_config

Macros
#define	DATE_FORMAT "%Y/%m/%d %T"

#define	TDS_BACKEND_NAME "CEL TDS logging backend"

Functions
static void	__reg_module (void)

static void	__unreg_module (void)

static char *	anti_injection (const char *, int)

struct ast_module *	AST_MODULE_SELF_SYM (void)

static int	execute_and_consume (DBPROCESS dbproc, const char fmt,...)

static void	get_date (char *, size_t len, struct timeval)

static int	load_module (void)

static int	mssql_connect (void)

static int	mssql_disconnect (void)

static int	reload (void)

static int	tds_error_handler (DBPROCESS dbproc, int severity, int dberr, int oserr, char dberrstr, char *oserrstr)

static int	tds_load_module (int reload)

static void	tds_log (struct ast_event *event)

static int	tds_message_handler (DBPROCESS dbproc, DBINT msgno, int msgstate, int severity, char msgtext, char srvname, char procname, int line)

static int	tds_unload_module (void)

static int	unload_module (void)

Variables
static struct ast_module_info	__mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_LOAD_ORDER , .description = "FreeTDS CEL Backend" , .key = ASTERISK_GPL_KEY , .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 char *	config = "cel_tds.conf"

static struct cel_tds_config *	settings

static ast_mutex_t	tds_lock = AST_MUTEX_INIT_VALUE

Detailed Description

FreeTDS CEL logger http://www.freetds.org/.

Definition in file cel_tds.c.

Macro Definition Documentation

◆ DATE_FORMAT

#define DATE_FORMAT "%Y/%m/%d %T"

 *
 * Table Structure for `cel`
 *

CREATE TABLE [dbo].[cel] (
    [accountcode] [varchar] (20) NULL ,
    [cidname] [varchar] (80) NULL ,
    [cidnum] [varchar] (80) NULL ,
    [cidani] [varchar] (80) NULL ,
    [cidrdnis] [varchar] (80) NULL ,
    [ciddnid] [varchar] (80) NULL ,
    [exten] [varchar] (80) NULL ,
    [context] [varchar] (80) NULL ,
    [channame] [varchar] (80) NULL ,
    [appname] [varchar] (80) NULL ,
    [appdata] [varchar] (80) NULL ,
    [eventtime] [datetime] NULL ,
    [eventtype] [varchar] (32) NULL ,
    [uniqueid] [varchar] (32) NULL ,
    [linkedid] [varchar] (32) NULL ,
    [amaflags] [varchar] (16) NULL ,
    [userfield] [varchar] (32) NULL ,
    [peer] [varchar] (32) NULL
) ON [PRIMARY]

Definition at line 77 of file cel_tds.c.

◆ TDS_BACKEND_NAME

#define TDS_BACKEND_NAME "CEL TDS logging backend"

Definition at line 79 of file cel_tds.c.

Function Documentation

◆ __reg_module()

static void __reg_module ( void )

static

Definition at line 584 of file cel_tds.c.

◆ __unreg_module()

static void __unreg_module ( void )

static

Definition at line 584 of file cel_tds.c.

◆ anti_injection()

static char * anti_injection	(	const char *	str,
		int	len
	)

static

Definition at line 260 of file cel_tds.c.

{
    /* Reference to http://www.nextgenss.com/papers/advanced_sql_injection.pdf */
    char *buf;
    char *buf_ptr, *srh_ptr;
    char *known_bad[] = {"select", "insert", "update", "delete", "drop", ";", "--", "\0"};
    int idx;
 
    if (!(buf = ast_calloc(1, len + 1))) {
        ast_log(LOG_ERROR, "Out of memory\n");
        return NULL;
    }
 
    buf_ptr = buf;
 
    /* Escape single quotes */
    for (; *str && strlen(buf) < len; str++) {
        if (*str == '\'') {
            *buf_ptr++ = '\'';
        }
        *buf_ptr++ = *str;
    }
    *buf_ptr = '\0';
 
    /* Erase known bad input */
    for (idx = 0; *known_bad[idx]; idx++) {
        while ((srh_ptr = strcasestr(buf, known_bad[idx]))) {
            memmove(srh_ptr, srh_ptr + strlen(known_bad[idx]), strlen(srh_ptr + strlen(known_bad[idx])) + 1);
        }
    }
    return buf;
}

References ast_calloc, ast_log, buf, len(), LOG_ERROR, NULL, str, and strcasestr().

Referenced by tds_log().

◆ AST_MODULE_SELF_SYM()

struct ast_module * AST_MODULE_SELF_SYM ( void )

Definition at line 584 of file cel_tds.c.

◆ execute_and_consume()

static int execute_and_consume	(	DBPROCESS *	dbproc,
		const char *	fmt,
			...
	)

static

Definition at line 305 of file cel_tds.c.

{
    va_list ap;
    char *buffer;
 
    va_start(ap, fmt);
    if (ast_vasprintf(&buffer, fmt, ap) < 0) {
        va_end(ap);
        return 1;
    }
    va_end(ap);
 
    if (dbfcmd(dbproc, buffer) == FAIL) {
        ast_free(buffer);
        return 1;
    }
 
    ast_free(buffer);
 
    if (dbsqlexec(dbproc) == FAIL) {
        return 1;
    }
 
    /* Consume the result set (we don't really care about the result, though) */
    while (dbresults(dbproc) != NO_MORE_RESULTS) {
        while (dbnextrow(dbproc) != NO_MORE_ROWS);
    }
 
    return 0;
}

References ast_free, and ast_vasprintf.

Referenced by mssql_connect().

◆ get_date()

static void get_date	(	char *	dateField,
		size_t	len,
		struct timeval	when
	)

static

Definition at line 293 of file cel_tds.c.

{
    /* To make sure we have date variable if not insert null to SQL */
    if (!ast_tvzero(when)) {
        struct ast_tm tm;
        ast_localtime(&when, &tm, NULL);
        ast_strftime(dateField, len, "'" DATE_FORMAT "'", &tm);
    } else {
        ast_copy_string(dateField, "null", len);
    }
}

References ast_copy_string(), ast_localtime(), ast_strftime(), ast_tvzero(), DATE_FORMAT, len(), and NULL.

Referenced by tds_log().

◆ load_module()

static int load_module ( void )

static

Definition at line 533 of file cel_tds.c.

{
    if (dbinit() == FAIL) {
        ast_log(LOG_ERROR, "Failed to initialize FreeTDS db-lib\n");
        return AST_MODULE_LOAD_DECLINE;
    }
 
    dberrhandle(tds_error_handler);
    dbmsghandle(tds_message_handler);
 
    settings = ast_calloc_with_stringfields(1, struct cel_tds_config, 256);
 
    if (!settings) {
        dbexit();
        return AST_MODULE_LOAD_DECLINE;
    }
 
    if (!tds_load_module(0)) {
        ast_string_field_free_memory(settings);
        ast_free(settings);
        settings = NULL;
        dbexit();
        ast_log(LOG_WARNING,"cel_tds module had config problems; declining load\n");
        return AST_MODULE_LOAD_DECLINE;
    }
 
    /* Register MSSQL CEL handler */
    if (ast_cel_backend_register(TDS_BACKEND_NAME, tds_log)) {
        ast_log(LOG_ERROR, "Unable to register MSSQL CEL handling\n");
        ast_string_field_free_memory(settings);
        ast_free(settings);
        settings = NULL;
        dbexit();
        return AST_MODULE_LOAD_DECLINE;
    }
 
    return AST_MODULE_LOAD_SUCCESS;
}

References ast_calloc_with_stringfields, ast_cel_backend_register(), ast_free, ast_log, AST_MODULE_LOAD_DECLINE, AST_MODULE_LOAD_SUCCESS, ast_string_field_free_memory, LOG_ERROR, LOG_WARNING, NULL, settings, TDS_BACKEND_NAME, tds_error_handler(), tds_load_module(), tds_log(), and tds_message_handler().

◆ mssql_connect()

static int mssql_connect ( void )

static

Definition at line 347 of file cel_tds.c.

{
    LOGINREC *login;
 
    if ((login = dblogin()) == NULL) {
        ast_log(LOG_ERROR, "Unable to allocate login structure for db-lib\n");
        return -1;
    }
 
    DBSETLAPP(login,  "TSQL");
    DBSETLUSER(login, (char *) settings->username);
    DBSETLPWD(login,  (char *) settings->password);
 
    if (!ast_strlen_zero(settings->charset)) {
        DBSETLCHARSET(login, (char *) settings->charset);
    }
 
    if (!ast_strlen_zero(settings->language)) {
        DBSETLNATLANG(login, (char *) settings->language);
    }
 
    if ((settings->dbproc = dbopen(login, (char *) settings->connection)) == NULL) {
        ast_log(LOG_ERROR, "Unable to connect to %s\n", settings->connection);
        dbloginfree(login);
        return -1;
    }
 
    dbloginfree(login);
 
    if (dbuse(settings->dbproc, (char *) settings->database) == FAIL) {
        ast_log(LOG_ERROR, "Unable to select database %s\n", settings->database);
        goto failed;
    }
 
    if (execute_and_consume(settings->dbproc, "SELECT 1 FROM [%s]", settings->table)) {
        ast_log(LOG_ERROR, "Unable to find table '%s'\n", settings->table);
        goto failed;
    }
 
    settings->connected = 1;
 
    return 0;
 
failed:
    dbclose(settings->dbproc);
    settings->dbproc = NULL;
    return -1;
}

References ast_log, ast_strlen_zero(), cel_tds_config::charset, cel_tds_config::connected, cel_tds_config::connection, cel_tds_config::database, cel_tds_config::dbproc, execute_and_consume(), cel_tds_config::language, LOG_ERROR, NULL, cel_tds_config::password, settings, cel_tds_config::table, and cel_tds_config::username.

Referenced by tds_load_module(), and tds_log().

◆ mssql_disconnect()

static int mssql_disconnect ( void )

static

Definition at line 336 of file cel_tds.c.

{
    if (settings->dbproc) {
        dbclose(settings->dbproc);
        settings->dbproc = NULL;
    }
    settings->connected = 0;
 
    return 0;
}

References cel_tds_config::connected, cel_tds_config::dbproc, NULL, and settings.

Referenced by tds_load_module(), tds_log(), and tds_unload_module().

◆ reload()

static int reload ( void )

static

Definition at line 528 of file cel_tds.c.

{
    return tds_load_module(1);
}

References tds_load_module().

Referenced by tds_load_module().

◆ tds_error_handler()

static int tds_error_handler	(	DBPROCESS *	dbproc,
		int	severity,
		int	dberr,
		int	oserr,
		char *	dberrstr,
		char *	oserrstr
	)

static

Definition at line 414 of file cel_tds.c.

{
    ast_log(LOG_ERROR, "%s (%d)\n", dberrstr, dberr);
 
    if (oserr != DBNOERR) {
        ast_log(LOG_ERROR, "%s (%d)\n", oserrstr, oserr);
    }
 
    return INT_CANCEL;
}

References ast_log, and LOG_ERROR.

Referenced by load_module().

◆ tds_load_module()

static int tds_load_module ( int reload )

static

Definition at line 433 of file cel_tds.c.

{
    struct ast_config *cfg;
    const char *ptr = NULL;
    struct ast_flags config_flags = { reload ? CONFIG_FLAG_FILEUNCHANGED : 0 };
 
    cfg = ast_config_load(config, config_flags);
    if (!cfg || cfg == CONFIG_STATUS_FILEINVALID) {
        ast_log(LOG_NOTICE, "Unable to load TDS config for CELs: %s\n", config);
        return 0;
    } else if (cfg == CONFIG_STATUS_FILEUNCHANGED) {
        return 0;
    }
 
    if (!ast_variable_browse(cfg, "global")) {
        /* nothing configured */
        ast_config_destroy(cfg);
        ast_log(LOG_NOTICE, "cel_tds has no global category, nothing to configure.\n");
        return 0;
    }
 
    ast_mutex_lock(&tds_lock);
 
    /* Clear out any existing settings */
    ast_string_field_init(settings, 0);
 
    ptr = ast_variable_retrieve(cfg, "global", "connection");
    if (ptr) {
        ast_string_field_set(settings, connection, ptr);
    } else {
        ast_log(LOG_ERROR, "Failed to connect: Database connection name not specified.\n");
        goto failed;
    }
 
    ptr = ast_variable_retrieve(cfg, "global", "dbname");
    if (ptr) {
        ast_string_field_set(settings, database, ptr);
    } else {
        ast_log(LOG_ERROR, "Failed to connect: Database dbname not specified.\n");
        goto failed;
    }
 
    ptr = ast_variable_retrieve(cfg, "global", "user");
    if (ptr) {
        ast_string_field_set(settings, username, ptr);
    } else {
        ast_log(LOG_ERROR, "Failed to connect: Database dbuser not specified.\n");
        goto failed;
    }
 
    ptr = ast_variable_retrieve(cfg, "global", "password");
    if (ptr) {
        ast_string_field_set(settings, password, ptr);
    } else {
        ast_log(LOG_ERROR, "Failed to connect: Database password not specified.\n");
        goto failed;
    }
 
    ptr = ast_variable_retrieve(cfg, "global", "charset");
    if (ptr) {
        ast_string_field_set(settings, charset, ptr);
    }
 
    ptr = ast_variable_retrieve(cfg, "global", "language");
    if (ptr) {
        ast_string_field_set(settings, language, ptr);
    }
 
    ptr = ast_variable_retrieve(cfg, "global", "table");
    if (ptr) {
        ast_string_field_set(settings, table, ptr);
    } else {
        ast_log(LOG_NOTICE, "Table name not specified, using 'cel' by default.\n");
        ast_string_field_set(settings, table, "cel");
    }
 
    mssql_disconnect();
 
    if (mssql_connect()) {
        /* We failed to connect (mssql_connect takes care of logging it) */
        goto failed;
    }
 
    ast_mutex_unlock(&tds_lock);
    ast_config_destroy(cfg);
 
    return 1;
 
failed:
    ast_mutex_unlock(&tds_lock);
    ast_config_destroy(cfg);
 
    return 0;
}

References ast_config_destroy(), ast_config_load, ast_log, ast_mutex_lock, ast_mutex_unlock, ast_string_field_init, ast_string_field_set, ast_variable_browse(), ast_variable_retrieve(), config, CONFIG_FLAG_FILEUNCHANGED, CONFIG_STATUS_FILEINVALID, CONFIG_STATUS_FILEUNCHANGED, language, LOG_ERROR, LOG_NOTICE, mssql_connect(), mssql_disconnect(), NULL, reload(), settings, and tds_lock.

Referenced by load_module(), and reload().

◆ tds_log()

static void tds_log ( struct ast_event * event )

static

Definition at line 110 of file cel_tds.c.

{
    char start[80];
    char *accountcode_ai, *clidnum_ai, *exten_ai, *context_ai, *clid_ai, *channel_ai, *app_ai, *appdata_ai, *uniqueid_ai, *linkedid_ai, *cidani_ai, *cidrdnis_ai, *ciddnid_ai, *peer_ai, *userfield_ai, *eventtype_ai;
    RETCODE erc;
    int attempt = 1;
    struct ast_cel_event_record record = {
        .version = AST_CEL_EVENT_RECORD_VERSION,
    };
 
    if (ast_cel_fill_record(event, &record)) {
        return;
    }
 
    ast_mutex_lock(&tds_lock);
 
    accountcode_ai = anti_injection(record.account_code, 20);
    clidnum_ai     = anti_injection(record.caller_id_num, 80);
    clid_ai        = anti_injection(record.caller_id_name, 80);
    cidani_ai      = anti_injection(record.caller_id_ani, 80);
    cidrdnis_ai    = anti_injection(record.caller_id_rdnis, 80);
    ciddnid_ai     = anti_injection(record.caller_id_dnid, 80);
    exten_ai       = anti_injection(record.extension, 80);
    context_ai     = anti_injection(record.context, 80);
    channel_ai     = anti_injection(record.channel_name, 80);
    app_ai         = anti_injection(record.application_name, 80);
    appdata_ai     = anti_injection(record.application_data, 80);
    uniqueid_ai    = anti_injection(record.unique_id, 32);
    linkedid_ai    = anti_injection(record.linked_id, 32);
    userfield_ai   = anti_injection(record.user_field, 32);
    peer_ai        = anti_injection(record.peer, 32);
    eventtype_ai   = anti_injection(
        (record.event_type == AST_CEL_USER_DEFINED)
            ? record.user_defined_name : record.event_name, 32);
 
    get_date(start, sizeof(start), record.event_time);
 
retry:
    /* Ensure that we are connected */
    if (!settings->connected) {
        ast_log(LOG_NOTICE, "Attempting to reconnect to %s (Attempt %d)\n", settings->connection, attempt);
        if (mssql_connect()) {
            /* Connect failed */
            if (attempt++ < 3) {
                goto retry;
            }
            goto done;
        }
    }
 
    erc = dbfcmd(settings->dbproc,
        "INSERT INTO %s "
        "("
        "accountcode,"
        "cidnum,"
        "cidname,"
        "cidani,"
        "cidrdnis,"
        "ciddnid,"
        "exten,"
        "context,"
        "channel,"
        "appname,"
        "appdata,"
        "eventtime,"
        "eventtype,"
        "amaflags, "
        "uniqueid,"
        "linkedid,"
        "userfield,"
        "peer"
        ") "
        "VALUES "
        "("
        "'%s'," /* accountcode */
        "'%s'," /* clidnum */
        "'%s'," /* clid */
        "'%s'," /* cid-ani */
        "'%s'," /* cid-rdnis */
        "'%s'," /* cid-dnid */
        "'%s'," /* exten */
        "'%s'," /* context */
        "'%s'," /* channel */
        "'%s'," /* app */
        "'%s'," /* appdata */
        "%s, "  /* eventtime */
        "'%s'," /* eventtype */
        "'%s'," /* amaflags */
        "'%s'," /* uniqueid */
        "'%s'," /* linkedid */
        "'%s'," /* userfield */
        "'%s'"  /* peer */
        ")",
        settings->table, accountcode_ai, clidnum_ai, clid_ai, cidani_ai, cidrdnis_ai,
        ciddnid_ai, exten_ai, context_ai, channel_ai, app_ai, appdata_ai, start,
        eventtype_ai,
                    ast_channel_amaflags2string(record.amaflag), uniqueid_ai, linkedid_ai,
        userfield_ai, peer_ai);
 
    if (erc == FAIL) {
        if (attempt++ < 3) {
            ast_log(LOG_NOTICE, "Failed to build INSERT statement, retrying...\n");
            mssql_disconnect();
            goto retry;
        } else {
            ast_log(LOG_ERROR, "Failed to build INSERT statement, no CEL was logged.\n");
            goto done;
        }
    }
 
    if (dbsqlexec(settings->dbproc) == FAIL) {
        if (attempt++ < 3) {
            ast_log(LOG_NOTICE, "Failed to execute INSERT statement, retrying...\n");
            mssql_disconnect();
            goto retry;
        } else {
            ast_log(LOG_ERROR, "Failed to execute INSERT statement, no CEL was logged.\n");
            goto done;
        }
    }
 
    /* Consume any results we might get back (this is more of a sanity check than
     * anything else, since an INSERT shouldn't return results). */
    while (dbresults(settings->dbproc) != NO_MORE_RESULTS) {
        while (dbnextrow(settings->dbproc) != NO_MORE_ROWS);
    }
 
done:
    ast_mutex_unlock(&tds_lock);
 
    ast_free(accountcode_ai);
    ast_free(clidnum_ai);
    ast_free(clid_ai);
    ast_free(cidani_ai);
    ast_free(cidrdnis_ai);
    ast_free(ciddnid_ai);
    ast_free(exten_ai);
    ast_free(context_ai);
    ast_free(channel_ai);
    ast_free(app_ai);
    ast_free(appdata_ai);
    ast_free(uniqueid_ai);
    ast_free(linkedid_ai);
    ast_free(userfield_ai);
    ast_free(peer_ai);
    ast_free(eventtype_ai);
 
    return;
}

Referenced by load_module().

◆ tds_message_handler()

static int tds_message_handler	(	DBPROCESS *	dbproc,
		DBINT	msgno,
		int	msgstate,
		int	severity,
		char *	msgtext,
		char *	srvname,
		char *	procname,
		int	line
	)

static

Definition at line 425 of file cel_tds.c.

{
    ast_debug(1, "Msg %d, Level %d, State %d, Line %d\n", msgno, severity, msgstate, line);
    ast_log(LOG_NOTICE, "%s\n", msgtext);
 
    return 0;
}

References ast_debug, ast_log, LOG_NOTICE, and severity.

Referenced by load_module().

◆ tds_unload_module()

static int tds_unload_module ( void )

static

Definition at line 396 of file cel_tds.c.

{
    ast_cel_backend_unregister(TDS_BACKEND_NAME);
 
    if (settings) {
        ast_mutex_lock(&tds_lock);
        mssql_disconnect();
        ast_mutex_unlock(&tds_lock);
 
        ast_string_field_free_memory(settings);
        ast_free(settings);
    }
 
    dbexit();
 
    return 0;
}

References ast_cel_backend_unregister(), ast_free, ast_mutex_lock, ast_mutex_unlock, ast_string_field_free_memory, mssql_disconnect(), settings, TDS_BACKEND_NAME, and tds_lock.

Referenced by unload_module().

◆ unload_module()

static int unload_module ( void )

static

Definition at line 572 of file cel_tds.c.

{
    return tds_unload_module();
}

References tds_unload_module().

Variable Documentation

◆ __mod_info

struct ast_module_info __mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_LOAD_ORDER , .description = "FreeTDS CEL Backend" , .key = ASTERISK_GPL_KEY , .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 584 of file cel_tds.c.

◆ ast_module_info

const struct ast_module_info* ast_module_info = &__mod_info

static

Definition at line 584 of file cel_tds.c.

◆ config

char* config = "cel_tds.conf"

static

Definition at line 81 of file cel_tds.c.

Referenced by tds_load_module().

◆ settings

struct cel_tds_config* settings

static

Definition at line 99 of file cel_tds.c.

Referenced by load_module(), mssql_connect(), mssql_disconnect(), tds_load_module(), tds_log(), and tds_unload_module().

◆ tds_lock

ast_mutex_t tds_lock = AST_MUTEX_INIT_VALUE

static

Definition at line 97 of file cel_tds.c.

Referenced by tds_load_module(), tds_log(), and tds_unload_module().

Data Structures

Macros

Functions

Variables

Detailed Description

Macro Definition Documentation

◆ DATE_FORMAT

◆ TDS_BACKEND_NAME

Function Documentation

◆ __reg_module()

◆ __unreg_module()

◆ anti_injection()

◆ AST_MODULE_SELF_SYM()

◆ execute_and_consume()

◆ get_date()

◆ load_module()

◆ mssql_connect()

◆ mssql_disconnect()

◆ reload()

◆ tds_error_handler()

◆ tds_load_module()

◆ tds_log()

◆ tds_message_handler()

◆ tds_unload_module()

◆ unload_module()

Variable Documentation

◆ __mod_info

◆ ast_module_info

◆ config

◆ settings

◆ tds_lock