1/*
2 Copyright (c) 2009 Constantin Berzan <exit3219@gmail.com>
3
4 This library is free software; you can redistribute it and/or modify it
5 under the terms of the GNU Library General Public License as published by
6 the Free Software Foundation; either version 2 of the License, or (at your
7 option) any later version.
8
9 This library is distributed in the hope that it will be useful, but WITHOUT
10 ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
11 FITNESS FOR A PARTICULAR PURPOSE. See the GNU Library General Public
12 License for more details.
13
14 You should have received a copy of the GNU Library General Public License
15 along with this library; see the file COPYING.LIB. If not, write to the
16 Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
17 02110-1301, USA.
18*/
19
20#include "transportresourcebase.h"
21#include "transportresourcebase_p.h"
22
23#include "dbusconnectionpool.h"
24#include "transportadaptor.h"
25
26#include <akonadi/itemfetchjob.h>
27#include <akonadi/itemfetchscope.h>
28
29#include <QtDBus/QDBusConnection>
30
31using namespace Akonadi;
32
33TransportResourceBasePrivate::TransportResourceBasePrivate(TransportResourceBase *qq)
34 : QObject()
35 , q(qq)
36{
37 new Akonadi__TransportAdaptor(this);
38 DBusConnectionPool::threadConnection().registerObject(QLatin1String("/Transport"),
39 this, QDBusConnection::ExportAdaptors);
40}
41
42void TransportResourceBasePrivate::send(Item::Id id)
43{
44 ItemFetchJob *job = new ItemFetchJob(Item(id));
45 job->fetchScope().fetchFullPayload();
46 job->setProperty("id", QVariant(id));
47 connect(job, SIGNAL(result(KJob*)), SLOT(fetchResult(KJob*)));
48}
49
50void TransportResourceBasePrivate::fetchResult(KJob *job)
51{
52 if (job->error()) {
53 const Item::Id id = job->property("id").toLongLong();
54 emit transportResult(id, (int)TransportResourceBase::TransportFailed, job->errorText());
55 return;
56 }
57
58 ItemFetchJob *fetchJob = qobject_cast<ItemFetchJob *>(job);
59 Q_ASSERT(fetchJob);
60
61 const Item item = fetchJob->items().first();
62 q->sendItem(item);
63}
64
65TransportResourceBase::TransportResourceBase()
66 : d(new TransportResourceBasePrivate(this))
67{
68}
69
70TransportResourceBase::~TransportResourceBase()
71{
72 delete d;
73}
74
75void TransportResourceBase::itemSent(const Item &item,
76 TransportResult result,
77 const QString &message)
78{
79 emit d->transportResult(item.id(), (int)result, message);
80}
81
82#include "moc_transportresourcebase_p.cpp"
83