googledataresource.cpp

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