Method GetObject

storage/fs/reader.go:24–112

GetObject retrieves an object from file system.

(
	ctx context.Context,
	reqHeader http.Header,
	_, name, _ string,
)

// GetObject retrieves an object from file system.
func (s *Storage) GetObject(
	ctx context.Context,
	reqHeader http.Header,
	_, name, _ string,
) (*storage.ObjectReader, error) {
	// If either container or object name is empty, return 404
	if len(name) == 0 {
		return storage.NewObjectNotFound(
			"invalid FS Storage URL: object name is empty",
		), nil
	}

	name = "/" + name

	// check that file exists
	f, err := s.fs.Open(name)
	if err != nil {
		if os.IsNotExist(err) {
			return storage.NewObjectNotFound(fmt.Sprintf("%s doesn't exist", name)), nil
		}

		return nil, err
	}

	// check that file is not a directory
	fi, err := f.Stat()
	if err != nil {
		return nil, err
	}

	if fi.IsDir() {
		return storage.NewObjectNotFound(fmt.Sprintf("%s is directory", name)), nil
	}

	// file basic properties
	size := fi.Size()
	body := io.ReadCloser(f)

	// result headers
	header := make(http.Header)

	// set default headers
	header.Set(httpheaders.AcceptRanges, "bytes")

	// try to detect content type from magic bytes or extension
	if mimetype := detectContentType(f, fi); len(mimetype) > 0 {
		header.Set(httpheaders.ContentType, mimetype)
	}

	// try requested range
	start, end, err := httprange.Parse(reqHeader.Get(httpheaders.Range))
	switch {
	case err != nil:
		f.Close()
		return storage.NewObjectInvalidRange(), nil //nolint:nilerr

	// Range requested: partial content should be returned
	case end != 0: