fix regression on ingestor with dnstap files (#732)

* fix #729
* Update README.md

README.md

@@ -1,9 +1,9 @@
 <p align="center">
 <img src="https://goreportcard.com/badge/github.com/dmachard/go-dns-collector" alt="Go Report"/>
 <img src="https://img.shields.io/badge/go%20version-min%201.21-green" alt="Go version"/>
-<img src="https://img.shields.io/badge/go%20tests-426-green" alt="Go tests"/>
+<img src="https://img.shields.io/badge/go%20tests-436-green" alt="Go tests"/>
 <img src="https://img.shields.io/badge/go%20bench-20-green" alt="Go bench"/>
-<img src="https://img.shields.io/badge/go%20lines-29697-green" alt="Go lines"/>
+<img src="https://img.shields.io/badge/go%20lines-29834-green" alt="Go lines"/>
 </p>
 
 <p align="center">

workers/file_ingestor.go

@@ -318,7 +318,7 @@ func (w *FileIngestor) StartCollect() {
 	dnstapProcessor := NewDNSTapProcessor(0, "", w.GetConfig(), w.GetLogger(), w.GetName(), w.GetConfig().Collectors.FileIngestor.ChannelBufferSize)
 	dnstapProcessor.SetDefaultRoutes(w.GetDefaultRoutes())
 	dnstapProcessor.SetDefaultDropped(w.GetDroppedRoutes())
-	go dnsProcessor.StartCollect()
+	go dnstapProcessor.StartCollect()
 
 	w.dnstapProcessor = dnstapProcessor
 	w.dnsProcessor = dnsProcessor

workers/file_ingestor_test.go

@@ -8,25 +8,47 @@ import (
 	"github.com/dmachard/go-logger"
 )
 
-func Test_FileIngestor_Pcap(t *testing.T) {
-	g := GetWorkerForTest(pkgconfig.DefaultBufferSize)
-	config := pkgconfig.GetDefaultConfig()
-
-	// watch tests data folder
-	config.Collectors.FileIngestor.WatchDir = "./../tests/testsdata/pcap/"
-
-	// init collector
-	c := NewFileIngestor([]Worker{g}, config, logger.New(false), "test")
-	go c.StartCollect()
-
-	// waiting message in channel
-	for {
-		// read dns message from channel
-		msg := <-g.GetInputChannel()
-
-		// check qname
-		if msg.DNSTap.Operation == dnsutils.DNSTapClientQuery {
-			break
-		}
+func Test_FileIngestor(t *testing.T) {
+	tests := []struct {
+		name      string
+		watchMode string
+		watchDir  string
+	}{
+		{
+			name:      "Pcap",
+			watchMode: "pcap",
+			watchDir:  "./../tests/testsdata/pcap/",
+		},
+		{
+			name:      "Dnstap",
+			watchMode: "dnstap",
+			watchDir:  "./../tests/testsdata/dnstap/",
+		},
+	}
+
+	for _, tt := range tests {
+		t.Run(tt.name, func(t *testing.T) {
+			g := GetWorkerForTest(pkgconfig.DefaultBufferSize)
+			config := pkgconfig.GetDefaultConfig()
+
+			// watch tests data folder
+			config.Collectors.FileIngestor.WatchMode = tt.watchMode
+			config.Collectors.FileIngestor.WatchDir = tt.watchDir
+
+			// init collector
+			c := NewFileIngestor([]Worker{g}, config, logger.New(false), "test")
+			go c.StartCollect()
+
+			// waiting message in channel
+			for {
+				// read dns message from channel
+				msg := <-g.GetInputChannel()
+
+				// check qname
+				if msg.DNSTap.Operation == dnsutils.DNSTapClientQuery {
+					break
+				}
+			}
+		})
 	}
 }