policies/reputation: delete reputation data from cache once save in d…

…atabase

Signed-off-by: Marc 'risson' Schmitt <marc.schmitt@risson.space>

authentik/policies/reputation/tasks.py

@@ -19,7 +19,8 @@
 def save_reputation(self: SystemTask):
     """Save currently cached reputation to database"""
     objects_to_update = []
-    for _, score in cache.get_many(cache.keys(CACHE_KEY_PREFIX + "*")).items():
+    data = cache.get_many(cache.keys(CACHE_KEY_PREFIX + "*"))
+    for _, score in data.items():
         rep, _ = Reputation.objects.get_or_create(
             ip=score["ip"],
             identifier=score["identifier"],
@@ -29,4 +30,5 @@ def save_reputation(self: SystemTask):
         rep.score = score["score"]
         objects_to_update.append(rep)
     Reputation.objects.bulk_update(objects_to_update, ["score", "ip_geo_data"])
+    cache.delete_many(data.keys())
     self.set_status(TaskStatus.SUCCESSFUL, "Successfully updated Reputation")