X-Git-Url: https://git.giacomolli.uk/onechat/blobdiff_plain/baf7a940be8927278e3b4b87e7366cebfc16532f..88581c0765be50dcabcc2913c38ae6786c426a3a:/journal.go diff --git a/journal.go b/journal.go index c12f7d0..bb1897c 100644 --- a/journal.go +++ b/journal.go @@ -81,6 +81,7 @@ func (j *Journal) Read(place Position) ([]byte, error) { reader, open := j.readers[place.day] if !open { var err error + reader, err = os.Open(filepath.Join(j.dir, journalDayName(place.day)+".jsonl")) if err != nil { return nil, fmt.Errorf("open day file: %w", err) @@ -111,6 +112,7 @@ func (j *Journal) Close() error { err := j.closeWriter() for day, reader := range j.readers { err = errors.Join(err, reader.Close()) + delete(j.readers, day) } @@ -128,6 +130,7 @@ func (j *Journal) Scan(ctx context.Context, place Position, add func([]byte, Pos } slices.Sort(paths) + for n, path := range paths { day, err := journalDayNumber(strings.TrimSuffix(filepath.Base(path), ".jsonl")) if err != nil {