Function NewURLDenyListWare

modules/frontend/pipeline/async_deny_list_middleware.go:15–32

(denyList []string)

}

func NewURLDenyListWare(denyList []string) AsyncMiddleware[combiner.PipelineResponse] {
	compiledDenylist := make([]*regexp.Regexp, 0)
	for _, v := range denyList {
		r, err := regexp.Compile(v)
		if err == nil {
			compiledDenylist = append(compiledDenylist, r)
		} else {
			panic(fmt.Sprintf("error compiling query frontend deny list regex: %s", err))
		}
	}

	return AsyncMiddlewareFunc[combiner.PipelineResponse](func(next AsyncRoundTripper[combiner.PipelineResponse]) AsyncRoundTripper[combiner.PipelineResponse] {
		return &urlDenylistWare{
			next:     next,
			denyList: compiledDenylist,
		}
	})
}

func (c urlDenylistWare) RoundTrip(req Request) (Responses[combiner.PipelineResponse], error) {
	if len(c.denyList) != 0 {