You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
264 lines
8.9 KiB
264 lines
8.9 KiB
/**
|
|
* acljobs.cpp
|
|
*
|
|
* Copyright (c) 2004 David Faure <faure@kde.org>
|
|
*
|
|
*
|
|
* This program is free software; you can redistribute it and/or modify
|
|
* it under the terms of the GNU General Public License as published by
|
|
* the Free Software Foundation; version 2 of the License
|
|
*
|
|
* This program 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 General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU General Public License
|
|
* along with this program; if not, write to the Free Software
|
|
* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
|
|
*
|
|
* In addition, as a special exception, the copyright holders give
|
|
* permission to link the code of this program with any edition of
|
|
* the TQt library by Trolltech AS, Norway (or with modified versions
|
|
* of TQt that use the same license as TQt), and distribute linked
|
|
* combinations including the two. You must obey the GNU General
|
|
* Public License in all respects for all of the code used other than
|
|
* TQt. If you modify this file, you may extend this exception to
|
|
* your version of the file, but you are not obligated to do so. If
|
|
* you do not wish to do so, delete this exception statement from
|
|
* your version.
|
|
*/
|
|
#include "acljobs.h"
|
|
#include <kio/scheduler.h>
|
|
#include <kdebug.h>
|
|
|
|
using namespace KMail;
|
|
|
|
// Convert str to an ACLPermissions value.
|
|
// url and user are there only for the error message
|
|
static unsigned int IMAPRightsToPermission( const TQString& str, const KURL& url, const TQString& user ) {
|
|
unsigned int perm = 0;
|
|
uint len = str.length();
|
|
for (uint i = 0; i < len; ++i) {
|
|
TQChar ch = str[i];
|
|
switch ( ch.latin1() ) {
|
|
case 'l': perm |= ACLJobs::List; break;
|
|
case 'r': perm |= ACLJobs::Read; break;
|
|
case 's': perm |= ACLJobs::WriteSeenFlag; break;
|
|
case 'w': perm |= ACLJobs::WriteFlags; break;
|
|
case 'i': perm |= ACLJobs::Insert; break;
|
|
case 'p': perm |= ACLJobs::Post; break;
|
|
case 'k': // fall through
|
|
case 'c': perm |= ACLJobs::Create; break;
|
|
case 'x': // fall through
|
|
case 'd': perm |= ACLJobs::Delete; break;
|
|
case 'a': perm |= ACLJobs::Administer; break;
|
|
default: break;
|
|
}
|
|
}
|
|
if ( ( perm & ACLJobs::Read ) && !( perm & ACLJobs::WriteSeenFlag ) ) {
|
|
// Reading without 'seen' is, well, annoying. Unusable, even.
|
|
// So we treat 'rs' as a single one.
|
|
// But if the permissions were set out of kmail, better check that both are set
|
|
kdWarning(5006) << "IMAPRightsToPermission: found read (r) but not seen (s). Things will not work well for folder " << url << " and user " << ( user.isEmpty() ? "myself" : user ) << endl;
|
|
if ( perm & ACLJobs::Administer )
|
|
kdWarning(5006) << "You can change this yourself in the ACL dialog" << endl;
|
|
else
|
|
kdWarning(5006) << "Ask your admin for 's' permissions." << endl;
|
|
// Is the above correct enough to be turned into a KMessageBox?
|
|
}
|
|
|
|
return perm;
|
|
}
|
|
|
|
static TQCString permissionsToIMAPRights( unsigned int permissions ) {
|
|
TQCString str = "";
|
|
if ( permissions & ACLJobs::List )
|
|
str += 'l';
|
|
if ( permissions & ACLJobs::Read )
|
|
str += 'r';
|
|
if ( permissions & ACLJobs::WriteSeenFlag )
|
|
str += 's';
|
|
if ( permissions & ACLJobs::WriteFlags )
|
|
str += 'w';
|
|
if ( permissions & ACLJobs::Insert )
|
|
str += 'i';
|
|
if ( permissions & ACLJobs::Post )
|
|
str += 'p';
|
|
if ( permissions & ACLJobs::Create )
|
|
str += 'c';
|
|
if ( permissions & ACLJobs::Delete )
|
|
str += 'd';
|
|
if ( permissions & ACLJobs::Administer )
|
|
str += 'a';
|
|
return str;
|
|
}
|
|
|
|
#ifndef NDEBUG
|
|
TQString ACLJobs::permissionsToString( unsigned int permissions )
|
|
{
|
|
TQString str;
|
|
if ( permissions & ACLJobs::List )
|
|
str += "List ";
|
|
if ( permissions & ACLJobs::Read )
|
|
str += "Read ";
|
|
if ( permissions & ACLJobs::WriteFlags )
|
|
str += "Write ";
|
|
if ( permissions & ACLJobs::Insert )
|
|
str += "Insert ";
|
|
if ( permissions & ACLJobs::Post )
|
|
str += "Post ";
|
|
if ( permissions & ACLJobs::Create )
|
|
str += "Create ";
|
|
if ( permissions & ACLJobs::Delete )
|
|
str += "Delete ";
|
|
if ( permissions & ACLJobs::Administer )
|
|
str += "Administer ";
|
|
if ( !str.isEmpty() )
|
|
str.truncate( str.length() - 1 );
|
|
return str;
|
|
}
|
|
#endif
|
|
|
|
TDEIO::SimpleJob* ACLJobs::setACL( TDEIO::Slave* slave, const KURL& url, const TQString& user, unsigned int permissions )
|
|
{
|
|
TQString perm = TQString::fromLatin1( permissionsToIMAPRights( permissions ) );
|
|
|
|
TQByteArray packedArgs;
|
|
TQDataStream stream( packedArgs, IO_WriteOnly );
|
|
stream << (int)'A' << (int)'S' << url << user << perm;
|
|
|
|
TDEIO::SimpleJob* job = TDEIO::special( url, packedArgs, false );
|
|
TDEIO::Scheduler::assignJobToSlave( slave, job );
|
|
return job;
|
|
}
|
|
|
|
ACLJobs::DeleteACLJob* ACLJobs::deleteACL( TDEIO::Slave* slave, const KURL& url, const TQString& user )
|
|
{
|
|
TQByteArray packedArgs;
|
|
TQDataStream stream( packedArgs, IO_WriteOnly );
|
|
stream << (int)'A' << (int)'D' << url << user;
|
|
|
|
ACLJobs::DeleteACLJob* job = new ACLJobs::DeleteACLJob( url, user, packedArgs, false );
|
|
TDEIO::Scheduler::assignJobToSlave( slave, job );
|
|
return job;
|
|
}
|
|
|
|
ACLJobs::GetACLJob* ACLJobs::getACL( TDEIO::Slave* slave, const KURL& url )
|
|
{
|
|
TQByteArray packedArgs;
|
|
TQDataStream stream( packedArgs, IO_WriteOnly );
|
|
stream << (int)'A' << (int)'G' << url;
|
|
|
|
ACLJobs::GetACLJob* job = new ACLJobs::GetACLJob( url, packedArgs, false );
|
|
TDEIO::Scheduler::assignJobToSlave( slave, job );
|
|
return job;
|
|
}
|
|
|
|
ACLJobs::GetUserRightsJob* ACLJobs::getUserRights( TDEIO::Slave* slave, const KURL& url )
|
|
{
|
|
TQByteArray packedArgs;
|
|
TQDataStream stream( packedArgs, IO_WriteOnly );
|
|
stream << (int)'A' << (int)'M' << url;
|
|
|
|
ACLJobs::GetUserRightsJob* job = new ACLJobs::GetUserRightsJob( url, packedArgs, false );
|
|
TDEIO::Scheduler::assignJobToSlave( slave, job );
|
|
return job;
|
|
}
|
|
|
|
ACLJobs::GetACLJob::GetACLJob( const KURL& url, const TQByteArray &packedArgs,
|
|
bool showProgressInfo )
|
|
: TDEIO::SimpleJob( url, TDEIO::CMD_SPECIAL, packedArgs, showProgressInfo )
|
|
{
|
|
connect( this, TQT_SIGNAL(infoMessage(TDEIO::Job*,const TQString&)),
|
|
TQT_SLOT(slotInfoMessage(TDEIO::Job*,const TQString&)) );
|
|
}
|
|
|
|
void ACLJobs::GetACLJob::slotInfoMessage( TDEIO::Job*, const TQString& str )
|
|
{
|
|
// Parse the result
|
|
TQStringList lst = TQStringList::split( "\"", str, true );
|
|
while ( lst.count() >= 2 ) // we take items 2 by 2
|
|
{
|
|
TQString user = lst.front(); lst.pop_front();
|
|
TQString imapRights = lst.front(); lst.pop_front();
|
|
unsigned int perm = IMAPRightsToPermission( imapRights, url(), user );
|
|
m_entries.append( ACLListEntry( user, imapRights, perm ) );
|
|
}
|
|
}
|
|
|
|
ACLJobs::GetUserRightsJob::GetUserRightsJob( const KURL& url, const TQByteArray &packedArgs,
|
|
bool showProgressInfo )
|
|
: TDEIO::SimpleJob( url, TDEIO::CMD_SPECIAL, packedArgs, showProgressInfo )
|
|
{
|
|
connect( this, TQT_SIGNAL(infoMessage(TDEIO::Job*,const TQString&)),
|
|
TQT_SLOT(slotInfoMessage(TDEIO::Job*,const TQString&)) );
|
|
}
|
|
|
|
void ACLJobs::GetUserRightsJob::slotInfoMessage( TDEIO::Job*, const TQString& str )
|
|
{
|
|
// Parse the result
|
|
m_permissions = IMAPRightsToPermission( str, url(), TQString() );
|
|
}
|
|
|
|
ACLJobs::DeleteACLJob::DeleteACLJob( const KURL& url, const TQString& userId,
|
|
const TQByteArray &packedArgs,
|
|
bool showProgressInfo )
|
|
: TDEIO::SimpleJob( url, TDEIO::CMD_SPECIAL, packedArgs, showProgressInfo ),
|
|
mUserId( userId )
|
|
{
|
|
}
|
|
|
|
////
|
|
|
|
ACLJobs::MultiSetACLJob::MultiSetACLJob( TDEIO::Slave* slave, const KURL& url, const ACLList& acl, bool showProgressInfo )
|
|
: TDEIO::Job( showProgressInfo ),
|
|
mSlave( slave ),
|
|
mUrl( url ), mACLList( acl ), mACLListIterator( mACLList.begin() )
|
|
{
|
|
TQTimer::singleShot(0, this, TQT_SLOT(slotStart()));
|
|
}
|
|
|
|
void ACLJobs::MultiSetACLJob::slotStart()
|
|
{
|
|
// Skip over unchanged entries
|
|
while ( mACLListIterator != mACLList.end() && !(*mACLListIterator).changed )
|
|
++mACLListIterator;
|
|
|
|
if ( mACLListIterator != mACLList.end() )
|
|
{
|
|
const ACLListEntry& entry = *mACLListIterator;
|
|
TDEIO::Job* job = 0;
|
|
if ( entry.permissions > -1 )
|
|
job = setACL( mSlave, mUrl, entry.userId, entry.permissions );
|
|
else
|
|
job = deleteACL( mSlave, mUrl, entry.userId );
|
|
|
|
addSubjob( job );
|
|
} else { // done!
|
|
emitResult();
|
|
}
|
|
}
|
|
|
|
void ACLJobs::MultiSetACLJob::slotResult( TDEIO::Job *job )
|
|
{
|
|
if ( job->error() ) {
|
|
TDEIO::Job::slotResult( job ); // will set the error and emit result(this)
|
|
return;
|
|
}
|
|
subjobs.remove(job);
|
|
const ACLListEntry& entry = *mACLListIterator;
|
|
emit aclChanged( entry.userId, entry.permissions );
|
|
|
|
// Move on to next one
|
|
++mACLListIterator;
|
|
slotStart();
|
|
}
|
|
|
|
ACLJobs::MultiSetACLJob* ACLJobs::multiSetACL( TDEIO::Slave* slave, const KURL& url, const ACLList& acl )
|
|
{
|
|
return new MultiSetACLJob( slave, url, acl, false /*showProgressInfo*/ );
|
|
}
|
|
|
|
#include "acljobs.moc"
|