Method GetObject

server/s3/backend.go:147–221

GetObject fetchs the object from the filesystem.

(ctx context.Context, bucketName, objectName string, rangeRequest *gofakes3.ObjectRangeRequest)

// GetObject fetchs the object from the filesystem.
func (b *s3Backend) GetObject(ctx context.Context, bucketName, objectName string, rangeRequest *gofakes3.ObjectRangeRequest) (s3Obj *gofakes3.Object, err error) {
	bucket, err := getBucketByName(bucketName)
	if err != nil {
		return nil, err
	}
	bucketPath := bucket.Path

	fp := path.Join(bucketPath, objectName)
	fmeta, _ := op.GetNearestMeta(fp)
	node, err := fs.Get(context.WithValue(ctx, conf.MetaKey, fmeta), fp, &fs.GetArgs{})
	if err != nil {
		return nil, gofakes3.KeyNotFound(objectName)
	}

	if node.IsDir() {
		return nil, gofakes3.KeyNotFound(objectName)
	}

	link, file, err := fs.Link(ctx, fp, model.LinkArgs{})
	if err != nil {
		return nil, err
	}
	defer func() {
		if s3Obj == nil {
			_ = link.Close()
		}
	}()

	size := link.ContentLength
	if size <= 0 {
		size = file.GetSize()
	}
	rnge, err := rangeRequest.Range(size)
	if err != nil {
		return nil, err
	}

	rrf, err := stream.GetRangeReaderFromLink(size, link)
	if err != nil {
		return nil, fmt.Errorf("the remote storage driver need to be enhanced to support s3")
	}

	var rd io.Reader
	if rnge != nil {
		rd, err = rrf.RangeRead(ctx, http_range.Range(*rnge))
	} else {
		rd, err = rrf.RangeRead(ctx, http_range.Range{Length: -1})
	}
	if err != nil {
		return nil, err
	}

	meta := map[string]string{
		"Last-Modified":       node.ModTime().Format(timeFormat),
		"Content-Disposition": utils.GenerateContentDisposition(file.GetName()),
		"Content-Type":        utils.GetMimeType(fp),
	}