You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
k3b/libk3b/cddb/k3bcddbhttpquery.cpp

234 lines
5.1 KiB

/*
*
* $Id: k3bcddbhttpquery.cpp 619556 2007-01-03 17:38:12Z trueg $
* Copyright (C) 2003 Sebastian Trueg <trueg@k3b.org>
*
* This file is part of the K3b project.
* Copyright (C) 1998-2007 Sebastian Trueg <trueg@k3b.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.
* See the file "COPYING" for the exact licensing terms.
*/
#include "k3bcddbhttpquery.h"
#include "k3bcddbresult.h"
#include <tqstringlist.h>
#include <tqregexp.h>
#include <textstream.h>
#include <klocale.h>
#include <kdebug.h>
#include <kio/global.h>
#include <kio/job.h>
K3bCddbHttpQuery::K3bCddbHttpQuery( TQObject* parent, const char* name )
: K3bCddbQuery( parent, name )
{
m_server = "freedb.org";
m_port = 80;
m_cgiPath = "/~cddb/cddb.cgi";
}
K3bCddbHttpQuery::~K3bCddbHttpQuery()
{
}
void K3bCddbHttpQuery::doQuery()
{
setError( WORKING );
m_state = TQUERY;
performCommand( queryString() );
}
void K3bCddbHttpQuery::doMatchQuery()
{
setError( WORKING );
m_state = READ;
m_parsingBuffer.truncate(0);
performCommand( TQString( "cddb read %1 %2").arg( header().category ).arg( header().discid ) );
}
void K3bCddbHttpQuery::performCommand( const TQString& cmd )
{
KURL url;
url.setProtocol( "http" );
url.setHost( m_server );
url.setPort( m_port );
url.setPath( m_cgiPath );
url.addQueryItem( "cmd", cmd );
url.addQueryItem( "hello", handshakeString() );
url.addQueryItem( "proto", "6" );
m_data.truncate(0);
kdDebug() << "(K3bCddbHttpQuery) getting url: " << url.prettyURL() << endl;
KIO::TransferJob* job = KIO::get( url, false, false );
if( !job ) {
setError( CONNECTION_ERROR );
emit infoMessage( i18n("Could not connect to host %1").arg(m_server) );
emitQueryFinished();
return;
}
connect( job, TQT_SIGNAL(data(KIO::Job*, const TQByteArray&)),
TQT_SLOT(slotData(KIO::Job*, const TQByteArray&)) );
connect( job, TQT_SIGNAL(result(KIO::Job*)),
TQT_SLOT(slotResult(KIO::Job*)) );
}
void K3bCddbHttpQuery::slotData( KIO::Job*, const TQByteArray& data )
{
if( data.size() ) {
TQDataStream stream( m_data, IO_WriteOnly | IO_Append );
stream.writeRawBytes( data.data(), data.size() );
}
}
void K3bCddbHttpQuery::slotResult( KIO::Job* job )
{
if( job->error() ) {
emit infoMessage( job->errorString() );
setError( CONNECTION_ERROR );
emitQueryFinished();
return;
}
TQStringList lines = TQStringList::split( "\n", TQString::fromUtf8( m_data.data(), m_data.size() ) );
for( TQStringList::const_iterator it = lines.begin(); it != lines.end(); ++it ) {
TQString line = *it;
// kdDebug() << "(K3bCddbHttpQuery) line: " << line << endl;
switch( m_state ) {
case TQUERY:
if( getCode( line ) == 200 ) {
// parse exact match and send a read command
K3bCddbResultHeader header;
parseMatchHeader( line.mid(4), header );
queryMatch( header );
}
else if( getCode( line ) == 210 ) {
// TODO: perhaps add an "exact" field to K3bCddbEntry
kdDebug() << "(K3bCddbHttpQuery) Found multiple exact matches" << endl;
emit infoMessage( i18n("Found multiple exact matches") );
m_state = TQUERY_DATA;
}
else if( getCode( line ) == 211 ) {
kdDebug() << "(K3bCddbHttpQuery) Found inexact matches" << endl;
emit infoMessage( i18n("Found inexact matches") );
m_state = TQUERY_DATA;
}
else if( getCode( line ) == 202 ) {
kdDebug() << "(K3bCddbHttpQuery) no match found" << endl;
emit infoMessage( i18n("No match found") );
setError(NO_ENTRY_FOUND);
m_state = FINISHED;
emitQueryFinished();
return;
}
else {
kdDebug() << "(K3bCddbHttpQuery) Error while querying: " << line << endl;
emit infoMessage( i18n("Error while querying") );
setError(TQUERY_ERROR);
m_state = FINISHED;
emitQueryFinished();
return;
}
break;
case TQUERY_DATA:
if( line.startsWith( "." ) ) {
// finished query
// go on reading
// here we have the inexact matches headers and should emit the
// inexactMatches signal
emit inexactMatches( this );
}
else {
kdDebug() << "(K3bCddbHttpQuery) inexact match: " << line << endl;
// create a new resultHeader
K3bCddbResultHeader header;
parseMatchHeader( line, header );
m_inexactMatches.append(header);
}
break;
case READ:
if( getCode( line ) == 210 ) {
// we just start parsing the read data
m_state = READ_DATA;
}
else {
emit infoMessage( i18n("Could not read match") );
setError(READ_ERROR);
m_state = FINISHED;
emitQueryFinished();
return;
}
break;
case READ_DATA:
// kdDebug() << "parsing line: " << line << endl;
if( line.startsWith( "." ) ) {
kdDebug() << "(K3bCddbHttpQuery query finished." << endl;
TQTextStream strStream( m_parsingBuffer, IO_ReadOnly );
parseEntry( strStream, result() );
setError(SUCCESS);
m_state = FINISHED;
emitQueryFinished();
return;
}
else {
m_parsingBuffer.append(line + "\n");
}
break;
}
}
}
#include "k3bcddbhttpquery.moc"