8db2489739
If you closed a main_window soon after opening it, and the UpdateCheckThread network request was slow and still in progress, the gui would freeze until the network request finished.
156 lines
6.3 KiB
Python
156 lines
6.3 KiB
Python
# Copyright (C) 2019 The Electrum developers
|
|
# Distributed under the MIT software license, see the accompanying
|
|
# file LICENCE or http://www.opensource.org/licenses/mit-license.php
|
|
|
|
import asyncio
|
|
import base64
|
|
from typing import Optional
|
|
|
|
from PyQt6.QtCore import Qt, QThread, pyqtSignal
|
|
from PyQt6.QtWidgets import (QWidget, QVBoxLayout, QLabel, QProgressBar,
|
|
QHBoxLayout, QPushButton, QDialog)
|
|
|
|
from electrum import version
|
|
from electrum import constants
|
|
from electrum.bitcoin import verify_usermessage_with_address
|
|
from electrum.i18n import _
|
|
from electrum.util import make_aiohttp_session
|
|
from electrum.logging import Logger
|
|
from electrum.network import Network
|
|
from electrum._vendor.distutils.version import StrictVersion
|
|
|
|
|
|
class UpdateCheck(QDialog, Logger):
|
|
url = "https://electrum.org/version"
|
|
download_url = "https://electrum.org/#download"
|
|
|
|
VERSION_ANNOUNCEMENT_SIGNING_KEYS = (
|
|
"13xjmVAB1EATPP8RshTE8S8sNwwSUM9p1P", # ThomasV (since 3.3.4)
|
|
"1Nxgk6NTooV4qZsX5fdqQwrLjYcsQZAfTg", # ghost43 (since 4.1.2)
|
|
)
|
|
|
|
def __init__(self, *, latest_version=None):
|
|
QDialog.__init__(self)
|
|
self.setWindowTitle('Electrum - ' + _('Update Check'))
|
|
self.content = QVBoxLayout()
|
|
self.content.setContentsMargins(*[10]*4)
|
|
|
|
self.heading_label = QLabel()
|
|
self.content.addWidget(self.heading_label)
|
|
|
|
self.detail_label = QLabel()
|
|
self.detail_label.setTextInteractionFlags(Qt.TextInteractionFlag.LinksAccessibleByMouse)
|
|
self.detail_label.setOpenExternalLinks(True)
|
|
self.content.addWidget(self.detail_label)
|
|
|
|
self.pb = QProgressBar()
|
|
self.pb.setMaximum(0)
|
|
self.pb.setMinimum(0)
|
|
self.content.addWidget(self.pb)
|
|
|
|
versions = QHBoxLayout()
|
|
versions.addWidget(QLabel(_("Current version: {}").format(version.ELECTRUM_VERSION)))
|
|
self.latest_version_label = QLabel(_("Latest version: {}").format(" "))
|
|
versions.addWidget(self.latest_version_label)
|
|
self.content.addLayout(versions)
|
|
|
|
self.update_view(latest_version)
|
|
|
|
self.update_check_thread = UpdateCheckThread()
|
|
self.update_check_thread.checked.connect(self.on_version_retrieved)
|
|
self.update_check_thread.failed.connect(self.on_retrieval_failed)
|
|
self.update_check_thread.start()
|
|
|
|
close_button = QPushButton(_("Close"))
|
|
close_button.clicked.connect(self.close)
|
|
self.content.addWidget(close_button)
|
|
self.setLayout(self.content)
|
|
self.show()
|
|
|
|
def on_version_retrieved(self, version):
|
|
self.update_view(version)
|
|
|
|
def on_retrieval_failed(self):
|
|
self.heading_label.setText('<h2>' + _("Update check failed") + '</h2>')
|
|
self.detail_label.setText(_("Sorry, but we were unable to check for updates. Please try again later."))
|
|
self.pb.hide()
|
|
|
|
@staticmethod
|
|
def is_newer(latest_version):
|
|
return latest_version > StrictVersion(version.ELECTRUM_VERSION)
|
|
|
|
def update_view(self, latest_version=None):
|
|
if latest_version:
|
|
self.pb.hide()
|
|
self.latest_version_label.setText(_("Latest version: {}").format(latest_version))
|
|
if self.is_newer(latest_version):
|
|
self.heading_label.setText('<h2>' + _("There is a new update available") + '</h2>')
|
|
url = "<a href='{u}'>{u}</a>".format(u=UpdateCheck.download_url)
|
|
self.detail_label.setText(_("You can download the new version from {}.").format(url))
|
|
else:
|
|
self.heading_label.setText('<h2>' + _("Already up to date") + '</h2>')
|
|
self.detail_label.setText(_("You are already on the latest version of Electrum."))
|
|
else:
|
|
self.heading_label.setText('<h2>' + _("Checking for updates...") + '</h2>')
|
|
self.detail_label.setText(_("Please wait while Electrum checks for available updates."))
|
|
|
|
|
|
class UpdateCheckThread(QThread, Logger):
|
|
checked = pyqtSignal(object)
|
|
failed = pyqtSignal()
|
|
|
|
def __init__(self):
|
|
QThread.__init__(self)
|
|
Logger.__init__(self)
|
|
self.network = Network.get_instance()
|
|
self._fut = None # type: Optional[asyncio.Future]
|
|
|
|
async def get_update_info(self):
|
|
# note: Use long timeout here as it is not critical that we get a response fast,
|
|
# and it's bad not to get an update notification just because we did not wait enough.
|
|
async with make_aiohttp_session(proxy=self.network.proxy, timeout=120) as session:
|
|
async with session.get(UpdateCheck.url) as result:
|
|
signed_version_dict = await result.json(content_type=None)
|
|
# example signed_version_dict:
|
|
# {
|
|
# "version": "3.9.9",
|
|
# "signatures": {
|
|
# "1Lqm1HphuhxKZQEawzPse8gJtgjm9kUKT4": "IA+2QG3xPRn4HAIFdpu9eeaCYC7S5wS/sDxn54LJx6BdUTBpse3ibtfq8C43M7M1VfpGkD5tsdwl5C6IfpZD/gQ="
|
|
# }
|
|
# }
|
|
version_num = signed_version_dict['version']
|
|
sigs = signed_version_dict['signatures']
|
|
for address, sig in sigs.items():
|
|
if address not in UpdateCheck.VERSION_ANNOUNCEMENT_SIGNING_KEYS:
|
|
continue
|
|
sig = base64.b64decode(sig)
|
|
msg = version_num.encode('utf-8')
|
|
if verify_usermessage_with_address(
|
|
address=address, sig65=sig, message=msg,
|
|
net=constants.BitcoinMainnet
|
|
):
|
|
self.logger.info(f"valid sig for version announcement '{version_num}' from address '{address}'")
|
|
break
|
|
else:
|
|
raise Exception('no valid signature for version announcement')
|
|
return StrictVersion(version_num.strip())
|
|
|
|
def run(self):
|
|
if not self.network:
|
|
self.failed.emit()
|
|
return
|
|
self._fut = asyncio.run_coroutine_threadsafe(self.get_update_info(), self.network.asyncio_loop)
|
|
try:
|
|
update_info = self._fut.result()
|
|
except Exception as e:
|
|
self.logger.info(f"got exception: '{repr(e)}'")
|
|
self.failed.emit()
|
|
else:
|
|
self.checked.emit(update_info)
|
|
|
|
def stop(self):
|
|
if self._fut:
|
|
self._fut.cancel()
|
|
self.exit()
|
|
self.wait()
|