Method upload

app/api/tasks.py:303–354

Add images to a task

(self, request, pk=None, project_pk=None)

    @action(detail=True, methods=['post'])
    def upload(self, request, pk=None, project_pk=None):
        """
        Add images to a task
        """
        try:
            task = self.queryset.get(pk=pk, project=project_pk)
            check_project_perms(request, task.project, ('change_project', ))
        except (ObjectDoesNotExist, ValidationError):
            raise exceptions.NotFound()

        files = flatten_files(request.FILES)
        if len(files) == 0:
            raise exceptions.ValidationError(detail=_("No files uploaded"))

        chunk_info = None
        chunk_index = request.data.get('dzchunkindex')
        uuid = request.data.get('dzuuid') 
        total_chunk_count = request.data.get('dztotalchunkcount', None)
        if len(files) == 1 and chunk_index is not None and uuid is not None and total_chunk_count is not None:
            byte_offset = request.data.get('dzchunkbyteoffset', 0)
            try:
                chunk_index = int(chunk_index)
                byte_offset = int(byte_offset)
                total_chunk_count = int(total_chunk_count)
            except ValueError:
                raise exceptions.ValidationError(detail="chunkIndex is not an int")
            
            chunk_info = {
                'uuid': re.sub('[^0-9a-zA-Z-]+', "", uuid),
                'chunk_index': chunk_index,
                'byte_offset': byte_offset,
                'total_chunk_count': total_chunk_count,
                'tmp_upload_file': os.path.join(settings.FILE_UPLOAD_TEMP_DIR, f"{uuid}.upload")
            }

        # 50% of the time, raise an exception
        # import random
        # if random.random() < 0.5:
        #     import time
        #     time.sleep(10)
        #     return Response('', status=524)
        #     raise exceptions.ValidationError(detail=_("Random upload failure for testing"))

        uploaded = task.handle_images_upload(files, chunk_info)
        if len(uploaded) > 0:
            task.images_count = len(task.scan_images())
            # Update other parameters such as processing node, task name, etc.
            serializer = TaskSerializer(task, data=request.data, partial=True)
            serializer.is_valid(raise_exception=True)
            serializer.save()
        
        return Response({'success': True, 'uploaded': uploaded}, status=status.HTTP_200_OK)

    @action(detail=True, methods=['post'])
    def duplicate(self, request, pk=None, project_pk=None):