diff options
Diffstat (limited to 'installerbuilder/libinstaller/getrepositoriesmetainfojob.cpp')
| -rw-r--r-- | installerbuilder/libinstaller/getrepositoriesmetainfojob.cpp | 183 |
1 files changed, 183 insertions, 0 deletions
diff --git a/installerbuilder/libinstaller/getrepositoriesmetainfojob.cpp b/installerbuilder/libinstaller/getrepositoriesmetainfojob.cpp new file mode 100644 index 000000000..6c8b2f545 --- /dev/null +++ b/installerbuilder/libinstaller/getrepositoriesmetainfojob.cpp @@ -0,0 +1,183 @@ +/************************************************************************** +** +** 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 "getrepositoriesmetainfojob.h" +#include "getrepositorymetainfojob.h" + +#include <cassert> + +using namespace KDUpdater; +using namespace QInstaller; + +GetRepositoriesMetaInfoJob::GetRepositoriesMetaInfoJob(const QByteArray &publicKey, + bool packageManager, QObject *parent) + : KDJob(parent), + m_publicKey(publicKey), + m_canceled(false), + m_silentRetries(3), + m_packageManager(packageManager), + m_haveIgnoredError(false) +{ + setCapabilities(Cancelable); +} + +QList< Repository > GetRepositoriesMetaInfoJob::repositories() const +{ + return m_repositories; +} + +void GetRepositoriesMetaInfoJob::setRepositories(const QList<Repository>& repos) +{ + m_repositories = repos; +} + +QStringList GetRepositoriesMetaInfoJob::temporaryDirectories() const +{ + return m_repositoryByTemporaryDirectory.keys(); +} + +QStringList GetRepositoriesMetaInfoJob::releaseTemporaryDirectories() const +{ + m_tempDirDeleter.releaseAll(); + return m_repositoryByTemporaryDirectory.keys(); +} + +Repository GetRepositoriesMetaInfoJob::repositoryForTemporaryDirectory(const QString &tmpDir) const +{ + return m_repositoryByTemporaryDirectory.value(tmpDir); +} + +int GetRepositoriesMetaInfoJob::numberOfRetrievedRepositories() const +{ + return m_repositoryByTemporaryDirectory.size(); +} + +int GetRepositoriesMetaInfoJob::silentRetries() const +{ + return m_silentRetries; +} + +void GetRepositoriesMetaInfoJob::setSilentRetries(int retries) +{ + m_silentRetries = retries; +} + +bool GetRepositoriesMetaInfoJob::isCanceled() const +{ + return m_canceled; +} + +void GetRepositoriesMetaInfoJob::doStart() +{ + fetchNextRepo(); +} + +void GetRepositoriesMetaInfoJob::doCancel() +{ + m_canceled = true; + if (m_job) + m_job->cancel(); +} + +void GetRepositoriesMetaInfoJob::fetchNextRepo() +{ + if (m_job) { + m_job->deleteLater(); + m_job = 0; + } + + if (m_canceled) { + emitFinished(); + return; + } + if (m_repositories.isEmpty()) { + if (m_haveIgnoredError) + emitFinishedWithError(UserIgnoreError, m_errorString); + else + emitFinished(); + return; + } + const Repository r = m_repositories.back(); + m_repositories.pop_back(); + m_job = new GetRepositoryMetaInfoJob(m_publicKey, m_packageManager, this); + m_job->setRepository(r); + m_job->setSilentRetries(silentRetries()); + connect(m_job, SIGNAL(finished(KDJob*)), this, SLOT(jobFinished(KDJob*))); + m_job->start(); +} + +void GetRepositoriesMetaInfoJob::slotInfoMessage(KDJob*, const QString& msg) +{ + emit infoMessage(this, msg); +} + +void GetRepositoriesMetaInfoJob::jobFinished(KDJob* j) +{ + const GetRepositoryMetaInfoJob* const job = qobject_cast<const GetRepositoryMetaInfoJob*>(j); + assert(job); + if(job->error() != KDJob::NoError && !job->temporaryDirectory().isEmpty()) { + try { + removeDirectory(job->temporaryDirectory()); + } catch(...) { + } + } + + if (job->error() == KDJob::Canceled) { + emitFinishedWithError(job->error(), job->errorString()); + return; + } + + if (job->error() == GetRepositoryMetaInfoJob::UserIgnoreError) { + m_haveIgnoredError = true; + m_errorString = job->errorString(); + QMetaObject::invokeMethod(this, "fetchNextRepo", Qt::QueuedConnection); + return; + } + + if (job->error() == GetRepositoryMetaInfoJob::InvalidMetaInfo) { + emitFinishedWithError(KDJob::UserDefinedError, tr("Error while accessing online " + "repository: %1. Please try again later").arg(job->errorString())); + return; + } + + if (job->error() != KDJob::NoError && job->repository().required()) { + emitFinishedWithError(KDJob::UserDefinedError, tr("Error while accessing online " + "repository: %1").arg(job->errorString())); + return; + } + + const QString tmpdir = job->releaseTemporaryDirectory(); + job->m_tempDirDeleter.passAndRelease(m_tempDirDeleter, tmpdir); + m_repositoryByTemporaryDirectory.insert(tmpdir, job->repository()); + + QMetaObject::invokeMethod(this, "fetchNextRepo", Qt::QueuedConnection); +} |