Please use virtual hosted style to access about goproxy HOT 11 CLOSED

// ossCache implements the `goproxy.Cache`. It is the cache unit of the `OSS`.
type ossCache struct {
	sync.Mutex

	bucket     *oss.Bucket
	objectName string
	readCloser io.ReadCloser
	offset     int64
	closed     bool
	name       string
	mimeType   string
	size       int64
	modTime    time.Time
	checksum   []byte
}

// resetReadCloser resets the `oc.readCloser`.
func (oc *ossCache) resetReadCloser() error {
	if oc.readCloser != nil {
		if err := oc.readCloser.Close(); err != nil {
			return err
		}
	}

	var err error
	oc.readCloser, err = oc.bucket.GetObject(
		oc.objectName,
		oss.Range(oc.offset, oc.size),
	)

	return err
}

// Read implements the `goproxy.Cache`.
func (oc *ossCache) Read(b []byte) (int, error) {
	oc.Lock()
	defer oc.Unlock()

	if oc.closed {
		return 0, os.ErrClosed
	} else if oc.offset >= oc.size {
		return 0, io.EOF
	}

	if oc.readCloser != nil {
		if err := oc.resetReadCloser(); err != nil {
			return 0, err
		}
	}

	n, err := oc.Read(b)
	oc.offset += int64(n)

	return n, err
}

// Seek implements the `goproxy.Cache`.
func (oc *ossCache) Seek(offset int64, whence int) (int64, error) {
	oc.Lock()
	defer oc.Unlock()

	if oc.closed {
		return 0, os.ErrClosed
	}

	switch whence {
	case io.SeekStart:
	case io.SeekCurrent:
		offset += oc.offset
	case io.SeekEnd:
		offset += oc.size
	default:
		return 0, errors.New("invalid whence")
	}

	if offset < 0 {
		return 0, errors.New("negative position")
	}

	oc.offset = offset
	if oc.offset < oc.size {
		if err := oc.resetReadCloser(); err != nil {
			return 0, err
		}
	}

	return oc.offset, nil
}

// Close implements the `goproxy.Cache`.
func (oc *ossCache) Close() error {
	oc.Lock()
	defer oc.Unlock()

	if oc.closed {
		return os.ErrClosed
	}

	if oc.readCloser != nil {
		if err := oc.readCloser.Close(); err != nil {
			return err
		}
	}

	oc.closed = true

	return nil
}

// Name implements the `goproxy.Cache`.
func (oc *ossCache) Name() string {
	return oc.name
}

// MIMEType implements the `goproxy.Cache`.
func (oc *ossCache) MIMEType() string {
	return oc.mimeType
}

// Size implements the `goproxy.Cache`.
func (oc *ossCache) Size() int64 {
	return oc.size
}

// ModTime implements the `goproxy.Cache`.
func (oc *ossCache) ModTime() time.Time {
	return oc.modTime
}

// Checksum implements the `goproxy.Cache`.
func (oc *ossCache) Checksum() []byte {
	return oc.checksum
}