summaryrefslogtreecommitdiffstats
path: root/libkcddb/asynchttplookup.cpp
diff options
context:
space:
mode:
authortoma <toma@283d02a7-25f6-0310-bc7c-ecb5cbfe19da>2009-11-25 17:56:58 +0000
committertoma <toma@283d02a7-25f6-0310-bc7c-ecb5cbfe19da>2009-11-25 17:56:58 +0000
commite2de64d6f1beb9e492daf5b886e19933c1fa41dd (patch)
tree9047cf9e6b5c43878d5bf82660adae77ceee097a /libkcddb/asynchttplookup.cpp
downloadtdemultimedia-e2de64d6f1beb9e492daf5b886e19933c1fa41dd.tar.gz
tdemultimedia-e2de64d6f1beb9e492daf5b886e19933c1fa41dd.zip
Copy the KDE 3.5 branch to branches/trinity for new KDE 3.5 features.
BUG:215923 git-svn-id: svn://anonsvn.kde.org/home/kde/branches/trinity/kdemultimedia@1054174 283d02a7-25f6-0310-bc7c-ecb5cbfe19da
Diffstat (limited to 'libkcddb/asynchttplookup.cpp')
-rw-r--r--libkcddb/asynchttplookup.cpp159
1 files changed, 159 insertions, 0 deletions
diff --git a/libkcddb/asynchttplookup.cpp b/libkcddb/asynchttplookup.cpp
new file mode 100644
index 00000000..a183b3d5
--- /dev/null
+++ b/libkcddb/asynchttplookup.cpp
@@ -0,0 +1,159 @@
+/*
+ Copyright (C) 2002 Rik Hemsley (rikkus) <rik@kde.org>
+ Copyright (C) 2002 Benjamin Meyer <ben-devel@meyerhome.net>
+
+ This library is free software; you can redistribute it and/or
+ modify it under the terms of the GNU Library General Public
+ License as published by the Free Software Foundation; either
+ version 2 of the License, or (at your option) any later version.
+
+ This library is distributed in the hope that it will be useful,
+ but WITHOUT ANY WARRANTY; without even the implied warranty of
+ MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ Library General Public License for more details.
+
+ You should have received a copy of the GNU Library General Public License
+ along with this library; see the file COPYING.LIB. If not, write to
+ the Free Software Foundation, Inc., 59 Temple Place - Suite 330,
+ Boston, MA 02111-1307, USA.
+*/
+
+#include <qstringlist.h>
+#include <qapplication.h>
+
+#include <kdebug.h>
+#include <kio/job.h>
+
+#include "asynchttplookup.h"
+
+namespace KCDDB
+{
+ AsyncHTTPLookup::AsyncHTTPLookup()
+ : HTTPLookup()
+ {
+ block_ = false;
+ }
+
+ AsyncHTTPLookup::~AsyncHTTPLookup()
+ {
+ // Empty.
+ }
+
+ CDDB::Result
+ AsyncHTTPLookup::lookup
+ (
+ const QString & hostName,
+ uint port,
+ const TrackOffsetList & trackOffsetList
+ )
+ {
+ if ( trackOffsetList.count() < 3 )
+ return UnknownError;
+
+ trackOffsetList_ = trackOffsetList;
+
+ connect( this, SIGNAL( queryReady() ), SLOT( slotQueryReady() ) );
+ connect( this, SIGNAL( readReady() ), SLOT( requestCDInfoForMatch() ) );
+
+ initURL( hostName, port );
+
+ // Run a query.
+ result_ = runQuery();
+
+ return result_;
+ }
+
+ CDDB::Result
+ AsyncHTTPLookup::runQuery()
+ {
+ data_ = QByteArray();
+ state_ = WaitingForQueryResponse;
+
+ result_ = sendQuery();
+
+ return result_;
+ }
+
+ void
+ AsyncHTTPLookup::slotQueryReady()
+ {
+ kdDebug(60010) << "Matches Found: " << matchList_.count() << endl;
+
+ if ( Success != result_ )
+ {
+ emit finished( result_ );
+ return;
+ }
+
+ requestCDInfoForMatch();
+ }
+
+ void
+ AsyncHTTPLookup::requestCDInfoForMatch()
+ {
+ if ( matchList_.isEmpty() )
+ {
+ result_ = cdInfoList_.isEmpty()? NoRecordFound : Success;
+ emit finished( result_ );
+ return;
+ }
+
+ CDDBMatch match = matchList_.first();
+ matchList_.remove( match );
+
+ data_ = QByteArray();
+ state_ = WaitingForReadResponse;
+
+ result_ = sendRead( match );
+
+ if ( Success != result_ )
+ emit finished( result_ );
+ }
+
+ void
+ AsyncHTTPLookup::slotData( KIO::Job *, const QByteArray &data )
+ {
+ if (data.size() > 0)
+ {
+ QDataStream stream(data_, IO_WriteOnly | IO_Append);
+ stream.writeRawBytes(data.data(), data.size());
+ }
+ }
+
+ void
+ AsyncHTTPLookup::slotResult( KIO::Job *job )
+ {
+ if ( 0 != job->error() )
+ {
+ result_ = ServerError;
+ if ( !block_ )
+ emit queryReady();
+ return;
+ }
+
+ jobFinished();
+ }
+
+ CDDB::Result
+ AsyncHTTPLookup::fetchURL()
+ {
+ kdDebug(60010) << "About to fetch: " << cgiURL_.url() << endl;
+
+ KIO::TransferJob* job = KIO::get( cgiURL_, false, false );
+
+ if ( 0 == job )
+ return ServerError;
+
+ connect( job, SIGNAL( data( KIO::Job *, const QByteArray & ) ),
+ SLOT( slotData( KIO::Job *, const QByteArray & ) ) );
+ connect( job, SIGNAL( result( KIO::Job * ) ),
+ SLOT( slotResult( KIO::Job * ) ) );
+
+ return Success;
+ }
+
+}
+
+#include "asynchttplookup.moc"
+
+// vim:tabstop=2:shiftwidth=2:expandtab:cinoptions=(s,U1,m1