lexer: rename runes.Reader to lexer.Reader and implement UnreadRune() and PeekRune() #4

Merged
amery merged 3 commits from pr-amery-reader into main 1 year ago
  1. 2
      lexer/lexer.go
  2. 46
      lexer/reader.go
  3. 2
      runes/docs.go

2
lexer/lexer.go

@ -0,0 +1,2 @@
// Package lexer provides basic helpers to implement parsers
package lexer

46
runes/reader.go → lexer/reader.go

@ -1,7 +1,8 @@
package runes package lexer
import ( import (
"bytes" "bytes"
"errors"
"io" "io"
"strings" "strings"
"unicode/utf8" "unicode/utf8"
@ -18,7 +19,14 @@ const (
// implemented interfaces // implemented interfaces
var ( var (
_ io.RuneReader = (*Reader)(nil) _ io.RuneReader = (*Reader)(nil)
_ io.RuneScanner = (*Reader)(nil)
)
var (
// ErrInvalidUnreadRune indicates UnreadRune() was calls after an
// action other than a successful ReadRune()
ErrInvalidUnreadRune = errors.New("invalid UnreadRune() call")
) )
// Reader is a RuneReader aimed at implementing text parsers // Reader is a RuneReader aimed at implementing text parsers
@ -28,6 +36,8 @@ type Reader struct {
buf []byte buf []byte
off int off int
cursor int cursor int
lastRuneSize int
} }
// String returns what's already Read but not yet emitted or discarded // String returns what's already Read but not yet emitted or discarded
@ -54,6 +64,9 @@ func (b *Reader) Discard() {
// step // step
b.off = b.cursor b.off = b.cursor
} }
// and prevent UnreadRune()
b.lastRuneSize = -1
} }
// ready tells how many bytes are ready to decode // ready tells how many bytes are ready to decode
@ -139,6 +152,8 @@ func (b *Reader) ReadRune() (rune, int, error) {
for { for {
err := b.needsBytes(count) err := b.needsBytes(count)
if err != nil { if err != nil {
b.lastRuneSize = -1
return 0, 0, err return 0, 0, err
} }
@ -153,9 +168,36 @@ func (b *Reader) ReadRune() (rune, int, error) {
// decode rune // decode rune
r, l := utf8.DecodeRune(b.buf[b.cursor:]) r, l := utf8.DecodeRune(b.buf[b.cursor:])
// step over
b.cursor += l
// and remember for UnreadRune()
b.lastRuneSize = l
return r, l, nil return r, l, nil
} }
// UnreadRune moves the cursor where it was before the last call to ReadRune
func (b *Reader) UnreadRune() error {
if b.lastRuneSize > 0 {
b.cursor -= b.lastRuneSize
b.lastRuneSize = -1
return nil
}
return ErrInvalidUnreadRune
}
// PeekRune returns information about the next rune without moving the
// cursor
func (b *Reader) PeekRune() (rune, int, error) {
r, l, err := b.ReadRune()
if err != nil {
return r, l, err
}
err = b.UnreadRune()
return r, l, err
}
// NewReader creates a new runes [Reader] using the given [io.Reader] // NewReader creates a new runes [Reader] using the given [io.Reader]
func NewReader(r io.Reader) *Reader { func NewReader(r io.Reader) *Reader {
if r == nil { if r == nil {

2
runes/docs.go

@ -1,2 +0,0 @@
// Package runes helps us work with runes
package runes
Loading…
Cancel
Save