/*
yahooaccount.cpp - Manages a single Yahoo account
Copyright (c) 2003 by Gav Wood <gav@kde.org>
Copyright (c) 2003-2004 by Matt Rogers <matt.rogers@kdemail.net>
Based on code by Olivier Goffart <ogoffart @ kde.org>
Kopete (c) 2002-2004 by the Kopete developers <kopete-devel@kde.org>
*************************************************************************
* *
* 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. *
* *
*************************************************************************
*/
//Standard Header
#include <ctime>
#include <stdlib.h>
//QT
#include <qfont.h>
#include <qdatetime.h>
#include <qcolor.h>
#include <qregexp.h>
#include <qimage.h>
#include <qfile.h>
#include <qdir.h>
#include <qfileinfo.h>
// KDE
#include <klocale.h>
#include <kconfig.h>
#include <kdebug.h>
#include <kaction.h>
#include <kpopupmenu.h>
#include <kmessagebox.h>
#include <kapplication.h>
#include <krun.h>
#include <kurl.h>
#include <kstandarddirs.h>
#include <kstandarddirs.h>
// Kopete
#include <kopetechatsession.h>
#include <kopetemessage.h>
#include <kopetepassword.h>
#include <kopeteuiglobal.h>
#include <knotification.h>
#include <kopetemetacontact.h>
#include <kopetecontactlist.h>
#include <kopetetransfermanager.h>
#include <kopeteview.h>
#include <contactaddednotifydialog.h>
// Yahoo
#include "yahooaccount.h"
#include "yahoocontact.h"
#include "yahooconnector.h"
#include "yahooclientstream.h"
#include "client.h"
#include "yahooverifyaccount.h"
#include "yahoowebcam.h"
#include "yahooconferencemessagemanager.h"
#include "yahooinvitelistimpl.h"
#include "yabentry.h"
#include "yahoouserinfodialog.h"
YahooAwayDialog::YahooAwayDialog(YahooAccount* account, QWidget *parent, const char *name) :
KopeteAwayDialog(parent, name)
{
theAccount = account;
}
void YahooAwayDialog::setAway(int awayType)
{
awayType = 0;
theAccount->setAway(awayType, getSelectedAwayMessage());
}
YahooAccount::YahooAccount(YahooProtocol *parent, const QString& accountId, const char *name)
: Kopete::PasswordedAccount(parent, accountId, 0, name)
{
// first things first - initialise internals
stateOnConnection = 0;
theHaveContactList = false;
theAwayDialog = new YahooAwayDialog( this );
m_protocol = parent;
m_session = new Client( this );
m_lastDisconnectCode = 0;
m_currentMailCount = 0;
m_webcam = 0L;
m_session->setUserId( accountId.lower() );
m_openInboxAction = new KAction( i18n( "Open Inbo&x..." ), "mail_generic", 0, this, SLOT( slotOpenInbox() ), this, "m_openInboxAction" );
m_openYABAction = new KAction( i18n( "Open &Addressbook..." ), "contents", 0, this, SLOT( slotOpenYAB() ), this, "m_openYABAction" );
m_editOwnYABEntry = new KAction( i18n( "&Edit my contact details..."), "contents", 0, this, SLOT( slotEditOwnYABEntry() ), this, "m_editOwnYABEntry" );
YahooContact* _myself=new YahooContact( this, accountId.lower(), accountId, Kopete::ContactList::self()->myself() );
setMyself( _myself );
_myself->setOnlineStatus( parent->Offline );
myself()->setProperty( YahooProtocol::protocol()->iconRemoteUrl, configGroup()->readEntry( "iconRemoteUrl", "" ) );
myself()->setProperty( Kopete::Global::Properties::self()->photo(), configGroup()->readEntry( "iconLocalUrl", "" ) );
myself()->setProperty( YahooProtocol::protocol()->iconCheckSum, configGroup()->readNumEntry( "iconCheckSum", 0 ) );
myself()->setProperty( YahooProtocol::protocol()->iconExpire, configGroup()->readNumEntry( "iconExpire", 0 ) );
QObject::connect( Kopete::ContactList::self(), SIGNAL( globalIdentityChanged(const QString&, const QVariant& ) ), SLOT( slotGlobalIdentityChanged(const QString&, const QVariant& ) ));
// initConnectionSignals( MakeConnections );
QString displayName = configGroup()->readEntry(QString::fromLatin1("displayName"));
if(!displayName.isEmpty())
_myself->setNickName(displayName);
m_YABLastMerge = configGroup()->readNumEntry( "YABLastMerge", 0 );
m_YABLastRemoteRevision = configGroup()->readNumEntry( "YABLastRemoteRevision", 0 );
}
YahooAccount::~YahooAccount()
{
if( m_webcam )
m_webcam->stopTransmission();
delete theAwayDialog;
}
void YahooAccount::setServer( const QString &server )
{
configGroup()->writeEntry( QString::fromLatin1( "Server" ), server );
}
void YahooAccount::setPort( int port )
{
configGroup()->writeEntry( QString::fromLatin1( "Port" ), port );
}
void YahooAccount::slotGoStatus( int status, const QString &awayMessage)
{
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << "GoStatus: " << status << " msg: " << awayMessage <<endl;
if( !isConnected() )
{
connect( m_protocol->statusFromYahoo( status ) );
stateOnConnection = status;
}
else
{
m_session->changeStatus( Yahoo::Status( status ), awayMessage,
(status == Yahoo::StatusAvailable)? Yahoo::StatusTypeAvailable : Yahoo::StatusTypeAway );
//sets the awayMessage property for the owner of the account. shows up in the statusbar icon's tooltip. the property is unset when awayMessage is null
myself()->setProperty( m_protocol->awayMessage, awayMessage );
myself()->setOnlineStatus( m_protocol->statusFromYahoo( status ) );
}
}
Client *YahooAccount::yahooSession()
{
return m_session ? m_session : 0L;
}
QString YahooAccount::stripMsgColorCodes(const QString& msg)
{
QString filteredMsg = msg;
//Handle bold, underline and italic messages
filteredMsg.replace( "\033[1m", "<b>" );
filteredMsg.replace( "\033[x1m", "</b>" );
filteredMsg.replace( "\033[2m", "<i>" );
filteredMsg.replace( "\033[x2m", "</i>" );
filteredMsg.replace( "\033[4m", "<u>" );
filteredMsg.replace( "\033[x4m", "</u>" );
//GAIM doesn't check for ^[[3m. Does this ever get sent?
filteredMsg.replace( "\033[3m", "<i>" );
filteredMsg.replace( "\033[x3m", "</i>" );
//Strip link tags
filteredMsg.remove( "\033[lm" );
filteredMsg.remove( "\033[xlm" );
//Remove color codes and other residual formatting
filteredMsg.remove( QRegExp("\033\\[[^m]*m") );
return filteredMsg;
}
QColor YahooAccount::getMsgColor(const QString& msg)
{
/* Yahoo sends a message either with color or without color
* so we have to use this really hacky method to get colors
*/
//kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << "msg is " << msg << endl;
//Please note that some of the colors are hard-coded to
//match the yahoo colors
if ( msg.find("\033[38m") != -1 )
return Qt::red;
if ( msg.find("\033[34m") != -1 )
return Qt::green;
if ( msg.find("\033[31m") != -1 )
return Qt::blue;
if ( msg.find("\033[39m") != -1 )
return Qt::yellow;
if ( msg.find("\033[36m") != -1 )
return Qt::darkMagenta;
if ( msg.find("\033[32m") != -1 )
return Qt::cyan;
if ( msg.find("\033[37m") != -1 )
return QColor("#FFAA39");
if ( msg.find("\033[35m") != -1 )
return QColor("#FFD8D8");
if ( msg.find("\033[#") != -1 )
{
kdDebug(YAHOO_GEN_DEBUG) << "Custom color is " << msg.mid(msg.find("\033[#")+2,7) << endl;
return QColor(msg.mid(msg.find("\033[#")+2,7));
}
//return a default value just in case
return Qt::black;
}
void YahooAccount::initConnectionSignals( enum SignalConnectionType sct )
{
if ( !m_session )
return;
if ( sct == MakeConnections )
{
QObject::connect(m_session, SIGNAL(loggedIn( int, const QString &)),
this, SLOT(slotLoginResponse(int, const QString &)) );
QObject::connect(m_session, SIGNAL(disconnected()),
this, SLOT(slotDisconnected()) );
QObject::connect(m_session, SIGNAL(loginFailed()),
this, SLOT(slotLoginFailed()) );
QObject::connect(m_session, SIGNAL(error(int)),
this, SLOT(slotError(int)));
QObject::connect(m_session, SIGNAL(gotBuddy(const QString &, const QString &, const QString &)),
this, SLOT(slotGotBuddy(const QString &, const QString &, const QString &)));
QObject::connect(m_session, SIGNAL(authorizationAccepted( const QString & )),
this, SLOT(slotAuthorizationAccepted( const QString & )) );
QObject::connect(m_session, SIGNAL(authorizationRejected( const QString &, const QString & )),
this, SLOT(slotAuthorizationRejected( const QString &, const QString & )) );
QObject::connect(m_session, SIGNAL(gotAuthorizationRequest( const QString &, const QString &, const QString & )),
this, SLOT(slotgotAuthorizationRequest( const QString &, const QString &, const QString & )) );
QObject::connect(m_session, SIGNAL(statusChanged(const QString&, int, const QString&, int, int)),
this, SLOT(slotStatusChanged(const QString&, int, const QString&, int, int)));
QObject::connect(m_session, SIGNAL(stealthStatusChanged(const QString &, Yahoo::StealthStatus)),
this, SLOT(slotStealthStatusChanged( const QString &, Yahoo::StealthStatus)) );
QObject::connect(m_session, SIGNAL(gotIm(const QString&, const QString&, long, int)),
this, SLOT(slotGotIm(const QString &, const QString&, long, int)));
QObject::connect(m_session, SIGNAL(gotBuzz(const QString&, long)),
this, SLOT(slotGotBuzz(const QString &, long)));
QObject::connect(m_session, SIGNAL( gotConferenceInvite( const QString&, const QString&,
const QString&, const QStringList&) ),
this,
SLOT( slotGotConfInvite( const QString&, const QString&,
const QString&, const QStringList& ) ) );
QObject::connect(m_session, SIGNAL(confUserDeclined(const QString&, const QString &, const QString &)),
this,
SLOT(slotConfUserDecline( const QString &, const QString &, const QString &)) );
QObject::connect(m_session , SIGNAL(confUserJoined( const QString &, const QString &)), this,
SLOT(slotConfUserJoin( const QString &, const QString &)) );
QObject::connect(m_session , SIGNAL(confUserLeft( const QString &, const QString &)), this,
SLOT(slotConfUserLeave( const QString &, const QString &)) );
QObject::connect(m_session , SIGNAL(gotConferenceMessage( const QString &, const QString &, const QString &)), this,
SLOT(slotConfMessage( const QString &, const QString &, const QString &)) );
QObject::connect(m_session,
SIGNAL(incomingFileTransfer(const QString &, const QString &, long, const QString &, const QString &, unsigned long)),
this,
SLOT(slotGotFile(const QString&, const QString&, long, const QString&, const QString&, unsigned long)));
QObject::connect(m_session, SIGNAL(fileTransferComplete(unsigned int)), this,
SLOT(slotFileTransferComplete(unsigned int)) );
QObject::connect(m_session, SIGNAL(fileTransferBytesProcessed(unsigned int,unsigned int)), this,
SLOT(slotFileTransferBytesProcessed(unsigned int,unsigned int)) );
QObject::connect(m_session, SIGNAL(fileTransferError(unsigned int,int,const QString &)), this,
SLOT(slotFileTransferError(unsigned int,int,const QString &)) );
QObject::connect(m_session, SIGNAL(typingNotify(const QString &, int)), this ,
SLOT(slotTypingNotify(const QString &, int)));
// QObject::connect(m_session, SIGNAL(gameNotify(const QString &, int)), this,
// SLOT(slotGameNotify( const QString &, int)));
QObject::connect(m_session, SIGNAL(mailNotify(const QString&, const QString&, int)), this,
SLOT(slotMailNotify(const QString &, const QString&, int)));
QObject::connect(m_session, SIGNAL(systemMessage(const QString&)), this,
SLOT(slotSystemMessage(const QString &)));
// QObject::connect(m_session, SIGNAL(gotIdentities(const QStringList &)), this,
// SLOT(slotGotIdentities( const QStringList&)));
QObject::connect(m_session, SIGNAL(gotWebcamInvite(const QString&)), this, SLOT(slotGotWebcamInvite(const QString&)));
QObject::connect(m_session, SIGNAL(webcamNotAvailable(const QString&)), this, SLOT(slotWebcamNotAvailable(const QString&)));
QObject::connect(m_session, SIGNAL(webcamImageReceived(const QString&, const QPixmap& )), this, SLOT(slotGotWebcamImage(const QString&, const QPixmap& )));
QObject::connect(m_session, SIGNAL(webcamClosed(const QString&, int )), this, SLOT(slotWebcamClosed(const QString&, int )));
QObject::connect(m_session, SIGNAL(webcamPaused(const QString&)), this, SLOT(slotWebcamPaused(const QString&)));
QObject::connect(m_session, SIGNAL(webcamReadyForTransmission()), this, SLOT(slotWebcamReadyForTransmission()));
QObject::connect(m_session, SIGNAL(webcamStopTransmission()), this, SLOT(slotWebcamStopTransmission()));
QObject::connect(m_session, SIGNAL(webcamViewerJoined(const QString&)), this, SLOT(slotWebcamViewerJoined(const QString&)));
QObject::connect(m_session, SIGNAL(webcamViewerLeft(const QString&)), this, SLOT(slotWebcamViewerLeft(const QString&)));
QObject::connect(m_session, SIGNAL(webcamViewerRequest(const QString&)), this, SLOT(slotWebcamViewerRequest( const QString&)));
QObject::connect(m_session, SIGNAL(pictureStatusNotify( const QString&, int )), SLOT(slotPictureStatusNotiy( const QString&, int)));
QObject::connect(m_session, SIGNAL(pictureDownloaded(const QString&, KTempFile*, int)), this, SLOT(slotGotBuddyIcon(const QString&, KTempFile*, int)) );
QObject::connect(m_session, SIGNAL(pictureInfoNotify(const QString&, KURL, int)), this, SLOT(slotGotBuddyIconInfo(const QString&, KURL, int )));
QObject::connect(m_session, SIGNAL(pictureChecksumNotify(const QString&, int)), this, SLOT(slotGotBuddyIconChecksum(const QString&, int )));
QObject::connect(m_session, SIGNAL(pictureRequest(const QString&)), this, SLOT(slotGotBuddyIconRequest(const QString&)) );
QObject::connect(m_session, SIGNAL(pictureUploaded( const QString &)), this, SLOT(slotBuddyIconChanged(const QString&)));
QObject::connect(m_session, SIGNAL(gotYABEntry( YABEntry * )), this, SLOT(slotGotYABEntry( YABEntry * )));
QObject::connect(m_session, SIGNAL(modifyYABEntryError( YABEntry *, const QString & )), this, SLOT(slotModifyYABEntryError( YABEntry *, const QString & )));
QObject::connect(m_session, SIGNAL(gotYABRevision( long, bool )), this, SLOT(slotGotYABRevision( long , bool )) );
}
if ( sct == DeleteConnections )
{
QObject::disconnect(m_session, SIGNAL(loggedIn(int, const QString &)),
this, SLOT(slotLoginResponse(int, const QString &)) );
QObject::disconnect(m_session, SIGNAL(disconnected()),
this, SLOT(slotDisconnected()) );
QObject::disconnect(m_session, SIGNAL(loginFailed()),
this, SLOT(slotLoginFailed()) );
QObject::disconnect(m_session, SIGNAL(error(int)),
this, SLOT(slotError(int)));
QObject::disconnect(m_session, SIGNAL(gotBuddy(const QString &, const QString &, const QString &)),
this, SLOT(slotGotBuddy(const QString &, const QString &, const QString &)));
QObject::disconnect(m_session, SIGNAL(authorizationAccepted( const QString &)),
this, SLOT(slotAuthorizationAccepted( const QString &)) );
QObject::disconnect(m_session, SIGNAL(authorizationRejected( const QString &, const QString &)),
this, SLOT(slotAuthorizationRejected( const QString &, const QString & )) );
QObject::disconnect(m_session, SIGNAL(gotAuthorizationRequest( const QString &, const QString &, const QString & )),
this, SLOT(slotgotAuthorizationRequest( const QString &, const QString &, const QString & )) );
QObject::disconnect(m_session, SIGNAL(statusChanged(const QString&, int, const QString&, int, int)),
this, SLOT(slotStatusChanged(const QString&, int, const QString&, int, int)));
QObject::disconnect(m_session, SIGNAL(stealthStatusChanged(const QString &, Yahoo::StealthStatus)),
this, SLOT(slotStealthStatusChanged( const QString &, Yahoo::StealthStatus)) );
QObject::disconnect(m_session, SIGNAL(gotIm(const QString&, const QString&, long, int)),
this, SLOT(slotGotIm(const QString &, const QString&, long, int)));
QObject::disconnect(m_session, SIGNAL(gotBuzz(const QString&, long)),
this, SLOT(slotGotBuzz(const QString &, long)));
QObject::disconnect(m_session,
SIGNAL( gotConferenceInvite( const QString&, const QString&,
const QString&, const QStringList&) ),
this,
SLOT( slotGotConfInvite( const QString&, const QString&,
const QString&, const QStringList&) ) );
QObject::disconnect(m_session,
SIGNAL(confUserDeclined(const QString&, const QString &, const QString &)),
this,
SLOT(slotConfUserDecline( const QString &, const QString &, const QString& ) ) );
QObject::disconnect(m_session , SIGNAL(confUserJoined( const QString &, const QString &)),
this, SLOT(slotConfUserJoin( const QString &, const QString &)) );
QObject::disconnect(m_session , SIGNAL(confUserLeft( const QString &, const QString &)),
this, SLOT(slotConfUserLeave( const QString &, const QString &)) );
QObject::disconnect(m_session , SIGNAL(gotConferenceMessage( const QString &, const QString &, const QString &)), this,
SLOT(slotConfMessage( const QString &, const QString &, const QString &)) );
QObject::disconnect(m_session,
SIGNAL(incomingFileTransfer(const QString &, const QString &,
long, const QString &, const QString &, unsigned long)),
this,
SLOT(slotGotFile(const QString&, const QString&,
long, const QString&, const QString&, unsigned long)));
QObject::disconnect(m_session, SIGNAL(fileTransferComplete(unsigned int)), this,
SLOT(slotFileTransferComplete(unsigned int)) );
QObject::disconnect(m_session, SIGNAL(fileTransferBytesProcessed(unsigned int,unsigned int)), this,
SLOT(slotFileTransferBytesProcessed(unsigned int,unsigned int)) );
QObject::disconnect(m_session, SIGNAL(fileTransferError(unsigned int,int,const QString &)), this,
SLOT(slotFileTransferError(unsigned int,int,const QString &)) );
QObject::disconnect(m_session, SIGNAL(typingNotify(const QString &, int)), this ,
SLOT(slotTypingNotify(const QString &, int)));
// QObject::disconnect(m_session, SIGNAL(gameNotify(const QString &, int)), this,
// SLOT(slotGameNotify( const QString &, int)));
QObject::disconnect(m_session, SIGNAL(mailNotify(const QString&, const QString&, int)), this,
SLOT(slotMailNotify(const QString &, const QString&, int)));
QObject::disconnect(m_session, SIGNAL(systemMessage(const QString&)), this,
SLOT(slotSystemMessage(const QString &)));
// QObject::disconnect(m_session, SIGNAL(gotIdentities(const QStringList &)), this,
// SLOT(slotGotIdentities( const QStringList&)));
QObject::disconnect(m_session, SIGNAL(gotWebcamInvite(const QString&)), this, SLOT(slotGotWebcamInvite(const QString&)));
QObject::disconnect(m_session, SIGNAL(webcamNotAvailable(const QString&)), this, SLOT(slotWebcamNotAvailable(const QString&)));
QObject::disconnect(m_session, SIGNAL(webcamImageReceived(const QString&, const QPixmap& )), this, SLOT(slotGotWebcamImage(const QString&, const QPixmap& )));
QObject::disconnect(m_session, SIGNAL(webcamClosed(const QString&, int )), this, SLOT(slotWebcamClosed(const QString&, int )));
QObject::disconnect(m_session, SIGNAL(webcamPaused(const QString&)), this, SLOT(slotWebcamPaused(const QString&)));
QObject::disconnect(m_session, SIGNAL(webcamReadyForTransmission()), this, SLOT(slotWebcamReadyForTransmission()));
QObject::disconnect(m_session, SIGNAL(webcamStopTransmission()), this, SLOT(slotWebcamStopTransmission()));
QObject::disconnect(m_session, SIGNAL(webcamViewerJoined(const QString&)), this, SLOT(slotWebcamViewerJoined(const QString&)));
QObject::disconnect(m_session, SIGNAL(webcamViewerLeft(const QString&)), this, SLOT(slotWebcamViewerLeft(const QString&)));
QObject::disconnect(m_session, SIGNAL(webcamViewerRequest(const QString&)), this, SLOT(slotWebcamViewerRequest( const QString&)));
QObject::disconnect(m_session, SIGNAL(pictureDownloaded(const QString&, KTempFile*, int )), this, SLOT(slotGotBuddyIcon(const QString&, KTempFile*,int )));
QObject::disconnect(m_session, SIGNAL(pictureInfoNotify(const QString&, KURL, int)), this, SLOT(slotGotBuddyIconInfo(const QString&, KURL, int )));
QObject::disconnect(m_session, SIGNAL(gotBuddyIconRequest(const QString&)), this, SLOT(slotGotBuddyIconRequest(const QString&)) );
QObject::disconnect(m_session, SIGNAL(pictureUploaded( const QString & )), this, SLOT(slotBuddyIconChanged(const QString&)));
QObject::disconnect(m_session, SIGNAL(pictureStatusNotify( const QString&, int )), this, SLOT(slotPictureStatusNotiy( const QString&, int)));
QObject::disconnect(m_session, SIGNAL(pictureChecksumNotify(const QString&, int)), this, SLOT(slotGotBuddyIconChecksum(const QString&, int )));
QObject::disconnect(m_session, SIGNAL(gotYABEntry( YABEntry * )), this, SLOT(slotGotYABEntry( YABEntry * )));
QObject::disconnect(m_session, SIGNAL(modifyYABEntryError( YABEntry *, const QString & )), this, SLOT(slotModifyYABEntryError( YABEntry *, const QString & )));
QObject::disconnect(m_session, SIGNAL(gotYABRevision( long, bool )), this, SLOT(slotGotYABRevision( long , bool )) );
}
}
void YahooAccount::connectWithPassword( const QString &passwd )
{
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << endl;
if ( isAway() )
{
slotGoOnline();
return;
}
if ( isConnected() ||
myself()->onlineStatus() == m_protocol->Connecting )
{
kdDebug(YAHOO_GEN_DEBUG) << "Yahoo plugin: Ignoring connect request (already connected)." <<endl;
return;
}
if ( passwd.isNull() )
{ //cancel the connection attempt
static_cast<YahooContact*>( myself() )->setOnlineStatus( m_protocol->Offline );
return;
}
QString server = configGroup()->readEntry( "Server", "scs.msg.yahoo.com" );
int port = configGroup()->readNumEntry( "Port", 5050 );
initConnectionSignals( MakeConnections );
//YahooSessionManager::manager()->setPager( server, port );
//m_session = YahooSessionManager::manager()->createSession( accountId(), passwd );
kdDebug(YAHOO_GEN_DEBUG) << "Attempting to connect to Yahoo on <" << server << ":"
<< port << ">. user <" << accountId() << ">" << endl;
static_cast<YahooContact *>( myself() )->setOnlineStatus( m_protocol->Connecting );
m_session->setStatusOnConnect( Yahoo::Status( initialStatus().internalStatus() ) );
m_session->connect( server, port, accountId().lower(), passwd );
}
void YahooAccount::disconnect()
{
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << endl;
m_currentMailCount = 0;
if ( isConnected() )
{
kdDebug(YAHOO_GEN_DEBUG) << "Attempting to disconnect from Yahoo server " << endl;
m_session->close();
static_cast<YahooContact *>( myself() )->setOnlineStatus( m_protocol->Offline );
for ( QDictIterator<Kopete::Contact> i( contacts() ); i.current(); ++i )
static_cast<YahooContact *>( i.current() )->setOnlineStatus( m_protocol->Offline );
disconnected( Manual );
}
else
{ //make sure we set everybody else offline explicitly, just for cleanup
kdDebug(YAHOO_GEN_DEBUG) << "Cancelling active login attempts (not fully connected)." << endl;
m_session->cancelConnect();
for ( QDictIterator<Kopete::Contact> i(contacts()); i.current(); ++i )
static_cast<YahooContact*>( i.current() )->setOnlineStatus( m_protocol->Offline );
}
initConnectionSignals( DeleteConnections );
theHaveContactList = false;
}
void YahooAccount::verifyAccount( const QString &word )
{
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << "Word: s" << word << endl;
m_session->setVerificationWord( word );
disconnected( BadPassword );
}
void YahooAccount::setAway(bool status, const QString &awayMessage)
{
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << endl;
if( awayMessage.isEmpty() )
slotGoStatus( status ? 2 : 0 );
else
slotGoStatus( status ? 99 : 0, awayMessage );
}
void YahooAccount::slotConnected()
{
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << "Moved to slotLoginResponse for the moment" << endl;
}
void YahooAccount::slotGoOnline()
{
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << endl;
if( !isConnected() )
connect( m_protocol->Online );
else
slotGoStatus(0);
}
void YahooAccount::slotGoOffline()
{
if ( isConnected() )
disconnect();
else
static_cast<YahooContact *>( myself() )->setOnlineStatus( m_protocol->Offline );
}
KActionMenu *YahooAccount::actionMenu()
{
// kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << endl;
KActionMenu *theActionMenu = Kopete::Account::actionMenu();
theActionMenu->popupMenu()->insertSeparator();
theActionMenu->insert( m_editOwnYABEntry );
theActionMenu->insert( m_openInboxAction );
theActionMenu->insert( m_openYABAction );
return theActionMenu;
}
YahooContact *YahooAccount::contact( const QString &id )
{
return static_cast<YahooContact *>(contacts()[id]);
}
bool YahooAccount::createContact(const QString &contactId, Kopete::MetaContact *parentContact )
{
// kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << " contactId: " << contactId << endl;
if(!contact(contactId))
{
// FIXME: New Contacts are NOT added to KABC, because:
// How on earth do you tell if a contact is being deserialised or added brand new here?
// -- actualy (oct 2004) this method is only called when new contact are added. but this will
// maybe change and you will be noticed --Olivier
YahooContact *newContact = new YahooContact( this, contactId,
parentContact->displayName(), parentContact );
return newContact != 0;
}
else
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << "Contact already exists" << endl;
return false;
}
void YahooAccount::slotGlobalIdentityChanged( const QString &key, const QVariant &value )
{
if( !configGroup()->readBoolEntry("ExcludeGlobalIdentity", false) )
{
if ( key == Kopete::Global::Properties::self()->photo().key() )
{
setBuddyIcon( KURL( value.toString() ) );
}
}
}
void YahooAccount::sendFile( YahooContact *to, const KURL &url )
{
QFile file( url.path() );
Kopete::Transfer *transfer = Kopete::TransferManager::transferManager()->addTransfer ( to,
url.fileName(), file.size(), to->userId(), Kopete::FileTransferInfo::Outgoing );
m_session->sendFile( transfer->info().transferId(), to->userId(), QString(), url );
QObject::connect( transfer, SIGNAL(result( KIO::Job * )), this, SLOT(slotFileTransferResult( KIO::Job * )) );
m_fileTransfers.insert( transfer->info().transferId(), transfer );
}
/***************************************************************************
* *
* Slot for KYahoo signals *
* *
***************************************************************************/
void YahooAccount::slotLoginResponse( int succ , const QString &url )
{
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << succ << ", " << url << ")]" << endl;
QString errorMsg;
if ( succ == Yahoo::LoginOk || (succ == Yahoo::LoginDupl && m_lastDisconnectCode == 2) )
{
if ( initialStatus().internalStatus() )
{
static_cast<YahooContact *>( myself() )->setOnlineStatus( initialStatus() );
}
else
{
static_cast<YahooContact *>( myself() )->setOnlineStatus( m_protocol->Online );
}
setBuddyIcon( myself()->property( Kopete::Global::Properties::self()->photo() ).value().toString() );
m_session->getYABEntries( m_YABLastMerge, m_YABLastRemoteRevision );
m_lastDisconnectCode = 0;
theHaveContactList = true;
return;
}
else if(succ == Yahoo::LoginPasswd)
{
initConnectionSignals( DeleteConnections );
password().setWrong();
static_cast<YahooContact *>( myself() )->setOnlineStatus( m_protocol->Offline );
disconnected( BadPassword );
return;
}
else if(succ == Yahoo::LoginLock)
{
initConnectionSignals( DeleteConnections );
errorMsg = i18n("Could not log into Yahoo service: your account has been locked.\nVisit %1 to reactivate it.").arg(url);
KMessageBox::queuedMessageBox(Kopete::UI::Global::mainWidget(), KMessageBox::Error, errorMsg);
static_cast<YahooContact *>( myself() )->setOnlineStatus( m_protocol->Offline );
disconnected( BadUserName ); // FIXME: add a more appropriate disconnect reason
return;
}
else if( succ == Yahoo::LoginUname )
{
initConnectionSignals( DeleteConnections );
errorMsg = i18n("Could not log into the Yahoo service: the username specified was invalid.");
KMessageBox::queuedMessageBox(Kopete::UI::Global::mainWidget(), KMessageBox::Error, errorMsg);
static_cast<YahooContact *>( myself() )->setOnlineStatus( m_protocol->Offline );
disconnected( BadUserName );
return;
}
else if( succ == Yahoo::LoginDupl && m_lastDisconnectCode != 2 )
{
initConnectionSignals( DeleteConnections );
errorMsg = i18n("You have been logged out of the Yahoo service, possibly due to a duplicate login.");
KMessageBox::queuedMessageBox(Kopete::UI::Global::mainWidget(), KMessageBox::Error, errorMsg);
static_cast<YahooContact *>( myself() )->setOnlineStatus( m_protocol->Offline );
disconnected( Manual ); // cannot use ConnectionReset since that will auto-reconnect
return;
}
else if( succ == Yahoo::LoginVerify )
{
initConnectionSignals( DeleteConnections );
static_cast<YahooContact *>( myself() )->setOnlineStatus( m_protocol->Offline );
YahooVerifyAccount *verifyDialog = new YahooVerifyAccount( this );
verifyDialog->setUrl( KURL(url) );
verifyDialog->show();
return;
}
//If we get here, something went wrong, so set ourselves to offline
static_cast<YahooContact *>( myself() )->setOnlineStatus( m_protocol->Offline );
disconnected( Unknown );
}
void YahooAccount::slotDisconnected()
{
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << endl;
initConnectionSignals( DeleteConnections );
if( !isConnected() )
return;
static_cast<YahooContact *>( myself() )->setOnlineStatus( m_protocol->Offline );
disconnected( ConnectionReset ); // may reconnect
QString message;
message = i18n( "%1 has been disconnected.\nError message:\n%2 - %3" )
.arg( accountId() ).arg( m_session->error() ).arg( m_session->errorString() );
KNotification::event( "connection_lost", message, myself()->onlineStatus().protocolIcon() );
}
void YahooAccount::slotLoginFailed()
{
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << endl;
initConnectionSignals( DeleteConnections );
static_cast<YahooContact *>( myself() )->setOnlineStatus( m_protocol->Offline );
disconnected( Manual ); // don't reconnect
QString message;
message = i18n( "There was an error while connecting %1 to the Yahoo server.\nError message:\n%2 - %3" )
.arg( accountId() ).arg( m_session->error() ).arg( m_session->errorString() );
KNotification::event( "cannot_connect", message, myself()->onlineStatus().protocolIcon() );
}
void YahooAccount::slotError( int level )
{
// enum LogLevel { Debug, Info, Notice, Warning, Error, Critical };
if( level <= Client::Notice )
return;
else if( level <= Client::Warning )
KMessageBox::information( Kopete::UI::Global::mainWidget(), i18n( "%1\n\nReason: %2 - %3" ).arg(m_session->errorInformation())
.arg(m_session->error()).arg(m_session->errorString()), i18n( "Yahoo Plugin" ) );
else
KMessageBox::error( Kopete::UI::Global::mainWidget(), i18n( "%1\n\nReason: %2 - %3" ).arg(m_session->errorInformation())
.arg(m_session->error()).arg(m_session->errorString()), i18n( "Yahoo Plugin" ) );
}
void YahooAccount::slotGotBuddy( const QString &userid, const QString &alias, const QString &group )
{
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << endl;
IDs[userid] = QPair<QString, QString>(group, alias);
// Serverside -> local
if ( !contact( userid ) )
{
kdDebug(YAHOO_GEN_DEBUG) << "SS Contact " << userid << " is not in the contact list. Adding..." << endl;
Kopete::Group *g=Kopete::ContactList::self()->findGroup(group);
addContact(userid, alias.isEmpty() ? userid : alias, g, Kopete::Account::ChangeKABC);
}
}
void YahooAccount::slotAuthorizationAccepted( const QString &who )
{
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << endl;
QString message;
message = i18n( "User %1 has granted your authorization request." )
.arg( who );
KNotification::event( "kopete_authorization", message, 0 , 0 , 0 );
if( contact( who ) )
contact( who )->setOnlineStatus( m_protocol->Online );
}
void YahooAccount::slotAuthorizationRejected( const QString &who, const QString &msg )
{
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << endl;
QString message;
message = i18n( "User %1 has granted your authorization request.\n%2" )
.arg( who ).arg( msg );
KNotification::event( "kopete_authorization", message, 0 , 0 , 0 );
}
void YahooAccount::slotgotAuthorizationRequest( const QString &user, const QString &msg, const QString &name )
{
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << endl;
Q_UNUSED( msg );
Q_UNUSED( name );
YahooContact *kc = contact( user );
Kopete::MetaContact *metaContact=0L;
if(kc)
metaContact=kc->metaContact();
int hideFlags=Kopete::UI::ContactAddedNotifyDialog::InfoButton;
if( metaContact && !metaContact->isTemporary() )
hideFlags |= Kopete::UI::ContactAddedNotifyDialog::AddCheckBox | Kopete::UI::ContactAddedNotifyDialog::AddGroupBox ;
Kopete::UI::ContactAddedNotifyDialog *dialog=
new Kopete::UI::ContactAddedNotifyDialog( user,QString::null,this, hideFlags );
QObject::connect(dialog,SIGNAL(applyClicked(const QString&)),
this,SLOT(slotContactAddedNotifyDialogClosed(const QString& )));
dialog->show();
}
void YahooAccount::slotContactAddedNotifyDialogClosed( const QString &user )
{
const Kopete::UI::ContactAddedNotifyDialog *dialog =
dynamic_cast<const Kopete::UI::ContactAddedNotifyDialog *>(sender());
if(!dialog || !isConnected())
return;
m_session->sendAuthReply( user, dialog->authorized(), QString::null );
if(dialog->added())
{
dialog->addContact();
}
}
void YahooAccount::slotGotIgnore( const QStringList & /* igns */ )
{
//kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << endl;
}
void YahooAccount::slotGotIdentities( const QStringList & /* ids */ )
{
//kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << endl;
}
void YahooAccount::slotStatusChanged( const QString &who, int stat, const QString &msg, int away, int idle )
{
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << who << " status: " << stat << " msg: " << msg << " away: " << away << " idle: " << idle <<endl;
YahooContact *kc = contact( who );
if( contact( who ) == myself() )
return;
if ( kc )
{
Kopete::OnlineStatus newStatus = m_protocol->statusFromYahoo( stat );
Kopete::OnlineStatus oldStatus = kc->onlineStatus();
if( newStatus == m_protocol->Custom ) {
if( away == 0 )
newStatus =m_protocol->Online;
kc->setProperty( m_protocol->awayMessage, msg);
}
else
kc->removeProperty( m_protocol->awayMessage );
if( newStatus != m_protocol->Offline &&
oldStatus == m_protocol->Offline && contact(who) != myself() )
{
//m_session->requestBuddyIcon( who ); // Try to get Buddy Icon
if ( !myself()->property( Kopete::Global::Properties::self()->photo() ).isNull() &&
myself()->onlineStatus() != m_protocol->Invisible &&
!kc->stealthed() )
{
kc->sendBuddyIconUpdate( m_session->pictureFlag() );
kc->sendBuddyIconChecksum( myself()->property( YahooProtocol::protocol()->iconCheckSum ).value().toInt() );
}
}
//if( newStatus == static_cast<YahooProtocol*>( m_protocol )->Idle ) {
if( newStatus == m_protocol->Idle )
kc->setIdleTime( idle ? idle : 1 );
else
kc->setIdleTime( 0 );
kc->setOnlineStatus( newStatus );
}
}
void YahooAccount::slotStealthStatusChanged( const QString &who, Yahoo::StealthStatus state )
{
//kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << "Stealth Status of " << who << "changed to " << state << endl;
YahooContact* kc = contact( who );
if ( kc == NULL ) {
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << "contact " << who << " doesn't exist." << endl;
return;
}
kc->setStealthed( state == Yahoo::StealthActive );
}
QString YahooAccount::prepareIncomingMessage( const QString &messageText )
{
QString newMsgText( messageText );
QRegExp regExp;
int pos = 0;
newMsgText = stripMsgColorCodes( newMsgText );
kdDebug(YAHOO_GEN_DEBUG) << "Message after stripping color codes '" << newMsgText << "'" << endl;
newMsgText.replace( QString::fromLatin1( "&" ), QString::fromLatin1( "&" ) );
// Replace Font tags
regExp.setMinimal( true );
regExp.setPattern( "<font([^>]*)size=\"([^>]*)\"([^>]*)>" );
pos = 0;
while ( pos >= 0 ) {
pos = regExp.search( newMsgText, pos );
if ( pos >= 0 ) {
pos += regExp.matchedLength();
newMsgText.replace( regExp, QString::fromLatin1("<font\\1style=\"font-size:\\2pt\">" ) );
}
}
// Remove FADE and ALT tags
regExp.setPattern( "<[/]*FADE([^>]*)>" );
pos = 0;
while ( pos >= 0 ) {
pos = regExp.search( newMsgText, pos );
if ( pos >= 0 ) {
pos += regExp.matchedLength();
newMsgText.replace( regExp, QString::fromLatin1("" ) );
}
}
regExp.setPattern( "<[/]*ALT([^>]*)>" );
pos = 0;
while ( pos >= 0 ) {
pos = regExp.search( newMsgText, pos );
if ( pos >= 0 ) {
pos += regExp.matchedLength();
newMsgText.replace( regExp, QString::fromLatin1("" ) );
}
}
// Replace < and > in text
regExp.setPattern( "<(?!(/*(font.*|[\"fbui])>))" );
pos = 0;
while ( pos >= 0 ) {
pos = regExp.search( newMsgText, pos );
if ( pos >= 0 ) {
pos += regExp.matchedLength();
newMsgText.replace( regExp, QString::fromLatin1("<" ) );
}
}
regExp.setPattern( "([^\"bui])>" );
pos = 0;
while ( pos >= 0 ) {
pos = regExp.search( newMsgText, pos );
if ( pos >= 0 ) {
pos += regExp.matchedLength();
newMsgText.replace( regExp, QString::fromLatin1("\\1>" ) );
}
}
// add closing tags when needed
regExp.setMinimal( false );
regExp.setPattern( "(<b>.*)(?!</b>)" );
newMsgText.replace( regExp, QString::fromLatin1("\\1</b>" ) );
regExp.setPattern( "(<i>.*)(?!</i>)" );
newMsgText.replace( regExp, QString::fromLatin1("\\1</i>" ) );
regExp.setPattern( "(<u>.*)(?!</u>)" );
newMsgText.replace( regExp, QString::fromLatin1("\\1</u>" ) );
regExp.setPattern( "(<font.*)(?!</font>)" );
newMsgText.replace( regExp, QString::fromLatin1("\\1</font>" ) );
newMsgText.replace( QString::fromLatin1( "\r" ), QString::fromLatin1( "<br/>" ) );
return newMsgText;
}
void YahooAccount::slotGotIm( const QString &who, const QString &msg, long tm, int /*stat*/)
{
QFont msgFont;
QDateTime msgDT;
Kopete::ContactPtrList justMe;
if( !contact( who ) )
{
kdDebug(YAHOO_GEN_DEBUG) << "Adding contact " << who << endl;
addContact( who,who, 0L, Kopete::Account::Temporary );
}
//Parse the message for it's properties
kdDebug(YAHOO_GEN_DEBUG) << "Original message is '" << msg << "'" << endl;
//kdDebug(YAHOO_GEN_DEBUG) << "Message color is " << getMsgColor(msg) << endl;
QColor fgColor = getMsgColor( msg );
if (tm == 0)
msgDT.setTime_t(time(0L));
else
msgDT.setTime_t(tm, Qt::LocalTime);
QString newMsgText = prepareIncomingMessage( msg );
kdDebug(YAHOO_GEN_DEBUG) << "Message after fixing font tags '" << newMsgText << "'" << endl;
Kopete::ChatSession *mm = contact(who)->manager(Kopete::Contact::CanCreate);
// Tell the message manager that the buddy is done typing
mm->receivedTypingMsg(contact(who), false);
justMe.append(myself());
Kopete::Message kmsg(msgDT, contact(who), justMe, newMsgText,
Kopete::Message::Inbound , Kopete::Message::RichText);
kmsg.setFg( fgColor );
mm->appendMessage(kmsg);
}
void YahooAccount::slotGotBuzz( const QString &who, long tm )
{
QFont msgFont;
QDateTime msgDT;
Kopete::ContactPtrList justMe;
if( !contact( who ) )
{
kdDebug(YAHOO_GEN_DEBUG) << "Adding contact " << who << endl;
addContact( who,who, 0L, Kopete::Account::Temporary );
}
if (tm == 0)
msgDT.setTime_t(time(0L));
else
msgDT.setTime_t(tm, Qt::LocalTime);
justMe.append(myself());
QString buzzMsgText = i18n("This string is shown when the user is buzzed by a contact", "Buzz!!");
Kopete::Message kmsg(msgDT, contact(who), justMe, buzzMsgText, Kopete::Message::Inbound,
Kopete::Message::PlainText, QString::null, Kopete::Message::TypeAction);
QColor fgColor( "gold" );
kmsg.setFg( fgColor );
Kopete::ChatSession *mm = contact(who)->manager(Kopete::Contact::CanCreate);
mm->appendMessage(kmsg);
// Emit the buzz notification.
mm->emitNudgeNotification();
}
void YahooAccount::slotGotConfInvite( const QString & who, const QString & room, const QString &msg, const QStringList &members )
{
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << who << " has invited you to join the conference \"" << room << "\" : " << msg << endl;
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << "Members: " << members << endl;
if( !m_pendingConfInvites.contains( room ) ) // We have to keep track of the invites as the server will send the same invite twice if it gets canceled by the host
m_pendingConfInvites.push_back( room );
else
{
return;
}
QString m = who;
QStringList myMembers;
myMembers.push_back( who );
for( QStringList::const_iterator it = ++members.begin(); it != members.end(); it++ )
{
if( *it != m_session->userId() )
{
m.append( QString(", %1").arg( *it ) );
myMembers.push_back( *it );
}
}
if( KMessageBox::Yes == KMessageBox::questionYesNo( Kopete::UI::Global::mainWidget(),
i18n("%1 has invited you to join a conference with %2.\n\nHis message: %3\n\n Accept?")
.arg(who).arg(m).arg(msg), QString::null, i18n("Accept"), i18n("Ignore") ) )
{
m_session->joinConference( room, myMembers );
if( !m_conferences[room] )
{
Kopete::ContactPtrList others;
YahooConferenceChatSession *session = new YahooConferenceChatSession( room, protocol(), myself(), others );
m_conferences[room] = session;
QObject::connect( session, SIGNAL(leavingConference( YahooConferenceChatSession * ) ), this, SLOT( slotConfLeave( YahooConferenceChatSession * ) ) );
for ( QValueList<QString>::ConstIterator it = myMembers.begin(); it != myMembers.end(); ++it )
{
YahooContact * c = contact( *it );
if ( !c )
{
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << "Adding contact " << *it << " to conference." << endl;
addContact( *it,*it, 0L, Kopete::Account::Temporary );
c = contact( *it );
}
session->joined( c );
}
session->view( true )->raise( false );
}
}
else
m_session->declineConference( room, myMembers, QString::null );
m_pendingConfInvites.remove( room );
}
void YahooAccount::prepareConference( const QString &who )
{
QString room;
for( int i = 0; i < 22; i++ )
{
char c = rand()%52;
room += (c > 25) ? c + 71 : c + 65;
}
room = QString("%1-%2--").arg(accountId()).arg(room);
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << "The generated roomname is: " << room << endl;
QStringList buddies;
QDictIterator<Kopete::Contact> it( contacts() );
for( ; it.current(); ++it )
{
if( (*it) != myself() )
buddies.push_back( (*it)->contactId() );
}
YahooInviteListImpl *dlg = new YahooInviteListImpl( Kopete::UI::Global::mainWidget() );
QObject::connect( dlg, SIGNAL( readyToInvite( const QString &, const QStringList &, const QStringList &, const QString & ) ),
this, SLOT( slotInviteConference( const QString &, const QStringList &, const QStringList &, const QString & ) ) );
dlg->setRoom( room );
dlg->fillFriendList( buddies );
dlg->addInvitees( QStringList( who ) );
dlg->show();
}
void YahooAccount::slotInviteConference( const QString &room, const QStringList &members, const QStringList &participants, const QString &msg )
{
Q_UNUSED( participants );
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << "Inviting " << members << " to the conference " << room << ". Message: " << msg << endl;
m_session->inviteConference( room, members, msg );
Kopete::ContactPtrList others;
YahooConferenceChatSession *session = new YahooConferenceChatSession( room, protocol(), myself(), others );
m_conferences[room] = session;
QObject::connect( session, SIGNAL(leavingConference( YahooConferenceChatSession * ) ), this, SLOT( slotConfLeave( YahooConferenceChatSession * ) ) );
session->joined( static_cast< YahooContact *>(myself()) );
session->view( true )->raise( false );
}
void YahooAccount::slotAddInviteConference( const QString &room, const QStringList &who, const QStringList &members, const QString &msg )
{
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << "Inviting " << who << " to the conference " << room << ". Message: " << msg << endl;
m_session->addInviteConference( room, who, members, msg );
}
void YahooAccount::slotConfUserDecline( const QString &who, const QString &room, const QString &msg)
{
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << endl;
if( !m_conferences.contains( room ) )
{
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << "Error. No chatsession for this conference found." << endl;
return;
}
YahooConferenceChatSession *session = m_conferences[room];
QString body = i18n( "%1 declined to join the conference: \"%2\"" ).arg( who ).arg( msg );
Kopete::Message message = Kopete::Message( contact( who ), myself(), body, Kopete::Message::Internal, Kopete::Message::PlainText );
session->appendMessage( message );
}
void YahooAccount::slotConfUserJoin( const QString &who, const QString &room )
{
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << endl;
if( !m_conferences.contains( room ) )
{
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << "Error. No chatsession for this conference found." << endl;
return;
}
YahooConferenceChatSession *session = m_conferences[room];
if( !contact( who ) )
{
addContact( who, who, 0L, Kopete::Account::Temporary );
}
session->joined( contact( who ) );
}
void YahooAccount::slotConfUserLeave( const QString & who, const QString &room )
{
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << endl;
if( !m_conferences.contains( room ) )
{
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << "Error. No chatsession for this conference found." << endl;
return;
}
YahooConferenceChatSession *session = m_conferences[room];
if( !contact( who ) )
{
addContact( who, who, 0L, Kopete::Account::Temporary );
}
session->left( contact( who ) );
}
void YahooAccount::slotConfLeave( YahooConferenceChatSession *s )
{
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << endl;
if( !s )
return;
QStringList members;
for( Kopete::ContactPtrList::iterator it = s->members().begin(); it != s->members().end(); ++it )
{
if( (*it) == myself() )
continue;
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << "Member: " << (*it)->contactId() << endl;
members.append( (*it)->contactId() );
}
m_session->leaveConference( s->room(), members );
m_conferences.remove( s->room() );
}
void YahooAccount::slotConfMessage( const QString &who, const QString &room, const QString &msg )
{
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << endl;
if( !m_conferences.contains( room ) )
{
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << "Error. No chatsession for this conference found." << endl;
return;
}
YahooConferenceChatSession *session = m_conferences[room];
QFont msgFont;
QDateTime msgDT;
Kopete::ContactPtrList justMe;
if( !contact( who ) )
{
kdDebug(YAHOO_GEN_DEBUG) << "Adding contact " << who << endl;
addContact( who,who, 0L, Kopete::Account::Temporary );
}
kdDebug(YAHOO_GEN_DEBUG) << "Original message is '" << msg << "'" << endl;
QColor fgColor = getMsgColor( msg );
msgDT.setTime_t(time(0L));
QString newMsgText = prepareIncomingMessage( msg );
kdDebug(YAHOO_GEN_DEBUG) << "Message after fixing font tags '" << newMsgText << "'" << endl;
session->receivedTypingMsg(contact(who), false);
justMe.append(myself());
Kopete::Message kmsg(msgDT, contact(who), justMe, newMsgText,
Kopete::Message::Inbound , Kopete::Message::RichText);
kmsg.setFg( fgColor );
session->appendMessage(kmsg);
}
void YahooAccount::sendConfMessage( YahooConferenceChatSession *s, Kopete::Message &message )
{
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << endl;
QStringList members;
for( Kopete::ContactPtrList::iterator it = s->members().begin(); it != s->members().end(); ++it )
{
if( (*it) == myself() )
continue;
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << "Member: " << (*it)->contactId() << endl;
members.append( (*it)->contactId() );
}
m_session->sendConferenceMessage( s->room(), members, YahooContact::prepareMessage( message.escapedBody() ) );
}
void YahooAccount::slotGotYABRevision( long rev, bool merged )
{
if( merged )
{
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << "Merge Revision received: " << rev << endl;
configGroup()->writeEntry( "YABLastMerge", rev );
m_YABLastMerge = rev;
}
else
{
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << "Remote Revision received: " << rev << endl;
configGroup()->writeEntry( "YABLastRemoteRevision", rev );
m_YABLastRemoteRevision = rev;
}
}
void YahooAccount::slotGotYABEntry( YABEntry *entry )
{
YahooContact* kc = contact( entry->yahooId );
if( !kc )
{
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << "YAB entry received for a contact not on our buddylist: " << entry->yahooId << endl;
delete entry;
}
else
{
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << "YAB entry received for: " << entry->yahooId << endl;
if( entry->source == YABEntry::SourceYAB )
{
kc->setYABEntry( entry );
}
else if( entry->source == YABEntry::SourceContact )
{
entry->YABId = kc->yabEntry()->YABId;
YahooUserInfoDialog *dlg = new YahooUserInfoDialog( kc, Kopete::UI::Global::mainWidget(), "yahoo userinfo" );
dlg->setData( *entry );
dlg->setAccountConnected( isConnected() );
dlg->show();
QObject::connect( dlg, SIGNAL(saveYABEntry( YABEntry & )), this, SLOT(slotSaveYABEntry( YABEntry & )));
delete entry;
}
}
}
void YahooAccount::slotSaveYABEntry( YABEntry &entry )
{
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << "YABId: " << entry.YABId << endl;
if( entry.YABId > 0 )
m_session->saveYABEntry( entry );
else
m_session->addYABEntry( entry );
}
void YahooAccount::slotModifyYABEntryError( YABEntry *entry, const QString &msg )
{
YahooContact* kc = contact( entry->yahooId );
if( kc )
kc->setYABEntry( entry, true );
KMessageBox::sorry( Kopete::UI::Global::mainWidget(), msg, i18n( "Yahoo Plugin" ) );
}
void YahooAccount::slotGotFile( const QString & who, const QString & url , long /* expires */, const QString & msg ,
const QString & fname, unsigned long fesize )
{
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << "Received File from " << who << ": " << msg << endl;
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << "Filename :" << fname << " size:" << fesize << endl;
Kopete::TransferManager::transferManager()->askIncomingTransfer( contact( who ) , fname, fesize, msg, url );
if( m_pendingFileTransfers.empty() )
{
QObject::connect( Kopete::TransferManager::transferManager(), SIGNAL( accepted( Kopete::Transfer *, const QString& ) ),
this, SLOT( slotReceiveFileAccepted( Kopete::Transfer *, const QString& ) ) );
QObject::connect( Kopete::TransferManager::transferManager(), SIGNAL( refused(const Kopete::FileTransferInfo& ) ),
this, SLOT( slotReceiveFileRefused( const Kopete::FileTransferInfo& ) ) );
}
m_pendingFileTransfers.append( url );
}
void YahooAccount::slotReceiveFileAccepted(Kopete::Transfer *transfer, const QString& fileName)
{
if( !m_pendingFileTransfers.contains( transfer->info().internalId() ) )
return;
m_pendingFileTransfers.remove( transfer->info().internalId() );
//Create directory if it doesn't already exist
QDir dir;
QString path = QFileInfo( fileName ).dirPath();
for( int i = 1; i <= path.contains('/'); ++i )
{
if( !dir.exists( path.section( '/', 0, i ) ) )
{
dir.mkdir( path.section( '/', 0, i) );
}
}
m_session->receiveFile( transfer->info().transferId(), transfer->info().contact()->contactId(), transfer->info().internalId(), fileName );
m_fileTransfers.insert( transfer->info().transferId(), transfer );
QObject::connect( transfer, SIGNAL(result( KIO::Job * )), this, SLOT(slotFileTransferResult( KIO::Job * )) );
if( m_pendingFileTransfers.empty() )
{
QObject::disconnect( Kopete::TransferManager::transferManager(), SIGNAL( accepted( Kopete::Transfer *, const QString& ) ),
this, SLOT( slotReceiveFileAccepted( Kopete::Transfer *, const QString& ) ) );
QObject::disconnect( Kopete::TransferManager::transferManager(), SIGNAL( refused(const Kopete::FileTransferInfo& ) ),
this, SLOT( slotReceiveFileRefused( const Kopete::FileTransferInfo& ) ) );
}
}
void YahooAccount::slotReceiveFileRefused( const Kopete::FileTransferInfo& info )
{
if( !m_pendingFileTransfers.contains( info.internalId() ) )
return;
m_pendingFileTransfers.remove( info.internalId() );
m_session->rejectFile( info.contact()->contactId(), info.internalId() );
if( m_pendingFileTransfers.empty() )
{
QObject::disconnect( Kopete::TransferManager::transferManager(), SIGNAL( accepted( Kopete::Transfer *, const QString& ) ),
this, SLOT( slotReceiveFileAccepted( Kopete::Transfer *, const QString& ) ) );
QObject::disconnect( Kopete::TransferManager::transferManager(), SIGNAL( refused(const Kopete::FileTransferInfo& ) ),
this, SLOT( slotReceiveFileRefused( const Kopete::FileTransferInfo& ) ) );
}
}
void YahooAccount::slotFileTransferBytesProcessed( unsigned int transferId, unsigned int bytes )
{
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << "Transfer: " << transferId << " Bytes:" << bytes << endl;
Kopete::Transfer *t = m_fileTransfers[transferId];
if( !t )
return;
t->slotProcessed( bytes );
}
void YahooAccount::slotFileTransferComplete( unsigned int transferId )
{
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << endl;
Kopete::Transfer *t = m_fileTransfers[transferId];
if( !t )
return;
t->slotComplete();
m_fileTransfers.remove( transferId );
}
void YahooAccount::slotFileTransferError( unsigned int transferId, int error, const QString &desc )
{
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << endl;
Kopete::Transfer *t = m_fileTransfers[transferId];
if( !t )
return;
t->slotError( error, desc );
m_fileTransfers.remove( transferId );
}
void YahooAccount::slotFileTransferResult( KIO::Job *job )
{
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << endl;
const Kopete::Transfer *t = dynamic_cast< const Kopete::Transfer * >( job );
if( !t )
return;
if( t->error() == KIO::ERR_USER_CANCELED )
{
m_session->cancelFileTransfer( t->info().transferId() );
m_fileTransfers.remove( t->info().transferId() );
}
}
void YahooAccount::slotContactAdded( const QString & /* myid */, const QString & /* who */, const QString & /* msg */ )
{
// kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << myid << " " << who << " " << msg << endl;
}
void YahooAccount::slotRejected( const QString & /* who */, const QString & /* msg */ )
{
// kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << endl;
}
void YahooAccount::slotTypingNotify( const QString &who, int what )
{
emit receivedTypingMsg(who, what);
}
void YahooAccount::slotGameNotify( const QString & /* who */, int /* stat */ )
{
// kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << endl;
}
void YahooAccount::slotMailNotify( const QString& from, const QString& /* subject */, int cnt )
{
// kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << "Mail count: " << cnt << endl;
if ( cnt > m_currentMailCount && from.isEmpty() )
{
QObject::connect(KNotification::event( "yahoo_mail", i18n( "You have one unread message in your Yahoo inbox.",
"You have %n unread messages in your Yahoo inbox.", cnt ), 0 , 0 , i18n( "Open Inbox..." ) ),
SIGNAL(activated(unsigned int ) ) , this, SLOT( slotOpenInbox() ) );
m_currentMailCount = cnt;
}
else if ( cnt > m_currentMailCount )
{ kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << "attempting to trigger event" << endl;
QObject::connect(KNotification::event( "yahoo_mail", i18n( "You have a message from %1 in your Yahoo inbox.").arg(from)
, 0 , 0 , i18n( "Open Inbox..." ) ), SIGNAL(activated(unsigned int ) ) , this, SLOT( slotOpenInbox() ) );
m_currentMailCount = cnt;
}
}
void YahooAccount::slotSystemMessage( const QString & /* msg */ )
{
// kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << msg << endl;
}
void YahooAccount::slotRemoveHandler( int /* fd */ )
{
// kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << endl;
}
void YahooAccount::slotGotWebcamInvite( const QString& who )
{
YahooContact* kc = contact( who );
if ( kc == NULL ) {
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << "contact " << who << " doesn't exist." << endl;
return;
}
if( m_pendingWebcamInvites.contains( who ) )
return;
m_pendingWebcamInvites.append( who );
if( KMessageBox::Yes == KMessageBox::questionYesNo( Kopete::UI::Global::mainWidget(), i18n("%1 has invited you to view his/her webcam. Accept?")
.arg(who), QString::null, i18n("Accept"), i18n("Ignore") ) )
{
m_pendingWebcamInvites.remove( who );
m_session->requestWebcam( who );
}
}
void YahooAccount::slotWebcamNotAvailable( const QString &who )
{
KMessageBox::sorry( Kopete::UI::Global::mainWidget(), i18n("Webcam for %1 is not available.").arg(who), i18n( "Yahoo Plugin" ) );
}
void YahooAccount::slotGotWebcamImage( const QString& who, const QPixmap& image )
{
YahooContact* kc = contact( who );
if ( kc == NULL ) {
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << "contact " << who << " doesn't exist." << endl;
return;
}
kc->receivedWebcamImage( image );
}
void YahooAccount::slotPictureStatusNotiy( const QString &who, int status)
{
YahooContact *kc = contact( who );
if ( kc == NULL ) {
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << "contact " << who << " doesn't exist." << endl;
return;
}
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << "contact " << who << " changed picture status to" << status << endl;
}
void YahooAccount::slotGotBuddyIconChecksum(const QString &who, int checksum)
{
YahooContact *kc = contact( who );
if ( kc == NULL ) {
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << "contact " << who << " doesn't exist." << endl;
return;
}
if ( checksum == kc->property( YahooProtocol::protocol()->iconCheckSum ).value().toInt() &&
QFile::exists( locateLocal( "appdata", "yahoopictures/"+ who.lower().replace(QRegExp("[./~]"),"-") +".png" ) ) )
{
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << "Icon already exists. I will not request it again." << endl;
return;
} else
m_session->requestPicture( who );
}
void YahooAccount::slotGotBuddyIconInfo(const QString &who, KURL url, int checksum)
{
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << endl;
YahooContact *kc = contact( who );
if ( kc == NULL ) {
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << "contact " << who << " doesn't exist." << endl;
return;
}
if ( checksum == kc->property( YahooProtocol::protocol()->iconCheckSum ).value().toInt() &&
QFile::exists( locateLocal( "appdata", "yahoopictures/"+ who.lower().replace(QRegExp("[./~]"),"-") +".png" ) ))
{
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << "Icon already exists. I will not download it again." << endl;
return;
} else
m_session->downloadPicture( who, url, checksum );
}
void YahooAccount::slotGotBuddyIcon( const QString &who, KTempFile *file, int checksum )
{
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << endl;
YahooContact *kc = contact( who );
if ( kc == NULL ) {
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << "contact " << who << " doesn't exist." << endl;
return;
}
kc->setDisplayPicture( file, checksum );
}
void YahooAccount::slotGotBuddyIconRequest( const QString & who )
{
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << endl;
YahooContact *kc = contact( who );
if ( kc == NULL ) {
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << "contact " << who << " doesn't exist." << endl;
return;
}
kc->sendBuddyIconInfo( myself()->property( YahooProtocol::protocol()->iconRemoteUrl ).value().toString(),
myself()->property( YahooProtocol::protocol()->iconCheckSum ).value().toInt() );
}
void YahooAccount::setBuddyIcon( KURL url )
{
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << "Url: " << url.path() << endl;
QString s = url.path();
if ( url.path().isEmpty() )
{
myself()->removeProperty( Kopete::Global::Properties::self()->photo() );
myself()->removeProperty( YahooProtocol::protocol()->iconRemoteUrl );
myself()->removeProperty( YahooProtocol::protocol()->iconExpire );
myself()->removeProperty( YahooProtocol::protocol()->iconCheckSum );
m_session->setPictureFlag( 0 );
slotBuddyIconChanged( QString::null );
}
else
{
QImage image( url.path() );
QString newlocation( locateLocal( "appdata", "yahoopictures/"+ url.fileName().lower() ) ) ;
QFile iconFile( newlocation );
QByteArray data;
uint expire = myself()->property( YahooProtocol::protocol()->iconExpire ).value().toInt();
if ( image.isNull() ) {
KMessageBox::sorry( Kopete::UI::Global::mainWidget(), i18n( "<qt>The selected buddy icon could not be opened. <br>Please set a new buddy icon.</qt>" ), i18n( "Yahoo Plugin" ) );
return;
}
image = image.smoothScale( 96, 96, QImage::ScaleMin );
if(image.width() < image.height())
{
image = image.copy((image.width()-image.height())/2, 0, 96, 96);
}
else if(image.height() < image.width())
{
image = image.copy(0, (image.height()-image.width())/2, 96, 96);
}
if( !image.save( newlocation, "PNG" ) || !iconFile.open(IO_ReadOnly) )
{
KMessageBox::sorry( Kopete::UI::Global::mainWidget(), i18n( "An error occurred when trying to change the display picture." ), i18n( "Yahoo Plugin" ) );
return;
}
data = iconFile.readAll();
iconFile.close();
// create checksum - taken from qhash.cpp of qt4
const uchar *p = reinterpret_cast<const uchar *>(data.data());
int n = data.size();
uint checksum = 0;
uint g;
while (n--)
{
checksum = (checksum << 4) + *p++;
if ((g = (checksum & 0xf0000000)) != 0)
checksum ^= g >> 23;
checksum &= ~g;
}
myself()->setProperty( Kopete::Global::Properties::self()->photo() , newlocation );
configGroup()->writeEntry( "iconLocalUrl", newlocation );
if ( checksum != static_cast<uint>(myself()->property( YahooProtocol::protocol()->iconCheckSum ).value().toInt()) ||
QDateTime::currentDateTime().toTime_t() > expire )
{
myself()->setProperty( YahooProtocol::protocol()->iconCheckSum, checksum );
myself()->setProperty( YahooProtocol::protocol()->iconExpire , QDateTime::currentDateTime().toTime_t() + 604800 );
configGroup()->writeEntry( "iconCheckSum", checksum );
configGroup()->writeEntry( "iconExpire", myself()->property( YahooProtocol::protocol()->iconExpire ).value().toInt() );
if ( m_session != 0 )
m_session->uploadPicture( newlocation );
}
}
}
void YahooAccount::slotBuddyIconChanged( const QString &url )
{
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << endl;
QDictIterator<Kopete::Contact> it( contacts() );
int checksum = myself()->property( YahooProtocol::protocol()->iconCheckSum ).value().toInt();
if ( url.isEmpty() ) // remove pictures from buddie's clients
{
checksum = 0;
m_session->setPictureFlag( 0 );
}
else
{
myself()->setProperty( YahooProtocol::protocol()->iconRemoteUrl, url );
configGroup()->writeEntry( "iconRemoteUrl", url );
m_session->setPictureFlag( 2 );
m_session->sendPictureChecksum( checksum, QString::null );
}
}
void YahooAccount::slotWebcamReadyForTransmission()
{
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << endl;
if( !m_webcam )
{
m_webcam = new YahooWebcam( this );
QObject::connect( m_webcam, SIGNAL(webcamClosing()), this, SLOT(slotOutgoingWebcamClosing()) );
}
m_webcam->startTransmission();
}
void YahooAccount::slotWebcamStopTransmission()
{
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << endl;
if( m_webcam )
{
m_webcam->stopTransmission();
}
}
void YahooAccount::slotOutgoingWebcamClosing()
{
m_session->closeOutgoingWebcam();
m_webcam->deleteLater();
m_webcam = 0L;
}
void YahooAccount::slotWebcamViewerJoined( const QString &viewer )
{
if( m_webcam )
{
m_webcam->addViewer( viewer );
}
}
void YahooAccount::slotWebcamViewerRequest( const QString &viewer )
{
if( KMessageBox::Yes == KMessageBox::questionYesNo( Kopete::UI::Global::mainWidget(), i18n("%1 wants to view your webcam. Grant access?")
.arg(viewer), QString::null, i18n("Accept"), i18n("Ignore") ) )
m_session->grantWebcamAccess( viewer );
}
void YahooAccount::slotWebcamViewerLeft( const QString &viewer )
{
if( m_webcam )
{
m_webcam->removeViewer( viewer );
}
}
void YahooAccount::slotWebcamClosed( const QString& who, int reason )
{
YahooContact* kc = contact( who );
if ( kc == NULL ) {
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << "contact " << who << " doesn't exist." << endl;
return;
}
kc->webcamClosed( reason );
}
void YahooAccount::slotWebcamPaused( const QString &who )
{
YahooContact* kc = contact( who );
if ( kc == NULL ) {
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << "contact " << who << " doesn't exist." << endl;
return;
}
kc->webcamPaused();
}
void YahooAccount::setOnlineStatus( const Kopete::OnlineStatus& status , const QString &reason)
{
kdDebug(YAHOO_GEN_DEBUG) << k_funcinfo << endl;
if ( myself()->onlineStatus().status() == Kopete::OnlineStatus::Offline &&
status.status() != Kopete::OnlineStatus::Offline )
{
if( !reason.isEmpty() )
m_session->setStatusMessageOnConnect( reason );
connect( status );
}
else if ( myself()->onlineStatus().status() != Kopete::OnlineStatus::Offline &&
status.status() == Kopete::OnlineStatus::Offline )
{
disconnect();
}
else if ( myself()->onlineStatus().status() != Kopete::OnlineStatus::Offline &&
status.internalStatus() == 2 && !reason.isEmpty())
{
slotGoStatus( 99, reason );
}
else if ( myself()->onlineStatus().status() != Kopete::OnlineStatus::Offline &&
status.internalStatus() == 99 && reason.isEmpty())
{
slotGoStatus( 2, reason );
}
else if ( myself()->onlineStatus().status() != Kopete::OnlineStatus::Offline )
{
slotGoStatus( status.internalStatus(), reason );
}
}
void YahooAccount::slotOpenInbox()
{
KRun::runURL( KURL( QString::fromLatin1("http://mail.yahoo.com/") ) , "text/html" );
}
void YahooAccount::slotOpenYAB()
{
KRun::runURL( KURL( QString::fromLatin1("http://address.yahoo.com/") ) , "text/html" );
}
void YahooAccount::slotEditOwnYABEntry()
{
myself()->slotUserInfo();
}
#include "yahooaccount.moc"
// vim: set noet ts=4 sts=4 sw=4:
//kate: indent-mode csands; tab-width 4;