yacloud/shadowmire
1
0
Fork 0
mirror of https://github.com/taoky/shadowmire.git synced 2025-07-08 09:12:43 +00:00
Code Issues Packages Projects Releases Wiki Activity

Auto PyPI fallback in SyncPlainHTTP

Browse Source
This commit is contained in:
taoky 2025-07-07 01:39:07 +08:00
parent 94cc16db5e
commit 1c8b0199b4
1 changed files with 38 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

42
shadowmire.py
View File

@ -674,7 +674,9 @@ class SyncBase:
exit_with_futures(futures) exit_with_futures(futures)
logger.info("%s packages to update in check_and_update()", len(to_update)) logger.info("%s packages to update in check_and_update()", len(to_update))
return self.parallel_update(to_update, prerelease_excludes, excluded_wheel_filenames) return self.parallel_update(
to_update, prerelease_excludes, excluded_wheel_filenames
)
def parallel_update( def parallel_update(
self, self,
@ -732,7 +734,9 @@ class SyncBase:
for package_name in to_remove: for package_name in to_remove:
self.do_remove(package_name) self.do_remove(package_name)
return self.parallel_update(to_update, prerelease_excludes, excluded_wheel_filenames) return self.parallel_update(
to_update, prerelease_excludes, excluded_wheel_filenames
)
def do_remove( def do_remove(
self, package_name: str, use_db: bool = True, remove_packages: bool = True self, package_name: str, use_db: bool = True, remove_packages: bool = True
@ -848,21 +852,33 @@ def download(
def filter_release_from_meta( def filter_release_from_meta(
meta: dict, patterns: list[re.Pattern[str]] | tuple[re.Pattern[str], ...] meta: dict, patterns: list[re.Pattern[str]] | tuple[re.Pattern[str], ...]
) -> None: ) -> bool:
"""
Returns True if meta changes, False otherwise.
"""
changed = False
for release in list(meta["releases"].keys()): for release in list(meta["releases"].keys()):
if match_patterns(release, patterns): if match_patterns(release, patterns):
del meta["releases"][release] del meta["releases"][release]
changed = True
return changed
def filter_wheel_file_from_meta( def filter_wheel_file_from_meta(
meta: dict, patterns: list[re.Pattern[str]] | tuple[re.Pattern[str], ...] meta: dict, patterns: list[re.Pattern[str]] | tuple[re.Pattern[str], ...]
) -> None: ) -> bool:
"""
Returns True if meta changes, False otherwise.
"""
changed = False
for release_infos in meta["releases"].values(): for release_infos in meta["releases"].values():
for release_idx in range(len(release_infos) - 1, -1, -1): for release_idx in range(len(release_infos) - 1, -1, -1):
release_info = release_infos[release_idx] release_info = release_infos[release_idx]
filename = release_info["filename"] filename = release_info["filename"]
if match_patterns(filename, patterns): if match_patterns(filename, patterns):
del release_infos[release_idx] del release_infos[release_idx]
changed = True
return changed
class SyncPyPI(SyncBase): class SyncPyPI(SyncBase):
@ -976,6 +992,9 @@ class SyncPyPI(SyncBase):
json_meta_path = self.jsonmeta_dir / package_name json_meta_path = self.jsonmeta_dir / package_name
with overwrite(json_meta_path) as f: with overwrite(json_meta_path) as f:
# Note that we're writing meta_original here! # Note that we're writing meta_original here!
# This is also the case for SyncPlainHTTP.
# When syncing, we want to keep the original meta (json/),
# but index.v1_json and index.v1_html are generated from modified meta.
json.dump(meta_original, f) json.dump(meta_original, f)
if use_db: if use_db:
@ -1071,7 +1090,20 @@ class SyncPlainHTTP(SyncBase):
dest.parent.mkdir(parents=True, exist_ok=True) dest.parent.mkdir(parents=True, exist_ok=True)
success, resp = download(self.session, url, dest) success, resp = download(self.session, url, dest)
if not success: if not success:
logger.warning("skipping %s as it fails downloading", package_name) if resp and resp.status_code == 404:
# handle special case: upstream filters out some files
logger.warning("cannot find %s at upstream, fallback to pypi", url)
url = i["url"] # original pypi URL
success, resp = download(self.session, url, dest)
if not success:
logger.warning(
"skipping %s as it fails downloading (from pypi)", package_name
)
return None
else:
logger.warning(
"skipping %s as it fails downloading", package_name
)
return None return None
# OK, now it's safe to rename # OK, now it's safe to rename