src/humanizer.go

   1 // NNCP -- Node to Node copy, utilities for store-and-forward data exchange
   2 // Copyright (C) 2016-2024 Sergey Matveev <stargrave@stargrave.org>
   3 //
   4 // This program is free software: you can redistribute it and/or modify
   5 // it under the terms of the GNU General Public License as published by
   6 // the Free Software Foundation, version 3 of the License.
   7 //
   8 // This program is distributed in the hope that it will be useful,
   9 // but WITHOUT ANY WARRANTY; without even the implied warranty of
  10 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  11 // GNU General Public License for more details.
  12 //
  13 // You should have received a copy of the GNU General Public License
  14 // along with this program.  If not, see <http://www.gnu.org/licenses/>.
  15
  16 package nncp
  17
  18 import (
  19         "fmt"
  20         "strings"
  21         "time"
  22
  23         "go.cypherpunks.ru/recfile"
  24 )
  25
  26 func (ctx *Ctx) HumanizeRec(rec string) string {
  27         r := recfile.NewReader(strings.NewReader(rec))
  28         le, err := r.NextMap()
  29         if err != nil {
  30                 return rec
  31         }
  32         humanized, err := ctx.Humanize(le)
  33         if err != nil {
  34                 return fmt.Sprintf("Can not humanize: %s\n%s", err, rec)
  35         }
  36         return humanized
  37 }
  38
  39 func (ctx *Ctx) Humanize(le map[string]string) (string, error) {
  40         when, err := time.Parse(time.RFC3339Nano, le["When"])
  41         if err != nil {
  42                 return "", err
  43         }
  44         var level string
  45         msg := le["Msg"]
  46         if errMsg, isErr := le["Err"]; isErr {
  47                 level = "ERROR "
  48                 msg += ": " + errMsg
  49         }
  50         return fmt.Sprintf("%s %s%s", when.Format(time.RFC3339), level, msg), nil
  51 }