diff options
Diffstat (limited to 'kresources/tvanytime/kcal_resourcetvanytime.cpp')
| -rw-r--r-- | kresources/tvanytime/kcal_resourcetvanytime.cpp | 489 |
1 files changed, 0 insertions, 489 deletions
diff --git a/kresources/tvanytime/kcal_resourcetvanytime.cpp b/kresources/tvanytime/kcal_resourcetvanytime.cpp deleted file mode 100644 index e447008c3..000000000 --- a/kresources/tvanytime/kcal_resourcetvanytime.cpp +++ /dev/null @@ -1,489 +0,0 @@ -/* - This file is part of tdepim. - - Copyright (c) 2005 Will Stephenson <wstephenson@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 "kcal_resourcetvanytime.h" - -#include "kcal_tvanytimeprefsbase.h" -#include "kcal_resourcetvanytimeconfig.h" - -#include <libkcal/icalformat.h> -#include <libkcal/calendarlocal.h> -#include <libkcal/confirmsavedialog.h> - -#include <libtdepim/kpimprefs.h> - -#include <tqapplication.h> -#include <tqdom.h> -#include <tqdatetime.h> -#include <tqptrlist.h> -#include <tqregexp.h> -#include <tqstringlist.h> -#include <tqtimer.h> - -#include <kabc/locknull.h> -#include <karchive.h> -#include <kdebug.h> -#include <klocale.h> -#include <kresources/configwidget.h> -#include <kstandarddirs.h> -#include <kstringhandler.h> -#include <ktempfile.h> -#include <ktar.h> -#include <kurl.h> - -using namespace KCal; - -ResourceTVAnytime::ResourceTVAnytime() - : ResourceCached( 0 ), mLock( true ) -{ - init(); - - mPrefs->addGroupPrefix( identifier() ); -} - -ResourceTVAnytime::ResourceTVAnytime( const TDEConfig *config ) - : ResourceCached( config ), mLock( true ) -{ - init(); - - mPrefs->addGroupPrefix( identifier() ); - - if ( config ) readConfig( config ); -} - -ResourceTVAnytime::~ResourceTVAnytime() -{ - disableChangeNotification(); - - delete mPrefs; - mPrefs = 0; -} - -void ResourceTVAnytime::init() -{ - mDownloadJob = 0; - mProgress = 0; - mDestination = 0; - - mIsShowingError = false; - - mPrefs = new TVAnytimePrefsBase(); - - setType( "tvanytime" ); - - enableChangeNotification(); - - //setReadOnly( true ); - - connect( &mResourceChangedTimer, TQT_SIGNAL( timeout() ), - this, TQT_SLOT( slotEmitResourceChanged() ) ); -} - -TVAnytimePrefsBase *ResourceTVAnytime::prefs() -{ - return mPrefs; -} - -void ResourceTVAnytime::readConfig( const TDEConfig *config ) -{ - kdDebug() << "KCal::ResourceTVAnytime::readConfig()" << endl; - - mPrefs->readConfig(); - - ResourceCached::readConfig( config ); - - TQStringList defaultActive; - defaultActive << "BBCOne" << "BBCTwo" << "BBCThree" << "BBCROne" << "BBCRTwo" << "BBCRThree" << "BBCRFour"; - mActiveServices = config->readListEntry( "ActiveServices", defaultActive ); - -} - -void ResourceTVAnytime::writeConfig( TDEConfig *config ) -{ - kdDebug() << "KCal::ResourceTVAnytime::writeConfig()" << endl; - - ResourceCalendar::writeConfig( config ); - - mPrefs->writeConfig(); - - ResourceCached::writeConfig( config ); - TQStringList activeServices; - ServiceMap::ConstIterator it; - for ( it = mServiceMap.begin(); it != mServiceMap.end(); ++it ) - if ( it.data().active() ) - activeServices.append( it.key() ); - config->writeEntry( "ActiveServices", activeServices ); -} - -bool ResourceTVAnytime::doOpen() -{ - return true; -} - -void ResourceTVAnytime::doClose() -{ - ResourceCached::doClose(); -} - -bool ResourceTVAnytime::doLoad() -{ - kdDebug() << "ResourceTVAnytime::load()" << endl; - - if ( mIsShowingError ) { - kdDebug() << "Still showing error" << endl; - return true; - } - - if ( mDownloadJob ) { - kdWarning() << "Download still in progress" << endl; - return false; - } - - mUidMap.clear(); - mCalendar.close(); - - disableChangeNotification(); - // FIXME - reenable cache - loadCache(); // TODO: default loadCache() won't set up the subresources... - enableChangeNotification(); - - emit resourceChanged( this ); - - clearChanges(); - - mDestination = new KTempFile; - KURL url( prefs()->url() ); - - KURL destination = KURL( mDestination->name() ); - - kdDebug(5850) << " SOURCE: " << url.url() << endl; - kdDebug(5850) << " DESTINATION: " << destination.url() << endl; - - // TODO: find out if the file to download is fresh. if not, just work with the cache. - mDownloadJob = TDEIO::file_copy( url, destination, -1, true ); - connect( mDownloadJob, TQT_SIGNAL( result( TDEIO::Job * ) ), - TQT_SLOT( slotJobResult( TDEIO::Job * ) ) ); - - mProgress = KPIM::ProgressManager::instance()->createProgressItem( - KPIM::ProgressManager::getUniqueID(), i18n("Downloading program schedule") ); - - connect( mProgress, - TQT_SIGNAL( progressItemCanceled( KPIM::ProgressItem * ) ), - TQT_SLOT( cancelLoad() ) ); - - return true; -} - -void ResourceTVAnytime::slotJobResult( TDEIO::Job *job ) -{ - kdDebug() << "ResourceTVAnytime::slotJobResult(): " << endl; - - if ( job->error() ) { - mIsShowingError = true; - loadError( job->errorString() ); - mIsShowingError = false; - delete mDestination; - mDestination = 0; - } else { - disableChangeNotification(); - - clearCache(); - - // FIXME: This does not take into account the time zone! - - readSchedule(); - - // FIXME - reenable cache - saveCache(); - enableChangeNotification(); - - clearChanges(); - - emit resourceChanged( this ); - emit resourceLoaded( this ); - } - - mDownloadJob = 0; - if ( mProgress ) mProgress->setComplete(); - mProgress = 0; - delete mDestination; - mDestination = 0; -} - -TQDomDocument ResourceTVAnytime::archiveFileXml( const TQString & name ) -{ - TQDomDocument result; - const KArchiveDirectory *dir = mScheduleArchive->directory(); - const KArchiveEntry * entry = dir->entry( name ); - if ( entry && entry->isFile() ) - { - const KArchiveFile * file = static_cast<const KArchiveFile *>( entry ); - result.setContent( file->data() ); - } - return result; -} - -bool ResourceTVAnytime::readSchedule() -{ - TQString uncompress = "application/x-gzip"; - mScheduleArchive = new KTar( mDestination->name(), uncompress ); - mScheduleArchive->open( IO_ReadOnly ); - - TQDomDocument serviceInfo = archiveFileXml( "ServiceInformation.xml" ); - if ( !serviceInfo.isNull() ) - readServiceInformation( serviceInfo ); - - - ServiceMap::Iterator it; - // for each date in the tarball/or user preference: -#if 1 - for ( it = mServiceMap.begin(); it != mServiceMap.end(); ++it ) - { - if ( (it.data().active() ) ) - readService( it.key() ); - } -#else - TQString serviceId = "BBCOne"; - Service s = mServiceMap[ serviceId ]; - if ( s.active() ) - readService( serviceId ); -#endif - - mScheduleArchive->close(); - return true; -} - -bool ResourceTVAnytime::readServiceInformation( const TQDomDocument & serviceInfo ) -{ - kdDebug() << k_funcinfo << endl; - TQDomElement docElem = serviceInfo.documentElement(); - - TQDomNode n = docElem.firstChild(); - while( !n.isNull() ) { - TQDomElement e = n.toElement(); // try to convert the node to an element. - if( !e.isNull() && e.tagName() == "ProgramDescription" ) { - TQDomNode n2 = e.firstChild(); - TQDomElement e2 = n2.toElement(); - if( !e2.isNull() && e2.tagName() == "ServiceInformationTable" ) { - TQDomNode n3 = e2.firstChild(); - while ( !n3.isNull() ) { - Service s; - TQDomElement e3 = n3.toElement(); - if (s.loadXML( e3 ) ) { - s.setActive( mActiveServices.contains( s.id() ) ); - bool newService = !mServiceMap.contains( s.id() ); - if ( newService ) - { - mServiceMap.insert( s.id(), s ); - emit signalSubresourceAdded( this, "Calendar", s.id(), s.name() ); - } - } - else - kdDebug() << " couldn't find ServiceInformation: " << e3.tagName() << endl; - n3 = n3.nextSibling(); - } - } - else - kdDebug() << " couldn't find ServiceInformationTable: " << e2.tagName() << endl; - } - else - kdDebug() << " couldn't find ProgramDescription: " << e.tagName() << endl; - n = n.nextSibling(); - } - return true; -} - -bool ResourceTVAnytime::readService( const TQString & serviceId ) -{ - kdDebug() << k_funcinfo << endl; - // open programme information table - Service service = mServiceMap[ serviceId ]; - - TQStringList entries = mScheduleArchive->directory()->entries(); - TQRegExp re( "^(\\d{8})" + serviceId ); - TQStringList dates; - TQString todaysDate = TQDate::currentDate().toString( "yyyyMMdd" ); - for( TQStringList::Iterator it = entries.begin(); it != entries.end(); ++it ) - { - if ( re.search( *it ) != -1 ) // this entry belongs to the requested service - { - TQString entry = re.cap( 1 ); - // handle this date according to user preferences - TQDate entryDate( entry.left( 4 ).toInt(), entry.mid( 4, 2 ).toInt(), entry.right( 2 ).toInt() ); - if ( entryDate < TQDate::currentDate() || ( entryDate > TQDate::currentDate().addDays( prefs()->days() - 1 ) ) ) - continue; - - if ( !dates.contains( re.cap( 1 ) ) ) - dates.append( re.cap( 1 ) ); - } - } - - kdDebug() << "reading schedule for " << serviceId << " on " << dates << endl; - - for( TQStringList::Iterator it = dates.begin(); it != dates.end(); ++it ) - { - ProgramInformationMap progInfoMap = service.programmeInformation(); - TQString programInfoFileName = TQString( *it + serviceId + "_pi.xml" ); - TQDomDocument programInfo = archiveFileXml( programInfoFileName ); - if ( !programInfo.isNull() ) { - TQDomElement docElem = programInfo.documentElement(); - TQDomNode n = docElem.firstChild(); - while( !n.isNull() ) { - TQDomElement e = n.toElement(); // try to convert the node to an element. - if( !e.isNull() && e.tagName() == "ProgramDescription" ) { - TQDomNode n2 = e.firstChild(); - TQDomElement e2 = n2.toElement(); - if( !e2.isNull() && e2.tagName() == "ProgramInformationTable" ) { - TQDomNode n3 = e2.firstChild(); - while ( !n3.isNull() ) { - TQDomElement e3 = n3.toElement(); - ProgramInformation pi; - if ( pi.loadXML( e3 ) ) { - //kdDebug() << "Found programme: " << pi.id() << "," << pi.title() << "," << pi.synopsis() << endl; - progInfoMap.insert( pi.id(), pi ); - } - n3 = n3.nextSibling(); - } - } - } - n = n.nextSibling(); - } - service.setProgramInformation( progInfoMap ); - } - else - kdDebug() << "Service file: " << programInfoFileName << " not found in archive" << endl; - // open programme location table, iterate and create incidences - - TQString programLocationFileName = TQString( *it + serviceId + "_pl.xml" ); - TQDomDocument programLocation = archiveFileXml( programLocationFileName ); - if ( !programLocation.isNull() ) { - TQDomElement docElem = programLocation.documentElement(); - TQDomNode n = docElem.firstChild(); - while( !n.isNull() ) { - TQDomElement e = n.toElement(); // try to convert the node to an element. - if( !e.isNull() && e.tagName() == "ProgramDescription" ) { - TQDomNode n2 = e.firstChild(); - TQDomElement e2 = n2.toElement(); - if( !e2.isNull() && e2.tagName() == "ProgramLocationTable" ) { - TQDomNode n3 = e2.firstChild(); - TQDomElement e3 = n3.toElement(); - if( !e3.isNull() && e3.tagName() == "Schedule" ) { - TQString foundServiceId = e3.attribute( "serviceIDRef" ); - if ( serviceId == foundServiceId ) { - TQDomNode n4 = e3.firstChild(); - while ( !n4.isNull() ) { - TQDomElement e4 = n4.toElement(); - ScheduleEvent se; - if ( se.loadXML( e4 ) ) { - ProgramInformation pi = progInfoMap[ se.crid() ]; - //kdDebug() << "programme incidence: " << se.crid() << "," << se.startTime() << "," << se.duration() << "," << pi.title() << "," << pi.synopsis() << endl; - KCal::Event *event = new KCal::Event(); - event->setFloats( false ); - event->setSummary( pi.title() ); - event->setDescription( pi.synopsis() ); - event->setDtStart( KPimPrefs::localTimeToUtc( se.startTime(), "Europe/London" ) ); - event->setDuration( se.duration() ); - event->setLocation( service.name() ); - event->setCategories( pi.genres() ); - event->setUid( se.programUrl() ); - event->setCustomProperty( "TVANYWHERE", "SERVICEID", serviceId ); - // store the reverse mapping from event to service, for subresources - mUidMap.insert( event->uid(), serviceId ); - event->setReadOnly( true ); - - addIncidence( event ); - } - n4 = n4.nextSibling(); - } - } - else - kdDebug() << " file contains schedule for another service!" << endl; - } - } - } - n = n.nextSibling(); - } - } - else - kdDebug() << "Program location file: " << programLocationFileName << " not found in archive" << endl; - } - return true; -} - -TQStringList ResourceTVAnytime::subresources() const -{ - //const_cast<ResourceTVAnytime*>( this )->doLoad(); - return mServiceMap.keys(); -} - -const TQString -ResourceTVAnytime::labelForSubresource( const TQString& subresource ) const -{ - Service s = mServiceMap[ subresource ]; - return s.name(); -} - -TQString ResourceTVAnytime::subresourceIdentifier( Incidence *incidence ) -{ - return incidence->customProperty( "TVANYWHERE", "SERVICEID" ); -} - -bool ResourceTVAnytime::subresourceActive( const TQString & subresource ) const -{ - Service s = mServiceMap[ subresource ]; - return s.active(); -} - -void ResourceTVAnytime::setSubresourceActive( const TQString & subresource, bool active ) -{ - if ( mServiceMap.contains( subresource ) ) - { - Service s = mServiceMap[ subresource ]; - if ( s.active() != active ) - { - s.setActive( active ); - mServiceMap.insert( subresource, s ); - doLoad(); - mResourceChangedTimer.changeInterval( 150 ); - } - } -} - -KABC::Lock *ResourceTVAnytime::lock() -{ - return &mLock; -} - -void ResourceTVAnytime::cancelLoad() -{ - if ( mDownloadJob ) mDownloadJob->kill(); - mDownloadJob = 0; - if ( mProgress ) mProgress->setComplete(); - mProgress = 0; -} - -void ResourceTVAnytime::slotEmitResourceChanged() -{ - emit resourceChanged( this ); - mResourceChangedTimer.stop(); -} - -#include "kcal_resourcetvanytime.moc" |