8 files changed, 118 insertions, 145 deletions

diff --git a/apache13.h b/apache13.h
index 1c262d7..8181c43 100644
--- a/apache13.h
+++ b/apache13.h
@@ -1,4 +1,4 @@
-/* $Header: /home/cvs/mod_log_sql/apache13.h,v 1.3 2004/01/22 05:26:56 urkle Exp $ */
+/* $Header: /home/cvs/mod_log_sql/apache13.h,v 1.4 2004/02/05 21:59:46 urkle Exp $ */
 #ifndef APACHE13_H
 #define APACHE13_H
 
@@ -41,6 +41,8 @@
 /* Functions */
 #define ap_get_remote_host(a,b,c,d) ap_get_remote_host(a,b,c)
 
+#define apr_uri_unparse ap_unparse_uri_components
+
 #define apr_pool_create(a,b) *(a) = ap_make_sub_pool(b)
 #define apr_palloc ap_palloc
 #define apr_pcalloc ap_pcalloc
diff --git a/configure.ac b/configure.ac
index 7e9ccb8..fb036ce 100644
--- a/configure.ac
+++ b/configure.ac
@@ -1,5 +1,5 @@
 dnl Required initializer
-AC_INIT(mod_log_sql, 1.94)
+AC_INIT(mod_log_sql, 1.95)
 AC_PREREQ(2.53)
 AC_CONFIG_HEADERS(config.h)
 
diff --git a/functions.h b/functions.h
index 60d08b5..917a1f9 100644
--- a/functions.h
+++ b/functions.h
@@ -1,4 +1,4 @@
-/* $Header: /home/cvs/mod_log_sql/functions.h,v 1.1 2004/01/20 19:38:08 urkle Exp $ */
+/* $Header: /home/cvs/mod_log_sql/functions.h,v 1.2 2004/02/05 21:59:46 urkle Exp $ */
 /* Begin the individual functions that, given a request r,
  * extract the needed information from it and return the
  * value to the calling entity.
@@ -9,6 +9,20 @@ static const char *extract_remote_host(request_rec *r, char *a)
         return (char *) ap_get_remote_host(r->connection, r->per_dir_config, REMOTE_NAME, NULL);
 }
 
+static const char *extract_remote_address(request_rec *r, char *a) __attribute__((unused));
+
+static const char *extract_remote_address(request_rec *r, char *a)
+{
+    return r->connection->remote_ip;
+}
+
+static const char *extract_local_address(request_rec *r, char *a) __attribute__((unused));
+
+static const char *extract_local_address(request_rec *r, char *a)
+{
+    return r->connection->local_ip;
+}
+
 static const char *extract_remote_logname(request_rec *r, char *a)
 {
         return (char *) ap_get_remote_logname(r);
@@ -29,19 +43,21 @@ static const char *extract_remote_user(request_rec *r, char *a)
         return rvalue;
 }
 
-static const char *extract_request_method(request_rec *r, char *a)
-{
-        return r->method;
-}
-
-static const char *extract_request_protocol(request_rec *r, char *a)
-{
-        return r->protocol;
-}
-
 static const char *extract_request_line(request_rec *r, char *a)
 {
-        return r->the_request;
+        /* Upddated to mod_log_config logic */
+        /* NOTE: If the original request contained a password, we
+         * re-write the request line here to contain XXXXXX instead:
+         * (note the truncation before the protocol string for HTTP/0.9 requests)
+         * (note also that r->the_request contains the unmodified request)
+         */
+        return (r->parsed_uri.password) 
+                                ? apr_pstrcat(r->pool, r->method, " ",
+                                        apr_uri_unparse(r->pool,
+                                                &r->parsed_uri, 0),
+                                        r->assbackwards ? NULL : " ", 
+                                        r->protocol, NULL)
+                                : r->the_request;
 }
 
 static const char *extract_request_file(request_rec *r, char *a)
@@ -54,47 +70,31 @@ static const char *extract_request_uri(request_rec *r, char *a)
         return r->uri;
 }
 
-static const char *extract_request_args(request_rec *r, char *a)
-{
-        return r->args;
-}
-
-static const char *extract_status(request_rec *r, char *a)
+static const char *extract_request_method(request_rec *r, char *a)
 {
-        if (r->status <= 0) {
-                return "-";
-        } else {
-                return apr_psprintf(r->pool, "%d", r->status);
-        }
+        return r->method;
 }
 
-static const char *extract_bytes_sent(request_rec *r, char *a)
+static const char *extract_request_protocol(request_rec *r, char *a)
 {
-        if (!r->sent_bodyct || !r->bytes_sent) {
-                return "-";
-        } else {
-                return apr_psprintf(r->pool, "%" APR_OFF_T_FMT, r->bytes_sent);
-        }
+        return r->protocol;
 }
 
-/*
-static const char *extract_header_in(request_rec *r, char *a)
+static const char *extract_request_query(request_rec *r, char *a)
 {
-        return table_get(r->headers_in, a);
+        return (r->args) ? apr_pstrcat(r->pool, "?",
+                                                r->args, NULL)
+                                         : "";
 }
 
-static const char *extract_header_out(request_rec *r, char *a)
+static const char *extract_status(request_rec *r, char *a)
 {
-        const char *cp = table_get(r->headers_out, a);
-        if (!strcasecmp(a, "Content-type") && r->content_type) {
-                cp = r->content_type;
-        }
-        if (cp) {
-                return cp;
+        if (r->status <= 0) {
+                return "-";
+        } else {
+                return apr_psprintf(r->pool, "%d", r->status);
         }
-        return table_get(r->err_headers_out, a);
 }
-*/
 
 static const char *extract_virtual_host(request_rec *r, char *a)
 {
@@ -115,6 +115,15 @@ static const char *extract_server_port(request_rec *r, char *a)
                         r->server->port ? r->server->port : ap_default_port(r));
 }
 
+/* This respects the setting of UseCanonicalName so that
+ * the dynamic mass virtual hosting trick works better.
+ */
+static const char *log_server_name(request_rec *r, char *a) __attribute__((unused));
+static const char *log_server_name(request_rec *r, char *a)
+{
+    return ap_get_server_name(r);
+}
+
 static const char *extract_child_pid(request_rec *r, char *a)
 {
     if (*a == '\0' || !strcmp(a, "pid")) {
@@ -158,83 +167,6 @@ static const char *extract_agent(request_rec *r, char *a)
     }
 }
 
-static const char *extract_cookie(request_rec *r, char *a)
-{
-    const char *cookiestr;
-    char *cookieend;
-        char *isvalid;
-        char *cookiebuf;
-
-        logsql_state *cls = ap_get_module_config(r->server->module_config,
-                                                                                        &log_sql_module);
-
-        if (cls->cookie_name != NULL) {
-                #ifdef DEBUG
-                        log_error(APLOG_MARK,APLOG_DEBUG, r->server,
-                                "watching for cookie '%s'", cls->cookie_name);
-                #endif
-
-                /* Fetch out the cookie header */
-                cookiestr  = (char *)apr_table_get(r->headers_in,  "cookie2");
-            if (cookiestr != NULL) {
-                        #ifdef DEBUG
-                                log_error(APLOG_MARK,APLOG_DEBUG, r->server,
-                                        "Cookie2: [%s]", cookiestr);
-                        #endif
-                        /* Does the cookie string contain one with our name? */
-                        isvalid = strstr(cookiestr, cls->cookie_name);
-                        if (isvalid != NULL) {
-                                /* Move past the cookie name and equal sign */
-                                isvalid += strlen(cls->cookie_name) + 1;
-                                /* Duplicate it into the pool */
-                            cookiebuf = apr_pstrdup(r->pool, isvalid);
-                                /* Segregate just this cookie out of the string
-                                 * with a terminating nul at the first semicolon */
-                            cookieend = strchr(cookiebuf, ';');
-                            if (cookieend != NULL)
-                               *cookieend = '\0';
-                                return cookiebuf;
-                        }
-                }
-
-                cookiestr  = (char *)apr_table_get(r->headers_in,  "cookie");
-            if (cookiestr != NULL) {
-                        #ifdef DEBUG
-                                log_error(APLOG_MARK,APLOG_DEBUG,r->server,
-                                        "Cookie: [%s]", cookiestr);
-                        #endif
-                        isvalid = strstr(cookiestr, cls->cookie_name);
-                        if (isvalid != NULL) {
-                                isvalid += strlen(cls->cookie_name) + 1;
-                            cookiebuf = apr_pstrdup(r->pool, isvalid);
-                            cookieend = strchr(cookiebuf, ';');
-                            if (cookieend != NULL)
-                               *cookieend = '\0';
-                                return cookiebuf;
-                        }
-                }
-
-                cookiestr = apr_table_get(r->headers_out,  "set-cookie");
-            if (cookiestr != NULL) {
-                        #ifdef DEBUG
-                             log_error(APLOG_MARK,APLOG_DEBUG,r->server,
-                                        "Set-Cookie: [%s]", cookiestr);
-                        #endif
-                        isvalid = strstr(cookiestr, cls->cookie_name);
-                        if (isvalid != NULL) {
-                            isvalid += strlen(cls->cookie_name) + 1;
-                            cookiebuf = apr_pstrdup(r->pool, isvalid);
-                            cookieend = strchr(cookiebuf, ';');
-                            if (cookieend != NULL)
-                               *cookieend = '\0';
-                                return cookiebuf;
-                        }
-                }
-        }
-
-        return "-";
-}
-
 static const char *extract_specific_cookie(request_rec *r, char *a)
 {
     const char *cookiestr;
@@ -309,18 +241,12 @@ static const char *extract_specific_cookie(request_rec *r, char *a)
         return "-";
 }
 
-
-/*
-static const char *extract_note(request_rec *r, char *a)
+static const char *extract_cookie(request_rec *r, char *a)
 {
-        return apr_table_get(r->notes, a);
-
-}
-*/
+        logsql_state *cls = ap_get_module_config(r->server->module_config,
+                                                                                        &log_sql_module);
 
-static const char *extract_env_var(request_rec *r, char *a)
-{
-        return apr_table_get(r->subprocess_env, a);
+        return extract_specific_cookie(r, (char *)cls->cookie_name);
 }
 
 static const char *extract_unique_id(request_rec *r, char *a)
diff --git a/functions13.h b/functions13.h
index 1b85d0e..7fe8850 100644
--- a/functions13.h
+++ b/functions13.h
@@ -1,4 +1,17 @@
-/* $Header: /home/cvs/mod_log_sql/functions13.h,v 1.2 2004/01/20 19:38:08 urkle Exp $ */
+/* $Header: /home/cvs/mod_log_sql/functions13.h,v 1.3 2004/02/05 21:59:46 urkle Exp $ */
+
+static const char *extract_bytes_sent(request_rec *r, char *a)
+{
+    if (!r->sent_bodyct) {
+        return "-";
+    }
+    else {
+        long int bs;
+        ap_bgetopt(r->connection->client, BO_BYTECT, &bs);
+        return ap_psprintf(r->pool, "%ld", bs);
+    }
+}
+
 static const char *extract_request_time(request_rec *r, char *a)
 {
         int timz;
@@ -24,16 +37,22 @@ static const char *extract_request_time(request_rec *r, char *a)
 
 static const char *extract_request_duration(request_rec *r, char *a)
 {
-        char duration[22];                       /* Long enough for 2^64 */
-
-        ap_snprintf(duration, sizeof(duration), "%ld", (long) time(NULL) - r->request_time);
-        return ap_pstrdup(r->pool, duration);
+        return ap_psprintf(r->pool, "%ld", time(NULL) - r->request_time);
 }
 
 static const char *extract_request_timestamp(request_rec *r, char *a)
 {
-        char tstr[32];
-
-        ap_snprintf(tstr, 32, "%ld", (long) time(NULL));
-        return ap_pstrdup(r->pool, tstr);
+        return ap_psprintf(r->pool, "%ld", (long) time(NULL));
+}
+static const char *extract_connection_status(request_rec *r, char *a) __attribute__((unused));
+static const char *extract_connection_status(request_rec *r, char *a)
+{
+    if (r->connection->aborted)
+        return "X";
+
+    if ((r->connection->keepalive) && 
+        ((r->server->keep_alive_max - r->connection->keepalives) > 0)) {
+        return "+";
+    }
+    return "-";
 }
diff --git a/functions20.h b/functions20.h
index c8701a2..31d9e4b 100644
--- a/functions20.h
+++ b/functions20.h
@@ -1,5 +1,14 @@
-/* $Header: /home/cvs/mod_log_sql/functions20.h,v 1.2 2004/01/20 19:38:08 urkle Exp $ */
+/* $Header: /home/cvs/mod_log_sql/functions20.h,v 1.3 2004/02/05 21:59:46 urkle Exp $ */
 /* functions */
+static const char *extract_bytes_sent(request_rec *r, char *a)
+{
+        if (!r->sent_bodyct || !r->bytes_sent) {
+                return "-";
+        } else {
+                return apr_psprintf(r->pool, "%" APR_OFF_T_FMT, r->bytes_sent);
+        }
+}
+
 static const char *extract_request_time_custom(request_rec *r, char *a,
                                            apr_time_exp_t *xt)
 {
@@ -91,3 +100,17 @@ static const char *extract_request_timestamp(request_rec *r, char *a)
 {
         return apr_psprintf(r->pool, "%"APR_TIME_T_FMT, apr_time_sec(apr_time_now()));
 }
+
+static const char *extract_connection_status(request_rec *r, char *a) __attribute__((unused));
+static const char *extract_connection_status(request_rec *r, char *a)
+{
+    if (r->connection->aborted)
+        return "X";
+
+    if (r->connection->keepalive == AP_CONN_KEEPALIVE && 
+        (!r->server->keep_alive_max ||
+         (r->server->keep_alive_max - r->connection->keepalives) > 0)) {
+        return "+";
+    }
+    return "-";
+}
diff --git a/m4/mod_ssl.m4 b/m4/mod_ssl.m4
index a8c6103..c431bce 100644
--- a/m4/mod_ssl.m4
+++ b/m4/mod_ssl.m4
@@ -18,6 +18,7 @@ AC_ARG_WITH(
                 db-inc,
                 [AC_HELP_STRING([--with-db-inc=DIR],[Location of DB header files])],
                 db_incdir="$withval",
+                db_incdir="/usr/include/db1"
         )
 
         if test "x$ssl_val" = "xyes"; then
diff --git a/mod_log_sql.c b/mod_log_sql.c
index f4b8c16..7320f66 100644
--- a/mod_log_sql.c
+++ b/mod_log_sql.c
@@ -1,4 +1,4 @@
-/* $Header: /home/cvs/mod_log_sql/mod_log_sql.c,v 1.13 2004/02/04 02:16:33 urkle Exp $ */
+/* $Header: /home/cvs/mod_log_sql/mod_log_sql.c,v 1.14 2004/02/05 21:59:46 urkle Exp $ */
 /* --------*
  * DEFINES *
  * --------*/
@@ -717,12 +717,13 @@ static void log_sql_module_init(server_rec *s, apr_pool_t *p)
         if (!global_config.tcpport)
                 global_config.tcpport = 3306;
 
+        /* TODO: Add local_address, remote_address, server_name, connection_status */
         /* Register handlers */
         log_sql_register_item(s,p,'A', extract_agent,             "agent",            1, 1);
-        log_sql_register_item(s,p,'a', extract_request_args,      "request_args",     1, 1);
+        log_sql_register_item(s,p,'a', extract_request_query,     "request_args",     1, 1);
         log_sql_register_item(s,p,'b', extract_bytes_sent,        "bytes_sent",       0, 0);
     log_sql_register_item(s,p,'c', extract_cookie,            "cookie",           0, 1);
-    log_sql_register_item(s,p,'e', extract_env_var,           "env_var",          0, 1);
+        /* TODO: Document */
     log_sql_register_item(s,p,'f', extract_request_file,      "request_file",     0, 1);
         log_sql_register_item(s,p,'H', extract_request_protocol,  "request_protocol", 0, 1);
         log_sql_register_item(s,p,'h', extract_remote_host,       "remote_host",      0, 1);
diff --git a/mod_log_sql.prj b/mod_log_sql.prj
index 9193940..ad294d5 100644
--- a/mod_log_sql.prj
+++ b/mod_log_sql.prj
@@ -52,7 +52,7 @@ anjuta.program.arguments=
 
 module.include.name=.
 module.include.type=
-module.include.expanded=0
+module.include.expanded=1
 module.include.files=\
         apache13.h\
         apache20.h\
@@ -98,7 +98,8 @@ module.doc.files=\
         INSTALL\
         Documentation/documentation.lyx\
         CHANGELOG\
-        LICENSE
+        LICENSE\
+        AUTHORS
 
 module.po.expanded=0
 module.po.files=