27c0c7c01f
Some checks failed
Mark stable commit / test-unit (push) Has been cancelled
Mark stable commit / test-integration (push) Has been cancelled
Mark stable commit / test-env-virtual (push) Has been cancelled
Mark stable commit / test-env-nix (push) Has been cancelled
Mark stable commit / test-e2e (push) Has been cancelled
Mark stable commit / test-virgin-user (push) Has been cancelled
Mark stable commit / test-virgin-root (push) Has been cancelled
Mark stable commit / codesniffer-shellcheck (push) Has been cancelled
Mark stable commit / codesniffer-ruff (push) Has been cancelled
Mark stable commit / mark-stable (push) Has been cancelled
* Parse host, owner, and repository name directly from Git remote URLs * Prevent provisioning under incorrect repository names * Make Git URL the single source of truth for remote provisioning * Improve diagnostics when URL parsing fails
71 lines
2.4 KiB
Python
71 lines
2.4 KiB
Python
# src/pkgmgr/actions/mirror/remote_provision.py
|
|
from __future__ import annotations
|
|
|
|
from typing import List
|
|
|
|
from pkgmgr.core.remote_provisioning import ProviderHint, RepoSpec, ensure_remote_repo
|
|
from pkgmgr.core.remote_provisioning.ensure import EnsureOptions
|
|
|
|
from .context import build_context
|
|
from .git_remote import determine_primary_remote_url
|
|
from .types import Repository
|
|
from .url_utils import normalize_provider_host, parse_repo_from_git_url
|
|
|
|
|
|
def ensure_remote_repository(
|
|
repo: Repository,
|
|
repositories_base_dir: str,
|
|
all_repos: List[Repository],
|
|
preview: bool,
|
|
) -> None:
|
|
ctx = build_context(repo, repositories_base_dir, all_repos)
|
|
resolved_mirrors = ctx.resolved_mirrors
|
|
|
|
primary_url = determine_primary_remote_url(repo, resolved_mirrors)
|
|
if not primary_url:
|
|
print("[INFO] No remote URL could be derived; skipping remote provisioning.")
|
|
return
|
|
|
|
host_raw, owner_from_url, name_from_url = parse_repo_from_git_url(primary_url)
|
|
host = normalize_provider_host(host_raw)
|
|
|
|
if not host or not owner_from_url or not name_from_url:
|
|
print("[WARN] Could not derive host/owner/repository from URL; cannot ensure remote repo.")
|
|
print(f" url={primary_url!r}")
|
|
print(f" host={host!r}, owner={owner_from_url!r}, repository={name_from_url!r}")
|
|
return
|
|
|
|
print("------------------------------------------------------------")
|
|
print(f"[REMOTE ENSURE] {ctx.identifier}")
|
|
print(f"[REMOTE ENSURE] host: {host}")
|
|
print("------------------------------------------------------------")
|
|
|
|
spec = RepoSpec(
|
|
host=str(host),
|
|
owner=str(owner_from_url),
|
|
name=str(name_from_url),
|
|
private=bool(repo.get("private", True)),
|
|
description=str(repo.get("description", "")),
|
|
)
|
|
|
|
provider_kind = str(repo.get("provider", "")).strip().lower() or None
|
|
|
|
try:
|
|
result = ensure_remote_repo(
|
|
spec,
|
|
provider_hint=ProviderHint(kind=provider_kind),
|
|
options=EnsureOptions(
|
|
preview=preview,
|
|
interactive=True,
|
|
allow_prompt=True,
|
|
save_prompt_token_to_keyring=True,
|
|
),
|
|
)
|
|
print(f"[REMOTE ENSURE] {result.status.upper()}: {result.message}")
|
|
if result.url:
|
|
print(f"[REMOTE ENSURE] URL: {result.url}")
|
|
except Exception as exc: # noqa: BLE001
|
|
print(f"[ERROR] Remote provisioning failed: {exc}")
|
|
|
|
print()
|