From 097ba4c6418e04db42cd2fa8bc238c70276ee8b4 Mon Sep 17 00:00:00 2001
From: Daniil Anfimov <anfimovdan@gmail.com>
Date: Wed, 13 May 2026 00:10:48 +0300
Subject: [PATCH] Add --use-remote-url flag to bootstrap_repositories.py

For dev instances that should not sync from remotes. When set, production
repos are registered with remote_url as their URL and Pulp repo/remote/sync
steps are skipped. Also works with -U: rewrites each repo's url to its
remote_url on update.
---
 alws/schemas/repository_schema.py |  1 +
 scripts/bootstrap_repositories.py | 29 ++++++++++++++++++++++++++++-
 2 files changed, 29 insertions(+), 1 deletion(-)

diff --git a/alws/schemas/repository_schema.py b/alws/schemas/repository_schema.py
index 69323a06d..32f24b51e 100644
--- a/alws/schemas/repository_schema.py
+++ b/alws/schemas/repository_schema.py
@@ -58,6 +58,7 @@ class RepositoryUpdate(BaseModel):
     export_path: typing.Optional[str] = None
     pulp_href: typing.Optional[str] = None
     mock_enabled: bool = True
+    url: typing.Optional[str] = None
 
 
 class RepositorySync(BaseModel):
diff --git a/scripts/bootstrap_repositories.py b/scripts/bootstrap_repositories.py
index 2a8c2b460..4e2699453 100644
--- a/scripts/bootstrap_repositories.py
+++ b/scripts/bootstrap_repositories.py
@@ -48,6 +48,15 @@ def parse_args():
         required=False,
         help="Do not sync repositories with " "corresponding remotes",
     )
+    parser.add_argument(
+        "--use-remote-url",
+        action="store_true",
+        default=False,
+        required=False,
+        help="Use remote_url directly as the repository URL even for "
+        "production repos, skipping Pulp repo/remote creation and sync. "
+        "Intended for dev instances that should not sync from remotes.",
+    )
     parser.add_argument(
         "-c",
         "--config",
@@ -261,6 +270,7 @@ async def process_repository(
     repo_info: dict,
     no_remotes: bool,
     no_sync: bool,
+    use_remote_url: bool,
     logger: logging.Logger,
 ):
     """Process a single repo: create repo + remote, return (id, sync_info)."""
@@ -270,6 +280,14 @@ async def process_repository(
     repo_sync_policy = repo_info.pop("repository_sync_policy", None)
     remote_sync_policy = repo_info.pop("remote_sync_policy", None)
 
+    if use_remote_url and is_production:
+        logger.info(
+            "use_remote_url is enabled; treating production repo %s as "
+            "non-production (remote_url used directly, no Pulp sync)",
+            repo_name,
+        )
+        is_production = False
+
     repository = await get_repository(
         pulp_client, repo_info, repo_name, is_production, logger
     )
@@ -317,6 +335,7 @@ async def process_repositories(
     repositories_data: list,
     no_remotes: bool,
     no_sync: bool,
+    use_remote_url: bool,
     logger: logging.Logger,
 ):
     sem = asyncio.Semaphore(BOOTSTRAP_CONCURRENCY)
@@ -324,7 +343,12 @@ async def process_repositories(
     async def bounded(repo_info):
         async with sem:
             return await process_repository(
-                pulp_client, repo_info, no_remotes, no_sync, logger
+                pulp_client,
+                repo_info,
+                no_remotes,
+                no_sync,
+                use_remote_url,
+                logger,
             )
 
     return await asyncio.gather(*(bounded(r) for r in repositories_data))
@@ -415,6 +439,8 @@ async def main_async():
                 platform_name,
             )
             for repo_id, repo_data in repos_to_update.items():
+                if args.use_remote_url and repo_data.get("remote_url"):
+                    repo_data = {**repo_data, "url": repo_data["remote_url"]}
                 await update_repository(repo_id, repo_data)
             logger.info(
                 "Updating repository data for platform %s is completed",
@@ -437,6 +463,7 @@ async def main_async():
             repositories_data,
             args.no_remotes,
             args.no_sync,
+            args.use_remote_url,
             logger,
         )
         repos_to_sync = []