[pkg/stanza] Remove duplicate test (#12090)

Author: djaglowski

pkg/stanza/fileconsumer/file_test.go

@@ -1081,14 +1081,7 @@ func TestEncodings(t *testing.T) {
 				require.NoError(t, operator.Stop())
 			}()
 
-			for _, expected := range tc.expected {
-				select {
-				case call := <-emitCalls:
-					require.Equal(t, expected, call.token)
-				case <-time.After(500 * time.Millisecond):
-					require.FailNow(t, "Timed out waiting for entry to be read")
-				}
-			}
+			waitForTokens(t, emitCalls, tc.expected)
 		})
 	}
 }

pkg/stanza/operator/input/file/file_test.go

@@ -753,90 +753,3 @@ func TestManyLogsDelivered(t *testing.T) {
 	}
 	expectNoMessages(t, logReceived)
 }
-
-func TestEncodings(t *testing.T) {
-	t.Parallel()
-	cases := []struct {
-		name     string
-		contents []byte
-		encoding string
-		expected [][]byte
-	}{
-		{
-			"Nop",
-			[]byte{0xc5, '\n'},
-			"",
-			[][]byte{{0xc5}},
-		},
-		{
-			"InvalidUTFReplacement",
-			[]byte{0xc5, '\n'},
-			"utf8",
-			[][]byte{{0xef, 0xbf, 0xbd}},
-		},
-		{
-			"ValidUTF8",
-			[]byte("foo\n"),
-			"utf8",
-			[][]byte{[]byte("foo")},
-		},
-		{
-			"ChineseCharacter",
-			[]byte{230, 138, 152, '\n'}, // 折\n
-			"utf8",
-			[][]byte{{230, 138, 152}},
-		},
-		{
-			"SmileyFaceUTF16",
-			[]byte{216, 61, 222, 0, 0, 10}, // 😀\n
-			"utf-16be",
-			[][]byte{{240, 159, 152, 128}},
-		},
-		{
-			"SmileyFaceNewlineUTF16",
-			[]byte{216, 61, 222, 0, 0, 10, 0, 102, 0, 111, 0, 111}, // 😀\nfoo
-			"utf-16be",
-			[][]byte{{240, 159, 152, 128}, {102, 111, 111}},
-		},
-		{
-			"SmileyFaceNewlineUTF16LE",
-			[]byte{61, 216, 0, 222, 10, 0, 102, 0, 111, 0, 111, 0}, // 😀\nfoo
-			"utf-16le",
-			[][]byte{{240, 159, 152, 128}, {102, 111, 111}},
-		},
-		{
-			"ChineseCharacterBig5",
-			[]byte{167, 233, 10}, // 折\n
-			"big5",
-			[][]byte{{230, 138, 152}},
-		},
-	}
-
-	for _, tc := range cases {
-		t.Run(tc.name, func(t *testing.T) {
-			t.Parallel()
-			operator, receivedEntries, tempDir := newTestFileOperator(t, func(cfg *Config) {
-				cfg.Splitter.EncodingConfig = helper.EncodingConfig{Encoding: tc.encoding}
-			}, nil)
-
-			// Popualte the file
-			temp := openTemp(t, tempDir)
-			_, err := temp.Write(tc.contents)
-			require.NoError(t, err)
-
-			require.NoError(t, operator.Start(testutil.NewMockPersister("test")))
-			defer func() {
-				require.NoError(t, operator.Stop())
-			}()
-
-			for _, expected := range tc.expected {
-				select {
-				case entry := <-receivedEntries:
-					require.Equal(t, expected, []byte(entry.Body.(string)))
-				case <-time.After(500 * time.Millisecond):
-					require.FailNow(t, "Timed out waiting for entry to be read")
-				}
-			}
-		})
-	}
-}