source: protocols/msn/passport.c @ d3307e2

/* 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 "ssl_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 char *passport_create_header( char *reply, char *email, char *pwd );
static int passport_retrieve_dalogin( gpointer data, gpointer func, char *header );
static void passport_retrieve_dalogin_connected( gpointer data, void *ssl, GaimInputCondition cond );
static int passport_get_id_from( gpointer data, gpointer func, char *header_i, char *url );
static void passport_get_id_connected( gpointer data, void *ssl, GaimInputCondition cond );
static void destroy_reply( struct passport_reply *rep );


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


static char *passport_create_header( char *reply, 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( reply, "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 );
}


static int passport_retrieve_dalogin( gpointer data, gpointer func, char *header )
{
        struct passport_reply *rep = g_new0( struct passport_reply, 1 );
        void *ssl;
        
        rep->data = data;
        rep->func = func;
        rep->header = header;
        
        ssl = ssl_connect( "nexus.passport.com", 443, passport_retrieve_dalogin_connected, rep );
        
        if( !ssl )
                destroy_reply( rep );
        
        return( ssl != NULL );
}

#define PPR_BUFFERSIZE 2048
#define PPR_REQUEST "GET /rdr/pprdr.asp HTTP/1.0\r\n\r\n"
static void passport_retrieve_dalogin_connected( gpointer data, void *ssl, GaimInputCondition cond )
{
        int ret;
        char buffer[PPR_BUFFERSIZE+1];
        struct passport_reply *rep = data;
        
        if( !g_slist_find( msn_connections, rep->data ) )
        {
                if( ssl ) ssl_disconnect( ssl );
                destroy_reply( rep );
                return;
        }
        
        if( !ssl )
        {
                rep->func( rep );
                destroy_reply( rep );
                return;
        }
        
        ssl_write( ssl, PPR_REQUEST, strlen( PPR_REQUEST ) );
        
        if( ( ret = ssl_read( ssl, buffer, PPR_BUFFERSIZE ) ) <= 0 )
        {
                goto failure;
        }

        {
                char *dalogin = strstr( buffer, "DALogin=" );
                char *urlend;
                
                if( !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_from( rep->data, rep->func, rep->header, prd_cached ) )
        {
                ssl_disconnect( ssl );
                destroy_reply( rep );
                return;
        }
        
failure:        
        ssl_disconnect( ssl );
        rep->func( rep );
        destroy_reply( rep );
}


static int passport_get_id_from( gpointer data, gpointer func, char *header_i, char *url )
{
        struct passport_reply *rep = g_new0( struct passport_reply, 1 );
        char server[512], *dummy;
        void *ssl;
        
        rep->data = data;
        rep->func = func;
        rep->redirects = 4;
        
        strncpy( server, url, 512 );
        dummy = strchr( server, '/' );
        if( dummy )
                *dummy = 0;
        
        ssl = ssl_connect( server, 443, passport_get_id_connected, rep );
        
        if( ssl )
        {
                rep->header = g_strdup( header_i );
                rep->url = g_strdup( url );
        }
        else
        {
                destroy_reply( rep );
        }
        
        return( ssl != NULL );
}

#define PPG_BUFFERSIZE 4096
static void passport_get_id_connected( gpointer data, void *ssl, GaimInputCondition cond )
{
        struct passport_reply *rep = data;
        char server[512], buffer[PPG_BUFFERSIZE+1], *dummy;
        int ret;
        
        if( !g_slist_find( msn_connections, rep->data ) )
        {
                if( ssl ) ssl_disconnect( ssl );
                destroy_reply( rep );
                return;
        }
        
        if( !ssl )
        {
                rep->func( rep );
                destroy_reply( rep );
                return;
        }
        
        memset( buffer, 0, PPG_BUFFERSIZE + 1 );
        
        strncpy( server, rep->url, 512 );
        dummy = strchr( server, '/' );
        if( dummy == NULL )
                goto end;
        
        g_snprintf( buffer, PPG_BUFFERSIZE - 1, "GET %s HTTP/1.0\r\n"
                    "%s\r\n\r\n", dummy, rep->header );
        
        ssl_write( ssl, buffer, strlen( buffer ) );
        memset( buffer, 0, PPG_BUFFERSIZE + 1 );
        
        {
                char *buffer2 = buffer;
                
                while( ( ( ret = ssl_read( ssl, buffer2, 512 ) ) > 0 ) &&
                       ( buffer + PPG_BUFFERSIZE - buffer2 - ret - 512 >= 0 ) )
                {
                        buffer2 += ret;
                }
        }
        
        if( *buffer == 0 )
                goto end;
        
        if( ( dummy = strstr( buffer, "Location:" ) ) )
        {
                char *urlend;
                
                rep->redirects --;
                if( rep->redirects == 0 )
                        goto end;
                
                dummy += strlen( "Location:" );
                while( isspace( *dummy ) ) dummy ++;
                urlend = dummy;
                while( !isspace( *urlend ) ) urlend ++;
                *urlend = 0;
                if( ( urlend = strstr( dummy, "://" ) ) )
                        dummy = urlend + strlen( "://" );
                
                g_free( rep->url );
                rep->url = g_strdup( dummy );
                
                strncpy( server, dummy, sizeof( server ) - 1 );
                dummy = strchr( server, '/' );
                if( dummy ) *dummy = 0;
                
                ssl_disconnect( ssl );
                
                if( ssl_connect( server, 443, passport_get_id_connected, rep ) )
                {
                        return;
                }
                else
                {
                        rep->func( rep );
                        destroy_reply( rep );
                        return;
                }
        }
        else if( strstr( buffer, "200 OK" ) )
        {
                if( ( dummy = strstr( buffer, "from-PP='" ) ) )
                {
                        char *responseend;
                        
                        dummy += strlen( "from-PP='" );
                        responseend = strchr( dummy, '\'' );
                        if( responseend )
                                *responseend = 0;
                        
                        rep->result = g_strdup( dummy );
                }
        }
        
end:
        ssl_disconnect( ssl );
        rep->func( rep );
        destroy_reply( rep );
}


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