Compare commits
11 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| cbd3f705f5 | |||
| c9f206c9aa | |||
| 9912146d21 | |||
| 71ab4a58c1 | |||
| 8e838c3566 | |||
| ff0c7d1b9f | |||
| fabd192e3d | |||
| 37f3efebfb | |||
| 506fff8725 | |||
| d75b2dbc78 | |||
| 46ba96d6b4 |
Vendored
+7
@@ -0,0 +1,7 @@
|
|||||||
|
{
|
||||||
|
"cSpell.words": [
|
||||||
|
"asciigoat",
|
||||||
|
"Subname",
|
||||||
|
"unescapes"
|
||||||
|
]
|
||||||
|
}
|
||||||
+10
-12
@@ -10,24 +10,22 @@ var (
|
|||||||
errInvalidToken = errors.New("invalid token")
|
errInvalidToken = errors.New("invalid token")
|
||||||
)
|
)
|
||||||
|
|
||||||
func newErrInvalidToken(t *token) *lexer.Error {
|
func newError(pos lexer.Position, content, hint string, err error) *lexer.Error {
|
||||||
err := &lexer.Error{
|
return &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 {
|
|
||||||
err = &lexer.Error{
|
|
||||||
Line: pos.Line,
|
Line: pos.Line,
|
||||||
Column: pos.Column,
|
Column: pos.Column,
|
||||||
Content: content,
|
Content: content,
|
||||||
|
Hint: hint,
|
||||||
Err: err,
|
Err: err,
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func newErrInvalidToken(t *token) *lexer.Error {
|
||||||
|
return newError(t.pos, t.value, "", errInvalidToken)
|
||||||
|
}
|
||||||
|
|
||||||
|
func (dec *decoder) OnError(pos lexer.Position, content string, err error) error {
|
||||||
|
err = newError(pos, content, "", err)
|
||||||
dec.executeFinal()
|
dec.executeFinal()
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|||||||
+31
-20
@@ -32,21 +32,21 @@ func (dec *decoder) executeFinal() {
|
|||||||
func (dec *decoder) execute(typ parser.TokenType) {
|
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.queueValue(1, parser.TokenSectionName)
|
||||||
|
|
||||||
if ok1 {
|
if ok1 {
|
||||||
name2, ok2 := dec.getValue(2, parser.TokenSectionSubname)
|
name2, ok2 := dec.queueValue(2, parser.TokenSectionSubname)
|
||||||
|
|
||||||
dec.addSection(name1, name2, ok2)
|
dec.addSection(name1, name2, ok2)
|
||||||
}
|
}
|
||||||
|
|
||||||
dec.reset()
|
dec.queueReset()
|
||||||
case parser.TokenFieldValue:
|
case parser.TokenFieldValue:
|
||||||
key, _ := dec.getValue(0, parser.TokenFieldKey)
|
key, _ := dec.queueValue(0, parser.TokenFieldKey)
|
||||||
value, _ := dec.getValue(1, parser.TokenFieldValue)
|
value, _ := dec.queueValue(1, parser.TokenFieldValue)
|
||||||
|
|
||||||
dec.addField(key, value)
|
dec.addField(key, value)
|
||||||
dec.reset()
|
dec.queueReset()
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -82,7 +82,8 @@ func (dec *decoder) addField(key, value string) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func (dec *decoder) getValue(idx int, typ parser.TokenType) (string, bool) {
|
// queueValue extracts the value of element on the queue if the type matches.
|
||||||
|
func (dec *decoder) queueValue(idx int, typ parser.TokenType) (string, bool) {
|
||||||
switch {
|
switch {
|
||||||
case idx < 0 || idx >= len(dec.queue):
|
case idx < 0 || idx >= len(dec.queue):
|
||||||
// out of range
|
// out of range
|
||||||
@@ -95,40 +96,48 @@ func (dec *decoder) getValue(idx int, typ parser.TokenType) (string, bool) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func (dec *decoder) reset() {
|
// queueReset removes all tokens from the queue
|
||||||
|
func (dec *decoder) queueReset() {
|
||||||
dec.queue = dec.queue[:0]
|
dec.queue = dec.queue[:0]
|
||||||
}
|
}
|
||||||
|
|
||||||
func (dec *decoder) depth(depth int) bool {
|
// queueDepth confirms the current depth of the queue
|
||||||
|
func (dec *decoder) queueDepth(depth int) bool {
|
||||||
return len(dec.queue) == depth
|
return len(dec.queue) == depth
|
||||||
}
|
}
|
||||||
|
|
||||||
func (dec *decoder) depthAfter(depth int, typ parser.TokenType) bool {
|
// queueDepthType confirms the current depth of the queue and the type of the last
|
||||||
_, ok := dec.getValue(depth-1, typ)
|
// element.
|
||||||
if ok {
|
func (dec *decoder) queueDepthType(depth int, typ parser.TokenType) bool {
|
||||||
return len(dec.queue) == depth
|
if dec.queueDepth(depth) {
|
||||||
|
return dec.queueType(depth-1, typ)
|
||||||
}
|
}
|
||||||
return false
|
return false
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// queueType tells if the specified element on the queue is of the required type.
|
||||||
|
func (dec *decoder) queueType(idx int, typ parser.TokenType) bool {
|
||||||
|
_, ok := dec.queueValue(idx, typ)
|
||||||
|
return ok
|
||||||
|
}
|
||||||
|
|
||||||
func (dec *decoder) typeOK(typ parser.TokenType) bool {
|
func (dec *decoder) typeOK(typ parser.TokenType) bool {
|
||||||
switch typ {
|
switch typ {
|
||||||
case parser.TokenSectionStart, parser.TokenFieldKey:
|
case parser.TokenSectionStart, parser.TokenFieldKey:
|
||||||
// first token only
|
// first token only
|
||||||
return dec.depth(0)
|
return dec.queueDepth(0)
|
||||||
case parser.TokenSectionName:
|
case parser.TokenSectionName:
|
||||||
// right after TokenSectionStart
|
// right after TokenSectionStart
|
||||||
return dec.depthAfter(1, parser.TokenSectionStart)
|
return dec.queueDepthType(1, parser.TokenSectionStart)
|
||||||
case parser.TokenSectionSubname:
|
case parser.TokenSectionSubname:
|
||||||
// right after TokenSectionName
|
// right after TokenSectionName
|
||||||
return dec.depthAfter(2, parser.TokenSectionName)
|
return dec.queueDepthType(2, parser.TokenSectionName)
|
||||||
case parser.TokenSectionEnd:
|
case parser.TokenSectionEnd:
|
||||||
// only on a section with name
|
// only on a section with name
|
||||||
_, ok := dec.getValue(1, parser.TokenSectionName)
|
return dec.queueType(1, parser.TokenSectionName)
|
||||||
return ok
|
|
||||||
case parser.TokenFieldValue:
|
case parser.TokenFieldValue:
|
||||||
// right after a TokenFieldKey
|
// right after a TokenFieldKey
|
||||||
return dec.depthAfter(1, parser.TokenFieldKey)
|
return dec.queueDepthType(1, parser.TokenFieldKey)
|
||||||
default:
|
default:
|
||||||
// never
|
// never
|
||||||
return false
|
return false
|
||||||
@@ -149,6 +158,8 @@ func (dec *decoder) OnToken(pos lexer.Position, typ parser.TokenType, value stri
|
|||||||
return nil
|
return nil
|
||||||
default:
|
default:
|
||||||
// unacceptable
|
// unacceptable
|
||||||
return newErrInvalidToken(t)
|
err := newErrInvalidToken(t)
|
||||||
|
dec.executeFinal()
|
||||||
|
return err
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -53,6 +53,12 @@ func (field Field) String() string {
|
|||||||
return buf.String()
|
return buf.String()
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// GoString generates a string output for "%#v"
|
||||||
|
func (*Field) GoString() string {
|
||||||
|
var buf bytes.Buffer
|
||||||
|
return buf.String()
|
||||||
|
}
|
||||||
|
|
||||||
func writeSectionToBuffer(w *bytes.Buffer, sec *Section, nl string) int {
|
func writeSectionToBuffer(w *bytes.Buffer, sec *Section, nl string) int {
|
||||||
var written, n int
|
var written, n int
|
||||||
|
|
||||||
@@ -90,6 +96,12 @@ func (sec *Section) String() string {
|
|||||||
return buf.String()
|
return buf.String()
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// GoString generates a string output for "%#v"
|
||||||
|
func (*Section) GoString() string {
|
||||||
|
var buf bytes.Buffer
|
||||||
|
return buf.String()
|
||||||
|
}
|
||||||
|
|
||||||
// WriteTo writes a INI representation of the document
|
// WriteTo writes a INI representation of the document
|
||||||
// onto the provided writer.
|
// onto the provided writer.
|
||||||
func (doc *Document) WriteTo(w io.Writer) (int64, error) {
|
func (doc *Document) WriteTo(w io.Writer) (int64, error) {
|
||||||
@@ -102,3 +114,9 @@ func (doc *Document) String() string {
|
|||||||
buf := doc.AsBuffer(WriteNewLine)
|
buf := doc.AsBuffer(WriteNewLine)
|
||||||
return buf.String()
|
return buf.String()
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// GoString generates a string output for "%#v"
|
||||||
|
func (Document) GoString() string {
|
||||||
|
var buf bytes.Buffer
|
||||||
|
return buf.String()
|
||||||
|
}
|
||||||
|
|||||||
+49
@@ -0,0 +1,49 @@
|
|||||||
|
package ini
|
||||||
|
|
||||||
|
import (
|
||||||
|
"bytes"
|
||||||
|
"io"
|
||||||
|
"strings"
|
||||||
|
|
||||||
|
"asciigoat.org/core"
|
||||||
|
"asciigoat.org/ini/parser"
|
||||||
|
)
|
||||||
|
|
||||||
|
// Decoder ...
|
||||||
|
type Decoder struct {
|
||||||
|
io.Closer
|
||||||
|
|
||||||
|
p *parser.Parser
|
||||||
|
}
|
||||||
|
|
||||||
|
// Decode ...
|
||||||
|
func (dec *Decoder) Decode() error {
|
||||||
|
defer dec.Close()
|
||||||
|
|
||||||
|
return dec.p.Run()
|
||||||
|
}
|
||||||
|
|
||||||
|
// NewDecoder creates a Decoder over the provided [io.Reader]
|
||||||
|
func NewDecoder(r io.Reader) *Decoder {
|
||||||
|
rc := core.NewReadCloser(r)
|
||||||
|
switch {
|
||||||
|
case rc == nil:
|
||||||
|
return nil
|
||||||
|
default:
|
||||||
|
dec := &Decoder{
|
||||||
|
p: parser.NewParser(rc),
|
||||||
|
Closer: rc,
|
||||||
|
}
|
||||||
|
return dec
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// NewDecoderBytes creates a Decoder over a provided bytes array
|
||||||
|
func NewDecoderBytes(b []byte) *Decoder {
|
||||||
|
return NewDecoder(bytes.NewReader(b))
|
||||||
|
}
|
||||||
|
|
||||||
|
// NewDecoderString creates a Decoder over a provided string of data
|
||||||
|
func NewDecoderString(s string) *Decoder {
|
||||||
|
return NewDecoder(strings.NewReader(s))
|
||||||
|
}
|
||||||
@@ -2,6 +2,11 @@ module asciigoat.org/ini
|
|||||||
|
|
||||||
go 1.19
|
go 1.19
|
||||||
|
|
||||||
|
replace (
|
||||||
|
asciigoat.org/core => ../core
|
||||||
|
darvaza.org/core => ../../darvaza.org/core
|
||||||
|
)
|
||||||
|
|
||||||
require (
|
require (
|
||||||
asciigoat.org/core v0.3.9
|
asciigoat.org/core v0.3.9
|
||||||
github.com/mgechev/revive v1.3.3
|
github.com/mgechev/revive v1.3.3
|
||||||
|
|||||||
@@ -1,5 +1,3 @@
|
|||||||
asciigoat.org/core v0.3.9 h1:hgDDz4ecm3ZvehX++m8A/IzAt+B5oDPiRtxatzfUHPQ=
|
|
||||||
asciigoat.org/core v0.3.9/go.mod h1:CAaHwyw8MpAq4a1MYtN2dxJrsK+hmIdW50OndaQZYPI=
|
|
||||||
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.1.0 h1:2JHa3hbYf5D9dsgseMKAmc/MZ109otzgNFk5s87H9Pc=
|
github.com/chavacava/garif v0.1.0 h1:2JHa3hbYf5D9dsgseMKAmc/MZ109otzgNFk5s87H9Pc=
|
||||||
|
|||||||
@@ -0,0 +1,15 @@
|
|||||||
|
package ini
|
||||||
|
|
||||||
|
import "io"
|
||||||
|
|
||||||
|
// ReadInto ...
|
||||||
|
func ReadInto(v any, r io.Reader) error {
|
||||||
|
dec := NewDecoder(r)
|
||||||
|
|
||||||
|
return dec.Unmarshal(v)
|
||||||
|
}
|
||||||
|
|
||||||
|
// Unmarshal ...
|
||||||
|
func (dec *Decoder) Unmarshal(any) error {
|
||||||
|
return dec.p.Run()
|
||||||
|
}
|
||||||
Reference in New Issue
Block a user