wap_push_ppg_pushuser.c File Reference

#include "wap_push_ppg_pushuser.h"
#include "numhash.h"
#include "gwlib/gw-regex.h"

Go to the source code of this file.

Data Structures
struct	WAPPushUser
struct	WAPPushUserList

Macros
#define	ADDITION   0.1

Typedefs
typedef struct WAPPushUser	WAPPushUser
typedef struct WAPPushUserList	WAPPushUserList

Enumerations
enum	{ NO_USERNAME = -1, NO_PASSWORD = 0, HEADER_AUTHENTICATION = 1 }

Functions
static void	destroy_users_list (void *l)
static WAPPushUserList *	pushusers_create (long number_of_users)
static WAPPushUser *	create_oneuser (CfgGroup *grp)
static void	destroy_oneuser (void *p)
static int	oneuser_add (CfgGroup *cfg)
static void	oneuser_dump (WAPPushUser *u)
static WAPPushUser *	user_find_by_username (Octstr *username)
static int	password_matches (WAPPushUser *u, Octstr *password)
static int	ip_allowed_by_user (WAPPushUser *u, Octstr *ip)
static int	prefix_allowed (WAPPushUser *u, Octstr *number)
static int	whitelisted (WAPPushUser *u, Octstr *number)
static int	blacklisted (WAPPushUser *u, Octstr *number)
static int	wildcarded_ip_found (Octstr *ip, Octstr *needle, Octstr *ip_sep)
static int	response (List *push_headers, Octstr **username, Octstr **password)
static void	challenge (HTTPClient *c, List *push_headers)
static void	reply (HTTPClient *c, List *push_headers)
static int	parse_cgivars_for_username (List *cgivars, Octstr **username)
static int	parse_cgivars_for_password (List *cgivars, Octstr **password)
static int	compare_octstr_sequence (Octstr *os1, Octstr *os2, long start)
static Octstr *	forced_smsc (WAPPushUser *u)
static Octstr *	default_smsc (WAPPushUser *u)
int	wap_push_ppg_pushuser_list_add (List *list, long number_of_pushes, long number_of_users)
void	wap_push_ppg_pushuser_list_destroy (void)
int	wap_push_ppg_pushuser_authenticate (HTTPClient *c, List *cgivars, Octstr *ip, List *push_headers, Octstr **username)
int	wap_push_ppg_pushuser_client_phone_number_acceptable (Octstr *username, Octstr *number)
int	wap_push_ppg_pushuser_search_ip_from_wildcarded_list (Octstr *haystack, Octstr *needle, Octstr *gwlist_sep, Octstr *ip_sep)
Octstr *	wap_push_ppg_pushuser_smsc_id_get (Octstr *username)
Octstr *	wap_push_ppg_pushuser_dlr_url_get (Octstr *username)
Octstr *	wap_push_ppg_pushuser_smsbox_id_get (Octstr *username)

Variables
static WAPPushUserList *	users = NULL
static Dict *	next_try = NULL

Macro Definition Documentation

ADDITION

#define ADDITION   0.1

Definition at line 192 of file wap_push_ppg_pushuser.c.

Referenced by wap_push_ppg_pushuser_authenticate().

Typedef Documentation

WAPPushUser

typedef struct WAPPushUser WAPPushUser

Definition at line 101 of file wap_push_ppg_pushuser.c.

WAPPushUserList

typedef struct WAPPushUserList WAPPushUserList

Definition at line 112 of file wap_push_ppg_pushuser.c.

Enumeration Type Documentation

anonymous enum

anonymous enum

Enumerator
NO_USERNAME
NO_PASSWORD
HEADER_AUTHENTICATION

Definition at line 186 of file wap_push_ppg_pushuser.c.

     {
    NO_USERNAME = -1,
    NO_PASSWORD = 0,
    HEADER_AUTHENTICATION = 1
};

Function Documentation

blacklisted()

static int blacklisted ( WAPPushUser *  u, Octstr *  number  )

static

Definition at line 977 of file wap_push_ppg_pushuser.c.

References WAPPushUser::black_list, WAPPushUser::black_list_regex, number, and numhash_find_number().

Referenced by wap_push_ppg_pushuser_client_phone_number_acceptable().

{
    int result = 0;
    
    if (u->black_list != NULL)
        result = numhash_find_number(u->black_list, number);

    if ((result == 0) && (u->black_list_regex != NULL))
        result = gw_regex_match_pre(u->black_list_regex, number);

    return result;
}

challenge()

static void challenge ( HTTPClient *  c, List *  push_headers  )

static

Definition at line 839 of file wap_push_ppg_pushuser.c.

References get_official_name(), http_create_empty_headers(), http_destroy_headers(), http_header_add(), http_send_reply(), HTTP_UNAUTHORIZED, octstr_append(), octstr_destroy(), octstr_format(), octstr_format_append(), octstr_get_cstr, and octstr_imm().

Referenced by wap_push_ppg_pushuser_authenticate().

{
    Octstr *challenge,
           *realm;
    int http_status;
    List *reply_headers;

    realm = octstr_format("%s", "Basic realm=");
    octstr_append(realm, get_official_name());
    octstr_format_append(realm, "%s", "\"wappush\"");
    reply_headers = http_create_empty_headers();
    http_header_add(reply_headers, "WWW-Authenticate", octstr_get_cstr(realm));
    http_status = HTTP_UNAUTHORIZED;
    challenge = octstr_imm("You must show your credentials.\n");
    
    http_send_reply(c, http_status, reply_headers, challenge);

    octstr_destroy(realm);
    http_destroy_headers(reply_headers);
}

compare_octstr_sequence()

static int compare_octstr_sequence ( Octstr *  os1, Octstr *  os2, long  start  )

static

Definition at line 1022 of file wap_push_ppg_pushuser.c.

References octstr_delete(), octstr_get_many_chars(), octstr_insert_data(), octstr_len(), octstr_ncompare(), and start.

Referenced by prefix_allowed().

{
    int ret;
    unsigned char *prefix;
    long end;

    if (octstr_len(os2) == 0)
        return 1;

    if (octstr_len(os1) == 0)
        return -1;

    prefix = NULL;
    if (start != 0) {
        prefix = gw_malloc(start);
        octstr_get_many_chars((char *)prefix, os1, 0, start);
        octstr_delete(os1, 0, start);
    }
    
    end = start + octstr_len(os2);
    ret = octstr_ncompare(os1, os2, end - start);
    
    if (start != 0) {
        octstr_insert_data(os1, 0, (char *)prefix, start);
        gw_free(prefix);
    }

    return ret;
}

create_oneuser()

static WAPPushUser * create_oneuser ( CfgGroup *  grp )

static

Definition at line 451 of file wap_push_ppg_pushuser.c.

References WAPPushUser::allowed_prefix, WAPPushUser::allowed_prefix_regex, WAPPushUser::black_list, WAPPushUser::black_list_regex, cfg_get, WAPPushUser::country_prefix, WAPPushUser::default_smsc_id, WAPPushUser::denied_prefix, WAPPushUser::denied_prefix_regex, destroy_oneuser(), WAPPushUser::dlr_url, error(), WAPPushUser::name, numhash_create(), octstr_destroy(), octstr_get_cstr, octstr_imm(), oneuser_dump(), panic, WAPPushUser::password, WAPPushUser::smsbox_id, WAPPushUser::smsc_id, WAPPushUser::user_allow_ip, WAPPushUser::user_deny_ip, WAPPushUser::username, warning(), WAPPushUser::white_list, and WAPPushUser::white_list_regex.

Referenced by oneuser_add().

{
    WAPPushUser *u;
    Octstr *grpname,
           *os;

    grpname = cfg_get(grp, octstr_imm("wap-push-user"));
    if (grpname == NULL) {
        error(0, "all users group (wap-push-user) are missing");
        goto no_grpname;
    }
   
    u = gw_malloc(sizeof(WAPPushUser));
    u->name = NULL;
    u->username = NULL;                  
    u->allowed_prefix = NULL;           
    u->allowed_prefix_regex = NULL;           
    u->denied_prefix = NULL;             
    u->denied_prefix_regex = NULL;             
    u->white_list = NULL;               
    u->white_list_regex = NULL;               
    u->black_list = NULL;              
    u->black_list_regex = NULL;              
    u->user_deny_ip = NULL;              
    u->user_allow_ip = NULL;
    u->smsc_id = NULL;
    u->default_smsc_id = NULL;

    u->name = cfg_get(grp, octstr_imm("wap-push-user"));

    if (u->name == NULL) {
        warning(0, "user name missing, dump follows");
        oneuser_dump(u);
        goto error;
    }

    u->username = cfg_get(grp, octstr_imm("ppg-username"));
    u->password = cfg_get(grp, octstr_imm("ppg-password"));

    if (u->username == NULL) {
        warning(0, "login name for user %s missing, dump follows", 
              octstr_get_cstr(u->name));
        oneuser_dump(u);
        goto error;
    }

    if (u->password == NULL) {
        warning(0, "password for user %s missing, dump follows", 
              octstr_get_cstr(u->name));
        oneuser_dump(u);
        goto error;
    }

    u->user_deny_ip = cfg_get(grp, octstr_imm("deny-ip"));
    u->user_allow_ip = cfg_get(grp, octstr_imm("allow-ip"));
    u->country_prefix = cfg_get(grp, octstr_imm("country-prefix"));
    u->allowed_prefix = cfg_get(grp, octstr_imm("allowed-prefix"));
    u->denied_prefix = cfg_get(grp, octstr_imm("denied-prefix"));
    u->smsc_id = cfg_get(grp, octstr_imm("forced-smsc"));
    u->default_smsc_id = cfg_get(grp, octstr_imm("default-smsc"));
    u->dlr_url = cfg_get(grp, octstr_imm("dlr-url"));
    u->smsbox_id = cfg_get(grp, octstr_imm("smsbox-id"));

    os = cfg_get(grp, octstr_imm("white-list"));
    if (os != NULL) {
        u->white_list = numhash_create(octstr_get_cstr(os));
        octstr_destroy(os);
    }
    os = cfg_get(grp, octstr_imm("black-list"));
    if (os != NULL) {
        u->black_list = numhash_create(octstr_get_cstr(os));
        octstr_destroy(os);
    }

    if ((os = cfg_get(grp, octstr_imm("allowed-prefix-regex"))) != NULL) {
        if ((u->allowed_prefix_regex = gw_regex_comp(os, REG_EXTENDED)) == NULL)
            panic(0, "Could not compile pattern '%s'", octstr_get_cstr(os));
        octstr_destroy(os);
    };
    if ((os = cfg_get(grp, octstr_imm("denied-prefix-regex"))) != NULL) {
        if ((u->denied_prefix_regex = gw_regex_comp(os, REG_EXTENDED)) == NULL)
            panic(0, "Could not compile pattern '%s'", octstr_get_cstr(os));
        octstr_destroy(os);
    };
    if ((os = cfg_get(grp, octstr_imm("white-list-regex"))) != NULL) {
        if ((u->white_list_regex = gw_regex_comp(os, REG_EXTENDED)) == NULL)
            panic(0, "Could not compile pattern '%s'", octstr_get_cstr(os));
        octstr_destroy(os);
    };
    if ((os = cfg_get(grp, octstr_imm("black-list-regex"))) != NULL) {
        if ((u->black_list_regex = gw_regex_comp(os, REG_EXTENDED)) == NULL)
            panic(0, "Could not compile pattern '%s'", octstr_get_cstr(os));
        octstr_destroy(os);
    };

    octstr_destroy(grpname);
    return u;

no_grpname:
    octstr_destroy(grpname);
    return NULL;

error:
    octstr_destroy(grpname);
    destroy_oneuser(u);
    return NULL;
}

default_smsc()

static Octstr * default_smsc ( WAPPushUser *  u )

static

Definition at line 1057 of file wap_push_ppg_pushuser.c.

References WAPPushUser::default_smsc_id.

Referenced by create_onetrans(), and wap_push_ppg_pushuser_smsc_id_get().

{
    return u->default_smsc_id;
}

destroy_oneuser()

static void destroy_oneuser ( void *  p )

static

Definition at line 559 of file wap_push_ppg_pushuser.c.

References WAPPushUser::allowed_prefix, WAPPushUser::allowed_prefix_regex, WAPPushUser::black_list, WAPPushUser::black_list_regex, WAPPushUser::country_prefix, WAPPushUser::default_smsc_id, WAPPushUser::denied_prefix, WAPPushUser::denied_prefix_regex, WAPPushUser::name, numhash_destroy(), octstr_destroy(), WAPPushUser::password, WAPPushUser::smsc_id, WAPPushUser::user_allow_ip, WAPPushUser::user_deny_ip, WAPPushUser::username, WAPPushUser::white_list, and WAPPushUser::white_list_regex.

Referenced by create_oneuser(), and wap_push_ppg_pushuser_list_destroy().

{
     WAPPushUser *u;

     u = p;
     if (u == NULL)
         return;

     octstr_destroy(u->name);
     octstr_destroy(u->username);  
     octstr_destroy(u->password);  
     octstr_destroy(u->country_prefix);              
     octstr_destroy(u->allowed_prefix);           
     octstr_destroy(u->denied_prefix);             
     numhash_destroy(u->white_list);               
     numhash_destroy(u->black_list);              
     octstr_destroy(u->user_deny_ip);              
     octstr_destroy(u->user_allow_ip);
     octstr_destroy(u->smsc_id);
     octstr_destroy(u->default_smsc_id);

     if (u->black_list_regex != NULL) gw_regex_destroy(u->black_list_regex);
     if (u->white_list_regex != NULL) gw_regex_destroy(u->white_list_regex);
     if (u->denied_prefix_regex != NULL) gw_regex_destroy(u->denied_prefix_regex);
     if (u->allowed_prefix_regex != NULL) gw_regex_destroy(u->allowed_prefix_regex);
     gw_free(u);             
}

destroy_users_list()

static void destroy_users_list ( void *  l )

static

Definition at line 431 of file wap_push_ppg_pushuser.c.

References gwlist_destroy().

Referenced by pushusers_create().

{
    gwlist_destroy(l, NULL);
}

forced_smsc()

static Octstr * forced_smsc ( WAPPushUser *  u )

static

Definition at line 1052 of file wap_push_ppg_pushuser.c.

References WAPPushUser::smsc_id.

Referenced by create_onetrans(), and wap_push_ppg_pushuser_smsc_id_get().

{
    return u->smsc_id;
}

ip_allowed_by_user()

static int ip_allowed_by_user ( WAPPushUser *  u, Octstr *  ip  )

static

Definition at line 702 of file wap_push_ppg_pushuser.c.

References octstr_compare(), octstr_destroy(), octstr_duplicate, octstr_get_cstr, octstr_imm(), WAPPushUser::user_allow_ip, WAPPushUser::user_deny_ip, WAPPushUser::username, wap_push_ppg_pushuser_search_ip_from_wildcarded_list(), and warning().

Referenced by wap_push_ppg_pushuser_authenticate().

{
    Octstr *copy,
           *ip_copy;
    
    if (u == NULL) {
        warning(0, "user not found from the users list");
        goto no_user;
    }

    copy = octstr_duplicate(u->username);

    if (u->user_deny_ip == NULL && u->user_allow_ip == NULL)
        goto allowed;

    if (u->user_deny_ip) {
        if (octstr_compare(u->user_deny_ip, octstr_imm("*.*.*.*")) == 0) {
            warning(0, "no ips allowed for %s", octstr_get_cstr(copy));
            goto denied;
        }
    }

    if (u->user_allow_ip)
        if (octstr_compare(u->user_allow_ip, octstr_imm("*.*.*.*")) == 0)
            goto allowed;

    if (u->user_deny_ip) {
        if (wap_push_ppg_pushuser_search_ip_from_wildcarded_list(u->user_deny_ip, 
                ip, octstr_imm(";"), octstr_imm("."))) {
            goto denied;
        }
    }

    if (u->user_allow_ip) {
        if (wap_push_ppg_pushuser_search_ip_from_wildcarded_list(u->user_allow_ip, 
                ip, octstr_imm(";"), octstr_imm("."))) {
            goto allowed;
        }
    }

    octstr_destroy(copy);
    warning(0, "ip not found from either ip list, deny it");
    return 0;

allowed:
    octstr_destroy(copy);
    return 1;

denied:
    ip_copy = octstr_duplicate(ip);
    warning(0, "%s denied by user %s", octstr_get_cstr(ip_copy), 
            octstr_get_cstr(copy));
    octstr_destroy(copy);
    octstr_destroy(ip_copy);
    return 0;

no_user:
    return 0;
}

oneuser_add()

static int oneuser_add ( CfgGroup *  cfg )

static

Definition at line 619 of file wap_push_ppg_pushuser.c.

References create_oneuser(), dict_get(), dict_put(), gwlist_append(), gwlist_create, WAPPushUserList::list, WAPPushUserList::names, WAPPushUser::username, and users.

Referenced by wap_push_ppg_pushuser_list_add().

{
    WAPPushUser *u;
    List *list;

    u = create_oneuser(grp);
    if (u == NULL)
        return -1;

    gwlist_append(users->list, u);

    list = dict_get(users->names, u->username);
    if (list == NULL) {
        list = gwlist_create();
        dict_put(users->names, u->username, list);
    }

    return 0;
}

oneuser_dump()

static void oneuser_dump ( WAPPushUser *  u )

static

Definition at line 587 of file wap_push_ppg_pushuser.c.

References WAPPushUser::allowed_prefix, WAPPushUser::country_prefix, debug(), WAPPushUser::default_smsc_id, WAPPushUser::denied_prefix, WAPPushUser::name, octstr_dump, WAPPushUser::smsc_id, WAPPushUser::user_allow_ip, WAPPushUser::user_deny_ip, and WAPPushUser::username.

Referenced by create_oneuser().

{
    if (u == NULL) {
        debug("wap.push.ppg.pushuser", 0, "no user found");
        return;
    }

    debug("wap.push.ppg.pushuser", 0, "Dumping user data: Name of the user:");
    octstr_dump(u->name, 0);
    debug("wap.push.ppg.pushuser", 0, "username:");
    octstr_dump(u->username, 0);  
    debug("wap.push.ppg.pushuser", 0, "omitting password");
    debug("wap-push.ppg.pushuser", 0, "country prefix");
    octstr_dump(u->country_prefix, 0);   
    debug("wap.push.ppg.pushuser", 0, "allowed prefix list:");            
    octstr_dump(u->allowed_prefix, 0);  
    debug("wap.push.ppg.pushuser", 0, "denied prefix list:");         
    octstr_dump(u->denied_prefix, 0);   
    debug("wap.push.ppg.pushuser", 0, "denied ip list:");                         
    octstr_dump(u->user_deny_ip, 0);    
    debug("wap.push.ppg.pushuser", 0, "allowed ip list:");                   
    octstr_dump(u->user_allow_ip, 0);
    debug("wap.push.ppg.pushuser", 0, "send via smsc-id:");                   
    octstr_dump(u->smsc_id, 0);
    debug("wap.push.ppg.pushuser", 0, "use default smsc:");
    octstr_dump(u->default_smsc_id, 0);
    debug("wap.push.ppg.pushuser", 0, "end of the dump");
}

parse_cgivars_for_password()

static int parse_cgivars_for_password ( List *  cgivars, Octstr **  password  )

static

Definition at line 1006 of file wap_push_ppg_pushuser.c.

References http_cgi_variable(), octstr_duplicate, and password.

Referenced by wap_push_ppg_pushuser_authenticate().

{
    *password = NULL;
    *password = octstr_duplicate(http_cgi_variable(cgivars, "password"));

    if (*password == NULL) {
        return 0;
    }

    return 1;
}

parse_cgivars_for_username()

static int parse_cgivars_for_username ( List *  cgivars, Octstr **  username  )

static

Definition at line 994 of file wap_push_ppg_pushuser.c.

References http_cgi_variable(), octstr_duplicate, and username.

Referenced by wap_push_ppg_pushuser_authenticate().

{
    *username = NULL;
    *username = octstr_duplicate(http_cgi_variable(cgivars, "username"));

    if (*username == NULL) {
        return 0;
    }

    return 1;
}

password_matches()

static int password_matches ( WAPPushUser *  u, Octstr *  password  )

static

Definition at line 660 of file wap_push_ppg_pushuser.c.

References octstr_compare(), WAPPushUser::password, and password.

Referenced by wap_push_ppg_pushuser_authenticate().

{
    if (password == NULL)
        return 0;    

    return octstr_compare(u->password, password) == 0;
}

prefix_allowed()

static int prefix_allowed ( WAPPushUser *  u, Octstr *  number  )

static

Definition at line 883 of file wap_push_ppg_pushuser.c.

References WAPPushUser::allowed_prefix, WAPPushUser::allowed_prefix_regex, compare_octstr_sequence(), WAPPushUser::country_prefix, WAPPushUser::denied_prefix, WAPPushUser::denied_prefix_regex, gwlist_destroy(), gwlist_get(), gwlist_len(), number, octstr_destroy_item(), octstr_imm(), octstr_insert(), and octstr_split().

Referenced by wap_push_ppg_pushuser_client_phone_number_acceptable().

{
    List *allowed,
         *denied;
    long i;
    Octstr *listed_prefix;

    allowed = NULL;
    denied = NULL;

    if (u == NULL)
        goto no_user;

    if (        u->allowed_prefix == NULL && u->denied_prefix == NULL 
        && u->allowed_prefix_regex == NULL && u->denied_prefix_regex == NULL)
        goto no_configuration;

    if (u->denied_prefix != NULL) {
        denied = octstr_split(u->denied_prefix, octstr_imm(";"));
        for (i = 0; i < gwlist_len(denied); ++i) {
             listed_prefix = gwlist_get(denied, i);
             if (u->country_prefix != NULL)
                 octstr_insert(listed_prefix, u->country_prefix, 0);
             if (compare_octstr_sequence(number, listed_prefix, 
                     0) == 0) {
                 goto denied;
             }
        }
    }

    /* note: country-prefix _must_be included in the pattern */
    if (u->denied_prefix_regex != NULL) 
        if (gw_regex_match_pre(u->denied_prefix_regex, number) == 1)
            goto denied;

    if (u->allowed_prefix_regex == NULL && u->allowed_prefix == NULL) 
        goto no_allowed_config;

    if (u->allowed_prefix != NULL) {
    allowed = octstr_split(u->allowed_prefix, octstr_imm(";"));
    for (i = 0; i < gwlist_len(allowed); ++i) {
         listed_prefix = gwlist_get(allowed, i);
         if (u->country_prefix != NULL)
             octstr_insert(listed_prefix, u->country_prefix, 0);
         if (compare_octstr_sequence(number, listed_prefix, 
                 0) == 0) {
             goto allowed;
         }
    }
    }

    /* note: country-prefix _must_ be included in the pattern */
    if (u->allowed_prefix_regex != NULL) 
        if (gw_regex_match_pre(u->allowed_prefix_regex, number) == 1)
            goto allowed;

/*
 * Here we have an intentional fall-through. It will removed when memory cleaning
 * functions are implemented.
 */
denied:         
    gwlist_destroy(allowed, octstr_destroy_item);
    gwlist_destroy(denied, octstr_destroy_item);
    return 0;

allowed:      
    gwlist_destroy(allowed, octstr_destroy_item);
    gwlist_destroy(denied, octstr_destroy_item);
    return 1;

no_configuration:
    return 1;

no_user:
    return 0;

no_allowed_config:
    gwlist_destroy(denied, octstr_destroy_item);
    return 1;
}

pushusers_create()

static WAPPushUserList * pushusers_create ( long  number_of_users )

static

Definition at line 436 of file wap_push_ppg_pushuser.c.

References destroy_users_list(), dict_create(), gwlist_create, WAPPushUserList::list, WAPPushUserList::names, number_of_users, and users.

Referenced by wap_push_ppg_pushuser_list_add().

{
    users = gw_malloc(sizeof(WAPPushUserList));
    users->list = gwlist_create();
    users->names = dict_create(number_of_users, destroy_users_list);

    return users;
}

reply()

static void reply ( HTTPClient *  c, List *  push_headers  )

static

Definition at line 863 of file wap_push_ppg_pushuser.c.

References http_create_empty_headers(), http_destroy_headers(), HTTP_FORBIDDEN, http_send_reply(), and octstr_imm().

Referenced by bb_smscconn_send_failed(), bb_smscconn_sent(), cgw_handle_op(), cimd2_request(), create_dlr_from_msg(), emi2_handle_smscreq(), handle_operation(), handle_reply(), handle_split(), httpd_add_smsc(), httpd_flush_dlr(), httpd_graceful_restart(), httpd_isolate(), httpd_loglevel(), httpd_reload_lists(), httpd_remove_message(), httpd_remove_smsc(), httpd_restart(), httpd_restart_smsc(), httpd_resume(), httpd_serve(), httpd_shutdown(), httpd_status(), httpd_stop_smsc(), httpd_store_status(), httpd_suspend(), obey_request_thread(), oisd_request(), and wap_push_ppg_pushuser_authenticate().

{
    int http_status;
    Octstr *denied;
    List *reply_headers;

    reply_headers = http_create_empty_headers();
    http_status = HTTP_FORBIDDEN;
    denied = octstr_imm("You are not allowed to use this service. Do not retry.\n");
 
    http_send_reply(c, http_status, push_headers, denied);

    http_destroy_headers(reply_headers);
}

response()

static int response ( List *  push_headers, Octstr **  username, Octstr **  password  )

static

Definition at line 769 of file wap_push_ppg_pushuser.c.

References debug(), gwlist_destroy(), gwlist_get(), gwlist_len(), HEADER_AUTHENTICATION, http_header_find_first, http_header_remove_all(), NO_PASSWORD, NO_USERNAME, octstr_base64_to_binary(), octstr_delete(), octstr_destroy(), octstr_destroy_item(), octstr_duplicate, octstr_imm(), octstr_len(), octstr_ncompare(), octstr_split(), octstr_strip_blanks(), password, and username.

Referenced by build_response(), cimd2_send_response(), http_send_reply(), oisd_send_response(), soap_parse_dlr(), soap_parse_mo(), wap_push_ppg_pushuser_authenticate(), xmlrpc_doc_create_faultresponse(), xmlrpc_is_fault(), xmlrpc_response_add_param(), xmlrpc_response_destroy(), xmlrpc_response_is_fault(), and xmlrpc_response_print().

{
    Octstr *header_value,
           *basic;
    size_t basic_len;
    List *auth_list;

    *username = NULL;
    *password = NULL;

    if ((header_value = http_header_find_first(push_headers, 
            "Authorization")) == NULL)
        goto no_response3; 

    octstr_strip_blanks(header_value);
    basic = octstr_imm("Basic");
    basic_len = octstr_len(basic);

    if (octstr_ncompare(header_value, basic, basic_len) != 0)
        goto no_response1;

    octstr_delete(header_value, 0, basic_len);
    octstr_strip_blanks(header_value);
    octstr_base64_to_binary(header_value);
    auth_list = octstr_split(header_value, octstr_imm(":"));

    if (gwlist_len(auth_list) != 2)
        goto no_response2;
    
    *username = octstr_duplicate(gwlist_get(auth_list, 0));
    *password = octstr_duplicate(gwlist_get(auth_list, 1));

    if (username == NULL) {
        goto no_response2;
    }

    if (password == NULL) {
        goto no_response4;
    }

    debug("wap.push.ppg.pushuser", 0, "we have an username and a password in" 
          " authorization header");
    gwlist_destroy(auth_list, octstr_destroy_item);
    octstr_destroy(header_value);
    http_header_remove_all(push_headers, "Authorization");
    return HEADER_AUTHENTICATION;

no_response1:
    octstr_destroy(header_value);
    return NO_USERNAME;

no_response2:   
    gwlist_destroy(auth_list, octstr_destroy_item);
    octstr_destroy(header_value);
    return NO_USERNAME;

no_response3:
    return NO_USERNAME;

no_response4:   
    gwlist_destroy(auth_list, octstr_destroy_item);
    octstr_destroy(header_value);
    return NO_PASSWORD;
}

user_find_by_username()

static WAPPushUser * user_find_by_username ( Octstr *  username )

static

Definition at line 639 of file wap_push_ppg_pushuser.c.

References dict_get(), gwlist_get(), gwlist_len(), WAPPushUserList::list, WAPPushUserList::names, octstr_compare(), WAPPushUser::username, username, and users.

Referenced by wap_push_ppg_pushuser_authenticate(), wap_push_ppg_pushuser_client_phone_number_acceptable(), wap_push_ppg_pushuser_dlr_url_get(), wap_push_ppg_pushuser_smsbox_id_get(), and wap_push_ppg_pushuser_smsc_id_get().

{
    WAPPushUser *u;
    long i;
    List *list;

    if (username == NULL)
        return NULL;

    if ((list = dict_get(users->names, username)) == NULL)
         return NULL;

    for (i = 0; i < gwlist_len(users->list); ++i) {
         u = gwlist_get(users->list, i);
         if (octstr_compare(u->username, username) == 0)
             return u;
    }

    return NULL;
}

wap_push_ppg_pushuser_authenticate()

int wap_push_ppg_pushuser_authenticate	(	HTTPClient *	c,
		List *	cgivars,
		Octstr *	ip,
		List *	push_headers,
		Octstr **	username
	)

Definition at line 223 of file wap_push_ppg_pushuser.c.

References ADDITION, challenge(), dict_get(), dict_put(), dict_remove(), error(), ip_allowed_by_user(), next_try, NO_USERNAME, octstr_destroy(), octstr_duplicate, octstr_format(), octstr_get_cstr, octstr_parse_long(), parse_cgivars_for_password(), parse_cgivars_for_username(), password, password_matches(), reply(), response(), user_find_by_username(), and username.

Referenced by pap_request_thread().

                                                                              {
        time_t now;
        static long next = 0L;            /* used only in this thread (and this 
                                             function) */
        long next_time;
        Octstr *next_time_os;
        static long multiplier = 1L;      /* ditto */
        WAPPushUser *u;
        Octstr *copy,
               *password;
        int ret;
        
        copy = octstr_duplicate(ip);
        time(&now);
        next_time_os = NULL;

        if ((ret = response(push_headers, username, &password)) == NO_USERNAME) { 
            if (!parse_cgivars_for_username(cgivars, username)) {
                error(0, "no user specified, challenging regardless");
                goto listed;
            }
        }

        if (password == NULL)
            parse_cgivars_for_password(cgivars, &password);

        u = user_find_by_username(*username);
        if (!ip_allowed_by_user(u, ip)) {
            goto not_listed;
        }

        next = 0;       

        if ((next_time_os = dict_get(next_try, ip)) != NULL) {
            octstr_parse_long(&next_time, next_time_os, 0, 10);
            if (difftime(now, (time_t) next_time) < 0) {
                error(0, "another try from %s, not much time used", 
                      octstr_get_cstr(copy));
                goto listed;
            }
        }

        if (u == NULL) {
            error(0, "user %s is not allowed by users list, challenging",
                  octstr_get_cstr(*username));
            goto listed;
        }

        if (!password_matches(u, password)) {
            error(0, "wrong or missing password in request from %s, challenging" , 
                  octstr_get_cstr(copy));
            goto listed;
        }

        dict_remove(next_try, ip);       /* no restrictions after authentica-
                                            tion */
        octstr_destroy(password);
        octstr_destroy(copy);
        octstr_destroy(next_time_os);
        return 1;

not_listed:
        octstr_destroy(password);
        octstr_destroy(copy); 
        reply(c, push_headers);
        octstr_destroy(next_time_os);
        return 0;

listed:
        challenge(c, push_headers);

        multiplier <<= 1;
        next = next + multiplier * ADDITION;
        next += now;
        next_time_os = octstr_format("%ld", next);
        dict_put(next_try, ip, next_time_os);
        
        octstr_destroy(copy);
        octstr_destroy(password);
        
        return 0;
}

wap_push_ppg_pushuser_client_phone_number_acceptable()

int wap_push_ppg_pushuser_client_phone_number_acceptable	(	Octstr *	username,
		Octstr *	number
	)

Definition at line 312 of file wap_push_ppg_pushuser.c.

References blacklisted(), error(), number, octstr_get_cstr, prefix_allowed(), user_find_by_username(), username, and whitelisted().

Referenced by pap_request_thread().

{
    WAPPushUser *u;

    u = user_find_by_username(username);
    if (!prefix_allowed(u, number)) {
        error(0, "Number %s not allowed by user %s (wrong prefix)", 
              octstr_get_cstr(number), octstr_get_cstr(username));
        return 0;
    }

    if (blacklisted(u, number)) {
        error(0, "Number %s not allowed by user %s (blacklisted)", 
              octstr_get_cstr(number), octstr_get_cstr(username) );
        return 0;
    }

    if (!whitelisted(u, number)) {
        error(0, "Number %s not allowed by user %s (not whitelisted)", 
              octstr_get_cstr(number), octstr_get_cstr(username) );
        return 0;
    }

    return 1;
}

wap_push_ppg_pushuser_dlr_url_get()

Octstr* wap_push_ppg_pushuser_dlr_url_get

(

Octstr *

username

)

Definition at line 400 of file wap_push_ppg_pushuser.c.

References WAPPushUser::dlr_url, dlr_url, octstr_duplicate, user_find_by_username(), and username.

Referenced by set_dlr_url().

{
    WAPPushUser *u;
    Octstr *dlr_url;

    u = user_find_by_username(username);
    dlr_url = u->dlr_url;     

    return octstr_duplicate(dlr_url);
}

wap_push_ppg_pushuser_list_add()

int wap_push_ppg_pushuser_list_add	(	List *	list,
		long	number_of_pushes,
		long	number_of_users
	)

Definition at line 156 of file wap_push_ppg_pushuser.c.

References dict_create(), gw_assert(), gwlist_destroy(), gwlist_extract_first(), WAPPushUserList::list, next_try, number_of_pushes, number_of_users, octstr_destroy_item(), oneuser_add(), pushusers_create(), and users.

Referenced by read_ppg_config().

{
    CfgGroup *grp;

    next_try = dict_create(number_of_pushes, octstr_destroy_item);
    users = pushusers_create(number_of_users);
    gw_assert(list);
    while (list && (grp = gwlist_extract_first(list))) {
        if (oneuser_add(grp) == -1) {
            gwlist_destroy(list, NULL);
            return 0;
        }
    }
    gwlist_destroy(list, NULL);

    return 1;
}

wap_push_ppg_pushuser_list_destroy()

void wap_push_ppg_pushuser_list_destroy

(

void

)

Definition at line 175 of file wap_push_ppg_pushuser.c.

References destroy_oneuser(), dict_destroy(), gwlist_destroy(), WAPPushUserList::list, WAPPushUserList::names, next_try, and users.

Referenced by wap_push_ppg_shutdown().

{
    dict_destroy(next_try);
    if (users == NULL)
        return;

    gwlist_destroy(users->list, destroy_oneuser);
    dict_destroy(users->names);
    gw_free(users);
}

wap_push_ppg_pushuser_search_ip_from_wildcarded_list()

int wap_push_ppg_pushuser_search_ip_from_wildcarded_list	(	Octstr *	haystack,
		Octstr *	needle,
		Octstr *	gwlist_sep,
		Octstr *	ip_sep
	)

Definition at line 339 of file wap_push_ppg_pushuser.c.

References found, gw_assert(), gwlist_destroy(), gwlist_get(), gwlist_len(), octstr_destroy_item(), octstr_search(), octstr_search_char(), octstr_split(), and wildcarded_ip_found().

Referenced by ip_allowed_by_ppg(), and ip_allowed_by_user().

{
    List *ips;
    long i;
    Octstr *configured_ip;

    gw_assert(haystack);
    gw_assert(gwlist_sep);
    gw_assert(ip_sep);

    /*There are no wildcards in the list*/    
    if (octstr_search_char(haystack, '*', 0) < 0) {
        if (octstr_search(haystack, needle, 0) >= 0) {
            return 1;
        } else { 
            return 0;
        }
    }
    
    /*There are wildcards in the list*/
    configured_ip = NULL;
    ips = octstr_split(haystack, gwlist_sep);
    for (i = 0; i < gwlist_len(ips); ++i) {
        configured_ip = gwlist_get(ips, i);
        if (wildcarded_ip_found(configured_ip, needle, ip_sep))
            goto found;
    }

    gwlist_destroy(ips, octstr_destroy_item);
    return 0;

found:
    gwlist_destroy(ips, octstr_destroy_item);
    return 1;
}

wap_push_ppg_pushuser_smsbox_id_get()

Octstr* wap_push_ppg_pushuser_smsbox_id_get

(

Octstr *

username

)

Definition at line 414 of file wap_push_ppg_pushuser.c.

References octstr_duplicate, WAPPushUser::smsbox_id, smsbox_id, user_find_by_username(), and username.

Referenced by set_smsbox_id().

{
    WAPPushUser *u;
    Octstr *smsbox_id;

    u = user_find_by_username(username);
    smsbox_id = u->smsbox_id;

    return octstr_duplicate(smsbox_id);
}

wap_push_ppg_pushuser_smsc_id_get()

Octstr* wap_push_ppg_pushuser_smsc_id_get

(

Octstr *

username

)

Definition at line 380 of file wap_push_ppg_pushuser.c.

References default_smsc(), forced_smsc(), octstr_duplicate, smsc_id, user_find_by_username(), and username.

Referenced by set_smsc_id().

{
    WAPPushUser *u;
    Octstr *smsc_id;

    if ((u = user_find_by_username(username)) == NULL) {
        /* no user found with this username */
        return NULL;
    }

    if ((smsc_id = forced_smsc(u)) != NULL)
        return octstr_duplicate(smsc_id);

    smsc_id = default_smsc(u);
    return octstr_duplicate(smsc_id);
}

whitelisted()

static int whitelisted ( WAPPushUser *  u, Octstr *  number  )

static

Definition at line 964 of file wap_push_ppg_pushuser.c.

References number, numhash_find_number(), WAPPushUser::white_list, and WAPPushUser::white_list_regex.

Referenced by wap_push_ppg_pushuser_client_phone_number_acceptable().

{
    int result = 1;

    if (u->white_list != NULL)
        result = numhash_find_number(u->white_list, number);

    if ((result == 0) && (u->white_list_regex != NULL))
        result = gw_regex_match_pre(u->white_list_regex, number);

    return result;
}

wildcarded_ip_found()

static int wildcarded_ip_found ( Octstr *  ip, Octstr *  needle, Octstr *  ip_sep  )

static

Definition at line 668 of file wap_push_ppg_pushuser.c.

References gw_assert(), gwlist_destroy(), gwlist_get(), gwlist_len(), octstr_compare(), octstr_destroy_item(), octstr_imm(), and octstr_split().

Referenced by wap_push_ppg_pushuser_search_ip_from_wildcarded_list().

{
    List *ip_fragments,
         *needle_fragments;
    long i;
    Octstr *ip_fragment,
           *needle_fragment;

    ip_fragments = octstr_split(ip, ip_sep);
    needle_fragments = octstr_split(needle, ip_sep);

    gw_assert(gwlist_len(ip_fragments) == gwlist_len(needle_fragments));
    for (i = 0; i < gwlist_len(ip_fragments); ++i) {
        ip_fragment = gwlist_get(ip_fragments, i);
        needle_fragment = gwlist_get(needle_fragments, i);
        if (octstr_compare(ip_fragment, needle_fragment) != 0 && 
                octstr_compare(ip_fragment, octstr_imm("*")) != 0)
            goto not_found;
    }

    gwlist_destroy(ip_fragments, octstr_destroy_item);
    gwlist_destroy(needle_fragments, octstr_destroy_item);   
    return 1;

not_found:
    gwlist_destroy(ip_fragments, octstr_destroy_item);
    gwlist_destroy(needle_fragments, octstr_destroy_item);
    return 0;
}

Variable Documentation

next_try

Dict* next_try = NULL

static

Definition at line 119 of file wap_push_ppg_pushuser.c.

Referenced by wap_push_ppg_pushuser_authenticate(), wap_push_ppg_pushuser_list_add(), and wap_push_ppg_pushuser_list_destroy().

users

WAPPushUserList* users = NULL

static

Definition at line 114 of file wap_push_ppg_pushuser.c.

Referenced by oneuser_add(), pushusers_create(), user_find_by_username(), wap_push_ppg_pushuser_list_add(), and wap_push_ppg_pushuser_list_destroy().