httpbody wrapper blockmatcher with func passing

feature: implement net.HttpBody to allow streaming filters on http body request and response
refactoring: blockContent,blockContentHex filters to use the new implementation

refactor: move ErrBlock form proxy to net
refactor: reuse types and enum and expose options to set httpbody matcher config
drop noleak because of transport related leaks
feature: read write body wrapper and test api with porting compress filter

Signed-off-by: Sandor Szücs <sandor.szuecs@zalando.de>

filters/block/block.go

@@ -1,10 +1,12 @@
 package block
 
 import (
+	"bytes"
 	"encoding/hex"
 	"errors"
 
 	"github.com/zalando/skipper/filters"
+	"github.com/zalando/skipper/net"
 )
 
 var (
@@ -16,10 +18,16 @@ type blockSpec struct {
 	hex                  bool
 }
 
+type toBlockKeys struct{ Str []byte }
+
+func (b toBlockKeys) String() string {
+	return string(b.Str)
+}
+
 type block struct {
-	toblockList       []toblockKeys
+	toblockList       []toBlockKeys
 	maxEditorBuffer   uint64
-	maxBufferHandling maxBufferHandling
+	maxBufferHandling net.MaxBufferHandling
 }
 
 // NewBlockFilter *deprecated* version of NewBlock
@@ -52,7 +60,7 @@ func (bs *blockSpec) CreateFilter(args []interface{}) (filters.Filter, error) {
 		return nil, filters.ErrInvalidFilterParameters
 	}
 
-	sargs := make([]toblockKeys, 0, len(args))
+	sargs := make([]toBlockKeys, 0, len(args))
 	for _, w := range args {
 		v, ok := w.(string)
 		if !ok {
@@ -63,33 +71,50 @@ func (bs *blockSpec) CreateFilter(args []interface{}) (filters.Filter, error) {
 			if err != nil {
 				return nil, err
 			}
-			sargs = append(sargs, toblockKeys{str: a})
+			sargs = append(sargs, toBlockKeys{Str: a})
 		} else {
-			sargs = append(sargs, toblockKeys{str: []byte(v)})
+			sargs = append(sargs, toBlockKeys{Str: []byte(v)})
 		}
 	}
 
-	b := &block{
+	return &block{
 		toblockList:       sargs,
-		maxBufferHandling: maxBufferBestEffort,
+		maxBufferHandling: net.MaxBufferBestEffort,
 		maxEditorBuffer:   bs.MaxMatcherBufferSize,
-	}
+	}, nil
+}
 
-	return *b, nil
+func blockMatcher(matches []toBlockKeys) func(b []byte) (int, error) {
+	return func(b []byte) (int, error) {
+		for _, s := range matches {
+			s := s
+			println("blockMatcher:", string(b), len(string(b)), "contains?:", string(s.Str))
+			if bytes.Contains(b, s.Str) {
+				b = nil
+				return 0, net.ErrBlocked
+			}
+		}
+		return len(b), nil
+	}
 }
 
-func (b block) Request(ctx filters.FilterContext) {
+func (b *block) Request(ctx filters.FilterContext) {
 	req := ctx.Request()
 	if req.ContentLength == 0 {
 		return
 	}
-
-	req.Body = newMatcher(
-		req.Body,
-		b.toblockList,
-		b.maxEditorBuffer,
-		b.maxBufferHandling,
-	)
+	// fix filter chaining - https://github.com/zalando/skipper/issues/2605
+	ctx.Request().Header.Del("Content-Length")
+	ctx.Request().ContentLength = -1
+
+	req.Body = net.WrapBodyWithOptions(
+		req.Context(),
+		net.BodyOptions{
+			MaxBufferHandling: b.maxBufferHandling,
+			ReadBufferSize:    b.maxEditorBuffer,
+		},
+		blockMatcher(b.toblockList),
+		req.Body)
 }
 
-func (block) Response(filters.FilterContext) {}
+func (*block) Response(filters.FilterContext) {}