X-Git-Url: http://www.git.cypherpunks.ru/?a=blobdiff_plain;f=r.go;h=33f3fb959e348bbc95410ce8221d89aba185fdf8;hb=88188862917fb5f831158bf4a8ce30b62f87e370;hp=36141715f151f5b8027ac962adf692897b40b4df;hpb=d2a8c845d659ec5b5dbda5e9c5207e7f09269c50;p=gorecfile.git diff --git a/r.go b/r.go index 3614171..33f3fb9 100644 --- a/r.go +++ b/r.go @@ -1,6 +1,6 @@ /* recfile -- GNU recutils'es recfiles parser on pure Go -Copyright (C) 2020 Sergey Matveev +Copyright (C) 2020-2021 Sergey Matveev This program is free software: you can redistribute it and/or modify it under the terms of the GNU General Public License as published by @@ -25,21 +25,20 @@ import ( "strings" ) +var KeyValRe = regexp.MustCompile(`([a-zA-Z%][a-zA-Z0-9_]*):\s*(.*)$`) + type Reader struct { scanner *bufio.Scanner } +// Create Reader for iterating through the records. It uses +// bufio.Scanner, so can read more than currently parsed records take. func NewReader(r io.Reader) *Reader { return &Reader{bufio.NewScanner(r)} } -type Field struct { - Name string - Value string -} - -var KeyValRe = regexp.MustCompile(`([a-zA-Z%][a-zA-Z0-9_]*):\s*(.*)$`) - +// Get next record. Each record is just a collection of fields. io.EOF +// is returned if there is nothing to read more. func (r *Reader) Next() ([]Field, error) { fields := make([]Field, 0, 1) var text string @@ -123,3 +122,29 @@ func (r *Reader) Next() ([]Field, error) { } return fields, nil } + +// Same as Next(), but with unique keys and last value. +func (r *Reader) NextMap() (map[string]string, error) { + fields, err := r.Next() + if err != nil { + return nil, err + } + m := make(map[string]string, len(fields)) + for _, f := range fields { + m[f.Name] = f.Value + } + return m, nil +} + +// Same as Next(), but with unique keys and slices of values. +func (r *Reader) NextMapWithSlice() (map[string][]string, error) { + fields, err := r.Next() + if err != nil { + return nil, err + } + m := make(map[string][]string) + for _, f := range fields { + m[f.Name] = append(m[f.Name], f.Value) + } + return m, nil +}