wap-appl.c File Reference

#include <string.h>
#include "gwlib/gwlib.h"
#include "wmlscript/ws.h"
#include "xml_shared.h"
#include "wml_compiler.h"
#include "mime_decompiler.h"
#include "wap/wap.h"
#include "wap-appl.h"
#include "wap_push_ppg.h"
#include "wap/wsp_strings.h"
#include "wap/wsp_caps.h"
#include "wap/wsp.h"
#include "radius/radius_acct.h"
#include "wap-error.h"
#include "wap-maps.h"

Go to the source code of this file.

Data Structures
struct	content
struct	request_data

Macros
#define	ENABLE_NOT_ACCEPTED
#define	NUM_CONVERTERS   ((long)(sizeof(converters) / sizeof(converters[0])))
#define	NUM_DECONVERTERS   ((long)(sizeof(deconverters) / sizeof(deconverters[0])))
#define	HEALTH_DECK

Enumerations
enum	{ limbo, running, terminating }

Functions
static void	main_thread (void *)
static void	start_fetch (WAPEvent *)
static void	return_replies_thread (void *)
static void	dev_null (const char *data, size_t len, void *context)
static Octstr *	convert_wml_to_wmlc (struct content *content)
static Octstr *	convert_wmlscript_to_wmlscriptc (struct content *content)
static Octstr *	deconvert_multipart_formdata (struct content *content)
static List *	negotiate_capabilities (List *req_caps)
static void	indicate_push_connection (WAPEvent *e)
static void	indicate_push_disconnect (WAPEvent *e)
static void	indicate_push_suspend (WAPEvent *e)
static void	indicate_push_resume (WAPEvent *e)
static void	confirm_push (WAPEvent *e)
static void	indicate_push_abort (WAPEvent *e)
static void	split_header_list (List **headers, List **new_headers, char *name)
static void	check_application_headers (List **headers, List **app_headers)
static void	decode_bearer_indication (List **headers, List **bearer_headers)
static void	response_push_connection (WAPEvent *e)
void	wap_appl_init (Cfg *cfg)
void	wap_appl_shutdown (void)
void	wap_appl_dispatch (WAPEvent *event)
long	wap_appl_get_load (void)
static int	convert_content (struct content *content, List *request_headers, int allow_empty)
static int	deconvert_content (struct content *content)
static void	add_kannel_version (List *headers)
static void	add_charset_headers (List *headers)
static void	add_accept_headers (List *headers)
static void	add_network_info (List *headers, WAPAddrTuple *addr_tuple)
static void	add_session_id (List *headers, long session_id)
static void	add_client_sdu_size (List *headers, long sdu_size)
static void	add_via (List *headers)
static void	add_x_wap_tod (List *headers)
static void	add_msisdn (List *headers, WAPAddrTuple *addr_tuple, Octstr *send_msisdn_header)
static void	set_referer_url (Octstr *url, WSPMachine *sm)
static Octstr *	get_referer_url (const WSPMachine *sm)
static void	return_session_reply (long server_transaction_id, long status, List *headers, Octstr *body, long session_id)
static void	return_unit_reply (WAPAddrTuple *tuple, long transaction_id, long status, List *headers, Octstr *body)
static void	normalize_charset (struct content *content, List *device_headers)
static void	return_reply (int status, Octstr *content_body, List *headers, long sdu_size, WAPEvent *orig_event, long session_id, Octstr *method, Octstr *url, int x_wap_tod, List *request_headers, Octstr *msisdn)

Variables
static enum { ... }	run_status = limbo
static List *	queue = NULL
static HTTPCaller *	caller = NULL
static Counter *	fetches = NULL
static List *	charsets = NULL
int	wsp_smart_errors
Octstr *	device_home
static int	have_ppg = 0
struct {
char *   type
char *   result_type
Octstr *(*   convert )(struct content *)
}	converters []
struct {
char *   type
char *   result_type
Octstr *(*   deconvert )(struct content *)
}	deconverters []

Macro Definition Documentation

ENABLE_NOT_ACCEPTED

#define ENABLE_NOT_ACCEPTED

Definition at line 105 of file wap-appl.c.

HEALTH_DECK

#define HEALTH_DECK

Value:

"<?xml version=\"1.0\"?>" \
    "<!DOCTYPE wml PUBLIC \"-//WAPFORUM//DTD 1.1//EN\" " \
    "\"http://www.wapforum.org/DTD/wml_1.1.xml\">" \
    "<wml><card id=\"health\"><p>Ok</p></card></wml>"

Definition at line 1097 of file wap-appl.c.

Referenced by start_fetch().

NUM_CONVERTERS

#define NUM_CONVERTERS   ((long)(sizeof(converters) / sizeof(converters[0])))

Definition at line 212 of file wap-appl.c.

Referenced by add_accept_headers(), and convert_content().

NUM_DECONVERTERS

#define NUM_DECONVERTERS   ((long)(sizeof(deconverters) / sizeof(deconverters[0])))

Definition at line 228 of file wap-appl.c.

Referenced by deconvert_content().

Enumeration Type Documentation

anonymous enum

anonymous enum

Enumerator
limbo
running
terminating

Definition at line 117 of file wap-appl.c.

{ limbo, running, terminating } run_status = limbo;

Function Documentation

add_accept_headers()

static void add_accept_headers ( List *  headers )

static

Definition at line 523 of file wap-appl.c.

References converters, http_header_add(), http_type_accepted(), NUM_CONVERTERS, result_type, and type.

Referenced by start_fetch().

{
    int i;
    
    for (i = 0; i < NUM_CONVERTERS; i++) {
        if (http_type_accepted(headers, "*/*") || (
            http_type_accepted(headers, converters[i].result_type)
            && !http_type_accepted(headers, converters[i].type))) {
            http_header_add(headers, "Accept", converters[i].type);
        }
    }
}

add_charset_headers()

static void add_charset_headers ( List *  headers )

static

Definition at line 515 of file wap-appl.c.

References http_charset_accepted(), and http_header_add().

Referenced by start_fetch().

{
    if (!http_charset_accepted(headers, "utf-8"))
        http_header_add(headers, "Accept-Charset", "utf-8");
}

add_client_sdu_size()

static void add_client_sdu_size ( List *  headers, long  sdu_size  )

static

Definition at line 559 of file wap-appl.c.

References http_header_add(), octstr_destroy(), octstr_format(), and octstr_get_cstr.

Referenced by start_fetch().

{
    if (sdu_size > 0) {
        Octstr *buf;
    
        buf = octstr_format("%ld", sdu_size);
        http_header_add(headers, "X-WAP-Client-SDU-Size", octstr_get_cstr(buf));
        octstr_destroy(buf);
    }
}

add_kannel_version()

static void add_kannel_version ( List *  headers )

static

Definition at line 505 of file wap-appl.c.

References http_header_add().

Referenced by start_fetch().

{
    http_header_add(headers, "X-WAP-Gateway", GW_NAME "/" GW_VERSION);
}

add_msisdn()

static void add_msisdn ( List *  headers, WAPAddrTuple *  addr_tuple, Octstr *  send_msisdn_header  )

static

Definition at line 608 of file wap-appl.c.

References addr_tuple, http_header_add(), http_header_remove_all(), http_header_value(), octstr_destroy(), octstr_get_cstr, octstr_len(), radius_acct_get_msisdn(), and warning().

Referenced by start_fetch().

{
    Octstr *msisdn = NULL;
    Octstr *value = NULL;

    if (send_msisdn_header == NULL || octstr_len(send_msisdn_header) == 0)
        return;

    /* 
     * Security considerations. If there are headers with the header name we
     * use to pass on the MSISDN number, then remove them.
     */
    if ((value = http_header_value(headers, send_msisdn_header)) != NULL) {
        warning(0, "MSISDN header <%s> already present on request, "
                   "header value=<%s>", octstr_get_cstr(send_msisdn_header), 
                  octstr_get_cstr(value));
        http_header_remove_all(headers, octstr_get_cstr(send_msisdn_header));
    }

    /* 
     * XXX Add generic msisdn provisioning cleanly in here!
     * See revision 1.89 for Bruno's try.
     */

    /* We do not accept NULL values to be added to the HTTP header */
    if ((msisdn = radius_acct_get_msisdn(addr_tuple->remote->address)) != NULL) {
        http_header_add(headers, octstr_get_cstr(send_msisdn_header), octstr_get_cstr(msisdn));
    }

    octstr_destroy(value);
    octstr_destroy(msisdn);
}

add_network_info()

static void add_network_info ( List *  headers, WAPAddrTuple *  addr_tuple  )

static

Definition at line 538 of file wap-appl.c.

References addr_tuple, http_header_add(), octstr_get_cstr, and octstr_len().

Referenced by start_fetch().

{
    if (octstr_len(addr_tuple->remote->address) > 0) {
        http_header_add(headers, "X-WAP-Network-Client-IP", 
                        octstr_get_cstr(addr_tuple->remote->address));
    }
}

add_session_id()

static void add_session_id ( List *  headers, long  session_id  )

static

Definition at line 548 of file wap-appl.c.

References http_header_add().

Referenced by start_fetch().

{
    if (session_id != -1) {
        char buf[40];
        sprintf(buf, "%ld", session_id);
        http_header_add(headers, "X-WAP-Session-ID", buf);
    }
}

add_via()

static void add_via ( List *  headers )

static

Definition at line 571 of file wap-appl.c.

References get_official_name(), http_header_add(), http_header_value(), octstr_destroy(), octstr_format(), octstr_get_cstr, octstr_imm(), and content::version.

Referenced by start_fetch().

{
    Octstr *os;
    Octstr *version;
    
    version = http_header_value(headers, octstr_imm("Encoding-Version"));
    os = octstr_format("WAP/%s %S (" GW_NAME "/%s)", 
                       (version ? octstr_get_cstr(version) : "1.1"),
                       get_official_name(), GW_VERSION);
    http_header_add(headers, "Via", octstr_get_cstr(os));
    octstr_destroy(os);
    octstr_destroy(version);
}

add_x_wap_tod()

static void add_x_wap_tod ( List *  headers )

static

Definition at line 592 of file wap-appl.c.

References date_format_http(), http_header_add(), octstr_destroy(), octstr_get_cstr, and warning().

Referenced by return_reply().

{
    Octstr *gateway_time;
    
    gateway_time = date_format_http(time(NULL));
    if (gateway_time == NULL) {
        warning(0, "Could not add X-WAP.TOD response header.");
        return;
    }
    
    http_header_add(headers, "X-WAP.TOD", octstr_get_cstr(gateway_time));
    octstr_destroy(gateway_time);
}

check_application_headers()

static void check_application_headers ( List **  headers, List **  app_headers  )

static

Definition at line 1462 of file wap-appl.c.

References debug(), error(), GW_ERROR, gwlist_len(), http_destroy_headers(), http_header_add(), http_header_dump(), http_header_get(), octstr_destroy(), octstr_dump, octstr_get_cstr, and split_header_list().

Referenced by indicate_push_connection().

{
    List *inh = NULL;
    int i;
    long len;
    Octstr *appid_name, *coded_octstr;
    char *appid_value, *coded_value;

    split_header_list(headers, &inh, "Accept-Application");
    
    if (*headers == NULL || gwlist_len(inh) == 0) {
        http_header_add(*application_headers, "Accept-Application", "wml ua");
        debug("wap.appl.push", 0, "APPL: No push application, assuming wml"
              " ua");
        if (*headers != NULL)
            http_destroy_headers(inh);
        return;
    }

    i = 0;
    len = gwlist_len(inh);
    coded_value = NULL;
    appid_value = NULL;

    while (i < len) {
        http_header_get(inh, i, &appid_name, &coded_octstr);

        /* Greatest value reserved by WINA is 0xFF00 0000*/
        coded_value = octstr_get_cstr(coded_octstr);
        if (coded_value != NULL)
       appid_value = (char *)wsp_application_id_to_cstr((long) coded_value);

        if (appid_value != NULL && coded_value != NULL)
            http_header_add(*application_headers, "Accept-Application", 
                            appid_value);
        else {
            error(0, "OTA: Unknown application is, skipping: ");
            octstr_dump(coded_octstr, 0, GW_ERROR);
        }

        i++;  
    }
   
    debug("wap.appl.push", 0, "application headers were");
    http_header_dump(*application_headers);

    http_destroy_headers(inh);
    octstr_destroy(appid_name);
    octstr_destroy(coded_octstr);
}

confirm_push()

static void confirm_push ( WAPEvent *  e )

static

Definition at line 1644 of file wap-appl.c.

References debug(), WAPEvent::u, wap_event_create, and wap_push_ppg_dispatch_event().

Referenced by main_thread().

{
    WAPEvent *ppg_event;

    ppg_event = wap_event_create(Po_ConfirmedPush_Cnf);
    ppg_event->u.Po_ConfirmedPush_Cnf.server_push_id = 
        e->u.S_ConfirmedPush_Cnf.server_push_id;
    ppg_event->u.Po_ConfirmedPush_Cnf.session_handle = 
         e->u.S_ConfirmedPush_Cnf.session_id;

    debug("wap.appl", 0, "OTA: confirming push for ppg");
    wap_push_ppg_dispatch_event(ppg_event);
}

convert_content()

static int convert_content ( struct content *  content, List *  request_headers, int  allow_empty  )

static

Definition at line 421 of file wap-appl.c.

References content::body, converters, debug(), http_type_accepted(), NUM_CONVERTERS, octstr_create, octstr_destroy(), octstr_dump, octstr_get_cstr, octstr_len(), octstr_str_compare(), result_type, and content::type.

Referenced by return_reply().

{
    Octstr *new_body;
    int failed = 0;
    int i;

    for (i = 0; i < NUM_CONVERTERS; i++) {
        if (octstr_str_compare(content->type, converters[i].type) == 0 &&
            !http_type_accepted(request_headers, octstr_get_cstr(content->type))) {
            debug("wap.convert",0,"WSP: Converting from <%s> to <%s>", 
                  octstr_get_cstr(content->type), converters[i].result_type);
            /* 
             * Note: if request is HEAD, body is empty and we still need to adapt
             * content-type but we don't need to convert a 0 bytes body 
             */
            if (allow_empty && octstr_len(content->body) == 0) 
                return 1;

            new_body = converters[i].convert(content);
            if (new_body != NULL) {
                long s = octstr_len(content->body);
                octstr_destroy(content->body);
                octstr_destroy(content->type);
                content->body = new_body;
                content->type = octstr_create(converters[i].result_type);
                debug("wap.convert",0,"WSP: Content-type is "
                      "now <%s>, size %ld bytes (before: %ld bytes), content body is:", 
                      converters[i].result_type, octstr_len(new_body), s);
                octstr_dump(new_body, 0);
                return 1;
            }
            debug("wap.convert",0,"WSP: Content convertion failed!");
            failed = 1;
        }
    }
    
    return (failed ? -1 : 0);
}

convert_wml_to_wmlc()

static Octstr * convert_wml_to_wmlc ( struct content *  content )

static

Definition at line 1316 of file wap-appl.c.

References content::body, content::charset, octstr_destroy(), content::version, warning(), and wml_compile().

{
    Octstr *wmlc;
    int ret;
   
    /* content->charset is passed from the HTTP header parsing */
    ret = wml_compile(content->body, content->charset, &wmlc, 
                      content->version);

    /* wmlc is created implicitely in wml_compile() */
    if (ret == 0)
        return wmlc;

    octstr_destroy(wmlc);
    warning(0, "WSP: WML compilation failed.");
    return NULL;
}

convert_wmlscript_to_wmlscriptc()

static Octstr * convert_wmlscript_to_wmlscriptc ( struct content *  content )

static

Definition at line 1335 of file wap-appl.c.

References content::body, dev_null(), WsCompilerParamsRec::meta_http_equiv_cb, WsCompilerParamsRec::meta_http_equiv_cb_context, WsCompilerParamsRec::meta_name_cb, WsCompilerParamsRec::meta_name_cb_context, octstr_create_from_data, octstr_get_cstr, octstr_len(), panic, WsCompilerParamsRec::print_assembler, WsCompilerParamsRec::print_symbolic_assembler, WsCompilerParamsRec::stderr_cb, WsCompilerParamsRec::stdout_cb, content::url, WsCompilerParamsRec::use_latin1_strings, warning(), ws_compile_data(), ws_create(), WS_OK, and ws_result_to_string().

{
    WsCompilerParams params;
    WsCompilerPtr compiler;
    WsResult result;
    unsigned char *result_data;
    size_t result_size;
    Octstr *wmlscriptc;
    
    memset(&params, 0, sizeof(params));
    params.use_latin1_strings = 0;
    params.print_symbolic_assembler = 0;
    params.print_assembler = 0;
    params.meta_name_cb = NULL;
    params.meta_name_cb_context = NULL;
    params.meta_http_equiv_cb = NULL;
    params.meta_http_equiv_cb_context = NULL;
    params.stdout_cb = dev_null;
    params.stderr_cb = dev_null;
    
    compiler = ws_create(&params);
    if (compiler == NULL) {
        panic(0, "WSP: could not create WMLScript compiler");
    }
    
    result = ws_compile_data(compiler, octstr_get_cstr(content->url),
                             (unsigned char *)octstr_get_cstr(content->body),
                             octstr_len(content->body),
                             &result_data, &result_size);
    if (result != WS_OK) {
        warning(0, "WSP: WMLScript compilation failed: %s",
                ws_result_to_string(result));
        wmlscriptc = NULL;
    } else {
        wmlscriptc = octstr_create_from_data((char *)result_data, result_size);
    }
    
    return wmlscriptc;
}

decode_bearer_indication()

static void decode_bearer_indication ( List **  headers, List **  bearer_headers  )

static

Definition at line 1522 of file wap-appl.c.

References debug(), error(), GW_ERROR, gwlist_len(), http_destroy_headers(), http_header_add(), http_header_dump(), http_header_get(), name, octstr_dump, octstr_get_char(), and split_header_list().

Referenced by indicate_push_connection(), and indicate_push_resume().

{
    List *inb;
    Octstr *name, *coded_octstr;
    char *value;
    unsigned char coded_value;

    if (*headers == NULL) {
        debug("wap.appl", 0, "APPL: no client headers, continuing");
        return;
    }

    split_header_list(headers, &inb, "Bearer-Indication");

    if (gwlist_len(inb) == 0) {
        debug("wap.appl.push", 0, "APPL: No bearer indication headers,"
              " continuing");
        http_destroy_headers(inb);
        return;  
    }

    if (gwlist_len(inb) > 1) {
        error(0, "APPL: To many bearer indication header(s), skipping"
              " them");
        http_destroy_headers(inb);
        return;
    }

    http_header_get(inb, 0, &name, &coded_octstr);
    http_destroy_headers(inb);

    /* Greatest assigned number for a bearer type is 0xff, see wdp, appendix C */
    coded_value = octstr_get_char(coded_octstr, 0);
    value = (char *)wsp_bearer_indication_to_cstr(coded_value);

    if (value != NULL && coded_value != 0) {
       http_header_add(*bearer_headers, "Bearer-Indication", value);
       debug("wap.appl.push", 0, "bearer indication header was");
       http_header_dump(*bearer_headers);
       return;
    } else {
       error(0, "APPL: Illegal bearer indication value, skipping:");
       octstr_dump(coded_octstr, 0, GW_ERROR);
       http_destroy_headers(*bearer_headers);
       return;
    }
}

deconvert_content()

static int deconvert_content ( struct content *  content )

static

Definition at line 469 of file wap-appl.c.

References content::body, debug(), deconverters, NUM_DECONVERTERS, octstr_create, octstr_destroy(), octstr_dump, octstr_get_cstr, octstr_len(), octstr_str_compare(), result_type, and content::type.

Referenced by start_fetch().

{
    Octstr *new_body;
    int failed = 0;
    int i;

    debug("wap.deconvert",0,"WSP deconvert: Trying to deconvert:"); 
    octstr_dump(content->body, 0);
    for (i = 0; i < NUM_DECONVERTERS; i++) {
        if (octstr_str_compare(content->type, deconverters[i].type) == 0) {
            debug("wap.deconvert",0,"WSP: Deconverting from <%s> to <%s>", 
                  octstr_get_cstr(content->type), 
            deconverters[i].result_type);
            new_body = deconverters[i].deconvert(content);
            if (new_body != NULL) {
                long s = octstr_len(content->body);
                octstr_destroy(content->body);
                octstr_destroy(content->type);
                content->body = new_body;
                content->type = octstr_create(deconverters[i].result_type);
                debug("wap.convert",0,"WSP: Content-type is "
                      "now <%s>, size %ld bytes (before: %ld bytes), content body is:", 
                deconverters[i].result_type, octstr_len(new_body), s);
                octstr_dump(new_body, 0);
                return 1;
            }
            debug("wap.deconvert",0,"WSP: Content convertion failed!");
            failed = 1;
        }
    }
    
    return (failed ? -1 : 0);
}

deconvert_multipart_formdata()

static Octstr * deconvert_multipart_formdata ( struct content *  content )

static

Definition at line 1399 of file wap-appl.c.

References content::body, and mime_decompile().

{
    Octstr *mime;
   
    if ((mime_decompile(content->body, &mime)) == 0)
        return mime;

    return NULL;
}

dev_null()

static void dev_null ( const char *  data, size_t  len, void *  context  )

static

Definition at line 1310 of file wap-appl.c.

Referenced by convert_wmlscript_to_wmlscriptc().

{
    /* nothing */
}

get_referer_url()

static Octstr* get_referer_url ( const WSPMachine *  sm )

static

Definition at line 685 of file wap-appl.c.

Referenced by return_reply().

{
    return sm ? sm->referer_url : NULL;
}

indicate_push_abort()

static void indicate_push_abort ( WAPEvent *  e )

static

Definition at line 1659 of file wap-appl.c.

References debug(), WAPEvent::u, wap_event_create, and wap_push_ppg_dispatch_event().

Referenced by main_thread().

{
    WAPEvent *ppg_event;

    ppg_event = wap_event_create(Po_PushAbort_Ind);
    ppg_event->u.Po_PushAbort_Ind.push_id = e->u.S_PushAbort_Ind.push_id;
    ppg_event->u.Po_PushAbort_Ind.reason = e->u.S_PushAbort_Ind.reason;
    ppg_event->u.Po_PushAbort_Ind.session_handle = 
        e->u.S_PushAbort_Ind.session_id;

    debug("wap.push.ota", 0, "OTA: making push abort indication for ppg");
    wap_push_ppg_dispatch_event(ppg_event);
}

indicate_push_connection()

static void indicate_push_connection ( WAPEvent *  e )

static

Definition at line 1589 of file wap-appl.c.

References check_application_headers(), debug(), decode_bearer_indication(), gwlist_len(), http_create_empty_headers(), http_destroy_headers(), http_header_duplicate(), WAPEvent::u, wap_addr_tuple_duplicate(), wap_event_create, wap_push_ppg_dispatch_event(), and wsp_cap_duplicate_list().

Referenced by main_thread().

{
    WAPEvent *ppg_event;
    List *push_headers, *application_headers, *bearer_headers;

    push_headers = http_header_duplicate(e->u.S_Connect_Ind.client_headers);
    application_headers = http_create_empty_headers();
    bearer_headers = http_create_empty_headers();
    
    ppg_event = wap_event_create(Pom_Connect_Ind);
    ppg_event->u.Pom_Connect_Ind.addr_tuple = 
        wap_addr_tuple_duplicate(e->u.S_Connect_Ind.addr_tuple);
    ppg_event->u.Pom_Connect_Ind.requested_capabilities = 
        wsp_cap_duplicate_list(e->u.S_Connect_Ind.requested_capabilities);

    check_application_headers(&push_headers, &application_headers);
    ppg_event->u.Pom_Connect_Ind.accept_application = application_headers;

    decode_bearer_indication(&push_headers, &bearer_headers);

    if (gwlist_len(bearer_headers) == 0) {
        http_destroy_headers(bearer_headers);
        ppg_event->u.Pom_Connect_Ind.bearer_indication = NULL;
    } else
        ppg_event->u.Pom_Connect_Ind.bearer_indication = bearer_headers;

    ppg_event->u.Pom_Connect_Ind.push_headers = push_headers;
    ppg_event->u.Pom_Connect_Ind.session_id = e->u.S_Connect_Ind.session_id;
    debug("wap.appl", 0, "APPL: making OTA connection indication to PPG");

    wap_push_ppg_dispatch_event(ppg_event);
}

indicate_push_disconnect()

static void indicate_push_disconnect ( WAPEvent *  e )

static

Definition at line 1623 of file wap-appl.c.

References octstr_duplicate, WAPEvent::u, wap_event_create, and wap_push_ppg_dispatch_event().

Referenced by main_thread().

{
    WAPEvent *ppg_event;

    ppg_event = wap_event_create(Pom_Disconnect_Ind);
    ppg_event->u.Pom_Disconnect_Ind.reason_code = 
        e->u.S_Disconnect_Ind.reason_code;
    ppg_event->u.Pom_Disconnect_Ind.error_headers =
        octstr_duplicate(e->u.S_Disconnect_Ind.error_headers);
    ppg_event->u.Pom_Disconnect_Ind.error_body =
        octstr_duplicate(e->u.S_Disconnect_Ind.error_body);
    ppg_event->u.Pom_Disconnect_Ind.session_handle =
        e->u.S_Disconnect_Ind.session_handle;

    wap_push_ppg_dispatch_event(ppg_event);
}

indicate_push_resume()

static void indicate_push_resume ( WAPEvent *  e )

static

Definition at line 1690 of file wap-appl.c.

References decode_bearer_indication(), gwlist_len(), http_create_empty_headers(), http_destroy_headers(), http_header_duplicate(), WAPEvent::u, wap_addr_tuple_duplicate(), wap_event_create, and wap_push_ppg_dispatch_event().

Referenced by main_thread().

{
    WAPEvent *ppg_event;
    List *push_headers, *bearer_headers;

    push_headers = http_header_duplicate(e->u.S_Resume_Ind.client_headers);
    bearer_headers = http_create_empty_headers();
    
    ppg_event = wap_event_create(Pom_Resume_Ind);
    ppg_event->u.Pom_Resume_Ind.addr_tuple = wap_addr_tuple_duplicate(
        e->u.S_Resume_Ind.addr_tuple);
   
    decode_bearer_indication(&push_headers, &bearer_headers);

    if (gwlist_len(bearer_headers) == 0) {
        http_destroy_headers(bearer_headers);
        ppg_event->u.Pom_Resume_Ind.bearer_indication = NULL;
    } else 
        ppg_event->u.Pom_Resume_Ind.bearer_indication = bearer_headers;

    ppg_event->u.Pom_Resume_Ind.client_headers = push_headers;
    ppg_event->u.Pom_Resume_Ind.session_id = e->u.S_Resume_Ind.session_id;

    wap_push_ppg_dispatch_event(ppg_event);
}

indicate_push_suspend()

static void indicate_push_suspend ( WAPEvent *  e )

static

Definition at line 1674 of file wap-appl.c.

References WAPEvent::u, wap_event_create, and wap_push_ppg_dispatch_event().

Referenced by main_thread().

{
    WAPEvent *ppg_event;

    ppg_event = wap_event_create(Pom_Suspend_Ind);
    ppg_event->u.Pom_Suspend_Ind.reason = e->u.S_Suspend_Ind.reason;
    ppg_event->u.Pom_Suspend_Ind.session_id =  e->u.S_Suspend_Ind.session_id;

    wap_push_ppg_dispatch_event(ppg_event);
}

main_thread()

static void main_thread ( void *  arg )

static

Definition at line 314 of file wap-appl.c.

References confirm_push(), gwlist_consume(), have_ppg, indicate_push_abort(), indicate_push_connection(), indicate_push_disconnect(), indicate_push_resume(), indicate_push_suspend(), negotiate_capabilities(), panic, queue, response_push_connection(), run_status, running, start_fetch(), WAPEvent::type, WAPEvent::u, wap_event_create, wap_event_destroy(), wap_event_name(), wap_push_ppg_have_push_session_for(), wap_push_ppg_have_push_session_for_sid(), and wsp_session_dispatch_event().

Referenced by wap_appl_init(), and wap_appl_shutdown().

{
    WAPEvent *ind, *res;
    long sid;
    WAPAddrTuple *tuple;
    
    while (run_status == running && (ind = gwlist_consume(queue)) != NULL) {
    switch (ind->type) {
    case S_MethodInvoke_Ind:
        res = wap_event_create(S_MethodInvoke_Res);
        res->u.S_MethodInvoke_Res.server_transaction_id =
            ind->u.S_MethodInvoke_Ind.server_transaction_id;
        res->u.S_MethodInvoke_Res.session_id =
        ind->u.S_MethodInvoke_Ind.session_id;
        wsp_session_dispatch_event(res);
        start_fetch(ind);
        break;
    
    case S_Unit_MethodInvoke_Ind:
        start_fetch(ind);
        break;

    case S_Connect_Ind:
        tuple  = ind->u.S_Connect_Ind.addr_tuple;
        if (have_ppg && wap_push_ppg_have_push_session_for(tuple)) {
            indicate_push_connection(ind);
        } else {
            res = wap_event_create(S_Connect_Res);
            /* FIXME: Not yet used by WSP layer */
            res->u.S_Connect_Res.server_headers = NULL;
            res->u.S_Connect_Res.negotiated_capabilities =
                negotiate_capabilities(ind->u.S_Connect_Ind.requested_capabilities);
            res->u.S_Connect_Res.session_id = 
                   ind->u.S_Connect_Ind.session_id;
            wsp_session_dispatch_event(res);
        }
        wap_event_destroy(ind);
        break;
    
    case S_Disconnect_Ind:
        sid = ind->u.S_Disconnect_Ind.session_handle;
        if (have_ppg && wap_push_ppg_have_push_session_for_sid(sid)) 
            indicate_push_disconnect(ind);
        wap_event_destroy(ind);
        break;

    case S_Suspend_Ind:
        sid = ind->u.S_Suspend_Ind.session_id;
        if (have_ppg && wap_push_ppg_have_push_session_for_sid(sid)) 
            indicate_push_suspend(ind);
        wap_event_destroy(ind);
        break;

    case S_Resume_Ind:
        sid = ind->u.S_Resume_Ind.session_id;
        if (have_ppg && wap_push_ppg_have_push_session_for_sid(sid)) {
            indicate_push_resume(ind);
        } else {
            res = wap_event_create(S_Resume_Res);
            res->u.S_Resume_Res.server_headers = NULL;
            res->u.S_Resume_Res.session_id = ind->u.S_Resume_Ind.session_id;
            wsp_session_dispatch_event(res);
        }
        wap_event_destroy(ind);
        break;
    
    case S_MethodResult_Cnf:
        wap_event_destroy(ind);
        break;

    case S_ConfirmedPush_Cnf:
        confirm_push(ind);
        wap_event_destroy(ind);
        break;
    
    case S_MethodAbort_Ind:
        /* XXX Interrupt the fetch thread somehow */
        wap_event_destroy(ind);
        break;

    case S_PushAbort_Ind:
        indicate_push_abort(ind);
        wap_event_destroy(ind);
        break;

    case Pom_Connect_Res:
        response_push_connection(ind);
        wap_event_destroy(ind);
        break;
    
    default:
        panic(0, "WAP-APPL: Can't handle %s event", 
              wap_event_name(ind->type));
        break;
    } /* switch */
    } /* while */
}

negotiate_capabilities()

static List * negotiate_capabilities ( List *  req_caps )

static

Definition at line 1439 of file wap-appl.c.

References gwlist_create.

Referenced by main_thread().

{
    /* Currently we don't know or care about any capabilities,
     * though it is likely that "Extended Methods" will be
     * the first. */
    return gwlist_create();
}

normalize_charset()

static void normalize_charset ( struct content *  content, List *  device_headers  )

static

Definition at line 729 of file wap-appl.c.

References content::body, charset, content::charset, charset_convert(), debug(), find_charset_encoding(), http_charset_accepted(), octstr_case_compare(), octstr_create, octstr_destroy(), octstr_duplicate, octstr_get_cstr, octstr_imm(), octstr_len(), and warning().

Referenced by return_reply().

{
    Octstr* charset;

    if ((charset = find_charset_encoding(content->body)) == NULL) {
        if (octstr_len(content->charset) > 0) {
            charset = octstr_duplicate(content->charset);
        } else {
            charset = octstr_imm("UTF-8");
        }
    }

    debug("wap-appl",0,"Normalizing charset from %s", octstr_get_cstr(charset));

    if (octstr_case_compare(charset, octstr_imm("UTF-8")) != 0 &&
      !http_charset_accepted(device_headers, octstr_get_cstr(charset))) {
        if (!http_charset_accepted(device_headers, "UTF-8")) {
            warning(0, "WSP: Device doesn't support charset <%s> neither UTF-8",
              octstr_get_cstr(charset));
        } else {
            debug("wsp",0,"Converting wml/xhtml from charset <%s> to UTF-8",
              octstr_get_cstr(charset));
            if (charset_convert(content->body,
              octstr_get_cstr(charset), "UTF-8") >= 0) {
                octstr_destroy(content->charset);
                content->charset = octstr_create("UTF-8");
            }
        }
    }
    octstr_destroy(charset);
}

response_push_connection()

static void response_push_connection ( WAPEvent *  e )

static

Definition at line 1721 of file wap-appl.c.

References debug(), gw_assert(), WAPEvent::type, WAPEvent::u, wap_event_create, wsp_cap_duplicate_list(), and wsp_session_dispatch_event().

Referenced by main_thread().

{
    WAPEvent *wsp_event;

    gw_assert(e->type = Pom_Connect_Res);

    wsp_event = wap_event_create(S_Connect_Res);
    wsp_event->u.S_Connect_Res.session_id = e->u.Pom_Connect_Res.session_id;
    wsp_event->u.S_Connect_Res.negotiated_capabilities =
        wsp_cap_duplicate_list(e->u.Pom_Connect_Res.negotiated_capabilities);
    debug("wap.appl", 0, "APPL: making push connect response");

    wsp_session_dispatch_event(wsp_event);
}

return_replies_thread()

static void return_replies_thread ( void *  arg )

static

Definition at line 1066 of file wap-appl.c.

References content::body, caller, request_data::client_SDU_size, request_data::event, http_destroy_headers(), http_receive_result, request_data::method, request_data::msisdn, octstr_destroy(), request_data::request_headers, return_reply(), run_status, running, request_data::session_id, request_data::url, wap_event_destroy(), and request_data::x_wap_tod.

Referenced by wap_appl_init(), and wap_appl_shutdown().

{
    Octstr *body;
    struct request_data *p;
    int status;
    Octstr *final_url;
    List *headers;

    while (run_status == running) {

        p = http_receive_result(caller, &status, &final_url, &headers, &body);
        if (p == NULL)
            break;

        return_reply(status, body, headers, p->client_SDU_size,
                     p->event, p->session_id, p->method, p->url, p->x_wap_tod,
                     p->request_headers, p->msisdn);

        wap_event_destroy(p->event);
        http_destroy_headers(p->request_headers);
        octstr_destroy(p->msisdn);
        gw_free(p);
        octstr_destroy(final_url);
    }
}

return_reply()

static void return_reply ( int  status, Octstr *  content_body, List *  headers, long  sdu_size, WAPEvent *  orig_event, long  session_id, Octstr *  method, Octstr *  url, int  x_wap_tod, List *  request_headers, Octstr *  msisdn  )

static

Definition at line 764 of file wap-appl.c.

References add_x_wap_tod(), addr_tuple, alog(), content::body, content::charset, convert_content(), counter_decrease(), debug(), device_home, error(), error_converting(), error_requesting(), error_requesting_back(), fetches, find_session_machine_by_id(), get_cookies(), get_referer_url(), gwlist_create, HTTP_BAD_GATEWAY, http_create_empty_headers(), http_destroy_headers(), http_header_combine(), http_header_get_content_type(), http_header_mark_transformation(), http_header_remove_all(), http_header_value(), HTTP_NOT_ACCEPTABLE, HTTP_OK, http_remove_hop_headers(), http_status_class(), HTTP_STATUS_SUCCESSFUL, http_type_accepted(), method, normalize_charset(), octstr_compare(), octstr_create, octstr_destroy(), octstr_get_cstr, octstr_imm(), octstr_len(), octstr_search(), return_session_reply(), return_unit_reply(), server(), set_referer_url(), WAPEvent::type, content::type, WAPEvent::u, url, content::url, content::version, warning(), and wsp_smart_errors.

Referenced by return_replies_thread(), and start_fetch().

{
    struct content content;
    int converted;
    WSPMachine *sm;
    List *device_headers, *t_headers;
    WAPAddrTuple *addr_tuple;
    Octstr *ua, *server;

    content.url = url;
    content.body = content_body;
    content.version = content.type = content.charset = NULL;
    server = ua = NULL;

    /* Get session machine for this session. If this was a connection-less
     * request be obviously will not find any session machine entry. */
    sm = find_session_machine_by_id(session_id);

    device_headers = gwlist_create();

    /* ensure we pass only the original headers to the convertion routine */
    t_headers = (orig_event->type == S_MethodInvoke_Ind) ?
        orig_event->u.S_MethodInvoke_Ind.session_headers :
        NULL;
    if (t_headers != NULL) http_header_combine(device_headers, t_headers);
    t_headers = (orig_event->type == S_MethodInvoke_Ind) ?
        orig_event->u.S_MethodInvoke_Ind.request_headers :
        orig_event->u.S_Unit_MethodInvoke_Ind.request_headers;
    if (t_headers != NULL) http_header_combine(device_headers, t_headers);

    /* 
     * We are acting as a proxy. Hence ensure we log a correct HTTP response
     * code to our access-log file to allow identification of failed proxying
     * requests in the main accesss-log.
     */
    /* get client IP and User-Agent identifier */
    addr_tuple = (orig_event->type == S_MethodInvoke_Ind) ?
        orig_event->u.S_MethodInvoke_Ind.addr_tuple : 
        orig_event->u.S_Unit_MethodInvoke_Ind.addr_tuple;
    ua = http_header_value(request_headers, octstr_imm("User-Agent"));

    if (headers != NULL) {
        /* get response content type and Server identifier */
        http_header_get_content_type(headers, &content.type, &content.charset);
        server = http_header_value(headers, octstr_imm("Server"));
    }

    /* log the access */
    /* XXX make this configurable in the future */
    alog("%s %s %s <%s> (%s, charset='%s') %ld %d <%s> <%s>", 
         octstr_get_cstr(addr_tuple->remote->address), 
         msisdn ? octstr_get_cstr(msisdn) : "-",         
         octstr_get_cstr(method), octstr_get_cstr(url), 
         content.type ? octstr_get_cstr(content.type) : "", 
         content.charset ? octstr_get_cstr(content.charset) : "",
         octstr_len(content.body), status < 0 ? HTTP_BAD_GATEWAY : status,
         ua ? octstr_get_cstr(ua) : "",
         server ? octstr_get_cstr(server) : "");

    octstr_destroy(ua);
    octstr_destroy(server);
    

    if (status < 0) {
        error(0, "WSP: HTTP lookup failed, oops.");
        /* smart WSP error messaging?! */
        if (wsp_smart_errors) {
            Octstr *referer_url;
            status = HTTP_OK;
            content.type = octstr_create("text/vnd.wap.wml");
            content.charset = octstr_create("");
            /*
             * check if a referer for this URL exists and 
             * get back to the previous page in this case
             */
            if ((referer_url = get_referer_url(find_session_machine_by_id(session_id)))) {
                content.body = error_requesting_back(url, referer_url);
                debug("wap.wsp",0,"WSP: returning smart error WML deck for referer URL");
            } 
            /*
             * if there is no referer to retun to, check if we have a
             * device-home defined and return to that, otherwise simply
             * drop an error wml deck.
             */
            else if (device_home != NULL) {
                content.body = error_requesting_back(url, device_home);
                debug("wap.wsp",0,"WSP: returning smart error WML deck for device-home URL");
            } else {
                content.body = error_requesting(url);
                debug("wap.wsp",0,"WSP: returning smart error WML deck");
            }

            /* 
             * if we did not connect at all there is no content in 
             * the headers list, so create for the upcoming transformation
             */
            if (headers == NULL)
                headers = http_create_empty_headers();

            converted = convert_content(&content, device_headers, 0);
            if (converted == 1)
                http_header_mark_transformation(headers, content.body, content.type);

        } else {
            /* no WSP smart error messaging */
            status = HTTP_BAD_GATEWAY;
            content.type = octstr_create("text/plain");
            content.charset = octstr_create("");
            content.body = octstr_create("");
        }

    } else {
        /* received response by HTTP server */
 
#ifdef ENABLE_COOKIES
        if (session_id != -1)
            if (get_cookies(headers, find_session_machine_by_id(session_id)) == -1)
                error(0, "WSP: Failed to extract cookies");
#endif

        /* 
         * XXX why do we transcode charsets on the content body here?!
         * Why is this not in the scope of the HTTP server, rather
         * then doing this inside Kannel?! st. 
         */

        /* 
         * Adapts content body's charset to device.
         * If device doesn't support body's charset but supports UTF-8, this 
         * block tries to convert body to UTF-8. 
         * (This is required for Sharp GX20 for example)
         */
        if (octstr_search(content.type, octstr_imm("text/vnd.wap.wml"), 0) >= 0 || 
            octstr_search(content.type, octstr_imm("application/xhtml+xml"), 0) >= 0 ||
            octstr_search(content.type, octstr_imm("application/vnd.wap.xhtml+xml"), 0) >= 0) {

            normalize_charset(&content, device_headers);
        }

        /* set WBXML Encoding-Version for wml->wmlc conversion */
        if (sm != NULL) {
            content.version = http_header_value(sm->http_headers, 
                                                octstr_imm("Encoding-Version"));
        } else {
            content.version = NULL;
        }

        /* convert content-type by our own converter table */
        converted = convert_content(&content, device_headers, 
                                    octstr_compare(method, octstr_imm("HEAD")) == 0);
        if (converted < 0) {
            warning(0, "WSP: All converters for `%s' at `%s' failed.",
                    octstr_get_cstr(content.type), octstr_get_cstr(url));

            /* 
             * Don't change status; just send the client what we did get.
             * Or if smart error messages are configured, send a wmlc deck
             * with accurate information.
             */
            if (wsp_smart_errors) {
                octstr_destroy(content.body);
                octstr_destroy(content.charset);
                content.body = error_converting(url, content.type);
                content.charset = octstr_create("UTF-8");
                
                debug("wap.wsp",0,"WSP: returning smart error WML deck for failed converters");

                converted = convert_content(&content, device_headers, 0);
                if (converted == 1)
                    http_header_mark_transformation(headers, content.body, content.type);

            }
        }
        else if (converted == 1) {
            http_header_mark_transformation(headers, content.body, content.type);

            /* 
             * set referer URL to WSPMachine, but only if this was a converted
             * content-type, like .wml
             */
            if (session_id != -1) {
                debug("wap.wsp.http",0,"WSP: Setting Referer URL to <%s>", 
                      octstr_get_cstr(url));
                if ((sm = find_session_machine_by_id(session_id)) != NULL) {
                    set_referer_url(url, sm);
                } else {
                    error(0,"WSP: Failed to find session machine for ID %ld",
                          session_id);
                }
            }
        }

        /* if converted == 0 then we pass the content wihtout modification */
    }

    if (headers == NULL)
        headers = http_create_empty_headers();
    http_remove_hop_headers(headers);
    http_header_remove_all(headers, "X-WAP.TOD");
    if (x_wap_tod)
        add_x_wap_tod(headers);

    if (content.body == NULL)
        content.body = octstr_create("");
   
    /*
     * Deal with otherwise wap-aware servers that return text/html error
     * messages if they report an error.
     * (Normally we leave the content type alone even if the client doesn't
     * claim to accept it, because the server might know better than the
     * gateway.)
     */
    if (http_status_class(status) != HTTP_STATUS_SUCCESSFUL &&
        !http_type_accepted(request_headers, octstr_get_cstr(content.type))) {
        warning(0, "WSP: Content type <%s> not supported by client,"
                   " deleting body.", octstr_get_cstr(content.type));
        octstr_destroy(content.body);
        content.body = octstr_create("");
        octstr_destroy(content.type);
        content.type = octstr_create("text/plain");
        http_header_mark_transformation(headers, content.body, content.type);
    }
    /* remove body if request method was HEAD, we act strictly here */
    else if (octstr_compare(method, octstr_imm("HEAD")) == 0) {
        octstr_destroy(content.body);
        content.body = octstr_create("");
        /* change to text/plain if received content-type is not accepted */
        if (!http_type_accepted(request_headers, "*/*") &&
            !http_type_accepted(request_headers, octstr_get_cstr(content.type))) {
            octstr_destroy(content.type);
            content.type = octstr_create("text/plain");
        }
        debug("wsp",0,"WSP: HEAD request, removing body, content-type is now <%s>", 
              octstr_get_cstr(content.type));
        http_header_mark_transformation(headers, content.body, content.type);
    }

#ifdef ENABLE_NOT_ACCEPTED 
    /* Returns HTTP response 406 if content-type is not supported by device */
    else if (request_headers && content.type &&
             !http_type_accepted(request_headers, octstr_get_cstr(content.type)) &&
             !http_type_accepted(request_headers, "*/*")) {
        warning(0, "WSP: content-type <%s> not supported", 
                octstr_get_cstr(content.type));
        status = HTTP_NOT_ACCEPTABLE;
        octstr_destroy(content.type);
        content.type = octstr_create("text/plain");
        octstr_destroy(content.charset);
        octstr_destroy(content.body);
        content.charset = octstr_create("");
        content.body = octstr_create("");
        http_header_mark_transformation(headers, content.body, content.type);
    }
#endif

    /*
     * If the response is too large to be sent to the client,
     * suppress it and inform the client.
     */
    if (octstr_len(content.body) > sdu_size && sdu_size > 0) {
        /*
         * Only change the status if it indicated success.
         * If it indicated an error, then that information is
         * more useful to the client than our "Bad Gateway" would be.
         * The too-large body is probably an error page in html.
         */
        /* XXX add WSP smart messaging here too */
        if (http_status_class(status) == HTTP_STATUS_SUCCESSFUL)
            status = HTTP_BAD_GATEWAY;
        warning(0, "WSP: Entity at %s too large (size %ld B, limit %lu B)",
                octstr_get_cstr(url), octstr_len(content.body), sdu_size);
        octstr_destroy(content.body);
        content.body = octstr_create("");
        http_header_mark_transformation(headers, content.body, content.type);
    }

    if (orig_event->type == S_MethodInvoke_Ind) {
        return_session_reply(orig_event->u.S_MethodInvoke_Ind.server_transaction_id,
                             status, headers, content.body, session_id);
    } else {
        return_unit_reply(orig_event->u.S_Unit_MethodInvoke_Ind.addr_tuple,
                          orig_event->u.S_Unit_MethodInvoke_Ind.transaction_id,
                          status, headers, content.body);
    }

    octstr_destroy(content.version); /* body was re-used above */
    octstr_destroy(content.type); /* body was re-used above */
    octstr_destroy(content.charset);
    octstr_destroy(url);          /* same as content.url */
    http_destroy_headers(device_headers);

    counter_decrease(fetches);
}

return_session_reply()

static void return_session_reply ( long  server_transaction_id, long  status, List *  headers, Octstr *  body, long  session_id  )

static

Definition at line 694 of file wap-appl.c.

References content::body, WAPEvent::u, wap_event_create, and wsp_session_dispatch_event().

Referenced by return_reply().

{
    WAPEvent *e;
    
    e = wap_event_create(S_MethodResult_Req);
    e->u.S_MethodResult_Req.server_transaction_id = server_transaction_id;
    e->u.S_MethodResult_Req.status = status;
    e->u.S_MethodResult_Req.response_headers = headers;
    e->u.S_MethodResult_Req.response_body = body;
    e->u.S_MethodResult_Req.session_id = session_id;
    wsp_session_dispatch_event(e);
}

return_unit_reply()

static void return_unit_reply ( WAPAddrTuple *  tuple, long  transaction_id, long  status, List *  headers, Octstr *  body  )

static

Definition at line 713 of file wap-appl.c.

References content::body, WAPEvent::u, wap_addr_tuple_duplicate(), wap_event_create, and wsp_unit_dispatch_event().

Referenced by return_reply().

{
    WAPEvent *e;

    e = wap_event_create(S_Unit_MethodResult_Req);
    e->u.S_Unit_MethodResult_Req.addr_tuple = 
        wap_addr_tuple_duplicate(tuple);
    e->u.S_Unit_MethodResult_Req.transaction_id = transaction_id;
    e->u.S_Unit_MethodResult_Req.status = status;
    e->u.S_Unit_MethodResult_Req.response_headers = headers;
    e->u.S_Unit_MethodResult_Req.response_body = body;
    wsp_unit_dispatch_event(e);
}

set_referer_url()

static void set_referer_url ( Octstr *  url, WSPMachine *  sm  )

static

Definition at line 675 of file wap-appl.c.

References gw_assert(), octstr_destroy(), octstr_duplicate, and url.

Referenced by return_reply().

{
    gw_assert(url != NULL);
    gw_assert(sm != NULL);

    octstr_destroy(sm->referer_url);
    sm->referer_url = octstr_duplicate(url);
}

split_header_list()

static void split_header_list ( List **  headers, List **  new_headers, char *  name  )

static

Definition at line 1575 of file wap-appl.c.

References http_header_find_all(), http_header_remove_all(), and name.

Referenced by check_application_headers(), and decode_bearer_indication().

{
    if (*headers == NULL)
        return;

    *new_headers = http_header_find_all(*headers, name);
    http_header_remove_all(*headers, name);  
}

start_fetch()

static void start_fetch ( WAPEvent *  event )

static

Definition at line 1103 of file wap-appl.c.

References add_accept_headers(), add_charset_headers(), add_client_sdu_size(), add_kannel_version(), add_msisdn(), add_network_info(), add_session_id(), add_via(), addr_tuple, content::body, caller, content::charset, request_data::client_SDU_size, counter_increase(), deconvert_content(), error(), request_data::event, fetches, find_session_machine_by_id(), gwlist_create, HEALTH_DECK, http_create_empty_headers(), http_destroy_headers(), http_header_add(), http_header_combine(), http_header_get_content_type(), http_header_mark_transformation(), http_header_pack(), http_header_remove_all(), http_name2method(), HTTP_NOT_IMPLEMENTED, HTTP_OK, http_remove_hop_headers(), http_start_request(), info(), method, request_data::method, request_data::msisdn, octstr_compare(), octstr_create, octstr_destroy(), octstr_duplicate, octstr_get_cstr, octstr_imm(), octstr_len(), octstr_str_compare(), radius_acct_get_msisdn(), request_data::request_headers, return_reply(), request_data::session_id, set_cookies(), WAPEvent::type, content::type, url, request_data::url, wap_event_destroy(), wap_map_url(), and request_data::x_wap_tod.

Referenced by main_thread().

{
    int ret;
    long client_SDU_size; /* 0 means no limit */
    Octstr *url;
    List *session_headers;
    List *request_headers;
    List *actual_headers;
    List *resp_headers;
    WAPAddrTuple *addr_tuple;
    long session_id;
    Octstr *content_body;
    Octstr *method;     /* type of request, normally a get or a post */
    Octstr *request_body;
    int x_wap_tod;          /* X-WAP.TOD header was present in request */
    Octstr *magic_url;
    struct request_data *p;
    Octstr *send_msisdn_query, *send_msisdn_header, *send_msisdn_format;
    int accept_cookies;
    Octstr *msisdn;
    
    counter_increase(fetches);
    
    if (event->type == S_MethodInvoke_Ind) {
        struct S_MethodInvoke_Ind *p;
    
        /* WSP, connection orientated */
        p = &event->u.S_MethodInvoke_Ind;
        session_headers = p->session_headers;
        request_headers = p->request_headers;
        url = octstr_duplicate(p->request_uri);
        addr_tuple = p->addr_tuple;
        session_id = p->session_id;
        client_SDU_size = p->client_SDU_size;
        request_body = octstr_duplicate(p->request_body);
        method = p->method;
    } else {
        struct S_Unit_MethodInvoke_Ind *p;
    
        /* WDP, non orientated */
        p = &event->u.S_Unit_MethodInvoke_Ind;
        session_headers = NULL;
        request_headers = p->request_headers;
        url = octstr_duplicate(p->request_uri);
        addr_tuple = p->addr_tuple;
        session_id = -1;
        client_SDU_size = 0; /* No limit */
        request_body = octstr_duplicate(p->request_body);
        method = p->method;
    }

    msisdn = radius_acct_get_msisdn(addr_tuple->remote->address);
    info(0, "Fetching URL <%s> for MSISDN <%s>, IP <%s:%ld>", octstr_get_cstr(url),
         msisdn ? octstr_get_cstr(msisdn) : "", 
         addr_tuple->remote->address ? octstr_get_cstr(addr_tuple->remote->address) : "",
         addr_tuple->remote->port);

    /* 
     * XXX this URL mapping needs to be rebuild! st. 
     */

    /* try to rewrite URL */
    wap_map_url(&url, &send_msisdn_query, &send_msisdn_header,
                &send_msisdn_format, &accept_cookies);
    /* if no mapping found, then use our RADIUS acct proxy header */
    if (send_msisdn_header == NULL)
        send_msisdn_header = octstr_create("X-WAP-Network-Client-MSISDN");

    actual_headers = gwlist_create();
    
    if (session_headers != NULL)
        http_header_combine(actual_headers, session_headers);
    if (request_headers != NULL)
        http_header_combine(actual_headers, request_headers);
    
    x_wap_tod = http_header_remove_all(actual_headers, "X-WAP.TOD");
    add_accept_headers(actual_headers);
    add_charset_headers(actual_headers);
    add_network_info(actual_headers, addr_tuple);
    add_client_sdu_size(actual_headers, client_SDU_size);
    add_via(actual_headers);

#ifdef ENABLE_COOKIES
    /* DAVI: to finish - accept_cookies -1, 
     * use global accept-cookies, 0 = no, 1 = yes ? */
    if (accept_cookies != 0 && (session_id != -1) &&  
        /* DAVI (set_cookies(url, actual_headers, 
                             find_session_machine_by_id(session_id)) == -1)) */
        (set_cookies(actual_headers, find_session_machine_by_id(session_id)) == -1)) 
        error(0, "WSP: Failed to add cookies");
#endif

    /* set referer URL to HTTP header from WSPMachine */
    /* 
     * XXX This makes Open Group's test suite wml/events/tasks/go/5 failing, 
     * which requires that device is *not* sending referer, but Kannel drops
     * it in. We have to remove this for now.
     */
    /*
    if (session_id != -1) {
        if ((referer_url = get_referer_url(find_session_machine_by_id(session_id))) != NULL) {
            add_referer_url(actual_headers, referer_url);
        }
    }
    */
    
    add_kannel_version(actual_headers);
    add_session_id(actual_headers, session_id);

    add_msisdn(actual_headers, addr_tuple, send_msisdn_header);
    octstr_destroy(send_msisdn_query);
    octstr_destroy(send_msisdn_header);
    octstr_destroy(send_msisdn_format);
    
    http_remove_hop_headers(actual_headers);
    http_header_pack(actual_headers);
    
    magic_url = octstr_imm("kannel:alive");

    /* check if this request is a call for our magic URL */
    if (octstr_str_compare(method, "GET")  == 0 && 
        octstr_compare(url, magic_url) == 0) {
        ret = HTTP_OK;
        resp_headers = gwlist_create();
        http_header_add(resp_headers, "Content-Type", "text/vnd.wap.wml");
        content_body = octstr_create(HEALTH_DECK);
        octstr_destroy(request_body);
        return_reply(ret, content_body, resp_headers, client_SDU_size,
                     event, session_id, method, url, x_wap_tod, actual_headers,
                     msisdn);
        wap_event_destroy(event);
        http_destroy_headers(actual_headers);
        octstr_destroy(msisdn);
    } 
    /* otherwise it should be a GET, POST or HEAD request type */
    else if (octstr_str_compare(method, "GET") == 0 ||
             octstr_str_compare(method, "POST") == 0 ||
             octstr_str_compare(method, "HEAD") == 0) {

        /* we don't allow a body within a GET or HEAD request */
        if (request_body != NULL && (octstr_str_compare(method, "GET") == 0 ||
                                     octstr_str_compare(method, "HEAD") == 0)) {
            octstr_destroy(request_body);
            request_body = NULL;
        }

        /* 
         * Call deconvert_content() here for transformations of binary
         * encoded POST requests from the client into plain text decoded
         * POST requests for the HTTP server.
         * Mainly this is used for multipart/form-data transmissions,
         * including MMS on-the-fly message decoding.
         * When we are doing mms, the phone POSTs contents and acknowled-
         * gements. In this case, we dont do not deconvert anything.
         */
        if (octstr_str_compare(method, "POST") == 0 && request_body && 
            octstr_len(request_body)) {
            struct content content;
            int converted;

            http_header_get_content_type(actual_headers, &content.type, 
                                         &content.charset);
            content.body = request_body;
            converted = deconvert_content(&content); 
            if (converted == 1) 
                http_header_mark_transformation(actual_headers, content.body, 
                                                content.type);
            request_body = content.body;
            octstr_destroy(content.type);
            octstr_destroy(content.charset);
        }

        /* struct that is used for the HTTP response identifier */
        p = gw_malloc(sizeof(*p));
        p->client_SDU_size = client_SDU_size;
        p->event = event;
        p->session_id = session_id;
        p->method = method;
        p->url = url;
        p->x_wap_tod = x_wap_tod;
        p->request_headers = actual_headers;
        p->msisdn = msisdn;

        /* issue the request to the HTTP server */
        http_start_request(caller, http_name2method(method), url, actual_headers, 
                           request_body, 0, p, NULL);

        octstr_destroy(request_body);
    } 
    /* we don't support the WSP/HTTP method the client asked us */
    else {
        error(0, "WSP: Method %s not supported.", octstr_get_cstr(method));
        content_body = octstr_create("");
        resp_headers = http_create_empty_headers();
        ret = HTTP_NOT_IMPLEMENTED;
        octstr_destroy(request_body);
        return_reply(ret, content_body, resp_headers, client_SDU_size,
                     event, session_id, method, url, x_wap_tod, actual_headers,
                     msisdn);
        wap_event_destroy(event);
        http_destroy_headers(actual_headers);
        octstr_destroy(msisdn);
    }
}

wap_appl_dispatch()

void wap_appl_dispatch

(

WAPEvent *

event

)

Definition at line 288 of file wap-appl.c.

References gw_assert(), gwlist_produce(), queue, run_status, and running.

Referenced by main().

{
    gw_assert(run_status == running);
    gwlist_produce(queue, event);
}

wap_appl_get_load()

long wap_appl_get_load

(

void

)

Definition at line 295 of file wap-appl.c.

References counter_value(), fetches, gw_assert(), gwlist_len(), queue, run_status, and running.

Referenced by main().

{
    gw_assert(run_status == running);
    return counter_value(fetches) + gwlist_len(queue);
}

wap_appl_init()

void wap_appl_init

(

Cfg *

cfg

)

Definition at line 249 of file wap-appl.c.

References caller, cfg, charsets, counter_create(), fetches, gw_assert(), gwlist_add_producer(), gwlist_create, gwthread_create, have_ppg, http_caller_create(), limbo, main_thread(), queue, return_replies_thread(), run_status, running, and wml_charsets().

Referenced by main().

{
    gw_assert(run_status == limbo);
    queue = gwlist_create();
    fetches = counter_create();
    gwlist_add_producer(queue);
    run_status = running;
    charsets = wml_charsets();
    caller = http_caller_create();
    gwthread_create(main_thread, NULL);
    gwthread_create(return_replies_thread, NULL);

    if (cfg != NULL)
        have_ppg = 1;
    else
        have_ppg = 0;
}

wap_appl_shutdown()

void wap_appl_shutdown

(

void

)

Definition at line 268 of file wap-appl.c.

References caller, charsets, counter_destroy(), fetches, gw_assert(), gwlist_destroy(), gwlist_remove_producer(), gwthread_join_every(), http_caller_destroy(), http_caller_signal_shutdown(), main_thread(), octstr_destroy_item(), queue, return_replies_thread(), run_status, running, terminating, wap_event_destroy_item(), wap_map_destroy(), and wap_map_user_destroy().

Referenced by main().

{
    gw_assert(run_status == running);
    run_status = terminating;
    
    gwlist_remove_producer(queue);
    gwthread_join_every(main_thread);
    
    http_caller_signal_shutdown(caller);
    gwthread_join_every(return_replies_thread);
    
    wap_map_destroy(); 
    wap_map_user_destroy(); 
    http_caller_destroy(caller);
    gwlist_destroy(queue, wap_event_destroy_item);
    gwlist_destroy(charsets, octstr_destroy_item);
    counter_destroy(fetches);
}

Variable Documentation

caller

HTTPCaller* caller = NULL

static

Definition at line 129 of file wap-appl.c.

Referenced by return_replies_thread(), start_fetch(), wap_appl_init(), and wap_appl_shutdown().

charsets

List* charsets = NULL

static

Definition at line 141 of file wap-appl.c.

Referenced by wap_appl_init(), and wap_appl_shutdown().

convert

Octstr*(* convert) (struct content *)

Definition at line 198 of file wap-appl.c.

converters

struct { ... } converters[]

Initial value:

= {
    { "text/vnd.wap.wml",
      "application/vnd.wap.wmlc",
      convert_wml_to_wmlc },
    { "text/vnd.wap.wmlscript",
      "application/vnd.wap.wmlscriptc",
      convert_wmlscript_to_wmlscriptc },

}

Referenced by add_accept_headers(), and convert_content().

deconvert

Octstr*(* deconvert) (struct content *)

Definition at line 217 of file wap-appl.c.

deconverters

struct { ... } deconverters[]

Initial value:

= {
    { "application/vnd.wap.multipart.form-data",
      "multipart/form-data; boundary=kannel_boundary",
      deconvert_multipart_formdata },

}

Referenced by deconvert_content().

device_home

Octstr* device_home

Definition at line 112 of file wapbox.c.

Referenced by config_reload(), main(), and return_reply().

fetches

Counter* fetches = NULL

static

Definition at line 135 of file wap-appl.c.

Referenced by return_reply(), start_fetch(), wap_appl_get_load(), wap_appl_init(), and wap_appl_shutdown().

have_ppg

int have_ppg = 0

static

Definition at line 176 of file wap-appl.c.

Referenced by main_thread(), and wap_appl_init().

queue

List* queue = NULL

static

Definition at line 123 of file wap-appl.c.

Referenced by downheap(), gw_prioqueue_add_producer(), gw_prioqueue_consume(), gw_prioqueue_destroy(), gw_prioqueue_foreach(), gw_prioqueue_get(), gw_prioqueue_insert(), gw_prioqueue_len(), gw_prioqueue_producer_count(), gw_prioqueue_remove(), gw_prioqueue_remove_producer(), main(), main_thread(), make_bigger(), queue_lock(), queue_unlock(), upheap(), wap_appl_dispatch(), wap_appl_get_load(), wap_appl_init(), and wap_appl_shutdown().

result_type

char* result_type

Definition at line 197 of file wap-appl.c.

Referenced by add_accept_headers(), convert_content(), and deconvert_content().

run_status

enum { ... } run_status

Referenced by main_thread(), return_replies_thread(), wap_appl_dispatch(), wap_appl_get_load(), wap_appl_init(), and wap_appl_shutdown().

type

char* type

Definition at line 196 of file wap-appl.c.

Referenced by add_accept_headers().

wsp_smart_errors

int wsp_smart_errors

Definition at line 111 of file wapbox.c.

Referenced by config_reload(), and return_reply().