parent
df54439972
commit
6ed7fcec67
@ -0,0 +1,200 @@
|
|||||||
|
// Copyright (c) 2020, The Monero Project
|
||||||
|
//
|
||||||
|
// All rights reserved.
|
||||||
|
//
|
||||||
|
// Redistribution and use in source and binary forms, with or without modification, are
|
||||||
|
// permitted provided that the following conditions are met:
|
||||||
|
//
|
||||||
|
// 1. Redistributions of source code must retain the above copyright notice, this list of
|
||||||
|
// conditions and the following disclaimer.
|
||||||
|
//
|
||||||
|
// 2. Redistributions in binary form must reproduce the above copyright notice, this list
|
||||||
|
// of conditions and the following disclaimer in the documentation and/or other
|
||||||
|
// materials provided with the distribution.
|
||||||
|
//
|
||||||
|
// 3. Neither the name of the copyright holder nor the names of its contributors may be
|
||||||
|
// used to endorse or promote products derived from this software without specific
|
||||||
|
// prior written permission.
|
||||||
|
//
|
||||||
|
// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND ANY
|
||||||
|
// EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
|
||||||
|
// MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL
|
||||||
|
// THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
|
||||||
|
// SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
|
||||||
|
// PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
|
||||||
|
// INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT,
|
||||||
|
// STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF
|
||||||
|
// THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
|
||||||
|
|
||||||
|
import QtQuick 2.9
|
||||||
|
import QtQuick.Controls 2.2
|
||||||
|
import QtQuick.Layouts 1.1
|
||||||
|
|
||||||
|
import moneroComponents.Downloader 1.0
|
||||||
|
|
||||||
|
import "../components" as MoneroComponents
|
||||||
|
|
||||||
|
Popup {
|
||||||
|
id: updateDialog
|
||||||
|
|
||||||
|
property bool allowed: true
|
||||||
|
property string error: ""
|
||||||
|
property string filename: ""
|
||||||
|
property double progress: url && downloader.total > 0 ? downloader.loaded * 100 / downloader.total : 0
|
||||||
|
property bool active: false
|
||||||
|
property string url: ""
|
||||||
|
property bool valid: false
|
||||||
|
property string version: ""
|
||||||
|
|
||||||
|
background: Rectangle {
|
||||||
|
border.color: MoneroComponents.Style.appWindowBorderColor
|
||||||
|
border.width: 1
|
||||||
|
color: MoneroComponents.Style.middlePanelBackgroundColor
|
||||||
|
}
|
||||||
|
closePolicy: Popup.NoAutoClose
|
||||||
|
padding: 20
|
||||||
|
visible: active && allowed
|
||||||
|
|
||||||
|
function show(version, url) {
|
||||||
|
updateDialog.error = "";
|
||||||
|
updateDialog.url = url;
|
||||||
|
updateDialog.valid = false;
|
||||||
|
updateDialog.version = version;
|
||||||
|
updateDialog.active = true;
|
||||||
|
}
|
||||||
|
|
||||||
|
ColumnLayout {
|
||||||
|
id: mainLayout
|
||||||
|
spacing: updateDialog.padding
|
||||||
|
|
||||||
|
Text {
|
||||||
|
color: MoneroComponents.Style.defaultFontColor
|
||||||
|
font.bold: true
|
||||||
|
font.family: MoneroComponents.Style.fontRegular.name
|
||||||
|
font.pixelSize: 18
|
||||||
|
text: qsTr("New Monero version v%1 is available.").arg(updateDialog.version)
|
||||||
|
}
|
||||||
|
|
||||||
|
Text {
|
||||||
|
id: errorText
|
||||||
|
color: "red"
|
||||||
|
font.family: MoneroComponents.Style.fontRegular.name
|
||||||
|
font.pixelSize: 18
|
||||||
|
text: updateDialog.error
|
||||||
|
visible: text
|
||||||
|
}
|
||||||
|
|
||||||
|
Text {
|
||||||
|
id: statusText
|
||||||
|
color: MoneroComponents.Style.defaultFontColor
|
||||||
|
font.family: MoneroComponents.Style.fontRegular.name
|
||||||
|
font.pixelSize: 18
|
||||||
|
visible: !errorText.visible
|
||||||
|
|
||||||
|
text: {
|
||||||
|
if (!updateDialog.url) {
|
||||||
|
return qsTr("Please visit getmonero.org for details") + translationManager.emptyString;
|
||||||
|
}
|
||||||
|
if (downloader.active) {
|
||||||
|
return "%1 (%2%)"
|
||||||
|
.arg(qsTr("Downloading"))
|
||||||
|
.arg(updateDialog.progress.toFixed(1))
|
||||||
|
+ translationManager.emptyString;
|
||||||
|
}
|
||||||
|
if (updateDialog.valid) {
|
||||||
|
return qsTr("Download finished") + translationManager.emptyString;
|
||||||
|
}
|
||||||
|
return qsTr("Do you want to download new version?") + translationManager.emptyString;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
Rectangle {
|
||||||
|
id: progressBar
|
||||||
|
color: MoneroComponents.Style.lightGreyFontColor
|
||||||
|
height: 3
|
||||||
|
Layout.fillWidth: true
|
||||||
|
visible: updateDialog.valid || downloader.active
|
||||||
|
|
||||||
|
Rectangle {
|
||||||
|
color: MoneroComponents.Style.buttonBackgroundColor
|
||||||
|
height: parent.height
|
||||||
|
width: parent.width * updateDialog.progress / 100
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
RowLayout {
|
||||||
|
Layout.alignment: Qt.AlignRight
|
||||||
|
spacing: parent.spacing
|
||||||
|
|
||||||
|
MoneroComponents.StandardButton {
|
||||||
|
id: cancelButton
|
||||||
|
fontBold: false
|
||||||
|
primary: !updateDialog.url
|
||||||
|
text: {
|
||||||
|
if (!updateDialog.url) {
|
||||||
|
return qsTr("Ok") + translationManager.emptyString;
|
||||||
|
}
|
||||||
|
if (updateDialog.valid || downloader.active || errorText.visible) {
|
||||||
|
return qsTr("Cancel") + translationManager.emptyString;
|
||||||
|
}
|
||||||
|
return qsTr("Download later") + translationManager.emptyString;
|
||||||
|
}
|
||||||
|
|
||||||
|
onClicked: {
|
||||||
|
downloader.cancel();
|
||||||
|
updateDialog.active = false;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
MoneroComponents.StandardButton {
|
||||||
|
id: downloadButton
|
||||||
|
KeyNavigation.tab: cancelButton
|
||||||
|
fontBold: false
|
||||||
|
text: (updateDialog.error ? qsTr("Retry") : qsTr("Download")) + translationManager.emptyString
|
||||||
|
visible: updateDialog.url && !updateDialog.valid && !downloader.active
|
||||||
|
|
||||||
|
onClicked: {
|
||||||
|
updateDialog.error = "";
|
||||||
|
updateDialog.filename = updateDialog.url.replace(/^.*\//, '');
|
||||||
|
const downloadingStarted = downloader.get(updateDialog.url, function(error) {
|
||||||
|
if (error) {
|
||||||
|
updateDialog.error = qsTr("Download failed") + translationManager.emptyString;
|
||||||
|
} else {
|
||||||
|
updateDialog.valid = true;
|
||||||
|
}
|
||||||
|
});
|
||||||
|
if (!downloadingStarted) {
|
||||||
|
updateDialog.error = qsTr("Failed to start download") + translationManager.emptyString;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
MoneroComponents.StandardButton {
|
||||||
|
id: saveButton
|
||||||
|
KeyNavigation.tab: cancelButton
|
||||||
|
fontBold: false
|
||||||
|
onClicked: {
|
||||||
|
const fullPath = oshelper.openSaveFileDialog(
|
||||||
|
qsTr("Save as") + translationManager.emptyString,
|
||||||
|
oshelper.downloadLocation(),
|
||||||
|
updateDialog.filename);
|
||||||
|
if (!fullPath) {
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
if (downloader.saveToFile(fullPath)) {
|
||||||
|
cancelButton.clicked();
|
||||||
|
oshelper.openContainingFolder(fullPath);
|
||||||
|
} else {
|
||||||
|
updateDialog.error = qsTr("Save operation failed") + translationManager.emptyString;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
text: qsTr("Save to file") + translationManager.emptyString
|
||||||
|
visible: updateDialog.valid
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
Downloader {
|
||||||
|
id: downloader
|
||||||
|
}
|
||||||
|
}
|
@ -0,0 +1,207 @@
|
|||||||
|
// Copyright (c) 2020, The Monero Project
|
||||||
|
//
|
||||||
|
// All rights reserved.
|
||||||
|
//
|
||||||
|
// Redistribution and use in source and binary forms, with or without modification, are
|
||||||
|
// permitted provided that the following conditions are met:
|
||||||
|
//
|
||||||
|
// 1. Redistributions of source code must retain the above copyright notice, this list of
|
||||||
|
// conditions and the following disclaimer.
|
||||||
|
//
|
||||||
|
// 2. Redistributions in binary form must reproduce the above copyright notice, this list
|
||||||
|
// of conditions and the following disclaimer in the documentation and/or other
|
||||||
|
// materials provided with the distribution.
|
||||||
|
//
|
||||||
|
// 3. Neither the name of the copyright holder nor the names of its contributors may be
|
||||||
|
// used to endorse or promote products derived from this software without specific
|
||||||
|
// prior written permission.
|
||||||
|
//
|
||||||
|
// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND ANY
|
||||||
|
// EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
|
||||||
|
// MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL
|
||||||
|
// THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
|
||||||
|
// SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
|
||||||
|
// PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
|
||||||
|
// INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT,
|
||||||
|
// STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF
|
||||||
|
// THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
|
||||||
|
|
||||||
|
#include "downloader.h"
|
||||||
|
|
||||||
|
#include <QReadLocker>
|
||||||
|
#include <QWriteLocker>
|
||||||
|
|
||||||
|
namespace
|
||||||
|
{
|
||||||
|
|
||||||
|
class DownloaderStateGuard
|
||||||
|
{
|
||||||
|
public:
|
||||||
|
DownloaderStateGuard(bool &active, QReadWriteLock &mutex, std::function<void()> onActiveChanged)
|
||||||
|
: m_active(active)
|
||||||
|
, m_acquired(false)
|
||||||
|
, m_mutex(mutex)
|
||||||
|
, m_onActiveChanged(std::move(onActiveChanged))
|
||||||
|
{
|
||||||
|
{
|
||||||
|
QWriteLocker locker(&m_mutex);
|
||||||
|
|
||||||
|
if (m_active)
|
||||||
|
{
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
m_active = true;
|
||||||
|
}
|
||||||
|
m_onActiveChanged();
|
||||||
|
|
||||||
|
m_acquired = true;
|
||||||
|
}
|
||||||
|
|
||||||
|
~DownloaderStateGuard()
|
||||||
|
{
|
||||||
|
if (!m_acquired)
|
||||||
|
{
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
{
|
||||||
|
QWriteLocker locker(&m_mutex);
|
||||||
|
|
||||||
|
m_active = false;
|
||||||
|
}
|
||||||
|
m_onActiveChanged();
|
||||||
|
}
|
||||||
|
|
||||||
|
bool acquired() const
|
||||||
|
{
|
||||||
|
return m_acquired;
|
||||||
|
}
|
||||||
|
|
||||||
|
private:
|
||||||
|
bool &m_active;
|
||||||
|
bool m_acquired;
|
||||||
|
QReadWriteLock &m_mutex;
|
||||||
|
std::function<void()> m_onActiveChanged;
|
||||||
|
};
|
||||||
|
|
||||||
|
} // namespace
|
||||||
|
|
||||||
|
Downloader::Downloader(QObject *parent)
|
||||||
|
: QObject(parent)
|
||||||
|
, m_active(false)
|
||||||
|
, m_httpClient(new HttpClient())
|
||||||
|
, m_network(this)
|
||||||
|
, m_scheduler(this)
|
||||||
|
{
|
||||||
|
QObject::connect(m_httpClient.get(), SIGNAL(contentLengthChanged()), this, SIGNAL(totalChanged()));
|
||||||
|
QObject::connect(m_httpClient.get(), SIGNAL(receivedChanged()), this, SIGNAL(loadedChanged()));
|
||||||
|
}
|
||||||
|
|
||||||
|
Downloader::~Downloader()
|
||||||
|
{
|
||||||
|
cancel();
|
||||||
|
}
|
||||||
|
|
||||||
|
void Downloader::cancel()
|
||||||
|
{
|
||||||
|
m_httpClient->cancel();
|
||||||
|
|
||||||
|
QWriteLocker locker(&m_mutex);
|
||||||
|
|
||||||
|
m_contents.clear();
|
||||||
|
}
|
||||||
|
|
||||||
|
bool Downloader::get(const QString &url, const QJSValue &callback)
|
||||||
|
{
|
||||||
|
auto future = m_scheduler.run(
|
||||||
|
[this, url]() {
|
||||||
|
DownloaderStateGuard stateGuard(m_active, m_mutex, [this]() {
|
||||||
|
emit activeChanged();
|
||||||
|
});
|
||||||
|
if (!stateGuard.acquired())
|
||||||
|
{
|
||||||
|
return QJSValueList({"downloading is already running"});
|
||||||
|
}
|
||||||
|
|
||||||
|
{
|
||||||
|
QWriteLocker locker(&m_mutex);
|
||||||
|
|
||||||
|
m_contents.clear();
|
||||||
|
}
|
||||||
|
|
||||||
|
std::string response;
|
||||||
|
{
|
||||||
|
QString error;
|
||||||
|
auto task = m_scheduler.run([this, &error, &response, &url] {
|
||||||
|
error = m_network.get(m_httpClient, url, response);
|
||||||
|
});
|
||||||
|
if (!task.first)
|
||||||
|
{
|
||||||
|
return QJSValueList({"failed to start downloading task"});
|
||||||
|
}
|
||||||
|
task.second.waitForFinished();
|
||||||
|
|
||||||
|
if (!error.isEmpty())
|
||||||
|
{
|
||||||
|
return QJSValueList({error});
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if (response.empty())
|
||||||
|
{
|
||||||
|
return QJSValueList({"empty response"});
|
||||||
|
}
|
||||||
|
|
||||||
|
{
|
||||||
|
QWriteLocker locker(&m_mutex);
|
||||||
|
|
||||||
|
m_contents = std::move(response);
|
||||||
|
}
|
||||||
|
|
||||||
|
return QJSValueList({});
|
||||||
|
},
|
||||||
|
callback);
|
||||||
|
|
||||||
|
return future.first;
|
||||||
|
}
|
||||||
|
|
||||||
|
bool Downloader::saveToFile(const QString &path) const
|
||||||
|
{
|
||||||
|
QWriteLocker locker(&m_mutex);
|
||||||
|
|
||||||
|
if (m_active || m_contents.empty())
|
||||||
|
{
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
|
||||||
|
QFile file(path);
|
||||||
|
if (!file.open(QIODevice::WriteOnly))
|
||||||
|
{
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
|
||||||
|
if (static_cast<size_t>(file.write(m_contents.data(), m_contents.size())) != m_contents.size())
|
||||||
|
{
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
|
||||||
|
return true;
|
||||||
|
}
|
||||||
|
|
||||||
|
bool Downloader::active() const
|
||||||
|
{
|
||||||
|
QReadLocker locker(&m_mutex);
|
||||||
|
|
||||||
|
return m_active;
|
||||||
|
}
|
||||||
|
|
||||||
|
quint64 Downloader::loaded() const
|
||||||
|
{
|
||||||
|
return m_httpClient->received();
|
||||||
|
}
|
||||||
|
|
||||||
|
quint64 Downloader::total() const
|
||||||
|
{
|
||||||
|
return m_httpClient->contentLength();
|
||||||
|
}
|
Reference in new issue