Merge branch '163-lock' into 'develop'

Resolve "Add a database lock when downloading remote file"

Closes #163

See merge request funkwhale/funkwhale!145

api/funkwhale_api/music/views.py

@@ -23,13 +23,14 @@ from rest_framework import permissions
 from musicbrainzngs import ResponseError
 
 from funkwhale_api.common import utils as funkwhale_utils
-from funkwhale_api.federation import actors
-from funkwhale_api.requests.models import ImportRequest
-from funkwhale_api.musicbrainz import api
 from funkwhale_api.common.permissions import (
     ConditionalAuthentication, HasModelPermission)
 from taggit.models import Tag
+from funkwhale_api.federation import actors
 from funkwhale_api.federation.authentication import SignatureAuthentication
+from funkwhale_api.federation.models import LibraryTrack
+from funkwhale_api.musicbrainz import api
+from funkwhale_api.requests.models import ImportRequest
 
 from . import filters
 from . import forms
@@ -195,12 +196,13 @@ class TrackFileViewSet(viewsets.ReadOnlyModelViewSet):
 
     @detail_route(methods=['get'])
     def serve(self, request, *args, **kwargs):
-        try:
+        queryset = models.TrackFile.objects.select_related(
-            f = models.TrackFile.objects.select_related(
             'library_track',
             'track__album__artist',
             'track__artist',
-            ).get(pk=kwargs['pk'])
+        )
+        try:
+            f = queryset.get(pk=kwargs['pk'])
         except models.TrackFile.DoesNotExist:
             return Response(status=404)
 
@@ -213,6 +215,13 @@ class TrackFileViewSet(viewsets.ReadOnlyModelViewSet):
         if library_track and not audio_file:
             if not library_track.audio_file:
                 # we need to populate from cache
+                with transaction.atomic():
+                    # why the transaction/select_for_update?
+                    # this is because browsers may send multiple requests
+                    # in a short time range, for partial content,
+                    # thus resulting in multiple downloads from the remote
+                    qs = LibraryTrack.objects.select_for_update()
+                    library_track = qs.get(pk=library_track.pk)
                     library_track.download_audio()
             audio_file = library_track.audio_file
             mt = library_track.audio_mimetype

changes/changelog.d/163.enhancement

@@ -0,0 +1 @@
+Avoid downloading audio files multiple times from remote libraries (#163)

changes/changelog.d/165.doc

@@ -0,0 +1 @@
+Better documentation for hardware requirements and memory usage (#165)