手机WAP编程

开发平台：
WINDOWS

bb_http.c：源码内容
							/*
 * bb_http.c : bearerbox http adminstration commands
 *
 * NOTE: this is a special bearerbox module - it does call
 *   functions from core module! (other modules are fully
 *    encapsulated, and only called outside)
 *
 * Kalle Marjola <rpr@wapit.com> 2000 for project Kannel
 */
#include <errno.h>
#include <signal.h>
#include <unistd.h>
#include "gwlib/gwlib.h"
#include "bearerbox.h"
/* passed from bearerbox core */
extern volatile sig_atomic_t bb_status;
/* our own thingies */
static volatile sig_atomic_t httpadmin_running;
static long	ha_port;
static Octstr	*ha_password;
static Octstr	*ha_status_pw;
static Octstr	*ha_allow_ip;
static Octstr	*ha_deny_ip;
/*---------------------------------------------------------
 * static functions
 */
/*
 * check if the password matches. Return NULL if
 * it does (or is not required)
 */
static Octstr *httpd_check_authorization(List *cgivars, int status)
{
    Octstr *password;
    static double sleep = 0.01;
    password = http_cgi_variable(cgivars, "password");
    if (status) {
	if (ha_status_pw == NULL)
	    return NULL;
	if (password == NULL)
	    goto denied;
	if (octstr_compare(password, ha_password)!=0
	    && octstr_compare(password, ha_status_pw)!=0)
	    goto denied;
    }
    else {
	if (password == NULL || octstr_compare(password, ha_password)!=0)
	    goto denied;
    }
    sleep = 0.0;
    return NULL;	/* allowed */
denied:
    gwthread_sleep(sleep);
    sleep += 1.0;		/* little protection against brute force
				 * password cracking */
    return octstr_create("Denied");
}
/*
 * check if we still have time to do things
 */
static Octstr *httpd_check_status(void)
{
    if (bb_status == BB_SHUTDOWN || bb_status == BB_DEAD)
	return octstr_create("Avalanche has already started, too late to "
	    	    	     "save the sheeps");
    return NULL;
}
    
static Octstr *httpd_status(List *cgivars, int status_type)
{
    Octstr *reply;
    if ((reply = httpd_check_authorization(cgivars, 1))!= NULL) return reply;
    return bb_print_status(status_type);
}
static Octstr *httpd_store_status(List *cgivars, int status_type)
{
    Octstr *reply;
    if ((reply = httpd_check_authorization(cgivars, 1))!= NULL) return reply;
    return store_status(status_type);
}
static Octstr *httpd_shutdown(List *cgivars)
{
    Octstr *reply;
    if ((reply = httpd_check_authorization(cgivars, 0))!= NULL) return reply;
    if (bb_status == BB_SHUTDOWN)
	bb_status = BB_DEAD;
    else
	bb_shutdown();
    return octstr_create("Bringing system down");
}
static Octstr *httpd_isolate(List *cgivars)
{
    Octstr *reply;
    if ((reply = httpd_check_authorization(cgivars, 0))!= NULL) return reply;
    if ((reply = httpd_check_status())!= NULL) return reply;
    if (bb_isolate() == -1)
	return octstr_create("Already isolated");
    else
	return octstr_create(GW_NAME " isolated from message providers");
}
static Octstr *httpd_suspend(List *cgivars)
{
    Octstr *reply;
    if ((reply = httpd_check_authorization(cgivars, 0))!= NULL) return reply;
    if ((reply = httpd_check_status())!= NULL) return reply;
    if (bb_suspend() == -1)
	return octstr_create("Already suspended");
    else
	return octstr_create(GW_NAME " suspended");
}
static Octstr *httpd_resume(List *cgivars)
{
    Octstr *reply;
    if ((reply = httpd_check_authorization(cgivars, 0))!= NULL) return reply;
    if ((reply = httpd_check_status())!= NULL) return reply;
 
    if (bb_resume() == -1)
	return octstr_create("Already running");
    else
	return octstr_create("Running resumed");
}
static Octstr *httpd_flush_dlr(List *cgivars)
{
    Octstr *reply;
    if ((reply = httpd_check_authorization(cgivars, 0))!= NULL) return reply;
    if ((reply = httpd_check_status())!= NULL) return reply;
    if (bb_flush_dlr() == -1)
	return octstr_create("Suspend " GW_NAME " before trying to flush DLR queue");
    else
	return octstr_create("DLR queue flushed");
}
static Octstr *httpd_stop_smsc(List *cgivars)
{
    Octstr *reply;
    Octstr *smsc;
    if ((reply = httpd_check_authorization(cgivars, 0))!= NULL) return reply;
    if ((reply = httpd_check_status())!= NULL) return reply;
    /* check if the smsc id is given */
    smsc = http_cgi_variable(cgivars, "smsc");
    if (smsc) {
        if (bb_stop_smsc(smsc) == -1)
            return octstr_format("Could not shut down smsc-id `%s'", octstr_get_cstr(smsc));
        else
            return octstr_format("SMSC `%s' shut down", octstr_get_cstr(smsc));
    } else
        return octstr_create("SMSC id not given");
}
static Octstr *httpd_restart_smsc(List *cgivars)
{
    Octstr *reply;
    Octstr *smsc;
    if ((reply = httpd_check_authorization(cgivars, 0))!= NULL) return reply;
    if ((reply = httpd_check_status())!= NULL) return reply;
    /* check if the smsc id is given */
    smsc = http_cgi_variable(cgivars, "smsc");
    if (smsc) {
        if (bb_restart_smsc(smsc) == -1)
            return octstr_format("Could not re-start smsc-id `%s'", octstr_get_cstr(smsc));
        else
            return octstr_format("SMSC `%s' re-started", octstr_get_cstr(smsc));
    } else
        return octstr_create("SMSC id not given");
}
static void httpd_serve(HTTPClient *client, Octstr *url, List *headers, 
    	    	    	Octstr *body, List *cgivars)
{
    Octstr *reply, *final_reply;
    char *content_type;
    char *header, *footer;
    int status_type;
    /* Set default reply format according to client
     * Accept: header */
    
    if (http_type_accepted(headers, "text/vnd.wap.wml")) {
	status_type = BBSTATUS_WML;
	content_type = "text/vnd.wap.wml";
    }
    else if (http_type_accepted(headers, "text/html")) {
	status_type = BBSTATUS_HTML;
	content_type = "text/html";
    }
    else if (http_type_accepted(headers, "text/xml")) {
	status_type = BBSTATUS_XML;
	content_type = "text/xml";
    } else {
	status_type = BBSTATUS_TEXT;
	content_type = "text/plain";
    }    
    if (octstr_str_compare(url, "/cgi-bin/status")==0
	|| octstr_str_compare(url, "/status")==0) {
	reply = httpd_status(cgivars, status_type);
    } else if (octstr_str_compare(url, "/cgi-bin/status.html")==0
	       || octstr_str_compare(url, "/status.html")==0) {
	status_type = BBSTATUS_HTML;
	reply = httpd_status(cgivars, status_type);
    } else if (octstr_str_compare(url, "/cgi-bin/status.wml")==0
	       || octstr_str_compare(url, "/status.wml")==0) {
	status_type = BBSTATUS_WML;
	reply = httpd_status(cgivars, status_type);
    } else if (octstr_str_compare(url, "/cgi-bin/status.txt")==0
	       || octstr_str_compare(url, "/status.txt")==0) {
	status_type = BBSTATUS_TEXT;
	reply = httpd_status(cgivars, status_type);
    } else if (octstr_str_compare(url, "/cgi-bin/status.xml")==0
	       || octstr_str_compare(url, "/status.xml")==0) {
	status_type = BBSTATUS_XML;
	reply = httpd_status(cgivars, status_type);
	/* content_type = "text/x-kannelstatus"; */
    } else if (octstr_str_compare(url, "/store-status") == 0) {
        status_type = BBSTATUS_TEXT;
        reply = httpd_store_status(cgivars, status_type);
    } else if (octstr_str_compare(url, "/store-status.html") == 0) {
        status_type = BBSTATUS_HTML;
        reply = httpd_store_status(cgivars, status_type);
    } else if (octstr_str_compare(url, "/store-status.xml") == 0) {
        status_type = BBSTATUS_XML;
        reply = httpd_store_status(cgivars, status_type);
    } else if (octstr_str_compare(url, "/cgi-bin/shutdown")==0
	       || octstr_str_compare(url, "/shutdown")==0) {
	reply = httpd_shutdown(cgivars);
    } else if (octstr_str_compare(url, "/cgi-bin/suspend")==0
	       || octstr_str_compare(url, "/suspend")==0) {
	reply = httpd_suspend(cgivars);
    } else if (octstr_str_compare(url, "/cgi-bin/isolate")==0
	       || octstr_str_compare(url, "/isolate")==0) {
	reply = httpd_isolate(cgivars);
    } else if (octstr_str_compare(url, "/cgi-bin/resume")==0
	       || octstr_str_compare(url, "/resume")==0) {
	reply = httpd_resume(cgivars);
    } else if (octstr_str_compare(url, "/cgi-bin/flush-dlr")==0
	       || octstr_str_compare(url, "/flush-dlr")==0) {
	reply = httpd_flush_dlr(cgivars);
    } else if (octstr_str_compare(url, "/cgi-bin/stop-smsc")==0
	       || octstr_str_compare(url, "/stop-smsc")==0) {
	reply = httpd_stop_smsc(cgivars);
    } else if (octstr_str_compare(url, "/cgi-bin/start-smsc")==0
	       || octstr_str_compare(url, "/start-smsc")==0) {
	reply = httpd_restart_smsc(cgivars);
    /*
     * reconfig? restart?
     */
    } else  {
	reply = octstr_format("Unknown command %S", url);
    }
    gw_assert(reply != NULL);
    if (status_type == BBSTATUS_HTML) {
	header = "<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 3.2//EN">n"
 	    "<html>n<title>" GW_NAME "</title>n<body>n<p>";
	footer = "</p>n</body></html>n";
	content_type = "text/html";
    } else if (status_type == BBSTATUS_WML) {
	header = "<?xml version="1.0"?>n"
            "<!DOCTYPE wml PUBLIC "-//WAPFORUM//DTD WML 1.1//EN" "
            ""http://www.wapforum.org/DTD/wml_1.1.xml">n"
            "n<wml>n <card>n  <p>";
	footer = "  </p>n </card>n</wml>n";
	content_type = "text/vnd.wap.wml";
    } else if (status_type == BBSTATUS_XML) {
	header = "<?xml version="1.0"?>n"
            "<gateway>n";
        footer = "</gateway>n";
    } else {
	header = "";
	footer = "";
	content_type = "text/plain";
    }
    final_reply = octstr_create(header);
    octstr_append(final_reply, reply);
    octstr_append_cstr(final_reply, footer);
    
    /* debug("bb.http", 0, "Result: '%s'", octstr_get_cstr(final_reply));
     */
    http_destroy_headers(headers);
    headers = list_create();
    http_header_add(headers, "Content-Type", content_type);
    http_send_reply(client, HTTP_OK, headers, final_reply);
    octstr_destroy(url);
    octstr_destroy(body);
    octstr_destroy(reply);
    octstr_destroy(final_reply);
    http_destroy_headers(headers);
    http_destroy_cgiargs(cgivars);
}
static void httpadmin_run(void *arg)
{
    HTTPClient *client;
    Octstr *ip, *url, *body;
    List *headers, *cgivars;
    while(bb_status != BB_DEAD) {
	if (bb_status == BB_SHUTDOWN)
	    bb_shutdown();
    	client = http_accept_request(ha_port, &ip, &url, &headers, &body, 
	    	    	    	     &cgivars);
	if (client == NULL)
	    break;
	if (is_allowed_ip(ha_allow_ip, ha_deny_ip, ip) == 0) {
	    info(0, "HTTP admin tried from denied host <%s>, disconnected",
		 octstr_get_cstr(ip));
	    http_close_client(client);
	    continue;
	}
        httpd_serve(client, url, headers, body, cgivars);
	octstr_destroy(ip);
    }
    httpadmin_running = 0;
}
/*-------------------------------------------------------------
 * public functions
 *
 */
int httpadmin_start(Cfg *cfg)
{
    CfgGroup *grp;
    int ssl = 0; 
#ifdef HAVE_LIBSSL
    Octstr *ssl_server_cert_file;
    Octstr *ssl_server_key_file;
#endif /* HAVE_LIBSSL */
    
    if (httpadmin_running) return -1;
    grp = cfg_get_single_group(cfg, octstr_imm("core"));
    if (cfg_get_integer(&ha_port, grp, octstr_imm("admin-port")) == -1)
	panic(0, "Missing admin-port variable, cannot start HTTP admin");
    ha_password = cfg_get(grp, octstr_imm("admin-password"));
    if (ha_password == NULL)
	panic(0, "You MUST set HTTP admin-password");
    
    ha_status_pw = cfg_get(grp, octstr_imm("status-password"));
    ha_allow_ip = cfg_get(grp, octstr_imm("admin-allow-ip"));
    ha_deny_ip = cfg_get(grp, octstr_imm("admin-deny-ip"));
#ifdef HAVE_LIBSSL
    cfg_get_bool(&ssl, grp, octstr_imm("admin-port-ssl"));
    
    /*
     * check if SSL is desired for HTTP servers and then
     * load SSL client and SSL server public certificates 
     * and private keys
     */    
    ssl_server_cert_file = cfg_get(grp, octstr_imm("ssl-server-cert-file"));
    ssl_server_key_file = cfg_get(grp, octstr_imm("ssl-server-key-file"));
    if (ssl_server_cert_file != NULL && ssl_server_key_file != NULL) {
        /* we are fine here, the following call is now in conn_config_ssl(),
         * so there is no reason to do this twice.
        use_global_server_certkey_file(ssl_server_cert_file, 
            ssl_server_key_file);
        */
    } else if (ssl) {
	   panic(0, "You MUST specify cert and key files within core group for SSL-enabled HTTP servers!");
    }
    octstr_destroy(ssl_server_cert_file);
    octstr_destroy(ssl_server_key_file);
#endif /* HAVE_LIBSSL */
    http_open_port(ha_port, ssl);
    if (gwthread_create(httpadmin_run, NULL) == -1)
	panic(0, "Failed to start a new thread for HTTP admin");
    httpadmin_running = 1;
    return 0;
}
void httpadmin_stop(void)
{
    http_close_all_ports();
    gwthread_join_every(httpadmin_run);
    octstr_destroy(ha_password);
    octstr_destroy(ha_status_pw);
    octstr_destroy(ha_allow_ip);
    octstr_destroy(ha_deny_ip);
    ha_password = NULL;
    ha_status_pw = NULL;
    ha_allow_ip = NULL;
    ha_deny_ip = NULL;
}

						