Changeset 9779c18 for protocols/http_client.c

Timestamp:

2006-06-03T20:20:43Z (18 years ago)

Author:

Jelmer Vernooij <jelmer@…>

Branches:

master

Children:

5973412

Parents:

a15c097 (diff), fb62f81f (diff)
Note: this is a merge changeset, the changes displayed below correspond to the merge itself.
Use the (diff) links above to see all the changes relative to each parent.

Message:

[merge] Wilmer

File:

• protocols/http_client.c (modified) (13 diffs)

protocols/http_client.c

@@ -69 +69 @@
         
         return( req );
+}
+
+void *http_dorequest_url( char *url_string, http_input_function func, gpointer data )
+{
+        url_t *url = g_new0( url_t, 1 );
+        char *request;
+        void *ret;
+        
+        if( !url_set( url, url_string ) )
+        {
+                g_free( url );
+                return NULL;
+        }
+        
+        if( url->proto != PROTO_HTTP && url->proto != PROTO_HTTPS )
+        {
+                g_free( url );
+                return NULL;
+        }
+        
+        request = g_strdup_printf( "GET %s HTTP/1.0\r\n"
+                                   "Host: %s\r\n"
+                                   "User-Agent: BitlBee " BITLBEE_VERSION " " ARCH "/" CPU "\r\n"
+                                   "\r\n", url->file, url->host );
+        
+        ret = http_dorequest( url->host, url->port,
+                              url->proto == PROTO_HTTPS, request, func, data );
+        
+        g_free( url );
+        g_free( request );
+        return ret;
 }
 
@@ -126 +157 @@
         
 error:
+        req->status_string = g_strdup( "Error while writing HTTP request" );
+        
         req->func( req );
         
@@ -185 +218 @@
                         if( !sockerr_again() )
                         {
+                                req->status_string = g_strdup( strerror( errno ) );
                                 goto cleanup;
                         }
@@ -209 +243 @@
 
 got_reply:
+        /* Maybe if the webserver is overloaded, or when there's bad SSL
+           support... */
+        if( req->bytes_read == 0 )
+        {
+                req->status_string = g_strdup( "Empty HTTP reply" );
+                goto cleanup;
+        }
+        
         /* Zero termination is very convenient. */
         req->reply_headers[req->bytes_read] = 0;
@@ -222 +264 @@
                 evil_server = 1;
         }
-        else
+        else if( end1 )
         {
                 end1 += 2;
         }
-        
-        if( end1 )
-        {
-                *end1 = 0;
-                
-                if( evil_server )
-                        req->reply_body = end1 + 1;
+        else
+        {
+                req->status_string = g_strdup( "Malformed HTTP reply" );
+                goto cleanup;
+        }
+        
+        *end1 = 0;
+        
+        if( evil_server )
+                req->reply_body = end1 + 1;
+        else
+                req->reply_body = end1 + 2;
+        
+        req->body_size = req->reply_headers + req->bytes_read - req->reply_body;
+        
+        if( ( end1 = strchr( req->reply_headers, ' ' ) ) != NULL )
+        {
+                if( sscanf( end1 + 1, "%d", &req->status_code ) != 1 )
+                {
+                        req->status_string = g_strdup( "Can't parse status code" );
+                        req->status_code = -1;
+                }
                 else
-                        req->reply_body = end1 + 2;
-        }
-        
-        if( ( end1 = strchr( req->reply_headers, ' ' ) ) != NULL )
-        {
-                if( sscanf( end1 + 1, "%d", &req->status_code ) != 1 )
-                        req->status_code = -1;
-        }
-        else
-        {
+                {
+                        char *eol;
+                        
+                        if( evil_server )
+                                eol = strchr( end1, '\n' );
+                        else
+                                eol = strchr( end1, '\r' );
+                        
+                        req->status_string = g_strndup( end1 + 1, eol - end1 - 1 );
+                        
+                        /* Just to be sure... */
+                        if( ( eol = strchr( req->status_string, '\r' ) ) )
+                                *eol = 0;
+                        if( ( eol = strchr( req->status_string, '\n' ) ) )
+                                *eol = 0;
+                }
+        }
+        else
+        {
+                req->status_string = g_strdup( "Can't locate status code" );
                 req->status_code = -1;
         }
@@ -252 +319 @@
                 int error = 0, new_port, new_proto;
                 
+                /* We might fill it again, so let's not leak any memory. */
+                g_free( req->status_string );
+                req->status_string = NULL;
+                
                 loc = strstr( req->reply_headers, "\nLocation: " );
                 if( loc == NULL ) /* We can't handle this redirect... */
+                {
+                        req->status_string = g_strdup( "Can't locate Location: header" );
                         goto cleanup;
+                }
                 
                 loc += 11;
@@ -271 +345 @@
                            don't need this yet anyway, I won't implement it. */
                         
+                        req->status_string = g_strdup( "Can't handle recursive redirects" );
+                        
                         goto cleanup;
                 }
@@ -288 +364 @@
                         if( !url_set( url, loc ) )
                         {
+                                req->status_string = g_strdup( "Malformed redirect URL" );
                                 g_free( url );
                                 goto cleanup;
@@ -298 +375 @@
                            going to use strcat(), whether you like it or not. :-) */
                         
-                        /* First, find the GET/POST/whatever from the original request. */
-                        s = strchr( req->request, ' ' );
+                        sprintf( new_request, "GET %s HTTP/1.0", url->file );
+                        
+                        s = strstr( req->request, "\r\n" );
                         if( s == NULL )
                         {
+                                req->status_string = g_strdup( "Error while rebuilding request string" );
                                 g_free( new_request );
                                 g_free( url );
@@ -307 +386 @@
                         }
                         
-                        *s = 0;
-                        sprintf( new_request, "%s %s HTTP/1.0\r\n", req->request, url->file );
-                        *s = ' ';
-                        
-                        s = strstr( req->request, "\r\n" );
-                        if( s == NULL )
-                        {
-                                g_free( new_request );
-                                g_free( url );
-                                goto cleanup;
-                        }
-                        
-                        strcat( new_request, s + 2 );
+                        strcat( new_request, s );
                         new_host = g_strdup( url->host );
                         new_port = url->port;
@@ -333 +400 @@
                 
                 req->fd = -1;
-                req->ssl = 0;
+                req->ssl = NULL;
                 
                 if( new_proto == PROTO_HTTPS )
@@ -351 +418 @@
                 if( error )
                 {
+                        req->status_string = g_strdup( "Connection problem during redirect" );
                         g_free( new_request );
                         goto cleanup;
@@ -379 +447 @@
         g_free( req->request );
         g_free( req->reply_headers );
+        g_free( req->status_string );
         g_free( req );
 }