swatbotrest: Invalidate all stepfailures lists when pushing new triage

Signed-off-by: Mathieu Dubois-Briand <[email protected]>

swattool/swatbotrest.py

@@ -164,7 +164,7 @@ def invalidate_stepfailures_cache():
     This can be used to force fetching failures on next build, when we suspect
     it might have changed remotely.
     """
-    Session().invalidate_cache(f"{REST_BASE_URL}/stepfailure/")
+    Session().invalidate_cache(f"{REST_BASE_URL}/stepfailure/", allparams=True)
 
 
 def get_stepfailures(status: Optional[TriageStatus] = None,

swattool/webrequests.py

@@ -53,25 +53,35 @@ def save_cookies(self):
             with COOKIESFILE.open('wb') as file:
                 pickle.dump(self.session.cookies, file)
 
-    def invalidate_cache(self, url: str):
+    def invalidate_cache(self, url: str, allparams: bool = False):
         """Invalidate cache for a given URL."""
         with cache_lock:
-            for file in self._get_cache_file_candidates(url):
-                file.unlink(missing_ok=True)
+            if allparams:
+                prefix = self._get_cache_file_prefix(url)
+                for file in prefix.parent.glob(f"{prefix.name}*"):
+                    file.unlink()
+            else:
+                for file in self._get_cache_file_candidates(url):
+                    file.unlink(missing_ok=True)
 
-    def _get_cache_file_candidates(self, url: str) -> list[pathlib.Path]:
+    def _get_cache_file_prefix(self, url: str) -> pathlib.Path:
         filestem = url.split('://', 1)[1].replace('/', '_').replace(':', '_')
 
         if len(filestem) > 100:
             hashname = hashlib.sha256(filestem.encode(), usedforsecurity=False)
             filestem = hashname.hexdigest()
 
+        return utils.CACHEDIR / filestem
+
+    def _get_cache_file_candidates(self, url: str) -> list[pathlib.Path]:
+        prefix = self._get_cache_file_prefix(url)
+
         candidates = [
-            utils.CACHEDIR / f"{filestem}.gz",
-            utils.CACHEDIR / filestem,
+            prefix.with_suffix('.gz'),
+            prefix,
 
             # For compatibility with old cache files
-            utils.CACHEDIR / f"{filestem}.json",
+            prefix.with_suffix('.json'),
         ]
 
         return candidates