127 lines
3.9 KiB
C++
127 lines
3.9 KiB
C++
/*
|
|
* Copyright © 2009 Rob Scheepmaker <r.scheepmaker@student.utwente.nl>
|
|
*
|
|
* This program is free software; you can redistribute it and/or modify
|
|
* it under the terms of the GNU Library General Public License version 2 as
|
|
* published by the Free Software Foundation
|
|
*
|
|
* 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 "remoteservicejob_p.h"
|
|
|
|
#include <KUrl>
|
|
|
|
#include <QtCore/QBuffer>
|
|
#include <QtJolie/Client>
|
|
#include <QtJolie/Message>
|
|
#include <QtJolie/PendingCallWatcher>
|
|
#include <QtJolie/PendingReply>
|
|
|
|
#include "../servicejob.h"
|
|
#include "../accessmanager.h"
|
|
#include "../authorizationmanager.h"
|
|
#include "authorizationmanager_p.h"
|
|
#include "remoteservice_p.h"
|
|
#include "joliemessagehelper_p.h"
|
|
#include <qtimer.h>
|
|
|
|
namespace Plasma
|
|
{
|
|
|
|
RemoteServiceJob::RemoteServiceJob(KUrl location,
|
|
const QString& destination,
|
|
const QString& operation,
|
|
QMap<QString,QVariant>& parameters,
|
|
QByteArray initialToken,
|
|
RemoteService* parent)
|
|
: ServiceJob(destination, operation, parameters, parent),
|
|
m_token(initialToken),
|
|
m_location(location),
|
|
m_service(parent)
|
|
{
|
|
}
|
|
|
|
void RemoteServiceJob::start()
|
|
{
|
|
QTimer::singleShot(30000, this, SLOT(timeout()));
|
|
|
|
Jolie::Client *client = m_service->m_client;
|
|
|
|
if (m_service->m_busy) {
|
|
//enqueue and wait
|
|
m_service->m_queue.enqueue(this);
|
|
kDebug() << "already busy... enqueue, queue contains " << m_service->m_queue.count();
|
|
return;
|
|
} else {
|
|
m_service->m_busy = true;
|
|
}
|
|
|
|
//serialize the parameters
|
|
QByteArray params;
|
|
QBuffer buffer(¶ms);
|
|
buffer.open(QIODevice::WriteOnly);
|
|
QDataStream out(&buffer);
|
|
out << parameters();
|
|
|
|
Jolie::Message message(m_location.path(KUrl::RemoveTrailingSlash).remove(0, 1).toUtf8(),
|
|
"startOperationCall");
|
|
Jolie::Value data;
|
|
data.children(Message::Field::OPERATION) << (Jolie::Value(operationName().toAscii()));
|
|
data.children(Message::Field::PARAMETERS) << Jolie::Value(params);
|
|
data.children(Message::Field::DESTINATION) << Jolie::Value(destination().toAscii());
|
|
message.setData(data);
|
|
|
|
Jolie::PendingCall pendingReply = client->asyncCall(m_service->signMessage(message));
|
|
Jolie::PendingCallWatcher *watcher = new Jolie::PendingCallWatcher(pendingReply, this);
|
|
connect(watcher, SIGNAL(finished(Jolie::PendingCallWatcher*)),
|
|
this, SLOT(callCompleted(Jolie::PendingCallWatcher*)));
|
|
}
|
|
|
|
void RemoteServiceJob::callCompleted(Jolie::PendingCallWatcher *watcher)
|
|
{
|
|
m_service->m_busy = false;
|
|
|
|
Jolie::PendingReply reply = *watcher;
|
|
Jolie::Message response = reply.reply();
|
|
|
|
//TODO:async
|
|
if (response.fault().isValid()) {
|
|
kDebug() << "fault: " << response.fault().name();
|
|
setError(-1);
|
|
setErrorText(Message::errorMessage(response.fault().name()));
|
|
emitResult();
|
|
return;
|
|
}
|
|
|
|
m_service->m_token = Message::field(Message::Field::TOKEN, response);
|
|
|
|
QVariant variantResult;
|
|
QByteArray byteArrayResult = Message::field(Message::Field::RESULT, response);
|
|
QBuffer buffer(&byteArrayResult);
|
|
buffer.open(QIODevice::ReadOnly);
|
|
QDataStream in(&buffer);
|
|
in >> variantResult;
|
|
|
|
setResult(variantResult);
|
|
}
|
|
|
|
void RemoteServiceJob::timeout()
|
|
{
|
|
m_service->m_busy = false;
|
|
kDebug() << "Service job timed out.";
|
|
setError(-1);
|
|
setErrorText(i18n("Timeout."));
|
|
emitResult();
|
|
}
|
|
|
|
} // namespace Plasma
|