buffer/bytes.go

package buffer

import (
	"errors"
	"io"
	"slices"
)

type bytesReader struct {
	bs    []byte
	index int64
}

func newBytesReader(bs []byte) *bytesReader {
	return &bytesReader{bs: bs, index: 0}
}

// Read implements the io.Reader interface.
func (r *bytesReader) Read(b []byte) (n int, err error) {
	if r.index >= int64(len(r.bs)) {
		return 0, io.EOF
	}
	n = copy(b, r.bs[r.index:])
	r.index += int64(n)
	return
}

// Seek implements the io.Seeker interface.
func (r *bytesReader) Seek(offset int64, whence int) (int64, error) {
	switch whence {
	case io.SeekStart:
		r.index = offset
	case io.SeekCurrent:
		r.index += offset
	case io.SeekEnd:
		r.index = int64(len(r.bs)) + offset
	}
	return r.index, nil
}

// ReadAt implements the io.ReaderAt interface.
func (r *bytesReader) ReadAt(b []byte, offset int64) (n int, err error) {
	if offset < 0 {
		return 0, errors.New("buffer.bytesReader.ReadAt: negative offset")
	}
	if offset >= int64(len(r.bs)) {
		return 0, io.EOF
	}
	n = copy(b, r.bs[offset:])
	if n < len(b) {
		err = io.EOF
	}
	return
}

func (r *bytesReader) insert(offset int64, b byte) {
	r.bs = slices.Insert(r.bs, int(offset), b)
}

func (r *bytesReader) delete(offset int64) {
	r.bs = slices.Delete(r.bs, int(offset), int(offset+1))
}

func (r *bytesReader) clone() *bytesReader {
	return newBytesReader(slices.Clone(r.bs))
}