test: improve the config change detection

Fix the flaky test TestFilterManagerEncode.
Signed-off-by: spacewander <[email protected]>

api/plugins/tests/integration/controlplane/control_plane.go

@@ -19,6 +19,7 @@ import (
 	"encoding/json"
 	"fmt"
 	"io"
+	"math/rand"
 	"net"
 	"os"
 	"runtime"
@@ -77,6 +78,15 @@ func NewControlPlane() *ControlPlane {
 	return cp
 }
 
+func getRandomString(n int) string {
+	var Letters = []rune("abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ")
+	result := make([]rune, n)
+	for i := range result {
+		result[i] = Letters[rand.Intn(len(Letters))]
+	}
+	return string(result)
+}
+
 func isWsl() bool {
 	f, err := os.Open("/proc/version")
 	if err != nil {
@@ -179,6 +189,7 @@ func (cp *ControlPlane) UseGoPluginConfig(t *testing.T, config *filtermanager.Fi
 						Domains: []string{"*"},
 						Routes: []*route.Route{
 							{
+								Name: getRandomString(8),
 								Match: &route.RouteMatch{
 									PathSpecifier: &route.RouteMatch_Path{
 										Path: "/detect_if_the_rds_takes_effect",
@@ -195,7 +206,7 @@ func (cp *ControlPlane) UseGoPluginConfig(t *testing.T, config *filtermanager.Fi
 											"fm": {
 												Override: &golang.RouterPlugin_Config{
 													Config: proto.MessageToAny(
-														FilterManagerConfigToTypedStruct(NewPluginConfig(nil))),
+														FilterManagerConfigToTypedStruct(NewSinglePluginConfig("detector", nil))),
 												},
 											},
 										},

api/plugins/tests/integration/dataplane/data_plane.go

@@ -56,6 +56,8 @@ type DataPlane struct {
 	opt  *Option
 	done chan error
 
+	latestRouteVersion string
+
 	dataPlanePort string
 	adminAPIPort  string
 }
@@ -476,14 +478,19 @@ func (dp *DataPlane) Grpcurl(importPath, protoFile, fullMethodName, req string)
 }
 
 func (dp *DataPlane) Configured() bool {
-	// TODO: this is fine for the first init of the envoy configuration.
-	// But it may be misleading when updating the configuration.
-	// Would be better to switch to Envoy's /config_dump API.
 	resp, err := dp.Head("/detect_if_the_rds_takes_effect", nil)
 	if err != nil {
 		return false
 	}
-	return resp.StatusCode == 200
+	if resp.StatusCode != 200 {
+		return false
+	}
+	name := resp.Header.Get("route-version")
+	if name == dp.latestRouteVersion {
+		return false
+	}
+	dp.latestRouteVersion = name
+	return true
 }
 
 func (dp *DataPlane) FlushCoverage() error {

api/plugins/tests/integration/dataplane/plugins.go

@@ -15,6 +15,7 @@
 package dataplane
 
 import (
+	"net/http"
 	"runtime/coverage"
 
 	"mosn.io/htnn/api/pkg/filtermanager/api"
@@ -59,6 +60,35 @@ func (f *coverageFilter) DecodeHeaders(headers api.RequestHeaderMap, endStream b
 	return &api.LocalResponse{Code: 200}
 }
 
+type detectorPlugin struct {
+	plugins.PluginMethodDefaultImpl
+	basePlugin
+}
+
+func (p *detectorPlugin) Factory() api.FilterFactory {
+	return detectorFactory
+}
+
+func detectorFactory(c interface{}, callbacks api.FilterCallbackHandler) api.Filter {
+	return &detectorFilter{
+		callbacks: callbacks,
+	}
+}
+
+type detectorFilter struct {
+	api.PassThroughFilter
+
+	callbacks api.FilterCallbackHandler
+}
+
+func (f *detectorFilter) DecodeHeaders(headers api.RequestHeaderMap, endStream bool) api.ResultAction {
+	hdr := http.Header{}
+	name := f.callbacks.StreamInfo().GetRouteName()
+	hdr.Add("route-version", name)
+	return &api.LocalResponse{Code: 200, Header: hdr}
+}
+
 func init() {
 	plugins.RegisterPlugin("coverage", &coveragePlugin{})
+	plugins.RegisterPlugin("detector", &detectorPlugin{})
 }