googledataresource.cpp

   1 #include "googledataresource.h"
   2
   3 #include "settings.h"
   4 #include "settingsadaptor.h"
   5
   6 #include <QtDBus/QDBusConnection>
   7 #include <kabc/addressee.h>
   8 #include <kabc/phonenumber.h>
   9 #include <kabc/key.h>
  10 #include <qstring.h>
  11
  12 extern "C" {
  13 #include <gcalendar.h>
  14 #include <gcontact.h>
  15 #include <gcal_status.h>
  16 }
  17
  18 using namespace Akonadi;
  19
  20 googledataResource::googledataResource( const QString &id )
  21         : ResourceBase( id )
  22 {
  23         new SettingsAdaptor( Settings::self() );
  24         QDBusConnection::sessionBus().registerObject( QLatin1String( "/Settings" ),
  25                                                       Settings::self(), QDBusConnection::ExportAdaptors );
  26
  27
  28         if (!(gcal = gcal_new(GCONTACT)))
  29                 exit(1);
  30         gcal_set_store_xml(gcal, 1);
  31 }
  32
  33 googledataResource::~googledataResource()
  34 {
  35         gcal_delete(gcal);
  36         gcal_cleanup_contacts(&all_contacts);
  37 }
  38
  39 void googledataResource::retrieveCollections()
  40 {
  41         Collection c;
  42         c.setParent(Collection::root());
  43         c.setRemoteId("google-contacts");
  44         c.setName(name());
  45
  46         QStringList mimeTypes;
  47         mimeTypes << "text/directory";
  48         c.setContentMimeTypes(mimeTypes);
  49
  50         Collection::List list;
  51         list << c;
  52         collectionsRetrieved(list);
  53
  54 }
  55
  56 void googledataResource::retrieveItems( const Akonadi::Collection &collection )
  57 {
  58         Q_UNUSED( collection );
  59
  60         Item::List items;
  61         int result;
  62
  63         /* Downloading the contacts can be slow and it is blocking. Will
  64          * it mess up with akonadi?
  65          */
  66         if ((result = gcal_get_contacts(gcal, &all_contacts)))
  67                 exit(1);
  68
  69         /* Each google entry has a unique ID and edit_url */
  70         for (size_t i = 0; i < all_contacts.length; ++i) {
  71
  72                 Item item(QLatin1String("text/directory"));
  73                 gcal_contact_t contact = gcal_contact_element(&all_contacts, i);
  74                 item.setRemoteId(gcal_contact_get_id(contact));
  75
  76                 items << item;
  77         }
  78
  79         itemsRetrieved(items);
  80 }
  81
  82 bool googledataResource::retrieveItem( const Akonadi::Item &item, const QSet<QByteArray> &parts )
  83 {
  84         Q_UNUSED( parts );
  85         const QString entry_id = item.remoteId();
  86         QString temp;
  87         Item newItem(item);
  88         gcal_contact_t contact;
  89         KABC::Addressee addressee;
  90         KABC::PhoneNumber number;
  91         KABC::Key key;
  92
  93         /*
  94          * And another question, are the requests in the same sequence that
  95          * I informed in 'retrieveItems'? For while, I try to locate the entry...
  96          */
  97         for (size_t i = 0; i < all_contacts.length; ++i) {
  98                 contact = gcal_contact_element(&all_contacts, i);
  99                 if (entry_id == gcal_contact_get_id(contact)) {
 100                         /* name */
 101                         temp = gcal_contact_get_title(contact);
 102                         addressee.setNameFromString(temp);
 103
 104                         /* email */
 105                         temp = gcal_contact_get_email(contact);
 106                         addressee.insertEmail(temp, true);
 107
 108                         /* edit url: required to do edit/delete */
 109                         temp = gcal_contact_get_url(contact);
 110                         addressee.setUid(temp);
 111
 112                         /* ETag: required by Google Data protocol 2.0 */
 113                         temp = gcal_contact_get_etag(contact);
 114                         key.setId(temp);
 115                         addressee.insertKey(key);
 116
 117                         /* TODO: telefone, address, etc */
 118
 119                         newItem.setPayload<KABC::Addressee>(addressee);
 120                         return true;
 121                 }
 122
 123         }
 124
 125         return false;
 126 }
 127
 128 void googledataResource::aboutToQuit()
 129 {
 130         // TODO: any cleanup you need to do while there is still an active
 131         // event loop. The resource will terminate after this method returns
 132 }
 133
 134 void googledataResource::configure( WId windowId )
 135 {
 136         Q_UNUSED( windowId );
 137
 138         /* TODO:
 139          * what kind of dialog to collect google acount username + password ?
 140          */
 141         synchronize();
 142 }
 143
 144 void googledataResource::itemAdded( const Akonadi::Item &item, const Akonadi::Collection &collection )
 145 {
 146
 147         KABC::Addressee addressee;
 148         gcal_contact_t contact;
 149         QString temp;
 150         int result;
 151
 152         if (item.hasPayload<KABC::Addressee>())
 153                 addressee = item.payload<KABC::Addressee>();
 154
 155         if (!(contact = gcal_contact_new(NULL)))
 156                 exit(1);
 157
 158         temp = addressee.realName();
 159         gcal_contact_set_title(contact, const_cast<char *>(qPrintable(temp)));
 160
 161         temp = addressee.fullEmail();
 162         gcal_contact_set_email(contact, const_cast<char *>(qPrintable(temp)));
 163
 164         /* TODO: add remaining fields */
 165
 166         if ((result = gcal_add_contact(gcal, contact)))
 167                 exit(1);
 168
 169         gcal_contact_delete(contact);
 170
 171 }
 172
 173 void googledataResource::itemChanged( const Akonadi::Item &item, const QSet<QByteArray> &parts )
 174 {
 175
 176         KABC::Addressee addressee;
 177         gcal_contact_t contact;
 178         KABC::Key key;
 179         QString temp;
 180         int result;
 181
 182         if (item.hasPayload<KABC::Addressee>())
 183                 addressee = item.payload<KABC::Addressee>();
 184
 185         if (!(contact = gcal_contact_new(NULL)))
 186                 exit(1);
 187
 188         temp = addressee.realName();
 189         gcal_contact_set_title(contact, const_cast<char *>(qPrintable(temp)));
 190
 191         temp = addressee.fullEmail();
 192         gcal_contact_set_email(contact, const_cast<char *>(qPrintable(temp)));
 193
 194         temp = addressee.uid();
 195         gcal_contact_set_id(contact, const_cast<char *>(qPrintable(temp)));
 196
 197         /* I suppose that this retrieves the first element in the key list */
 198         key = addressee.keys()[0];
 199         temp = key.id();
 200         gcal_contact_set_etag(contact, const_cast<char *>(qPrintable(temp)));
 201
 202
 203         /* TODO: add remaining fields */
 204
 205         if ((result = gcal_update_contact(gcal, contact)))
 206                 exit(1);
 207
 208
 209         /* Updates the ETag/url: I suppose that akonadi will save this object */
 210         temp = gcal_contact_get_url(contact);
 211         addressee.setUid(temp);
 212
 213         temp = gcal_contact_get_etag(contact);
 214         key.setId(temp);
 215         addressee.insertKey(key);
 216
 217
 218         gcal_contact_delete(contact);
 219
 220 }
 221
 222 void googledataResource::itemRemoved( const Akonadi::Item &item )
 223 {
 224         KABC::Addressee addressee;
 225         gcal_contact_t contact;
 226         KABC::Key key;
 227         QString temp;
 228         int result;
 229
 230         if (item.hasPayload<KABC::Addressee>())
 231                 addressee = item.payload<KABC::Addressee>();
 232
 233         if (!(contact = gcal_contact_new(NULL)))
 234                 exit(1);
 235
 236         temp = addressee.uid();
 237         gcal_contact_set_id(contact, const_cast<char *>(qPrintable(temp)));
 238
 239         /* I suppose that this retrieves the first element in the key list */
 240         key = addressee.keys()[0];
 241         temp = key.id();
 242         gcal_contact_set_etag(contact, const_cast<char *>(qPrintable(temp)));
 243
 244         if ((result = gcal_erase_contact(gcal, contact)))
 245                 exit(1);
 246
 247         gcal_contact_delete(contact);
 248
 249 }
 250
 251 AKONADI_RESOURCE_MAIN( googledataResource )
 252
 253 #include "googledataresource.moc"