Function TestPlainTextFile

importer/parser_test.go:216–265

(t *testing.T)

}

func TestPlainTextFile(t *testing.T) {
	err := godotenv.Load("../.env")
	require.NoError(t, err)

	path := "../test_data/text_file/conn.log"

	entries := make(chan zeektypes.Conn)
	errc := make(chan error)
	metaDBChan := make(chan MetaDBFile)

	// get the current time in microseconds
	start := time.Now().UTC().UnixMicro()

	// create a unique import id using the start time
	importID, err := util.NewFixedStringHash(strconv.FormatInt(start, 10))
	require.NoError(t, err)

	go func() {
		parseFile(afero.NewOsFs(), path, entries, errc, metaDBChan, "test", importID)
		close(errc)
		close(entries)
		close(metaDBChan)
	}()

	receivedErr := false
	openChannels := 3
	recordCount := 0
	for openChannels > 0 {
		select {
		case _, ok := <-entries:
			if !ok {
				openChannels--
			} else {
				recordCount++
			}
		case _, ok := <-metaDBChan:
			if !ok {
				openChannels--
			}
		case err, ok := <-errc:
			if !ok {
				openChannels--
			} else if errors.Is(err, errUnknownFileType) {
				receivedErr = true
			}

		}
	}
	require.True(t, receivedErr, "should receive unknown file type error")
}