Delete unloved beatmap files along with db rows

common/osu/beatmap_provider.py

@@ -16,6 +16,10 @@ class AbstractBeatmapProvider(ABC):
     def get_beatmap_file(self, beatmap_id: str) -> str:
         raise NotImplementedError()
 
+    @abstractmethod
+    def delete_beatmap(self, beatmap_id: str):
+        raise NotImplementedError()
+
 
 class LiveBeatmapProvider(AbstractBeatmapProvider):
     def get_beatmap_file(self, beatmap_id: str) -> str:
@@ -32,6 +36,11 @@ def get_beatmap_file(self, beatmap_id: str) -> str:
 
         return beatmap_path
 
+    def delete_beatmap(self, beatmap_id: str):
+        beatmap_path = os.path.join(settings.BEATMAP_CACHE_PATH, f"{beatmap_id}.osu")
+        if os.path.isfile(beatmap_path):
+            os.remove(beatmap_path)
+
 
 class StubBeatmapProvider(AbstractBeatmapProvider):
     def get_beatmap_file(self, beatmap_id: str) -> str:
@@ -49,6 +58,9 @@ def get_beatmap_file(self, beatmap_id: str) -> str:
 
         return beatmap_path
 
+    def delete_beatmap(self, beatmap_id: str):
+        pass
+
 
 BeatmapProvider: Type[AbstractBeatmapProvider] = import_string(
     settings.BEATMAP_PROVIDER_CLASS

profiles/tasks.py

@@ -3,6 +3,7 @@
 
 from celery import shared_task
 
+from common.osu.beatmap_provider import BeatmapProvider
 from common.osu.enums import BeatmapStatus, Gamemode
 from leaderboards.models import Leaderboard
 from leaderboards.tasks import update_memberships
@@ -91,6 +92,8 @@ def update_loved_beatmaps():
                 f"Beatmap {beatmap.id} appears to have been unloved. Deleting..."
             )
             beatmap.delete()
+            beatmap_provider = BeatmapProvider()
+            beatmap_provider.delete_beatmap(str(beatmap.id))
             return None
 
         outdated_scores = updated_beatmap.scores.filter(