diff options
Diffstat (limited to 'kopete/protocols/yahoo/libkyahoo/sendpicturetask.cpp')
| -rw-r--r-- | kopete/protocols/yahoo/libkyahoo/sendpicturetask.cpp | 247 |
1 files changed, 247 insertions, 0 deletions
diff --git a/kopete/protocols/yahoo/libkyahoo/sendpicturetask.cpp b/kopete/protocols/yahoo/libkyahoo/sendpicturetask.cpp new file mode 100644 index 00000000..c1b1f5f0 --- /dev/null +++ b/kopete/protocols/yahoo/libkyahoo/sendpicturetask.cpp @@ -0,0 +1,247 @@ +/* + Kopete Yahoo Protocol + sendpicturetask.cpp - Send our picture or information about it + + Copyright (c) 2005 André Duffeck <[email protected]> + + ************************************************************************* + * * + * This library is free software; you can redistribute it and/or * + * modify it under the terms of the GNU Lesser General Public * + * License as published by the Free Software Foundation; either * + * version 2 of the License, or (at your option) any later version. * + * * + ************************************************************************* +*/ + +#include "sendpicturetask.h" +#include "transfer.h" +#include "ymsgtransfer.h" +#include "yahootypes.h" +#include "client.h" +#include <qstring.h> +#include <qfile.h> +#include <qcstring.h> +#include <qdatastream.h> +#include <kio/global.h> +#include <kio/job.h> +#include <kio/jobclasses.h> +#include <kbufferedsocket.h> +#include <kdebug.h> +#include <klocale.h> + +using namespace KNetwork; + +SendPictureTask::SendPictureTask(Task* parent) : Task(parent) +{ + kdDebug(YAHOO_RAW_DEBUG) << k_funcinfo << endl; + m_socket = 0; +} + +SendPictureTask::~SendPictureTask() +{ + delete m_socket; +} + +void SendPictureTask::onGo() +{ + switch( m_type ) + { + case UploadPicture: + initiateUpload(); + break; + case SendChecksum: + sendChecksum(); + break; + case SendInformation: + sendInformation(); + case SendStatus: + sendStatus(); + break; + } +} + +void SendPictureTask::initiateUpload() +{ + kdDebug(YAHOO_RAW_DEBUG) << k_funcinfo << endl; + m_socket = new KBufferedSocket( "filetransfer.msg.yahoo.com", QString::number(80) ); + connect( m_socket, SIGNAL( connected( const KResolverEntry& ) ), this, SLOT( connectSucceeded() ) ); + connect( m_socket, SIGNAL( gotError(int) ), this, SLOT( connectFailed(int) ) ); + + m_socket->connect(); +} + +void SendPictureTask::connectFailed( int i) +{ + m_socket->close(); + kdDebug(YAHOO_RAW_DEBUG) << k_funcinfo << i << ": " << static_cast<const KBufferedSocket*>( sender() )->errorString() << endl; + client()->notifyError(i18n("The picture was not successfully uploaded"), QString("%1 - %2").arg(i).arg(static_cast<const KBufferedSocket*>( sender() )->errorString()), Client::Error ); + setSuccess( false ); +} + +void SendPictureTask::connectSucceeded() +{ + kdDebug(YAHOO_RAW_DEBUG) << k_funcinfo << endl; + YMSGTransfer t(Yahoo::ServicePictureUpload); + + QFile file( m_path ); + + t.setId( client()->sessionID() ); + t.setParam( 1, client()->userId().local8Bit()); + t.setParam( 38, 604800); + t.setParam( 0, client()->userId().local8Bit()); + t.setParam( 28, file.size() ); + t.setParam( 27, m_fileName.local8Bit() ); + t.setParam( 14, "" ); + QByteArray buffer; + QByteArray paket; + QDataStream stream( buffer, IO_WriteOnly ); + + if ( file.open(IO_ReadOnly ) ) + { + kdDebug(YAHOO_RAW_DEBUG) << k_funcinfo << "File successfully opened. Reading..." << endl; + } + else + { + kdDebug(YAHOO_RAW_DEBUG) << k_funcinfo << "Error opening file: " << file.errorString() << endl; + client()->notifyError(i18n("Error opening file: %1").arg(m_path), file.errorString(), Client::Error ); + return; + } + + paket = t.serialize(); + kdDebug(YAHOO_RAW_DEBUG) << k_funcinfo << "Sizes: File (" << m_path << "): " << file.size() << " - paket: " << paket.size() << endl; + QString header = QString::fromLatin1("POST /notifyft HTTP/1.1\r\n" + "Cookie: Y=%1; T=%2; C=%3 ;\r\n" + "User-Agent: Mozilla/4.0 (compatible; MSIE 5.5)\r\n" + "Host: filetransfer.msg.yahoo.com\r\n" + "Content-length: %4\r\n" + "Cache-Control: no-cache\r\n\r\n").arg(client()->yCookie()).arg(client()->tCookie()).arg(client()->cCookie()).arg(file.size()+4+paket.size()); + stream.writeRawBytes( header.local8Bit(), header.length() ); + stream.writeRawBytes( paket.data(), paket.size() ); + stream << (Q_INT8)0x32 << (Q_INT8)0x39 << (Q_INT8)0xc0 << (Q_INT8)0x80; + stream.writeRawBytes( file.readAll(), file.size() ); + + kdDebug(YAHOO_RAW_DEBUG) << k_funcinfo << "Buffersize: " << buffer.size() << endl; + if( m_socket->writeBlock( buffer, buffer.size() ) ) + { + kdDebug(YAHOO_RAW_DEBUG) << k_funcinfo << "Upload Successful." << endl; + connect( m_socket, SIGNAL( readyRead() ), this, SLOT( readResult() ) ); + } + else + { + kdDebug(YAHOO_RAW_DEBUG) << k_funcinfo << "Upload Failed." << endl; + m_socket->close(); + setSuccess( false ); + } +} + +void SendPictureTask::readResult() +{ + QByteArray ar( m_socket->bytesAvailable() ); + m_socket->readBlock ( ar.data (), ar.size () ); + QString buf( ar ); + + m_socket->close(); + if( buf.find( "error", 0, false ) >= 0 ) + { + kdDebug(YAHOO_RAW_DEBUG) << k_funcinfo << "Picture upload failed" << endl; + setSuccess( false ); + } + else + { + kdDebug(YAHOO_RAW_DEBUG) << k_funcinfo << "Picture upload acknowledged." << endl; + setSuccess( true ); + } + +} + +void SendPictureTask::sendChecksum() +{ + kdDebug(YAHOO_RAW_DEBUG) << k_funcinfo << endl; + + YMSGTransfer *t = new YMSGTransfer(Yahoo::ServicePictureChecksum); + t->setId( client()->sessionID() ); + t->setParam(1, client()->userId().local8Bit()); + if( !m_target.isEmpty() ) + t->setParam( 5, m_target.local8Bit() ); + t->setParam(192, m_checksum); + t->setParam(212, 1); + send( t ); + + setSuccess( true ); +} + +void SendPictureTask::sendInformation() +{ + kdDebug(YAHOO_RAW_DEBUG) << k_funcinfo << endl; + + YMSGTransfer *t = new YMSGTransfer(Yahoo::ServicePicture); + t->setId( client()->sessionID() ); + t->setParam(1, client()->userId().local8Bit()); + t->setParam(4, client()->userId().local8Bit()); + t->setParam(13, 2 ); + t->setParam(5, m_target.local8Bit() ); + t->setParam(20, m_url.local8Bit() ); + t->setParam(192, m_checksum); + + send( t ); + + setSuccess( true ); +} + +void SendPictureTask::sendStatus() +{ + kdDebug(YAHOO_RAW_DEBUG) << k_funcinfo << endl; + + YMSGTransfer *t = new YMSGTransfer(Yahoo::ServicePictureUpdate); + t->setId( client()->sessionID() ); + t->setParam(1, client()->userId().local8Bit()); + t->setParam(5, m_target.local8Bit() ); + t->setParam(206, m_status ); + + send( t ); + + setSuccess( true ); +} + +void SendPictureTask::setType( Type type ) +{ + m_type = type; +} + +void SendPictureTask::setTarget( const QString &to ) +{ + m_target = to; +} + +void SendPictureTask::setFilename( const QString &filename ) +{ + m_fileName = filename; +} + +void SendPictureTask::setFilesize( int filesize ) +{ + m_fileSize = filesize; +} + +void SendPictureTask::setPath( const QString &path ) +{ + m_path = path; +} + +void SendPictureTask::setChecksum( int checksum ) +{ + m_checksum = checksum; +} + +void SendPictureTask::setStatus( int status ) +{ + m_status = status; +} + +void SendPictureTask::setUrl( const QString &url ) +{ + m_url = url; +} + +#include "sendpicturetask.moc" |