Method post

coreplugins/dronedb/api_views.py:329–381

(self, request, pk)

class ShareTaskView(TaskView):
    def post(self, request, pk):

        from app.plugins import logger

        task = self.get_and_check_task(request, pk)

        # Get optional tag and datasetName from request
        tag = request.data.get('tag', None)
        dataset_name = request.data.get('datasetName', None) or task.name

        # Validate tag format if provided
        if tag is not None and tag.strip():
            tag = tag.strip().lower()
            if not TAG_PATTERN.match(tag):
                return Response({
                    'error': 'Invalid tag format. Must be "org" or "org/dataset" with lowercase alphanumeric characters and hyphens only.'
                }, status=status.HTTP_400_BAD_REQUEST)

        # Sanitize dataset_name (remove potentially dangerous characters)
        if dataset_name:
            dataset_name = dataset_name.strip()[:255]  # Limit length

        status_key = get_status_key(pk)

        datastore = get_current_plugin().get_global_data_store()

        data = {
            'status': 1, # Running
            'shareUrl': None,
            'uploadedFiles': 0,
            'totalFiles': 0,
            'uploadedSize': 0,
            'totalSize': 0,
            'error': None
        }

        datastore.set_json(status_key, data)

        settings = get_settings(request)

        available_assets = [task.get_asset_file_or_stream(f) for f in list(set(task.available_assets) & set(DRONEDB_ASSETS))]

        if 'textured_model.zip' in task.available_assets:
            texture_files = [join(task.assets_path('odm_texturing'), f) for f in listdir(task.assets_path('odm_texturing')) if isfile(join(task.assets_path('odm_texturing'), f))]
            available_assets.extend(texture_files)

        assets_path = task.assets_path()

        files = [{'path': f, 'name': f[len(assets_path)+1:], 'size': os.path.getsize(f)} for f in available_assets]

        share_to_ddb.delay(pk, settings, files, tag, dataset_name)

        return Response(data, status=status.HTTP_200_OK)


@task