func()

in server/pkg/cloud/storage/s3.go [51:86]


func (b *s3Backend) GetObject(ctx context.Context, path string) (*Object, error) {
	// Check parameters
	if b.client == nil {
		return nil, errors.New("s3: client is nil")
	}

	// Prepare request
	input := &s3.GetObjectInput{
		Bucket: aws.String(b.bucket),
		Key:    aws.String(pathutil.Join(b.prefix, path)),
	}

	// Get object from bucket
	result, err := b.client.GetObjectWithContext(ctx, input)
	if err != nil {
		var aerr awserr.Error
		if errors.As(err, &aerr) {
			switch aerr.Code() {
			case s3.ErrCodeNoSuchKey:
				return nil, fmt.Errorf("s3: object not found '%s'", *input.Key)
			default:
				return nil, fmt.Errorf("s3: unable to retrieve object: %w", aerr)
			}
		}
		return nil, fmt.Errorf("s3: unable to process request: %w", err)
	}

	// Assemble response
	var object Object
	object.Path = path
	object.Content = result.Body
	object.LastModified = *result.LastModified

	// No error
	return &object, nil
}