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.
tdepim/tdeioslave/mbox/mbox.cpp

169 lines
3.5 KiB

/*
* This is a simple tdeioslave to handle mbox-files.
* Copyright (C) 2004 Mart Kelder (mart.kde@hccnet.nl)
*
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser 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
* Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public
* License along with this library; if not, write to the Free Software
* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
*/
#include "mbox.h"
#include "readmbox.h"
#include "stat.h"
#include "urlinfo.h"
#include <tqstring.h>
#include <tqcstring.h>
#include <kdebug.h>
#include <tdelocale.h>
#include <kinstance.h>
#include <tdeglobal.h>
#include <kurl.h>
#include <tdeio/global.h>
#include <stdlib.h>
#include <kdemacros.h>
#include "mbox.h"
extern "C" { KDE_EXPORT int kdemain(int argc, char* argv[]); }
int kdemain( int argc, char * argv[] )
{
TDELocale::setMainCatalogue("tdelibs");
TDEInstance instance("tdeio_mbox");
(void) TDEGlobal::locale();
if (argc != 4) {
fprintf(stderr, "Usage: tdeio_mbox protocol "
"domain-socket1 domain-socket2\n");
exit(-1);
}
MBoxProtocol slave(argv[2], argv[3]);
slave.dispatchLoop();
return 0;
}
MBoxProtocol::MBoxProtocol( const TQCString& arg1, const TQCString& arg2 )
: TDEIO::SlaveBase( "mbox2", arg1, arg2 ),
m_errorState( true )
{
}
MBoxProtocol::~MBoxProtocol()
{
}
void MBoxProtocol::get( const KURL& url )
{
m_errorState = false;
UrlInfo info( url, UrlInfo::message );
TQString line;
TQByteArray ba_line;
if( info.type() == UrlInfo::invalid && !m_errorState )
{
error( TDEIO::ERR_DOES_NOT_EXIST, info.url() );
return;
}
ReadMBox mbox( &info, this );
while( !mbox.atEnd() && !m_errorState)
{
line = mbox.currentLine();
line += '\n';
ba_line = TQCString( line.utf8() );
ba_line.truncate( ba_line.size() - 1 ); //Removing training '\0'
data( ba_line );
mbox.nextLine();
};
if( !m_errorState )
{
data( TQByteArray() );
finished();
}
}
void MBoxProtocol::listDir( const KURL& url )
{
m_errorState = false;
TDEIO::UDSEntry entry;
UrlInfo info( url, UrlInfo::directory );
ReadMBox mbox( &info, this, hasMetaData( "onlynew" ), hasMetaData( "savetime" ) );
if( m_errorState )
return;
if( info.type() != UrlInfo::directory )
{
error( TDEIO::ERR_DOES_NOT_EXIST, info.url() );
return;
}
while( !mbox.atEnd() && !m_errorState )
{
entry = Stat::stat( mbox, info );
if( mbox.inListing() )
listEntry( entry, false );
}
listEntry( TDEIO::UDSEntry(), true );
finished();
}
void MBoxProtocol::stat( const KURL& url )
{
UrlInfo info( url );
if( info.type() == UrlInfo::invalid )
{
error( TDEIO::ERR_DOES_NOT_EXIST, url.path() );
return;
} else
{
statEntry( Stat::stat( info ) );
}
finished();
}
void MBoxProtocol::mimetype( const KURL& url )
{
m_errorState = false;
UrlInfo info( url );
if( m_errorState )
return;
if( info.type() == UrlInfo::invalid )
error( TDEIO::ERR_DOES_NOT_EXIST, i18n( "Invalid URL" ) );
else
mimeType( info.mimetype() );
finished();
}
void MBoxProtocol::emitError( int errno, const TQString& arg )
{
m_errorState = true;
error( errno, arg );
}