From b363d2579af0a11b77e698aed2e1021c2233b644 Mon Sep 17 00:00:00 2001 From: Timothy Pearson Date: Sat, 26 Jan 2013 13:17:50 -0600 Subject: Rename a number of libraries and executables to avoid conflicts with KDE4 --- tderesources/egroupware/knotes_resourcexmlrpc.cpp | 336 ++++++++++++++++++++++ 1 file changed, 336 insertions(+) create mode 100644 tderesources/egroupware/knotes_resourcexmlrpc.cpp (limited to 'tderesources/egroupware/knotes_resourcexmlrpc.cpp') diff --git a/tderesources/egroupware/knotes_resourcexmlrpc.cpp b/tderesources/egroupware/knotes_resourcexmlrpc.cpp new file mode 100644 index 000000000..1b19831bc --- /dev/null +++ b/tderesources/egroupware/knotes_resourcexmlrpc.cpp @@ -0,0 +1,336 @@ +/* + This file is part of tdepim. + + Copyright (c) 2004 Tobias Koenig + + 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 +#include + +#include +#include +#include +#include +#include + +#include "libkcal/journal.h" + +#include "knotes/resourcemanager.h" + +#include "knotes_egroupwareprefs.h" +#include "knotes_resourcexmlrpc.h" +#include "knotes_resourcexmlrpcconfig.h" + +#include "synchronizer.h" +#include "xmlrpciface.h" + +using namespace KNotes; + +typedef KRES::PluginFactory< ResourceXMLRPC, ResourceXMLRPCConfig> XMLRPCFactory; +K_EXPORT_COMPONENT_FACTORY( knotes_xmlrpc, XMLRPCFactory ) + +static const TQString SearchNotesCommand = "infolog.boinfolog.search"; +static const TQString AddNoteCommand = "infolog.boinfolog.write"; +static const TQString DeleteNoteCommand = "infolog.boinfolog.delete"; +static const TQString LoadNoteCategoriesCommand = "infolog.boinfolog.categories"; + +ResourceXMLRPC::ResourceXMLRPC( const TDEConfig* config ) + : ResourceNotes( config ), mCalendar( TQString::fromLatin1("UTC") ), + mServer( 0 ) +{ + init(); + + mPrefs->addGroupPrefix( identifier() ); + + if ( config ) { + readConfig( config ); + } else { + setResourceName( i18n( "eGroupware Server" ) ); + } +} + +ResourceXMLRPC::ResourceXMLRPC( ) + : ResourceNotes( 0 ), mCalendar( TQString::fromLatin1("UTC") ), + mServer( 0 ) +{ + init(); + + mPrefs->addGroupPrefix( identifier() ); +} + +ResourceXMLRPC::~ResourceXMLRPC() +{ + delete mServer; + mServer = 0; + + delete mPrefs; + mPrefs = 0; + + delete mSynchronizer; + mSynchronizer = 0; +} + +void ResourceXMLRPC::init() +{ + setType( "xmlrpc" ); + + mPrefs = new EGroupwarePrefs; + + mSynchronizer = new Synchronizer; +} + +void ResourceXMLRPC::readConfig( const TDEConfig* ) +{ + mPrefs->readConfig(); +} + +void ResourceXMLRPC::writeConfig( TDEConfig* config ) +{ + ResourceNotes::writeConfig( config ); + + mPrefs->writeConfig(); +} + +bool ResourceXMLRPC::load() +{ + mCalendar.close(); + + if ( mServer ) + delete mServer; + + mServer = new KXMLRPC::Server( KURL(), this ); + mServer->setUrl( KURL( mPrefs->url() ) ); + mServer->setUserAgent( "KDE-Notes" ); + + TQMap args, columns; + args.insert( "domain", mPrefs->domain() ); + args.insert( "username", mPrefs->user() ); + args.insert( "password", mPrefs->password() ); + + mServer->call( "system.login", TQVariant( args ), + this, TQT_SLOT( loginFinished( const TQValueList&, const TQVariant& ) ), + this, TQT_SLOT( fault( int, const TQString&, const TQVariant& ) ) ); + + mSynchronizer->start(); + + columns.insert( "type", "note" ); + args.clear(); + args.insert( "filter", "none" ); + args.insert( "col_filter", columns ); + args.insert( "order", "id_parent" ); + + mServer->call( SearchNotesCommand, args, + this, TQT_SLOT( listNotesFinished( const TQValueList&, const TQVariant& ) ), + this, TQT_SLOT( fault( int, const TQString&, const TQVariant& ) ) ); + + mSynchronizer->start(); + + return true; +} + +bool ResourceXMLRPC::save() +{ + mCalendar.close(); + + return true; +} + +bool ResourceXMLRPC::addNote( KCal::Journal *journal ) +{ + TQMap args; + writeNote( journal, args ); + + KCal::Journal *oldJournal = mCalendar.journal( journal->uid() ); + + bool added = false; + if ( oldJournal ) { + if ( !oldJournal->isReadOnly() ) { + writeNote( journal, args ); + args.insert( "id", mUidMap[ journal->uid() ].toInt() ); + mServer->call( AddNoteCommand, TQVariant( args ), + this, TQT_SLOT( updateNoteFinished( const TQValueList&, const TQVariant& ) ), + this, TQT_SLOT( fault( int, const TQString&, const TQVariant& ) ) ); + mCalendar.addJournal( journal ); + added = true; + } + } else { + mServer->call( AddNoteCommand, TQVariant( args ), + this, TQT_SLOT( addNoteFinished( const TQValueList&, const TQVariant& ) ), + this, TQT_SLOT( fault( int, const TQString&, const TQVariant& ) ), + TQVariant( journal->uid() ) ); + + mCalendar.addJournal( journal ); + added = true; + } + + if ( added ) + mSynchronizer->start(); + + return true; +} + +bool ResourceXMLRPC::deleteNote( KCal::Journal *journal ) +{ + int id = mUidMap[ journal->uid() ].toInt(); + + mServer->call( DeleteNoteCommand, id, + this, TQT_SLOT( deleteNoteFinished( const TQValueList&, const TQVariant& ) ), + this, TQT_SLOT( fault( int, const TQString&, const TQVariant& ) ), + TQVariant( journal->uid() ) ); + mSynchronizer->start(); + + return true; +} + +KCal::Alarm::List ResourceXMLRPC::alarms( const TQDateTime& from, const TQDateTime& to ) +{ + KCal::Alarm::List alarms; + KCal::Journal::List notes = mCalendar.journals(); + KCal::Journal::List::ConstIterator note; + for ( note = notes.begin(); note != notes.end(); ++note ) + { + TQDateTime preTime = from.addSecs( -1 ); + KCal::Alarm::List::ConstIterator it; + for( it = (*note)->alarms().begin(); it != (*note)->alarms().end(); ++it ) + { + if ( (*it)->enabled() ) + { + TQDateTime dt = (*it)->nextRepetition( preTime ); + if ( dt.isValid() && dt <= to ) + alarms.append( *it ); + } + } + } + + return alarms; +} + +void ResourceXMLRPC::loginFinished( const TQValueList& variant, + const TQVariant& ) +{ + TQMap map = variant[ 0 ].toMap(); + + KURL url = KURL( mPrefs->url() ); + if ( map[ "GOAWAY" ].toString() == "XOXO" ) { // failed + mSessionID = mKp3 = ""; + } else { + mSessionID = map[ "sessionid" ].toString(); + mKp3 = map[ "kp3" ].toString(); + } + + url.setUser( mSessionID ); + url.setPass( mKp3 ); + mServer->setUrl( url ); + + mSynchronizer->stop(); +} + +void ResourceXMLRPC::logoutFinished( const TQValueList& variant, + const TQVariant& ) +{ + TQMap map = variant[ 0 ].toMap(); + + if ( map[ "GOODBYE" ].toString() != "XOXO" ) + kdError() << "logout failed" << endl; + + KURL url = KURL( mPrefs->url() ); + mSessionID = mKp3 = ""; + url.setUser( mSessionID ); + url.setPass( mKp3 ); + mServer->setUrl( url ); + + mSynchronizer->stop(); +} + +void ResourceXMLRPC::listNotesFinished( const TQValueList &list, const TQVariant& ) +{ + TQMap::Iterator uidIt; + for ( uidIt = mUidMap.begin(); uidIt != mUidMap.end(); ++uidIt ) { + KCal::Journal *journal = mCalendar.journal( uidIt.key() ); + mCalendar.deleteJournal( journal ); + } + + mUidMap.clear(); + + TQValueList noteList = list[ 0 ].toList(); + TQValueList::Iterator noteIt; + + for ( noteIt = noteList.begin(); noteIt != noteList.end(); ++noteIt ) { + TQMap map = (*noteIt).toMap(); + + KCal::Journal *journal = new KCal::Journal(); + + TQString uid; + readNote( map, journal, uid ); + mUidMap.insert( journal->uid(), uid ); + + mCalendar.addJournal( journal ); + manager()->registerNote( this, journal ); + } + + mSynchronizer->stop(); +} + +void ResourceXMLRPC::addNoteFinished( const TQValueList &list, const TQVariant &id ) +{ + int uid = list[ 0 ].toInt(); + mUidMap.insert( id.toString(), TQString::number( uid ) ); + + mSynchronizer->stop(); +} + +void ResourceXMLRPC::updateNoteFinished( const TQValueList&, const TQVariant& ) +{ + mSynchronizer->stop(); +} + +void ResourceXMLRPC::deleteNoteFinished( const TQValueList&, const TQVariant &id ) +{ + mUidMap.erase( id.toString() ); + + KCal::Journal *journal = mCalendar.journal( id.toString() ); + mCalendar.deleteJournal( journal ); + + mSynchronizer->stop(); +} + +void ResourceXMLRPC::fault( int error, const TQString& errorMsg, const TQVariant& ) +{ + kdError() << "Server send error " << error << ": " << errorMsg << endl; + mSynchronizer->stop(); +} + +void ResourceXMLRPC::writeNote( KCal::Journal* journal, TQMap& args ) +{ + args.insert( "subject", journal->summary() ); + args.insert( "des", journal->description() ); + args.insert( "access", + (journal->secrecy() == KCal::Journal::SecrecyPublic ? "public" : "private" ) ); +} + +void ResourceXMLRPC::readNote( const TQMap& args, KCal::Journal *journal, TQString &uid ) +{ + uid = args[ "id" ].toString(); + + journal->setSummary( args[ "subject" ].toString() ); + journal->setDescription( args[ "des" ].toString() ); + journal->setSecrecy( args[ "access" ].toString() == "public" ? + KCal::Journal::SecrecyPublic : KCal::Journal::SecrecyPrivate ); +} + +#include "knotes_resourcexmlrpc.moc" -- cgit v1.2.1