4063195b4d
When updates are queued, they are removed from the update's list. An exceptions is made when the queued item comes from repairing (without updating), in which case the update is disabled for the runtime. A queued item can be either removed (if it is an update it will be added back to the updates groups) or forced to be updated now. If a queued item is forced, the currently running item will be added to the front of the queue. Downloads will be queued if there is no active download but there is a queue already. The download thread is now responsible for emitting the progress to `RareGame` InstallDialog: Pass `RareGame` and `InstallOptionsModel` only as arguments. The `update`, `repair` and `silent` arguments are already part of `InstallOptionsModel` `RareGame` is used to query information about the game. InstallInfoWorker: Pass only `InstallOptionsModel` as argument Emit `InstallQueueItemModel` as result, to re-use the worker when queuing stopped games RareGame: Query and store metadata property about entitlement grant date RareGame: Add `RareEosOverlay` class that imitates `RareGame` to handle the overlay LibraryWidgetController: Remove dead signal routing code, these signals are handled by `RareGame` Directly parent library widgets instead of reparenting them GameWidgets: Remove unused signals EOSGroup: Set install location based on preferences and use EOSOverlayApp from legendary GamesTab: Connect the `progress` signals of dlcs to the base game's signals GamesTab: Remove dead code GlobalSignals: Remove `ProgresSignals` RareCore: Mangle internal signleton's names Signed-off-by: loathingKernel <142770+loathingKernel@users.noreply.github.com>
81 lines
3.3 KiB
Python
81 lines
3.3 KiB
Python
import os
|
|
import sys
|
|
from argparse import Namespace
|
|
from logging import getLogger
|
|
|
|
from PyQt5.QtCore import pyqtSignal, QObject, QRunnable
|
|
|
|
from rare.lgndr.cli import LegendaryCLI
|
|
from rare.lgndr.core import LegendaryCore
|
|
from rare.lgndr.glue.arguments import LgndrVerifyGameArgs
|
|
from rare.lgndr.glue.monkeys import LgndrIndirectStatus
|
|
from rare.models.game import RareGame
|
|
|
|
logger = getLogger("VerificationWorker")
|
|
|
|
|
|
class VerifyWorker(QRunnable):
|
|
class Signals(QObject):
|
|
status = pyqtSignal(RareGame, int, int, float, float)
|
|
result = pyqtSignal(RareGame, bool, int, int)
|
|
error = pyqtSignal(RareGame, str)
|
|
|
|
num: int = 0
|
|
total: int = 1 # set default to 1 to avoid DivisionByZero before it is initialized
|
|
|
|
def __init__(self, core: LegendaryCore, args: Namespace, rgame: RareGame):
|
|
sys.excepthook = sys.__excepthook__
|
|
super(VerifyWorker, self).__init__()
|
|
self.signals = VerifyWorker.Signals()
|
|
self.setAutoDelete(True)
|
|
self.core = core
|
|
self.args = args
|
|
self.rgame = rgame
|
|
|
|
def status_callback(self, num: int, total: int, percentage: float, speed: float):
|
|
self.rgame.signals.progress.update.emit(num * 100 // total)
|
|
self.signals.status.emit(self.rgame, num, total, percentage, speed)
|
|
|
|
def run(self):
|
|
self.rgame.signals.progress.start.emit()
|
|
cli = LegendaryCLI(self.core)
|
|
status = LgndrIndirectStatus()
|
|
args = LgndrVerifyGameArgs(
|
|
app_name=self.rgame.app_name, indirect_status=status, verify_stdout=self.status_callback
|
|
)
|
|
|
|
# lk: first pass, verify with the current manifest
|
|
repair_mode = False
|
|
result = cli.verify_game(
|
|
args, print_command=False, repair_mode=repair_mode, repair_online=not self.args.offline
|
|
)
|
|
if result is None:
|
|
# lk: second pass with downloading the latest manifest
|
|
# lk: this happens if the manifest was not found and repair_mode was not requested
|
|
# lk: we already have checked if the directory exists before starting the worker
|
|
try:
|
|
# lk: this try-except block handles the exception caused by a missing manifest
|
|
# lk: and is raised only in the case we are offline
|
|
repair_mode = True
|
|
result = cli.verify_game(
|
|
args, print_command=False, repair_mode=repair_mode, repair_online=not self.args.offline
|
|
)
|
|
if result is None:
|
|
raise ValueError
|
|
except ValueError:
|
|
self.rgame.signals.progress.finish.emit(True)
|
|
self.signals.error.emit(self.rgame, status.message)
|
|
return
|
|
|
|
success = result is not None and not any(result)
|
|
if success:
|
|
# lk: if verification was successful we delete the repair file and run the clean procedure
|
|
# lk: this could probably be cut down to what is relevant for this use-case and skip the `cli` call
|
|
repair_file = os.path.join(self.core.lgd.get_tmp_path(), f"{self.rgame.app_name}.repair")
|
|
cli.install_game_cleanup(game=self.rgame.game, igame=self.rgame.igame, repair_mode=True, repair_file=repair_file)
|
|
self.rgame.update_rgame()
|
|
|
|
self.rgame.signals.progress.finish.emit(False)
|
|
self.signals.result.emit(self.rgame, success, *result)
|
|
|