# HG changeset patch
# User RhodeCode Admin <admin@rhodecode.com>
# Date 2024-07-29 16:02:15
# Node ID a9fbe41d368faacc5b5a68002c23225e77519ef7
# Parent  633e0a3d379429b7bb6e044b8dca7e90c936c202

feat(caches): make sure commit-caches propagate to parent repo groups

diff --git a/rhodecode/lib/celerylib/tasks.py b/rhodecode/lib/celerylib/tasks.py
--- a/rhodecode/lib/celerylib/tasks.py
+++ b/rhodecode/lib/celerylib/tasks.py
@@ -207,7 +207,7 @@ def create_repo(form_data, cur_user):
         hooks_base.create_repository(created_by=owner.username, **repo.get_dict())
 
         # update repo commit caches initially
-        repo.update_commit_cache()
+        repo.update_commit_cache(recursive=False)
 
         # set new created state
         repo.set_state(Repository.STATE_CREATED)
@@ -298,7 +298,7 @@ def create_repo_fork(form_data, cur_user
         # update repo commit caches initially
         config = repo._config
         config.set('extensions', 'largefiles', '')
-        repo.update_commit_cache(config=config)
+        repo.update_commit_cache(config=config, recursive=False)
 
         # set new created state
         repo.set_state(Repository.STATE_CREATED)
@@ -390,7 +390,7 @@ def sync_last_update_for_objects(*args, 
             .order_by(Repository.group_id.asc())
 
         for repo in repos:
-            repo.update_commit_cache()
+            repo.update_commit_cache(recursive=False)
 
     skip_groups = kwargs.get('skip_groups')
     if not skip_groups:
diff --git a/rhodecode/lib/utils.py b/rhodecode/lib/utils.py
--- a/rhodecode/lib/utils.py
+++ b/rhodecode/lib/utils.py
@@ -582,7 +582,7 @@ def repo2db_mapper(initial_repo_list, re
                 log.debug('Running update server info')
                 git_repo._update_server_info(force=True)
 
-            db_repo.update_commit_cache()
+            db_repo.update_commit_cache(recursive=False)
 
         config = db_repo._config
         config.set('extensions', 'largefiles', '')
diff --git a/rhodecode/model/db.py b/rhodecode/model/db.py
--- a/rhodecode/model/db.py
+++ b/rhodecode/model/db.py
@@ -2568,10 +2568,10 @@ class Repository(Base, BaseModel):
         return commit
 
     def flush_commit_cache(self):
-        self.update_commit_cache(cs_cache={'raw_id':'0'})
+        self.update_commit_cache(cs_cache={'raw_id': '0'})
         self.update_commit_cache()
 
-    def update_commit_cache(self, cs_cache=None, config=None):
+    def update_commit_cache(self, cs_cache=None, config=None, recursive=True):
         """
         Update cache of last commit for repository
         cache_keys should be::
@@ -2610,6 +2610,14 @@ class Repository(Base, BaseModel):
         if isinstance(cs_cache, BaseCommit):
             cs_cache = cs_cache.__json__()
 
+        def maybe_update_recursive(instance, _config, _recursive, _cs_cache, _last_change):
+            if _recursive:
+                repo_id = instance.repo_id
+                _cs_cache['source_repo_id'] = repo_id
+                for gr in instance.groups_with_parents:
+                    gr.changeset_cache = _cs_cache
+                    gr.updated_on = _last_change
+
         def is_outdated(new_cs_cache):
             if (new_cs_cache['raw_id'] != self.changeset_cache['raw_id'] or
                 new_cs_cache['revision'] != self.changeset_cache['revision']):
@@ -2636,6 +2644,7 @@ class Repository(Base, BaseModel):
             self.changeset_cache = cs_cache
             self.updated_on = last_change
             Session().add(self)
+            maybe_update_recursive(self, config, recursive, cs_cache, last_change)
             Session().commit()
 
         else:
@@ -2650,6 +2659,7 @@ class Repository(Base, BaseModel):
             self.changeset_cache = cs_cache
             self.updated_on = _date_latest
             Session().add(self)
+            maybe_update_recursive(self, config, recursive, cs_cache, _date_latest)
             Session().commit()
 
         log.debug('updated repo `%s` with new commit cache %s, and last update_date: %s',