Method GetObject

storage/s3/reader.go:19–122

GetObject retrieves an object from Azure cloud

(
	ctx context.Context,
	reqHeader http.Header,
	bucket, key, query string,
)

// GetObject retrieves an object from Azure cloud
func (s *Storage) GetObject(
	ctx context.Context,
	reqHeader http.Header,
	bucket, key, query string,
) (*storage.ObjectReader, error) {
	// If either bucket or object key is empty, return 404
	if len(bucket) == 0 || len(key) == 0 {
		return storage.NewObjectNotFound(
			"invalid S3 Storage URL: bucket name or object key are empty",
		), nil
	}

	// Check if access to the container is allowed
	if !common.IsBucketAllowed(bucket, s.config.AllowedBuckets, s.config.DeniedBuckets) {
		return nil, fmt.Errorf("access to the S3 bucket %s is denied", bucket)
	}

	input := &s3.GetObjectInput{
		Bucket: aws.String(bucket),
		Key:    aws.String(key),
	}

	if len(query) > 0 {
		input.VersionId = aws.String(query)
	}

	if r := reqHeader.Get(httpheaders.Range); len(r) != 0 {
		input.Range = aws.String(r)
	} else {
		if ifNoneMatch := reqHeader.Get(httpheaders.IfNoneMatch); len(ifNoneMatch) > 0 {
			input.IfNoneMatch = aws.String(ifNoneMatch)
		}

		if ifModifiedSince := reqHeader.Get(httpheaders.IfModifiedSince); len(ifModifiedSince) > 0 {
			parsedIfModifiedSince, err := time.Parse(http.TimeFormat, ifModifiedSince)
			if err == nil {
				input.IfModifiedSince = &parsedIfModifiedSince
			}
		}
	}

	output, _, err := callWithClient(s, bucket, func(client s3Client) (*s3.GetObjectOutput, error) {
		output, err := client.GetObject(ctx, input)

		defer func() {
			if err != nil && output != nil && output.Body != nil {
				output.Body.Close()
			}
		}()

		return output, err
	})

	if err != nil {
		return handleError(err)
	}

	contentLength := int64(-1)