src/lastfm.cpp

   1 /***************************************************************************
   2  * copyright            : (C) 2006 Chris Muehlhaeuser <chris@chris.de>     *
   3  *                      : (C) 2006 Seb Ruiz <ruiz@kde.org>                 *
   4  *                      : (C) 2006 Ian Monroe <ian@monroe.nu>              *
   5  *                      : (C) 2006 Mark Kretschmann <markey@web.de>        *
   6  **************************************************************************/
   7
   8 /***************************************************************************
   9  *                                                                         *
  10  *   This program is free software; you can redistribute it and/or modify  *
  11  *   it under the terms of the GNU General Public License as published by  *
  12  *   the Free Software Foundation; either version 2 of the License, or     *
  13  *   (at your option) any later version.                                   *
  14  *                                                                         *
  15  ***************************************************************************/
  16
  17 #define DEBUG_PREFIX "LastFm"
  18
  19 #include "lastfm.h"
  20
  21 #include "amarokconfig.h"   //last.fm username and passwd
  22 #include "amarok.h"         //APP_VERSION, actioncollection
  23 #include "collectiondb.h"
  24 #include "debug.h"
  25 #include "enginecontroller.h"
  26 #include "statusbar.h"      //showError()
  27
  28 #include <q3http.h>
  29 #include <Q3ValueList>
  30 #include <QByteArray>
  31 #include <QDomDocument>
  32 #include <QDomElement>
  33 #include <QDomNode>
  34 #include <QLabel>
  35 #include <QRegExp>
  36
  37 #include <KAction>
  38 #include <KApplication>
  39 #include <KCodecs>       //md5sum
  40 #include <KHBox>
  41 #include <KIO/Job>
  42 #include <KLineEdit>
  43 #include <KMessageBox>
  44 #include <KProtocolManager>
  45 #include <KShortcut>
  46 #include <KUrl>
  47 #include <KVBox>
  48
  49 #include <time.h>
  50 #include <unistd.h>
  51
  52 using namespace LastFm;
  53
  54 ///////////////////////////////////////////////////////////////////////////////
  55 // CLASS AmarokHttp
  56 // AmarokHttp is a hack written so that lastfm code could easily use something proxy aware.
  57 // DO NOT use this class for anything else, use KIO directly instead.
  58 ////////////////////////////////////////////////////////////////////////////////
  59 AmarokHttp::AmarokHttp ( const QString& hostname, quint16 port,
  60                          QObject* parent )
  61     : QObject( parent ),
  62       m_hostname( hostname ),
  63       m_port( port )
  64 {}
  65
  66 int
  67 AmarokHttp::get ( const QString & path )
  68 {
  69     QString uri = QString( "http://%1:%2/%3" )
  70                   .arg( m_hostname )
  71                   .arg( m_port )
  72                   .arg( path );
  73
  74     m_done = false;
  75     m_error = Q3Http::NoError;
  76     m_state = Q3Http::Connecting;
  77     KIO::TransferJob *job = KIO::get(uri, KIO::Reload, KIO::HideProgressInfo);
  78     connect(job,  SIGNAL(data(KIO::Job*, const QByteArray&)),
  79             this, SLOT(slotData(KIO::Job*, const QByteArray&)));
  80     connect(job,  SIGNAL(result(KJob*)),
  81             this, SLOT(slotResult(KJob*)));
  82
  83     return 0;
  84 }
  85
  86 Q3Http::State
  87 AmarokHttp::state() const
  88 {
  89     return m_state;
  90 }
  91
  92 QByteArray
  93 AmarokHttp::readAll ()
  94 {
  95     return m_result;
  96 }
  97
  98 Q3Http::Error
  99 AmarokHttp::error()
 100 {
 101     return m_error;
 102 }
 103
 104 void
 105 AmarokHttp::slotData(KIO::Job*, const QByteArray& data)
 106 {
 107     if( data.size() == 0 ) {
 108         return;
 109     }
 110     else if ( m_result.size() == 0 ) {
 111         m_result = data;
 112     }
 113     else {
 114         m_result.resize( m_result.size() + data.size() );
 115         memcpy( m_result.end(), data.data(),  data.size() );
 116     }
 117 }
 118
 119 void
 120 AmarokHttp::slotResult(KJob* job)
 121 {
 122     bool err = job->error();
 123     if( err || m_error != Q3Http::NoError ) {
 124         m_error = Q3Http::UnknownError;
 125     }
 126     else {
 127         m_error = Q3Http::NoError;
 128     }
 129     m_done = true;
 130     m_state = Q3Http::Unconnected;
 131     emit( requestFinished( 0, err ) );
 132 }
 133
 134
 135
 136 ///////////////////////////////////////////////////////////////////////////////
 137 // CLASS Controller
 138 ////////////////////////////////////////////////////////////////////////////////
 139
 140 Controller *Controller::s_instance = 0;
 141
 142 Controller::Controller()
 143     : QObject( EngineController::instance() )
 144     , m_service( 0 )
 145 {
 146     setObjectName( "lastfmController" );
 147     KActionCollection* ac = Amarok::actionCollection();
 148     KAction *action = new KAction( KIcon( Amarok::icon( "remove" ) ), i18n( "Ban" ), ac );
 149     connect( action, SIGNAL( triggered( bool ) ), this, SLOT( ban() ) );
 150     action->setShortcut( QKeySequence( Qt::CTRL | Qt::Key_B ) );
 151     m_actionList.append( action );
 152
 153     action = new KAction( KIcon( Amarok::icon( "love" ) ), i18n( "Love" ), ac );
 154     connect( action, SIGNAL( triggered( bool ) ), this, SLOT( love() ) );
 155     action->setShortcut( QKeySequence( Qt::CTRL | Qt::Key_L ) );
 156     m_actionList.append( action );
 157
 158     action = new KAction( KIcon( Amarok::icon( "next" ) ), i18n( "Skip" ), ac );
 159     connect( action, SIGNAL( triggered( bool ) ), this, SLOT(  skip() ) );
 160     action->setShortcut( QKeySequence( Qt::CTRL | Qt::Key_K ) );
 161     m_actionList.append( action );
 162     setActionsEnabled( false );
 163 }
 164
 165
 166 Controller*
 167 Controller::instance()
 168 {
 169     if( !s_instance ) s_instance = new Controller();
 170     return s_instance;
 171 }
 172
 173
 174 KUrl
 175 Controller::getNewProxy( QString genreUrl )
 176 {
 177     DEBUG_BLOCK
 178
 179     m_genreUrl = genreUrl;
 180
 181     if ( m_service ) playbackStopped();
 182
 183     m_service = new WebService( this );
 184
 185     if( checkCredentials() )
 186     {
 187         QString user = AmarokConfig::scrobblerUsername();
 188         QString pass = AmarokConfig::scrobblerPassword();
 189
 190         if( !user.isEmpty() && !pass.isEmpty() &&
 191             m_service->handshake( user, pass ) )
 192         {
 193             bool ok = m_service->changeStation( m_genreUrl );
 194             if( ok ) // else playbackStopped()
 195             {
 196                 if( !AmarokConfig::submitPlayedSongs() )
 197                     m_service->enableScrobbling( false );
 198                 setActionsEnabled( true );
 199                 return KUrl( m_service->proxyUrl() );
 200             }
 201         }
 202     }
 203
 204     // Some kind of failure happened, so crap out
 205     playbackStopped();
 206     return KUrl();
 207 }
 208
 209
 210 void
 211 Controller::playbackStopped() //SLOT
 212 {
 213     setActionsEnabled( false );
 214
 215     delete m_service;
 216     m_service = 0;
 217 }
 218
 219
 220 bool
 221 Controller::checkCredentials() //static
 222 {
 223     if( AmarokConfig::scrobblerUsername().isEmpty() || AmarokConfig::scrobblerPassword().isEmpty() )
 224     {
 225         LoginDialog dialog( 0 );
 226         dialog.setCaption( "last.fm" );
 227         return dialog.exec() == QDialog::Accepted;
 228     }
 229     return true;
 230 }
 231
 232
 233 QString
 234 Controller::createCustomStation() //static
 235 {
 236     QString token;
 237     CustomStationDialog dialog( 0 );
 238
 239     if( dialog.exec() == QDialog::Accepted )
 240     {
 241         token = dialog.text();
 242     }
 243
 244     return token;
 245 }
 246
 247
 248 void
 249 Controller::ban()
 250 {
 251     if( m_service )
 252         m_service->ban();
 253 }
 254
 255
 256 void
 257 Controller::love()
 258 {
 259     if( m_service )
 260         m_service->love();
 261 }
 262
 263
 264 void
 265 Controller::skip()
 266 {
 267     if( m_service )
 268         m_service->skip();
 269 }
 270
 271
 272 void
 273 Controller::setActionsEnabled( bool enable )
 274 {   //pausing last.fm streams doesn't do anything good
 275     Amarok::actionCollection()->action( "play_pause" )->setEnabled( !enable );
 276     Amarok::actionCollection()->action( "pause" )->setEnabled( !enable );
 277
 278     KAction* action;
 279     for( action = m_actionList.first(); action; action = m_actionList.next() )
 280         action->setEnabled( enable );
 281 }
 282
 283 /// return a translatable description of the station we are connected to
 284 QString
 285 Controller::stationDescription( QString url )
 286 {
 287     if( url.isEmpty() && instance() && instance()->isPlaying() )
 288         url = instance()->getService()->currentStation();
 289
 290     if( url.isEmpty() ) return QString();
 291
 292     QStringList elements = url.split( '/' );
 293
 294     /// TAG RADIOS
 295     // eg: lastfm://globaltag/rock
 296     if ( elements[1] == "globaltags" )
 297         return i18n( "Global Tag Radio: %1", elements[2] );
 298
 299     /// ARTIST RADIOS
 300     if ( elements[1] == "artist" )
 301     {
 302         // eg: lastfm://artist/Queen/similarartists
 303         if ( elements[3] == "similarartists" )
 304             return i18n( "Similar Artists to %1", elements[2] );
 305
 306         if ( elements[3] == "fans" )
 307             return i18n( "Artist Fan Radio: %1", elements[2] );
 308     }
 309
 310     /// CUSTOM STATION
 311     if ( elements[1] == "artistnames" )
 312     {
 313         // eg: lastfm://artistnames/genesis,pink floyd,queen
 314
 315         // turn "genesis,pink floyd,queen" into "Genesis, Pink Floyd, Queen"
 316         QString artists = elements[2];
 317         artists.replace( ",", ", " );
 318         const QStringList words = QString( artists ).remove( "," ).split( " " );
 319         oldForeach( words ) {
 320             QString capitalized = *it;
 321             capitalized.replace( 0, 1, (*it)[0].toUpper() );
 322             artists.replace( *it, capitalized );
 323         }
 324
 325         return i18n( "Custom Station: %1", artists );
 326     }
 327
 328     /// USER RADIOS
 329     else if ( elements[1] == "user" )
 330     {
 331         // eg: lastfm://user/sebr/neighbours
 332         if ( elements[3] == "neighbours" )
 333             return i18n( "%1's Neighbor Radio", elements[2] );
 334
 335         // eg: lastfm://user/sebr/personal
 336         if ( elements[3] == "personal" )
 337             return i18n( "%1's Personal Radio", elements[2] );
 338
 339         // eg: lastfm://user/sebr/loved
 340         if ( elements[3] == "loved" )
 341             return i18n( "%1's Loved Radio", elements[2] );
 342
 343         // eg: lastfm://user/sebr/recommended/100 : 100 is number for how obscure the music should be
 344         if ( elements[3] == "recommended" )
 345             return i18n( "%1's Recommended Radio", elements[2] );
 346     }
 347
 348     /// GROUP RADIOS
 349     //eg: lastfm://group/Amarok%20users
 350     else if ( elements[1] == "group" )
 351         return i18n( "Group Radio: %1", elements[2] );
 352
 353     /// TRACK RADIOS
 354     else if ( elements[1] == "play" )
 355     {
 356         if ( elements[2] == "tracks" )
 357             return i18n( "Track Radio" );
 358         else if ( elements[2] == "artists" )
 359             return i18n( "Artist Radio" );
 360     }
 361     //kaput!
 362     return url;
 363 }
 364
 365
 366
 367 ////////////////////////////////////////////////////////////////////////////////
 368 // CLASS WebService
 369 ////////////////////////////////////////////////////////////////////////////////
 370
 371 WebService::WebService( QObject* parent )
 372     : QObject( parent )
 373     , m_server( 0 )
 374 {
 375     setObjectName( "lastfmParent" );
 376     debug() << "Initialising Web Service";
 377 }
 378
 379
 380 WebService::~WebService()
 381 {
 382     DEBUG_BLOCK
 383
 384     delete m_server;
 385 }
 386
 387
 388 void
 389 WebService::readProxy() //SLOT
 390 {
 391     QString line;
 392
 393     while( m_server->readln( line ) != -1 ) {
 394         debug() << line;
 395
 396         if( line == "AMAROK_PROXY: SYNC" )
 397             requestMetaData();
 398     }
 399 }
 400
 401
 402 bool
 403 WebService::handshake( const QString& username, const QString& password )
 404 {
 405     DEBUG_BLOCK
 406
 407     m_username = username;
 408     m_password = password;
 409
 410     AmarokHttp http( "ws.audioscrobbler.com", 80 );
 411
 412     const QString path =
 413             QString( "/radio/handshake.php?version=%1&platform=%2&username=%3&passwordmd5=%4&debug=%5" )
 414             .arg( APP_VERSION )             //Muesli-approved: Amarok version, and Amarok-as-platform
 415             .arg( QString("Amarok") )
 416             .arg( QString( Q3Url( username ).encodedPathAndQuery() ) )
 417             .arg( KMD5( m_password.toUtf8() ).hexDigest().data() )
 418             .arg( "0" );
 419
 420     http.get( path );
 421
 422     do
 423         kapp->processEvents();
 424     while( http.state() != Q3Http::Unconnected );
 425
 426     if ( http.error() != Q3Http::NoError )
 427         return false;
 428
 429     const QString result( http.readAll() );
 430
 431     debug() << "result: " << result;
 432
 433     m_session = parameter( "session", result );
 434     m_baseHost = parameter( "base_url", result );
 435     m_basePath = parameter( "base_path", result );
 436     m_subscriber = parameter( "subscriber", result ) == "1";
 437     m_streamUrl = Q3Url( parameter( "stream_url", result ) );
 438 //     bool banned = parameter( "banned", result ) == "1";
 439
 440     if ( m_session.toLower() == "failed" ) {
 441         Amarok::StatusBar::instance()->longMessage( i18n(
 442         "Amarok failed to establish a session with last.fm. <br>"
 443         "Check if your last.fm user and password are correctly set."
 444         ) );
 445         return false;
 446     }
 447
 448     Amarok::config( "Scrobbler" ).writeEntry( "Subscriber", m_subscriber );
 449
 450     // Find free port
 451     MyServerSocket* socket = new MyServerSocket();
 452     const int port = socket->port();
 453     debug() << "Proxy server using port: " << port;
 454     delete socket;
 455
 456     m_proxyUrl = QString( "http://localhost:%1/lastfm.mp3" ).arg( port );
 457
 458     m_server = new Amarok::ProcIO();
 459     m_server->setComm( K3Process::Communication( K3Process::AllOutput ) );
 460     *m_server << "amarok_proxy.rb";
 461     *m_server << "--lastfm";
 462     *m_server << QString::number( port );
 463     *m_server << m_streamUrl.toString();
 464     *m_server << AmarokConfig::soundSystem();
 465     *m_server << Amarok::proxyForUrl( m_streamUrl.toString() );
 466
 467     if( !m_server->start( K3ProcIO::NotifyOnExit, true ) ) {
 468         error() << "Failed to start amarok_proxy.rb";
 469         return false;
 470     }
 471
 472     QString line;
 473     while( true ) {
 474         kapp->processEvents();
 475         m_server->readln( line );
 476         if( line == "AMAROK_PROXY: startup" ) break;
 477     }
 478
 479     connect( m_server, SIGNAL( readReady( K3ProcIO* ) ), this, SLOT( readProxy() ) );
 480     connect( m_server, SIGNAL( processExited( K3Process* ) ), Controller::instance(), SLOT( playbackStopped() ) );
 481
 482     return true;
 483 }
 484
 485
 486 bool
 487 WebService::changeStation( QString url )
 488 {
 489     debug() << "Changing station:" << url;
 490
 491     AmarokHttp http( m_baseHost, 80 );
 492
 493     http.get( QString( m_basePath + "/adjust.php?session=%1&url=%2&debug=0" )
 494              .arg( m_session )
 495              .arg( url ) );
 496
 497     do
 498         kapp->processEvents();
 499     while( http.state() != Q3Http::Unconnected );
 500
 501     if ( http.error() != Q3Http::NoError )
 502     {
 503         showError( E_OTHER ); // default error
 504         return false;
 505     }
 506
 507     const QString result( http.readAll() );
 508     const int errCode = parameter( "error", result ).toInt();
 509
 510     if ( errCode )
 511     {
 512         showError( errCode );
 513         return false;
 514     }
 515
 516     const QString _url = parameter( "url", result );
 517     if ( _url.startsWith( "lastfm://" ) )
 518     {
 519         m_station = _url; // parse it in stationDescription
 520         emit stationChanged( _url, m_station );
 521     }
 522     else
 523         emit stationChanged( _url, QString() );
 524
 525     return true;
 526 }
 527
 528 void
 529 WebService::requestMetaData() //SLOT
 530 {
 531     AmarokHttp *http = new AmarokHttp( m_baseHost, 80, this );
 532     foreach( QObject *observer, m_metaDataObservers )
 533         connect( http, SIGNAL( requestFinished( int, bool ) ), observer, SLOT( metaDataFinished( int, bool ) ) );
 534
 535     http->get( QString( m_basePath + "/np.php?session=%1&debug=%2" )
 536                   .arg( m_session )
 537                   .arg( "0" ) );
 538 }
 539
 540
 541 void
 542 WebService::metaDataFinished( int /*id*/, bool error ) //SLOT
 543 {
 544     DEBUG_BLOCK
 545
 546     AmarokHttp* http = (AmarokHttp*) sender();
 547     http->deleteLater();
 548     if( error ) return;
 549
 550     const QString result( http->readAll() );
 551     debug() << result;
 552
 553     int errCode = parameter( "error", result ).toInt();
 554     if ( errCode > 0 ) {
 555         debug() << "Metadata failed with error code: " << errCode;
 556         showError( errCode );
 557         return;
 558     }
 559
 560     m_metaBundle.setArtist( parameter( "artist", result ) );
 561     m_metaBundle.setAlbum ( parameter( "album", result )  );
 562     m_metaBundle.setTitle ( parameter( "track", result )  );
 563     m_metaBundle.setUrl   ( KUrl( Controller::instance()->getGenreUrl() ) );
 564     m_metaBundle.setLength( parameter( "trackduration", result ).toInt()  );
 565
 566     Bundle lastFmStuff;
 567     QString imageUrl = parameter( "albumcover_medium", result );
 568
 569     if( imageUrl == "http://static.last.fm/coverart/" ||
 570         imageUrl == "http://static.last.fm/depth/catalogue/no_album_large.gif" )
 571         imageUrl.clear();
 572
 573     lastFmStuff.setImageUrl ( CollectionDB::instance()->notAvailCover( true ) );
 574     lastFmStuff.setArtistUrl( parameter( "artist_url", result ) );
 575     lastFmStuff.setAlbumUrl ( parameter( "album_url", result ) );
 576     lastFmStuff.setTitleUrl ( parameter( "track_url", result ) );
 577 //     bool discovery = parameter( "discovery", result ) != "-1";
 578
 579     m_metaBundle.setLastFmBundle( lastFmStuff );
 580
 581     const KUrl u( imageUrl );
 582     if( !u.isValid() ) {
 583         debug() << "imageUrl empty or invalid.";
 584         emit metaDataResult( m_metaBundle );
 585         return;
 586     }
 587
 588     KIO::Job* job = KIO::storedGet( u, KIO::Reload, KIO::HideProgressInfo );
 589     connect( job, SIGNAL( result( KIO::Job* ) ), this, SLOT( fetchImageFinished( KIO::Job* ) ) );
 590 }
 591
 592
 593 void
 594 WebService::fetchImageFinished( KIO::Job* job ) //SLOT
 595 {
 596     DEBUG_BLOCK
 597
 598     if( job->error() == 0 ) {
 599         const QString path = Amarok::saveLocation() + "lastfm_image.png";
 600         const int size = AmarokConfig::coverPreviewSize();
 601
 602         QImage img = QImage::fromData( static_cast<KIO::StoredTransferJob*>( job )->data() );
 603         img.scaled( size, size, Qt::IgnoreAspectRatio, Qt::SmoothTransformation ).save( path, "PNG" );
 604
 605         m_metaBundle.lastFmBundle()->setImageUrl( CollectionDB::makeShadowedImage( path, false ) );
 606     }
 607     emit metaDataResult( m_metaBundle );
 608 }
 609
 610
 611 void
 612 WebService::enableScrobbling( bool enabled ) //SLOT
 613 {
 614     if ( enabled )
 615         debug() << "Enabling Scrobbling!";
 616     else
 617         debug() << "Disabling Scrobbling!";
 618
 619     AmarokHttp *http = new AmarokHttp( m_baseHost, 80, this );
 620     connect( http, SIGNAL( requestFinished( int, bool ) ), this, SLOT( enableScrobblingFinished( int, bool ) ) );
 621
 622     http->get( QString( m_basePath + "/control.php?session=%1&command=%2&debug=%3" )
 623                   .arg( m_session )
 624                   .arg( enabled ? QString( "rtp" ) : QString( "nortp" ) )
 625                   .arg( "0" ) );
 626 }
 627
 628
 629 void
 630 WebService::enableScrobblingFinished( int /*id*/, bool error ) //SLOT
 631 {
 632     AmarokHttp* http = (AmarokHttp*) sender();
 633     http->deleteLater();
 634     if ( error ) return;
 635
 636     emit enableScrobblingDone();
 637 }
 638
 639
 640 void
 641 WebService::love() //SLOT
 642 {
 643     AmarokHttp *http = new AmarokHttp( m_baseHost, 80, this );
 644     connect( http, SIGNAL( requestFinished( int, bool ) ), this, SLOT( loveFinished( int, bool ) ) );
 645
 646     http->get( QString( m_basePath + "/control.php?session=%1&command=love&debug=%2" )
 647                   .arg( m_session )
 648                   .arg( "0" ) );
 649     Amarok::StatusBar::instance()->shortMessage( i18nc("love, as in affection", "Loving song...") );
 650 }
 651
 652
 653 void
 654 WebService::skip() //SLOT
 655 {
 656     AmarokHttp *http = new AmarokHttp( m_baseHost, 80, this );
 657     connect( http, SIGNAL( requestFinished( int, bool ) ), this, SLOT( skipFinished( int, bool ) ) );
 658
 659     http->get( QString( m_basePath + "/control.php?session=%1&command=skip&debug=%2" )
 660                   .arg( m_session )
 661                   .arg( "0" ) );
 662     Amarok::StatusBar::instance()->shortMessage( i18n("Skipping song...") );
 663 }
 664
 665
 666 void
 667 WebService::ban() //SLOT
 668 {
 669     AmarokHttp *http = new AmarokHttp( m_baseHost, 80, this );
 670     connect( http, SIGNAL( requestFinished( int, bool ) ), this, SLOT( banFinished( int, bool ) ) );
 671
 672     http->get( QString( m_basePath + "/control.php?session=%1&command=ban&debug=%2" )
 673                   .arg( m_session )
 674                   .arg( "0" ) );
 675     Amarok::StatusBar::instance()->shortMessage( i18nc("Ban, as in dislike", "Banning song...") );
 676 }
 677
 678
 679 void
 680 WebService::loveFinished( int /*id*/, bool error ) //SLOT
 681 {
 682     DEBUG_BLOCK
 683
 684     AmarokHttp* http = (AmarokHttp*) sender();
 685     http->deleteLater();
 686     if( error ) return;
 687
 688     emit loveDone();
 689 }
 690
 691
 692 void
 693 WebService::skipFinished( int /*id*/, bool error ) //SLOT
 694 {
 695     DEBUG_BLOCK
 696
 697     AmarokHttp* http = (AmarokHttp*) sender();
 698     http->deleteLater();
 699     if( error ) return;
 700
 701     EngineController::engine()->flushBuffer();
 702     emit skipDone();
 703 }
 704
 705
 706 void
 707 WebService::banFinished( int /*id*/, bool error ) //SLOT
 708 {
 709     DEBUG_BLOCK
 710
 711     AmarokHttp* http = (AmarokHttp*) sender();
 712     http->deleteLater();
 713     if( error ) return;
 714
 715     EngineController::engine()->flushBuffer();
 716     emit banDone();
 717     emit skipDone();
 718 }
 719
 720
 721 void
 722 WebService::friends( QString username )
 723 {
 724     if ( username.isEmpty() )
 725         username = m_username;
 726
 727     AmarokHttp *http = new AmarokHttp( m_baseHost, 80, this );
 728     connect( http, SIGNAL( requestFinished( bool ) ), this, SLOT( friendsFinished( bool ) ) );
 729
 730     http->get( QString( "/1.0/user/%1/friends.xml" )
 731                   .arg( QString( Q3Url( username ).encodedPathAndQuery() ) ) );
 732 }
 733
 734
 735 void
 736 WebService::friendsFinished( int /*id*/, bool error ) //SLOT
 737 {
 738     AmarokHttp* http = (AmarokHttp*) sender();
 739     http->deleteLater();
 740     if( error ) return;
 741
 742     QDomDocument document;
 743     document.setContent( http->readAll() );
 744
 745     if ( document.elementsByTagName( "friends" ).length() == 0 )
 746     {
 747         emit friendsResult( QString( "" ), QStringList() );
 748         return;
 749     }
 750
 751     QStringList friends;
 752     QString user = document.elementsByTagName( "friends" ).item( 0 ).attributes().namedItem( "user" ).nodeValue();
 753     QDomNodeList values = document.elementsByTagName( "user" );
 754     for ( int i = 0; i < values.count(); i++ )
 755     {
 756         friends << values.item( i ).attributes().namedItem( "username" ).nodeValue();
 757     }
 758
 759     emit friendsResult( user, friends );
 760 }
 761
 762
 763 void
 764 WebService::neighbours( QString username )
 765 {
 766     if ( username.isEmpty() )
 767         username = m_username;
 768
 769     AmarokHttp *http = new AmarokHttp( m_baseHost, 80, this );
 770     connect( http, SIGNAL( requestFinished( bool ) ), this, SLOT( neighboursFinished( bool ) ) );
 771
 772     http->get( QString( "/1.0/user/%1/neighbours.xml" )
 773                   .arg( QString( Q3Url( username ).encodedPathAndQuery() ) ) );
 774 }
 775
 776
 777 void
 778 WebService::neighboursFinished( int /*id*/, bool error ) //SLOT
 779 {
 780     AmarokHttp* http = (AmarokHttp*) sender();
 781     http->deleteLater();
 782     if( error )  return;
 783
 784     QDomDocument document;
 785     document.setContent( http->readAll() );
 786
 787     if ( document.elementsByTagName( "neighbours" ).length() == 0 )
 788     {
 789         emit friendsResult( QString( "" ), QStringList() );
 790         return;
 791     }
 792
 793     QStringList neighbours;
 794     QString user = document.elementsByTagName( "neighbours" ).item( 0 ).attributes().namedItem( "user" ).nodeValue();
 795     QDomNodeList values = document.elementsByTagName( "user" );
 796     for ( int i = 0; i < values.count(); i++ )
 797     {
 798         neighbours << values.item( i ).attributes().namedItem( "username" ).nodeValue();
 799     }
 800
 801     emit neighboursResult( user, neighbours );
 802 }
 803
 804
 805 void
 806 WebService::userTags( QString username )
 807 {
 808     if ( username.isEmpty() )
 809         username = m_username;
 810
 811     AmarokHttp *http = new AmarokHttp( m_baseHost, 80, this );
 812     connect( http, SIGNAL( requestFinished( bool ) ), this, SLOT( userTagsFinished( bool ) ) );
 813
 814     http->get( QString( "/1.0/user/%1/tags.xml?debug=%2" )
 815                   .arg( QString( Q3Url( username ).encodedPathAndQuery() ) ) );
 816 }
 817
 818
 819 void
 820 WebService::userTagsFinished( int /*id*/, bool error ) //SLOT
 821 {
 822     AmarokHttp* http = (AmarokHttp*) sender();
 823     http->deleteLater();
 824     if( error ) return;
 825
 826     QDomDocument document;
 827     document.setContent( http->readAll() );
 828
 829     if ( document.elementsByTagName( "toptags" ).length() == 0 )
 830     {
 831         emit userTagsResult( QString(), QStringList() );
 832         return;
 833     }
 834
 835     QStringList tags;
 836     QDomNodeList values = document.elementsByTagName( "tag" );
 837     QString user = document.elementsByTagName( "toptags" ).item( 0 ).attributes().namedItem( "user" ).nodeValue();
 838     for ( int i = 0; i < values.count(); i++ )
 839     {
 840         QDomNode item = values.item( i ).namedItem( "name" );
 841         tags << item.toElement().text();
 842     }
 843     emit userTagsResult( user, tags );
 844 }
 845
 846
 847 void
 848 WebService::recentTracks( QString username )
 849 {
 850     if ( username.isEmpty() )
 851         username = m_username;
 852
 853     AmarokHttp *http = new AmarokHttp( m_baseHost, 80, this );
 854     connect( http, SIGNAL( requestFinished( bool ) ), this, SLOT( recentTracksFinished( bool ) ) );
 855
 856     http->get( QString( "/1.0/user/%1/recenttracks.xml" )
 857                   .arg( QString( Q3Url( username ).encodedPathAndQuery() ) ) );
 858 }
 859
 860
 861 void
 862 WebService::recentTracksFinished( int /*id*/, bool error ) //SLOT
 863 {
 864     AmarokHttp* http = (AmarokHttp*) sender();
 865     http->deleteLater();
 866     if( error ) return;
 867
 868     Q3ValueList< QPair<QString, QString> > songs;
 869     QDomDocument document;
 870     document.setContent( http->readAll() );
 871
 872     if ( document.elementsByTagName( "recenttracks" ).length() == 0 )
 873     {
 874         emit recentTracksResult( QString(), songs );
 875         return;
 876     }
 877
 878     QDomNodeList values = document.elementsByTagName( "track" );
 879     QString user = document.elementsByTagName( "recenttracks" ).item( 0 ).attributes().namedItem( "user" ).nodeValue();
 880     for ( int i = 0; i < values.count(); i++ )
 881     {
 882         QPair<QString, QString> song;
 883         song.first = values.item( i ).namedItem( "artist" ).toElement().text();
 884         song.second = values.item( i ).namedItem( "name" ).toElement().text();
 885
 886         songs << song;
 887     }
 888     emit recentTracksResult( user, songs );
 889 }
 890
 891
 892 void
 893 WebService::recommend( int type, QString username, QString artist, QString token )
 894 {
 895     QString modeToken = "";
 896     switch ( type )
 897     {
 898         case 0:
 899             modeToken = QString( "artist_name=%1" ).arg( QString( Q3Url( artist ).encodedPathAndQuery() ) );
 900             break;
 901
 902         case 1:
 903             modeToken = QString( "album_artist=%1&album_name=%2" )
 904                            .arg( QString( Q3Url( artist ).encodedPathAndQuery() ) )
 905                            .arg( QString( Q3Url( token ).encodedPathAndQuery() ) );
 906             break;
 907
 908         case 2:
 909             modeToken = QString( "track_artist=%1&track_name=%2" )
 910                            .arg( QString( Q3Url( artist ).encodedPathAndQuery() ) )
 911                            .arg( QString( Q3Url( token ).encodedPathAndQuery() ) );
 912             break;
 913     }
 914
 915     Q3Http *http = new Q3Http( "wsdev.audioscrobbler.com", 80, this );
 916     connect( http, SIGNAL( requestFinished( bool ) ), this, SLOT( recommendFinished( bool ) ) );
 917
 918     uint currentTime = QDateTime::currentDateTime().toUTC().toTime_t();
 919     QString challenge = QString::number( currentTime );
 920
 921     QByteArray md5pass = KMD5( KMD5( m_password.toUtf8() ).hexDigest().append( QString::number( currentTime ).toLocal8Bit() ) ).hexDigest();
 922
 923     QString atoken = QString( "user=%1&auth=%2&nonce=%3recipient=%4" )
 924                        .arg( QString( Q3Url( currentUsername() ).encodedPathAndQuery() ) )
 925                        .arg( QString( Q3Url( md5pass ).encodedPathAndQuery() ) )
 926                        .arg( QString( Q3Url( challenge ).encodedPathAndQuery() ) )
 927                        .arg( QString( Q3Url( username ).encodedPathAndQuery() ) );
 928
 929     Q3HttpRequestHeader header( "POST", "/1.0/rw/recommend.php?" + atoken.toUtf8() );
 930     header.setValue( "Host", "wsdev.audioscrobbler.com" );
 931     header.setContentType( "application/x-www-form-urlencoded" );
 932     http->request( header, modeToken.toUtf8() );
 933 }
 934
 935
 936 void
 937 WebService::recommendFinished( int /*id*/, bool /*error*/ ) //SLOT
 938 {
 939     AmarokHttp* http = (AmarokHttp*) sender();
 940     http->deleteLater();
 941
 942     debug() << "Recommendation:" << http->readAll();
 943 }
 944
 945
 946 QString
 947 WebService::parameter( const QString keyName, const QString data ) const
 948 {
 949     QStringList list = data.split( '\n' );
 950
 951     for ( int i = 0; i < list.size(); i++ )
 952     {
 953         QStringList values = list[i].split( '=' );
 954         if ( values[0] == keyName )
 955         {
 956             values.removeAt( 0 );
 957             return QString::fromUtf8( values.join( "=" ).toAscii() );
 958         }
 959     }
 960
 961     return QString( "" );
 962 }
 963
 964
 965 QStringList
 966 WebService::parameterArray( const QString keyName, const QString data ) const
 967 {
 968     QStringList result;
 969     QStringList list = data.split( '\n' );
 970
 971     for ( int i = 0; i < list.size(); i++ )
 972     {
 973         QStringList values = list[i].split( '=' );
 974         if ( values[0].startsWith( keyName ) )
 975         {
 976             values.removeAt( 0 );
 977             result.append( QString::fromUtf8( values.join( "=" ).toAscii() ) );
 978         }
 979     }
 980
 981     return result;
 982 }
 983
 984
 985 QStringList
 986 WebService::parameterKeys( const QString keyName, const QString data ) const
 987 {
 988     QStringList result;
 989     QStringList list = data.split( '\n' );
 990
 991     for ( int i = 0; i < list.size(); i++ )
 992     {
 993         QStringList values = list[i].split( '=' );
 994         if ( values[0].startsWith( keyName ) )
 995         {
 996             values = values[0].split( '[' );
 997             values = values[1].split( ']' );
 998             result.append( values[0] );
 999         }
1000     }
1001
1002
1003     return result;
1004 }
1005
1006 void
1007 WebService::showError( int code, QString message )
1008 {
1009     switch ( code )
1010     {
1011         case E_NOCONTENT:
1012             message = i18n( "There is not enough content to play this station." );
1013             break;
1014         case E_NOMEMBERS:
1015             message = i18n( "This group does not have enough members for radio." );
1016             break;
1017         case E_NOFANS:
1018             message = i18n( "This artist does not have enough fans for radio." );
1019             break;
1020         case E_NOAVAIL:
1021             message = i18n( "This item is not available for streaming." );
1022             break;
1023         case E_NOSUBSCRIBER:
1024             message = i18n( "This feature is only available to last.fm subscribers." );
1025             break;
1026         case E_NONEIGHBOURS:
1027             message = i18n( "There are not enough neighbors for this radio." );
1028             break;
1029         case E_NOSTOPPED:
1030             message = i18n( "This stream has stopped. Please try another station." );
1031             break;
1032         default:
1033             if( message.isEmpty() )
1034                 message = i18n( "Failed to play this last.fm stream." );
1035     }
1036
1037     Amarok::StatusBar::instance()->longMessage( message, KDE::StatusBar::Sorry );
1038 }
1039
1040 ////////////////////////////////////////////////////////////////////////////////
1041 // CLASS LastFm::Bundle
1042 ////////////////////////////////////////////////////////////////////////////////
1043
1044 Bundle::Bundle( const Bundle& lhs )
1045     : m_imageUrl( lhs.m_imageUrl )
1046     , m_albumUrl( lhs.m_albumUrl )
1047     , m_artistUrl( lhs.m_artistUrl )
1048     , m_titleUrl( lhs.m_titleUrl )
1049 {}
1050
1051 ////////////////////////////////////////////////////////////////////////////////
1052 // CLASS LastFm::LoginDialog
1053 ////////////////////////////////////////////////////////////////////////////////
1054 LoginDialog::LoginDialog( QWidget *parent )
1055     : KDialog( parent )
1056 {
1057     setModal( true );
1058     setButtons( Ok | Cancel );
1059
1060     //makeGridMainWidget( 1, Qt::Horizontal );
1061     KVBox* vbox = new KVBox( this );
1062     setMainWidget( vbox );
1063     new QLabel( i18n( "To use last.fm with Amarok, you need a last.fm profile." ), vbox );
1064
1065     //makeGridMainWidget( 2, Qt::Horizontal );
1066     KHBox* hbox = new KHBox( vbox );
1067     QLabel *nameLabel = new QLabel( i18n("&Username:"), hbox );
1068     m_userLineEdit = new KLineEdit( hbox );
1069     nameLabel->setBuddy( m_userLineEdit );
1070
1071     QLabel *passLabel = new QLabel( i18n("&Password:"), hbox );
1072     m_passLineEdit = new KLineEdit( hbox );
1073     m_passLineEdit->setEchoMode( QLineEdit::Password );
1074     passLabel->setBuddy( m_passLineEdit );
1075
1076     m_userLineEdit->setFocus();
1077 }
1078
1079
1080 void LoginDialog::slotButtonClicked( ButtonCode button )
1081 {
1082     if ( button == Ok ) {
1083         AmarokConfig::setScrobblerUsername( m_userLineEdit->text() );
1084         AmarokConfig::setScrobblerPassword( m_passLineEdit->text() );
1085     }
1086
1087     KDialog::slotButtonClicked( button );
1088 }
1089
1090
1091 ////////////////////////////////////////////////////////////////////////////////
1092 // CLASS LastFm::CustomStationDialog
1093 ////////////////////////////////////////////////////////////////////////////////
1094 CustomStationDialog::CustomStationDialog( QWidget *parent )
1095     : KDialog( parent )
1096 {
1097     setCaption( i18n( "Create Custom Station" ) );
1098     setModal( true );
1099     setButtons( Ok | Cancel );
1100
1101
1102     KVBox *vbox = new KVBox( this );
1103     setMainWidget( vbox );
1104
1105
1106     new QLabel( i18n( "Enter the name of a band or artist you like:" ), mainWidget() );
1107
1108     m_edit = new KLineEdit( mainWidget() );
1109     m_edit->setFocus();
1110 }
1111
1112
1113 QString
1114 CustomStationDialog::text() const
1115 {
1116     return m_edit->text();
1117 }
1118
1119
1120 #include "lastfm.moc"