fix: log entries were not being loaded

Broke in ec18c3c Signed-off-by: Hiram Chirino <hiram@hiramchirino.com>
hedhyw · Sep 12, 2024 · 0ac6191 · 0ac6191
1 parent 7967282
commit 0ac6191
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 4 deletions.
diff --git a/internal/pkg/source/source.go b/internal/pkg/source/source.go
@@ -4,10 +4,11 @@ import (
 	"bufio"
 	"bytes"
 	"errors"
-	"github.com/hedhyw/semerr/pkg/v1/semerr"
 	"io"
 	"os"
 
+	"github.com/hedhyw/semerr/pkg/v1/semerr"
+
 	"github.com/hedhyw/json-log-viewer/internal/pkg/config"
 )
 

diff --git a/internal/pkg/source/sreamer.go b/internal/pkg/source/sreamer.go
@@ -16,7 +16,7 @@ func (is *Source) StartStreaming(ctx context.Context, send func(msg LazyLogEntri
 	eofEvent := make(chan struct{}, 1)
 
 	// Load log entries async..
-	go is.readLogEntries(ctx, send, &logEntriesLock, logEntries, eofEvent)
+	go is.readLogEntries(ctx, send, &logEntriesLock, &logEntries, eofEvent)
 
 	// periodically send new log entries to the program.
 	go func() {
@@ -57,7 +57,7 @@ func (is *Source) StartStreaming(ctx context.Context, send func(msg LazyLogEntri
 	}()
 }
 
-func (is *Source) readLogEntries(ctx context.Context, send func(msg LazyLogEntries, err error), logEntriesLock *sync.Mutex, logEntries []LazyLogEntry, eofEvent chan struct{}) {
+func (is *Source) readLogEntries(ctx context.Context, send func(msg LazyLogEntries, err error), logEntriesLock *sync.Mutex, logEntries *[]LazyLogEntry, eofEvent chan struct{}) {
 	defer func() {
 		eofEvent <- struct{}{}
 	}()
@@ -93,7 +93,7 @@ func (is *Source) readLogEntries(ctx context.Context, send func(msg LazyLogEntri
 			return
 		}
 		logEntriesLock.Lock()
-		logEntries = append(logEntries, entry)
+		*logEntries = append(*logEntries, entry)
 		logEntriesLock.Unlock()
 	}
 }