Method post

app/api/tasks.py:842–927

(self, request, project_pk=None)

    parser_classes = (parsers.MultiPartParser, parsers.JSONParser, parsers.FormParser,)

    def post(self, request, project_pk=None):
        project = get_and_check_project(request, project_pk, ('change_project',))
        files = flatten_files(request.FILES)
        tmp_upload_dir = get_external_import_tmpdir(request)

        if len(files) != 1:
            raise exceptions.ValidationError(detail=_("Cannot create task, you need to upload 1 file"))

        file_type = [k for k in request.FILES][0]
        file_ext = os.path.splitext(files[0].name)[1]
        
        asset_file = None
        asset_file_candidates = EXTERNAL_ASSET_FILES.get(file_type)
        if asset_file_candidates is None: 
            raise exceptions.ValidationError(detail=_("Invalid file type"))

        ext_aliases = {
            '.tiff': '.tif'
        }
        for f in asset_file_candidates:
            if os.path.splitext(f)[1].lower() == ext_aliases.get(file_ext.lower(), file_ext.lower()):
                asset_file = f
                break

        if asset_file is None:
            raise exceptions.ValidationError(detail=_("Invalid file type (extension mismatch)"))

        chunk_index = request.data.get('dzchunkindex')
        uuid = request.data.get('dzuuid') 
        total_chunk_count = request.data.get('dztotalchunkcount', None)

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

        # Chunked upload?
        tmp_upload_file = None
        if len(files) > 0 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=_("Some parameters are not integers"))
            uuid = re.sub('[^0-9a-zA-Z-]+', "", uuid)

            tmp_upload_file = os.path.join(tmp_upload_dir, f"{uuid}.upload")
            if os.path.isfile(tmp_upload_file) and chunk_index == 0:
                os.unlink(tmp_upload_file)
            
            with open(tmp_upload_file, 'ab') as fd:
                fd.truncate(byte_offset)