/* * Copyright 2005 by Aaron Seigo <aseigo@kde.org> * Copyright 2007 by Riccardo Iaconelli <riccardo@kde.org> * Copyright 2008 by Ménard Alexis <darktears31@gmail.com> * * This program 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, 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 Library General Public * License along with this program; if not, write to the * Free Software Foundation, Inc., * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA. */ #include "dataengineconsumer_p.h" #include <QtCore/QSet> #include <kdebug.h> #include <plasma/dataenginemanager.h> #include <plasma/servicejob.h> namespace Plasma { ServiceMonitor::ServiceMonitor(DataEngineConsumer *consumer) : m_consumer(consumer) { } ServiceMonitor::~ServiceMonitor() { } void ServiceMonitor::slotJobFinished(Plasma::ServiceJob *job) { //kDebug() << "engine ready!"; QString engineName = job->parameters()["EngineName"].toString(); QString location = job->destination(); QPair<QString, QString> pair(location, engineName); //kDebug() << "pair = " << pair; if (!m_consumer->m_remoteEngines.contains(pair)) { kDebug() << "engine does not exist yet!"; } else { KUrl engineLocation(location); engineLocation.setFileName(job->result().toString()); //kDebug() << "setting location : " << engineLocation.prettyUrl(); // m_consumer->m_remoteEngines[pair]->setLocation(engineLocation); } } void ServiceMonitor::slotServiceReady(Plasma::Service *plasmoidService) { //kDebug() << "service ready!"; if (!m_consumer->m_engineNameForService.contains(plasmoidService)) { kDebug() << "no engine name for service!"; kDebug() << "amount of services in map: " << m_consumer->m_engineNameForService.count(); } else { //kDebug() << "value = " << m_consumer->m_engineNameForService.value(plasmoidService); } //kDebug() << "requesting dataengine!"; KConfigGroup op = plasmoidService->operationDescription("DataEngine"); op.writeEntry("EngineName", m_consumer->m_engineNameForService.value(plasmoidService)); plasmoidService->startOperationCall(op); connect(plasmoidService, SIGNAL(finished(Plasma::ServiceJob*)), this, SLOT(slotJobFinished(Plasma::ServiceJob*))); } DataEngineConsumer::DataEngineConsumer() : m_monitor(new ServiceMonitor(this)) { } DataEngineConsumer::~DataEngineConsumer() { foreach (const QString &engine, m_loadedEngines) { DataEngineManager::self()->unloadEngine(engine); } delete m_monitor; } void DataEngineConsumer::finishedWithEngine(const QString &name) { if (m_loadedEngines.contains(name)) { DataEngineManager::self()->unloadEngine(name); } } DataEngine *DataEngineConsumer::dataEngine(const QString &name) { if (m_loadedEngines.contains(name)) { return DataEngineManager::self()->engine(name); } DataEngine *engine = DataEngineManager::self()->loadEngine(name); if (engine->isValid()) { m_loadedEngines.insert(name); } return engine; } DataEngine *DataEngineConsumer::remoteDataEngine(const KUrl &location, const QString &name) { Q_UNUSED(location); Q_UNUSED(name); return 0; } } // namespace Plasma #include "dataengineconsumer_p.moc"