summaryrefslogtreecommitdiffstats
path: root/libkpimexchange/core/exchangeupload.cpp
diff options
context:
space:
mode:
authortoma <toma@283d02a7-25f6-0310-bc7c-ecb5cbfe19da>2009-11-25 17:56:58 +0000
committertoma <toma@283d02a7-25f6-0310-bc7c-ecb5cbfe19da>2009-11-25 17:56:58 +0000
commit460c52653ab0dcca6f19a4f492ed2c5e4e963ab0 (patch)
tree67208f7c145782a7e90b123b982ca78d88cc2c87 /libkpimexchange/core/exchangeupload.cpp
downloadtdepim-460c52653ab0dcca6f19a4f492ed2c5e4e963ab0.tar.gz
tdepim-460c52653ab0dcca6f19a4f492ed2c5e4e963ab0.zip
Copy the KDE 3.5 branch to branches/trinity for new KDE 3.5 features.
BUG:215923 git-svn-id: svn://anonsvn.kde.org/home/kde/branches/trinity/kdepim@1054174 283d02a7-25f6-0310-bc7c-ecb5cbfe19da
Diffstat (limited to 'libkpimexchange/core/exchangeupload.cpp')
-rw-r--r--libkpimexchange/core/exchangeupload.cpp371
1 files changed, 371 insertions, 0 deletions
diff --git a/libkpimexchange/core/exchangeupload.cpp b/libkpimexchange/core/exchangeupload.cpp
new file mode 100644
index 000000000..8332979a0
--- /dev/null
+++ b/libkpimexchange/core/exchangeupload.cpp
@@ -0,0 +1,371 @@
+/*
+ This file is part of libkpimexchange
+ Copyright (c) 2002 Jan-Pascal van Best <janpascal@vanbest.org>
+
+ This library is free software; you can redistribute it and/or
+ modify it under the terms of the GNU Library General Public
+ License as published by the Free Software Foundation; either
+ version 2 of the License, or (at your option) any later version.
+
+ This library 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
+ Library General Public License for more details.
+
+ You should have received a copy of the GNU Library General Public License
+ along with this library; see the file COPYING.LIB. If not, write to
+ the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
+ Boston, MA 02110-1301, USA.
+*/
+
+#include <qstring.h>
+#include <qregexp.h>
+
+#include <kurl.h>
+#include <kdebug.h>
+#include <krfcdate.h>
+#include <kio/job.h>
+
+#include <kio/slave.h>
+#include <kio/scheduler.h>
+#include <kio/slavebase.h>
+#include <kio/davjob.h>
+#include <kio/http.h>
+
+extern "C" {
+ #include <ical.h>
+}
+
+#include <libkcal/event.h>
+#include <libkcal/icalformat.h>
+#include <libkcal/icalformatimpl.h>
+#include <libkcal/recurrence.h>
+#include <libkcal/incidence.h>
+#include <libkcal/event.h>
+
+#include "exchangeclient.h"
+#include "exchangeprogress.h"
+#include "exchangeupload.h"
+#include "exchangeaccount.h"
+#include "utils.h"
+
+using namespace KPIM;
+
+ExchangeUpload::ExchangeUpload( KCal::Event *event, ExchangeAccount *account,
+ const QString &timeZoneId, QWidget *window )
+ : mTimeZoneId( timeZoneId ), mWindow( window )
+{
+ kdDebug() << "Called ExchangeUpload" << endl;
+
+ mAccount = account;
+ m_currentUpload = event;
+ m_currentUploadNumber = 0;
+
+// kdDebug() << "Trying to add appointment " << m_currentUpload->summary() << endl;
+
+ // TODO: For exisiting events the URL for the uid should already be known.
+ // Store it after downloading and keep the mapping
+
+ findUid( m_currentUpload->uid() );
+}
+
+ExchangeUpload::~ExchangeUpload()
+{
+ kdDebug() << "Entering ExchangeUpload destructor" << endl;
+ kdDebug() << "Finished ExchangeUpload destructor" << endl;
+}
+
+void ExchangeUpload::findUid( QString const &uid )
+{
+ QString query =
+ "SELECT \"DAV:href\", \"urn:schemas:calendar:uid\"\r\n"
+ "FROM Scope('shallow traversal of \"\"')\r\n"
+ "WHERE \"urn:schemas:calendar:uid\" = '" + uid + "'\r\n";
+
+ kdDebug() << "Find uid query: " << endl << query << endl;
+ kdDebug() << "Looking for uid " << uid << endl;
+
+ KIO::DavJob* job = KIO::davSearch( mAccount->calendarURL(), "DAV:", "sql",
+ query, false );
+ job->setWindow( mWindow );
+ connect( job, SIGNAL( result( KIO::Job * ) ),
+ SLOT( slotFindUidResult( KIO::Job * ) ) );
+}
+
+void ExchangeUpload::slotFindUidResult( KIO::Job * job )
+{
+ kdDebug() << "slotFindUidResult()" << endl;
+
+ if ( job->error() ) {
+ kdDebug() << "Error: " << job->error() << endl;
+ job->showErrorDialog( 0 );
+ emit finished( this, ExchangeClient::CommunicationError,
+ "IO Error: " + QString::number(job->error()) + ":" +
+ job->errorString() );
+ return;
+ }
+ QDomDocument &response = static_cast<KIO::DavJob *>( job )->response();
+
+ kdDebug() << "Search uid result: " << endl << response.toString() << endl;
+
+ QDomElement item = response.documentElement().firstChild().toElement();
+ QDomElement hrefElement = item.namedItem( "href" ).toElement();
+ if ( item.isNull() || hrefElement.isNull() ) {
+ // No appointment with this UID in exchange database
+ // Create a new filename for this appointment and store it there
+ tryExist();
+ return;
+ }
+ // The appointment is already in the exchange database
+ // Overwrite it with the new data
+ QString href = hrefElement.text();
+ KURL url( href );
+ kdDebug() << "Found URL with identical uid: " << url.prettyURL()
+ << ", overwriting that one" << endl;
+
+ startUpload( toDAV( url ) );
+}
+
+void ExchangeUpload::tryExist()
+{
+ // FIXME: we should first check if current's uid is already in the Exchange database
+ // Maybe use locking?
+ KURL url = mAccount->calendarURL();
+ if ( m_currentUploadNumber == 0 )
+ url.addPath( m_currentUpload->summary() + ".EML" );
+ else
+ url.addPath( m_currentUpload->summary() + "-" + QString::number( m_currentUploadNumber ) + ".EML" );
+
+ kdDebug() << "Trying to see whether " << url.prettyURL() << " exists" << endl;
+
+ QDomDocument doc;
+ QDomElement root = addElement( doc, doc, "DAV:", "propfind" );
+ QDomElement prop = addElement( doc, root, "DAV:", "prop" );
+ addElement( doc, prop, "DAV:", "displayname" );
+ addElement( doc, prop, "urn:schemas:calendar", "uid" );
+
+ KIO::DavJob *job = KIO::davPropFind( url, doc, "0", false );
+ job->setWindow( mWindow );
+ job->addMetaData( "errorPage", "false" );
+ connect( job, SIGNAL( result( KIO::Job * ) ),
+ SLOT( slotPropFindResult( KIO::Job * ) ) );
+}
+
+void ExchangeUpload::slotPropFindResult( KIO::Job *job )
+{
+ kdDebug() << "slotPropFindResult()" << endl;
+ int error = job->error();
+ kdDebug() << "PROPFIND error: " << error << ":" << job->errorString() << endl;
+ if ( error && error != KIO::ERR_DOES_NOT_EXIST ) {
+ job->showErrorDialog( 0 );
+ emit finished( this, ExchangeClient::CommunicationError,
+ "IO Error: " + QString::number(error) + ":" +
+ job->errorString() );
+ return;
+ }
+
+ if ( !error ) {
+ // File exist, try another one
+ m_currentUploadNumber++;
+ tryExist();
+ return;
+ }
+
+ // We got a 404 error, resource doesn't exist yet, create it
+ // FIXME: race condition possible if resource is created under
+ // our nose.
+
+ KURL url = mAccount->calendarURL();
+ if ( m_currentUploadNumber == 0 )
+ url.addPath( m_currentUpload->summary() + ".EML" );
+ else
+ url.addPath( m_currentUpload->summary() + "-" +
+ QString::number( m_currentUploadNumber ) + ".EML" );
+
+ startUpload( url );
+}
+
+QString timezoneid( int offset )
+{
+ switch ( offset ) {
+ case 0: return "0";
+ case -60: return "3";
+ case -120: return "5";
+ case -180: return "51";
+ case -210: return "25";
+ case -240: return "24"; // Abu Dhabi
+ case -270: return "48"; // Kabul
+ case -300: return "47"; // Islamabad
+ case -330: return "23"; // Bombay
+ case -360: return "46"; // Dhaka
+ case -420: return "22"; // Bangkok
+ case -480: return "45"; // Beijing
+ case -540: return "20"; // Tokyo
+ case -570: return "44"; // Darwin
+ case -600: return "18"; // Brisbane
+ case -660: return "41"; // Solomon Islands
+ case -720: return "17"; // Auckland
+ case 60: return "29"; // Azores
+ case 120: return "30"; // Mid Atlantic
+ case 180: return "8"; // Brasilia
+ case 210: return "28"; // Newfoundland
+ case 240: return "9"; // Atlantic time Canada
+ case 300: return "10"; // Eastern
+ case 360: return "11"; // Central time
+ case 420: return "12"; // Mountain time
+ case 480: return "13"; // Pacific time
+ case 540: return "14"; // Alaska time
+ case 600: return "15"; // Hawaii
+ case 660: return "16"; // Midway Island
+ case 720: return "39"; // Eniwetok
+ default: return "52"; // Invalid time zone
+ }
+}
+
+
+void ExchangeUpload::startUpload( const KURL &url )
+{
+ KCal::Event *event = static_cast<KCal::Event *>( m_currentUpload );
+ if ( ! event ) {
+ kdDebug() << "ERROR: trying to upload a non-Event Incidence" << endl;
+ emit finished( this, ExchangeClient::NonEventError, "The incidence that is to be uploaded to the exchange server is not of type KCal::Event" );
+ return;
+ }
+
+ QDomDocument doc;
+ QDomElement root = addElement( doc, doc, "DAV:", "propertyupdate" );
+ QDomElement set = addElement( doc, root, "DAV:", "set" );
+ QDomElement prop = addElement( doc, set, "DAV:", "prop" );
+ addElement( doc, prop, "DAV:", "contentclass", "urn:content-classes:appointment" );
+// addElement( doc, prop, "http://schemas.microsoft.com/exchange/", "outlookmessageclass", "IPM.appointment" );
+ addElement( doc, prop, "http://schemas.microsoft.com/exchange/",
+ "outlookmessageclass", "IPM.Appointment" );
+ // addElement( doc, prop, "urn:schemas:calendar:", "method", "Add" );
+ addElement( doc, prop, "urn:schemas:calendar:", "alldayevent",
+ event->doesFloat() ? "1" : "0" );
+ addElement( doc, prop, "urn:schemas:calendar:", "busystatus",
+ event->transparency() ? "Free" : "Busy" );
+ // KLUDGE: somehow we need to take the opposite of the
+ // value that localUTCOffset() supplies...
+ // FIXME: What do we need that offset for anyway???
+ int tzOffset = - KRFCDate::localUTCOffset();
+ QString offsetString;
+ if ( tzOffset == 0 )
+ offsetString = "Z";
+ else if ( tzOffset > 0 )
+ offsetString = QString( "+%1:%2" ).arg(tzOffset/60, 2).arg( tzOffset%60, 2 );
+ else
+ offsetString = QString( "-%1:%2" ).arg((-tzOffset)/60, 2).arg( (-tzOffset)%60, 2 );
+ offsetString = offsetString.replace( QRegExp(" "), "0" );
+
+ kdDebug() << "Timezone offset: " << tzOffset << " : " << offsetString << endl;
+ kdDebug() << "ExchangeUpload::mTimeZoneId=" << mTimeZoneId << endl;
+
+ addElement( doc, prop, "urn:schemas:calendar:", "dtstart",
+ zoneAsUtc( event->dtStart(), mTimeZoneId ).toString( Qt::ISODate ) + "Z" );
+ // event->dtStart().toString( "yyyy-MM-ddThh:mm:ss.zzzZ" ) );
+ // 2002-06-04T08:00:00.000Z" );
+ addElement( doc, prop, "urn:schemas:calendar:", "dtend",
+ zoneAsUtc( event->dtEnd(), mTimeZoneId ).toString( Qt::ISODate ) + "Z" );
+#if 0
+ addElement( doc, prop, "urn:schemas:calendar:", "dtstart",
+ event->dtStart().toString( "yyyy-MM-ddThh:mm:ss.zzz" )+ offsetString );
+ // event->dtStart().toString( "yyyy-MM-ddThh:mm:ss.zzzZ" ) );
+ // 2002-06-04T08:00:00.000Z" );
+ addElement( doc, prop, "urn:schemas:calendar:", "dtend",
+ event->dtEnd().toString( "yyyy-MM-ddThh:mm:ss.zzz" ) + offsetString );
+#endif
+ addElement( doc, prop, "urn:schemas:calendar:", "lastmodified", zoneAsUtc( event->lastModified(), mTimeZoneId ).toString( Qt::ISODate )+"Z" );
+
+// addElement( doc, prop, "urn:schemas:calendar:", "meetingstatus", "confirmed" );
+ addElement( doc, prop, "urn:schemas:httpmail:", "textdescription", event->description() );
+ addElement( doc, prop, "urn:schemas:httpmail:", "subject", event->summary() );
+ addElement( doc, prop, "urn:schemas:calendar:", "location", event->location() );
+ // addElement( doc, prop, "urn:schemas:mailheader:", "subject", event->summary() );
+ addElement( doc, prop, "urn:schemas:calendar:", "uid", event->uid() );
+// addElement( doc, prop, "urn:schemas:calendar:", "organizer", event->organizer() );
+
+ KCal::Recurrence *recurrence = event->recurrence();
+ kdDebug() << "Recurrence->doesRecur(): " << recurrence->doesRecur() << endl;
+ if ( recurrence->recurrenceType() != KCal::Recurrence::rNone ) {
+ addElement( doc, prop, "urn:schemas:calendar:", "instancetype", "1" );
+ KCal::ICalFormat *format = new KCal::ICalFormat();
+ QString recurstr = format->toString( recurrence->defaultRRule() );
+ // Strip leading "RRULE\n :" and whitespace
+ recurstr = recurstr.replace( QRegExp("^[A-Z]*[\\s]*:"), "").stripWhiteSpace();
+ kdDebug() << "Recurrence rule after replace: \"" << recurstr << "\"" << endl;
+ delete format;
+ QDomElement rrule = addElement( doc, prop, "urn:schemas:calendar:", "rrule" );
+ addElement( doc, rrule, "xml:", "v", recurstr );
+ addElement( doc, prop, "urn:schemas:calendar:", "timezoneid", timezoneid( tzOffset ) );
+ } else {
+ addElement( doc, prop, "urn:schemas:calendar:", "instancetype", "0" );
+ }
+
+ KCal::DateList exdates = recurrence->exDates();
+ if ( !exdates.isEmpty() ) {
+ QDomElement exdate = addElement( doc, prop, "urn:schemas:calendar:", "exdate" );
+ KCal::DateList::iterator it;
+ for ( it = exdates.begin(); it != exdates.end(); ++it ) {
+ QString date = (*it).toString( "yyyy-MM-ddT00:00:00.000" )+ offsetString;
+// QString date = zoneAsUtc( (*it), mTimeZoneId ).toString( Qt::ISODate );
+ addElement( doc, exdate, "xml:", "v", date );
+ }
+ }
+
+ KCal::Alarm::List alarms = event->alarms();
+ if ( alarms.count() > 0 ) {
+ KCal::Alarm* alarm = alarms.first();
+ // TODO: handle multiple alarms
+ // TODO: handle end offsets and general alarm times
+ // TODO: handle alarm types
+ if ( alarm->hasStartOffset() ) {
+ int offset = - alarm->startOffset().asSeconds();
+ addElement( doc, prop, "urn:schemas:calendar:", "reminderoffset", QString::number( offset ) );
+ }
+ }
+
+ kdDebug() << "Uploading event: " << endl;
+ kdDebug() << doc.toString() << endl;
+
+ kdDebug() << "Upload url: " << url << endl;
+
+ KIO::DavJob *job = KIO::davPropPatch( url, doc, false );
+ job->setWindow( mWindow );
+ connect( job, SIGNAL( result( KIO::Job * ) ),
+ SLOT( slotPatchResult( KIO::Job * ) ) );
+}
+
+void ExchangeUpload::slotPatchResult( KIO::Job *job )
+{
+ kdDebug() << "slotPropPatchResult()" << endl;
+ if ( job->error() ) {
+ job->showErrorDialog( 0 );
+ kdDebug() << "Error: " << job->error() << endl;
+ emit finished( this, ExchangeClient::CommunicationError,
+ "IO Error: " + QString::number(job->error()) + ":" +
+ job->errorString() );
+ return;
+ }
+ QDomDocument response = static_cast<KIO::DavJob *>( job )->response();
+ kdDebug() << "Patch result: " << response.toString() << endl;
+
+ // Either we have a "201 Created" (if a new event has been created) or
+ // we have a "200 OK" (if an existing event has been altered),
+ // or else an error has occurred ;)
+ QDomElement status = response.documentElement().namedItem( "response" )
+ .namedItem( "status" ).toElement();
+ QDomElement propstat = response.documentElement().namedItem( "response" )
+ .namedItem( "propstat" ).namedItem( "status" )
+ .toElement();
+ kdDebug() << "status: " << status.text() << endl;
+ kdDebug() << "propstat: " << propstat.text() << endl;
+ if ( ! ( status.text().contains( "201" ) ||
+ propstat.text().contains( "200" ) ) )
+ emit finished( this, ExchangeClient::EventWriteError,
+ "Upload error response: \n" + response.toString() );
+ else
+ emit finished( this, ExchangeClient::ResultOK, QString::null );
+}
+
+#include "exchangeupload.moc"