Repository mirror

User can 'mirror' a repository.

re #5738
https://pulp.plan.io/issues/5738

CHANGES/5738.feature

@@ -0,0 +1 @@
+Use can 'mirror' a repository.

pulp_rpm/app/models/repository.py

@@ -52,7 +52,11 @@ class RpmRepository(Repository):
 
     sub_repo = models.BooleanField(default=False)
 
-    def new_version(self, base_version=None):
+    def __init__(self, *args, **kwargs):
+        super().__init__(*args, **kwargs)
+        self.mirror = False
+
+    def new_version(self, base_version=None, mirror=False):
         """
         Create a new RepositoryVersion for this Repository.
 
@@ -62,11 +66,13 @@ def new_version(self, base_version=None):
             repository (pulpcore.app.models.Repository): to create a new version of
             base_version (pulpcore.app.models.RepositoryVersion): an optional repository version
                 whose content will be used as the set of content for the new version
+            mirror (bool): new_version is a mirror or not
 
         Returns:
             pulpcore.app.models.RepositoryVersion: The Created RepositoryVersion
 
         """
+        self.mirror = mirror
         with transaction.atomic():
             version = RepositoryVersion(
                 repository=self,
@@ -114,11 +120,13 @@ def finalize_new_version(self, new_version):
 
         remove_duplicates(new_version)
 
-        from pulp_rpm.app.modulemd import resolve_module_packages  # avoid circular import
-        resolve_module_packages(new_version, previous_version)
+        # in mirror mode we don't update, only sync new repo
+        if not self.mirror:
+            from pulp_rpm.app.modulemd import resolve_module_packages  # avoid circular import
+            resolve_module_packages(new_version, previous_version)
 
-        from pulp_rpm.app.advisory import resolve_advisories  # avoid circular import
-        resolve_advisories(new_version, previous_version)
+            from pulp_rpm.app.advisory import resolve_advisories  # avoid circular import
+            resolve_advisories(new_version, previous_version)
 
 
 class RpmRemote(Remote):

pulp_rpm/app/tasks/synchronizing.py

@@ -97,7 +97,7 @@ def repodata_exists(remote, url):
     return True
 
 
-def synchronize(remote_pk, repository_pk):
+def synchronize(remote_pk, repository_pk, mirror):
     """
     Sync content from the remote repository.
 
@@ -146,7 +146,8 @@ def synchronize(remote_pk, repository_pk):
 
     first_stage = RpmFirstStage(remote, deferred_download, treeinfo=treeinfo)
     dv = RpmDeclarativeVersion(first_stage=first_stage,
-                               repository=repository)
+                               repository=repository,
+                               mirror=mirror)
     dv.create()
 
 
@@ -629,6 +630,7 @@ async def run(self):
                                 update_record = UpdateRecord(
                                     **UpdateRecord.createrepo_to_dict(update)
                                 )
+
                                 update_record.digest = hash_update_record(update)
                                 future_relations = {
                                     'collections': defaultdict(list), 'references': []

pulp_rpm/app/viewsets.py

@@ -121,13 +121,15 @@ def sync(self, request, pk):
         )
         serializer.is_valid(raise_exception=True)
         remote = serializer.validated_data.get('remote')
+        mirror = serializer.validated_data.get('mirror', False)
 
         result = enqueue_with_reservation(
             tasks.synchronize,
             [repository, remote],
             kwargs={
                 'remote_pk': remote.pk,
-                'repository_pk': repository.pk
+                'repository_pk': repository.pk,
+                'mirror': mirror
             }
         )
         return OperationPostponedResponse(result, request)