]> git.giacomolli.uk - onechat/blobdiff - journal.go
Separate multiline Go statements
[onechat] / journal.go
index c12f7d089be403eb706f362843dd482961560737..3fb8f649d7c6cdacfe89d40102f733c3a423433d 100644 (file)
@@ -71,6 +71,7 @@ func (j *Journal) Write(day string, line []byte) (Position, error) {
                offset: j.size,
                length: uint32(len(line)),
        }
                offset: j.size,
                length: uint32(len(line)),
        }
+
        j.size += uint64(len(line))
 
        return place, nil
        j.size += uint64(len(line))
 
        return place, nil
@@ -81,6 +82,7 @@ func (j *Journal) Read(place Position) ([]byte, error) {
        reader, open := j.readers[place.day]
        if !open {
                var err 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)
                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 +113,7 @@ func (j *Journal) Close() error {
        err := j.closeWriter()
        for day, reader := range j.readers {
                err = errors.Join(err, reader.Close())
        err := j.closeWriter()
        for day, reader := range j.readers {
                err = errors.Join(err, reader.Close())
+
                delete(j.readers, day)
        }
 
                delete(j.readers, day)
        }
 
@@ -128,6 +131,7 @@ func (j *Journal) Scan(ctx context.Context, place Position, add func([]byte, Pos
        }
 
        slices.Sort(paths)
        }
 
        slices.Sort(paths)
+
        for n, path := range paths {
                day, err := journalDayNumber(strings.TrimSuffix(filepath.Base(path), ".jsonl"))
                if err != nil {
        for n, path := range paths {
                day, err := journalDayNumber(strings.TrimSuffix(filepath.Base(path), ".jsonl"))
                if err != nil {