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