summaryrefslogtreecommitdiffstats
path: root/tderesources/remote/resourceremote.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'tderesources/remote/resourceremote.cpp')
-rw-r--r--tderesources/remote/resourceremote.cpp352
1 files changed, 352 insertions, 0 deletions
diff --git a/tderesources/remote/resourceremote.cpp b/tderesources/remote/resourceremote.cpp
new file mode 100644
index 000000000..ed05f8405
--- /dev/null
+++ b/tderesources/remote/resourceremote.cpp
@@ -0,0 +1,352 @@
+/*
+ This file is part of libkcal.
+
+ Copyright (c) 2003,2004 Cornelius Schumacher <schumacher@kde.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 <typeinfo>
+#include <stdlib.h>
+
+#include <tqdatetime.h>
+#include <tqstring.h>
+#include <tqptrlist.h>
+
+#include <kdebug.h>
+#include <kurl.h>
+#include <kio/job.h>
+#include <klocale.h>
+#include <kmessagebox.h>
+#include <kstandarddirs.h>
+
+#include <libkcal/icalformat.h>
+#include <libkcal/exceptions.h>
+#include <libkcal/incidence.h>
+#include <libkcal/event.h>
+#include <libkcal/todo.h>
+#include <libkcal/journal.h>
+#include <libkcal/filestorage.h>
+
+#include <kabc/lock.h>
+
+#include <tderesources/configwidget.h>
+
+#include "resourceremoteconfig.h"
+
+#include "resourceremote.h"
+
+using namespace KCal;
+
+ResourceRemote::ResourceRemote( const TDEConfig *config )
+ : ResourceCached( config ), mUseProgressManager( true ), mUseCacheFile( true )
+{
+ if ( config ) {
+ readConfig( config );
+ } else {
+ setResourceName( i18n( "Remote Calendar" ) );
+ }
+
+ init();
+}
+
+ResourceRemote::ResourceRemote( const KURL &downloadUrl, const KURL &uploadUrl )
+ : ResourceCached( 0 ), mUseProgressManager( false ), mUseCacheFile( false )
+{
+ mDownloadUrl = downloadUrl;
+
+ if ( uploadUrl.isEmpty() ) {
+ mUploadUrl = mDownloadUrl;
+ } else {
+ mUploadUrl = uploadUrl;
+ }
+
+ init();
+}
+
+ResourceRemote::~ResourceRemote()
+{
+ close();
+
+ if ( mDownloadJob ) mDownloadJob->kill();
+ if ( mUploadJob ) mUploadJob->kill();
+
+ delete mLock;
+}
+
+void ResourceRemote::init()
+{
+ mDownloadJob = 0;
+ mUploadJob = 0;
+
+ mProgress = 0;
+
+ setType( "remote" );
+
+ mLock = new KABC::Lock( cacheFile() );
+
+ enableChangeNotification();
+}
+
+void ResourceRemote::readConfig( const TDEConfig *config )
+{
+ TQString url = config->readEntry( "DownloadUrl" );
+ mDownloadUrl = KURL( url );
+
+ url = config->readEntry( "UploadUrl" );
+ mUploadUrl = KURL( url );
+
+ ResourceCached::readConfig( config );
+}
+
+void ResourceRemote::writeConfig( TDEConfig *config )
+{
+ kdDebug(5800) << "ResourceRemote::writeConfig()" << endl;
+
+ ResourceCalendar::writeConfig( config );
+
+ config->writeEntry( "DownloadUrl", mDownloadUrl.url() );
+ config->writeEntry( "UploadUrl", mUploadUrl.url() );
+
+ ResourceCached::writeConfig( config );
+}
+
+void ResourceRemote::setDownloadUrl( const KURL &url )
+{
+ mDownloadUrl = url;
+}
+
+KURL ResourceRemote::downloadUrl() const
+{
+ return mDownloadUrl;
+}
+
+void ResourceRemote::setUploadUrl( const KURL &url )
+{
+ mUploadUrl = url;
+}
+
+KURL ResourceRemote::uploadUrl() const
+{
+ return mUploadUrl;
+}
+
+void ResourceRemote::setUseProgressManager( bool useProgressManager )
+{
+ mUseProgressManager = useProgressManager;
+}
+
+bool ResourceRemote::useProgressManager() const
+{
+ return mUseProgressManager;
+}
+
+void ResourceRemote::setUseCacheFile( bool useCacheFile )
+{
+ mUseCacheFile = useCacheFile;
+}
+
+bool ResourceRemote::useCacheFile() const
+{
+ return mUseCacheFile;
+}
+
+bool ResourceRemote::doLoad()
+{
+ kdDebug(5800) << "ResourceRemote::load()" << endl;
+
+ if ( mDownloadJob ) {
+ kdWarning() << "ResourceRemote::load(): download still in progress."
+ << endl;
+ return true;
+ }
+ if ( mUploadJob ) {
+ kdWarning() << "ResourceRemote::load(): upload still in progress."
+ << endl;
+ return false;
+ }
+
+ mCalendar.close();
+
+ if ( mUseCacheFile ) {
+ disableChangeNotification();
+ loadCache();
+ enableChangeNotification();
+ }
+
+ clearChanges();
+
+ emit resourceChanged( this );
+
+ if ( mLock->lock() )
+ {
+ kdDebug() << "Download from: " << mDownloadUrl << endl;
+
+ mDownloadJob = TDEIO::file_copy( mDownloadUrl, KURL( cacheFile() ), -1, true,
+ false, !mUseProgressManager );
+ connect( mDownloadJob, TQT_SIGNAL( result( TDEIO::Job * ) ),
+ TQT_SLOT( slotLoadJobResult( TDEIO::Job * ) ) );
+ if ( mUseProgressManager ) {
+ connect( mDownloadJob, TQT_SIGNAL( percent( TDEIO::Job *, unsigned long ) ),
+ TQT_SLOT( slotPercent( TDEIO::Job *, unsigned long ) ) );
+ mProgress = KPIM::ProgressManager::createProgressItem(
+ KPIM::ProgressManager::getUniqueID(), i18n("Downloading Calendar") );
+
+ mProgress->setProgress( 0 );
+ }
+ }
+ else
+ kdDebug() << "ResourceRemote::load(): cache file is locked - something else must be loading the file" << endl;
+ return true;
+}
+
+void ResourceRemote::slotPercent( TDEIO::Job *, unsigned long percent )
+{
+ kdDebug() << "ResourceRemote::slotPercent(): " << percent << endl;
+
+ mProgress->setProgress( percent );
+}
+
+void ResourceRemote::slotLoadJobResult( TDEIO::Job *job )
+{
+ if ( job->error() ) {
+ // TODO: Should detect 404, 401 etc. vs host not found and prompt to create new resource only when 404 is returned
+ TQString warningString = TQString("<b>") + i18n("Remote data access failure") + TQString("</b><p>") + i18n("Detailed information") \
+ + TQString(":<br>") + job->errorString() + TQString("<p>") + i18n("What would you like to do?");
+ int rc = KMessageBox::warningContinueCancel(0,
+ warningString, i18n("Remote Data Access Failure"), i18n("&Continue with cached resource"));
+ if ( rc == KMessageBox::Continue ) {
+ mCalendar.close();
+ disableChangeNotification();
+ loadCache();
+ enableChangeNotification();
+
+ emit resourceChanged( this );
+ }
+ //job->showErrorDialog( 0 );
+ } else {
+ kdDebug(5800) << "ResourceRemote::slotLoadJobResult() success" << endl;
+
+ mCalendar.close();
+ disableChangeNotification();
+ loadCache();
+ enableChangeNotification();
+
+ emit resourceChanged( this );
+ }
+
+ mDownloadJob = 0;
+ if ( mProgress ) {
+ mProgress->setComplete();
+ mProgress = 0;
+ }
+
+ mLock->unlock();
+ emit resourceLoaded( this );
+}
+
+bool ResourceRemote::doSave()
+{
+ kdDebug(5800) << "ResourceRemote::save()" << endl;
+
+ if ( readOnly() || !hasChanges() ) {
+ emit resourceSaved( this );
+ return true;
+ }
+
+ if ( mDownloadJob ) {
+ kdWarning() << "ResourceRemote::save(): download still in progress."
+ << endl;
+ return false;
+ }
+ if ( mUploadJob ) {
+ kdWarning() << "ResourceRemote::save(): upload still in progress."
+ << endl;
+ return false;
+ }
+
+ mChangedIncidences = allChanges();
+
+ saveCache();
+
+ mUploadJob = TDEIO::file_copy( KURL( cacheFile() ), mUploadUrl, -1, true );
+ connect( mUploadJob, TQT_SIGNAL( result( TDEIO::Job * ) ),
+ TQT_SLOT( slotSaveJobResult( TDEIO::Job * ) ) );
+
+ return true;
+}
+
+bool ResourceRemote::isSaving()
+{
+ return mUploadJob;
+}
+
+void ResourceRemote::slotSaveJobResult( TDEIO::Job *job )
+{
+ if ( job->error() ) {
+ job->showErrorDialog( 0 );
+ } else {
+ kdDebug(5800) << "ResourceRemote::slotSaveJobResult() success" << endl;
+
+ Incidence::List::ConstIterator it;
+ for( it = mChangedIncidences.begin(); it != mChangedIncidences.end();
+ ++it ) {
+ clearChange( *it );
+ }
+ mChangedIncidences.clear();
+ }
+
+ mUploadJob = 0;
+
+ emit resourceSaved( this );
+}
+
+KABC::Lock *ResourceRemote::lock()
+{
+ return mLock;
+}
+
+void ResourceRemote::dump() const
+{
+ ResourceCalendar::dump();
+ kdDebug(5800) << " DownloadUrl: " << mDownloadUrl.url() << endl;
+ kdDebug(5800) << " UploadUrl: " << mUploadUrl.url() << endl;
+ kdDebug(5800) << " ReloadPolicy: " << reloadPolicy() << endl;
+}
+
+void ResourceRemote::addInfoText( TQString &txt ) const
+{
+ txt += "<br>";
+ txt += i18n("URL: %1").arg( mDownloadUrl.prettyURL() );
+}
+
+bool ResourceRemote::setValue( const TQString &key, const TQString &value )
+{
+ if ( key == "URL" ) {
+ setUploadUrl( KURL( value ) );
+ setDownloadUrl( KURL( value ) );
+ return true;
+ } else if ( key == "DownloadURL" ) {
+ setDownloadUrl( KURL( value ) );
+ return true;
+ } else if ( key == "UploadURL" ) {
+ setUploadUrl( KURL( value ) );
+ return true;
+ } else
+ return ResourceCached::setValue( key, value );
+}
+
+#include "resourceremote.moc"