bb_alog.c File Reference

#include "gwlib/gwlib.h"
#include "msg.h"
#include "sms.h"
#include "bearerbox.h"
#include "smscconn.h"

Go to the source code of this file.

Functions
static Octstr *	get_pattern (SMSCConn *conn, Msg *msg, const char *message)
void	bb_alog_init (const Octstr *format)
void	bb_alog_shutdown (void)
void	bb_alog_sms (SMSCConn *conn, Msg *msg, const char *message)

Variables
static Octstr *	custom_log_format = NULL

Function Documentation

bb_alog_init()

void bb_alog_init

(

const Octstr *

format

)

Definition at line 359 of file bb_alog.c.

References custom_log_format, gw_assert(), and octstr_duplicate.

Referenced by init_bearerbox().

{
    gw_assert(format != NULL);

    custom_log_format = octstr_duplicate(format);
}

bb_alog_shutdown()

void bb_alog_shutdown

(

void

)

Definition at line 367 of file bb_alog.c.

References custom_log_format, and octstr_destroy().

Referenced by main().

{
    octstr_destroy(custom_log_format);
    custom_log_format = NULL;
}

bb_alog_sms()

void bb_alog_sms	(	SMSCConn *	conn,
		Msg *	msg,
		const char *	message
	)

Definition at line 374 of file bb_alog.c.

References alog(), custom_log_format, DC_8BIT, DC_UCS2, get_pattern(), gw_assert(), msg, octstr_binary_to_hex(), octstr_convert_printable(), octstr_create, octstr_destroy(), octstr_duplicate, octstr_get_cstr, octstr_imm(), octstr_len(), smscconn_id(), smscconn_name(), and text.

Referenced by bb_smscconn_receive(), bb_smscconn_receive_internal(), bb_smscconn_send_failed(), bb_smscconn_sent(), and handle_pdu().

{
    Octstr *text = NULL;
    
    gw_assert(msg_type(msg) == sms);

    /* if we don't have any custom log, then use our "default" one */
    
    if (custom_log_format == NULL) {
        Octstr *udh;
        const Octstr *cid;

        text = msg->sms.msgdata ? octstr_duplicate(msg->sms.msgdata) : octstr_create("");
        udh = msg->sms.udhdata ? octstr_duplicate(msg->sms.udhdata) : octstr_create("");

        if (conn && smscconn_id(conn))
            cid = smscconn_id(conn);
        else if (conn && smscconn_name(conn))
            cid = smscconn_name(conn);
        else if (msg->sms.smsc_id)
            cid = msg->sms.smsc_id;
        else
            cid = octstr_imm("");

        if ((msg->sms.coding == DC_8BIT || msg->sms.coding == DC_UCS2))
            octstr_binary_to_hex(text, 1);
        else
            octstr_convert_printable(text);
        octstr_binary_to_hex(udh, 1);

        alog("%s [SMSC:%s] [SVC:%s] [ACT:%s] [BINF:%s] [FID:%s] [META:%s] [from:%s] [to:%s] [flags:%ld:%ld:%ld:%ld:%ld] "
             "[msg:%ld:%s] [udh:%ld:%s]",
             message,
             octstr_get_cstr(cid),
             msg->sms.service ? octstr_get_cstr(msg->sms.service) : "",
             msg->sms.account ? octstr_get_cstr(msg->sms.account) : "",
             msg->sms.binfo ? octstr_get_cstr(msg->sms.binfo) : "",
             msg->sms.foreign_id ? octstr_get_cstr(msg->sms.foreign_id) : "",
             msg->sms.meta_data ? octstr_get_cstr(msg->sms.meta_data) : "",
             msg->sms.sender ? octstr_get_cstr(msg->sms.sender) : "",
             msg->sms.receiver ? octstr_get_cstr(msg->sms.receiver) : "",
             msg->sms.mclass, msg->sms.coding, msg->sms.mwi, msg->sms.compress,
             msg->sms.dlr_mask, 
             octstr_len(msg->sms.msgdata), octstr_get_cstr(text),
             octstr_len(msg->sms.udhdata), octstr_get_cstr(udh)
        );

        octstr_destroy(udh);
    } else {
        text = get_pattern(conn, msg, message);
        alog("%s", octstr_get_cstr(text));
    }

    octstr_destroy(text);
}

get_pattern()

static Octstr* get_pattern ( SMSCConn *  conn, Msg *  msg, const char *  message  )

static

Definition at line 117 of file bb_alog.c.

References custom_log_format, DC_8BIT, DC_UCS2, gw_assert(), gw_gmtime(), gwlist_create, gwlist_destroy(), gwlist_get(), gwlist_len(), msg, MSG_PARAM_UNDEFINED, octstr_append(), octstr_append_char(), octstr_append_cstr(), octstr_append_data(), octstr_append_decimal(), octstr_binary_to_hex(), octstr_convert_printable(), octstr_create, octstr_destroy(), octstr_destroy_item(), octstr_duplicate, octstr_format_append(), octstr_get_char(), octstr_get_cstr, octstr_len(), octstr_split_words(), report_mo, smscconn_id(), smscconn_name(), text, uuid_is_null(), UUID_STR_LEN, uuid_unparse(), and warning().

Referenced by bb_alog_sms().

{
    int nextarg, j;
    struct tm tm;
    int num_words;
    List *word_list;
    Octstr *result;
    const char *pattern;
    Octstr *temp, *text, *udh;
    size_t n;
    long i;
 
    text = msg->sms.msgdata ? octstr_duplicate(msg->sms.msgdata) : octstr_create("");
    udh = msg->sms.udhdata ? octstr_duplicate(msg->sms.udhdata) : octstr_create("");
    if ((msg->sms.coding == DC_8BIT || msg->sms.coding == DC_UCS2))
        octstr_binary_to_hex(text, 1);
    else
        octstr_convert_printable(text);
    octstr_binary_to_hex(udh, 1);

    if (octstr_len(text)) {
        word_list = octstr_split_words(text);
        num_words = gwlist_len(word_list);
    } else {
        word_list = gwlist_create();
        num_words = 0;
    }

    result = octstr_create("");
    pattern = octstr_get_cstr(custom_log_format);

    nextarg = 1;

    while (*pattern != '\0') {
        n = strcspn(pattern, "%");
        octstr_append_data(result, pattern, n);
        pattern += n;
        gw_assert(*pattern == '%' || *pattern == '\0');
        if (*pattern == '\0')
            break;

        pattern++;
        
        switch (*pattern) {
            case 'k':
                if (num_words <= 0)
                    break;
                octstr_append(result, gwlist_get(word_list, 0));
                break;

            case 's':
                if (nextarg >= num_words)
                    break;
                octstr_append(result, gwlist_get(word_list, nextarg));
                ++nextarg;
                break;

            case 'S':
                if (nextarg >= num_words)
                    break;
                temp = gwlist_get(word_list, nextarg);
                for (i = 0; i < octstr_len(temp); ++i) {
                    if (octstr_get_char(temp, i) == '*')
                        octstr_append_char(result, '~');
                    else
                        octstr_append_char(result, octstr_get_char(temp, i));
                }
                ++nextarg;
                break;

            case 'r':
                for (j = nextarg; j < num_words; ++j) {
                    if (j != nextarg)
                        octstr_append_char(result, '+');
                    octstr_append(result, gwlist_get(word_list, j));
                }
                break;
    
            case 'l':
                if (message)
                    octstr_append_cstr(result, message);
                break;

            case 'P':
                if (msg->sms.receiver)
                    octstr_append(result, msg->sms.receiver);
                break;

            case 'p':
                if (msg->sms.sender)
                    octstr_append(result, msg->sms.sender);
                break;

            case 'a':
                for (j = 0; j < num_words; ++j) {
                    if (j > 0)
                        octstr_append_char(result, ' ');
                    octstr_append(result, gwlist_get(word_list, j));
                }
                break;

            case 'b':
                if (text)
                    octstr_append(result, text);
                break;

            case 'L':
                octstr_append_decimal(result, octstr_len(msg->sms.msgdata));
                break;

            case 't':
                tm = gw_gmtime(msg->sms.time);
                octstr_format_append(result, "%04d-%02d-%02d %02d:%02d:%02d",
                        tm.tm_year + 1900,
                        tm.tm_mon + 1,
                        tm.tm_mday,
                        tm.tm_hour,
                        tm.tm_min,
                        tm.tm_sec);
                break;

            case 'T':
                if (msg->sms.time != MSG_PARAM_UNDEFINED)
                    octstr_format_append(result, "%ld", msg->sms.time);
                break;

            case 'i':
                if (conn && smscconn_id(conn))
                    octstr_append(result, smscconn_id(conn));
                else if (conn && smscconn_name(conn))
                    octstr_append(result, smscconn_name(conn));
                else if (msg->sms.smsc_id)
                    octstr_append(result, msg->sms.smsc_id);
                break;

            case 'I':
                if (!uuid_is_null(msg->sms.id)) {
                    char id[UUID_STR_LEN + 1];
                    uuid_unparse(msg->sms.id, id);
                    octstr_append_cstr(result, id);
                }
                break;

            case 'n':
                if (msg->sms.service != NULL)
                    octstr_append(result, msg->sms.service);
                break;

            case 'd':
                octstr_append_decimal(result, msg->sms.dlr_mask);
                break;

            case 'R':
                if (msg->sms.dlr_url != NULL)
                    octstr_append(result, msg->sms.dlr_url);
                break;

            case 'N':
                if (msg->sms.sms_type == report_mo && text != NULL)
                    octstr_append(result, text);
                break;

            case 'D': /* meta_data */
                if (msg->sms.meta_data != NULL)
                    octstr_append(result, msg->sms.meta_data);
                break;

            case 'c':
                octstr_append_decimal(result, msg->sms.coding);
                break;

            case 'm':
                octstr_append_decimal(result, msg->sms.mclass);
                break;

            case 'C':
                octstr_append_decimal(result, msg->sms.compress);
                break;

            case 'M':
                octstr_append_decimal(result, msg->sms.mwi);
                break;

            case 'u':
                if (octstr_len(udh)) {
                    octstr_append(result, udh);
                }
                break;

            case 'U':
                octstr_append_decimal(result, octstr_len(msg->sms.udhdata));
                break;

            case 'B':  /* billing identifier/information */
                if (octstr_len(msg->sms.binfo)) {
                    octstr_append(result, msg->sms.binfo);
                }
                break;

            case 'A':  /* account */
                if (octstr_len(msg->sms.account)) {
                    octstr_append(result, msg->sms.account);
                }
                break;

            case 'F': /* the foreign (smsc-provided) message ID */
                if (msg->sms.foreign_id != NULL)
                    octstr_append(result, msg->sms.foreign_id);
                break;

            case 'x': /* the boxc_id, hence the smsbox-id of the message */
                if (msg->sms.boxc_id != NULL)
                    octstr_append(result, msg->sms.boxc_id);
                break;

                /* XXX add more here if needed */

            case '%':
                octstr_format_append(result, "%%");
                break;

            default:
                warning(0, "Unknown escape code (%%%c) within custom-log-format, skipping!", *pattern);
                octstr_format_append(result, "%%%c", *pattern);
                break;
        } /* switch(...) */
    
        pattern++;
    } /* for ... */

    gwlist_destroy(word_list, octstr_destroy_item);
    octstr_destroy(text);
    octstr_destroy(udh);

    return result;
}

Variable Documentation

custom_log_format

Octstr* custom_log_format = NULL

static

Definition at line 70 of file bb_alog.c.

Referenced by bb_alog_init(), bb_alog_shutdown(), bb_alog_sms(), and get_pattern().