diff options
Diffstat (limited to 'installerbuilder/common/zipjob.cpp')
| -rw-r--r-- | installerbuilder/common/zipjob.cpp | 216 |
1 files changed, 216 insertions, 0 deletions
diff --git a/installerbuilder/common/zipjob.cpp b/installerbuilder/common/zipjob.cpp new file mode 100644 index 000000000..0b3018279 --- /dev/null +++ b/installerbuilder/common/zipjob.cpp @@ -0,0 +1,216 @@ +/************************************************************************** +** +** This file is part of Qt SDK** +** +** Copyright (c) 2011 Nokia Corporation and/or its subsidiary(-ies).* +** +** Contact: Nokia Corporation qt-info@nokia.com** +** +** No Commercial Usage +** +** This file contains pre-release code and may not be distributed. +** You may use this file in accordance with the terms and conditions +** contained in the Technology Preview License Agreement accompanying +** this package. +** +** GNU Lesser General Public License Usage +** +** This file may be used under the terms of the GNU Lesser General Public +** License version 2.1 as published by the Free Software Foundation and +** appearing in the file LICENSE.LGPL included in the packaging of this file. +** Please review the following information to ensure the GNU Lesser General +** Public License version 2.1 requirements will be met: +** http://www.gnu.org/licenses/old-licenses/lgpl-2.1.html. +** +** In addition, as a special exception, Nokia gives you certain additional +** rights. These rights are described in the Nokia Qt LGPL Exception version +** 1.1, included in the file LGPL_EXCEPTION.txt in this package. +** +** If you are unsure which license is appropriate for your use, please contact +** (qt-info@nokia.com). +** +**************************************************************************/ +#include <common/zipjob.h> + +#include <QDebug> +#include <QDir> +#include <QStringList> +#include <QMetaType> + +#include <cassert> +#include <climits> + +class ZipJob::Private { + ZipJob* const q; +public: + explicit Private( ZipJob* qq ) : + q( qq ), + outputDevice( 0 ), + process( 0 ) + { + } + + QIODevice* outputDevice; + QDir workingDir; + QProcess* process; + QStringList filesToArchive; +}; + +Q_DECLARE_METATYPE( QProcess::ExitStatus ); + +ZipJob::ZipJob() + : QObject(), + QRunnable(), + d( new Private( this ) ) +{ + qRegisterMetaType< QProcess::ExitStatus >(); +} + +ZipJob::~ZipJob() { + delete d; +} + +void ZipJob::run() { + assert( !d->process ); + d->process = new QProcess; + d->process->setWorkingDirectory( d->workingDir.absolutePath() ); + QStringList args; + args << QLatin1String( "-" ) << QLatin1String( "-r" ) << d->filesToArchive; + connect( d->process, SIGNAL(error(QProcess::ProcessError)), this, SLOT(processError(QProcess::ProcessError)) ); + connect( d->process, SIGNAL(finished(int,QProcess::ExitStatus)), this, SLOT(processFinished(int,QProcess::ExitStatus)) ); + connect( d->process, SIGNAL(readyReadStandardOutput()), this, SLOT(processReadyReadStandardOutput()) ); + + d->process->start( QLatin1String( "zip" ), args ); + if ( !d->process->waitForStarted() ) { + //TODO handle + } + + if ( !d->process->waitForFinished( INT_MAX ) ) { + //TODO handle + } + + delete d->process; + d->process = 0; + // emit result +} + +void ZipJob::processError( QProcess::ProcessError ) { + emit error(); +} + +void ZipJob::processFinished( int, QProcess::ExitStatus ) { + emit finished(); +} + +void ZipJob::processReadyReadStandardOutput() { + const QByteArray buf = d->process->readAll(); + const qint64 toWrite = buf.size(); + qint64 written = 0; + while ( written < toWrite ) { + const qint64 num = d->outputDevice->write( buf.constData() + written, toWrite - written ); + if ( num < 0 ) { + //TODO: handle error + return; + } + written += num; + } +} + +void ZipJob::setOutputDevice( QIODevice* device ) +{ + d->outputDevice = device; +} + +void ZipJob::setWorkingDirectory( const QDir& dir ) { + d->workingDir = dir; +} + +void ZipJob::setFilesToArchive( const QStringList& files ) { + d->filesToArchive = files; +} + +class UnzipJob::Private { + UnzipJob* const q; +public: + explicit Private( UnzipJob* qq ) + : q( qq ), + inputDevice( 0 ) + { + } + +public: + QIODevice* inputDevice; + QString outputPath; + QStringList filesToExtract; +}; + +UnzipJob::UnzipJob() + : QObject(), + QRunnable(), + d( new Private( this ) ) +{ + qRegisterMetaType< QProcess::ExitStatus >(); +} + +UnzipJob::~UnzipJob() { + delete d; +} + +void UnzipJob::setInputDevice( QIODevice* device ) +{ + d->inputDevice = device; +} + +void UnzipJob::setOutputPath( const QString& path ) +{ + d->outputPath = path; +} + +void UnzipJob::processError( QProcess::ProcessError ) +{ + emit error(); +} + +void UnzipJob::run() +{ + QProcess process; + // TODO: this won't work on Windows... grmpfl, but on Mac and Linux, at least... + QStringList args; + args << QLatin1String( "/dev/stdin" ); + if( !d->filesToExtract.isEmpty() ) + args << QLatin1String( "-x" ) << d->filesToExtract; + process.setWorkingDirectory( d->outputPath ); + process.start( QLatin1String( "unzip" ), args ); + connect( &process, SIGNAL( error( QProcess::ProcessError ) ), this, SLOT( processError( QProcess::ProcessError ) ) ); + connect( &process, SIGNAL( finished( int, QProcess::ExitStatus ) ), this, SLOT( processFinished( int, QProcess::ExitStatus ) ) ); + if( !process.waitForStarted() ) + { + // TODO handle + return; + } + + const int bufferSize = 4096; + QByteArray buffer; + while( d->inputDevice->bytesAvailable() > 0 || d->inputDevice->waitForReadyRead( INT_MAX ) ) + { + buffer = d->inputDevice->read( bufferSize ); + process.write( buffer ); + process.waitForBytesWritten( INT_MAX ); + } + process.closeWriteChannel(); + + if( !process.waitForFinished( INT_MAX ) ) + { + // TODO handle + } +} + +void UnzipJob::processFinished( int, QProcess::ExitStatus ) +{ + emit finished(); +} + +void UnzipJob::setFilesToExtract( const QStringList& files ) +{ + d->filesToExtract = files; +} |