Compare commits
1 Commits
8557ef9a7e
..
v0.2.1
| Author | SHA1 | Date | |
|---|---|---|---|
| 11c5ce70a6 |
+14
-12
@@ -10,22 +10,24 @@ var (
|
|||||||
errInvalidToken = errors.New("invalid token")
|
errInvalidToken = errors.New("invalid token")
|
||||||
)
|
)
|
||||||
|
|
||||||
func newError(pos lexer.Position, content, hint string, err error) *lexer.Error {
|
|
||||||
return &lexer.Error{
|
|
||||||
Line: pos.Line,
|
|
||||||
Column: pos.Column,
|
|
||||||
Content: content,
|
|
||||||
Hint: hint,
|
|
||||||
Err: err,
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
func newErrInvalidToken(t *token) *lexer.Error {
|
func newErrInvalidToken(t *token) *lexer.Error {
|
||||||
return newError(t.pos, t.value, "", errInvalidToken)
|
err := &lexer.Error{
|
||||||
|
Line: t.pos.Line,
|
||||||
|
Column: t.pos.Column,
|
||||||
|
Content: t.value,
|
||||||
|
Err: errInvalidToken,
|
||||||
|
}
|
||||||
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
func (dec *decoder) OnError(pos lexer.Position, content string, err error) error {
|
func (dec *decoder) OnError(pos lexer.Position, content string, err error) error {
|
||||||
err = newError(pos, content, "", err)
|
err = &lexer.Error{
|
||||||
|
Line: pos.Line,
|
||||||
|
Column: pos.Column,
|
||||||
|
Content: content,
|
||||||
|
Err: err,
|
||||||
|
}
|
||||||
|
|
||||||
dec.executeFinal()
|
dec.executeFinal()
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|||||||
+5
-13
@@ -29,7 +29,7 @@ func (dec *decoder) executeFinal() {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func (dec *decoder) execute(typ parser.TokenType) error {
|
func (dec *decoder) execute(typ parser.TokenType) {
|
||||||
switch typ {
|
switch typ {
|
||||||
case parser.TokenSectionEnd:
|
case parser.TokenSectionEnd:
|
||||||
name1, ok1 := dec.getValue(1, parser.TokenSectionName)
|
name1, ok1 := dec.getValue(1, parser.TokenSectionName)
|
||||||
@@ -48,8 +48,6 @@ func (dec *decoder) execute(typ parser.TokenType) error {
|
|||||||
dec.addField(key, value)
|
dec.addField(key, value)
|
||||||
dec.reset()
|
dec.reset()
|
||||||
}
|
}
|
||||||
|
|
||||||
return nil
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func (dec *decoder) addSection(key, id string, allowEmptyID bool) {
|
func (dec *decoder) addSection(key, id string, allowEmptyID bool) {
|
||||||
@@ -138,25 +136,19 @@ func (dec *decoder) typeOK(typ parser.TokenType) bool {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (dec *decoder) OnToken(pos lexer.Position, typ parser.TokenType, value string) error {
|
func (dec *decoder) OnToken(pos lexer.Position, typ parser.TokenType, value string) error {
|
||||||
var err error
|
|
||||||
t := &token{pos, typ, value}
|
t := &token{pos, typ, value}
|
||||||
|
|
||||||
switch {
|
switch {
|
||||||
case typ == parser.TokenComment:
|
case typ == parser.TokenComment:
|
||||||
// ignore comments
|
// ignore comments
|
||||||
|
return nil
|
||||||
case dec.typeOK(typ):
|
case dec.typeOK(typ):
|
||||||
// acceptable token
|
// acceptable token
|
||||||
dec.queue = append(dec.queue, t)
|
dec.queue = append(dec.queue, t)
|
||||||
err = dec.execute(typ)
|
dec.execute(typ)
|
||||||
|
return nil
|
||||||
default:
|
default:
|
||||||
// unacceptable
|
// unacceptable
|
||||||
err = newErrInvalidToken(t)
|
return newErrInvalidToken(t)
|
||||||
}
|
}
|
||||||
|
|
||||||
if err != nil {
|
|
||||||
dec.executeFinal()
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
|
|
||||||
return nil
|
|
||||||
}
|
}
|
||||||
|
|||||||
-72
@@ -1,72 +0,0 @@
|
|||||||
package ini
|
|
||||||
|
|
||||||
import (
|
|
||||||
"bytes"
|
|
||||||
"io"
|
|
||||||
"strings"
|
|
||||||
|
|
||||||
"asciigoat.org/core"
|
|
||||||
"asciigoat.org/core/reflection"
|
|
||||||
"asciigoat.org/ini/parser"
|
|
||||||
)
|
|
||||||
|
|
||||||
// Decoder ...
|
|
||||||
type Decoder[T any] struct {
|
|
||||||
io.Closer
|
|
||||||
|
|
||||||
out *reflection.Reflection[T]
|
|
||||||
p *parser.Parser
|
|
||||||
queue []*token
|
|
||||||
}
|
|
||||||
|
|
||||||
// Decode ...
|
|
||||||
func (dec *Decoder[T]) Decode(v *T) error {
|
|
||||||
defer dec.Close()
|
|
||||||
|
|
||||||
r, err := reflection.New(v)
|
|
||||||
switch e := err.(type) {
|
|
||||||
case *reflection.InvalidUnmarshalError:
|
|
||||||
// customize error
|
|
||||||
e.Prefix = "ini"
|
|
||||||
e.Method = "Decode"
|
|
||||||
case nil:
|
|
||||||
// good reflection. Go!
|
|
||||||
dec.out = r
|
|
||||||
err = dec.p.Run()
|
|
||||||
}
|
|
||||||
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
|
|
||||||
// NewDecoder creates a Decoder using the provided [io.Reader]
|
|
||||||
// as source
|
|
||||||
func NewDecoder[T any](r io.Reader) *Decoder[T] {
|
|
||||||
rc := core.NewReadCloser(r)
|
|
||||||
switch {
|
|
||||||
case rc == nil:
|
|
||||||
return nil
|
|
||||||
default:
|
|
||||||
dec := &Decoder[T]{
|
|
||||||
p: parser.NewParser(rc),
|
|
||||||
Closer: rc,
|
|
||||||
}
|
|
||||||
dec.init()
|
|
||||||
return dec
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
func (dec *Decoder[T]) init() {
|
|
||||||
dec.p.OnToken = dec.parserOnToken
|
|
||||||
dec.p.OnError = dec.parserOnError
|
|
||||||
}
|
|
||||||
|
|
||||||
// NewDecoderBytes creates a Decoder using the provided bytes array
|
|
||||||
// as source
|
|
||||||
func NewDecoderBytes[T any](b []byte) *Decoder[T] {
|
|
||||||
return NewDecoder[T](bytes.NewReader(b))
|
|
||||||
}
|
|
||||||
|
|
||||||
// NewDecoderString creates a Decoder over a provided string of data
|
|
||||||
func NewDecoderString[T any](s string) *Decoder[T] {
|
|
||||||
return NewDecoder[T](strings.NewReader(s))
|
|
||||||
}
|
|
||||||
@@ -1,33 +0,0 @@
|
|||||||
package ini
|
|
||||||
|
|
||||||
import (
|
|
||||||
"errors"
|
|
||||||
"log"
|
|
||||||
|
|
||||||
"asciigoat.org/core/lexer"
|
|
||||||
)
|
|
||||||
|
|
||||||
var (
|
|
||||||
errInvalidToken = errors.New("invalid token")
|
|
||||||
)
|
|
||||||
|
|
||||||
func newError(pos lexer.Position, content, hint string, err error) *lexer.Error {
|
|
||||||
return &lexer.Error{
|
|
||||||
Line: pos.Line,
|
|
||||||
Column: pos.Column,
|
|
||||||
Content: content,
|
|
||||||
Hint: hint,
|
|
||||||
Err: err,
|
|
||||||
}
|
|
||||||
}
|
|
||||||
func (*Decoder[T]) newErrInvalidToken(t *token) *lexer.Error {
|
|
||||||
return newError(t.pos, t.value, "", errInvalidToken)
|
|
||||||
}
|
|
||||||
|
|
||||||
// parserOnError is the callback for lexer errors
|
|
||||||
func (dec *Decoder[T]) parserOnError(pos lexer.Position, content string, err error) error {
|
|
||||||
log.Printf("%s: %s %s: %q: %v", "ini", pos, "error:", content, err)
|
|
||||||
|
|
||||||
dec.executeFinal()
|
|
||||||
return newError(pos, content, "", err)
|
|
||||||
}
|
|
||||||
@@ -1,56 +0,0 @@
|
|||||||
package ini
|
|
||||||
|
|
||||||
import (
|
|
||||||
"fmt"
|
|
||||||
"log"
|
|
||||||
|
|
||||||
"asciigoat.org/core/lexer"
|
|
||||||
"asciigoat.org/ini/parser"
|
|
||||||
)
|
|
||||||
|
|
||||||
type token struct {
|
|
||||||
pos lexer.Position
|
|
||||||
typ parser.TokenType
|
|
||||||
value string
|
|
||||||
}
|
|
||||||
|
|
||||||
func (t token) String() string {
|
|
||||||
return fmt.Sprintf("%s %s: %q", t.pos, t.typ, t.value)
|
|
||||||
}
|
|
||||||
|
|
||||||
// typeOK tells if a token of the specified type is acceptable
|
|
||||||
// at this time.
|
|
||||||
func (dec *Decoder[T]) typeOK(typ parser.TokenType) bool
|
|
||||||
|
|
||||||
// execute is called after each acceptable token is appended to the queue
|
|
||||||
func (dec *Decoder[T]) execute() error
|
|
||||||
|
|
||||||
// executeFinal is called after an error
|
|
||||||
func (dec *Decoder[T]) executeFinal()
|
|
||||||
|
|
||||||
// parserOnToken is the callback from the parser
|
|
||||||
func (dec *Decoder[T]) parserOnToken(pos lexer.Position, typ parser.TokenType, value string) error {
|
|
||||||
var err error
|
|
||||||
|
|
||||||
log.Printf("%s: %s %s %q", "ini", pos, typ, value)
|
|
||||||
|
|
||||||
t := &token{pos, typ, value}
|
|
||||||
switch {
|
|
||||||
case typ == parser.TokenComment:
|
|
||||||
// ignore comments
|
|
||||||
case dec.typeOK(typ):
|
|
||||||
// acceptable token
|
|
||||||
dec.queue = append(dec.queue, t)
|
|
||||||
err = dec.execute()
|
|
||||||
default:
|
|
||||||
// unacceptable
|
|
||||||
err = dec.newErrInvalidToken(t)
|
|
||||||
}
|
|
||||||
|
|
||||||
if err != nil {
|
|
||||||
dec.executeFinal()
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
|
|
||||||
return nil
|
|
||||||
}
|
|
||||||
@@ -2,8 +2,6 @@ module asciigoat.org/ini
|
|||||||
|
|
||||||
go 1.19
|
go 1.19
|
||||||
|
|
||||||
replace asciigoat.org/core => ../core
|
|
||||||
|
|
||||||
require (
|
require (
|
||||||
asciigoat.org/core v0.3.7
|
asciigoat.org/core v0.3.7
|
||||||
github.com/mgechev/revive v1.3.3
|
github.com/mgechev/revive v1.3.3
|
||||||
|
|||||||
@@ -1,3 +1,5 @@
|
|||||||
|
asciigoat.org/core v0.3.7 h1:tMasdvZgsMJJMVsZVfXXB5lqq82pFiCsyEmOEmcmAfI=
|
||||||
|
asciigoat.org/core v0.3.7/go.mod h1:tXj+JUutxRbcO40ZQRuUVaZ4rnYz1kAZ0nblisV8u74=
|
||||||
github.com/BurntSushi/toml v1.3.2 h1:o7IhLm0Msx3BaB+n3Ag7L8EVlByGnpq14C4YWiu/gL8=
|
github.com/BurntSushi/toml v1.3.2 h1:o7IhLm0Msx3BaB+n3Ag7L8EVlByGnpq14C4YWiu/gL8=
|
||||||
github.com/BurntSushi/toml v1.3.2/go.mod h1:CxXYINrC8qIiEnFrOxCa7Jy5BFHlXnUU2pbicEuybxQ=
|
github.com/BurntSushi/toml v1.3.2/go.mod h1:CxXYINrC8qIiEnFrOxCa7Jy5BFHlXnUU2pbicEuybxQ=
|
||||||
github.com/chavacava/garif v0.0.0-20230608123814-4bd63c2919ab h1:5JxePczlyGAtj6R1MUEFZ/UFud6FfsOejq7xLC2ZIb0=
|
github.com/chavacava/garif v0.0.0-20230608123814-4bd63c2919ab h1:5JxePczlyGAtj6R1MUEFZ/UFud6FfsOejq7xLC2ZIb0=
|
||||||
|
|||||||
Reference in New Issue
Block a user