mirrors/legendary
1
0
Fork 0
mirror of https://github.com/derrod/legendary.git synced 2025-02-27 07:46:45 +00:00
Code Issues Projects Releases Wiki Activity

Handle file tasks case-insensitively

Browse source
This commit is contained in:
Mathis Dröge 2025-02-11 09:15:51 +01:00
parent 3963382b3f
commit f08dbc4a62
No known key found for this signature in database
GPG key ID: 3071D4EFBB298F5F
1 changed files with 8 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
legendary/downloader/mp/workers.py
View file

@ -12,6 +12,7 @@ from queue import Empty
import requests import requests
from requests.adapters import HTTPAdapter, DEFAULT_POOLBLOCK from requests.adapters import HTTPAdapter, DEFAULT_POOLBLOCK
from legendary.lfs.wine_helpers import case_insensitive_file_search
from legendary.models.chunk import Chunk from legendary.models.chunk import Chunk
from legendary.models.downloading import ( from legendary.models.downloading import (
DownloaderTask, DownloaderTaskResult, DownloaderTask, DownloaderTaskResult,
@ -187,11 +188,12 @@ class FileWorker(Process):
break break
# make directories if required # make directories if required
path = os.path.split(j.filename)[0] path, filename = os.path.split(j.filename)
if not os.path.exists(os.path.join(self.base_path, path)): file_dir = case_insensitive_file_search(os.path.join(self.base_path, path))
os.makedirs(os.path.join(self.base_path, path)) if not os.path.exists(file_dir):
os.makedirs(file_dir)
full_path = os.path.join(self.base_path, j.filename) full_path = os.path.join(file_dir, filename)
if j.flags & TaskFlags.CREATE_EMPTY_FILE: # just create an empty file if j.flags & TaskFlags.CREATE_EMPTY_FILE: # just create an empty file
open(full_path, 'a').close() open(full_path, 'a').close()
@ -230,7 +232,8 @@ class FileWorker(Process):
continue continue
try: try:
os.rename(os.path.join(self.base_path, j.old_file), full_path) old_path = case_insensitive_file_search(os.path.join(self.base_path, j.old_file))
os.rename(old_path, full_path)
except OSError as e: except OSError as e:
logger.error(f'Renaming file failed: {e!r}') logger.error(f'Renaming file failed: {e!r}')
self.o_q.put(WriterTaskResult(success=False, **j.__dict__)) self.o_q.put(WriterTaskResult(success=False, **j.__dict__))