X-Git-Url: https://git.giacomolli.uk/onechat/blobdiff_plain/a606686934b4028c29dca8e9dae6b2e188cee9c5..3b2bf881d484ba1a33ff77a342564b8195a75c80:/log.go?ds=sidebyside diff --git a/log.go b/log.go index 24feb3b..6d0d478 100644 --- a/log.go +++ b/log.go @@ -111,6 +111,7 @@ func (l *Log) AppendDated(kind, text, date string) (Message, error) { } var err error + now := l.clock() if date == "" { date = now.Format(time.RFC3339Nano) @@ -176,6 +177,7 @@ func (l *Log) Message(id int) (Message, error) { } var message Message + err = json.Unmarshal(line, &message) if err != nil { return Message{}, fmt.Errorf("decode message %d: %w", id, err) @@ -206,9 +208,10 @@ func (l *Log) catchUp(ctx context.Context) error { return l.journal.Scan(ctx, start, func(line []byte, place Position) error { var message Message + err := json.Unmarshal(line, &message) if err != nil { - return err + return fmt.Errorf("decode log message: %w", err) } if message.ID != l.index.count {