Function completeOne

apps/sim/app/api/files/multipart/route.ts:333–381

(payload: UploadTokenPayload, parts: ClientCompletedPart[])

          storageProvider === 'blob' ? await import('@/lib/uploads/providers/blob/client') : null

        const completeOne = async (payload: UploadTokenPayload, parts: ClientCompletedPart[]) => {
          const { uploadId, key, context } = payload
          const config = getStorageConfig(context)

          let completed: { location: string; path: string; key: string }
          if (storageProvider === 's3' && s3Module) {
            const { completeS3MultipartUpload } = s3Module
            const s3Parts = parts.map((p) => {
              if (!p.etag) {
                throw new Error(`Missing etag for S3 part ${p.partNumber}`)
              }
              return { ETag: p.etag, PartNumber: p.partNumber }
            })
            completed = await completeS3MultipartUpload(
              key,
              uploadId,
              s3Parts,
              buildS3CustomConfig(config)
            )
          } else if (storageProvider === 'blob' && blobModule) {
            const { completeMultipartUpload, deriveBlobBlockId } = blobModule
            const blobParts = parts.map((p) => ({
              partNumber: p.partNumber,
              blockId: deriveBlobBlockId(p.partNumber),
            }))
            completed = await completeMultipartUpload(key, blobParts, buildBlobCustomConfig(config))
          } else {
            throw new Error(`Unsupported storage provider: ${storageProvider}`)
          }

          try {
            await recordKnowledgeBaseOwnership(payload, completed.key)
          } catch (error) {
            // The object is committed, but without an ownership binding a KB file
            // is unreadable and undeletable via the KB paths. Remove the orphan
            // best-effort and surface a retryable error so the client re-uploads.
            if (payload.context === 'knowledge-base') {
              await deleteFile({ key: completed.key, context: 'knowledge-base' }).catch(() => {})
            }
            throw error
          }

          return {
            success: true as const,
            location: completed.location,
            path: completed.path,
            key: completed.key,
          }
        }

        if ('uploads' in data && Array.isArray(data.uploads)) {
          const verified: Array<{ payload: UploadTokenPayload; parts: ClientCompletedPart[] }> = []