diff options
Diffstat (limited to 'kopete/protocols/msn/msnswitchboardsocket.cpp')
| -rw-r--r-- | kopete/protocols/msn/msnswitchboardsocket.cpp | 1142 |
1 files changed, 1142 insertions, 0 deletions
diff --git a/kopete/protocols/msn/msnswitchboardsocket.cpp b/kopete/protocols/msn/msnswitchboardsocket.cpp new file mode 100644 index 00000000..77b7b550 --- /dev/null +++ b/kopete/protocols/msn/msnswitchboardsocket.cpp @@ -0,0 +1,1142 @@ +/* + msnswitchboardsocket.cpp - switch board connection socket + + Copyright (c) 2002 by Martijn Klingens <klingens@kde.org> + Copyright (c) 2002-2006 by Olivier Goffart <ogoffart@ kde.org> + Kopete (c) 2002-2005 by the Kopete developers <kopete-devel@kde.org> + + Portions of this code are taken from KMerlin, + (c) 2001 by Olaf Lueg <olueg@olsd.de> + + ************************************************************************* + * * + * This program is free software; you can redistribute it and/or modify * + * it under the terms of the GNU General Public License as published by * + * the Free Software Foundation; either version 2 of the License, or * + * (at your option) any later version. * + * * + ************************************************************************* +*/ + + +#include "msnswitchboardsocket.h" + +#include <stdlib.h> +#include <time.h> +#include <cmath> + +// qt +#include <tqstylesheet.h> +#include <tqregexp.h> +#include <tqimage.h> +#include <tqtimer.h> +#include <tqfile.h> +#include <tqfileinfo.h> + +// kde +#include <kdebug.h> +#include <tdemessagebox.h> +#include <tdeapplication.h> +#include <tdeaboutdata.h> +#include <tdetempfile.h> +#include <tdeconfig.h> +#include <kmdcodec.h> +#include <kstandarddirs.h> +#include <tdetempfile.h> + +// for the display picture +#include <msncontact.h> +#include "msnnotifysocket.h" + +//kopete +#include "msnaccount.h" +#include "msnprotocol.h" +#include "kopetemessage.h" +#include "kopetecontact.h" +#include "kopeteuiglobal.h" +#include "kopeteemoticons.h" +//#include "kopeteaccountmanager.h" +//#include "kopeteprotocol.h" + +#include "sha1.h" + +#include "dispatcher.h" +using P2P::Dispatcher; + +MSNSwitchBoardSocket::MSNSwitchBoardSocket( MSNAccount *account , TQObject *parent ) +: MSNSocket( parent ) +{ + m_account = account; + m_recvIcons=0; + m_emoticonTimer=0L; + m_chunks=0; + m_clientcapsSent=false; + m_dispatcher = 0l; + m_keepAlive = 0l; + m_keepAliveNb=0; +} + +MSNSwitchBoardSocket::~MSNSwitchBoardSocket() +{ + kdDebug(14140) << k_funcinfo << endl; + + TQMap<TQString , TQPair<TQString , KTempFile*> >::Iterator it; + for ( it = m_emoticons.begin(); it != m_emoticons.end(); ++it ) + { + delete it.data().second; + } +} + +void MSNSwitchBoardSocket::connectToSwitchBoard(TQString ID, TQString address, TQString auth) +{ + // we need these for the handshake later on (when we're connected) + m_ID = ID; + m_auth = auth; + + TQString server = address.left( address.find( ":" ) ); + uint port = address.right( address.length() - address.findRev( ":" ) - 1 ).toUInt(); + + TQObject::connect( this, TQT_SIGNAL( blockRead( const TQByteArray & ) ), + this, TQT_SLOT(slotReadMessage( const TQByteArray & ) ) ); + + TQObject::connect( this, TQT_SIGNAL( onlineStatusChanged( MSNSocket::OnlineStatus ) ), + this, TQT_SLOT( slotOnlineStatusChanged( MSNSocket::OnlineStatus ) ) ); + + TQObject::connect( this, TQT_SIGNAL( socketClosed( ) ), + this, TQT_SLOT( slotSocketClosed( ) ) ); + + connect( server, port ); +} + +void MSNSwitchBoardSocket::handleError( uint code, uint id ) +{ + kdDebug(14140) << k_funcinfo << endl; + + TQString msg; + MSNSocket::ErrorType type; + + switch( code ) + { + case 208: + { + msg = i18n( "Invalid user:\n" + "this MSN user does not exist; please check the MSN ID." ); + type = MSNSocket::ErrorServerError; + + userLeftChat(m_msgHandle , i18n("user never joined")); + break; + } + case 215: + { + msg = i18n( "The user %1 is already in this chat." ).arg( m_msgHandle ); + type = MSNSocket::ErrorServerError; + + //userLeftChat(m_msgHandle , i18n("user was twice in this chat") ); //(the user shouln't join there + break; + } + case 216: + { + msg = i18n( "The user %1 is online but has blocked you:\nyou can not talk to this user." ).arg( m_msgHandle ); + type = MSNSocket::ErrorInformation; + + userLeftChat(m_msgHandle, i18n("user blocked you")); + break; + } + case 217: + { + // TODO: we need to know the nickname instead of the handle. + msg = i18n( "The user %1 is currently not signed in.\n" "Messages will not be delivered." ).arg( m_msgHandle ); + type = MSNSocket::ErrorServerError; + + userLeftChat(m_msgHandle, i18n("user disconnected")); + break; + } + case 713: + { + TQString msg = i18n( "You are trying to invite too many contacts to this chat at the same time" ).arg( m_msgHandle ); + type = MSNSocket::ErrorInformation; + + userLeftChat(m_msgHandle, i18n("user blocked you")); + break; + } + case 911: + { + msg = i18n("Kopete MSN plugin has trouble authenticating with switchboard server."); + type = MSNSocket::ErrorServerError; + + break; + } + default: + MSNSocket::handleError( code, id ); + break; + } + + if( !msg.isEmpty() ) + emit errorMessage( type, msg ); +} + +void MSNSwitchBoardSocket::parseCommand( const TQString &cmd, uint id , + const TQString &data ) +{ + if( cmd == "NAK" ) + { + emit msgAcknowledgement(id, false); // msg was not accepted + } + else if( cmd == "ACK" ) + { + emit msgAcknowledgement(id, true); // msg has received + } + else if( cmd == "JOI" ) + { + // new user joins the chat, update user in chat list + TQString handle = data.section( ' ', 0, 0 ); + TQString screenname = unescape(data.section( ' ', 1, 1 )); + if( !m_chatMembers.contains( handle ) ) + m_chatMembers.append( handle ); + emit userJoined( handle, screenname, false ); + } + else if( cmd == "IRO" ) + { + // we have joined a multi chat session- this are the users in this chat + TQString handle = data.section( ' ', 2, 2 ); + if( !m_chatMembers.contains( handle ) ) + m_chatMembers.append( handle ); + + TQString screenname = unescape(data.section( ' ', 3, 3)); + emit userJoined( handle, screenname, true ); + } + else if( cmd == "USR" ) + { + slotInviteContact(m_msgHandle); + } + else if( cmd == "BYE" ) + { + // some has disconnect from chat, update user in chat list + cleanQueue(); //in case some message are waiting their emoticons, never mind, send them + + TQString handle = data.section( ' ', 0, 0 ).replace( "\r\n" , "" ); + userLeftChat( handle, (data.section( ' ', 1, 1 ) == "1" ) ? i18n("timeout") : TQString() ); + } + else if( cmd == "MSG" ) + { + TQString len = data.section( ' ', 2, 2 ); + + // we need to know who's sending is the block... + m_msgHandle = data.section( ' ', 0, 0 ); + + /*//This is WRONG! the displayName is never updated on the switchboeardsocket + //so we can't trust it. + //that's why the official client does not uptade alaws the nickname immediately. + if(m_account->contacts()[ m_msgHandle ]) + { + TQString displayName=data.section( ' ', 1, 1 ); + if(m_account->contacts()[ m_msgHandle ]->displayName() != displayName) + m_account->contacts()[ m_msgHandle ]->rename(displayName); + }*/ + + readBlock(len.toUInt()); + } +} + +void MSNSwitchBoardSocket::slotReadMessage( const TQByteArray &bytes ) +{ + TQString msg = TQString::fromUtf8(bytes, bytes.size()); + + TQRegExp rx("Content-Type: ([A-Za-z0-9/\\-]*)"); + rx.search(msg); + TQString type=rx.cap(1); + + rx=TQRegExp("User-Agent: ([A-Za-z0-9./\\-]*)"); + rx.search(msg); + TQString clientStr=rx.cap(1); + + if( !clientStr.isNull() && !m_msgHandle.isNull()) + { + Kopete::Contact *c=m_account->contacts()[m_msgHandle]; + if(c) + c->setProperty( MSNProtocol::protocol()->propClient , clientStr ); + } + + // incoming message for File-transfer + if( type== "text/x-msmsgsinvite" ) + { + emit invitation(m_msgHandle,msg); + } + else if( type== "text/x-msmsgscontrol" ) + { + TQString message; + message = msg.right( msg.length() - msg.findRev( " " ) - 1 ); + message = message.replace( "\r\n" ,"" ); + emit receivedTypingMsg( message.lower(), true ); + } + else if(type == "text/x-msnmsgr-datacast") + { + if(msg.contains("ID:")) + { + TQRegExp rx("ID: ([0-9]*)"); + rx.search(msg); + uint dataCastId = rx.cap(1).toUInt(); + if( dataCastId == 1 ) + { + kdDebug(14140) << k_funcinfo << "Received a nudge !" << endl; + emit nudgeReceived(m_msgHandle); + } + } + } + else if(type=="text/plain" /* || type.isEmpty()*/ ) + { + // Some MSN Clients (like CCMSN) don't like to stick to the rules. + // In case of CCMSN, it doesn't send what the content type is when + // sending a text message. So if it's not supplied, we'll just + // assume its that. + + TQColor fontColor; + TQFont font; + + if ( msg.contains( "X-MMS-IM-Format" ) ) + { + TQString fontName; + TQString fontInfo; + TQString color; + + rx=TQRegExp("X-MMS-IM-Format: ([^\r\n]*)"); + rx.search(msg); + fontInfo =rx.cap(1); + + color = parseFontAttr(fontInfo, "CO"); + + // FIXME: this is so BAAAAAAAAAAAAD :( + if (!color.isEmpty() && color.toInt(0,16)!=0) + { + if ( color.length() == 2) // only #RR (red color) given + fontColor.setRgb( + color.mid(0,2).toInt(0,16), + 0, + 0); + else if ( color.length() == 4) // #GGRR (green, red) given. + { + fontColor.setRgb( + color.mid(2,2).toInt(0,16), + color.mid(0,2).toInt(0,16), + 0); + } + else if ( color.length() == 6) // full #BBGGRR given + { + fontColor.setRgb( + color.mid(4,2).toInt(0, 16), + color.mid(2,2).toInt(0,16), + color.mid(0,2).toInt(0,16)); + } + } + + fontName = parseFontAttr(fontInfo, "FN").replace( "%20" , " " ); + + // Some clients like Trillian and Kopete itself send a font + // name of 'MS Serif' since MS changed the server to + // _require_ a font name specified in june 2002. + // MSN's own client defaults to 'MS Sans Serif', which also + // has issues. + // Handle 'MS Serif' and 'MS Sans Serif' as an empty font name + if( !fontName.isEmpty() && fontName != "MS Serif" && fontName != "MS Sans Serif" ) + { + TQString ef=parseFontAttr( fontInfo, "EF" ); + + font = TQFont( fontName, + parseFontAttr( fontInfo, "PF" ).toInt(), // font size + ef.contains( 'B' ) ? TQFont::Bold : TQFont::Normal, + ef.contains( 'I' ) ); + font.setUnderline(ef.contains( 'U' )); + font.setStrikeOut(ef.contains( 'S' )); + } + } + + TQPtrList<Kopete::Contact> others; + others.append( m_account->myself() ); + TQStringList::iterator it2; + for( it2 = m_chatMembers.begin(); it2 != m_chatMembers.end(); ++it2 ) + { + if( *it2 != m_msgHandle ) + others.append( m_account->contacts()[ *it2 ] ); + } + + TQString message=msg.right( msg.length() - msg.find("\r\n\r\n") - 4 ); + + //Stupid MSN PLUS colors code. message with incorrect charactere are not showed correctly in the chatwindow. + //TODO: parse theses one to show the color too in Kopete + message.replace("\3","").replace("\4","").replace("\2","").replace("\5","").replace("\6","").replace("\7",""); + + if(!m_account->contacts()[m_msgHandle]) + { + //this may happens if the contact has been deleted. + kdDebug(14140) << k_funcinfo <<"WARNING: contact is null, adding it" <<endl; + if( !m_chatMembers.contains( m_msgHandle ) ) + m_chatMembers.append( m_msgHandle ); + emit userJoined( m_msgHandle , m_msgHandle , false); + } + + Kopete::Message kmsg( m_account->contacts()[ m_msgHandle ], others, + message, + Kopete::Message::Inbound , Kopete::Message::PlainText ); + + kmsg.setFg( fontColor ); + kmsg.setFont( font ); + + rx=TQRegExp("Chunks: ([0-9]*)"); + rx.search(msg); + unsigned int chunks=rx.cap(1).toUInt(); + rx=TQRegExp("Chunk: ([0-9]*)"); + rx.search(msg); + unsigned int chunk=rx.cap(1).toUInt(); + + if(chunk != 0 && !m_msgQueue.isEmpty()) + { + TQString msg=m_msgQueue.last().plainBody(); + m_msgQueue.pop_back(); //removes the last item + kmsg.setBody( msg+ message, Kopete::Message::PlainText ); + } + + if(chunk == 0 ) + m_chunks=chunks; + else if(chunk+1 >= m_chunks) + m_chunks=0; + + if ( m_recvIcons > 0 || m_chunks > 0) + { //Some custom emoticons are waiting to be received. so append the message to the queue + //Or the message has not been fully received, so same thing + kdDebug(14140) << k_funcinfo << "Message not fully received => append to queue. Emoticon left: " << m_recvIcons << " chunks: " << chunk+1 << " of " << m_chunks <<endl; + m_msgQueue.append( kmsg ); + if(!m_emoticonTimer) //to be sure no message will be lost, we will appends message to + { // the queue in 15 secondes even if we have not received emoticons + m_emoticonTimer=new TQTimer(this); + TQObject::connect(m_emoticonTimer , TQT_SIGNAL(timeout()) , this, TQT_SLOT(cleanQueue())); + m_emoticonTimer->start( 15000 , true ); + } + } + else + emit msgReceived( parseCustomEmoticons( kmsg ) ); + + } + else if( type== "text/x-mms-emoticon" || type== "text/x-mms-animemoticon") + { + // TODO remove Displatcher. + TDEConfig *config = TDEGlobal::config(); + config->setGroup( "MSN" ); + if ( config->readBoolEntry( "useCustomEmoticons", true ) ) + { + TQRegExp rx("([^\\s]*)[\\s]*(<msnobj [^>]*>)"); + rx.setMinimal(true); + int pos = rx.search(msg); + while( pos != -1) + { + TQString msnobj=rx.cap(2); + TQString txt=rx.cap(1); + kdDebug(14140) << k_funcinfo << "emoticon: " << txt << " msnobj: " << msnobj<< endl; + + if( !m_emoticons.contains(msnobj) || !m_emoticons[msnobj].second ) + { + m_emoticons.insert(msnobj, tqMakePair(txt,(KTempFile*)0L)); + MSNContact *c=static_cast<MSNContact*>(m_account->contacts()[m_msgHandle]); + if(!c) + return; + + // we are receiving emoticons, so delay message display until received signal + m_recvIcons++; + PeerDispatcher()->requestDisplayIcon(m_msgHandle, msnobj); + } + pos=rx.search(msg, pos+rx.matchedLength()); + } + } + } + else if( type== "application/x-msnmsgrp2p" ) + { + PeerDispatcher()->slotReadMessage(m_msgHandle, bytes); + } + else if( type == "text/x-clientcaps" ) + { + rx=TQRegExp("Client-Name: ([A-Za-z0-9.$!*/% \\-]*)"); + rx.search(msg); + clientStr=unescape( rx.cap(1) ); + + if( !clientStr.isNull() && !m_msgHandle.isNull()) + { + Kopete::Contact *c=m_account->contacts()[m_msgHandle]; + if(c) + c->setProperty( MSNProtocol::protocol()->propClient , clientStr ); + } + + if(!m_clientcapsSent) + { + TDEConfig *config = TDEGlobal::config(); + config->setGroup( "MSN" ); + + TQString JabberID; + if(config->readBoolEntry("SendJabber", true)) + JabberID=config->readEntry("JabberAccount"); + + if(!JabberID.isEmpty()) + JabberID="JabberID: "+JabberID +"\r\n"; + + if( config->readBoolEntry("SendClientInfo", true) || !JabberID.isEmpty()) + { + + TQCString message = TQString( "MIME-Version: 1.0\r\n" + "Content-Type: text/x-clientcaps\r\n" + "Client-Name: Kopete/"+escape(kapp->aboutData()->version())+"\r\n" + +JabberID+ + "\r\n" ).utf8(); + + TQString args = "U"; + sendCommand( "MSG", args, true, message ); + } + m_clientcapsSent=true; + } + + + } + else if(type == "image/gif" || msg.contains("Message-ID:")) + { + // Incoming inkformatgif. + TQRegExp regex("Message-ID: \\{([0-9A-F\\-]*)\\}"); + regex.search(msg); + TQString messageId = regex.cap(1); + regex = TQRegExp("Chunks: (\\d+)"); + regex.search(msg); + TQString chunks = regex.cap(1); + regex = TQRegExp("Chunk: (\\d+)"); + regex.search(msg); + TQString chunk = regex.cap(1); + + if(!messageId.isNull()) + { + bool valid = true; + // Retrieve the nmber of data chunks. + TQ_UINT32 numberOfChunks = chunks.toUInt(&valid); + if(valid && (numberOfChunks > 1)) + { + regex = TQRegExp("base64:([0-9a-zA-Z+/=]+)"); + regex.search(msg); + // Retrieve the first chunk of the ink format gif. + TQString base64 = regex.cap(1); + // More chunks are expected, buffer the chunk received. + InkMessage inkMessage; + inkMessage.chunks = numberOfChunks; + inkMessage.data += base64; + m_inkMessageBuffer.insert(messageId, inkMessage); + } + } + else + { + // There is only one chunk of data. + regex = TQRegExp("base64:([0-9a-zA-Z+/=]*)"); + regex.search(msg); + // Retrieve the base64 encoded ink data. + TQString data = regex.cap(1); + DispatchInkMessage(data); + } + + if(!messageId.isNull()) + { + if(m_inkMessageBuffer.contains(messageId)) + { + if(chunks.isNull()) + { + InkMessage inkMessage = m_inkMessageBuffer[messageId]; + inkMessage.data += msg.section("\r\n\r\n", -1); + if(inkMessage.chunks == chunk.toUInt() + 1) + { + DispatchInkMessage(inkMessage.data); + // Remove the ink message from the buffer. + m_inkMessageBuffer.remove(messageId); + } + } + } + } + } + else + { + kdDebug(14140) << k_funcinfo <<" Unknown type '" << type << "' message: \n"<< msg <<endl; + } +} + +void MSNSwitchBoardSocket::DispatchInkMessage(const TQString& base64String) +{ + TQByteArray image; + // Convert from base64 encoded string to byte array. + KCodecs::base64Decode(base64String.utf8() , image); + KTempFile *inkImage = new KTempFile(locateLocal( "tmp", "inkformatgif-" ), ".gif"); + inkImage->setAutoDelete(true); + inkImage->file()->writeBlock(image.data(), image.size()); + inkImage->file()->close(); + + slotEmoticonReceived(inkImage , "inkformatgif"); + inkImage = 0l; +} + +void MSNSwitchBoardSocket::sendTypingMsg( bool isTyping ) +{ + if( !isTyping ) + return; + + if ( onlineStatus() != Connected || m_chatMembers.empty()) + { + //we are not yet in a chat. + //if we send that command now, we may get disconnected. + return; + } + + + TQCString message = TQString( "MIME-Version: 1.0\r\n" + "Content-Type: text/x-msmsgscontrol\r\n" + "TypingUser: " + m_myHandle + "\r\n" + "\r\n" ).utf8(); + + // Length is appended by sendCommand() + TQString args = "U"; + sendCommand( "MSG", args, true, message ); +} + +// this Invites an Contact +void MSNSwitchBoardSocket::slotInviteContact(const TQString &handle) +{ + m_msgHandle=handle; + sendCommand( "CAL", handle ); +} +// +// Send a custum emoticon +// +int MSNSwitchBoardSocket::sendCustomEmoticon(const TQString &name, const TQString &filename) +{ + TQString picObj; + + //try to find it in the cache. + const TQMap<TQString, TQString> objectList = PeerDispatcher()->objectList; + for (TQMap<TQString,TQString>::ConstIterator it = objectList.begin(); it != objectList.end(); ++it ) + { + if(it.data() == filename) + { + picObj=it.key(); + break; + } + } + + if(picObj.isNull()) + { //if not found in the cache, generate the picture object + TQFileInfo fi(filename); + // open the icon file + TQFile pictFile(fi.filePath()); + if (pictFile.open(IO_ReadOnly)) { + + TQByteArray ar = pictFile.readAll(); + pictFile.close(); + + TQString sha1d = TQString(KCodecs::base64Encode(SHA1::hash(ar))); + TQString size = TQString::number( pictFile.size() ); + TQString all = "Creator" + m_account->accountId() + "Size" + size + "Type2Location" + fi.fileName() + "FriendlyAAA=SHA1D" + sha1d; + TQString sha1c = TQString(KCodecs::base64Encode(SHA1::hashString(all.utf8()))); + picObj = "<msnobj Creator=\"" + m_account->accountId() + "\" Size=\"" + size + "\" Type=\"2\" Location=\""+ fi.fileName() + "\" Friendly=\"AAA=\" SHA1D=\""+sha1d+ "\" SHA1C=\""+sha1c+"\"/>"; + + PeerDispatcher()->objectList.insert(picObj, filename); + } + else + return 0; + } + + TQString msg = "MIME-Version: 1.0\r\n" + "Content-Type: text/x-mms-emoticon\r\n" + "\r\n" + + name + "\t" + picObj + "\t\r\n"; + + return sendCommand("MSG", "A", true, msg.utf8()); + +} + +// this sends a short message to the server +int MSNSwitchBoardSocket::sendMsg( const Kopete::Message &msg ) +{ + if ( onlineStatus() != Connected || m_chatMembers.empty()) + { +// m_messagesQueue.append(msg); + return -1; + } + +#if 0 //this is to test webcam + if(msg.plainBody().contains("/webcam")) + { + PeerDispatcher()->startWebcam( m_myHandle , m_msgHandle); + return -3; + } +#endif + + TDEConfig *config = TDEGlobal::config(); + config->setGroup( "MSN" ); + if ( config->readBoolEntry( "exportEmoticons", false ) ) + { + TQMap<TQString, TQStringList> emap = Kopete::Emoticons::self()->emoticonAndPicList(); + + // Check the list for any custom emoticons + for (TQMap<TQString, TQStringList>::const_iterator itr = emap.begin(); itr != emap.end(); itr++) + { + for ( TQStringList::const_iterator itr2 = itr.data().constBegin(); itr2 != itr.data().constEnd(); ++itr2 ) + { + if ( msg.plainBody().contains( *itr2 ) ) + sendCustomEmoticon( *itr2, itr.key() ); + } + } + } + + if( msg.format() & Kopete::Message::RichText ) + { + TQRegExp regex("^\\s*<img src=\"([^>\"]+)\"[^>]*>\\s*$"); + if(regex.search(msg.escapedBody()) != -1) + { + // FIXME why are we sending the images.. the contact should request them. + PeerDispatcher()->sendImage(regex.cap(1), m_msgHandle); + return -3; + } + } + + // User-Agent is not a official flag, but PIDGIN has it + TQString UA; + if( config->readBoolEntry("SendClientInfo", true) ) + { + UA="User-Agent: Kopete/"+escape(kapp->aboutData()->version())+"\r\n"; + } + + TQString head = + "MIME-Version: 1.0\r\n" + "Content-Type: text/plain; charset=UTF-8\r\n" + +UA+ + "X-MMS-IM-Format: "; + + if(msg.font() != TQFont() ) + { + //It's verry strange that if the font name is bigger than 31 char, the _server_ close the socket and don't deliver the message. + // the real question is why ? my guess is that MS patched the server because a bug in their client, but that's just a guess. + // - Olivier 06-2005 + head += "FN=" + escape( msg.font().family().left(31)); + head += "; EF="; + if(msg.font().bold()) + head += "B"; + if(msg.font().italic()) + head += "I"; + if(msg.font().strikeOut()) + head += "S"; + if(msg.font().underline()) + head += "U"; + head += "; "; + } + else head+="FN=; EF=; "; + /* + * I don't know what to set by default, so i decided to set nothing. CF Bug 82734 + * (but don't forgeto to add an empty FN= and EF= , or webmessenger will break. (CF Bug 102371) ) + else head+="FN=MS%20Serif; EF=; "; + */ + + // Color support + if (msg.fg().isValid()) + { + TQString colorCode = TQColor(msg.fg().blue(),msg.fg().green(),msg.fg().red()).name().remove(0,1); //colors aren't sent in RGB but in BGR (O.G.) + head += "CO=" + colorCode; + } + else + { + head += "CO=0"; + } + + head += "; CS=0; PF=0"; + if (msg.plainBody().isRightToLeft()) + head += "; RL=1"; + head += "\r\n"; + + TQString message= msg.plainBody().replace( "\n" , "\r\n" ); + + //-- Check if the message isn't too big, TODO: do that at the libkopete level. + int len_H=head.utf8().length(); // != head.length() because i need the size in butes and + int len_M=message.utf8().length(); // some utf8 char may be longer than one byte + if( len_H+len_M >= 1660 ) //1664 is the maximum size of messages allowed by the server + { + //We will certenly split the message in several ones. + //It's possible to made the opposite client join them, as explained in this MS Word document + //http://www.bot-depot.com/forums/index.php?act=Attach&type=post&id=35110 + + head+="Message-ID: {7B7B34E6-7A8D-44FF-926C-1799156B58"+TQString::number( rand()%10)+TQString::number( rand()%10)+"}\r\n"; + int len_H=head.utf8().length()+ 14; //14 is the size of "Chunks: x" + //this is the size of each part of the message (excluding the header) + int futurmessages_size=1400; //1400 is a common good size + //int futurmessages_size=1664-len_H; + + int nb=(int)ceil((float)(len_M)/(float)(futurmessages_size)); + + if(KMessageBox::warningContinueCancel(0L /* FIXME: we should try to find a parent somewere*/ , + i18n("The message you are trying to send is too long; it will be split into %1 messages.").arg(nb) , + i18n("Message too big - MSN Plugin" ), KStdGuiItem::cont() , "SendLongMessages" ) + == KMessageBox::Continue ) + { + int place=0; + int result; + int chunk=0; + do + { + TQString m=message.mid(place, futurmessages_size); + place += futurmessages_size; + + //make sure the size is not too big because of utf8 + int d=m.utf8().length() + len_H -1664; + if( d > 0 ) + {//it contains some utf8 chars, so we strip the string a bit. + m=m.left( futurmessages_size - d ); + place -= d; + } + + //try to snip on space if possible + int len=m.length(); + d=0; + while(d<200 && !m[len-d].isSpace() ) + d++; + if(d<200) + { + m=m.left(len-d); + place -= d; + } + TQString chunk_str; + if(chunk==0) + chunk_str="Chunks: "+TQString::number(nb)+"\r\n"; + else if(chunk<nb) + chunk_str="Chunk: "+TQString::number(chunk)+"\r\n"; + else + { + kdDebug(14140) << k_funcinfo <<"The message is slit in more than initially estimated" <<endl; + } + result=sendCommand( "MSG", "A", true, (head+chunk_str+"\r\n"+m).utf8() ); + chunk++; + } + while(place < len_M) ; + + while(chunk<nb) + { + kdDebug(14140) << k_funcinfo <<"The message is plit in less than initially estimated. Sending empty message to complete" <<endl; + TQString chunk_str="Chunk: "+TQString::number(chunk); + sendCommand( "MSG", "A", true, (head+chunk_str+"\r\n").utf8() ); + chunk++; + } + return result; + } + return -2; //the message hasn't been sent. + } + + if(!m_keepAlive) + { + m_keepAliveNb=20; + m_keepAlive=new TQTimer(this); + TQObject::connect(m_keepAlive, TQT_SIGNAL(timeout()) , this , TQT_SLOT(slotKeepAliveTimer())); + m_keepAlive->start(50*1000); + } + + + return sendCommand( "MSG", "A", true, (head+"\r\n"+message).utf8() ); +} + +void MSNSwitchBoardSocket::slotSocketClosed( ) +{ + for( TQStringList::Iterator it = m_chatMembers.begin(); it != m_chatMembers.end(); ++it ) + { + emit userLeft( (*it), i18n("connection closed")); + } + + // we have lost the connection, send a message to chatwindow (this will not displayed) +// emit switchBoardIsActive(false); + emit switchBoardClosed( ); +} + +void MSNSwitchBoardSocket::slotCloseSession() +{ + sendCommand( "OUT", TQString(), false ); + disconnect(); +} + +// Check if we are connected. If so, then send the handshake. +void MSNSwitchBoardSocket::slotOnlineStatusChanged( MSNSocket::OnlineStatus status ) +{ + if (status == Connected) + { + TQCString command; + TQString args; + + if( !m_ID ) // we're inviting + { + command = "USR"; + args = m_myHandle + " " + m_auth; + } + else // we're invited + { + command = "ANS"; + args = m_myHandle + " " + m_auth + " " + m_ID; + } + sendCommand( command, args ); + + if(!m_keepAlive) + { + m_keepAliveNb=20; + m_keepAlive=new TQTimer(this); + TQObject::connect(m_keepAlive, TQT_SIGNAL(timeout()) , this , TQT_SLOT(slotKeepAliveTimer())); + m_keepAlive->start(50*1000); + } + } +} + +void MSNSwitchBoardSocket::userLeftChat(const TQString& handle , const TQString &reason) +{ + emit userLeft( handle, reason ); + + if( m_chatMembers.contains( handle ) ) + m_chatMembers.remove( handle ); + + if(m_chatMembers.isEmpty()) + disconnect(); +} + +void MSNSwitchBoardSocket::requestDisplayPicture() +{ + MSNContact *contact = static_cast<MSNContact*>(m_account->contacts()[m_msgHandle]); + if(!contact) return; + + PeerDispatcher()->requestDisplayIcon(m_msgHandle, contact->object()); +} + +void MSNSwitchBoardSocket::slotEmoticonReceived( KTempFile *file, const TQString &msnObj ) +{ + kdDebug(14141) << k_funcinfo << msnObj << endl; + + if(m_emoticons.contains(msnObj)) + { //it's an emoticon + m_emoticons[msnObj].second=file; + + if( m_recvIcons > 0 ) + m_recvIcons--; + kdDebug(14140) << k_funcinfo << "emoticons received queue is now: " << m_recvIcons << endl; + + if ( m_recvIcons <= 0 ) + cleanQueue(); + } + else if(msnObj == "inkformatgif") + { + TQString msg=i18n("<img src=\"%1\" alt=\"Typewrited message\" />" ).arg( file->name() ); + + kdDebug(14140) << k_funcinfo << file->name() <<endl; + + m_typewrited.append(file); + m_typewrited.setAutoDelete(true); + + TQPtrList<Kopete::Contact> others; + others.append( m_account->myself() ); + + TQStringList::iterator it2; + for( it2 = m_chatMembers.begin(); it2 != m_chatMembers.end(); ++it2 ) + { + if( *it2 != m_msgHandle ) + others.append( m_account->contacts()[ *it2 ] ); + } + + if(!m_account->contacts()[m_msgHandle]) + { + //this may happens if the contact has been deleted. + kdDebug(14140) << k_funcinfo <<"WARNING: contact is null, adding it" <<endl; + if( !m_chatMembers.contains( m_msgHandle ) ) + m_chatMembers.append( m_msgHandle ); + emit userJoined( m_msgHandle , m_msgHandle , false); + } + + Kopete::Message kmsg( m_account->contacts()[ m_msgHandle ], others, + msg, Kopete::Message::Inbound , Kopete::Message::RichText ); + + emit msgReceived( kmsg ); + } + else //if it is not an emoticon, + { // it's certenly the displaypicture. + MSNContact *c=static_cast<MSNContact*>(m_account->contacts()[m_msgHandle]); + if(c && c->object()==msnObj) + c->setDisplayPicture(file); + else + delete file; + } +} + +void MSNSwitchBoardSocket::slotIncomingFileTransfer(const TQString& from, const TQString& /*fileName*/, TQ_INT64 /*fileSize*/) +{ + TQPtrList<Kopete::Contact> others; + others.append( m_account->myself() ); + TQStringList::iterator it2; + for( it2 = m_chatMembers.begin(); it2 != m_chatMembers.end(); ++it2 ) + { + if( *it2 != m_msgHandle ) + others.append( m_account->contacts()[ *it2 ] ); + } + + if(!m_account->contacts()[m_msgHandle]) + { + //this may happens if the contact has been deleted. + kdDebug(14140) << k_funcinfo <<"WARNING: contact is null, adding it" <<endl; + if( !m_chatMembers.contains( m_msgHandle ) ) + m_chatMembers.append( m_msgHandle ); + emit userJoined( m_msgHandle , m_msgHandle , false); + } + TQString invite = "Incoming file transfer."; + Kopete::Message msg = + Kopete::Message(m_account->contacts()[from], others, invite, Kopete::Message::Internal, Kopete::Message::PlainText); + emit msgReceived(msg); +} + +void MSNSwitchBoardSocket::cleanQueue() +{ + if(m_emoticonTimer) + { + m_emoticonTimer->stop(); + m_emoticonTimer->deleteLater(); + m_emoticonTimer=0L; + } + kdDebug(14141) << k_funcinfo << m_msgQueue.count() << endl; + + TQValueList<const Kopete::Message>::Iterator it_msg; + for ( it_msg = m_msgQueue.begin(); it_msg != m_msgQueue.end(); ++it_msg ) + { + Kopete::Message kmsg = (*it_msg); + emit msgReceived( parseCustomEmoticons( kmsg ) ); + } + m_msgQueue.clear(); +} + +Kopete::Message &MSNSwitchBoardSocket::parseCustomEmoticons(Kopete::Message &kmsg) +{ + TQString message=kmsg.escapedBody(); + TQMap<TQString , TQPair<TQString , KTempFile*> >::Iterator it; + for ( it = m_emoticons.begin(); it != m_emoticons.end(); ++it ) + { + TQString es=TQStyleSheet::escape(it.data().first); + KTempFile *f=it.data().second; + if(message.contains(es) && f) + { + TQString imgPath = f->name(); + TQImage iconImage(imgPath); + /* We don't use a comple algoritm (like the one in the #if) because the msn client shows + * emoticons like that. So, in that case, we show like the MSN client */ + #if 0 + TQString em = TQRegExp::escape( es ); + message.replace( TQRegExp(TQString::fromLatin1( "(^|[\\W\\s]|%1)(%2)(?!\\w)" ).arg(em).arg(em)), + TQString::fromLatin1("\\1<img align=\"center\" width=\"") + + #endif + //match any occurence which is not in a html tag. + message.replace( TQRegExp(TQString::fromLatin1("%1(?![^><]*>)").arg(TQRegExp::escape(es))), + TQString::fromLatin1("<img align=\"center\" width=\"") + + TQString::number(iconImage.width()) + + TQString::fromLatin1("\" height=\"") + + TQString::number(iconImage.height()) + + TQString::fromLatin1("\" src=\"") + imgPath + + TQString::fromLatin1("\" title=\"") + es + + TQString::fromLatin1("\" alt=\"") + es + + TQString::fromLatin1( "\"/>" ) ); + kmsg.setBody(message, Kopete::Message::RichText); + } + } + return kmsg; +} + +int MSNSwitchBoardSocket::sendNudge() +{ + TQCString message = TQString( "MIME-Version: 1.0\r\n" + "Content-Type: text/x-msnmsgr-datacast\r\n" + "\r\n" + "ID: 1\r\n" + "\r\n\r\n" ).utf8(); + + TQString args = "U"; + return sendCommand( "MSG", args, true, message ); +} + + + +// FIXME: This is nasty... replace with a regexp or so. +TQString MSNSwitchBoardSocket::parseFontAttr(TQString str, TQString attr) +{ + TQString tmp; + int pos1=0, pos2=0; + + pos1 = str.find(attr + "="); + + if (pos1 == -1) + return ""; + + pos2 = str.find(";", pos1+3); + + if (pos2 == -1) + tmp = str.mid(pos1+3, str.length() - pos1 - 3); + else + tmp = str.mid(pos1+3, pos2 - pos1 - 3); + + return tmp; +} + +Dispatcher* MSNSwitchBoardSocket::PeerDispatcher() +{ + if(!m_dispatcher) + { + // Create a new msnslp dispatcher to handle + // all peer to peer requests. + TQStringList ip; + if(m_account->notifySocket()) + { + ip << m_account->notifySocket()->localIP(); + if(m_account->notifySocket()->localIP() != m_account->notifySocket()->getLocalIP()) + ip << m_account->notifySocket()->getLocalIP(); + } + m_dispatcher = new Dispatcher(this, m_account->accountId(),ip ); + +// TQObject::connect(this, TQT_SIGNAL(blockRead(const TQByteArray&)), m_dispatcher, TQT_SLOT(slotReadMessage(const TQByteArray&))); +// TQObject::connect(m_dispatcher, TQT_SIGNAL(sendCommand(const TQString&, const TQString&, bool, const TQByteArray&, bool)), this, TQT_SLOT(sendCommand(const TQString&, const TQString&, bool, const TQByteArray&, bool))); + TQObject::connect(m_dispatcher, TQT_SIGNAL(incomingTransfer(const TQString&, const TQString&, TQ_INT64)), this, TQT_SLOT(slotIncomingFileTransfer(const TQString&, const TQString&, TQ_INT64))); + TQObject::connect(m_dispatcher, TQT_SIGNAL(displayIconReceived(KTempFile *, const TQString&)), this, TQT_SLOT(slotEmoticonReceived( KTempFile *, const TQString&))); + TQObject::connect(this, TQT_SIGNAL(msgAcknowledgement(unsigned int, bool)), m_dispatcher, TQT_SLOT(messageAcknowledged(unsigned int, bool))); + m_dispatcher->m_pictureUrl = m_account->pictureUrl(); + } + return m_dispatcher; +} + +void MSNSwitchBoardSocket::slotKeepAliveTimer( ) +{ + /* + This is a workaround against the bug 113425 + The problem: the P2P::Webcam class is parent of us, and when we get deleted, it get deleted. + the correct solution would be to change that. + The second problem: after one minute of inactivity, the official client close the chat socket. + the workaround: we simulate the activity by sending small packet each 50 seconds + the nice side effect: the "xxx has closed the chat" is now meaningfull + the bad side effect: some switchboard connection may be maintained for really long time! + */ + + if ( onlineStatus() != Connected || m_chatMembers.empty()) + { + //we are not yet in a chat. + //if we send that command now, we may get disconnected. + return; + } + + + TQCString message = TQString( "MIME-Version: 1.0\r\n" + "Content-Type: text/x-keepalive\r\n" + "\r\n" ).utf8(); + + // Length is appended by sendCommand() + TQString args = "U"; + sendCommand( "MSG", args, true, message ); + + m_keepAliveNb--; + if(m_keepAliveNb <= 0) + { + m_keepAlive->deleteLater(); + m_keepAlive=0L; + } +} + +#include "msnswitchboardsocket.moc" + +// vim: set noet ts=4 sts=4 sw=4: + |