File indexing completed on 2024-05-19 04:50:21

 /****************************************************************************************
  * Copyright (c) 2008 Casey Link <unnamedrambler@gmail.com>                             *
  *                                                                                      *
  * 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.                                                                             *
  *                                                                                      *
  * This program 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 General Public License for more details.             *
  *                                                                                      *
  * You should have received a copy of the GNU General Public License along with         *
  * this program.  If not, see <http://www.gnu.org/licenses/>.                           *
  ****************************************************************************************/
 
 #include "Mp3tunesHarmonyHandler.h"
 #include "mp3tunesharmonyhandleradaptor.h"
 #include "App.h"
 #include "core/support/Debug.h"
 
 #include <QList>
 #include <QVariant>
 
 #include <unistd.h>
 
 
 Mp3tunesHarmonyHandler::Mp3tunesHarmonyHandler( QString identifier,
                                                 QString email,
                                                 QString pin )
     : QObject( qApp )
     , m_daemon( 0 )
     , m_identifier( identifier )
     , m_email( email )
     , m_pin( pin )
 {
     new Mp3tunesHarmonyHandlerAdaptor( this );
     QDBusConnection::sessionBus().registerObject("/Mp3tunesHarmonyHandler", this);
     debug() << "All aboard the DBUS!";
 }
 Mp3tunesHarmonyHandler::~Mp3tunesHarmonyHandler()
 {
     stopDaemon();
     if( m_daemon )
         delete m_daemon;
 }
 
 bool Mp3tunesHarmonyHandler::startDaemon()
 {
     m_daemon = new AmarokProcess( this );
     if( m_email.isEmpty() && m_pin.isEmpty() )
         *m_daemon << "amarokmp3tunesharmonydaemon" << m_identifier;
     else if( !m_email.isEmpty() && !m_pin.isEmpty() )
         *m_daemon << "amarokmp3tunesharmonydaemon" << m_identifier << m_email << m_pin;
     m_daemon->setOutputChannelMode( KProcess::OnlyStdoutChannel );
     connect( m_daemon, QOverload<int>::of( &QProcess::finished ), this, &Mp3tunesHarmonyHandler::slotFinished );
     connect( m_daemon, QOverload<QProcess::ProcessError>::of( &AmarokProcess::error ), this, &Mp3tunesHarmonyHandler::slotError );
     m_daemon->start();
     sleep(3); // sleep for 3 seconds to allow the process to start and register.
     return m_daemon->waitForStarted( -1 );
 }
 
 void Mp3tunesHarmonyHandler::stopDaemon()
 {
     if( daemonRunning() )
         m_daemon->close();
 }
 
 void
 Mp3tunesHarmonyHandler::slotFinished( )
 {
     m_daemon->deleteLater();
     m_daemon = 0;
 }
 
 void
 Mp3tunesHarmonyHandler::slotError( QProcess::ProcessError error )
 {
     if( error == QProcess::Crashed )
     {
         //handleRestart();
     }
 }
 
 bool Mp3tunesHarmonyHandler::daemonRunning()
 {
     if( !m_daemon )
         return false;
     debug() << "Daemon process is running";
     return true;
 }
 
 bool Mp3tunesHarmonyHandler::daemonConnected()
 {
     DEBUG_BLOCK
     if( !daemonRunning() )
         return false;
     QString name = "org.kde.amarok.Mp3tunesHarmonyDaemon-" + QString::number( m_daemon->pid() );
     debug() << "Making Dbus call about daemonConnected to: " << name;
     QDBusMessage m = QDBusMessage::createMethodCall( name,
                                                "/Mp3tunesHarmonyDaemon",
                                                "",
                                                "daemonConnected" );
     QDBusMessage response = QDBusConnection::sessionBus().call( m );
     if( response.type() == QDBusMessage::ErrorMessage )
     {
             debug() << "Got ERROR response daemonConnected";
             debug() << response.errorName() << ":  " << response.errorMessage();
     }
     QList<QVariant> args = response.arguments();
     if( args.count() == 1)
     {
         if( args[0].toString() == "true" ) {
             debug() << "Daemon Connected";
             return true;
         } else if( args[0].toString() == "false" ) {
             debug() << "Daemon Not Connected";
             return false;
         }
     }
     debug() << "Unexpected DBUS return. " << args.count();
     return false;
 }
 
 void Mp3tunesHarmonyHandler::makeConnection()
 {
     DEBUG_BLOCK
     if( !daemonRunning() )
         return;
     QString name = "org.kde.amarok.Mp3tunesHarmonyDaemon-" + QString::number( m_daemon->pid() );
     debug() << "Making Dbus call about makeConnection to: " << name;
     QDBusMessage m = QDBusMessage::createMethodCall( name,
                                                "/Mp3tunesHarmonyDaemon",
                                                "",
                                                "makeConnection" );
     QDBusMessage response = QDBusConnection::sessionBus().call( m );
     if( response.type() == QDBusMessage::ErrorMessage )
     {
             debug() << "Got ERROR response makeConnection";
             debug() << response.errorName() << ":  " << response.errorMessage();
     }
 }
 
 void Mp3tunesHarmonyHandler::breakConnection()
 {
         DEBUG_BLOCK
     if( !daemonRunning() )
         return;
     QString name = "org.kde.amarok.Mp3tunesHarmonyDaemon-" + QString::number( m_daemon->pid() );
     //QString name = "org.kde.amarok.Mp3tunesHarmonyDaemon";
     debug() << "Making Dbus call about breakConnection to: " << name;
     QDBusMessage m = QDBusMessage::createMethodCall( name,
                                                "/Mp3tunesHarmonyDaemon",
                                                "",
                                                "breakConnection" );
     QDBusMessage response = QDBusConnection::sessionBus().call( m );
     if( response.type() == QDBusMessage::ErrorMessage )
     {
             debug() << "Got ERROR response ";
             debug() << response.errorName() << ":  " << response.errorMessage();
     }
 }
 
 QString Mp3tunesHarmonyHandler::pin()
 {
         DEBUG_BLOCK
     if( !daemonRunning() )
         return QString();
     QString name = "org.kde.amarok.Mp3tunesHarmonyDaemon-" + QString::number( m_daemon->pid() );
     //QString name = "org.kde.amarok.Mp3tunesHarmonyDaemon";
     debug() << "Making Dbus call about pin to: " << name;
     QDBusMessage m = QDBusMessage::createMethodCall( name,
                                                "/Mp3tunesHarmonyDaemon",
                                                "",
                                                "pin" );
     QDBusMessage response = QDBusConnection::sessionBus().call( m );
     if( response.type() == QDBusMessage::ErrorMessage )
     {
             debug() << "Got ERROR response pin";
             debug() << response.errorName() << ":  " << response.errorMessage();
     }
     QList<QVariant> args = response.arguments();
     if( args.count() == 1)
     {
         return args[0].toString();
     }
     return QString();
 }
 
 QString Mp3tunesHarmonyHandler::email()
 {
     DEBUG_BLOCK
     if( !daemonRunning() )
         return QString();
     QString name = "org.kde.amarok.Mp3tunesHarmonyDaemon-" + QString::number( m_daemon->pid() );
     //QString name = "org.kde.amarok.Mp3tunesHarmonyDaemon";
     debug() << "Making Dbus call about email to: " << name;
     QDBusMessage m = QDBusMessage::createMethodCall( name,
                                                "/Mp3tunesHarmonyDaemon",
                                                "",
                                                "email" );
     QDBusMessage response = QDBusConnection::sessionBus().call( m );
     if( response.type() == QDBusMessage::ErrorMessage )
     {
             debug() << "Got ERROR response email";
             debug() << response.errorName() << ":  " << response.errorMessage();
     }
     QList<QVariant> args = response.arguments();
     if( args.count() == 1)
     {
         return args[0].toString();
     }
     return QString();
 }
 
 void
 Mp3tunesHarmonyHandler::emitError( const QString &error )
 {
    emit( signalError( error ) );
 }
 
 void
 Mp3tunesHarmonyHandler::emitWaitingForEmail( const QString &pin )
 {
     emit( waitingForEmail( pin ) );
 }
 
 void
 Mp3tunesHarmonyHandler::emitWaitingForPin()
 {
     emit( waitingForPin() );
 }
 
 void
 Mp3tunesHarmonyHandler::emitConnected()
 {
     emit( connected() );
 }
 
 void
 Mp3tunesHarmonyHandler::emitDisconnected()
 {
     emit( disconnected() );
 }
 
 void
 Mp3tunesHarmonyHandler::emitDownloadReady( const QVariantMap &download  )
 {
     emit( downloadReady( download ) );
 }
 
 void
 Mp3tunesHarmonyHandler::emitDownloadPending( const QVariantMap &download  )
 {
     emit( downloadReady( download ) );
 }