#include "convert.h"
//#include "conversionoptions.h"
#include "convertpluginloader.h"
#include "replaygainpluginloader.h"
#include "replaygain.h"
#include "ripperpluginloader.h"
#include "config.h"
#include "tagengine.h"
#include "cdmanager.h"
#include "logger.h"
#include "filelist.h"
#include "replaygainscanner.h"

#include <math.h>

#include <klocale.h>
#include <kglobal.h>
//#include <kdebug.h>
#include <ktempfile.h>
#include <kio/job.h>
//#include <kprocess.h>
#include <kstandarddirs.h>

#include <tqfile.h>
#include <tqtimer.h>

ConvertItem::ConvertItem()
{
    // create a new item with the file list item pointer set to zero
    ConvertItem( (FileListItem*)0 );
}

ConvertItem::ConvertItem( FileListItem* item )
{
    fileListItem = item;
    getTime = getCorrectionTime = ripTime = decodeTime = encodeTime = replaygainTime = 0;
}

ConvertItem::~ConvertItem()
{}


Convert::Convert( Config* _config, TagEngine* _tagEngine, CDManager* _cdManager, FileList* _fileList, Logger* _logger )
{
    config = _config;
    tagEngine = _tagEngine;
    cdManager = _cdManager;
    fileList = _fileList;
    connect( fileList, TQT_SIGNAL(convertItem(FileListItem*)),
               this, TQT_SLOT(add(FileListItem*))
             );
    connect( fileList, TQT_SIGNAL(stopItem(FileListItem*)),
               this, TQT_SLOT(stop(FileListItem*))
             );
    connect( this, TQT_SIGNAL(finished(FileListItem*,int)),
               fileList, TQT_SLOT(itemFinished(FileListItem*,int))
             );
    connect( this, TQT_SIGNAL(rippingFinished(const TQString&)),
               fileList, TQT_SLOT(rippingFinished(const TQString&))
             );
    logger = _logger;
    connect( this, TQT_SIGNAL(finishedProcess(int,int)),
               logger, TQT_SLOT(processCompleted(int,int))
             );

    tUpdateProgressIndicator = new TQTimer( this, "tUpdateProgressIndicator" );
    connect( tUpdateProgressIndicator, TQT_SIGNAL(timeout()),
               this, TQT_SLOT(updateProgressIndicator())
             );
}

Convert::~Convert()
{}

void Convert::cleanUp()
{
    // TODO clean up
}

void Convert::get( ConvertItem* item )
{
    logger->log( item->logID, i18n("Getting file") );
    item->state = ConvertItem::get;

    item->fileListItem->setText( fileList->columnByName(i18n("State")), i18n("Getting file")+"... 00 %" );

    KURL source( item->fileListItem->options.filePathName.tqreplace("?","%3f") );
    KURL destination( item->tempInFile->name() );

    if( source.isLocalFile() && destination.isLocalFile() ) {
        item->convertProcess->clearArguments();

        *(item->convertProcess) << "cp";
        *(item->convertProcess) << source.path();
        *(item->convertProcess) << destination.path();

        logger->log( item->logID, "cp \"" + source.path() + "\" \"" + destination.path() + "\"" );

        item->convertProcess->setPriority( config->data.general.priority );
        item->convertProcess->start( KProcess::NotifyOnExit, KProcess::AllOutput );
    }
    else {
        item->moveJob = new KIO::FileCopyJob( source, destination, -1, false, true, false, false );
        connect( item->moveJob, TQT_SIGNAL(percent(KIO::Job*,unsigned long)),
                this, TQT_SLOT(moveProgress(KIO::Job*,unsigned long))
                );
        connect( item->moveJob, TQT_SIGNAL(result(KIO::Job*)),
                this, TQT_SLOT(moveFinished(KIO::Job*))
                );
    }
}

void Convert::getCorrection( ConvertItem* item )
{
    logger->log( item->logID, i18n("Getting correction file") );
    item->state = ConvertItem::get_correction;

    // calculate the name of the correction input file
    TQFile file( OutputDirectory::changeExtension(item->fileListItem->options.filePathName,item->correctionInputExtension) );
    if( !file.exists() ) {
        logger->log( item->logID, " " + i18n("Aborting, file does not exist") + " (" + file.name() + ")" );
        executeNextStep( item );
        return;
    }

    KURL source( file.name() );
    KURL destination( item->correctionInFile );

    item->fileListItem->setText( fileList->columnByName(i18n("State")), i18n("Getting correction file")+"... 00 %" );

    if( source.isLocalFile() && destination.isLocalFile() ) {
        item->convertProcess->clearArguments();

        *(item->convertProcess) << "cp";
        *(item->convertProcess) << source.path();
        *(item->convertProcess) << destination.path();

        logger->log( item->logID, "cp \"" + source.path() + "\" \"" + destination.path() + "\"" );

        item->convertProcess->setPriority( config->data.general.priority );
        item->convertProcess->start( KProcess::NotifyOnExit, KProcess::AllOutput );
    }
    else {
        item->moveJob = new KIO::FileCopyJob( source, destination, -1, false, true, false, false );
        connect( item->moveJob, TQT_SIGNAL(percent(KIO::Job*,unsigned long)),
                this, TQT_SLOT(moveProgress(KIO::Job*,unsigned long))
                );
        connect( item->moveJob, TQT_SIGNAL(result(KIO::Job*)),
                this, TQT_SLOT(moveFinished(KIO::Job*))
                );
    }
}

void Convert::rip( ConvertItem* item )
{
    logger->log( item->logID, i18n("Ripping") );
    item->state = ConvertItem::rip;

/** kaudiocreator
	TQString wavFile;
	TQString args = job->device;
	if(!args.isEmpty())
		args = TQString("?device=%1").tqarg(args);
	args = args+"&fileNameTemplate=Track %{number}";
	if(job->track < 10)
		wavFile = TQString("audiocd:/Wav/Track 0%1.wav%2").tqarg(job->track).tqarg(args);
	else
		wavFile = TQString("audiocd:/Wav/Track %1.wav%2").tqarg(job->track).tqarg(args);
*/

    RipperPlugin* plugin = config->getCurrentRipper();

    if( plugin == 0 ) {
        // NOTE process devices like '/dev/cdrom' - seems to be done
        // TODO implement process priority (nice level)
        TQString src;
        if( item->fileListItem->track != 0 ) {
            // TODO does it work with cds with less than 10 tracks?
            src.sprintf( "audiocd:/Wav/Track %02i.wav?device=" + item->fileListItem->device + "&fileNameTemplate=Track %%{number}", item->fileListItem->track );
        }
        else {
            // FIXME implement ripping of full cds
            src = "audiocd:/Full CD/Full CD.wav?device=" + item->fileListItem->device + "&albumTemplate=Full CD";
            item->tracks = 1;
        }
        KURL source( src );
        KURL dest( item->tempWavFile->name() );

        item->fileListItem->setText( fileList->columnByName(i18n("State")), i18n("Ripping")+"... 00 %" );
        item->fileListItem->ripping = true;

        item->moveJob = new KIO::FileCopyJob( source, dest, -1, false, true, false, false );
        connect( item->moveJob, TQT_SIGNAL(percent(KIO::Job*,unsigned long)),
                   this, TQT_SLOT(moveProgress(KIO::Job*,unsigned long))
                 );
        connect( item->moveJob, TQT_SIGNAL(result(KIO::Job*)),
                   this, TQT_SLOT(moveFinished(KIO::Job*))
                 );
    }
    else {
        TQStringList params;
        TQString param, paramSplinter;


        item->convertProcess->clearArguments();

        param = TQString();
        if( plugin->rip.param ) param.append( " " + plugin->rip.param );
        if( plugin->rip.device ) param.append( " " + plugin->rip.device );
        if( plugin->rip.overwrite ) param.append( " " + plugin->rip.overwrite );

        if( item->fileListItem->track != 0 ) {
            if( plugin->rip.track ) param.append( " " + plugin->rip.track );
        }
        else {
            if( plugin->rip.full_disc.param ) param.append( " " + plugin->rip.full_disc.param );
            item->tracks = cdManager->getTrackCount( item->fileListItem->device );
            item->track = 0;
        }

//         if( plugin->rip.out_file.tqfind("%p") != -1 ) {
//             TQString t_str = plugin->rip.out_file;
//             t_str.tqreplace( "%p", param );
//             param = plugin->rip.bin + " " + t_str;
//         }
//         else {
//             param = plugin->rip.bin + param + " " + plugin->rip.out_file;
//         }

        TQString t_str = plugin->rip.out_file;
        t_str.tqreplace( "%p", param );
        param = config->binaries[plugin->rip.bin] + " " + t_str;

        param.simplifyWhiteSpace();

        params = TQStringList::split( ' ', param );

        for( TQStringList::Iterator it = params.begin(); it != params.end(); ++it )
        {
            paramSplinter = *it;
            paramSplinter.tqreplace( "%d", item->fileListItem->device );
            paramSplinter.tqreplace( "%t", TQString().sprintf("%i",item->fileListItem->track) );
            paramSplinter.tqreplace( "%n", TQString().sprintf("%i",cdManager->getTrackCount(item->fileListItem->device)) );
            paramSplinter.tqreplace( "%o", item->tempWavFile->name() );
            *(item->convertProcess) << paramSplinter;
        }

        param.tqreplace( "%d", item->fileListItem->device );
        param.tqreplace( "%t", TQString().sprintf("%i",item->fileListItem->track) );
        param.tqreplace( "%n", TQString().sprintf("%i",cdManager->getTrackCount(item->fileListItem->device)) );
        param.tqreplace( "%o", "\""+item->tempWavFile->name()+"\"" );
        logger->log( item->logID, param );

        //kdDebug() << " Executing: `" << param << "'" << endl;

        //item->readOutputTimer.start();
        item->lastOutputTimer.start();

        item->fileListItem->setText( fileList->columnByName(i18n("State")), i18n("Ripping")+"... 00 %" );
        item->fileListItem->ripping = true;

        item->convertProcess->setPriority( config->data.general.priority );
        item->convertProcess->start( KProcess::NotifyOnExit, KProcess::AllOutput );
    }
}

void Convert::decode( ConvertItem* item )
{
    logger->log( item->logID, i18n("Decoding") );
    item->state = ConvertItem::decode;

    TQStringList params;
    TQString param, paramSplinter;

    item->convertProcess->clearArguments();

    ConvertPlugin* plugin = config->decoderForFormat( item->fileListItem->mimeType );
    if( plugin == 0 ) {
        logger->log( item->logID, " NULL POINTER: Convert::decode( ... ) / plugin" );
        return;
    }

    param = "";
    if( !plugin->dec.param.isEmpty() ) param.append( " " + plugin->dec.param );
    if( !plugin->dec.overwrite.isEmpty() ) param.append( " " + plugin->dec.overwrite );

    TQString t_str = plugin->dec.in_out_files;
    t_str.tqreplace( "%p", param );
    param = config->binaries[plugin->dec.bin] + " " + t_str;

    param = param.simplifyWhiteSpace();

    params = TQStringList::split( ' ', param );

    for( TQStringList::Iterator it = params.begin(); it != params.end(); ++it )
    {
        paramSplinter = *it;
        paramSplinter.tqreplace( "%i", item->tempInFile->name() );
        paramSplinter.tqreplace( "%o", item->tempWavFile->name() );
        *(item->convertProcess) << paramSplinter;
    }

    param.tqreplace( "%i", "\""+item->tempInFile->name()+"\"" );
    param.tqreplace( "%o", "\""+item->tempWavFile->name()+"\"" );
    //item->log = param;
    logger->log( item->logID, param );

    //kdDebug() << " Executing: `" << param << "'" << endl;

    //item->readOutputTimer.start();
    item->lastOutputTimer.start();

    item->fileListItem->setText( fileList->columnByName(i18n("State")), i18n("Decoding")+"... 00 %" );

    item->convertProcess->setPriority( config->data.general.priority );
    item->convertProcess->start( KProcess::NotifyOnExit, KProcess::AllOutput );
}

void Convert::encode( ConvertItem* item )
{
    // TODO test quality profiles (never done)

    TQString sStrength;
    TQString sBitrate;
    TQString sQuality;
    TQString sMinBitrate;
    TQString sMaxBitrate;
    TQString sSamplingRate;

    int t_int;
    float t_float;

    logger->log( item->logID, i18n("Encoding") );
    item->state = ConvertItem::encode;

    TQStringList params;
    TQString param, paramSplinter;

    item->convertProcess->clearArguments();

    // NOTE use mimetype
    FormatItem* formatItem = config->getFormatItem( item->fileListItem->options.encodingOptions.sFormat );
    if( formatItem == 0 ) {
        //kdDebug() << "NULL POINTER: `" << "Convert::encode( ... ) / formatItem" << "'" << endl;
        logger->log( 1000, "NULL POINTER: `Convert::encode( ... ) / formatItem'" );
        return;
    }
    ConvertPlugin* plugin = formatItem->encoder;
    if( plugin == 0 ) {
        //kdDebug() << "NULL POINTER: `" << "Convert::encode( ... ) / plugin" << "'" << endl;
        logger->log( 1000, "NULL POINTER: `Convert::encode( ... ) / plugin'" );
        return;
    }

//     item->binary = plugin->enc.bin;

    param = "";
    if( !plugin->enc.param.isEmpty() ) param.append( " " + plugin->enc.param );
    if( !plugin->enc.overwrite.isEmpty() ) param.append( " " + plugin->enc.overwrite );

    if( plugin->enc.strength.enabled ) {
        param.append( " " + plugin->enc.strength.param );
        int compressionLevel = formatItem->compressionLevel;

        if( plugin->enc.strength.profiles.empty() ) {
            if( plugin->enc.strength.step < 1 ) {
                if( plugin->enc.strength.range_max >= plugin->enc.strength.range_min )
                    sStrength = TQString::number( compressionLevel * plugin->enc.strength.step );
                else
                    sStrength = TQString::number( plugin->enc.strength.range_min - compressionLevel * plugin->enc.strength.step );
            }
            else {
                if( plugin->enc.strength.range_max >= plugin->enc.strength.range_min )
                    sStrength = TQString::number( int(compressionLevel * plugin->enc.strength.step) );
                else
                    sStrength = TQString::number( int(plugin->enc.strength.range_min - compressionLevel * plugin->enc.strength.step) );
            }
            if( plugin->enc.strength.separator != '.' ) sStrength.tqreplace( TQChar('.'), plugin->enc.strength.separator );
        }
        else {
            TQStringList::Iterator it = plugin->enc.strength.profiles.at( compressionLevel );
            sStrength = *it;
        }
    }

    if( item->fileListItem->options.encodingOptions.sQualityMode == i18n("Bitrate") ) {
        if( item->fileListItem->options.encodingOptions.sBitrateMode == "cbr" && plugin->enc.lossy.bitrate.cbr.enabled ) {
            param.append( " " + plugin->enc.lossy.bitrate.cbr.param );
            sBitrate = TQString::number( item->fileListItem->options.encodingOptions.iQuality );
        }
        else if( item->fileListItem->options.encodingOptions.sBitrateMode == "abr" && plugin->enc.lossy.bitrate.abr.enabled ) {
            param.append( " " + plugin->enc.lossy.bitrate.abr.param );
            sBitrate = TQString::number( item->fileListItem->options.encodingOptions.iQuality );
            if( item->fileListItem->options.encodingOptions.bBitrateRange && plugin->enc.lossy.bitrate.abr.bitrate_range.enabled ) {
                param.append( " " + plugin->enc.lossy.bitrate.abr.bitrate_range.param_min );
                sMinBitrate = TQString::number( item->fileListItem->options.encodingOptions.iMinBitrate );
                param.append( " " + plugin->enc.lossy.bitrate.abr.bitrate_range.param_max );
                sMaxBitrate = TQString::number( item->fileListItem->options.encodingOptions.iMaxBitrate );
            }
        }
    }
    else if( item->fileListItem->options.encodingOptions.sQualityMode == i18n("Quality") && plugin->enc.lossy.quality.enabled ) {
        param.append( " " + plugin->enc.lossy.quality.param );
        if( plugin->enc.lossy.quality.profiles.empty() ) {
            if( plugin->enc.lossy.quality.step < 1 ) {
                if( plugin->enc.lossy.quality.range_max >= plugin->enc.lossy.quality.range_min)
                    t_float = ( (float)item->fileListItem->options.encodingOptions.iQuality * ( plugin->enc.lossy.quality.range_max - plugin->enc.lossy.quality.range_min ) / 100 ) + plugin->enc.lossy.quality.range_min;
                else
                    t_float = ( (100.0f - (float)item->fileListItem->options.encodingOptions.iQuality) * ( plugin->enc.lossy.quality.range_min - plugin->enc.lossy.quality.range_max ) / 100 ) + plugin->enc.lossy.quality.range_max;
                //t_float -= t_float%plugin->enc.quality.step;
                //sQuality = TQString().sprintf( "%.2f", t_float );
                sQuality = TQString::number( t_float );
            }
            else {
                if( plugin->enc.lossy.quality.range_max >= plugin->enc.lossy.quality.range_min)
                    t_int = ( item->fileListItem->options.encodingOptions.iQuality * (int)( plugin->enc.lossy.quality.range_max - plugin->enc.lossy.quality.range_min ) / 100) + (int)plugin->enc.lossy.quality.range_min;
                else
                    t_int = ( (100 - item->fileListItem->options.encodingOptions.iQuality) * (int)( plugin->enc.lossy.quality.range_min - plugin->enc.lossy.quality.range_max ) / 100) + (int)plugin->enc.lossy.quality.range_max;
                //t_int -= t_int%plugin->enc.quality.step;
                sQuality = TQString::number( t_int );
            }
            if( plugin->enc.bin == "oggenc" ) sQuality.tqreplace(TQChar('.'),KGlobal::locale()->decimalSymbol()); // HACK make oggenc usable with all langauges
            else if( plugin->enc.lossy.quality.separator != '.' ) sQuality.tqreplace(TQChar('.'),plugin->enc.lossy.quality.separator);
        }
        else {
            TQStringList::Iterator it = plugin->enc.lossy.quality.profiles.at( rint(item->fileListItem->options.encodingOptions.iQuality*plugin->enc.lossy.quality.range_max/100) );
            sQuality = *it;
        }
    }
    else if( item->fileListItem->options.encodingOptions.sQualityMode == i18n("Lossless") && plugin->enc.lossless.enabled ) {
        param.append( " " + plugin->enc.lossless.param );
    }
    else if( item->fileListItem->options.encodingOptions.sQualityMode == i18n("Hybrid") && plugin->enc.hybrid.enabled ) {
        param.append( " " + plugin->enc.hybrid.param );
        sBitrate = TQString::number( item->fileListItem->options.encodingOptions.iQuality );
    }

    if( item->fileListItem->options.encodingOptions.samplingRate.bEnabled && plugin->enc.lossy.samplingrate.enabled ) {
        param.append( " " + plugin->enc.lossy.samplingrate.param );
        if( plugin->enc.lossy.samplingrate.unit == PluginLoaderBase::Hz ) {
            sSamplingRate = TQString::number( item->fileListItem->options.encodingOptions.samplingRate.iSamplingRate );
        }
        else {
            sSamplingRate = TQString::number( (float)item->fileListItem->options.encodingOptions.samplingRate.iSamplingRate/1000 );
        }
    }

    if( item->fileListItem->options.encodingOptions.channels.bEnabled ) {
        if( item->fileListItem->options.encodingOptions.channels.sChannels == i18n("Mono") && plugin->enc.lossy.channels.mono_enabled ) {
            param.append( " " + plugin->enc.lossy.channels.mono_param );
        }
        else if( item->fileListItem->options.encodingOptions.channels.sChannels == i18n("Stereo") && plugin->enc.lossy.channels.stereo_enabled ) {
            param.append( " " + plugin->enc.lossy.channels.stereo_param );
        }
        else if( item->fileListItem->options.encodingOptions.channels.sChannels == i18n("Joint-Stereo") && plugin->enc.lossy.channels.joint_stereo_enabled ) {
            param.append( " " + plugin->enc.lossy.channels.joint_stereo_param );
        }
        else if( item->fileListItem->options.encodingOptions.channels.sChannels == i18n("Forced Joint-Stereo") && plugin->enc.lossy.channels.forced_joint_stereo_enabled ) {
            param.append( " " + plugin->enc.lossy.channels.forced_joint_stereo_param );
        }
        else if( item->fileListItem->options.encodingOptions.channels.sChannels == i18n("Dual Channels") && plugin->enc.lossy.channels.dual_channels_enabled ) {
            param.append( " " + plugin->enc.lossy.channels.dual_channels_param );
        }
    }

    if( item->fileListItem->options.encodingOptions.replaygain.bEnabled && plugin->enc.replaygain.enabled && plugin->enc.replaygain.use && formatItem->internalReplayGain ) {
        param.append( " " + plugin->enc.replaygain.use );
    }
    else if( plugin->enc.replaygain.enabled && plugin->enc.replaygain.avoid ) {
        param.append( " " + plugin->enc.replaygain.avoid );
    }

//     if( !tagEngine->canWrite(item->fileListItem->options.encodingOptions.sFormat) && item->fileListItem->tags && plugin->enc.tag.enabled ) {
    if( item->fileListItem->tags && plugin->enc.tag.enabled && item->fileListItem->options.encodingOptions.sFormat != "aac" ) { // HACK don't write metadata to aac
        if( !plugin->enc.tag.param.isEmpty() ) param.append( " " + plugin->enc.tag.param );
        if( !plugin->enc.tag.artist.isEmpty() && !item->fileListItem->tags->artist.isEmpty() ) param.append( " " + plugin->enc.tag.artist );
        if( !plugin->enc.tag.album.isEmpty() && !item->fileListItem->tags->album.isEmpty() ) param.append( " " + plugin->enc.tag.album );
        if( !plugin->enc.tag.comment.isEmpty() && !item->fileListItem->tags->comment.isEmpty() ) param.append( " " + plugin->enc.tag.comment );
        if( !plugin->enc.tag.disc.isEmpty() && item->fileListItem->tags->disc != 0 ) param.append( " " + plugin->enc.tag.disc );
        if( !plugin->enc.tag.genre.isEmpty() && !item->fileListItem->tags->genre.isEmpty() ) param.append( " " + plugin->enc.tag.genre );
        if( !plugin->enc.tag.track.isEmpty() && item->fileListItem->tags->track != 0 ) param.append( " " + plugin->enc.tag.track );
        if( !plugin->enc.tag.composer.isEmpty() && !item->fileListItem->tags->composer.isEmpty() ) param.append( " " + plugin->enc.tag.composer );
        if( !plugin->enc.tag.title.isEmpty() && !item->fileListItem->tags->title.isEmpty() ) param.append( " " + plugin->enc.tag.title );
        if( !plugin->enc.tag.year.isEmpty() && item->fileListItem->tags->year != 0 ) param.append( " " + plugin->enc.tag.year );
    }

    TQString sInOutFiles = item->fileListItem->options.encodingOptions.sInOutFiles;
    param = sInOutFiles.tqreplace( "%p", param );

    // cosmetic surgery
    param = param.simplifyWhiteSpace();

    params = TQStringList::split( ' ', param );

    TQString inputFile;
    if( item->mode & ConvertItem::decode || item->mode & ConvertItem::rip ) inputFile = item->tempWavFile->name();
    else inputFile = item->tempInFile->name();

    for( TQStringList::Iterator it = params.begin(); it != params.end(); ++it )
    {
        paramSplinter = *it;
        paramSplinter.tqreplace( "%i", inputFile );
        paramSplinter.tqreplace( "%o", item->tempOutFile->name() );
        paramSplinter.tqreplace( "%c", sStrength );
        paramSplinter.tqreplace( "%b", sBitrate );
        paramSplinter.tqreplace( "%q", sQuality );
        paramSplinter.tqreplace( "%m", sMinBitrate );
        paramSplinter.tqreplace( "%M", sMaxBitrate );
        paramSplinter.tqreplace( "%s", sSamplingRate );

        if( item->fileListItem->tags ) {
            paramSplinter.tqreplace( "%ta", ( item->fileListItem->tags->artist != "" ) ? item->fileListItem->tags->artist : i18n("Unknown") );
            paramSplinter.tqreplace( "%tb", ( item->fileListItem->tags->album != "" ) ? item->fileListItem->tags->album : i18n("Unknown") );
            paramSplinter.tqreplace( "%tc", ( item->fileListItem->tags->comment != "" ) ? item->fileListItem->tags->comment : i18n("Unknown") );
            paramSplinter.tqreplace( "%td", ( TQString::number(item->fileListItem->tags->disc) != "" ) ? TQString::number(item->fileListItem->tags->disc) : "0" );
            paramSplinter.tqreplace( "%tg", ( item->fileListItem->tags->genre != "" ) ? item->fileListItem->tags->genre : i18n("Unknown") );
            paramSplinter.tqreplace( "%tn", ( TQString::number(item->fileListItem->tags->track) != "" ) ? TQString::number(item->fileListItem->tags->track) : "0" );
            paramSplinter.tqreplace( "%tp", ( item->fileListItem->tags->composer != "" ) ? item->fileListItem->tags->composer : i18n("Unknown") );
            paramSplinter.tqreplace( "%tt", ( item->fileListItem->tags->title != "" ) ? item->fileListItem->tags->title : i18n("Unknown") );
            paramSplinter.tqreplace( "%ty", ( TQString::number(item->fileListItem->tags->year) != "" ) ? TQString::number(item->fileListItem->tags->year) : "0" );
        }

        if( paramSplinter != "" && paramSplinter != " " ) *(item->convertProcess) << paramSplinter; // NOTE fixes wavpack encoding
    }

    param.tqreplace( "%i", "\""+inputFile+"\"" );
    param.tqreplace( "%o", "\""+item->tempOutFile->name()+"\"" );
    param.tqreplace( "%c", sStrength );
    param.tqreplace( "%b", sBitrate );
    param.tqreplace( "%q", sQuality );
    param.tqreplace( "%m", sMinBitrate );
    param.tqreplace( "%M", sMaxBitrate );
    param.tqreplace( "%s", sSamplingRate );

    if( item->fileListItem->tags ) {
        param.tqreplace( "%ta", "\""+item->fileListItem->tags->artist+"\"" );
        param.tqreplace( "%tb", "\""+item->fileListItem->tags->album+"\"" );
        param.tqreplace( "%tc", "\""+item->fileListItem->tags->comment+"\"" );
        param.tqreplace( "%td", TQString::number(item->fileListItem->tags->disc) );
        param.tqreplace( "%tg", "\""+item->fileListItem->tags->genre+"\"" );
        param.tqreplace( "%tn", TQString::number(item->fileListItem->tags->track) );
        param.tqreplace( "%tp", "\""+item->fileListItem->tags->composer+"\"" );
        param.tqreplace( "%tt", "\""+item->fileListItem->tags->title+"\"" );
        param.tqreplace( "%ty", TQString::number(item->fileListItem->tags->year) );
    }

    logger->log( item->logID, param );

    //kdDebug() << " Executing: `" << param << "'" << endl;

    //item->readOutputTimer.start();
    item->lastOutputTimer.start();

    item->fileListItem->setText( fileList->columnByName(i18n("State")), i18n("Encoding")+"... 00 %" );

    item->convertProcess->setPriority( config->data.general.priority );
    item->convertProcess->start( KProcess::NotifyOnExit, KProcess::AllOutput );
}

void Convert::replaygain( ConvertItem* item )
{
    logger->log( item->logID, i18n("Applying Replay Gain") );
    item->state = ConvertItem::replaygain;

    FormatItem* formatItem = config->getFormatItem( item->fileListItem->options.encodingOptions.sFormat );
    if( formatItem == 0 ) {
        logger->log( item->logID, " NULL POINTER: Convert::replaygain( ... ) / formatItem" );
        return;
    }
    ConvertPlugin* plugin = formatItem->encoder;
    if( plugin == 0 ) {
        logger->log( item->logID, " NULL POINTER: Convert::replaygain( ... ) / plugin" );
        return;
    }

    if( plugin->enc.replaygain.enabled && formatItem->internalReplayGain ) {
        executeNextStep( item );
        return;
    }

    item->replayGain = new ReplayGain( config, logger );
    bool ret = item->replayGain->apply( item->tempOutFile->name(), item->fileListItem->options.encodingOptions.sFormat, item->convertProcess, item->logID );

    if( !ret ) {
        executeNextStep( item );
        return;
    }

    //item->readOutputTimer.start();
    item->lastOutputTimer.start();

    item->fileListItem->setText( fileList->columnByName(i18n("State")), i18n("Replay Gain")+"... 00 %" );
}

void Convert::writeTags( ConvertItem* item )
{
    logger->log( item->logID, i18n("Writing tags") );
    item->state = ConvertItem::write_tags;

    if( item->mode & ConvertItem::encode ) {
        tagEngine->writeTags( item->tempOutFile->name(), item->fileListItem->tags );
        item->fileListItem->setText( fileList->columnByName(i18n("State")), i18n("Writing tags")+"... 00 %" );
    }

    executeNextStep( item );
}

void Convert::put( ConvertItem* item )
{
    logger->log( item->logID, i18n("Moving file") );
    item->state = ConvertItem::put;

    TQString src;
    if( item->mode & ConvertItem::encode ) src = item->tempOutFile->name();
    else src = item->tempWavFile->name();
    item->fileListItem->setText( fileList->columnByName(i18n("State")), i18n("Moving file")+"... 00 %" );

    item->outputFilePathName = OutputDirectory::makePath( OutputDirectory::uniqueFileName(OutputDirectory::calcPath(item->fileListItem,config)) ).tqreplace("%2f","%252f");

    KURL source( src );
    KURL destination( item->outputFilePathName );

    if( source.isLocalFile() && destination.isLocalFile() ) {
        item->convertProcess->clearArguments();

        *(item->convertProcess) << "cp";
        *(item->convertProcess) << source.path();
        *(item->convertProcess) << destination.path();

        logger->log( item->logID, "cp \"" + source.path() + "\" \"" + destination.path() + "\"" );

        item->convertProcess->setPriority( config->data.general.priority );
        item->convertProcess->start( KProcess::NotifyOnExit, KProcess::AllOutput );
    }
    else {
        item->moveJob = new KIO::FileCopyJob( source, destination, -1, false, false, false, false );
        connect( item->moveJob, TQT_SIGNAL(percent(KIO::Job*,unsigned long)),
                this, TQT_SLOT(moveProgress(KIO::Job*,unsigned long))
                );
        connect( item->moveJob, TQT_SIGNAL(result(KIO::Job*)),
                this, TQT_SLOT(moveFinished(KIO::Job*))
                );
    }
}

void Convert::putCorrection( ConvertItem* item )
{
    logger->log( item->logID, i18n("Moving correction file") );
    item->state = ConvertItem::put_correction;

    TQString src = item->correctionOutFile;

    TQString dest = OutputDirectory::makePath( OutputDirectory::calcPath(item->fileListItem,config,item->correctionOutputExtension) ).tqreplace("%2f","%252f");

    KURL source( src );
//     KURL destination( dest );
    KURL destination;
    destination.setPath( dest );

    item->fileListItem->setText( fileList->columnByName(i18n("State")), i18n("Moving correction file")+"... 00 %" );

    if( source.isLocalFile() && destination.isLocalFile() ) {
        item->convertProcess->clearArguments();

        *(item->convertProcess) << "cp";
        *(item->convertProcess) << source.path();
        *(item->convertProcess) << destination.path();

        logger->log( item->logID, "cp \"" + source.path() + "\" \"" + destination.path() + "\"" );

        item->convertProcess->setPriority( config->data.general.priority );
        item->convertProcess->start( KProcess::NotifyOnExit, KProcess::AllOutput );
    }
    else {
        item->moveJob = new KIO::FileCopyJob( source, destination, -1, false, false, false, false );
        connect( item->moveJob, TQT_SIGNAL(percent(KIO::Job*,unsigned long)),
                this, TQT_SLOT(moveProgress(KIO::Job*,unsigned long))
                );
        connect( item->moveJob, TQT_SIGNAL(result(KIO::Job*)),
                this, TQT_SLOT(moveFinished(KIO::Job*))
                );
    }
}

void Convert::executeUserScript( ConvertItem* item )
{
    logger->log( item->logID, i18n("Running user script") );
    item->state = ConvertItem::execute_userscript;

    KURL source( item->fileListItem->options.filePathName );
    KURL destination( item->outputFilePathName );

    item->fileListItem->setText( fileList->columnByName(i18n("State")), i18n("Running user script")+"... 00 %" );

    item->convertProcess->clearArguments();

    TQString userscript = locate( "data", "soundkonverter/userscript.sh" );
    if( userscript == "" ) executeNextStep( item );

    *(item->convertProcess) << userscript;
    *(item->convertProcess) << source.path();
    *(item->convertProcess) << destination.path();

    logger->log( item->logID, userscript + " \"" + source.path() + "\" \"" + destination.path() + "\"" );

    item->convertProcess->setPriority( config->data.general.priority );
    item->convertProcess->start( KProcess::NotifyOnExit, KProcess::AllOutput );
}

void Convert::executeNextStep( ConvertItem* item )
{
    logger->log( item->logID, i18n("Executing next step") );

    item->percent = 0;
    item->lastPercent = 0; // used for ripping a whole cd to one file

    switch( item->state )
    {
        case ConvertItem::get:
        {
            if( item->mode & ConvertItem::get_correction ) getCorrection( item );
            else if( item->mode & ConvertItem::rip ) rip( item );
            else if( item->mode & ConvertItem::decode ) decode( item );
            else if( item->mode & ConvertItem::encode ) encode( item );
            else if( item->mode & ConvertItem::replaygain ) replaygain( item );
            else if( item->mode & ConvertItem::write_tags ) writeTags( item );
            else if( item->mode & ConvertItem::put ) put( item );
            else if( item->mode & ConvertItem::put_correction ) putCorrection( item );
            else if( config->data.general.executeUserScript ) executeUserScript( item );
            else remove( item );
            break;
        }
        case ConvertItem::get_correction:
        {
            if( item->mode & ConvertItem::rip ) rip( item );
            else if( item->mode & ConvertItem::decode ) decode( item );
            else if( item->mode & ConvertItem::encode ) encode( item );
            else if( item->mode & ConvertItem::replaygain ) replaygain( item );
            else if( item->mode & ConvertItem::write_tags ) writeTags( item );
            else if( item->mode & ConvertItem::put ) put( item );
            else if( item->mode & ConvertItem::put_correction ) putCorrection( item );
            else if( config->data.general.executeUserScript ) executeUserScript( item );
            else remove( item );
            break;
        }
        case ConvertItem::rip:
        {
            if( item->mode & ConvertItem::decode ) decode( item );
            else if( item->mode & ConvertItem::encode ) encode( item );
            else if( item->mode & ConvertItem::replaygain ) replaygain( item );
            else if( item->mode & ConvertItem::write_tags ) writeTags( item );
            else if( item->mode & ConvertItem::put ) put( item );
            else if( item->mode & ConvertItem::put_correction ) putCorrection( item );
            else if( config->data.general.executeUserScript ) executeUserScript( item );
            else remove( item );
            break;
        }
        case ConvertItem::decode:
        {
            if( item->mode & ConvertItem::encode ) encode( item );
            else if( item->mode & ConvertItem::replaygain ) replaygain( item );
            else if( item->mode & ConvertItem::write_tags ) writeTags( item );
            else if( item->mode & ConvertItem::put ) put( item );
            else if( item->mode & ConvertItem::put_correction ) putCorrection( item );
            else if( config->data.general.executeUserScript ) executeUserScript( item );
            else remove( item );
            break;
        }
        case ConvertItem::encode:
        {
            if( item->mode & ConvertItem::replaygain ) replaygain( item );
            else if( item->mode & ConvertItem::write_tags ) writeTags( item );
            else if( item->mode & ConvertItem::put ) put( item );
            else if( item->mode & ConvertItem::put_correction ) putCorrection( item );
            else if( config->data.general.executeUserScript ) executeUserScript( item );
            else remove( item );
            break;
        }
        case ConvertItem::replaygain:
        {
            if( item->mode & ConvertItem::write_tags ) writeTags( item );
            else if( item->mode & ConvertItem::put ) put( item );
            else if( item->mode & ConvertItem::put_correction ) putCorrection( item );
            else if( config->data.general.executeUserScript ) executeUserScript( item );
            else remove( item );
            break;
        }
        case ConvertItem::write_tags:
        {
            if( item->mode & ConvertItem::put ) put( item );
            else if( item->mode & ConvertItem::put_correction ) putCorrection( item );
            else if( config->data.general.executeUserScript ) executeUserScript( item );
            else remove( item );
            break;
        }
        case ConvertItem::put:
        {
            if( item->mode & ConvertItem::put_correction ) putCorrection( item );
            else if( config->data.general.executeUserScript ) executeUserScript( item );
            else remove( item );
            break;
        }
        case ConvertItem::put_correction:
        {
            if( config->data.general.executeUserScript ) executeUserScript( item );
            else remove( item );
            break;
        }
        case ConvertItem::execute_userscript:
        {
            remove( item );
            break;
        }
        default: // case (ConvertItem::Mode)0x0000:
        {
            if( item->mode & ConvertItem::get ) get( item );
            else if( item->mode & ConvertItem::get_correction ) getCorrection( item );
            else if( item->mode & ConvertItem::rip ) rip( item );
            else if( item->mode & ConvertItem::decode ) decode( item );
            else if( item->mode & ConvertItem::encode ) encode( item );
            else if( item->mode & ConvertItem::replaygain ) replaygain( item );
            else if( item->mode & ConvertItem::write_tags ) writeTags( item );
            else if( item->mode & ConvertItem::put ) put( item );
            else if( item->mode & ConvertItem::put_correction ) putCorrection( item );
            else if( config->data.general.executeUserScript ) executeUserScript( item );
            else remove( item );
            break;
        }
    }
}

void Convert::moveProgress( KIO::Job* job, unsigned long percent )
{
    // search the item list for our item
    for( TQValueList<ConvertItem*>::Iterator item = items.begin(); item != items.end(); item++ ) {
        if( (*item)->moveJob == job ) {
            (*item)->percent = percent;
        }
    }
}

void Convert::moveFinished( KIO::Job* job )
{
    // search the item list for our item
    for( TQValueList<ConvertItem*>::Iterator item = items.begin(); item != items.end(); item++ ) {
        if( (*item)->moveJob == job ) {

            (*item)->percent = 0;
            if( (*item)->state == ConvertItem::get ) {
                if( job->error() != 0 ) {
                    remove( *item, 1 );
                    updateProgressIndicator();
                    return;
                }

                logger->log( (*item)->logID, " " + i18n("Got file") );

                // if file is remote or the tag reding failed previously, read the tags now
                if( (*item)->fileListItem->tags == 0 ) {
                    (*item)->fileListItem->tags = tagEngine->readTags( (*item)->tempInFile->name() );
                }

                emit countTime( (*item)->getTime );
            }
            else if( (*item)->state == ConvertItem::get_correction ) {
                if( job->error() != 0 ) {
                    emit uncountTime( (*item)->getTime );
                    remove( *item, 1 );
                    updateProgressIndicator();
                    return;
                }

                logger->log( (*item)->logID, " " + i18n("Got file") );
                emit countTime( (*item)->getCorrectionTime );
            }
            else if( (*item)->state == ConvertItem::rip ) {
                if( job->error() != 0 ) {
                    remove( *item, 1 );
                    updateProgressIndicator();
                    return;
                }

                //logger->log( (*item)->logID, " " + i18n("Ripped track") );
                (*item)->fileListItem->ripping = false;
                emit countTime( (*item)->ripTime );
                emit rippingFinished( (*item)->fileListItem->device );
            }
            else if( (*item)->state == ConvertItem::put ) {
                if( job->error() != 0 ) {
                    logger->log( (*item)->logID, i18n("Could not write to file: `%1'").tqarg(OutputDirectory::calcPath((*item)->fileListItem,config)) );
                    emit uncountTime( (*item)->getTime );
                    emit uncountTime( (*item)->getCorrectionTime );
                    emit uncountTime( (*item)->ripTime );
                    emit uncountTime( (*item)->decodeTime );
                    emit uncountTime( (*item)->encodeTime );
                    emit uncountTime( (*item)->replaygainTime );
                    remove( *item, 1 );
                    updateProgressIndicator();
                    return;
                }

                logger->log( (*item)->logID, " " + i18n("File moved") );
            }
            else if( (*item)->state == ConvertItem::put_correction ) {
                if( job->error() != 0 ) {
                    emit uncountTime( (*item)->getTime );
                    emit uncountTime( (*item)->getCorrectionTime );
                    emit uncountTime( (*item)->ripTime );
                    emit uncountTime( (*item)->decodeTime );
                    emit uncountTime( (*item)->encodeTime );
                    emit uncountTime( (*item)->replaygainTime );
                    remove( *item, 1 );
                    updateProgressIndicator();
                    return;
                }

                logger->log( (*item)->logID, " " + i18n("File moved") );
            }

            executeNextStep( *item );
            return;
        }
    }
}

void Convert::processOutput( KProcess* proc, char* data, int )
{
    int iPercent = 0, iTime = 0, iPos = 0, iNum = 0;

    // search the item list for our item
    for( TQValueList<ConvertItem*>::Iterator item = items.begin(); item != items.end(); item++ )
    {
        if( (*item)->convertProcess == proc )
        {
            TQString log_data = data;
/*            log_data.tqreplace("\n","\\n");
            log_data.tqreplace("\t","\\t");
            log_data.tqreplace("\r","\\r");
            log_data.tqreplace("\b","\\b");*/
            logger->log( (*item)->logID, " " + i18n("Output") + ": " + log_data );

            //if( (*item)->readOutputTimer.elapsed() < /*config->pauseTime*/ 100 ) return; // TODO use config value
            //(*item)->readOutputTimer.start();

            if( (*item)->state == ConvertItem::decode )
            {
                if( (*item)->fileListItem == 0 )  return;

                ConvertPlugin* plugin = config->decoderForFormat( (*item)->fileListItem->mimeType );
                // TODO null pointer check

                TQString outputPattern = plugin->dec.output;
                //outputPattern.tqreplace( "%i", "%p" ); // for compatibility with old plugins

                if( outputPattern.tqfind("%p") != -1 ) {
                     outputPattern.tqreplace( "%p", "%i" );
                     sscanf( data, outputPattern, &iPercent );
                }
                else if( outputPattern.tqfind("%t") != -1 ) {
                     outputPattern.tqreplace( "%t", "%i" );
                     sscanf( data, outputPattern, &iTime );
                     iPercent = iTime * 100 / (*item)->fileListItem->time;
                }
                else if( outputPattern.tqfind("%0") != -1 && outputPattern.tqfind("%1") != -1 ) {
                     if( outputPattern.tqfind("%0") < outputPattern.tqfind("%1") ) {
                         outputPattern.tqreplace( "%0", "%i" );
                         outputPattern.tqreplace( "%1", "%i" );
                         sscanf( data, outputPattern, &iPos, &iNum );
                     }
                     else {
                         outputPattern.tqreplace( "%0", "%i" );
                         outputPattern.tqreplace( "%1", "%i" );
                         sscanf( data, outputPattern, &iNum, &iPos );
                     }
                     if( iPos != 0 && iNum != 0 ) iPercent = iPos * 100 / iNum;
                }

                if( iPercent > 0 && iPercent <= 100 )
                {
                    // TODO guess progress, when no signal is received
                    (*item)->lastOutputTimer.start();
                    (*item)->percent = iPercent;
                }
            }
            else if( (*item)->state == ConvertItem::encode )
            {
                if( (*item)->fileListItem == 0 )  return;

                // NOTE use mimetype
                ConvertPlugin* plugin = config->encoderForFormat( (*item)->fileListItem->options.encodingOptions.sFormat );
                // TODO null pointer check

                TQString outputPattern;
                if( (*item)->fileListItem->options.encodingOptions.sQualityMode == i18n("Quality") ) outputPattern = plugin->enc.lossy.quality.output;
                else if( (*item)->fileListItem->options.encodingOptions.sQualityMode == i18n("Bitrate") && (*item)->fileListItem->options.encodingOptions.sBitrateMode == "cbr" ) outputPattern = plugin->enc.lossy.bitrate.cbr.output;
                else if( (*item)->fileListItem->options.encodingOptions.sQualityMode == i18n("Bitrate") && (*item)->fileListItem->options.encodingOptions.sBitrateMode == "abr" ) outputPattern = plugin->enc.lossy.bitrate.abr.output;

                //outputPattern.tqreplace( "%i", "%p" ); // for compatibility with old plugins

                if( outputPattern.tqfind("%p") != -1 ) {
                     outputPattern.tqreplace( "%p", "%i" );
                     sscanf( data, outputPattern, &iPercent );
                }
                else if( outputPattern.tqfind("%t") != -1 ) {
                     outputPattern.tqreplace( "%t", "%i" );
                     sscanf( data, outputPattern, &iTime );
                     iPercent = iTime * 100 / (*item)->fileListItem->time;
                }
                else if( outputPattern.tqfind("%0") != -1 && outputPattern.tqfind("%1") != -1 ) {
                     if( outputPattern.tqfind("%0") < outputPattern.tqfind("%1") ) {
                         outputPattern.tqreplace( "%0", "%i" );
                         outputPattern.tqreplace( "%1", "%i" );
                         sscanf( data, outputPattern, &iPos, &iNum );
                     }
                     else {
                         outputPattern.tqreplace( "%0", "%i" );
                         outputPattern.tqreplace( "%1", "%i" );
                         sscanf( data, outputPattern, &iNum, &iPos );
                     }
                     if( iPos != 0 && iNum != 0 ) iPercent = iPos * 100 / iNum;
                }

                if( iPercent > 0 && iPercent <= 100 )
                {
                    // TODO guess progress, when no signal is received
                    (*item)->lastOutputTimer.start();
                    (*item)->percent = iPercent;
                }
            }
            else if( (*item)->state == ConvertItem::rip ) // ### soundkonverter 0.4 make the progress dependent on the track length
            {
                if( (*item)->fileListItem == 0 )  return;

                RipperPlugin* plugin = config->getCurrentRipper();
                // TODO null pointer check

                TQString outputPattern;
                if( (*item)->fileListItem->track != 0 ) outputPattern = plugin->rip.output;
                else outputPattern = plugin->rip.full_disc.output;
                //outputPattern.tqreplace( "%i", "%p" ); // for compatibility with old plugins

                if( outputPattern.tqfind("%p") != -1 || outputPattern.tqfind("%a") != -1 ) {
                     outputPattern.tqreplace( "%p", "%i" );
                     outputPattern.tqreplace( "%a", "%i" );
                     sscanf( data, outputPattern, &iPercent );
                }
                else if( outputPattern.tqfind("%t") != -1 ) {
                     outputPattern.tqreplace( "%t", "%i" );
                     sscanf( data, outputPattern, &iTime );
                     iPercent = iTime * 100 / (*item)->fileListItem->time;
                }
                else if( outputPattern.tqfind("%0") != -1 && outputPattern.tqfind("%1") != -1 ) {
                     if( outputPattern.tqfind("%0") < outputPattern.tqfind("%1") ) {
                         outputPattern.tqreplace( "%0", "%i" );
                         outputPattern.tqreplace( "%1", "%i" );
                         sscanf( data, outputPattern, &iPos, &iNum );
                     }
                     else {
                         outputPattern.tqreplace( "%0", "%i" );
                         outputPattern.tqreplace( "%1", "%i" );
                         sscanf( data, outputPattern, &iNum, &iPos );
                     }
                     if( iPos != 0 && iNum != 0 ) iPercent = iPos * 100 / iNum;
                }

                if( iPercent > 0 && iPercent <= 100 )
                {
                    // TODO guess progress, when no signal is received
                    (*item)->lastOutputTimer.start();
                    if( (*item)->fileListItem->track == 0 && plugin->rip.full_disc.output.tqfind("%a") != -1 ) {
                        if( iPercent < (*item)->lastPercent ) (*item)->track++;
                        (*item)->lastPercent = iPercent;
                        (*item)->percent = (*item)->track * 100 / (*item)->tracks + iPercent / (*item)->tracks;
                    }
                    else {
                        (*item)->percent = iPercent;
                    }
                }
            }
            return;
        }
    }
}

void Convert::processExit( KProcess* proc )
{
    // search the item list for our item
    for( TQValueList<ConvertItem*>::Iterator item = items.begin(); item != items.end(); item++ ) {
//        if( (*item)->convertProcess == proc && (*item)->fileListItem != 0 ) {
        if( (*item)->convertProcess == proc ) {

            (*item)->percent = 0;
            if( (*item)->state == ConvertItem::rip ) {
                if( proc->signalled() ) { // FIXME does only check, whether the process has been killed
                    remove( *item, 1 );
                    updateProgressIndicator();
                    return;
                }
                else if( !proc->normalExit() ) {
                    remove( *item, -1 );
                    updateProgressIndicator();
                    return;
                }
                else {
                    (*item)->fileListItem->ripping = false;
                    emit countTime( (*item)->ripTime );
                    emit rippingFinished( (*item)->fileListItem->device );
                }
            }
            if( (*item)->state == ConvertItem::get ) {
                if( proc->signalled() ) {
                    remove( *item, 1 );
                    updateProgressIndicator();
                    return;
                }
                else if( !proc->normalExit() ) {
                    remove( *item, -1 );
                    updateProgressIndicator();
                    return;
                }
                else {
                    logger->log( (*item)->logID, " " + i18n("Got file") );

                    // if file is remote or the tag reding failed previously, read the tags now
                    if( (*item)->fileListItem->tags == 0 ) {
                        (*item)->fileListItem->tags = tagEngine->readTags( (*item)->tempInFile->name() );
                    }

                    emit countTime( (*item)->getTime );
                }
            }
            if( (*item)->state == ConvertItem::get_correction ) {
                if( proc->signalled() ) {
                    emit uncountTime( (*item)->getTime );
                    remove( *item, 1 );
                    updateProgressIndicator();
                    return;
                }
                else if( !proc->normalExit() ) {
                    emit uncountTime( (*item)->getTime );
                    remove( *item, -1 );
                    updateProgressIndicator();
                    return;
                }
                else {
                    logger->log( (*item)->logID, " " + i18n("Got file") );
                    emit countTime( (*item)->getCorrectionTime );
                }
            }
            if( (*item)->state == ConvertItem::decode ) {
                if( proc->signalled() ) {
                    emit uncountTime( (*item)->getTime );
                    emit uncountTime( (*item)->getCorrectionTime );
                    remove( *item, 1 );
                    updateProgressIndicator();
                    return;
                }
                else if( !proc->normalExit() ) {
                    emit uncountTime( (*item)->getTime );
                    emit uncountTime( (*item)->getCorrectionTime );
                    remove( *item, -1 );
                    updateProgressIndicator();
                    return;
                }
                else {
                    emit countTime( (*item)->decodeTime );
                }
            }
            if( (*item)->state == ConvertItem::encode ) {
                if( proc->signalled() ) {
                    emit uncountTime( (*item)->getTime );
                    emit uncountTime( (*item)->getCorrectionTime );
                    emit uncountTime( (*item)->ripTime );
                    emit uncountTime( (*item)->decodeTime );
                    remove( *item, 1 );
                    updateProgressIndicator();
                    return;
                }
                else if( !proc->normalExit() ) {
                    emit uncountTime( (*item)->getTime );
                    emit uncountTime( (*item)->getCorrectionTime );
                    emit uncountTime( (*item)->ripTime );
                    emit uncountTime( (*item)->decodeTime );
                    remove( *item, -1 );
                    updateProgressIndicator();
                    return;
                }
                else {
/*                    if( (*item)->binary == "faac" ) {
                        emit uncountTime( (*item)->getTime );
                        emit uncountTime( (*item)->getCorrectionTime );
                        emit uncountTime( (*item)->ripTime );
                        emit uncountTime( (*item)->decodeTime );
                        remove( *item, 1 );
                        updateProgressIndicator();
                        return;
                    }*/
                    emit countTime( (*item)->encodeTime );
                }
            }
            if( (*item)->state == ConvertItem::put ) {
                if( proc->signalled() ) {
                    logger->log( (*item)->logID, i18n("Could not write to file: `%1'").tqarg(OutputDirectory::calcPath((*item)->fileListItem,config)) );
                    emit uncountTime( (*item)->getTime );
                    emit uncountTime( (*item)->getCorrectionTime );
                    emit uncountTime( (*item)->ripTime );
                    emit uncountTime( (*item)->decodeTime );
                    emit uncountTime( (*item)->encodeTime );
                    emit uncountTime( (*item)->replaygainTime );
                    remove( *item, 1 );
                    updateProgressIndicator();
                    return;
                }
                if( !proc->normalExit() ) {
                    logger->log( (*item)->logID, i18n("Could not write to file: `%1'").tqarg(OutputDirectory::calcPath((*item)->fileListItem,config)) );
                    emit uncountTime( (*item)->getTime );
                    emit uncountTime( (*item)->getCorrectionTime );
                    emit uncountTime( (*item)->ripTime );
                    emit uncountTime( (*item)->decodeTime );
                    emit uncountTime( (*item)->encodeTime );
                    emit uncountTime( (*item)->replaygainTime );
                    remove( *item, -1 );
                    updateProgressIndicator();
                    return;
                }
                else {
                    logger->log( (*item)->logID, " " + i18n("File moved") );
                }
            }
            if( (*item)->state == ConvertItem::put_correction ) {
                if( proc->signalled() ) {
                    emit uncountTime( (*item)->getTime );
                    emit uncountTime( (*item)->getCorrectionTime );
                    emit uncountTime( (*item)->ripTime );
                    emit uncountTime( (*item)->decodeTime );
                    emit uncountTime( (*item)->encodeTime );
                    emit uncountTime( (*item)->replaygainTime );
                    remove( *item, 1 );
                    updateProgressIndicator();
                    return;
                }
                if( !proc->normalExit() ) {
                    emit uncountTime( (*item)->getTime );
                    emit uncountTime( (*item)->getCorrectionTime );
                    emit uncountTime( (*item)->ripTime );
                    emit uncountTime( (*item)->decodeTime );
                    emit uncountTime( (*item)->encodeTime );
                    emit uncountTime( (*item)->replaygainTime );
                    remove( *item, -1 );
                    updateProgressIndicator();
                    return;
                }
                else {
                    logger->log( (*item)->logID, " " + i18n("File moved") );
                }
            }
            if( (*item)->state == ConvertItem::replaygain ) {
                if( proc->signalled() ) {
                    emit uncountTime( (*item)->getTime );
                    emit uncountTime( (*item)->getCorrectionTime );
                    emit uncountTime( (*item)->ripTime );
                    emit uncountTime( (*item)->decodeTime );
                    emit uncountTime( (*item)->encodeTime );
                    remove( *item, 1 );
                    updateProgressIndicator();
                    return;
                }
                else if( !proc->normalExit() ) {
                    emit uncountTime( (*item)->getTime );
                    emit uncountTime( (*item)->getCorrectionTime );
                    emit uncountTime( (*item)->ripTime );
                    emit uncountTime( (*item)->decodeTime );
                    emit uncountTime( (*item)->encodeTime );
                    remove( *item, -1 );
                    updateProgressIndicator();
                    return;
                }
                else {
                    emit countTime( (*item)->replaygainTime );
                }
            }
            // TODO did we get errors? (complete)
            executeNextStep( *item );
            return;
        }
    }
}

void Convert::add( FileListItem* item )
{
    logger->log( 1000, i18n("Adding new item to conversion list: `%1'").tqarg(item->options.filePathName) );

    // append the item to the item list and store the iterator
    TQValueList<ConvertItem*>::Iterator newItem = items.append( new ConvertItem( item ) );

    // register at the logger
    (*newItem)->logID = logger->registerProcess( item->options.filePathName );
    logger->log( 1000, " " + i18n("Got log ID: %1").tqarg((*newItem)->logID) );

    logger->log( (*newItem)->logID, "Mime Type: " + (*newItem)->fileListItem->mimeType );
    if( (*newItem)->fileListItem->tags ) logger->log( (*newItem)->logID, i18n("Tags successfully read") );
    else logger->log( (*newItem)->logID, i18n("Reading tags failed") );

    // set some variables to default values
    (*newItem)->mode = (ConvertItem::Mode)0x0000;
    (*newItem)->state = (ConvertItem::Mode)0x0000;
    (*newItem)->convertProcess = 0;
    (*newItem)->moveJob = 0;
    (*newItem)->replayGain = 0;

    /* seems to be unnecessary
    (*newItem)->correctionInFile = TQString()();
    (*newItem)->correctionOutFile = TQString()();
    (*newItem)->correctionInputExtension = TQString()();
    (*newItem)->correctionOutputExtension = TQString()();*/

    // connect convertProcess of our new item with the slots of Convert
    (*newItem)->convertProcess = new KProcess();
    connect( (*newItem)->convertProcess, TQT_SIGNAL(receivedStdout(KProcess*,char*,int)),
               this, TQT_SLOT(processOutput(KProcess*,char*,int))
             );
    connect( (*newItem)->convertProcess, TQT_SIGNAL(receivedStderr(KProcess*,char*,int)),
               this, TQT_SLOT(processOutput(KProcess*,char*,int))
             );
    connect( (*newItem)->convertProcess, TQT_SIGNAL(processExited(KProcess*)),
               this, TQT_SLOT(processExit(KProcess*))
             );

    // NOTE the tempInFile is also created if the file is a audio cd track

    // set up the names of our temp files
    (*newItem)->tempInFile = new KTempFile( TQString(), "." + item->fileFormat );
    (*newItem)->tempInFile->setAutoDelete( true );
    (*newItem)->tempInFile->close();

    (*newItem)->tempWavFile = new KTempFile( TQString(), ".wav" );
    (*newItem)->tempWavFile->setAutoDelete( true );
    (*newItem)->tempWavFile->close();

    (*newItem)->tempOutFile = new KTempFile( TQString(), "." + item->options.encodingOptions.sFormat );
    (*newItem)->tempOutFile->setAutoDelete( true );
    (*newItem)->tempOutFile->close();

    if( item->track >= 0 ) // it's an audio cd track
    {
        (*newItem)->mode = ConvertItem::Mode( ConvertItem::rip );
    }
    else // it's a file
    {
        (*newItem)->mode = ConvertItem::Mode( ConvertItem::get );
        if( item->fileFormat != "wav" )
        {
            (*newItem)->mode = ConvertItem::Mode( (*newItem)->mode | ConvertItem::decode );
        }
    }

    if( item->options.encodingOptions.sFormat != "wav" )
    {
        (*newItem)->mode = ConvertItem::Mode( (*newItem)->mode | ConvertItem::encode );
    }
    if( item->options.encodingOptions.replaygain.bEnabled )
    {
        (*newItem)->mode = ConvertItem::Mode( (*newItem)->mode | ConvertItem::replaygain );
    }

    TQString extension;

    extension = config->getCorrectionExtension( item->mimeType );
    if( !extension.isEmpty() ) {
        (*newItem)->correctionInputExtension = extension;
        (*newItem)->correctionInFile = OutputDirectory::changeExtension( (*newItem)->tempInFile->name(), extension );
        (*newItem)->mode = ConvertItem::Mode( (*newItem)->mode | ConvertItem::get_correction );
        logger->log( (*newItem)->logID, " correctionInFile: `" + (*newItem)->correctionInFile + "'" );
    }

    extension = config->getCorrectionExtension( item->options.encodingOptions.sFormat );
    if( !extension.isEmpty() && item->options.encodingOptions.sQualityMode == i18n("Hybrid") ) {
        (*newItem)->correctionOutputExtension = extension;
        (*newItem)->correctionOutFile = OutputDirectory::changeExtension( (*newItem)->tempOutFile->name(), extension );
        (*newItem)->mode = ConvertItem::Mode( (*newItem)->mode | ConvertItem::put_correction );
        logger->log( (*newItem)->logID, " correctionOutFile: `" + (*newItem)->correctionOutFile + "'" );
    }

    (*newItem)->mode = ConvertItem::Mode( (*newItem)->mode | ConvertItem::write_tags | ConvertItem::put );

    // TODO use the values from the format info files !!!

    if( (*newItem)->mode & ConvertItem::get ) {
        if( !item->local ) {
            (*newItem)->getTime = 0.8; // TODO use the file size from the format info files
        }
    }
    if( (*newItem)->mode & ConvertItem::get_correction ) {
        if( !item->local ) {
            (*newItem)->getCorrectionTime = 2.0; // TODO use the file size from the format info files
        }
    }
    if( (*newItem)->mode & ConvertItem::rip ) {
        (*newItem)->ripTime = 1.0;
    }
    if( (*newItem)->mode & ConvertItem::decode ) {
        (*newItem)->decodeTime = 0.4;
    }
    if( (*newItem)->mode & ConvertItem::encode ) {
        (*newItem)->encodeTime = 1.0;
    }
    if( (*newItem)->mode & ConvertItem::replaygain ) {
        (*newItem)->replaygainTime = 0.2;
    }

    float sum = ( (*newItem)->getTime + (*newItem)->getCorrectionTime + (*newItem)->ripTime + (*newItem)->decodeTime + (*newItem)->encodeTime + (*newItem)->replaygainTime ) / item->time;

    (*newItem)->getTime /= sum;
    (*newItem)->getCorrectionTime /= sum;
    (*newItem)->ripTime /= sum;
    (*newItem)->decodeTime /= sum;
    (*newItem)->encodeTime /= sum;
    (*newItem)->replaygainTime /= sum;

    // visual feedback
    item->converting = true;

    if( !tUpdateProgressIndicator->isActive() ) {
        tUpdateProgressIndicator->start( config->data.general.updateDelay );
    }

    // and start
    executeNextStep( *newItem );
}

void Convert::stop( FileListItem* item )
{
    // search the item list for our item to stop 
    for( TQValueList<ConvertItem*>::Iterator stopItem = items.begin(); stopItem != items.end(); stopItem++ ) {
        // is fileListItem pointing at the same address, as item
        if( (*stopItem)->fileListItem == item ) {

            if( (*stopItem)->convertProcess->isRunning() ) {
                bool ret = (*stopItem)->convertProcess->kill( SIGKILL );
                //kdDebug() << "Killing process... (" << ret << ")" << endl;
                if( ret ) {
                    logger->log( (*stopItem)->logID, i18n("Killing process ...") );
                }
                else {
                    logger->log( (*stopItem)->logID, i18n("Killing process failed. Stopping after files are completed ...") );
                }
            }
            else if( (*stopItem)->moveJob != 0 ) {
                //kdDebug() << "Killing file copy..." << endl;
                // FIXME crashes sometimes - should be fixed by SIGKILL
                // FIXME crash if file_copy was stealthed
                logger->log( (*stopItem)->logID, i18n("Killing process ...") );
                (*stopItem)->moveJob->kill( false );
            }

            return;
        }
    }
}

void Convert::remove( ConvertItem* item, int state )
{
    // TODO "remove" (re-add) the times to the progress indicator
    //emit uncountTime( item->getTime + item->getCorrectionTime + item->ripTime +
    //                  item->decodeTime + item->encodeTime + item->replaygainTime );

    logger->log( item->logID, i18n("Removing file from conversion list. Exit code %1").tqarg(state) );

    if( item->fileListItem->notify != "" ) {
        TQString command = item->fileListItem->notify;
        command.tqreplace( "%u", item->fileListItem->url );
        command.tqreplace( "%i", item->fileListItem->options.filePathName.tqreplace(" ","%20") );
        command.tqreplace( "%o", item->outputFilePathName.tqreplace(" ","%20") );
        logger->log( item->logID, " "+i18n("Executing command: \"%1\"").tqarg(command) );
        notify.clearArguments();
        TQString paramSplinter;
        // FIXME split correct (strings with spaces are splited by mistake)
        // FIXME only one command can be executed at once!?
        TQStringList params = TQStringList::split( ' ', item->fileListItem->notify );
        for( TQStringList::Iterator it = params.begin(); it != params.end(); ++it )
        {
            paramSplinter = *it;
            paramSplinter.tqreplace( "%u", item->fileListItem->url );
            paramSplinter.tqreplace( "%i", item->fileListItem->options.filePathName );
            paramSplinter.tqreplace( "%o", item->outputFilePathName );
            notify << paramSplinter;
        }
        notify.start( KProcess::DontCare );
    }

    item->fileListItem->converting = false;
    emit finished( item->fileListItem, state ); // send signal to FileList
    emit finishedProcess( item->logID, state ); // send signal to Logger

    item->fileListItem = 0;
    if( item->convertProcess != 0 ) delete item->convertProcess;
    item->convertProcess = 0;
    //if( item->moveJob != 0 ) delete item->moveJob; // NOTE makes soundkonverter crash
    //item->moveJob = 0;
    if( item->replayGain != 0 ) delete item->replayGain;
    item->replayGain = 0;

    if( item->tempInFile != 0 ) delete item->tempInFile;
    item->tempInFile = 0;
    if( item->tempWavFile != 0 ) delete item->tempWavFile;
    item->tempWavFile = 0;
    if( item->tempOutFile != 0 ) delete item->tempOutFile;
    item->tempOutFile = 0;
    TQFile file;
    file.setName( item->correctionInFile );
    if( file.exists() ) file.remove();
    file.setName( item->correctionOutFile );
    if( file.exists() ) file.remove();

    for( TQValueList<ConvertItem*>::Iterator it = items.begin(); it != items.end(); it++ ) {
        if( (*it) == item ) {
            items.remove( it );
            break;
        }
    }

    delete item;
    item = 0;

    if( items.count() == 0 ) {
        tUpdateProgressIndicator->stop();
    }
}

void Convert::updateProgressIndicator()
{
    float time = 0;

    for( TQValueList<ConvertItem*>::Iterator it = items.begin(); it != items.end(); it++ ) {
        if( (*it)->state == ConvertItem::get ) {
            time += (*it)->getTime * (*it)->percent / 100;
            (*it)->fileListItem->setText( fileList->columnByName(i18n("State")), i18n("Getting file")+"... "+TQString().sprintf("%02i %%",(*it)->percent) );
        }
        else if( (*it)->state == ConvertItem::get_correction ) {
            time += (*it)->getCorrectionTime * (*it)->percent / 100;
            (*it)->fileListItem->setText( fileList->columnByName(i18n("State")), i18n("Getting correction file")+"... "+TQString().sprintf("%02i %%",(*it)->percent) );
        }
        else if( (*it)->state == ConvertItem::rip ) {
            RipperPlugin* plugin = config->getCurrentRipper();
            if( plugin != 0 && plugin->rip.output.isEmpty() ) {
                (*it)->fileListItem->setText( fileList->columnByName(i18n("State")), i18n("Ripping")+"... "+i18n("State")+": "+i18n("Unknown") );
            }
            else {
                time += (*it)->ripTime * (*it)->percent / 100;
                (*it)->fileListItem->setText( fileList->columnByName(i18n("State")), i18n("Ripping")+"... "+TQString().sprintf("%02i %%",(*it)->percent) );
            }
        }
        else if( (*it)->state == ConvertItem::decode ) {
            ConvertPlugin* plugin = config->decoderForFormat( (*it)->fileListItem->mimeType );
            if( plugin == 0 || plugin->dec.output.isEmpty() ) {
                (*it)->fileListItem->setText( fileList->columnByName(i18n("State")), i18n("Decoding")+"... "+i18n("State")+": "+i18n("Unknown") );
            }
            else {
                time += (*it)->decodeTime * (*it)->percent / 100;
                (*it)->fileListItem->setText( fileList->columnByName(i18n("State")), i18n("Decoding")+"... "+TQString().sprintf("%02i %%",(*it)->percent) );
            }
        }
        else if( (*it)->state == ConvertItem::encode ) {
            ConvertPlugin* plugin = config->encoderForFormat( (*it)->fileListItem->options.encodingOptions.sFormat );
            TQString outputPattern;
            if( plugin != 0 && (*it)->fileListItem->options.encodingOptions.sQualityMode == i18n("Quality") ) outputPattern = plugin->enc.lossy.quality.output;
            else if( plugin != 0 && (*it)->fileListItem->options.encodingOptions.sQualityMode == i18n("Bitrate") && (*it)->fileListItem->options.encodingOptions.sBitrateMode == "cbr" ) outputPattern = plugin->enc.lossy.bitrate.cbr.output;
            else if( plugin != 0 && (*it)->fileListItem->options.encodingOptions.sQualityMode == i18n("Bitrate") && (*it)->fileListItem->options.encodingOptions.sBitrateMode == "abr" ) outputPattern = plugin->enc.lossy.bitrate.abr.output;
            if( outputPattern.isEmpty() ) {
                (*it)->fileListItem->setText( fileList->columnByName(i18n("State")), i18n("Encoding")+"... "+i18n("State")+": "+i18n("Unknown") );
            }
            else {
                time += (*it)->encodeTime * (*it)->percent / 100;
                (*it)->fileListItem->setText( fileList->columnByName(i18n("State")), i18n("Encoding")+"... "+TQString().sprintf("%02i %%",(*it)->percent) );
            }
        }
        else if( (*it)->state == ConvertItem::replaygain ) {
            time += (*it)->replaygainTime * (*it)->percent / 100;
            (*it)->fileListItem->setText( fileList->columnByName(i18n("State")), i18n("Replay Gain")+"... "+TQString().sprintf("%02i %%",(*it)->percent) );
        }
        else if( (*it)->state == ConvertItem::put ) {
            (*it)->fileListItem->setText( fileList->columnByName(i18n("State")), i18n("Moving file")+"... "+TQString().sprintf("%02i %%",(*it)->percent) );
        }
        else if( (*it)->state == ConvertItem::put_correction ) {
            time += (*it)->getCorrectionTime * (*it)->percent / 100;
            (*it)->fileListItem->setText( fileList->columnByName(i18n("State")), i18n("Moving correction file")+"... "+TQString().sprintf("%02i %%",(*it)->percent) );
        }
    }
    emit update( time );
}

// void Convert::priorityChanged( int priority )
// { // FIXME setting a higher priority does not work
//     KProcess pChangePriority;
// 
//     for( TQValueList<ConvertItem*>::Iterator it = items.begin(); it != items.end(); it++ ) {
//         if( (*it)->convertProcess->isRunning() ) {
//             //(*it)->convertProcess->setPriority( priority );
//             pChangePriority.clearArguments();
//             pChangePriority << "renice";
//             TQString prio;
//             prio.sprintf( "%i", priority );
//             pChangePriority << prio;
//             TQString pid;
//             pid.sprintf( "%i", (*it)->convertProcess->pid() );
//             pChangePriority << pid;
//             //TQString cmd;
//             //cmd.sprintf( "renice %i %i",  );
//             pChangePriority.start( KProcess::Block );
//         }
//     }
// }