#include "downloadManager.h" //#include #include #include #include int downloadManager::downloaded = 0; // ---------------------------------------------------------------------------------------- downloadManager::downloadManager() { qnam = new QNetworkAccessManager(); dip = false; // the whole QDir thing is questionable.. downloadDir = QDir(downloadPath); // Check if downloadPath exists, if not create it. if (!downloadDir.exists()){ if (debug) qDebug() << "Download directory: " << downloadDir.path() << "doesn't exist."; QDir::current().mkdir(downloadPath); if (downloadDir.exists() && debug) qDebug() << "Created download directory: " << downloadDir.path(); } else if (debug) qDebug() << "Download directory: " << downloadDir.path() << "exists."; } // ---------------------------------------------------------------------------------------- void downloadManager::downloadFile(QString& filename){ if (debug) qDebug() << "Received downloadFile signal for:" << filename; QUrl fileUrl; fileUrl = baseURL.resolved(QUrl(filename)); qDebug() << "fileUrl: " << fileUrl; this->processDownloadRequest(fileUrl); } // ---------------------------------------------------------------------------------------- void downloadManager::downloadFile(QUrl& fileUrl){ if (debug) qDebug() << "Received downloadFile signal for:" << fileUrl; this->processDownloadRequest(fileUrl); } // ---------------------------------------------------------------------------------------- void downloadManager::processDownloadRequest(QUrl& url) { // Test on empty URL in case such a call happens, which should not // happen given how javascriptInterface::startDownload(..) is implemented. if (url.isEmpty()){ if (debug) qDebug() << "No URL specified for download."; return; } // If download in progress, enqueue file and return. if (dip) { if (debug) qDebug() << "Download in progress! Enqueueing:" << url.toString() << "(" << dlQ.size() << "in queue)"; dlQ.enqueue(url); return; } // No running downloads: enqueue and start next download. dlQ.enqueue(url); if (debug) qDebug() << "Enqueueing:" << url.toString() << endl; startNextDownload(); } // ---------------------------------------------------------------------------------------- void downloadManager::startNextDownload() { if (dlQ.isEmpty()) { emit downloadQueueEmpty(); if (debug) qDebug() << "Download manager ready. (1)"; return; } if (debug) qDebug() << "Starting next download: " << dlQ.head().toString() << "(" << dlQ.size() << "in queue.)"; // Dequeue next URL to download. QUrl url = dlQ.dequeue(); // Get temporary filename from URL. QString tmp = url.path(); tmp.remove(0, tmp.lastIndexOf(QChar('/')) + 1); if (debug) qDebug() << "Extracted " << tmp << "from " << url.toString(); // temp file name will be renamed to the filename parsed from the // header ("Content-Disposition" --> filename) outfile.setFileName(downloadPath + "/" + tmp); if (!outfile.open(QIODevice::WriteOnly)) { if (debug) qDebug() << "Couldn't open file! Skipping..."; return; } QNetworkRequest request(url); currentDownload = qnam->get(request); if (currentDownload->error() != QNetworkReply::NoError) { if (debug) qDebug() << "Network reply error, skipping download..."; return; } currentProgress = 0; dip = true; QObject::connect(currentDownload, SIGNAL(readyRead()), this, SLOT(downloadReady())); QObject::connect(currentDownload, SIGNAL(downloadProgress(qint64, qint64)), this, SLOT(downloadProgress(qint64, qint64))); QObject::connect(currentDownload, SIGNAL(finished()), this, SLOT(downloadFinished())); } // ---------------------------------------------------------------------------------------- // Private slots // ---------------------------------------------------------------------------------------- // This slot listens to readyRead() emmited when data is available for reading. void downloadManager::downloadReady() { // this is done every signal call atm, to fix... const QByteArray cd = "Content-Disposition"; QByteArray cdc = currentDownload->rawHeader(cd); cdc.chop(1); int x = cdc.indexOf("filename=\"") + 10; cdc.remove(0, x); // End file name = cdc. currentTargetFilename = cdc; // readyRead() fired, so save the readable data. outfile.write(currentDownload->readAll()); } // ---------------------------------------------------------------------------------------- // This triggers sends the update progress back to the site. void downloadManager::downloadProgress(qint64 bytesIn, qint64 bytesTotal) { if (debug) qDebug() << "Download progress of " << currentDownload->url().toString() << ": " << bytesIn << "/" << bytesTotal; int tmp = ((bytesIn * 100) / bytesTotal); if (tmp > currentProgress){ currentProgress = tmp; emit updateProgress(currentDownload->url().toString(), tmp); } // Progress difference < 1% return; } // ---------------------------------------------------------------------------------------- // This slot listens to the finished() which is emmited // when all the data from the reply has been read. void downloadManager::downloadFinished() { // Close output file. outfile.close(); QString tmp = outfile.fileName(); tmp.remove(0, tmp.lastIndexOf(QChar('/')) + 1); qDebug() << "Trying to rename " << tmp << " to --> " << currentTargetFilename; if (outfile.rename(downloadPath + "/" + currentTargetFilename)) { if (debug) qDebug() << "Renamed file!"; } else { if (debug) qDebug() << "Failure to rename file!"; } currentDownload->deleteLater(); downloaded++; dip = false; if (debug) qDebug() << "Download of " << currentDownload->url().toString() << "finished. (dlcount = "<< downloaded << ")"; // If queue is empty, we are done. if (dlQ.isEmpty()){ emit downloadQueueEmpty(); if (debug) qDebug() << "Download manager ready. (2)"; return; } // Queue not empty: initialise next download. startNextDownload(); }