Function handleGetPartPresignedURL

server/asset_upload_handler.go:641–715

handleGetPartPresignedURL generates a presigned URL for a specific part in multipart upload

(c *gin.Context, assetCache *assetcachepojo.AssetFolderCache)

// handleGetPartPresignedURL generates a presigned URL for a specific part in multipart upload
func handleGetPartPresignedURL(c *gin.Context, assetCache *assetcachepojo.AssetFolderCache) {
	uploadId := c.Query("upload_id")
	partNumberStr := c.Query("part_number")

	if uploadId == "" || partNumberStr == "" {
		c.AbortWithError(400, fmt.Errorf("upload_id and part_number are required"))
		return
	}

	partNumber, err := strconv.ParseInt(partNumberStr, 10, 32)
	if err != nil {
		c.AbortWithError(400, fmt.Errorf("invalid part_number: %v", err))
		return
	}

	// Check if this is S3 storage
	if assetCache.Credentials == nil {
		c.AbortWithError(400, fmt.Errorf("presigned URLs not supported for this storage type"))
		return
	}

	providerType, ok := assetCache.Credentials["type"].(string)
	if !ok || providerType != "s3" {
		c.AbortWithError(400, fmt.Errorf("presigned URLs only supported for S3 storage"))
		return
	}

	// Extract bucket and key
	rootPath := assetCache.CloudStore.RootPath
	fileName := c.Query("filename")
	if fileName == "" {
		c.AbortWithError(400, fmt.Errorf("filename is required"))
		return
	}

	keyPath := assetCache.Keyname + "/" + fileName

	// Parse bucket name
	bucketName := ""
	if strings.Contains(rootPath, ":") {
		parts := strings.Split(rootPath, ":")
		if len(parts) >= 2 {
			bucketName = strings.TrimPrefix(parts[1], "/")
			if strings.Contains(bucketName, "/") {
				pathParts := strings.SplitN(bucketName, "/", 2)
				bucketName = pathParts[0]
				if len(pathParts) > 1 {
					keyPath = pathParts[1] + "/" + keyPath
				}
			}
		}
	}

	if bucketName == "" {
		c.AbortWithError(500, fmt.Errorf("could not extract bucket name"))
		return
	}