smsc_soap.c File Reference

#include <sys/types.h>
#include <sys/socket.h>
#include <unistd.h>
#include <errno.h>
#include <time.h>
#include <limits.h>
#include "gwlib/gwlib.h"
#include "gwlib/http.h"
#include "smscconn.h"
#include "smscconn_p.h"
#include "bb_smscconn_cb.h"
#include "msg.h"
#include "sms.h"
#include "dlr.h"
#include <libxml/xmlmemory.h>
#include <libxml/parser.h>
#include "msg-decl.h"

Go to the source code of this file.

Data Structures
struct	privdata
struct	client_data
struct	argument_map

Macros
#define	SOAP_SLEEP_TIME   0.01
#define	SOAP_MAX_MESSAGE_PER_ROUND   1
#define	SOAP_DEFAULT_SENDER_STRING   "Kannel"
#define	SOAP_DEFAULT_VALIDITY   60
#define	SOAP_MO_URI   "/mo"
#define	SOAP_DLR_URI   "/dlr"
#define	SOAP_DEFAULT_MESSAGE   "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\r\n<Error>No method by that name</Error>"
#define	SOAP_ERROR_NO_DLR_MESSAGE   "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\r\n<Error>Sorry - no DLR for that MT</Error>"
#define	SOAP_ERROR_DLR_MESSAGE   "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\r\n<Error>Fatal error while trying to parse delivery report</Error>"
#define	SOAP_ERROR_MO_MESSAGE   "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\r\n<Error>Fatal error while trying to parse incoming MO</Error>"
#define	SOAP_ERROR_NO_DATA_MESSAGE   "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\r\n<Error>No data received</Error>"
#define	SOAP_ERROR_MALFORMED_DATA_MESSAGE   "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\r\n<Error>Malformed data received</Error>"
#define	SOAP_ERROR_NO_DLR_CODE   HTTP_BAD_METHOD
#define	SOAP_DEFAULT_CODE   HTTP_NOT_FOUND
#define	SOAP_ERROR_DLR_CODE   HTTP_INTERNAL_SERVER_ERROR
#define	SOAP_ERROR_MO_CODE   HTTP_INTERNAL_SERVER_ERROR
#define	SOAP_ERROR_NO_DATA_CODE   HTTP_NOT_IMPLEMENTED
#define	SOAP_ERROR_MALFORMED_DATA_CODE   HTTP_BAD_GATEWAY
#define	SOAP_QUERY_OK   HTTP_OK
#define	MIN_SOAP_CLIENTS   5
#define	MAX_SOAP_CLIENTS   50
#define	CLIENT_BUSY_TIME   5
#define	CLIENT_TEARDOWN_TIME   600
#define	CLIENT_BUSY_LOAD   5
#define	SPEC_DEFAULT   "default"
#define	O_DESTROY(a)   { if(a) octstr_destroy(a); a=NULL; }
#define	INTEGER(fieldname)
#define	INT64(fieldname)
#define	OCTSTR(fieldname)
#define	UUID(fieldname)
#define	VOID(fieldname)
#define	MSG(type, stmt)   case type: { struct type *p = &msg->type; stmt } break;

Typedefs
typedef struct privdata	PrivData
typedef struct client_data	ClientData
typedef struct argument_map	ArgumentMap

Functions
int	smsc_soap_create (SMSCConn *conn, CfgGroup *cfg)
static int	soap_add_msg_cb (SMSCConn *conn, Msg *sms)
static int	soap_shutdown_cb (SMSCConn *conn, int finish_sending)
static void	soap_start_cb (SMSCConn *conn)
static void	soap_stop_cb (SMSCConn *conn)
static long	soap_queued_cb (SMSCConn *conn)
static void	soap_listener (void *arg)
static void	soap_server (void *arg)
static void	soap_send_loop (SMSCConn *conn)
static void	soap_send (PrivData *privdata, Octstr *xmlbuffer, Msg *msgid)
static void	soap_read_response (SMSCConn *conn)
static Octstr *	soap_format_xml (Octstr *xml_file, Msg *msg, PrivData *privdata)
static long long	soap_parse_response (PrivData *privdata, Octstr *xmlResponse)
static long	soap_parse_mo (SMSCConn *conn, Octstr *request, Octstr **response)
static long	soap_parse_dlr (SMSCConn *conn, Octstr *request, Octstr **response)
int	soap_xmlnode_get_long (xmlNodePtr cur, long *out)
int	soap_xmlnode_get_int64 (xmlNodePtr cur, long long *out)
int	soap_xmlnode_get_octstr (xmlNodePtr cur, Octstr **out)
time_t	soap_read_date (Octstr *dateString)
static Octstr *	soap_write_date (time_t date)
int	soap_server_start (SMSCConn *conn)
static void	soap_server_stop (PrivData *privdata)
static ClientData *	soap_create_client_data ()
static void	soap_destroy_client_data (void *data)
static void	soap_client_init_query (PrivData *privdata, List *headers, Octstr *data, Msg *msg)
static ClientData *	soap_client_have_response (List *client_list)
static Octstr *	soap_convert_token (Msg *msg, Octstr *name, PrivData *privdata)
List *	soap_create_map (Octstr *spec, long count, char *keywords[], char *types[], void *storage[])
void	soap_destroy_map (void *item)
int	soap_map_xml_data (xmlNodePtr xml, List *maps)
Octstr *	soap_fetch_xml_data (xmlNodePtr xml, Octstr *path)
long	soap_release_dependences (Octstr *deps, List *lstmaps, Msg *msg, PrivData *privdata)
int	soap_process_deps (int key_index, int key_func_ind, Msg *msg, PrivData *privdata)
int	soap_msgtype_deps (int key_func_index, Msg *msg)
int	soap_msgdata_deps (int key_func_index, Msg *msg, PrivData *privdata)
int	soap_lookup_function (Octstr *funcname)
Octstr *	soap_select_function (int index, Msg *msg, PrivData *privdata)
Octstr *	soap_bouyg_content_attribute (Msg *msg)
Octstr *	soap_mobitai_content_attribute (Msg *msg)
Octstr *	soap_o2o_msgdata_attribute (Msg *msg, PrivData *privdata)
Octstr *	soap_msgdata_attribute (Msg *msg, PrivData *privdata)
Octstr *	soap_o2o_validity30_attribute (Msg *msg)
Octstr *	soap_mobitai_validity_date_attribute (Msg *msg)
Octstr *	soap_bouyg_validity_attribute (Msg *msg)
Octstr *	soap_o2o_date_attribute (Msg *msg)
Octstr *	soap_mobitai_date_attribute (Msg *msg)
Octstr *	soap_rand_attribute (Msg *msg)
Octstr *	soap_o2o_dlrmask_smsc_yn_attribute (Msg *msg)
Octstr *	soap_o2o_dlrmask_success_01_attribute (Msg *msg)
int	soap_get_index (List *where, Octstr *key, int map_index)

Macro Definition Documentation

CLIENT_BUSY_LOAD

#define CLIENT_BUSY_LOAD   5

Definition at line 168 of file smsc_soap.c.

Referenced by soap_client_init_query().

CLIENT_BUSY_TIME

#define CLIENT_BUSY_TIME   5

Definition at line 166 of file smsc_soap.c.

Referenced by soap_client_init_query().

CLIENT_TEARDOWN_TIME

#define CLIENT_TEARDOWN_TIME   600

Definition at line 167 of file smsc_soap.c.

INT64

#define INT64

(

fieldname

)

Value:

if (!octstr_str_compare(name, #fieldname)) { \
                sprintf(buf,"%lld", p->fieldname); \
                return octstr_create(buf); \
        }

INTEGER

#define INTEGER

(

fieldname

)

Value:

if (!octstr_str_compare(name, #fieldname)) { \
                sprintf(buf,"%ld", p->fieldname); \
                return octstr_create(buf); \
        }

MAX_SOAP_CLIENTS

#define MAX_SOAP_CLIENTS   50

Definition at line 165 of file smsc_soap.c.

Referenced by soap_client_init_query().

MIN_SOAP_CLIENTS

#define MIN_SOAP_CLIENTS   5

Definition at line 164 of file smsc_soap.c.

MSG

#define MSG	(		type,
			stmt
	)		case type: { struct type *p = &msg->type; stmt } break;

O_DESTROY

#define O_DESTROY

(

a

)

{ if(a) octstr_destroy(a); a=NULL; }

Definition at line 225 of file smsc_soap.c.

Referenced by smsc_soap_create(), soap_listener(), soap_msgdata_attribute(), soap_o2o_msgdata_attribute(), soap_read_response(), soap_release_dependences(), soap_send(), soap_send_loop(), and soap_server().

OCTSTR

#define OCTSTR

(

fieldname

)

Value:

if (!octstr_str_compare(name, #fieldname)) \
                return octstr_duplicate(p->fieldname);

SOAP_DEFAULT_CODE

#define SOAP_DEFAULT_CODE   HTTP_NOT_FOUND

Definition at line 154 of file smsc_soap.c.

Referenced by soap_server().

SOAP_DEFAULT_MESSAGE

#define SOAP_DEFAULT_MESSAGE   "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\r\n<Error>No method by that name</Error>"

Definition at line 145 of file smsc_soap.c.

Referenced by soap_server().

SOAP_DEFAULT_SENDER_STRING

#define SOAP_DEFAULT_SENDER_STRING   "Kannel"

Definition at line 137 of file smsc_soap.c.

Referenced by soap_parse_mo().

SOAP_DEFAULT_VALIDITY

#define SOAP_DEFAULT_VALIDITY   60

Definition at line 138 of file smsc_soap.c.

Referenced by soap_o2o_validity30_attribute().

SOAP_DLR_URI

#define SOAP_DLR_URI   "/dlr"

Definition at line 142 of file smsc_soap.c.

Referenced by soap_server().

SOAP_ERROR_DLR_CODE

#define SOAP_ERROR_DLR_CODE   HTTP_INTERNAL_SERVER_ERROR

Definition at line 155 of file smsc_soap.c.

Referenced by soap_server().

SOAP_ERROR_DLR_MESSAGE

#define SOAP_ERROR_DLR_MESSAGE   "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\r\n<Error>Fatal error while trying to parse delivery report</Error>"

Definition at line 147 of file smsc_soap.c.

Referenced by soap_server().

SOAP_ERROR_MALFORMED_DATA_CODE

#define SOAP_ERROR_MALFORMED_DATA_CODE   HTTP_BAD_GATEWAY

Definition at line 158 of file smsc_soap.c.

Referenced by soap_parse_dlr(), and soap_parse_mo().

SOAP_ERROR_MALFORMED_DATA_MESSAGE

#define SOAP_ERROR_MALFORMED_DATA_MESSAGE   "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\r\n<Error>Malformed data received</Error>"

Definition at line 150 of file smsc_soap.c.

Referenced by soap_parse_dlr(), and soap_parse_mo().

SOAP_ERROR_MO_CODE

#define SOAP_ERROR_MO_CODE   HTTP_INTERNAL_SERVER_ERROR

Definition at line 156 of file smsc_soap.c.

Referenced by soap_server().

SOAP_ERROR_MO_MESSAGE

#define SOAP_ERROR_MO_MESSAGE   "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\r\n<Error>Fatal error while trying to parse incoming MO</Error>"

Definition at line 148 of file smsc_soap.c.

Referenced by soap_server().

SOAP_ERROR_NO_DATA_CODE

#define SOAP_ERROR_NO_DATA_CODE   HTTP_NOT_IMPLEMENTED

Definition at line 157 of file smsc_soap.c.

Referenced by soap_parse_dlr(), and soap_parse_mo().

SOAP_ERROR_NO_DATA_MESSAGE

#define SOAP_ERROR_NO_DATA_MESSAGE   "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\r\n<Error>No data received</Error>"

Definition at line 149 of file smsc_soap.c.

Referenced by soap_parse_dlr(), and soap_parse_mo().

SOAP_ERROR_NO_DLR_CODE

#define SOAP_ERROR_NO_DLR_CODE   HTTP_BAD_METHOD

Definition at line 153 of file smsc_soap.c.

Referenced by soap_parse_dlr().

SOAP_ERROR_NO_DLR_MESSAGE

#define SOAP_ERROR_NO_DLR_MESSAGE   "<?xml version=\"1.0\" encoding=\"UTF-8\"?>\r\n<Error>Sorry - no DLR for that MT</Error>"

Definition at line 146 of file smsc_soap.c.

Referenced by soap_parse_dlr().

SOAP_MAX_MESSAGE_PER_ROUND

#define SOAP_MAX_MESSAGE_PER_ROUND   1

Definition at line 136 of file smsc_soap.c.

Referenced by soap_send_loop().

SOAP_MO_URI

#define SOAP_MO_URI   "/mo"

Definition at line 141 of file smsc_soap.c.

Referenced by soap_server().

SOAP_QUERY_OK

#define SOAP_QUERY_OK   HTTP_OK

Definition at line 159 of file smsc_soap.c.

Referenced by soap_parse_dlr(), and soap_parse_mo().

SOAP_SLEEP_TIME

#define SOAP_SLEEP_TIME   0.01

Definition at line 135 of file smsc_soap.c.

Referenced by soap_listener(), and soap_server().

SPEC_DEFAULT

#define SPEC_DEFAULT   "default"

Definition at line 170 of file smsc_soap.c.

Referenced by soap_release_dependences().

UUID

#define UUID

(

fieldname

)

VOID

#define VOID

(

fieldname

)

Typedef Documentation

ArgumentMap

typedef struct argument_map ArgumentMap

ClientData

typedef struct client_data ClientData

PrivData

typedef struct privdata PrivData

Function Documentation

smsc_soap_create()

int smsc_soap_create	(	SMSCConn *	conn,
		CfgGroup *	cfg
	)

Definition at line 354 of file smsc_soap.c.

References privdata::allow_ip, privdata::alt_charset, cfg, cfg_get, cfg_get_bool(), cfg_get_integer(), smscconn::connect_time, smscconn::data, debug(), privdata::deny_ip, privdata::dlr_spec_file, privdata::dlr_xml_file, error(), privdata::form_urlencoded, privdata::form_variable, gwlist_create, gwlist_destroy(), gwlist_extract_first(), gwlist_len(), gwthread_create, smscconn::id, info(), smscconn::is_stopped, privdata::listener_thread, privdata::mo_deps_file, privdata::mo_spec_file, privdata::mo_xml_file, privdata::mt_spec_file, privdata::mt_xml_file, privdata::name, smscconn::name, O_DESTROY, octstr_create, octstr_destroy(), octstr_destroy_item(), octstr_duplicate, octstr_format(), octstr_get_cstr, octstr_imm(), octstr_read_file(), octstr_split(), privdata::outgoing_queue, privdata::port, smscconn::queued, smscconn::send_msg, privdata::server_thread, privdata::shutdown, smscconn::shutdown, SMSCCONN_CONNECTING, SMSCCONN_DEAD, SMSCCONN_DISCONNECTED, SMSCCONN_KILLED_CANNOT_CONNECT, soap_add_msg_cb(), privdata::soap_client, soap_listener(), soap_queued_cb(), privdata::soap_server, soap_shutdown_cb(), soap_start_cb(), soap_stop_cb(), privdata::ssl, smscconn::start_conn, smscconn::status, smscconn::stop_conn, privdata::uri, and smscconn::why_killed.

{
    PrivData *privdata;
    Octstr* temp = NULL;
    List* filenames = NULL;

    /* allocate and init internat data structure */
    privdata = gw_malloc(sizeof(PrivData));
    privdata->outgoing_queue = gwlist_create();
    /* privdata->pending_ack_queue = gwlist_create(); */

    privdata->shutdown = 0;
    privdata->soap_client = NULL;
    privdata->soap_server = 0;

    /* read configuration data */
    if (cfg_get_integer(&(privdata->port), cfg, octstr_imm("receive-port-ssl")) == -1)
        if (cfg_get_integer(&(privdata->port), cfg, octstr_imm("receive-port")) == -1)
            privdata->port = 0;
        else
            privdata->ssl = 0;
    else

        privdata->ssl = 1;

    privdata->uri = cfg_get(cfg, octstr_imm("send-url"));

    privdata->allow_ip = cfg_get(cfg, octstr_imm("connect-allow-ip"));
    if (privdata->allow_ip)
        privdata->deny_ip = octstr_create("*.*.*.*");
    else
        privdata->deny_ip = NULL;

    /* read XML configuration */
    privdata->form_variable = cfg_get(cfg, octstr_imm("form-variable"));
    cfg_get_bool(&(privdata->form_urlencoded), cfg, octstr_imm("form-urlencoded"));

    privdata->alt_charset = cfg_get(cfg, octstr_imm("alt-charset"));
    if (!privdata->alt_charset)
        privdata->alt_charset = octstr_create("utf-8");

    /* check validity of stuff */
    if (privdata->port <= 0 || privdata->port > 65535) {
        error(0, "invalid port definition for SOAP server (%ld) - aborting", 
              privdata->port);
        goto error;
    }

    if (!privdata->uri) {
        error(0, "invalid or missing send-url definition for SOAP - aborting.");
        goto error;
    }

    if (!privdata->form_variable) {
        error(0, "invalid or missing form variable name definition for SOAP - aborting.");
        goto error;
    }

    /* load XML templates and specs */
    filenames = octstr_split(temp = cfg_get(cfg,octstr_imm("xml-files")), 
                             octstr_imm(";"));
    octstr_destroy(temp);
    if (gwlist_len(filenames) < 3) {
        error(0,"SOAP: Not enough template files for XML generation, you need 3 - aborting"); 
        goto error;
    }
    if ( !(privdata->mt_xml_file = octstr_read_file(
            octstr_get_cstr(temp = gwlist_extract_first(filenames))))) {
        error(0,"SOAP: Can't load XML template for MT - aborting"); 
        goto error;

    }
    octstr_destroy(temp);
    if ( !(privdata->mo_xml_file = octstr_read_file(
            octstr_get_cstr(temp = gwlist_extract_first(filenames))))) {
        error(0,"SOAP: Can't load XML template for MO - aborting"); 
        goto error;
    }
    octstr_destroy(temp);
    if ( !(privdata->dlr_xml_file = octstr_read_file(
            octstr_get_cstr(temp = gwlist_extract_first(filenames))))) {

        error(0,"SOAP: Can't load XML template for DLR - aborting"); 
        goto error;
    }
    octstr_destroy(temp);
    gwlist_destroy(filenames, octstr_destroy_item);

    filenames = octstr_split(temp = cfg_get(cfg,octstr_imm("xmlspec-files")), 
                             octstr_imm(";"));
    octstr_destroy(temp);
    if (gwlist_len(filenames) < 4) {
        error(0,"Not enough spec files for XML parsing, you need 4 - aborting"); 
        goto error;
    }
    if ( !(privdata->mt_spec_file = octstr_read_file(
            octstr_get_cstr(temp = gwlist_extract_first(filenames))))) {
        error(0,"Can't load spec for MT parsing - aborting"); 
        goto error;
    }
    octstr_destroy(temp);
    if ( !(privdata->mo_spec_file = octstr_read_file(
            octstr_get_cstr(temp = gwlist_extract_first(filenames))))) {
        error(0,"SOAP: Can't load spec for MO parsing - aborting"); 
        goto error;
    }
    octstr_destroy(temp);
    if ( !(privdata->dlr_spec_file = octstr_read_file(
            octstr_get_cstr(temp = gwlist_extract_first(filenames))))) {
        error(0,"SOAP: Can't load spec for DLR parsing - aborting"); 
        goto error;
    }
    octstr_destroy(temp);

    if ( !(privdata->mo_deps_file = octstr_read_file(
            octstr_get_cstr(temp = gwlist_extract_first(filenames))))) {
        error(0,"SOAP: Can't load 'deps' file for MO processing - aborting"); 
        goto error;
    }
    octstr_destroy(temp);

    gwlist_destroy(filenames, octstr_destroy_item);

    debug("bb.soap.create",0,"Connecting to %s",
          octstr_get_cstr(privdata->uri));

    /* store private data struct in connection data */
    conn->data = privdata;

    /* state my name */
    conn->name = octstr_format("SOAP: %s", octstr_get_cstr(privdata->uri) );
    privdata->name = octstr_duplicate(conn->id);

    /* init status vars */
    conn->status = SMSCCONN_CONNECTING;
    conn->connect_time = time(NULL);

    /* set up call backs for bearerbox */
    conn->shutdown = soap_shutdown_cb;
    conn->queued = soap_queued_cb;
    conn->start_conn = soap_start_cb;
    conn->stop_conn = soap_stop_cb;
    conn->send_msg = soap_add_msg_cb;
  
    privdata->listener_thread = 0;
    privdata->server_thread = 0;
  
    /* check whether we can start right away */
    if (!conn->is_stopped)
        /* yes, we can */
        conn->status = SMSCCONN_CONNECTING;
    else
        conn->status = SMSCCONN_DISCONNECTED;

    /* any which way - start the connection thread */
    if ((privdata->listener_thread = gwthread_create(soap_listener, conn)) == -1) {
        error(0, "SOAP: soap_create, failed to spawn thread - aborting");
        goto error;
    }

    return 0; /* done - ok */

error:
    /* oh oh, problems */
    error(0, "SOAP: Failed to create SOAP smsc connection");

    /* release stuff */
    if (privdata != NULL) {
        gwlist_destroy(privdata->outgoing_queue, NULL);
        /* gwlist_destroy(privdata->pending_ack_queue, NULL); */

        O_DESTROY(privdata->uri);
        O_DESTROY(privdata->allow_ip);
        O_DESTROY(privdata->deny_ip);
        O_DESTROY(privdata->form_variable);
        O_DESTROY(privdata->alt_charset);
        O_DESTROY(privdata->name);
        O_DESTROY(privdata->mo_xml_file);
        O_DESTROY(privdata->dlr_xml_file);
        O_DESTROY(privdata->mt_xml_file);
        O_DESTROY(privdata->mo_spec_file);
        O_DESTROY(privdata->dlr_spec_file);
        O_DESTROY(privdata->mt_spec_file);
        O_DESTROY(privdata->mo_deps_file);
    }
    gw_free(privdata);
    octstr_destroy(temp);
    gwlist_destroy(filenames, octstr_destroy_item);

    /* notify bearerbox */
    conn->why_killed = SMSCCONN_KILLED_CANNOT_CONNECT;
    conn->status = SMSCCONN_DEAD;

    info(0, "exiting");
    return -1; /* I'm dead */
}

soap_add_msg_cb()

static int soap_add_msg_cb ( SMSCConn *  conn, Msg *  sms  )

static

Definition at line 563 of file smsc_soap.c.

References smscconn::data, debug(), gwlist_append(), gwlist_len(), gwthread_wakeup(), privdata::listener_thread, msg_duplicate(), privdata::name, octstr_get_cstr, privdata::outgoing_queue, SMSCCONN_DEAD, and smscconn::status.

Referenced by smsc_soap_create().

{

    PrivData *privdata = conn->data;
    Msg *copy;

    /* I'm dead and cannot take any calls at the moment, please don't leave a message */
    if (conn->status == SMSCCONN_DEAD)
        return -1;

    copy = msg_duplicate(sms); /* copy the message */
    gwlist_append(privdata->outgoing_queue, copy); /* put it in the queue */

    debug("bb.soap.add_msg",0,"SOAP[%s]: got a new MT from %s, list has now %ld MTs", 
          octstr_get_cstr(privdata->name), octstr_get_cstr(sms->sms.sender), 
          gwlist_len(privdata->outgoing_queue));

    gwthread_wakeup(privdata->listener_thread);

    return 0;
}

soap_bouyg_content_attribute()

Octstr * soap_bouyg_content_attribute

(

Msg *

msg

)

Definition at line 2700 of file smsc_soap.c.

References DC_8BIT, msg, and octstr_create.

Referenced by soap_select_function().

{

    if (msg->sms.coding == DC_8BIT)
        return octstr_create("D");
    else
        return octstr_create("A");
}

soap_bouyg_validity_attribute()

Octstr * soap_bouyg_validity_attribute

(

Msg *

msg

)

Definition at line 2851 of file smsc_soap.c.

References msg, and octstr_format().

Referenced by soap_select_function().

{
    return octstr_format("%d", msg->sms.validity - time(NULL));
}

soap_client_have_response()

static ClientData * soap_client_have_response ( List *  client_list )

static

Definition at line 2009 of file smsc_soap.c.

References client_data::caller, gwlist_get(), gwlist_len(), gwlist_lock(), and gwlist_unlock().

Referenced by soap_read_response().

{
    long index;
    ClientData* cd;

    if (!client_list)
        return NULL;

    /* lock the list so nobody removes or adds clients while I'm looping on the list */
    gwlist_lock(client_list);

    for (index = gwlist_len(client_list) - 1; index >= 0; --index) {
        cd = gwlist_get(client_list,index);
        if (gwlist_len(cd->caller)) {

            gwlist_unlock(client_list);
            return gwlist_get(client_list, index);
        }
    }

    gwlist_unlock(client_list);
    return NULL;
}

soap_client_init_query()

static void soap_client_init_query ( PrivData *  privdata, List *  headers, Octstr *  data, Msg *  msg  )

static

Definition at line 1933 of file smsc_soap.c.

References client_data::caller, CLIENT_BUSY_LOAD, CLIENT_BUSY_TIME, debug(), gwlist_append(), gwlist_create, gwlist_delete(), gwlist_extract_first(), gwlist_get(), gwlist_len(), gwlist_lock(), gwlist_unlock(), HTTP_METHOD_POST, http_start_request(), client_data::last_access, MAX_SOAP_CLIENTS, msg, privdata::name, octstr_get_cstr, client_data::requests, privdata::soap_client, soap_create_client_data(), and privdata::uri.

Referenced by soap_send().

{
    ClientData *cur_client = NULL;
    long index;


    /* no list yet, generate one */
    if (!privdata->soap_client)
        privdata->soap_client = gwlist_create();

    /* I'm going to change the list, so lock it */
    gwlist_lock(privdata->soap_client);

    /* find the next live caller */
    for (index = gwlist_len(privdata->soap_client) - 1 ; index >= 0; --index) {
        cur_client = gwlist_get(privdata->soap_client, index);
        if (
            cur_client->last_access + CLIENT_BUSY_TIME < time(NULL)
            &&
            cur_client->requests < CLIENT_BUSY_LOAD
        ) {
            debug("bb.soap.init_query",0,"SOAP[%s]: init_query getting a client",octstr_get_cstr(privdata->name));

            /* client is not busy - get it */
            gwlist_delete(privdata->soap_client, index, 1);
            break;
        }
        cur_client = NULL;
    }

    if (!cur_client) {
        if (gwlist_len(privdata->soap_client) > MAX_SOAP_CLIENTS) {
            debug("bb.soap.init_query",0,"SOAP[%s]: init_query all clients are busy, getting the first client",octstr_get_cstr(privdata->name));
            /* query not dispatched, and we have the max number of callers -
               grab the first caller (least used) from the list */
            cur_client = gwlist_extract_first(privdata->soap_client);
        } else {
            /* query not dispatched, and we don't have enough callers -
               start a new one */
            debug("bb.soap.init_query",0,"SOAP[%s]: init_query creates a new client",octstr_get_cstr(privdata->name));
            cur_client = soap_create_client_data();
        }
    }

    /* dispatch query to selected client */
    http_start_request(cur_client->caller, HTTP_METHOD_POST, privdata->uri, headers, data, 1, msg, NULL);
    cur_client->requests++;
    cur_client->last_access = time(NULL);
    gwlist_append(privdata->soap_client, cur_client);
    gwlist_unlock(privdata->soap_client);
}

soap_convert_token()

static Octstr * soap_convert_token ( Msg *  msg, Octstr *  name, PrivData *  privdata  )

static

Definition at line 2040 of file smsc_soap.c.

References error(), msg, name, octstr_get_cstr, soap_lookup_function(), and soap_select_function().

Referenced by soap_format_xml().

{
    char buf[20];
    int index;

    if ( (index=soap_lookup_function(name)) >= 0 )
        return soap_select_function(index, msg, privdata);


#define INTEGER(fieldname) \
        if (!octstr_str_compare(name, #fieldname)) { \
                sprintf(buf,"%ld", p->fieldname); \
                return octstr_create(buf); \
        }
#define INT64(fieldname) \
        if (!octstr_str_compare(name, #fieldname)) { \
                sprintf(buf,"%lld", p->fieldname); \
                return octstr_create(buf); \
        }
#define OCTSTR(fieldname) \
        if (!octstr_str_compare(name, #fieldname)) \
                return octstr_duplicate(p->fieldname);
#define UUID(fieldname) 
#define VOID(fieldname)

#define MSG(type, stmt) \
        case type: { struct type *p = &msg->type; stmt } break;

    switch (msg->type) {
#include "msg-decl.h"
        default:


            error(0, "SOAP: Internal error: unknown message type %d", msg->type);
            return NULL;
    }

    error(0,"SOAP: soap_convert_token, can't find token named <%s>", octstr_get_cstr(name));
    return NULL;
}

soap_create_client_data()

static ClientData * soap_create_client_data ( )

static

Definition at line 1915 of file smsc_soap.c.

References client_data::caller, http_caller_create(), client_data::last_access, and client_data::requests.

Referenced by soap_client_init_query().

{

    ClientData *cd = gw_malloc(sizeof(ClientData));

    cd->last_access = 0;
    cd->requests = 0;
    cd->caller = http_caller_create();

    return cd;
}

soap_create_map()

List * soap_create_map	(	Octstr *	spec,
		long	count,
		char *	keywords[],
		char *	types[],
		void *	storage[]
	)

Definition at line 2088 of file smsc_soap.c.

References argument_map::attribute, debug(), gwlist_append(), gwlist_create, gwlist_destroy(), gwlist_extract_first(), gwlist_get(), gwlist_len(), keywords, argument_map::name, octstr_create, octstr_destroy(), octstr_destroy_item(), octstr_get_cstr, octstr_imm(), octstr_split(), octstr_split_words(), octstr_str_compare(), argument_map::path, argument_map::sscan_type, and argument_map::store.

Referenced by soap_parse_dlr(), soap_parse_mo(), and soap_parse_response().

{
    List *parse_items, *out;

    out = gwlist_create();

    /* read the list of items from the spec file */
    parse_items = octstr_split(spec, octstr_imm("\n"));

    while (gwlist_len(parse_items)) {
        ArgumentMap* map;
        int index;
        Octstr* temp = gwlist_extract_first(parse_items);
        List* item = octstr_split_words(temp);


        /* make sure we have at least two things in the item : a keyword and a path */
        if (gwlist_len(item) < 2) {
            debug("bb.soap.parse_create_map",0,"SOAP: broken spec file line <%s> in soap_create_map",
                  octstr_get_cstr(temp));
            octstr_destroy(temp);
            gwlist_destroy(item, octstr_destroy_item);
            continue;
        }

        /* check that the keyword matches something in the list of keywords */
        for (index = 0; index < count; ++index) {
            if (!octstr_str_compare(gwlist_get(item,0), keywords[index])) {
                /* allocate the structure */
                map = gw_malloc(sizeof(ArgumentMap));
                map->name = gwlist_extract_first(item);
                map->path = gwlist_extract_first(item);
                map->attribute = gwlist_extract_first(item); /* could be NULL, but that is ok */
                map->sscan_type = octstr_create(types[index]);
                map->store = storage[index];
                gwlist_append(out, map);
                break;
            }
        }

        /* destroy temporary variables; */
        gwlist_destroy(item, octstr_destroy_item);
        octstr_destroy(temp);
    }

    gwlist_destroy(parse_items, octstr_destroy_item);

    return out;
}

soap_destroy_client_data()

static void soap_destroy_client_data ( void *  data )

static

Definition at line 1991 of file smsc_soap.c.

References client_data::caller, http_caller_destroy(), and http_caller_signal_shutdown().

Referenced by soap_listener().

{
    ClientData *cd = (ClientData*) data;

    /* signal the caller to stop and then kill it */
    if (cd->caller) {
        http_caller_signal_shutdown(cd->caller);
        http_caller_destroy(cd->caller);
    }
}

soap_destroy_map()

void soap_destroy_map

(

void *

item

)

Definition at line 2143 of file smsc_soap.c.

References argument_map::attribute, argument_map::name, octstr_destroy(), argument_map::path, and argument_map::sscan_type.

Referenced by soap_parse_dlr(), soap_parse_mo(), and soap_parse_response().

{
    ArgumentMap* map = item;
    octstr_destroy(map->name);
    octstr_destroy(map->path);
    octstr_destroy(map->attribute);
    octstr_destroy(map->sscan_type);
    gw_free(map);
}

soap_fetch_xml_data()

Octstr * soap_fetch_xml_data	(	xmlNodePtr	xml,
		Octstr *	path
	)

Definition at line 2162 of file smsc_soap.c.

References content, debug(), found, gwlist_destroy(), gwlist_get(), gwlist_len(), octstr_copy, octstr_create, octstr_destroy(), octstr_destroy_item(), octstr_get_char(), octstr_get_cstr, octstr_imm(), octstr_len(), octstr_split(), and octstr_str_compare().

{
    Octstr *temp, *xml_path, *attr_name = NULL;
    List* path_elements;
    unsigned char c;
    xmlNodePtr parent, node;
    int index;


    /* sanity check */
    if (!octstr_len(path) || !xml)
        return NULL;


    /* stop here for case (c) */
    if (((c = octstr_get_char(path, 0)) == '"' || c == '\'') &&
            (octstr_get_char(path, octstr_len(path)-1) == c))
        return octstr_copy(path, 1, octstr_len(path) - 2);

    /* split into XML path and attribute name */
    path_elements = octstr_split(path, octstr_imm(","));
    xml_path = gwlist_get(path_elements,0);
    if (gwlist_len(path_elements) > 1) /* case (b), we have an attribute */
        attr_name = gwlist_get(path_elements,1);
    gwlist_destroy(path_elements, NULL);

    /* split path into parts */
    path_elements = octstr_split(xml_path, octstr_imm("/"));

    /* walk the message tree down the path */
    parent = NULL;
    node = xml;
    index = 0;
    while (index < gwlist_len(path_elements)) {
        int found = 0;
        /* get the next path element */
        temp = gwlist_get(path_elements, index);
        do {
            if (!octstr_str_compare(temp,(char *)node->name)) {
                /* found what we're looking for */
                if (!(node->xmlChildrenNode) && index < (gwlist_len(path_elements)-1)) {
                    /* while this is indeed the item we are looking for, it's not the end
                     * of the path, and this item has no children */
                    debug("bb.soap.fetch_xml_data",0,"SOAP: fetch_xml - error parsing XML, "
                          "looking for <%s>, but element <%s> has no children",
                          octstr_get_cstr(xml_path), octstr_get_cstr(temp));
                } else {
                    ++index; /* go down the path */
                    parent = node; /* remember where I came from */
                    node = node->xmlChildrenNode; /* trace into the node */
                    ++found; /* remember that I found it */
                    break; /* escape to the next level */
                }
            }
            /* get the next node on this level - this runs if the current node is not in the path */
        } while ((node = node->next));

        if (!found) {
            /* didn't find anything - back track */
            node = parent;
            parent = node->parent;
            if (--index < 0)
                /* I backtracked too much up the tree, nowhere to go to */
                break; /* out of the main loop with nothing to show for it */

            if (!(node = node->next))

                /* after back tracking, go over to the next sibling of the node I just
                 * finished searching under, or bail out if no more siblings */
                break;
        }
    }

    /* coming here there are two options:
     * 1) we looped over all the tree, but did not succeed in traveling the
     *    requested path - index not pointing past the list of path elements - */
    if (index < gwlist_len(path_elements)) {
        /* didn't find the full path */
        debug("bb.soap.map_xml_data",0,"SOAP: fetch_xml - path <%s> cannot be traveled in input XML",
              octstr_get_cstr(xml_path));
        gwlist_destroy(path_elements, octstr_destroy_item);
        octstr_destroy(xml_path);
        octstr_destroy(attr_name);
        return NULL;
    }


    /* 2) index is pointing past the end of the path and the correct node
     * is stored in parent */
    if (attr_name) { /* The caller wants to get an attribute */
        xmlChar* content;
        content = xmlGetProp(parent, (xmlChar *)octstr_get_cstr(attr_name));
        if (content)
            temp = octstr_create((char *)content);
        else /* dont treat an empty or non-existant attribute as an error right away */
            temp = octstr_create("");
        xmlFree(content);
    } else { /* the caller wants to get the content */
        xmlChar* content;
        content = xmlNodeGetContent(parent);
        if (content)
            temp = octstr_create((char *)content);
        else /* don't treat an empty tag an error right away */
            temp = octstr_create("");
        xmlFree(content);
    }

    gwlist_destroy(path_elements, octstr_destroy_item);
    octstr_destroy(xml_path);
    octstr_destroy(attr_name);

    return temp;
}

soap_format_xml()

static Octstr * soap_format_xml ( Octstr *  xml_file, Msg *  msg, PrivData *  privdata  )

static

Definition at line 1014 of file smsc_soap.c.

References error(), msg, octstr_append(), octstr_append_char(), octstr_copy, octstr_create, octstr_destroy(), octstr_get_char(), octstr_get_cstr, octstr_len(), soap_convert_token(), start, and token.

Referenced by soap_parse_dlr(), soap_parse_mo(), and soap_send_loop().

{
    Octstr *xml;
    long t;
    long start = -1;
    int curly_enclose = 0;

    xml = octstr_create("");

    for (t = 0; t < octstr_len(xml_file); ++t) {
        unsigned char c;
         
        if ((c = octstr_get_char(xml_file,t)) == '%') {
            /* found start of token */
            start = t+1;
            continue;
        }

        if (c == '{' && start == t) { /* the token is enclosed in curlys */
            ++start; /* make sure the token is read from the next char */
            curly_enclose=1;
        }

        if (start < 0)
            octstr_append_char(xml,c);
        else if (
            (curly_enclose && (c == '}')) /* end of token in case of curly enclosure */
            ||
            (!curly_enclose && !((c >= 'a' && c <= 'z') || (c >= 'A' && c <= 'Z') || 
                                 (c >= '0' && c <= '9') || c == '_'))) {
            /* found end of token */
            Octstr *data, *token;
          
            token = octstr_copy(xml_file,start,(t-start));
            if ((data = soap_convert_token(msg, token, privdata))) {
                octstr_append(xml, data);
                octstr_destroy(data);
            } else {
                error(0,"SOAP: format_xml - failed to format token %s using message",
                      octstr_get_cstr(token));
                octstr_destroy(token);
                octstr_destroy(xml);
                return NULL;

            }
            octstr_destroy(token);
            start = -1;
            if (!curly_enclose)
                /* I want to get that char again, to let the normal behaviour 
                 * deal with it - only if it's not the ending curly */
                --t; 
            else
                curly_enclose = 0;
        }
    }

    return xml;
}

soap_get_index()

int soap_get_index	(	List *	where,
		Octstr *	key,
		int	map_index
	)

Definition at line 2889 of file smsc_soap.c.

References error(), gwlist_get(), gwlist_len(), argument_map::name, octstr_compare(), octstr_get_cstr, and octstr_str_compare().

Referenced by soap_release_dependences().

{
    int i, j;
    ArgumentMap* map;

    /* ADD HERE: */
    /* key and key_deps values as defined in mo.deps */
    char* funcs_deps[] = {
                             "msgtype", "msgdata"
                         };

    for (i=0; i < gwlist_len(where); ++i) {
        map = gwlist_get(where, i);
        if (!octstr_compare(map->name, key)) {
            if (map_index==1) /* return index from the list where found name */
                return i;

            for (j=0; j < sizeof(funcs_deps)/sizeof(funcs_deps[0]); ++j) {
                if (!octstr_str_compare(map->name, funcs_deps[j]))
                    return j;
            }
        }
    }
    error(0, "SOAP: soap_get_index, broken 'deps' file, can't find key <%s> ", octstr_get_cstr(key));
    return -1;
}

soap_listener()

static void soap_listener ( void *  arg )

static

Definition at line 718 of file smsc_soap.c.

References privdata::allow_ip, privdata::alt_charset, bb_smscconn_connected(), bb_smscconn_killed(), bb_smscconn_send_failed(), smscconn::data, debug(), privdata::deny_ip, privdata::dlr_spec_file, privdata::dlr_xml_file, error(), smscconn::flow_mutex, privdata::form_variable, gwlist_destroy(), gwlist_extract_first(), gwlist_len(), gwthread_sleep(), privdata::mo_deps_file, privdata::mo_spec_file, privdata::mo_xml_file, msg, privdata::mt_spec_file, privdata::mt_xml_file, mutex_lock, mutex_unlock, privdata::name, O_DESTROY, octstr_get_cstr, privdata::outgoing_queue, privdata::shutdown, SMSCCONN_ACTIVE, SMSCCONN_CONNECTING, SMSCCONN_DEAD, SMSCCONN_DISCONNECTED, SMSCCONN_FAILED_SHUTDOWN, SMSCCONN_RECONNECTING, privdata::soap_client, soap_destroy_client_data(), soap_read_response(), soap_send_loop(), privdata::soap_server, soap_server_start(), soap_server_stop(), SOAP_SLEEP_TIME, smscconn::status, and privdata::uri.

Referenced by smsc_soap_create(), and soap_start_cb().

{
    SMSCConn *conn = arg;
    PrivData *privdata = conn->data;
    Msg *msg = NULL;
    debug("bb.soap.listener",0,"SOAP[%s]: listener entering", 
          octstr_get_cstr(privdata->name));

    while (!privdata->shutdown) {

        /* check connection status */
        switch (conn->status) {
            case SMSCCONN_RECONNECTING:
            case SMSCCONN_CONNECTING:
                if (privdata->soap_server) {
                    soap_server_stop(privdata);
                }

                if (soap_server_start(conn)) {
                    privdata->shutdown = 1;
                    error(0, "SOAP[%s]: failed to start HTTP server!", 
                          octstr_get_cstr(privdata->name));
                    break;
                }

                mutex_lock(conn->flow_mutex);
                conn->status = SMSCCONN_ACTIVE;
                mutex_unlock(conn->flow_mutex);

                bb_smscconn_connected(conn);
                break;

            case SMSCCONN_DISCONNECTED:
                if (privdata->soap_server)
                    soap_server_stop(privdata);
                break;

            case SMSCCONN_ACTIVE:
                if (!privdata->soap_server) {
                    mutex_lock(conn->flow_mutex);
                    conn->status = SMSCCONN_RECONNECTING;
                    mutex_unlock(conn->flow_mutex);
                    break;
                }

                /* run the normal send/receive loop */
                if (gwlist_len(privdata->outgoing_queue) > 0) { /* we have messages to send */
                    soap_send_loop(conn); /* send any messages in queue */
                }
                break;

            case SMSCCONN_DEAD:
                /* this shouldn't happen here - 
                 * I'm the only one allowed to set SMSCCONN_DEAD */

            default:
                break;
        }

        soap_read_response(conn); /* collect HTTP responses */

        /* sleep for a while so I wont busy-loop */
        gwthread_sleep(SOAP_SLEEP_TIME); 
    }

    debug("bb.soap.connection",0,"SOAP[%s]: connection shutting down", 
          octstr_get_cstr(privdata->name));

    soap_server_stop(privdata);

    /* send all queued messages to bearerbox for recycling */
    debug("bb.soap.connection",0,"SOAP[%s]: sending messages back to bearerbox", 
          octstr_get_cstr(privdata->name));

    while ((msg = gwlist_extract_first(privdata->outgoing_queue)) != NULL)
        bb_smscconn_send_failed(conn, msg, SMSCCONN_FAILED_SHUTDOWN, NULL);

    /* lock module public state data */
    mutex_lock(conn->flow_mutex);

    debug("bb.soap.connection",0,"SOAP[%s]: playing dead", 
          octstr_get_cstr(privdata->name));
    conn->status = SMSCCONN_DEAD; /* set state */

    /* destroy lists */
    debug("bb.soap.connection",0,"SOAP[%s]: don't need the queue anymore", 
          octstr_get_cstr(privdata->name));

    gwlist_destroy(privdata->outgoing_queue, NULL);
    /* gwlist_destroy(privdata->pending_ack_queue, NULL); */

    /* clear the soap client collection */
    debug("bb.soap.connection",0,"SOAP[%s]: tell caller to stop", 
          octstr_get_cstr(privdata->name));
    if (privdata->soap_client)
        gwlist_destroy(privdata->soap_client, soap_destroy_client_data);

    /* destroy private data stores */
    debug("bb.soap.connection",0,"SOAP[%s]: done with privdata", 
          octstr_get_cstr(privdata->name));
    O_DESTROY(privdata->uri);
    O_DESTROY(privdata->allow_ip);
    O_DESTROY(privdata->deny_ip);

    O_DESTROY(privdata->form_variable);

    O_DESTROY(privdata->alt_charset);
    O_DESTROY(privdata->name);
    O_DESTROY(privdata->mo_xml_file);

    O_DESTROY(privdata->dlr_xml_file);
    O_DESTROY(privdata->mt_xml_file);
    O_DESTROY(privdata->mo_spec_file);
    O_DESTROY(privdata->dlr_spec_file);
    O_DESTROY(privdata->mt_spec_file);
    O_DESTROY(privdata->mo_deps_file);

    gw_free(privdata);
    conn->data = NULL;

    mutex_unlock(conn->flow_mutex);

    debug("bb.soap.connection", 0, "SOAP: module has completed shutdown.");
    bb_smscconn_killed();
}

soap_lookup_function()

int soap_lookup_function

(

Octstr *

funcname

)

Definition at line 2637 of file smsc_soap.c.

References octstr_str_compare().

Referenced by soap_convert_token().

{
    int i;

    /* ADD HERE: XML functions aliasis */
    char *aliasis[] = {
                          "bouyg_content", "mobitai_content",
                          "o2o_msgdata", "msgdata",
                          "o2o_validity30", "mobitai_validity_date", "bouyg_validity",
                          "o2o_date", "mobitai_date", "rand",
                          "o2o_dlrmask_smsc_yn", "o2o_dlrmask_success_01"
                      };

    for (i=0; i<sizeof(aliasis)/sizeof(aliasis[0]); ++i)
    {
        if (!octstr_str_compare(funcname, aliasis[i]))
            return i;
    }
    return -1;
}

soap_map_xml_data()

int soap_map_xml_data	(	xmlNodePtr	xml,
		List *	maps
	)

Definition at line 2282 of file smsc_soap.c.

References argument_map::attribute, content, debug(), found, gwlist_destroy(), gwlist_get(), gwlist_len(), argument_map::name, octstr_create, octstr_destroy(), octstr_destroy_item(), octstr_get_cstr, octstr_imm(), octstr_split(), octstr_str_compare(), octstr_strip_blanks(), argument_map::path, argument_map::sscan_type, and argument_map::store.

Referenced by soap_parse_dlr(), soap_parse_mo(), and soap_parse_response().

{
    int mapindex = 0, args = 0;
    xmlNodePtr node, parent;

    /* step through the items on the map */
    while (mapindex < gwlist_len(maps)) {

        Octstr* temp;

        int index = 0;
        ArgumentMap* map = gwlist_get(maps,mapindex);
        /* split the path elements */
        List* path_elements = octstr_split(map->path, octstr_imm("/"));

        /* walk the message tree down the path */
        parent = NULL;
        node = xml;
        while (index < gwlist_len(path_elements)) {
            int found = 0;
            /* get the next path element */
            temp = gwlist_get(path_elements, index);
            do {
                if (!octstr_str_compare(temp,(char *)node->name)) {
                    /* found what we're looking for */
                    if (!(node->xmlChildrenNode) && index < (gwlist_len(path_elements)-1)) {
                        /* while this is indeed the item we are looking for, it's not the end
                           of the path, and this item has no children */
                        debug("bb.soap.map_xml_data",0,"SOAP: error parsing XML, looking for <%s>, but element <%s> has no children",
                              octstr_get_cstr(map->path), octstr_get_cstr(temp));
                    } else {
                        ++index; /* go down the path */
                        parent = node; /* remember where I came from */
                        node = node->xmlChildrenNode; /* trace into the node */
                        ++found;
                        break; /* escape to the next level */
                    }
                }
            } while ((node = node->next));

            if (!found) {
                /* didn't find anything - back track */
                node = parent;
                if (parent==NULL) /* first tag not found, quickly go out ! */
                    return 0;

                parent = node->parent;
                if (--index < 0)
                    /* I backtracked too much up the tree, nowhere to go to */
                    break;

                if (!(node = node->next))
                    /* no more childs under the main tree to look under, abort */
                    break;

            }
        }


        if (index < gwlist_len(path_elements)) {
            /* didn't find the full path */
            debug("bb.soap.map_xml_data",0,"SOAP: didn't find element for keyword <%s> in XML data",
                  octstr_get_cstr(map->name));
            gwlist_destroy(path_elements, octstr_destroy_item);
            ++mapindex;
            continue;
        }

        /* found the correct node (it's stored in parent) */
        if (map->attribute) {

            /* The user wants to get an attribute */
            xmlChar* content;
            content = xmlGetProp(parent, (xmlChar *)octstr_get_cstr(map->attribute));
            if (content)
                temp = octstr_create((char *)content);
            else /* dont treat an empty or non-existant attribute as an error right away */
                temp = octstr_create("");
            xmlFree(content);
        } else {
            /* the user wants to get the content */
            xmlChar* content;
            content = xmlNodeGetContent(parent);
            if (content)
                temp = octstr_create((char *)content);
            else /*  don't treat an empty tag an error right away */

                temp = octstr_create("");
            xmlFree(content);
        }

        /* parse the content using sscan_type from the map */
        octstr_strip_blanks(temp);
        if (!octstr_str_compare(map->sscan_type,"%s")) {
            /* special processing of %s - this means the whole string, while sscanf stops at spaces */
            strcpy(map->store,octstr_get_cstr(temp));

            ++args;
        } else {
            if (!sscanf(octstr_get_cstr(temp), octstr_get_cstr(map->sscan_type), map->store)) {
                debug("bb.soap.map_xml_data",0,"SOAP: failed to scan content '%s' for '%s' in xml parsing",
                      octstr_get_cstr(temp), octstr_get_cstr(map->sscan_type));
            } else {
                ++args;
            }
        }


        /* done for this item */
        octstr_destroy(temp);
        gwlist_destroy(path_elements, octstr_destroy_item);
        ++mapindex;
    }
    return args;
}

soap_mobitai_content_attribute()

Octstr * soap_mobitai_content_attribute

(

Msg *

msg

)

Definition at line 2709 of file smsc_soap.c.

References DC_8BIT, msg, and octstr_create.

Referenced by soap_select_function().

{
    if (msg->sms.coding == DC_8BIT)
        return octstr_create("binary");
    else
        return octstr_create("text");

}

soap_mobitai_date_attribute()

Octstr * soap_mobitai_date_attribute

(

Msg *

msg

)

Definition at line 2863 of file smsc_soap.c.

References date_create_iso(), and msg.

Referenced by soap_select_function().

{
    return date_create_iso(msg->sms.time);
}

soap_mobitai_validity_date_attribute()

Octstr * soap_mobitai_validity_date_attribute

(

Msg *

msg

)

Definition at line 2845 of file smsc_soap.c.

References date_create_iso(), and msg.

Referenced by soap_select_function().

{
    return date_create_iso(msg->sms.validity);
}

soap_msgdata_attribute()

Octstr * soap_msgdata_attribute	(	Msg *	msg,
		PrivData *	privdata
	)

Definition at line 2789 of file smsc_soap.c.

References privdata::alt_charset, charset_convert(), DC_7BIT, DC_8BIT, DC_UCS2, DC_UNDEF, debug(), error(), msg, O_DESTROY, octstr_append(), octstr_binary_to_hex(), octstr_convert_to_html_entities(), octstr_dump, octstr_duplicate, and octstr_get_cstr.

Referenced by soap_select_function().

{
    Octstr *data, *udhdata;
    int ret;


    data = octstr_duplicate(msg->sms.msgdata);

    if (msg->sms.coding == DC_8BIT) {
        udhdata = octstr_duplicate(msg->sms.udhdata);
        octstr_append(udhdata, data);
        octstr_binary_to_hex(udhdata, 1);
        O_DESTROY(data);
        return udhdata;
    }
    else if (msg->sms.coding == DC_7BIT || msg->sms.coding == DC_UNDEF) {
        /* convert message data to target encoding */
        debug("bb.soap.msgdata_attribute", 0, "SOAP: converting from UTF-8 to %s", octstr_get_cstr(privdata->alt_charset));
        ret = charset_convert(data, "UTF-8", octstr_get_cstr(privdata->alt_charset));
        if (ret == -1) {
            error(0,"SOAP: soap_msgdata_attribute, charset_convert failed");
            octstr_dump(msg->sms.msgdata, 0);
            O_DESTROY(data);
            return NULL;
        }
        debug("bb.soap.msgdata_attribute",0,"SOAP: converting to HTML entities");
        octstr_convert_to_html_entities(data);
        return data;
    }
    else if (msg->sms.coding == DC_UCS2) {
        /* convert message data to target encoding */
        debug("bb.soap.msgdata_attribute", 0, "converting from USC-2 to %s", octstr_get_cstr(privdata->alt_charset));
        ret = charset_convert(data, "UCS-2BE", octstr_get_cstr(privdata->alt_charset));
        if (ret == -1) {
            error(0,"SOAP: soap_msgdata_attribute, charset_convert failed");

            octstr_dump(data, 0);
            O_DESTROY(data);
            return NULL;
        }
        return data;
    }
    else {
        error(0,"SOAP: soap_msgdata_attribute, unknown coding: %ld", msg->sms.coding);
        O_DESTROY(data);
        return NULL;
    }
}

soap_msgdata_deps()

int soap_msgdata_deps	(	int	key_func_index,
		Msg *	msg,
		PrivData *	privdata
	)

Definition at line 2581 of file smsc_soap.c.

References privdata::alt_charset, charset_convert(), debug(), error(), msg, privdata::name, octstr_base64_to_binary(), octstr_case_compare(), octstr_create, octstr_dump, octstr_get_cstr, octstr_hex_to_binary(), and octstr_imm().

Referenced by soap_process_deps().

{
    int ret = 0;
    /* {"set_iso","64_binary","hex_binary","unicode","default"}  msgdata */

    /* ADD HERE: */
    switch (key_func_index)
    {
        case 0:       /* "set_iso" */
            msg->sms.charset = octstr_create("ISO-8859-1");
            break;
        case 1:      /* "64_binary" */
            octstr_base64_to_binary(msg->sms.msgdata);
            break;
        case 2:          /* "hex_binary" */
            octstr_hex_to_binary(msg->sms.msgdata);
            break;

        case 3:         /* "unicode" */
        case 4:         /* "default" */

            if (!octstr_case_compare(privdata->alt_charset, octstr_imm("UCS-2"))) {
                debug("bb.soap.msgdata_deps",0,"SOAP[%s]: converting from %s to UCS-2BE",
                      octstr_get_cstr(privdata->name), octstr_get_cstr(privdata->alt_charset));
                ret = charset_convert(msg->sms.msgdata, octstr_get_cstr(privdata->alt_charset), "UCS-2BE");

                if (ret == -1) {

                    error(2,"SOAP[%s]: Error converting MO data from %s to unicode",
                          octstr_get_cstr(privdata->name), octstr_get_cstr(privdata->alt_charset));
                }
            }
            else if (ret != 0) {
                debug("bb.soap.parse_mo",1,"SOAP[%s]: charset_convert made %d irreversable transformations",
                      octstr_get_cstr(privdata->name), ret);
            }
            msg->sms.charset = octstr_create("UCS-2");

            debug("bb.soap.parse_mo",0,"SOAP[%s]: message decoded -", octstr_get_cstr(privdata->name));
            octstr_dump(msg->sms.msgdata, 0);
            break;

        default:
            /* out of range */

            error(0, "SOAP: soap_msgdata_deps, unknown index %d", key_func_index);
            return -1;
    }
    return 0;
}

soap_msgtype_deps()

int soap_msgtype_deps	(	int	key_func_index,
		Msg *	msg
	)

Definition at line 2555 of file smsc_soap.c.

References DC_7BIT, DC_8BIT, DC_UCS2, error(), and msg.

Referenced by soap_process_deps().

{
    /* {"text","binary","unicode","default"}    msgtype  */

    /* ADD HERE: see order in funcs[][] */
    switch (key_func_index)
    {
        case 0:                                 /* "text" */
            msg->sms.coding = DC_7BIT;
            break;
        case 1:                                 /* "binary" */
            msg->sms.coding = DC_8BIT;
            break;

        case 2:                                 /* "unicode" */
        case 3:                                 /* "default" == unicode */
            msg->sms.coding = DC_UCS2;
            break;
        default:
            /* out of range */
            error(0, "SOAP: soap_msgtype_deps, unknown index %d", key_func_index);
            return -1;
    }
    return 0;
}

soap_o2o_date_attribute()

Octstr * soap_o2o_date_attribute

(

Msg *

msg

)

Definition at line 2856 of file smsc_soap.c.

References msg, and soap_write_date().

Referenced by soap_select_function().

{
    return soap_write_date(msg->sms.time);
}

soap_o2o_dlrmask_smsc_yn_attribute()

Octstr * soap_o2o_dlrmask_smsc_yn_attribute

(

Msg *

msg

)

Definition at line 2874 of file smsc_soap.c.

References DLR_IS_ENABLED_SMSC, msg, and octstr_create.

Referenced by soap_select_function().

{
    return octstr_create(DLR_IS_ENABLED_SMSC(msg->sms.dlr_mask) ? "Y" : "N");
}

soap_o2o_dlrmask_success_01_attribute()

Octstr * soap_o2o_dlrmask_success_01_attribute

(

Msg *

msg

)

Definition at line 2880 of file smsc_soap.c.

References DLR_IS_SUCCESS, msg, and octstr_create.

Referenced by soap_select_function().

{
    return octstr_create( DLR_IS_SUCCESS(msg->sms.dlr_mask) ? "0" : "1");
}

soap_o2o_msgdata_attribute()

Octstr * soap_o2o_msgdata_attribute	(	Msg *	msg,
		PrivData *	privdata
	)

Definition at line 2718 of file smsc_soap.c.

References privdata::alt_charset, charset_convert(), DC_7BIT, DC_8BIT, DC_UCS2, DC_UNDEF, debug(), error(), msg, O_DESTROY, octstr_append(), octstr_binary_to_base64(), octstr_convert_to_html_entities(), octstr_create, octstr_dump, octstr_duplicate, octstr_format(), octstr_get_cstr, and octstr_len().

Referenced by soap_select_function().

{
    Octstr *data, *res, *udhres;
    int ret;

    data = octstr_duplicate(msg->sms.msgdata);

    if (msg->sms.coding == DC_8BIT) {
        debug("bb.soap.o2o_msgdata_attribute",0,"SOAP: base 64 encoding");
        octstr_binary_to_base64(data);
        res = octstr_format("<Control_Data>%S</Control_Data>", data);

        if (octstr_len(msg->sms.udhdata) > 0) { /* add UDH */
            O_DESTROY(data);
            data = octstr_duplicate(msg->sms.udhdata);
            debug("bb.soap.o2o_msgdata_attribute",0,"SOAP: UDH base 64 encoding");
            octstr_binary_to_base64(data);
            udhres = octstr_format("<UDH>%S</UDH>", data);
            octstr_append(res, udhres);
            O_DESTROY(udhres);
        }
        else {
            error(0, "SOAP: o2o_msgdata_attribute, UDH not defined");
            udhres = octstr_create("<UDH></UDH>");
            octstr_append(res, udhres);
            O_DESTROY(udhres);
        }
        O_DESTROY(data);
        return res;
    }
    else if (msg->sms.coding == DC_7BIT || msg->sms.coding == DC_UNDEF) {
        /* convert message data to target encoding */
        debug("bb.soap.o2o_msgdata_attribute", 0, "SOAP: converting from UTF-8 to %s", octstr_get_cstr(privdata->alt_charset));
        ret = charset_convert(data, "UTF-8", octstr_get_cstr(privdata->alt_charset));
        if (ret == -1) {
            error(0,"SOAP: soap_o2o_msgdata_attribute, charset_convert failed");
            octstr_dump(msg->sms.msgdata, 0);
            O_DESTROY(data);
            return NULL;
        }
        debug("bb.soap.o2o_msgdata_attribute",0,"SOAP: converting to HTML entities");
        octstr_convert_to_html_entities(data);
        res = octstr_format("<Message_Text>%S</Message_Text>", data);
        O_DESTROY(data);
        return res;
    }
    else if (msg->sms.coding == DC_UCS2) {
        /* convert message data to target encoding */
        debug("bb.soap.o2o_msgdata_attribute", 0, "converting from USC-2 to %s", octstr_get_cstr(privdata->alt_charset));
        ret = charset_convert(msg->sms.msgdata, "UCS-2BE", octstr_get_cstr(privdata->alt_charset));
        if (ret == -1) {
            error(0,"SOAP: soap_o2o_msgdata_attribute, charset_convert failed");

            octstr_dump(msg->sms.msgdata, 0);
            O_DESTROY(data);
            return NULL;
        }
        res = octstr_format("<Message_Text>%s</Message_Text>", data);
        O_DESTROY(data);
        return res;
    }

    else {
        error(0,"SOAP: soap_o2o_msgdata_attribute, unknown coding: %ld", msg->sms.coding);
        O_DESTROY(data);
        return NULL;

    }
}

soap_o2o_validity30_attribute()

Octstr * soap_o2o_validity30_attribute

(

Msg *

msg

)

Definition at line 2839 of file smsc_soap.c.

References msg, octstr_format(), SMS_PARAM_UNDEFINED, and SOAP_DEFAULT_VALIDITY.

Referenced by soap_select_function().

{
    return octstr_format("%ld",(msg->sms.validity != SMS_PARAM_UNDEFINED ? (msg->sms.validity - time(NULL))/60 : SOAP_DEFAULT_VALIDITY) / 30);
}

soap_parse_dlr()

static long soap_parse_dlr ( SMSCConn *  conn, Octstr *  request, Octstr **  response  )

static

Definition at line 1512 of file smsc_soap.c.

References bb_smscconn_receive(), smscconn::data, debug(), DLR_BUFFERED, DLR_FAIL, dlr_find(), privdata::dlr_spec_file, DLR_SUCCESS, privdata::dlr_xml_file, error(), gwlist_destroy(), smscconn::id, keywords, privdata::name, octstr_create, octstr_delete(), octstr_destroy(), octstr_get_cstr, octstr_imm(), octstr_search_char(), octstr_url_decode(), response(), soap_create_map(), soap_destroy_map(), SOAP_ERROR_MALFORMED_DATA_CODE, SOAP_ERROR_MALFORMED_DATA_MESSAGE, SOAP_ERROR_NO_DATA_CODE, SOAP_ERROR_NO_DATA_MESSAGE, SOAP_ERROR_NO_DLR_CODE, SOAP_ERROR_NO_DLR_MESSAGE, soap_format_xml(), soap_map_xml_data(), and SOAP_QUERY_OK.

Referenced by soap_server().

{
    PrivData *privdata = conn->data;
    xmlDocPtr requestDoc;
    xmlNodePtr root;
    Msg* dlrmsg = NULL;
    long dlrtype;
    int pos;

    List* maps;
    char receiver[30], soapdate[30], msgid[30];
    long result = -1;
    char* keywords[] = { "receiver", "soapdate", "id", "result" };

    char* sscans[] = { "%s", "%s", "%s", "%ld" };
    void* pointers[] = { &receiver, &soapdate, &msgid, &result };

    receiver[0] = soapdate[0] = msgid[0] = '\0';

    if (!response) /* how am I supposed to return a response now ? */
        return -1;

    if (!request) {
        *response = octstr_create(SOAP_ERROR_NO_DATA_MESSAGE);
        return SOAP_ERROR_NO_DATA_CODE;
    }

    /* find the POST parameter name */
    if ( (pos = octstr_search_char(request,'=',0)) < 0) {
        /* didn't find it - */
        *response = octstr_create(SOAP_ERROR_MALFORMED_DATA_MESSAGE);
        return SOAP_ERROR_MALFORMED_DATA_CODE;
    }

    /* cut of the parameter name - I'm not really interested in it */
    octstr_delete(request,0,pos+1);

    /* decode the URL encoded data */
    if (octstr_url_decode(request) < 0) {
        /* probably not URL encoded */
        *response = octstr_create(SOAP_ERROR_MALFORMED_DATA_MESSAGE);
        return SOAP_ERROR_MALFORMED_DATA_CODE;
    }

    debug("bb.soap.parse_dlr",0,"SOAP[%s]: parse_dlr  - DLR request dump <%s>", octstr_get_cstr(privdata->name),octstr_get_cstr(request));

    /* parse XML */

    if ( !(requestDoc = xmlParseDoc((xmlChar *)octstr_get_cstr(request))) ) {
        error(0,"SOAP[%s]: parse_dlr couldn't parse XML response", octstr_get_cstr(privdata->name));
        return -1;
    }

    /* get root element */
    if ( ! (root = xmlDocGetRootElement(requestDoc)) ) {

        error(0,"SOAP[%s]: parse_dlr couldn't get XML root element for request", octstr_get_cstr(privdata->name));
        xmlFreeDoc(requestDoc);
        return -1;
    }

    /* create the argument map */

    maps = soap_create_map(privdata->dlr_spec_file, 4, keywords, sscans, pointers);

    /* run the map and the xml through the parser */
    if (soap_map_xml_data(root, maps) < 4) {
        error(0,"SOAP[%s]: parse_dlr failed to map all the arguments from the XML data",

              octstr_get_cstr(privdata->name));
    }

    gwlist_destroy(maps, soap_destroy_map);

    /* done with the document */
    xmlFreeDoc(requestDoc);

    if (strlen(msgid) == 0) {
        error(0,"SOAP: parse_dlr - failed to get message ID");
        *response = octstr_create(SOAP_ERROR_MALFORMED_DATA_MESSAGE);
        return SOAP_ERROR_MALFORMED_DATA_CODE;
    }

    if (result == -1) {

        error(0,"SOAP: parse_dlr - failed to get delivery code");
        *response = octstr_create(SOAP_ERROR_MALFORMED_DATA_MESSAGE);
        return SOAP_ERROR_MALFORMED_DATA_CODE;
    }

    /* we not need it because receiver now is constant string "receiver"
      if (strlen(receiver) == 0) {
            error(0,"SOAP: parse_dlr - failed to get receiver");
        *response = octstr_create(SOAP_ERROR_MALFORMED_DATA_MESSAGE);
        return SOAP_ERROR_MALFORMED_DATA_CODE;
        }
    */
    /* log the delivery code - this could be used to determine dlrtype (or so I hope) */
    debug("bb.soap.parse_dlr",0,"SOAP[%s]: parse_dlr DELIVERY_CODE : %ld", octstr_get_cstr(privdata->name),result);
    if (result == 0)
        dlrtype = DLR_SUCCESS;
    else
        dlrtype = DLR_FAIL;

    /* fetch the DLR */

    dlrmsg = dlr_find(conn->id, octstr_imm(msgid), octstr_imm("receiver"), /* destination */
                      dlrtype, 0);

    if (!dlrmsg) {
        error(0,"SOAP[%s]: parse_dlr invoked (%ld), but no DLR found for MsgID %s", octstr_get_cstr(privdata->name),dlrtype,msgid);
        *response = octstr_create(SOAP_ERROR_NO_DLR_MESSAGE);
        return SOAP_ERROR_NO_DLR_CODE;
    }

    debug("bb.soap.parse_dlr",0,"SOAP[%s]: parse_dlr found dlr", octstr_get_cstr(privdata->name));
    octstr_destroy(dlrmsg->sms.msgdata);
    switch (dlrtype) { /* change message according to DLR type */
        case DLR_SUCCESS:
            dlrmsg->sms.msgdata = octstr_create("Delivered");
            break;
        case DLR_BUFFERED:
            dlrmsg->sms.msgdata = octstr_create("Buffered");
            break;
        case DLR_FAIL:
            dlrmsg->sms.msgdata = octstr_create("Failed");
            break;
        default:
            break;

    }

    /*
    if (dlrmsg->sms.receiver) {
        octstr_destroy(dlrmsg->sms.sender);
        dlrmsg->sms.sender = dlrmsg->sms.receiver;
    }
    dlrmsg->sms.receiver = octstr_create(receiver);
    dlrmsg->sms.id = strtol(msgid, NULL, 10);
    */

    debug("bb.soap.parse_dlr",0,"SOAP[%s]: parse_dlr sent dlr <%s>", octstr_get_cstr(privdata->name),octstr_get_cstr(dlrmsg->sms.msgdata));


    *response = soap_format_xml(privdata->dlr_xml_file, dlrmsg, privdata);
    if (*response)
        debug("bb.soap.response_dlr",0,"SOAP[%s]: data dump: %s", octstr_get_cstr(privdata->name), octstr_get_cstr(*response));

    /* send to bearerbox */
    bb_smscconn_receive(conn, dlrmsg);

    return SOAP_QUERY_OK;

}

soap_parse_mo()

static long soap_parse_mo ( SMSCConn *  conn, Octstr *  request, Octstr **  response  )

static

Definition at line 1275 of file smsc_soap.c.

References bb_smscconn_receive(), smscconn::data, date(), date_convert_universal(), date_parse_iso(), debug(), error(), gwlist_destroy(), gwlist_len(), smscconn::id, keywords, privdata::mo_deps_file, privdata::mo_spec_file, privdata::mo_xml_file, msg, msg_create, privdata::name, octstr_create, octstr_delete(), octstr_destroy(), octstr_duplicate, octstr_get_cstr, octstr_search_char(), octstr_url_decode(), response(), soap_create_map(), SOAP_DEFAULT_SENDER_STRING, soap_destroy_map(), SOAP_ERROR_MALFORMED_DATA_CODE, SOAP_ERROR_MALFORMED_DATA_MESSAGE, SOAP_ERROR_NO_DATA_CODE, SOAP_ERROR_NO_DATA_MESSAGE, soap_format_xml(), soap_map_xml_data(), SOAP_QUERY_OK, and soap_release_dependences().

Referenced by soap_server().

{
    PrivData *privdata = conn->data;
    xmlDocPtr requestDoc;
    xmlNodePtr root;

    Msg* msg;
    int pos = 0;

    long res = -1;

    List* maps;
    char receiver[30], sender[30], msgtype[30], msgdata[255], date[30];
    long long msgid = -1;
    char* keywords[] = { "receiver", "sender", "msgtype", "msgdata", "date", "id" };
    char* sscans[] = { "%s", "%s", "%s", "%s", "%s", "%lld" };
    void* pointers[] = { &receiver, &sender, &msgtype, &msgdata, &date, &msgid };

    receiver[0] = sender[0] = msgtype[0] = msgdata[0] = date[0] = '\0';

    if (!response) /* how am I supposed to return a response now ? */
        return -1;

    if (!request) {
        *response = octstr_create(SOAP_ERROR_NO_DATA_MESSAGE);
        return SOAP_ERROR_NO_DATA_CODE;
    }

    /* find the POST parameter name */
    if ( (pos = octstr_search_char(request,'=',0)) < 0) {
        /* didn't find it - */
        *response = octstr_create(SOAP_ERROR_MALFORMED_DATA_MESSAGE);
        return SOAP_ERROR_MALFORMED_DATA_CODE;
    }

    /* cut of the parameter name - I'm not really interested in it */
    octstr_delete(request,0,pos+1);

    /* decode the URL encoded data */
    if (octstr_url_decode(request) < 0) {
        /* probably not URL encoded */

        *response = octstr_create(SOAP_ERROR_MALFORMED_DATA_MESSAGE);
        return SOAP_ERROR_MALFORMED_DATA_CODE;
    }

    debug("bb.soap.parse_mo",0,"SOAP[%s]: parse_mo  - MO request dump <%s>", octstr_get_cstr(privdata->name),octstr_get_cstr(request));

    /* parse XML */
    if ( !(requestDoc = xmlParseDoc((xmlChar *)octstr_get_cstr(request))) ) {
        error(0,"SOAP[%s]: parse_mo couldn't parse XML response", octstr_get_cstr(privdata->name));
        return -1;
    }

    /* get root element */
    if ( ! (root = xmlDocGetRootElement(requestDoc)) ) {
        error(0,"SOAP[%s]: parse_mo couldn't get XML root element for request", octstr_get_cstr(privdata->name));
        xmlFreeDoc(requestDoc);
        return -1;
    }

    /* create the argument map */
    maps = soap_create_map(privdata->mo_spec_file, 6, keywords, sscans, pointers);


    /* run the map and the xml through the parser */
    if (soap_map_xml_data(root, maps) < gwlist_len(maps)) {
        error(0,"SOAP[%s]: parse_mo failed to map all the arguments from the XML data",
              octstr_get_cstr(privdata->name));
    }

    /* done with the document */
    xmlFreeDoc(requestDoc);

    if (strlen(receiver) == 0) {
        error(0,"SOAP: parse_mo - failed to get receiver");
        *response = octstr_create(SOAP_ERROR_MALFORMED_DATA_MESSAGE);
        return SOAP_ERROR_MALFORMED_DATA_CODE;
    }

    if (strlen(sender) == 0) {
        error(0,"SOAP: parse_mo - failed to get sender");
        *response = octstr_create(SOAP_ERROR_MALFORMED_DATA_MESSAGE);
        return SOAP_ERROR_MALFORMED_DATA_CODE;
    }

    if (strlen(msgdata) == 0) {
        error(0,"SOAP: parse_mo - failed to get message content");
        *response = octstr_create(SOAP_ERROR_MALFORMED_DATA_MESSAGE);

        return SOAP_ERROR_MALFORMED_DATA_CODE;
    }

    /* create me a message to store data in it */

    msg = msg_create(sms);

    /*
     * XXX UUID is used, fix this. 

    if (msgid == -1) {
        error(0,"SOAP: parse_mo - failed to get message ID, generate by itself");
        msg->sms.id = gw_generate_id(); 
    }
    */

    /* fill in the fields from the parsed arguments */
    msg->sms.sender = octstr_create(sender);
    msg->sms.receiver = octstr_create(receiver);
    /*
     * XXX UUID is used, fix this. 
    msg->sms.id = msgid;
    */
    msg->sms.msgdata = octstr_create(msgdata);

    /* special processing and refill appropriate fields */
    if (privdata->mo_deps_file) {
        if ((res = soap_release_dependences(privdata->mo_deps_file, maps, msg, privdata))!=0)
            error(0,"SOAP: parse_mo - failed to release all dependences");
    }
    gwlist_destroy(maps, soap_destroy_map);

    /* fill in the date */
    if (strlen(date)) {
        struct universaltime tm;
        Octstr* temp = octstr_create(date);
        if (date_parse_iso(&tm, temp))
            /* failed to parse the date */
            msg->sms.time = time(NULL);
        else
            msg->sms.time = date_convert_universal(&tm);
        octstr_destroy(temp);
    } else
        msg->sms.time = time(NULL);

    /*
        / * check message data type - B stands for "base 64 encoded" in Team Mobile * /
        if (!strcmp(msgtype, "B")) {
            octstr_base64_to_binary(msg->sms.msgdata);
            msg->sms.coding = DC_8BIT;

        } else if (!strcmp(msgtype, "binary")) {
            octstr_hex_to_binary(msg->sms.msgdata);
            msg->sms.coding = DC_8BIT;
        } else {
    */

    /* not gonna play this game - just convert from whatever alt_charset is set to, to UCS-2
        / * scan message for unicode chars (UTF-8 encoded) * /
        pos = 0;
        while (pos < octstr_len(msg->sms.msgdata)) {
        if (octstr_get_char(msg->sms.msgdata,pos) & 128)
            break;
        ++pos;
        }

        if (pos < octstr_len(msg->sms.msgdata)) {
            / * message has some unicode - we need to convert to UCS-2 first * /
            Octstr* temp = msg->sms.msgdata;

            msg->sms.coding = DC_UCS2;
        if (charset_from_utf8(temp, &(msg->sms.msgdata), octstr_imm("UCS-2")) < 0) {
                error(0,"SOAP[%s]: parse_mo couldn't convert msg text from UTF-8 to UCS-2. leaving as is.", octstr_get_cstr(privdata->name));
                O_DESTROY(msg->sms.msgdata);
                msg->sms.msgdata = octstr_duplicate(temp);
            / *  set coding to 8bit and hope for the best * /
            msg->sms.coding = DC_8BIT;

            }
            octstr_destroy(temp);
        } else
             / * not unicode : 7bit * /
             msg->sms.coding = DC_7BIT;
    */

    /* if it's not binary, then assume unicode and convert from alt_charset to UCS-2 */
    /*        msg->sms.coding = DC_UCS2;



            if (!octstr_case_compare(privdata->alt_charset, octstr_imm("UCS-2")))  {
                int ret = 0;
                debug("bb.soap.parse_mo",0,"SOAP[%s]: converting from %s to UCS-2BE",
                        octstr_get_cstr(privdata->name), octstr_get_cstr(privdata->alt_charset));
                ret = charset_convert(msg->sms.msgdata, octstr_get_cstr(privdata->alt_charset), "UCS-2BE");


                if (ret == -1) {
                    error(2,"SOAP[%s]: Error converting MO data from %s to unicode",
                            octstr_get_cstr(privdata->name),  octstr_get_cstr(privdata->alt_charset));
                } else if (ret != 0) {
                    debug("bb.soap.parse_mo",1,"SOAP[%s]: charset_convert made %d irreversable transformations",
                            octstr_get_cstr(privdata->name), ret);
                }
            }
            msg->sms.charset = octstr_create("UCS-2");
        }
        debug("bb.soap.parse_mo",0,"SOAP[%s]: message decoded -", octstr_get_cstr(privdata->name));
        octstr_dump(msg->sms.msgdata,0);
    */

    /* check that we have all the fields necessary */
    if (!(msg->sms.sender)
            ||
            !(msg->sms.msgdata)) {
        /* generate error message */
        *response = octstr_create(SOAP_ERROR_MALFORMED_DATA_MESSAGE);
        return SOAP_ERROR_MALFORMED_DATA_CODE;
    }

    /* setup defaults */
    if (msg->sms.time <= 0)
        msg->sms.time = time(NULL);

    if (!msg->sms.receiver)
        msg->sms.receiver = octstr_create(SOAP_DEFAULT_SENDER_STRING);

    if (!msg->sms.smsc_id)
        msg->sms.smsc_id = octstr_duplicate(conn->id);

    *response = soap_format_xml(privdata->mo_xml_file,msg,privdata);
    if (*response)
        debug("bb.soap.response_dlr",0,"SOAP[%s]: data dump: %s", octstr_get_cstr(privdata->name), octstr_get_cstr(*response));

    bb_smscconn_receive(conn,msg);

    return SOAP_QUERY_OK;
}

soap_parse_response()

static long long soap_parse_response ( PrivData *  privdata, Octstr *  xmlResponse  )

static

Definition at line 1205 of file smsc_soap.c.

References error(), gwlist_destroy(), keywords, privdata::mt_spec_file, privdata::name, octstr_get_cstr, soap_create_map(), soap_destroy_map(), soap_map_xml_data(), and warning().

Referenced by soap_read_response().

{
    long long msgID = -1;
    long responseStatus = -1;
    xmlDocPtr responseDoc;
    xmlNodePtr root;
    List* maps;
    char* keywords[] = { "id", "result" };
    char* sscans[] = { "%lld", "%ld" };
    void* pointers[] = { &msgID, &responseStatus };

    if (!xmlResponse)
        return -1;
    /* FIXME: do something here */

    /* parse XML */
    if ( !(responseDoc = xmlParseDoc((xmlChar *)octstr_get_cstr(xmlResponse))) ) {
        error(0,"SOAP[%s]: couldn't parse XML response [ %s ] in MT parsing",
              octstr_get_cstr(privdata->name), octstr_get_cstr(xmlResponse));
        return -1;
    }

    /* get root element */
    if ( ! (root = xmlDocGetRootElement(responseDoc)) ) {
        error(0,"SOAP[%s]: couldn't get XML root element in MT parsing",
              octstr_get_cstr(privdata->name));
        xmlFreeDoc(responseDoc);
        return -1;
    }

    /* create the argument map */
    maps = soap_create_map(privdata->mt_spec_file, 2, keywords, sscans, pointers);

    /* run the map and the xml through the parser */
    if (soap_map_xml_data(root, maps) < 2) {
        error(0,"SOAP[%s]: failed to map all the arguments from the XML data",
              octstr_get_cstr(privdata->name));
    }

    gwlist_destroy(maps, soap_destroy_map);

    /* done with the document */
    xmlFreeDoc(responseDoc);

    if (msgID == -1) {
        if (responseStatus == 0) {   /* success without msg ID */
            warning(0, "SOAP[%s]: parse_response - the protocol does not support message ID",
                    octstr_get_cstr(privdata->name));
            return 0;
        }
        else {
            error(0,"SOAP[%s]: parse_response - response code isn't 0 ! (%ld)",
                  octstr_get_cstr(privdata->name), responseStatus);
            return -1;  /* Nack */
        }
    }
    else
        return msgID;   /* success with msg ID */

}

soap_process_deps()

int soap_process_deps	(	int	key_index,
		int	key_func_ind,
		Msg *	msg,
		PrivData *	privdata
	)

Definition at line 2536 of file smsc_soap.c.

References msg, soap_msgdata_deps(), and soap_msgtype_deps().

Referenced by soap_release_dependences().

{
    /* ADD HERE: MO 'key' functions */
    switch (key_index)
    {
        case 0:
            return soap_msgtype_deps(key_func_ind, msg);
        case 1:
            return soap_msgdata_deps(key_func_ind, msg, privdata);
        default:
            return -1;
    }
    return -1;
}

soap_queued_cb()

static long soap_queued_cb ( SMSCConn *  conn )

static

Definition at line 688 of file smsc_soap.c.

References smscconn::data, gwlist_len(), smscconn::load, privdata::outgoing_queue, SMSCCONN_DEAD, and smscconn::status.

Referenced by smsc_soap_create().

{
    PrivData *privdata = conn->data;
    long ret;

    /* I'm dead, so I have no queues - well there ! */
    if (conn->status == SMSCCONN_DEAD)
        return -1;

    ret = gwlist_len(privdata->outgoing_queue); 
    /* + gwlist_len(privdata->pending_ack_queue); */

    /* use internal queue as load, maybe something else later */
    conn->load = ret;

    return ret;
}

soap_rand_attribute()

Octstr * soap_rand_attribute

(

Msg *

msg

)

Definition at line 2868 of file smsc_soap.c.

References gw_rand(), and octstr_format().

Referenced by soap_select_function().

{
    return octstr_format("%d",gw_rand());
}

soap_read_date()

time_t soap_read_date

(

Octstr *

dateString

)

Definition at line 1777 of file smsc_soap.c.

References date_convert_universal(), universaltime::day, debug(), universaltime::hour, universaltime::minute, universaltime::month, octstr_get_cstr, octstr_len(), octstr_parse_long(), universaltime::second, and universaltime::year.

{
    int pos, count;
    struct universaltime stTime;
    long arTime[5];


    if (!dateString) /* sanity check */
        return -1;

    pos = count = 0;
    /* tricky control structures are my favourite among complicated expressions ;-) */
    while (count < 5 && pos < octstr_len(dateString) &&
            (pos = octstr_parse_long(&(arTime[count++]),dateString, pos,10)) && pos != -1)
        ++pos;

    if (count < 5) {
        /* error parsing the date */
        debug("bb.soap.read_date",0,"read_date failed parsing the date value <%s>", octstr_get_cstr(dateString));
        return -1;
    }

    stTime.day = arTime[0];
    stTime.month = arTime[1];
    stTime.year = arTime[2];
    stTime.hour = arTime[3];
    stTime.minute = arTime[4];
    stTime.second = 0;
    return date_convert_universal(&stTime);
}

soap_read_response()

static void soap_read_response ( SMSCConn *  conn )

static

Definition at line 1118 of file smsc_soap.c.

References bb_smscconn_send_failed(), bb_smscconn_sent(), client_data::caller, smscconn::data, debug(), dlr_add(), gwlist_len(), http_destroy_headers(), http_receive_result, smscconn::id, msg, privdata::name, O_DESTROY, octstr_create, octstr_get_cstr, octstr_imm(), client_data::requests, SMSCCONN_FAILED_MALFORMED, privdata::soap_client, soap_client_have_response(), and soap_parse_response().

Referenced by soap_listener().

{
    PrivData *privdata = conn->data;
    Msg* msg;
    Octstr *responseBody, *responseURL;
    List* responseHeaders;
    int responseStatus;
    long long msgID;
    ClientData* cd;

    /* don't get in here unless I have some callers */
    /* (I shouldn't have one before I start sending messages) */
    if (!gwlist_len(privdata->soap_client))
        return;


    /* see if we have any responses pending */
    if (!(cd = soap_client_have_response(privdata->soap_client)))
        return;

    cd->requests--;
    msg = http_receive_result(cd->caller, &responseStatus, &responseURL, &responseHeaders, &responseBody);

    if (!msg) /* no responses here */
    {
        debug("bb.soap.read_response",0,"SOAP[%s]: sorry, no response", octstr_get_cstr(privdata->name));
        return;
    }

    if (responseStatus == -1) {
        debug("bb.soap.read_response",0,"SOAP[%s]: HTTP connection failed - blame the server (requeing msg)",
              octstr_get_cstr(privdata->name));
        bb_smscconn_send_failed(conn, msg,
                SMSCCONN_FAILED_MALFORMED, octstr_create("MALFORMED"));
        /*    bb_smscconn_send_failed(conn, msg, SMSCCONN_FAILED_TEMPORARILY); */
        /*      gwlist_append(privdata->outgoing_queue, msg); */
        return;
    }

    debug("bb.soap.read_response",0,"SOAP[%s]: got a response %d= %s",
          octstr_get_cstr(privdata->name), responseStatus, responseBody?octstr_get_cstr(responseBody):octstr_get_cstr(octstr_imm("NULL")));


    /* got a message from HTTP, parse it */
    if ( (msgID = soap_parse_response(privdata, responseBody)) >= 0)
    { /* ack with msg ID */
        char tmpid[30];

        /*
         * XXX UUID is used, fix this. 

        if (msgID == 0)
            msgID = msg->sms.id;
        */

        sprintf(tmpid,"%lld",msgID);
        debug("bb.soap.read_response",0,"SOAP[%s]: ACK - id: %lld", octstr_get_cstr(privdata->name), msgID);

        dlr_add(conn->id, octstr_imm(tmpid), msg, 0);

        /* send msg back to bearerbox for recycling */
        bb_smscconn_sent(conn, msg, NULL);
    }

    else { /* nack */
        debug("bb.soap.read_response",0,"SOAP[%s]: NACK", octstr_get_cstr(privdata->name));

        /* send msg back to bearerbox for recycling */
        bb_smscconn_send_failed(conn, msg,
                SMSCCONN_FAILED_MALFORMED, octstr_create("MALFORMED"));
    }

    http_destroy_headers(responseHeaders);
    O_DESTROY(responseBody);
    O_DESTROY(responseURL);
}

soap_release_dependences()

long soap_release_dependences	(	Octstr *	deps,
		List *	lstmaps,
		Msg *	msg,
		PrivData *	privdata
	)

Definition at line 2404 of file smsc_soap.c.

References error(), gwlist_destroy(), gwlist_extract_first(), gwlist_get(), gwlist_len(), msg, O_DESTROY, octstr_create, octstr_destroy_item(), octstr_duplicate, octstr_get_cstr, octstr_imm(), octstr_split(), octstr_split_words(), octstr_str_compare(), octstr_strip_blanks(), octstr_strip_crlfs(), soap_get_index(), soap_process_deps(), SPEC_DEFAULT, and argument_map::store.

Referenced by soap_parse_mo().

{
    List *issues;
    long i, j, key_index, key_deps_index, map_index;
    int res, k;
    List *issue_items, *header_item;
    int key_func_index;
    ArgumentMap* map;
    Octstr *header, *key, *key_deps;
    Octstr *func_alias = NULL, *block;

    /* follows  keys and funcs identifiers must be
     * the same as in a 'deps' file
     **/


    /*  structure of file_deps;
     *
     *  <key> <key_deps>
     *  <key_deps_value> <function_alias>
     *  <key_deps_value> <function_alias>
     *  ;
     */

    /* ADD HERE: */

    char* funcs[][5] = {    /* functions aliasis used in mo.deps file */
                           {"text","binary","unicode","default"},                     /*  msgtype */
                           {"set_iso","64_binary","hex_binary","unicode","default"}  /* msgdata */
                       };


    issues = octstr_split(file_deps, octstr_imm(";"));                  /* get paragraphs */

    if (gwlist_len(issues) == 0) {
        error(0, "SOAP: soap_release_dependences, empty or broken 'deps' file");
        return -1;
    }

    for (i=0; i<gwlist_len(issues); ++i)                                    /* loop paragraphs */
    {
        block = gwlist_get(issues, i);
        octstr_strip_crlfs(block);
        octstr_strip_blanks(block);

        issue_items = octstr_split(block, octstr_imm("\n"));
        if (gwlist_len(issue_items) < 2) {
            error(0, "SOAP: soap_release_dependences, broken file 'deps' can't find any definition for <key>");
            gwlist_destroy(issue_items, octstr_destroy_item);
            gwlist_destroy(issues, octstr_destroy_item);
            return -1;
        }


        header = gwlist_extract_first(issue_items);
        header_item = octstr_split_words(header);               /* header content */
        O_DESTROY(header);

        if (gwlist_len(header_item) < 2) {
            error(0, "SOAP: soap_release_dependences, broken 'deps' file in <key> <key_deps> part");
            gwlist_destroy(header_item, octstr_destroy_item);
            gwlist_destroy(issue_items, octstr_destroy_item);
            gwlist_destroy(issues, octstr_destroy_item);
            return -1;
        }

        key      = gwlist_get(header_item, 0);
        key_deps = gwlist_get(header_item, 1);
        key_index      = soap_get_index(lstmaps, key, 0);      /* search key_index */
        key_deps_index = soap_get_index(lstmaps, key_deps, 0); /* search key_deps_index, from what depends */

        if (key_index == -1 || key_deps_index == -1) {
            gwlist_destroy(header_item, octstr_destroy_item);
            gwlist_destroy(issue_items, octstr_destroy_item);
            gwlist_destroy(issues, octstr_destroy_item);
            return -1;
        }

        map_index = soap_get_index(lstmaps, key_deps, 1); /* get index for map->name==key_deps */
        map = gwlist_get(lstmaps, map_index);

        /* search <function_identifier> and if not found try to set default */
        for (j=0; j < gwlist_len(issue_items); ++j) {

            Octstr *tmp = gwlist_get(issue_items, j);
            List *row = octstr_split_words(tmp);

            if (!octstr_str_compare(gwlist_get(row, 0), map->store)) {
                func_alias = octstr_duplicate(gwlist_get(row, 1));
                gwlist_destroy(row, octstr_destroy_item);
                break;
            }

            if (j==gwlist_len(issue_items)-1) {
                error(0, "SOAP: soap_release_dependences, \
                      can't find function_alias for <%s> in 'deps' file, set default", (char*)map->store);
                func_alias = octstr_create(SPEC_DEFAULT);
            }
            gwlist_destroy(row, octstr_destroy_item);
        }

        key_func_index = -1;
        /* searching index of function by its alias */
        for (k=0; k < sizeof(funcs[key_index])/sizeof(funcs[key_index][0]); ++k)
        {
            if (!octstr_str_compare(func_alias, funcs[key_index][k])) {
                key_func_index = k;
                break;
            }
        }
        if (key_func_index==-1)
            error(0, "SOAP: soap_release_dependences, can't find function for alias <%s>", octstr_get_cstr(func_alias));

        O_DESTROY(func_alias);

        gwlist_destroy(header_item, octstr_destroy_item);
        gwlist_destroy(issue_items, octstr_destroy_item);

        /* which field has deps, which func need be called, msg need be changed */
        if ((res=soap_process_deps(key_index, key_func_index, msg, privdata)) < 0)
            error(0, "SOAP: soap_release_dependences, error processing dependent value");
    }
    gwlist_destroy(issues, octstr_destroy_item);


    return 0; /* OK */
}

soap_select_function()

Octstr * soap_select_function	(	int	index,
		Msg *	msg,
		PrivData *	privdata
	)

Definition at line 2663 of file smsc_soap.c.

References error(), msg, soap_bouyg_content_attribute(), soap_bouyg_validity_attribute(), soap_mobitai_content_attribute(), soap_mobitai_date_attribute(), soap_mobitai_validity_date_attribute(), soap_msgdata_attribute(), soap_o2o_date_attribute(), soap_o2o_dlrmask_smsc_yn_attribute(), soap_o2o_dlrmask_success_01_attribute(), soap_o2o_msgdata_attribute(), soap_o2o_validity30_attribute(), and soap_rand_attribute().

Referenced by soap_convert_token().

{
    /* ADD HERE: XML functions  */
    switch (index)
    {
        case 0:
            return soap_bouyg_content_attribute(msg);
        case 1:
            return soap_mobitai_content_attribute(msg);
        case 2:
            return soap_o2o_msgdata_attribute(msg, privdata);
        case 3:
            return soap_msgdata_attribute(msg, privdata);           /* mobitai/bouyg */
        case 4:
            return soap_o2o_validity30_attribute(msg);
        case 5:
            return soap_mobitai_validity_date_attribute(msg);
        case 6:
            return soap_bouyg_validity_attribute(msg);
        case 7:
            return soap_o2o_date_attribute(msg);
        case 8:
            return soap_mobitai_date_attribute(msg);
        case 9:
            return soap_rand_attribute(msg);
        case 10:
            return soap_o2o_dlrmask_smsc_yn_attribute(msg);
        case 11:
            return soap_o2o_dlrmask_success_01_attribute(msg);
        default:
            error(0,"SOAP: soap_select_function can't find function");
            return NULL;
    }
}

soap_send()

static void soap_send ( PrivData *  privdata, Octstr *  xmlbuffer, Msg *  msgid  )

static

Definition at line 1080 of file smsc_soap.c.

References privdata::form_urlencoded, privdata::form_variable, http_create_empty_headers(), http_destroy_headers(), http_header_add(), msg, O_DESTROY, octstr_format(), and soap_client_init_query().

Referenced by soap_send_loop().

{
    List *requestHeaders;
    Octstr* postdata;

    /* create request headers */
    requestHeaders = http_create_empty_headers();
    http_header_add(requestHeaders, "User-Agent", "Kannel " GW_VERSION);

    if (privdata->form_urlencoded) {
        http_header_add(requestHeaders, "Content-Type", "application/x-www-form-urlencoded");
        postdata = octstr_format("%S=%E", privdata->form_variable, xmlbuffer);
    } else {
        http_header_add(requestHeaders, "Content-Type", "multipart/form-data, boundary=AaB03x");
        postdata = octstr_format("--AaB03x\r\n"
                                 "content-disposition: form-data; name=\"%S\"\r\n\r\n%S",
                                 privdata->form_variable, xmlbuffer);
    }

    /* send the request along */
    soap_client_init_query(privdata, requestHeaders, postdata, msg);

    O_DESTROY(postdata);

    /* done with that */
    http_destroy_headers(requestHeaders);

    return;

}

soap_send_loop()

static void soap_send_loop ( SMSCConn *  conn )

static

Definition at line 963 of file smsc_soap.c.

References bb_smscconn_send_failed(), counter, smscconn::data, debug(), gwlist_extract_first(), msg, privdata::mt_xml_file, privdata::name, O_DESTROY, octstr_create, octstr_get_cstr, privdata::outgoing_queue, SMSCCONN_FAILED_MALFORMED, soap_format_xml(), SOAP_MAX_MESSAGE_PER_ROUND, soap_send(), uuid_generate(), and uuid_is_null().

Referenced by soap_listener().

{
    PrivData* privdata = conn->data;
    Msg *msg;
    Octstr* xmldata = NULL;
    int counter = 0;
 
    debug("bb.soap.client",0,"SOAP[%s]: client - entering", 
          octstr_get_cstr(privdata->name));

    while ((counter < SOAP_MAX_MESSAGE_PER_ROUND) && 
            (msg = gwlist_extract_first(privdata->outgoing_queue))) { 
        /* as long as we have some messages */
        ++counter;

        if (uuid_is_null(msg->sms.id))   /* generate a message id */
            uuid_generate(msg->sms.id);

        /* format the messages as a character buffer to send */
        if (!(xmldata = soap_format_xml(privdata->mt_xml_file, msg, privdata))) {
            debug("bb.soap.client",0,"SOAP[%s]: client - failed to format message for sending", 
                  octstr_get_cstr(privdata->name));
            bb_smscconn_send_failed(conn, msg,
                    SMSCCONN_FAILED_MALFORMED, octstr_create("MALFORMED"));
            continue;
        }

        debug("bb.soap.client",0,"SOAP[%s]: client - Sending message <%s>",
              octstr_get_cstr(privdata->name), octstr_get_cstr(msg->sms.msgdata));
        if (xmldata)
            debug("bb.soap.client",0,"SOAP[%s]: data dump: %s",
                  octstr_get_cstr(privdata->name), octstr_get_cstr(xmldata));

        /* send to the server */
        soap_send(privdata, xmldata, msg);

        /* store in the second queue so that soap_read_response will know what to do */
        /* gwlist_append(privdata->pending_ack_queue,msg); */

        /* don't need this anymore */
        O_DESTROY(xmldata);
    }
}

soap_server()

static void soap_server ( void *  arg )

static

Definition at line 850 of file smsc_soap.c.

References smscconn::data, date_format_http(), debug(), error(), gwlist_destroy(), gwthread_sleep(), http_accept_request(), http_create_empty_headers(), http_destroy_headers(), http_header_add(), http_send_reply(), privdata::name, O_DESTROY, octstr_compare(), octstr_create, octstr_get_cstr, octstr_imm(), privdata::port, SOAP_DEFAULT_CODE, SOAP_DEFAULT_MESSAGE, SOAP_DLR_URI, SOAP_ERROR_DLR_CODE, SOAP_ERROR_DLR_MESSAGE, SOAP_ERROR_MO_CODE, SOAP_ERROR_MO_MESSAGE, SOAP_MO_URI, soap_parse_dlr(), soap_parse_mo(), privdata::soap_server, and SOAP_SLEEP_TIME.

Referenced by soap_server_start().

{
    SMSCConn* conn = (SMSCConn*)arg;
    PrivData* privdata = conn->data;
    /* PrivData* privdata = (PrivData*)arg; */

    HTTPClient* remote_client = NULL;
    List *request_headers = NULL, *response_headers = NULL;
    List *cgivars = NULL;
    Octstr *client_ip = NULL, *request_uri = NULL, *request_body = NULL;
    Octstr *response_body = NULL;
    Octstr *timebuf = NULL;
    int http_response_status;

    debug("bb.soap.server",0,"SOAP[%s]: Server starting", 
          octstr_get_cstr(privdata->name));

    /* create basic headers */
    response_headers = http_create_empty_headers();
    http_header_add(response_headers, "Content-type","text/xml");
    /* http_header_add(response_headers, "Content-type","application/x-www-form-urlencoded"); */
    /* http_header_add(response_headers,"Connection", "Close"); */
    http_header_add(response_headers, "Server","Kannel");

    while (privdata->soap_server) {
        if ((remote_client = http_accept_request(privdata->port,
                              &client_ip, &request_uri, &request_headers, 
                              &request_body, &cgivars))) {

            debug("bb.soap.server",0,"SOAP[%s]: server got a request for "
                  "%s from %s, with body <%s>", octstr_get_cstr(privdata->name),
                  octstr_get_cstr(request_uri),octstr_get_cstr(client_ip),
                  request_body ? octstr_get_cstr(request_body) : "<null>");

            /* parse request */
            if (!octstr_compare(request_uri,octstr_imm(SOAP_MO_URI))) {
                /* this is an incoming MO */
                if ((http_response_status = 
                        soap_parse_mo(conn,request_body, &response_body)) == -1) {
                    /* fatal error parsing MO */
                    error(0,"SOAP[%s]: fatal error parsing MO", 
                          octstr_get_cstr(privdata->name));
                    response_body = octstr_create(SOAP_ERROR_MO_MESSAGE);
                    http_response_status = SOAP_ERROR_MO_CODE;
                }
            } else if (!octstr_compare(request_uri,octstr_imm(SOAP_DLR_URI))) {
                /* a delivery report */
                if ((http_response_status = 
                        soap_parse_dlr(conn,request_body, &response_body)) == -1) {
                    /* fatal error parsing MO */
                    error(0,"SOAP[%s]: fatal error parsing DLR", 
                          octstr_get_cstr(privdata->name));
                    response_body = octstr_create(SOAP_ERROR_DLR_MESSAGE);
                    http_response_status = SOAP_ERROR_DLR_CODE;
                }
            } else {
                /* unknown command send default message */
                response_body = octstr_create(SOAP_DEFAULT_MESSAGE);
                http_response_status = SOAP_DEFAULT_CODE;
            }

            /* create response */
            /*
            response_body = octstr_create("<?xml version=\"1.0\" encoding=\"UTF-8\"?>\n"
            "<!DOCTYPE SMSCACCESS_REPLY SYSTEM \"http://superion/~oded/smsc_reply-1_0.dtd\">\n"
            "<SMSCACCESS_REPLY>\n"
            "   <SUBSCRIBER>447951718145</SUBSCRIBER>\n"
            "   <DATE_RECEIVED>22/01/2002:15:12</DATE_RECEIVED>\n"
            "   <RETURN_CODE>00</RETURN_CODE>\n"
            "</SMSCACCESS_REPLY>\n");
            */

            /* encode date in headers */

            timebuf = date_format_http(time(NULL));
            /* http_header_add(response_headers, "Date", octstr_get_cstr(timebuf)); */
            O_DESTROY(timebuf);
            /* http_header_dump(response_headers); */

            /* send response back to client */
            http_send_reply(remote_client,http_response_status,response_headers, response_body);

            /* destroy response data */
            /* http_destroy_headers(response_headers); */
            O_DESTROY(response_body);

            /* destroy request data */
            O_DESTROY(request_uri);
            O_DESTROY(request_body);
            O_DESTROY(client_ip);

            http_destroy_headers(request_headers);
            gwlist_destroy(cgivars, NULL);
        }

        gwthread_sleep(SOAP_SLEEP_TIME);
    }

    debug("bb.soap.server",0,"SOAP[%s]: server going down", 
          octstr_get_cstr(privdata->name));
    /* privdata->server_thread = 0; */
}

soap_server_start()

int soap_server_start

(

SMSCConn *

conn

)

Definition at line 1845 of file smsc_soap.c.

References smscconn::data, debug(), error(), gwthread_create, http_close_port(), http_open_port(), privdata::name, octstr_get_cstr, privdata::port, privdata::server_thread, privdata::soap_server, soap_server(), and privdata::ssl.

Referenced by soap_listener().

{
    PrivData* privdata = conn->data;

    debug("bb.soap.server_stop",0,"SOAP[%s]: Starting HTTP server", octstr_get_cstr(privdata->name));
    /* start the HTTP server */
    if (http_open_port(privdata->port,privdata->ssl)) {
        return -1;
    }


    /* raise server flag */
    privdata->soap_server = 1;

    if ( (privdata->server_thread = gwthread_create(soap_server, conn)) == -1)
    {
        error(0, "SOAP[%s]: server_start failed to create server thread!", octstr_get_cstr(privdata->name));
        http_close_port(privdata->port);
        return -1;
    }


    return 0;
}

soap_server_stop()

static void soap_server_stop ( PrivData *  privdata )

static

Definition at line 1875 of file smsc_soap.c.

References debug(), gwthread_join(), gwthread_wakeup(), http_close_port(), privdata::name, octstr_get_cstr, privdata::port, privdata::server_thread, and privdata::soap_server.

Referenced by soap_listener().

{
    /*    time_t start = time(NULL); */

    debug("bb.soap.server_stop",0,"SOAP[%s]: Stopping HTTP server", octstr_get_cstr(privdata->name));
    /* signal the server thread to stop */
    privdata->soap_server = 0;

    /* close the http server thread */
    http_close_port(privdata->port);

    if (privdata->server_thread) {
        gwthread_wakeup(privdata->server_thread);
        gwthread_join(privdata->server_thread);
        privdata->server_thread = 0;
    }


    /*
    / * wait upto 5 minutes for our server thread to shutdown * /
    while (privdata->server_thread &&  (start + 300 > time(NULL)))
    gwthread_sleep(SOAP_SLEEP_TIME);


    if (privdata->server_thread) {
    error(0,"SOAP[%s]: our server refuses to die!", octstr_get_cstr(privdata->name));
    privdata->server_thread = 0; / * dump it either way * /

    }*/

    debug("bb.soap.server_stop",0,"SOAP[%s]: Done stopping HTTP server", octstr_get_cstr(privdata->name));
}

soap_shutdown_cb()

static int soap_shutdown_cb ( SMSCConn *  conn, int  finish_sending  )

static

Definition at line 594 of file smsc_soap.c.

References bb_smscconn_send_failed(), smscconn::data, debug(), gwlist_extract_first(), gwthread_join(), gwthread_wakeup(), privdata::listener_thread, msg, privdata::name, octstr_get_cstr, privdata::outgoing_queue, privdata::shutdown, SMSCCONN_DEAD, SMSCCONN_FAILED_SHUTDOWN, SMSCCONN_KILLED_SHUTDOWN, smscconn::status, and smscconn::why_killed.

Referenced by smsc_soap_create().

{
    PrivData *privdata = conn->data;
    long thread;

    /* I'm dead, there's really no point in killing me again, is it ? */
    if (conn->status == SMSCCONN_DEAD)
        return -1;

    debug("bb.soap.cb", 0, "SOAP[%s]: Shutting down SMSCConn, %s", 
          octstr_get_cstr(privdata->name), finish_sending ? "slow" : "instant");

    /* Documentation claims this would have been done by smscconn.c, 
     * but isn't when this code is being written.*/
    conn->why_killed = SMSCCONN_KILLED_SHUTDOWN;
    /* Separate from why_killed to avoid locking, 
     * as why_killed may be changed from outside? */
    privdata->shutdown = 1;

    if (finish_sending == 0) {
        Msg *msg;
        while ((msg = gwlist_extract_first(privdata->outgoing_queue)) != NULL)
            bb_smscconn_send_failed(conn, msg, SMSCCONN_FAILED_SHUTDOWN, NULL);
    }

    thread = privdata->listener_thread;

    gwthread_wakeup(thread);
    gwthread_join(thread);

    return 0;
}

soap_start_cb()

static void soap_start_cb ( SMSCConn *  conn )

static

Definition at line 634 of file smsc_soap.c.

References smscconn::data, debug(), error(), gwthread_create, privdata::listener_thread, privdata::name, octstr_get_cstr, privdata::shutdown, SMSCCONN_CONNECTING, SMSCCONN_DEAD, SMSCCONN_KILLED_CANNOT_CONNECT, soap_listener(), smscconn::status, and smscconn::why_killed.

Referenced by smsc_soap_create().

{
    PrivData *privdata = conn->data;

    debug("smsc.soap.start", 0, "SOAP[%s]: start called", 
          octstr_get_cstr(privdata->name));

    /* set the status so that connection_thread will know what to do */
    conn->status = SMSCCONN_CONNECTING;

    /* start connection_thread, in case its not started. */
    if ((!privdata->listener_thread) &&
        ((privdata->listener_thread = gwthread_create(soap_listener, conn)) == -1)) {
        error(0, "SOAP: soap_start, failed to spawn thread - aborting");
        conn->why_killed = SMSCCONN_KILLED_CANNOT_CONNECT;
        conn->status = SMSCCONN_DEAD;
        privdata->shutdown = 1;
        return;
    }
    /* gwthread_wakeup(privdata->listener_thread); */
    debug("smsc.soap.start",0,"SOAP[%s]: starting OK", 
          octstr_get_cstr(privdata->name));
}

soap_stop_cb()

static void soap_stop_cb ( SMSCConn *  conn )

static

Definition at line 665 of file smsc_soap.c.

References smscconn::data, debug(), privdata::name, octstr_get_cstr, SMSCCONN_DEAD, SMSCCONN_DISCONNECTED, and smscconn::status.

Referenced by smsc_soap_create().

{
    PrivData *privdata = conn->data;

    /* I'm dead, its really too late to take a break now */
    if (conn->status == SMSCCONN_DEAD)
        return;

    debug("smsc.soap.stop", 0, "SOAP[%s]: stop called", 
          octstr_get_cstr(privdata->name));

    /* make connection thread disconnect */
    conn->status = SMSCCONN_DISCONNECTED;
}

soap_write_date()

static Octstr * soap_write_date ( time_t  date )

static

Definition at line 1814 of file smsc_soap.c.

References date(), octstr_create, and octstr_format().

Referenced by soap_o2o_date_attribute().

{
    struct tm date_parts;
    Octstr* out;

    if (date < 0)
        /* sanity check - I don't think it should ever happen, but I don't want to get
           support calls at 2am because some gateway in the UK went bananas. */
        return octstr_create("ERROR");

    /* split up epoch time to elements */
    gmtime_r(&date, &date_parts);

    out = octstr_format("%d/%02d/%02d:%02d:%02d",
                        date_parts.tm_year + 1900, date_parts.tm_mon + 1, date_parts.tm_mday, date_parts.tm_hour, date_parts.tm_min);

    /* again */
    if (out)
        return out;
    else
        return octstr_create("ERROR");
    /* assuming octstr_create never fails, unlike octstr_format. this is not the case currently (both cannot fail), but it may change */
}

soap_xmlnode_get_int64()

int soap_xmlnode_get_int64	(	xmlNodePtr	cur,
		long long *	out
	)

Definition at line 1712 of file smsc_soap.c.

References error().

{
    xmlChar* nodeContent;
    char* endPointer;

    if (!out)  /* sanity check */
        return -1;

    /* get content of tag */
    if (!(nodeContent = xmlNodeGetContent(cur))) {
        error(0,"SOAP: get_long - xml Node has content !");
        return -1;
    }


    /* read the content into output */
    *out = strtoll((char *)nodeContent,&endPointer,10);
    xmlFree(nodeContent);

    if (endPointer == (char*)nodeContent) {
        error(0,"SOAP: get_long - node has non-numeric content <%s>", nodeContent);
        return -1;
    }

    return 0;
}

soap_xmlnode_get_long()

int soap_xmlnode_get_long	(	xmlNodePtr	cur,
		long *	out
	)

Definition at line 1679 of file smsc_soap.c.

References error().

{
    xmlChar* nodeContent;
    char* endPointer;

    if (!out)  /* sanity check */
        return -1;

    /* get content of tag */
    if (!(nodeContent = xmlNodeGetContent(cur))) {
        error(0,"SOAP: get_long - xml Node has content !");
        return -1;
    }

    /* read the content into output */
    *out = strtol((char *)nodeContent,&endPointer,10);
    xmlFree(nodeContent);

    if (endPointer == (char*)nodeContent) {
        error(0,"SOAP: get_long - node has non-numeric content <%s>", nodeContent);
        return -1;
    }

    return 0;
}

soap_xmlnode_get_octstr()

int soap_xmlnode_get_octstr	(	xmlNodePtr	cur,
		Octstr **	out
	)

Definition at line 1746 of file smsc_soap.c.

References error(), and octstr_create.

{
    xmlChar* nodeContent;

    if (!out)  /* sanity check */
        return -1;

    /* get content of tag */
    if (!(nodeContent = xmlNodeGetContent(cur))) {
        error(0,"SOAP: get_octstr - xml Node has content !");
        return -1;
    }

    /* store the content into output */
    *out = octstr_create((char *)nodeContent);
    xmlFree(nodeContent);

    if (*out)
        return 0;
    else
        return -1;


}