Function TestFilterPanic

proxy/proxy_test.go:1033–1115

(t *testing.T)

func (*nilFilterSpec) CreateFilter(config []interface{}) (filters.Filter, error) { return nil, nil }

func TestFilterPanic(t *testing.T) {
	testLog := NewTestLog()
	defer testLog.Close()

	var backendRequests int32
	s := startTestServer([]byte("Hello World!"), 0, func(r *http.Request) {
		atomic.AddInt32(&backendRequests, 1)
	})
	defer s.Close()

	metrics := &metricstest.MockMetrics{}
	defer metrics.Close()
	d := 50 * time.Millisecond
	reg := scheduler.RegistryWith(scheduler.Options{
		Metrics:                metrics,
		EnableRouteFIFOMetrics: true,
		MetricsUpdateTimeout:   d,
	})
	defer reg.Close()

	fr := make(filters.Registry)
	fr.Register(builtin.NewAppendRequestHeader())
	fr.Register(builtin.NewAppendResponseHeader())
	fr.Register(fscheduler.NewFifo())
	fr.Register(new(nilFilterSpec))

	doc := fmt.Sprintf(`test:
		Path("/foo") ->
		fifo(2000,20,"1s") ->
		appendRequestHeader("X-Expected", "before") ->
		appendResponseHeader("X-Expected", "before") ->
		nilFilter() ->
		appendRequestHeader("X-Expected", "after") ->
		appendResponseHeader("X-Expected", "after") ->
		"%s"`, s.URL)

	dc, err := testdataclient.NewDoc(doc)
	if err != nil {
		t.Fatalf("Failed to create testdataclient: %v", err)
	}
	defer dc.Close()
	ro := routing.Options{
		SignalFirstLoad: true,
		FilterRegistry:  fr,
		DataClients:     []routing.DataClient{dc},
		PostProcessors:  []routing.PostProcessor{reg},
	}
	rt := routing.New(ro)
	defer rt.Close()
	<-rt.FirstLoad()

	pr := WithParams(Params{
		Flags:   FlagsNone,
		Metrics: metrics,
		Routing: rt,
	})
	defer pr.Close()