source: protocols/msn/passport.c @ a2582c8

/* passport.c
 *
 * Functions to login to microsoft passport service for Messenger
 * Copyright (C) 2004 Wouter Paesen <wouter@blue-gate.be>
 * Copyright (C) 2004 Wilmer van der Gaast <wilmer@gaast.net>
 *
 * This program is free software; you can redistribute it and/or modify             
 * it under the terms of the GNU General Public License version 2                   
 * as published by the Free Software Foundation                                     
 *                                                                                   
 * This program is distributed in the hope that is will be useful,                  
 * bit WITHOU ANY WARRANTY; without even the implied warranty of                   
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the                    
 * GNU General Public License for more details.                                     
 *                                                                                   
 * You should have received a copy of the GNU General Public License                
 * along with this program; if not, write to the Free Software                      
 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA          
 *
 */

#include "http_client.h"
#include "passport.h"
#include "msn.h"
#include "bitlbee.h"
#include <ctype.h>
#include <errno.h>

#define MSN_BUF_LEN 8192

static char *prd_cached = NULL;

static int passport_get_id_real( gpointer func, gpointer data, char *header );
static void passport_get_id_ready( struct http_request *req );

static int passport_retrieve_dalogin( gpointer data, gpointer func, char *header );
static void passport_retrieve_dalogin_ready( struct http_request *req );

static char *passport_create_header( char *cookie, char *email, char *pwd );
static void destroy_reply( struct passport_reply *rep );

int passport_get_id( gpointer func, gpointer data, char *username, char *password, char *cookie )
{
        char *header = passport_create_header( cookie, username, password );
        
        if( prd_cached == NULL )
                return passport_retrieve_dalogin( func, data, header );
        else
                return passport_get_id_real( func, data, header );
}

static int passport_get_id_real( gpointer func, gpointer data, char *header )
{
        struct passport_reply *rep;
        char *server, *dummy, *reqs;
        struct http_request *req;
        
        rep = g_new0( struct passport_reply, 1 );
        rep->data = data;
        rep->func = func;
        
        server = g_strdup( prd_cached );
        dummy = strchr( server, '/' );
        
        if( dummy == NULL )
        {
                destroy_reply( rep );
                return( 0 );
        }
        
        reqs = g_strdup_printf( "GET %s HTTP/1.0\r\n%s\r\n\r\n", dummy, header );
        
        *dummy = 0;
        req = http_dorequest( server, 443, 1, reqs, passport_get_id_ready, rep );
        
        g_free( server );
        g_free( reqs );
        
        if( req == NULL )
                destroy_reply( rep );
        
        return( req != NULL );
}

static void passport_get_id_ready( struct http_request *req )
{
        struct passport_reply *rep = req->data;
        
        if( !g_slist_find( msn_connections, rep->data ) )
        {
                destroy_reply( rep );
                return;
        }
        
        if( req->finished && req->reply_headers && req->status_code == 200 )
        {
                char *dummy;
                
                if( ( dummy = strstr( req->reply_headers, "from-PP='" ) ) )
                {
                        char *responseend;
                        
                        dummy += strlen( "from-PP='" );
                        responseend = strchr( dummy, '\'' );
                        if( responseend )
                                *responseend = 0;
                        
                        rep->result = g_strdup( dummy );
                }
                else
                {
                        rep->error_string = g_strdup( "Could not parse Passport server response" );
                }
        }
        else
        {
                rep->error_string = g_strdup_printf( "HTTP error: %s",
                                      req->status_string ? req->status_string : "Unknown error" );
        }
        
        rep->func( rep );
        destroy_reply( rep );
}

static char *passport_create_header( char *cookie, char *email, char *pwd )
{
        char *buffer = g_new0( char, 2048 );
        char *currenttoken;
        char *email_enc, *pwd_enc;
        
        email_enc = g_new0( char, strlen( email ) * 3 + 1 );
        strcpy( email_enc, email );
        http_encode( email_enc );
        
        pwd_enc = g_new0( char, strlen( pwd ) * 3 + 1 );
        strcpy( pwd_enc, pwd );
        http_encode( pwd_enc );
        
        currenttoken = strstr( cookie, "lc=" );
        if( currenttoken == NULL )
                return( NULL );
        
        g_snprintf( buffer, 2048,
                    "Authorization: Passport1.4 OrgVerb=GET,"
                    "OrgURL=http%%3A%%2F%%2Fmessenger%%2Emsn%%2Ecom,"
                    "sign-in=%s,pwd=%s,%s", email_enc, pwd_enc,
                    currenttoken );
        
        g_free( email_enc );
        g_free( pwd_enc );
        
        return( buffer );
}

#define PPR_REQUEST "GET /rdr/pprdr.asp HTTP/1.0\r\n\r\n"
static int passport_retrieve_dalogin( gpointer func, gpointer data, char *header )
{
        struct passport_reply *rep = g_new0( struct passport_reply, 1 );
        struct http_request *req;
        
        rep->data = data;
        rep->func = func;
        rep->header = header;
        
        req = http_dorequest( "nexus.passport.com", 443, 1, PPR_REQUEST, passport_retrieve_dalogin_ready, rep );
        
        if( !req )
                destroy_reply( rep );
        
        return( req != NULL );
}

static void passport_retrieve_dalogin_ready( struct http_request *req )
{
        struct passport_reply *rep = req->data;
        char *dalogin;
        char *urlend;
        
        if( !g_slist_find( msn_connections, rep->data ) )
        {
                destroy_reply( rep );
                return;
        }
        
        if( !req->finished || !req->reply_headers || req->status_code != 200 )
        {
                rep->error_string = g_strdup_printf( "HTTP error while fetching DALogin (%s)",
                                        req->status_string ? req->status_string : "Unknown error" );
                goto failure;
        }
        
        dalogin = strstr( req->reply_headers, "DALogin=" );     
        
        if( !dalogin )
        {
                rep->error_string = g_strdup( "Parse error while fetching DALogin" );
                goto failure;
        }
        
        dalogin += strlen( "DALogin=" );
        urlend = strchr( dalogin, ',' );
        if( urlend )
                *urlend = 0;
        
        /* strip the http(s):// part from the url */
        urlend = strstr( urlend, "://" );
        if( urlend )
                dalogin = urlend + strlen( "://" );
        
        if( prd_cached == NULL )
                prd_cached = g_strdup( dalogin );
        
        if( passport_get_id_real( rep->func, rep->data, rep->header ) )
        {
                destroy_reply( rep );
                return;
        }
        
failure:        
        rep->func( rep );
        destroy_reply( rep );
}

static void destroy_reply( struct passport_reply *rep )
{
        g_free( rep->result );
        g_free( rep->header );
        g_free( rep->error_string );
        g_free( rep );
}