remove dead tcp stream shim

Author: ncode

pkg/auditserver/server.go

@@ -234,10 +234,6 @@ func (as *AuditServer) OnTraffic(c gnet.Conn) (action gnet.Action) {
 	return newTransportAdapter(as.auditTransport, as.logger, as).OnTraffic(c)
 }
 
-func (as *AuditServer) handleTCPStream(frame []byte, carryover []byte) []byte {
-	return newTransportAdapter("tcp", as.logger, as).handleTCPStream(frame, carryover)
-}
-
 func (as *AuditServer) executor() ruleGroupExecutor {
 	if as.ruleExecutor.groups != nil {
 		return as.ruleExecutor

pkg/auditserver/server_test.go

@@ -1630,36 +1630,6 @@ func TestRuleGroup_shouldLog_RuntimeErrorContinues(t *testing.T) {
 	assert.True(t, rg.shouldLog(&AuditLog{}))
 }
 
-func TestAuditServer_HandleTCPStream(t *testing.T) {
-	logger := slog.New(slog.NewTextHandler(io.Discard, &slog.HandlerOptions{Level: slog.LevelDebug}))
-	writer := new(bytes.Buffer)
-
-	as := &AuditServer{
-		logger: logger,
-		ruleGroups: []RuleGroup{
-			{Name: "default", Writer: writer},
-		},
-	}
-
-	stream := []byte(string(auditFrame()) + "\n" + string(auditFrame()) + "\r\n")
-	remaining := as.handleTCPStream(stream, nil)
-	require.Empty(t, remaining)
-
-	frameText := string(auditFrame())
-	assert.Equal(t, 2, strings.Count(writer.String(), frameText))
-
-	// split frame across reads and validate carryover behavior
-	full := string(auditFrame())
-	mid := len(full) / 2
-	carry := as.handleTCPStream([]byte(full[:mid]), nil)
-	require.NotEmpty(t, carry)
-
-	carry = as.handleTCPStream([]byte(full[mid:]+"\n"), carry)
-	require.Empty(t, carry)
-
-	assert.Equal(t, 3, strings.Count(writer.String(), frameText))
-}
-
 func TestNew_AuditTransportConfiguration(t *testing.T) {
 	server, err := New(nil)
 	require.NoError(t, err)