#include "gw-config.h"
#include "gwlib/gwlib.h"
#include "msg.h"
#include "bearerbox.h"
#include "bb_store.h"

Data Structures
struct	status

Functions
int	store_init (Cfg cfg, const Octstr type, const Octstr fname, long dump_freq, void pack_func, void *unpack_func)

static void	status_cb (Msg msg, void d)

Octstr *	store_status (int status_type)

Variables
long(*	store_messages )(void)

int(*	store_save )(Msg *msg)

int(*	store_save_ack )(Msg *msg, ack_status_t status)

int(*	store_load )(void(receive_msg)(Msg ))

int(*	store_dump )(void)

void(*	store_shutdown )(void)

Octstr (	store_msg_pack )(Msg *msg)

Msg (	store_msg_unpack )(Octstr *os)

void(*	store_for_each_message )(void(callback_fn)(Msg msg, void data), void data)

Function Documentation

◆ status_cb()

static void status_cb	(	Msg *	msg,
		void *	d
	)

static

Definition at line 111 of file bb_store.c.

References status::data, status::format, gw_gmtime(), gw_localtime(), mo, msg, mt_push, mt_reply, octstr_format_append(), octstr_get_cstr, octstr_imm(), report_mo, report_mt, status::status, UUID_STR_LEN, and uuid_unparse().

Referenced by store_status().

 {
     struct status *data = d;
     struct tm tm;
     char id[UUID_STR_LEN + 1];
 
     if (msg == NULL)
         return;
 
     /* transform the time value */
 #if LOG_TIMESTAMP_LOCALTIME
     tm = gw_localtime(msg->sms.time);
 #else
     tm = gw_gmtime(msg->sms.time);
 #endif
 
     uuid_unparse(msg->sms.id, id);
 
     octstr_format_append(data->status, data->format,
         id,
         (msg->sms.sms_type == mo ? "MO" :
         msg->sms.sms_type == mt_push ? "MT-PUSH" :
         msg->sms.sms_type == mt_reply ? "MT-REPLY" :
         msg->sms.sms_type == report_mo ? "DLR-MO" :
         msg->sms.sms_type == report_mt ? "DLR-MT" : ""),
         tm.tm_year + 1900, tm.tm_mon + 1, tm.tm_mday,
         tm.tm_hour, tm.tm_min, tm.tm_sec,
         (msg->sms.sender ? octstr_get_cstr(msg->sms.sender) : ""),
         (msg->sms.receiver ? octstr_get_cstr(msg->sms.receiver) : ""),
         (msg->sms.smsc_id ? octstr_get_cstr(msg->sms.smsc_id) : ""),
         (msg->sms.boxc_id ? octstr_get_cstr(msg->sms.boxc_id) : ""),
         msg->sms.mclass, msg->sms.coding, msg->sms.mwi, msg->sms.compress,
         msg->sms.dlr_mask,
         (msg->sms.udhdata ? msg->sms.udhdata : octstr_imm("")),
         (msg->sms.msgdata ? msg->sms.msgdata : octstr_imm("")));
 }

◆ store_init()

int store_init	(	Cfg *	cfg,
		const Octstr *	type,
		const Octstr *	fname,
		long	dump_freq,
		void *	pack_func,
		void *	unpack_func
	)

Definition at line 82 of file bb_store.c.

References cfg, error(), octstr_str_compare(), store_file_init(), store_msg_pack, store_msg_unpack, store_spool_init(), and type.

Referenced by init_bearerbox(), init_smppbox(), and main().

 {
     int ret;
     
     store_msg_pack = pack_func;
     store_msg_unpack = unpack_func;
 
     if (type == NULL || octstr_str_compare(type, "file") == 0) {
         ret = store_file_init(fname, dump_freq);
     } else if (octstr_str_compare(type, "spool") == 0) {
         ret = store_spool_init(fname);
 #ifdef HAVE_REDIS
     } else if (octstr_str_compare(type, "redis") == 0) {
         ret = store_redis_init(cfg);
 #endif
     } else {
         error(0, "Unknown 'store-type' defined.");
         ret = -1;
     }
 
     return ret;
 }

◆ store_status()

Octstr* store_status ( int status_type )

Definition at line 148 of file bb_store.c.

References BBSTATUS_HTML, BBSTATUS_XML, status::data, format(), octstr_append_cstr(), octstr_create, status_cb(), and store_for_each_message.

Referenced by httpd_store_status().

 {
     Octstr *ret = octstr_create("");
     const char *format;
     struct status data;
 
     /* check if we are active */
     if (store_for_each_message == NULL)
         return ret;
 
     /* set the type based header */
     if (status_type == BBSTATUS_HTML) {
         octstr_append_cstr(ret, "<table border=1>\n"
             "<tr><td>SMS ID</td><td>Type</td><td>Time</td><td>Sender</td><td>Receiver</td>"
             "<td>SMSC ID</td><td>BOX ID</td><td>Flags</td>"
             "<td>UDH</td><td>Message</td>"
             "</tr>\n");
 
         format = "<tr><td>%s</td><td>%s</td>"
                 "<td>%04d-%02d-%02d %02d:%02d:%02d</td>"
                 "<td>%s</td><td>%s</td><td>%s</td>"
                 "<td>%s</td><td>%ld:%ld:%ld:%ld:%ld</td><td>%E</td><td>%E</td></tr>\n";
     } else if (status_type == BBSTATUS_XML) {
         format = "\t<message>\n\t<id>%s</id>\n\t<type>%s</type>\n\t"
                 "<time>%04d-%02d-%02d %02d:%02d:%02d</time>\n\t"
                 "<sender>%s</sender>\n\t"
                 "<receiver>%s</receiver>\n\t<smsc-id>%s</smsc-id>\n\t"
                 "<box-id>%s</box-id>\n\t"
                 "<flags>%ld:%ld:%ld:%ld:%ld</flags>\n\t"
                 "<udh-data>%E</udh-data>\n\t<msg-data>%E</msg-data>\n\t"
                 "</message>\n";
     } else {
         octstr_append_cstr(ret, "[SMS ID] [Type] [Time] [Sender] [Receiver] [SMSC ID] [BOX ID] [Flags] [UDH] [Message]\n");
         format = "[%s] [%s] [%04d-%02d-%02d %02d:%02d:%02d] [%s] [%s] [%s] [%s] [%ld:%ld:%ld:%ld:%ld] [%E] [%E]\n";
     }
 
     data.format = format;
     data.status = ret;
 
     store_for_each_message(status_cb, &data);
 
     /* set the type based footer */
     if (status_type == BBSTATUS_HTML) {
         octstr_append_cstr(ret,"</table>");
     }
 
     return ret;
 }