Move plugins to the roadrunner-plugins repository

36 files changed, 0 insertions, 6452 deletions

diff --git a/plugins/http/attributes/attributes.go b/plugins/http/attributes/attributes.go
deleted file mode 100644
index 4c453766..00000000
--- a/plugins/http/attributes/attributes.go
+++ /dev/null
@@ -1,85 +0,0 @@
-package attributes
-
-import (
-	"context"
-	"errors"
-	"net/http"
-)
-
-// contextKey is a value for use with context.WithValue. It's used as
-// a pointer so it fits in an interface{} without allocation.
-type contextKey struct {
-	name string
-}
-
-func (k *contextKey) String() string { return k.name }
-
-var (
-	// PsrContextKey is a context key. It can be used in the http attributes
-	PsrContextKey = &contextKey{"psr_attributes"}
-)
-
-type attrs map[string]interface{}
-
-func (v attrs) get(key string) interface{} {
-	if v == nil {
-		return ""
-	}
-
-	return v[key]
-}
-
-func (v attrs) set(key string, value interface{}) {
-	v[key] = value
-}
-
-func (v attrs) del(key string) {
-	delete(v, key)
-}
-
-// Init returns request with new context and attribute bag.
-func Init(r *http.Request) *http.Request {
-	return r.WithContext(context.WithValue(r.Context(), PsrContextKey, attrs{}))
-}
-
-// All returns all context attributes.
-func All(r *http.Request) map[string]interface{} {
-	v := r.Context().Value(PsrContextKey)
-	if v == nil {
-		return attrs{}
-	}
-
-	return v.(attrs)
-}
-
-// Get gets the value from request context. It replaces any existing
-// values.
-func Get(r *http.Request, key string) interface{} {
-	v := r.Context().Value(PsrContextKey)
-	if v == nil {
-		return nil
-	}
-
-	return v.(attrs).get(key)
-}
-
-// Set sets the key to value. It replaces any existing
-// values. Context specific.
-func Set(r *http.Request, key string, value interface{}) error {
-	v := r.Context().Value(PsrContextKey)
-	if v == nil {
-		return errors.New("unable to find `psr:attributes` context key")
-	}
-
-	v.(attrs).set(key, value)
-	return nil
-}
-
-// Delete deletes values associated with attribute key.
-func (v attrs) Delete(key string) {
-	if v == nil {
-		return
-	}
-
-	v.del(key)
-}
diff --git a/plugins/http/attributes/attributes_test.go b/plugins/http/attributes/attributes_test.go
deleted file mode 100644
index 5622deb4..00000000
--- a/plugins/http/attributes/attributes_test.go
+++ /dev/null
@@ -1,77 +0,0 @@
-package attributes
-
-import (
-	"net/http"
-	"testing"
-
-	"github.com/stretchr/testify/assert"
-)
-
-func TestAllAttributes(t *testing.T) {
-	r := &http.Request{}
-	r = Init(r)
-
-	err := Set(r, "key", "value")
-	if err != nil {
-		t.Errorf("error during the Set: error %v", err)
-	}
-
-	assert.Equal(t, All(r), map[string]interface{}{
-		"key": "value",
-	})
-}
-
-func TestAllAttributesNone(t *testing.T) {
-	r := &http.Request{}
-	r = Init(r)
-
-	assert.Equal(t, All(r), map[string]interface{}{})
-}
-
-func TestAllAttributesNone2(t *testing.T) {
-	r := &http.Request{}
-
-	assert.Equal(t, All(r), map[string]interface{}{})
-}
-
-func TestGetAttribute(t *testing.T) {
-	r := &http.Request{}
-	r = Init(r)
-
-	err := Set(r, "key", "value")
-	if err != nil {
-		t.Errorf("error during the Set: error %v", err)
-	}
-	assert.Equal(t, Get(r, "key"), "value")
-}
-
-func TestGetAttributeNone(t *testing.T) {
-	r := &http.Request{}
-	r = Init(r)
-
-	assert.Equal(t, Get(r, "key"), nil)
-}
-
-func TestGetAttributeNone2(t *testing.T) {
-	r := &http.Request{}
-
-	assert.Equal(t, Get(r, "key"), nil)
-}
-
-func TestSetAttribute(t *testing.T) {
-	r := &http.Request{}
-	r = Init(r)
-
-	err := Set(r, "key", "value")
-	if err != nil {
-		t.Errorf("error during the Set: error %v", err)
-	}
-	assert.Equal(t, Get(r, "key"), "value")
-}
-
-func TestSetAttributeNone(t *testing.T) {
-	r := &http.Request{}
-	err := Set(r, "key", "value")
-	assert.Error(t, err)
-	assert.Equal(t, Get(r, "key"), nil)
-}
diff --git a/plugins/http/config.go b/plugins/http/config.go
deleted file mode 100644
index 00d2940b..00000000
--- a/plugins/http/config.go
+++ /dev/null
@@ -1,291 +0,0 @@
-package http
-
-import (
-	"net"
-	"os"
-	"runtime"
-	"strings"
-	"time"
-
-	"github.com/spiral/errors"
-	poolImpl "github.com/spiral/roadrunner/v2/pkg/pool"
-)
-
-type Cidrs []*net.IPNet
-
-func (c *Cidrs) IsTrusted(ip string) bool {
-	if len(*c) == 0 {
-		return false
-	}
-
-	i := net.ParseIP(ip)
-	if i == nil {
-		return false
-	}
-
-	for _, cird := range *c {
-		if cird.Contains(i) {
-			return true
-		}
-	}
-
-	return false
-}
-
-// Config configures RoadRunner HTTP server.
-type Config struct {
-	// Port and port to handle as http server.
-	Address string
-
-	// SSL defines https server options.
-	SSL *SSLConfig
-
-	// FCGI configuration. You can use FastCGI without HTTP server.
-	FCGI *FCGIConfig
-
-	// HTTP2 configuration
-	HTTP2 *HTTP2Config
-
-	// MaxRequestSize specified max size for payload body in megabytes, set 0 to unlimited.
-	MaxRequestSize uint64
-
-	// TrustedSubnets declare IP subnets which are allowed to set ip using X-Real-Ip and X-Forwarded-For
-	TrustedSubnets []string
-
-	// Uploads configures uploads configuration.
-	Uploads *UploadsConfig
-
-	// Pool configures worker pool.
-	Pool *poolImpl.Config
-
-	// Env is environment variables passed to the  http pool
-	Env map[string]string
-
-	// List of the middleware names (order will be preserved)
-	Middleware []string
-
-	// slice of net.IPNet
-	cidrs Cidrs
-}
-
-// FCGIConfig for FastCGI server.
-type FCGIConfig struct {
-	// Address and port to handle as http server.
-	Address string
-}
-
-// HTTP2Config HTTP/2 server customizations.
-type HTTP2Config struct {
-	// Enable or disable HTTP/2 extension, default enable.
-	Enabled bool
-
-	// H2C enables HTTP/2 over TCP
-	H2C bool
-
-	// MaxConcurrentStreams defaults to 128.
-	MaxConcurrentStreams uint32
-}
-
-// InitDefaults sets default values for HTTP/2 configuration.
-func (cfg *HTTP2Config) InitDefaults() error {
-	cfg.Enabled = true
-	cfg.MaxConcurrentStreams = 128
-
-	return nil
-}
-
-// SSLConfig defines https server configuration.
-type SSLConfig struct {
-	// Port to listen as HTTPS server, defaults to 443.
-	Port int
-
-	// Redirect when enabled forces all http connections to switch to https.
-	Redirect bool
-
-	// Key defined private server key.
-	Key string
-
-	// Cert is https certificate.
-	Cert string
-
-	// Root CA file
-	RootCA string
-}
-
-// EnableHTTP is true when http server must run.
-func (c *Config) EnableHTTP() bool {
-	return c.Address != ""
-}
-
-// EnableTLS returns true if pool must listen TLS connections.
-func (c *Config) EnableTLS() bool {
-	return c.SSL.Key != "" || c.SSL.Cert != "" || c.SSL.RootCA != ""
-}
-
-// EnableHTTP2 when HTTP/2 extension must be enabled (only with TSL).
-func (c *Config) EnableHTTP2() bool {
-	return c.HTTP2.Enabled
-}
-
-// EnableH2C when HTTP/2 extension must be enabled on TCP.
-func (c *Config) EnableH2C() bool {
-	return c.HTTP2.H2C
-}
-
-// EnableFCGI is true when FastCGI server must be enabled.
-func (c *Config) EnableFCGI() bool {
-	return c.FCGI.Address != ""
-}
-
-// Hydrate must populate Config values using given Config source. Must return error if Config is not valid.
-func (c *Config) InitDefaults() error {
-	if c.Pool == nil {
-		// default pool
-		c.Pool = &poolImpl.Config{
-			Debug:           false,
-			NumWorkers:      int64(runtime.NumCPU()),
-			MaxJobs:         1000,
-			AllocateTimeout: time.Second * 60,
-			DestroyTimeout:  time.Second * 60,
-			Supervisor:      nil,
-		}
-	}
-
-	if c.HTTP2 == nil {
-		c.HTTP2 = &HTTP2Config{}
-	}
-
-	if c.FCGI == nil {
-		c.FCGI = &FCGIConfig{}
-	}
-
-	if c.Uploads == nil {
-		c.Uploads = &UploadsConfig{}
-	}
-
-	if c.SSL == nil {
-		c.SSL = &SSLConfig{}
-	}
-
-	if c.SSL.Port == 0 {
-		c.SSL.Port = 443
-	}
-
-	err := c.HTTP2.InitDefaults()
-	if err != nil {
-		return err
-	}
-	err = c.Uploads.InitDefaults()
-	if err != nil {
-		return err
-	}
-
-	if c.TrustedSubnets == nil {
-		// @see https://en.wikipedia.org/wiki/Reserved_IP_addresses
-		c.TrustedSubnets = []string{
-			"10.0.0.0/8",
-			"127.0.0.0/8",
-			"172.16.0.0/12",
-			"192.168.0.0/16",
-			"::1/128",
-			"fc00::/7",
-			"fe80::/10",
-		}
-	}
-
-	cidrs, err := ParseCIDRs(c.TrustedSubnets)
-	if err != nil {
-		return err
-	}
-	c.cidrs = cidrs
-
-	return c.Valid()
-}
-
-func ParseCIDRs(subnets []string) (Cidrs, error) {
-	c := make(Cidrs, 0, len(subnets))
-	for _, cidr := range subnets {
-		_, cr, err := net.ParseCIDR(cidr)
-		if err != nil {
-			return nil, err
-		}
-
-		c = append(c, cr)
-	}
-
-	return c, nil
-}
-
-// IsTrusted if api can be trusted to use X-Real-Ip, X-Forwarded-For
-func (c *Config) IsTrusted(ip string) bool {
-	if c.cidrs == nil {
-		return false
-	}
-
-	i := net.ParseIP(ip)
-	if i == nil {
-		return false
-	}
-
-	for _, cird := range c.cidrs {
-		if cird.Contains(i) {
-			return true
-		}
-	}
-
-	return false
-}
-
-// Valid validates the configuration.
-func (c *Config) Valid() error {
-	const op = errors.Op("validation")
-	if c.Uploads == nil {
-		return errors.E(op, errors.Str("malformed uploads config"))
-	}
-
-	if c.HTTP2 == nil {
-		return errors.E(op, errors.Str("malformed http2 config"))
-	}
-
-	if c.Pool == nil {
-		return errors.E(op, "malformed pool config")
-	}
-
-	if !c.EnableHTTP() && !c.EnableTLS() && !c.EnableFCGI() {
-		return errors.E(op, errors.Str("unable to run http service, no method has been specified (http, https, http/2 or FastCGI)"))
-	}
-
-	if c.Address != "" && !strings.Contains(c.Address, ":") {
-		return errors.E(op, errors.Str("malformed http server address"))
-	}
-
-	if c.EnableTLS() {
-		if _, err := os.Stat(c.SSL.Key); err != nil {
-			if os.IsNotExist(err) {
-				return errors.E(op, errors.Errorf("key file '%s' does not exists", c.SSL.Key))
-			}
-
-			return err
-		}
-
-		if _, err := os.Stat(c.SSL.Cert); err != nil {
-			if os.IsNotExist(err) {
-				return errors.E(op, errors.Errorf("cert file '%s' does not exists", c.SSL.Cert))
-			}
-
-			return err
-		}
-
-		// RootCA is optional, but if provided - check it
-		if c.SSL.RootCA != "" {
-			if _, err := os.Stat(c.SSL.RootCA); err != nil {
-				if os.IsNotExist(err) {
-					return errors.E(op, errors.Errorf("root ca path provided, but path '%s' does not exists", c.SSL.RootCA))
-				}
-				return err
-			}
-		}
-	}
-
-	return nil
-}
diff --git a/plugins/http/constants.go b/plugins/http/constants.go
deleted file mode 100644
index 773d1f46..00000000
--- a/plugins/http/constants.go
+++ /dev/null
@@ -1,6 +0,0 @@
-package http
-
-import "net/http"
-
-var http2pushHeaderKey = http.CanonicalHeaderKey("http2-push")
-var TrailerHeaderKey = http.CanonicalHeaderKey("trailer")
diff --git a/plugins/http/errors.go b/plugins/http/errors.go
deleted file mode 100644
index fb8762ef..00000000
--- a/plugins/http/errors.go
+++ /dev/null
@@ -1,25 +0,0 @@
-// +build !windows
-
-package http
-
-import (
-	"errors"
-	"net"
-	"os"
-	"syscall"
-)
-
-// Broken pipe
-var errEPIPE = errors.New("EPIPE(32) -> connection reset by peer")
-
-// handleWriteError just check if error was caused by aborted connection on linux
-func handleWriteError(err error) error {
-	if netErr, ok2 := err.(*net.OpError); ok2 {
-		if syscallErr, ok3 := netErr.Err.(*os.SyscallError); ok3 {
-			if syscallErr.Err == syscall.EPIPE {
-				return errEPIPE
-			}
-		}
-	}
-	return err
-}
diff --git a/plugins/http/errors_windows.go b/plugins/http/errors_windows.go
deleted file mode 100644
index 3d0ba04c..00000000
--- a/plugins/http/errors_windows.go
+++ /dev/null
@@ -1,27 +0,0 @@
-// +build windows
-
-package http
-
-import (
-	"errors"
-	"net"
-	"os"
-	"syscall"
-)
-
-//Software caused connection abort.
-//An established connection was aborted by the software in your host computer,
-//possibly due to a data transmission time-out or protocol error.
-var errEPIPE = errors.New("WSAECONNABORTED (10053) ->  an established connection was aborted by peer")
-
-// handleWriteError just check if error was caused by aborted connection on windows
-func handleWriteError(err error) error {
-	if netErr, ok2 := err.(*net.OpError); ok2 {
-		if syscallErr, ok3 := netErr.Err.(*os.SyscallError); ok3 {
-			if syscallErr.Err == syscall.WSAECONNABORTED {
-				return errEPIPE
-			}
-		}
-	}
-	return err
-}
diff --git a/plugins/http/handler.go b/plugins/http/handler.go
deleted file mode 100644
index 57590bfd..00000000
--- a/plugins/http/handler.go
+++ /dev/null
@@ -1,240 +0,0 @@
-package http
-
-import (
-	"net"
-	"net/http"
-	"strconv"
-	"strings"
-	"sync"
-	"time"
-
-	"github.com/hashicorp/go-multierror"
-	"github.com/spiral/errors"
-	"github.com/spiral/roadrunner/v2/interfaces/events"
-	"github.com/spiral/roadrunner/v2/interfaces/log"
-	"github.com/spiral/roadrunner/v2/interfaces/pool"
-)
-
-const (
-	// EventResponse thrown after the request been processed. See ErrorEvent as payload.
-	EventResponse = iota + 500
-
-	// EventError thrown on any non job error provided by road runner server.
-	EventError
-)
-
-const MB = 1024 * 1024
-
-type Handle interface {
-	AddListener(l events.EventListener)
-	ServeHTTP(w http.ResponseWriter, r *http.Request)
-}
-
-// ErrorEvent represents singular http error event.
-type ErrorEvent struct {
-	// Request contains client request, must not be stored.
-	Request *http.Request
-
-	// Error - associated error, if any.
-	Error error
-
-	// event timings
-	start   time.Time
-	elapsed time.Duration
-}
-
-// Elapsed returns duration of the invocation.
-func (e *ErrorEvent) Elapsed() time.Duration {
-	return e.elapsed
-}
-
-// ResponseEvent represents singular http response event.
-type ResponseEvent struct {
-	// Request contains client request, must not be stored.
-	Request *Request
-
-	// Response contains service response.
-	Response *Response
-
-	// event timings
-	start   time.Time
-	elapsed time.Duration
-}
-
-// Elapsed returns duration of the invocation.
-func (e *ResponseEvent) Elapsed() time.Duration {
-	return e.elapsed
-}
-
-// Handler serves http connections to underlying PHP application using PSR-7 protocol. Context will include request headers,
-// parsed files and query, payload will include parsed form dataTree (if any).
-type handler struct {
-	maxRequestSize uint64
-	uploads        UploadsConfig
-	trusted        Cidrs
-	log            log.Logger
-	pool           pool.Pool
-	mul            sync.Mutex
-	lsn            events.EventListener
-}
-
-func NewHandler(maxReqSize uint64, uploads UploadsConfig, trusted Cidrs, pool pool.Pool) (Handle, error) {
-	if pool == nil {
-		return nil, errors.E(errors.Str("pool should be initialized"))
-	}
-	return &handler{
-		maxRequestSize: maxReqSize * MB,
-		uploads:        uploads,
-		pool:           pool,
-		trusted:        trusted,
-	}, nil
-}
-
-// Listen attaches handler event controller.
-func (h *handler) AddListener(l events.EventListener) {
-	h.mul.Lock()
-	defer h.mul.Unlock()
-
-	h.lsn = l
-}
-
-// mdwr serve using PSR-7 requests passed to underlying application. Attempts to serve static files first if enabled.
-func (h *handler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
-	const op = errors.Op("ServeHTTP")
-	start := time.Now()
-
-	// validating request size
-	if h.maxRequestSize != 0 {
-		err := h.maxSize(w, r, start, op)
-		if err != nil {
-			return
-		}
-	}
-
-	req, err := NewRequest(r, h.uploads)
-	if err != nil {
-		h.handleError(w, r, err, start)
-		return
-	}
-
-	// proxy IP resolution
-	h.resolveIP(req)
-
-	req.Open(h.log)
-	defer req.Close(h.log)
-
-	p, err := req.Payload()
-	if err != nil {
-		h.handleError(w, r, err, start)
-		return
-	}
-
-	rsp, err := h.pool.Exec(p)
-	if err != nil {
-		h.handleError(w, r, err, start)
-		return
-	}
-
-	resp, err := NewResponse(rsp)
-	if err != nil {
-		h.handleError(w, r, err, start)
-		return
-	}
-
-	h.handleResponse(req, resp, start)
-	err = resp.Write(w)
-	if err != nil {
-		h.handleError(w, r, err, start)
-	}
-}
-
-func (h *handler) maxSize(w http.ResponseWriter, r *http.Request, start time.Time, op errors.Op) error {
-	if length := r.Header.Get("content-length"); length != "" {
-		if size, err := strconv.ParseInt(length, 10, 64); err != nil {
-			h.handleError(w, r, err, start)
-			return err
-		} else if size > int64(h.maxRequestSize) {
-			h.handleError(w, r, errors.E(op, errors.Str("request body max size is exceeded")), start)
-			return err
-		}
-	}
-	return nil
-}
-
-// handleError sends error.
-func (h *handler) handleError(w http.ResponseWriter, r *http.Request, err error, start time.Time) {
-	h.mul.Lock()
-	defer h.mul.Unlock()
-	// if pipe is broken, there is no sense to write the header
-	// in this case we just report about error
-	if err == errEPIPE {
-		h.throw(ErrorEvent{Request: r, Error: err, start: start, elapsed: time.Since(start)})
-		return
-	}
-	err = multierror.Append(err)
-	// ResponseWriter is ok, write the error code
-	w.WriteHeader(500)
-	_, err2 := w.Write([]byte(err.Error()))
-	// error during the writing to the ResponseWriter
-	if err2 != nil {
-		err = multierror.Append(err2, err)
-		// concat original error with ResponseWriter error
-		h.throw(ErrorEvent{Request: r, Error: errors.E(err), start: start, elapsed: time.Since(start)})
-		return
-	}
-	h.throw(ErrorEvent{Request: r, Error: err, start: start, elapsed: time.Since(start)})
-}
-
-// handleResponse triggers response event.
-func (h *handler) handleResponse(req *Request, resp *Response, start time.Time) {
-	h.throw(ResponseEvent{Request: req, Response: resp, start: start, elapsed: time.Since(start)})
-}
-
-// throw invokes event handler if any.
-func (h *handler) throw(ctx interface{}) {
-	if h.lsn != nil {
-		h.lsn(ctx)
-	}
-}
-
-// get real ip passing multiple proxy
-func (h *handler) resolveIP(r *Request) {
-	if h.trusted.IsTrusted(r.RemoteAddr) == false {
-		return
-	}
-
-	if r.Header.Get("X-Forwarded-For") != "" {
-		ips := strings.Split(r.Header.Get("X-Forwarded-For"), ",")
-		ipCount := len(ips)
-
-		for i := ipCount - 1; i >= 0; i-- {
-			addr := strings.TrimSpace(ips[i])
-			if net.ParseIP(addr) != nil {
-				r.RemoteAddr = addr
-				return
-			}
-		}
-
-		return
-	}
-
-	// The logic here is the following:
-	// In general case, we only expect X-Real-Ip header. If it exist, we get the IP address from header and set request Remote address
-	// But, if there is no X-Real-Ip header, we also trying to check CloudFlare headers
-	// True-Client-IP is a general CF header in which copied information from X-Real-Ip in CF.
-	// CF-Connecting-IP is an Enterprise feature and we check it last in order.
-	// This operations are near O(1) because Headers struct are the map type -> type MIMEHeader map[string][]string
-	if r.Header.Get("X-Real-Ip") != "" {
-		r.RemoteAddr = fetchIP(r.Header.Get("X-Real-Ip"))
-		return
-	}
-
-	if r.Header.Get("True-Client-IP") != "" {
-		r.RemoteAddr = fetchIP(r.Header.Get("True-Client-IP"))
-		return
-	}
-
-	if r.Header.Get("CF-Connecting-IP") != "" {
-		r.RemoteAddr = fetchIP(r.Header.Get("CF-Connecting-IP"))
-	}
-}
diff --git a/plugins/http/parse.go b/plugins/http/parse.go
deleted file mode 100644
index d4a1604b..00000000
--- a/plugins/http/parse.go
+++ /dev/null
@@ -1,147 +0,0 @@
-package http
-
-import (
-	"net/http"
-)
-
-// MaxLevel defines maximum tree depth for incoming request data and files.
-const MaxLevel = 127
-
-type dataTree map[string]interface{}
-type fileTree map[string]interface{}
-
-// parseData parses incoming request body into data tree.
-func parseData(r *http.Request) dataTree {
-	data := make(dataTree)
-	if r.PostForm != nil {
-		for k, v := range r.PostForm {
-			data.push(k, v)
-		}
-	}
-
-	if r.MultipartForm != nil {
-		for k, v := range r.MultipartForm.Value {
-			data.push(k, v)
-		}
-	}
-
-	return data
-}
-
-// pushes value into data tree.
-func (d dataTree) push(k string, v []string) {
-	keys := FetchIndexes(k)
-	if len(keys) <= MaxLevel {
-		d.mount(keys, v)
-	}
-}
-
-// mount mounts data tree recursively.
-func (d dataTree) mount(i []string, v []string) {
-	if len(i) == 1 {
-		// single value context (last element)
-		d[i[0]] = v[len(v)-1]
-		return
-	}
-
-	if len(i) == 2 && i[1] == "" {
-		// non associated array of elements
-		d[i[0]] = v
-		return
-	}
-
-	if p, ok := d[i[0]]; ok {
-		p.(dataTree).mount(i[1:], v)
-		return
-	}
-
-	d[i[0]] = make(dataTree)
-	d[i[0]].(dataTree).mount(i[1:], v)
-}
-
-// parse incoming dataTree request into JSON (including contentMultipart form dataTree)
-func parseUploads(r *http.Request, cfg UploadsConfig) *Uploads {
-	u := &Uploads{
-		cfg:  cfg,
-		tree: make(fileTree),
-		list: make([]*FileUpload, 0),
-	}
-
-	for k, v := range r.MultipartForm.File {
-		files := make([]*FileUpload, 0, len(v))
-		for _, f := range v {
-			files = append(files, NewUpload(f))
-		}
-
-		u.list = append(u.list, files...)
-		u.tree.push(k, files)
-	}
-
-	return u
-}
-
-// pushes new file upload into it's proper place.
-func (d fileTree) push(k string, v []*FileUpload) {
-	keys := FetchIndexes(k)
-	if len(keys) <= MaxLevel {
-		d.mount(keys, v)
-	}
-}
-
-// mount mounts data tree recursively.
-func (d fileTree) mount(i []string, v []*FileUpload) {
-	if len(i) == 1 {
-		// single value context
-		d[i[0]] = v[0]
-		return
-	}
-
-	if len(i) == 2 && i[1] == "" {
-		// non associated array of elements
-		d[i[0]] = v
-		return
-	}
-
-	if p, ok := d[i[0]]; ok {
-		p.(fileTree).mount(i[1:], v)
-		return
-	}
-
-	d[i[0]] = make(fileTree)
-	d[i[0]].(fileTree).mount(i[1:], v)
-}
-
-// FetchIndexes parses input name and splits it into separate indexes list.
-func FetchIndexes(s string) []string {
-	var (
-		pos  int
-		ch   string
-		keys = make([]string, 1)
-	)
-
-	for _, c := range s {
-		ch = string(c)
-		switch ch {
-		case " ":
-			// ignore all spaces
-			continue
-		case "[":
-			pos = 1
-			continue
-		case "]":
-			if pos == 1 {
-				keys = append(keys, "")
-			}
-			pos = 2
-		default:
-			if pos == 1 || pos == 2 {
-				keys = append(keys, "")
-			}
-
-			keys[len(keys)-1] += ch
-			pos = 0
-		}
-	}
-
-	return keys
-}
diff --git a/plugins/http/plugin.go b/plugins/http/plugin.go
deleted file mode 100644
index 9729a355..00000000
--- a/plugins/http/plugin.go
+++ /dev/null
@@ -1,548 +0,0 @@
-package http
-
-import (
-	"context"
-	"crypto/tls"
-	"crypto/x509"
-	"fmt"
-	"io/ioutil"
-	"net/http"
-	"net/http/fcgi"
-	"net/url"
-	"strings"
-	"sync"
-
-	"github.com/hashicorp/go-multierror"
-	"github.com/spiral/endure"
-	"github.com/spiral/errors"
-	"github.com/spiral/roadrunner/v2/interfaces/config"
-	"github.com/spiral/roadrunner/v2/interfaces/events"
-	"github.com/spiral/roadrunner/v2/interfaces/log"
-	"github.com/spiral/roadrunner/v2/interfaces/pool"
-	"github.com/spiral/roadrunner/v2/interfaces/server"
-	"github.com/spiral/roadrunner/v2/interfaces/status"
-	"github.com/spiral/roadrunner/v2/interfaces/worker"
-	poolImpl "github.com/spiral/roadrunner/v2/pkg/pool"
-	"github.com/spiral/roadrunner/v2/plugins/http/attributes"
-	"github.com/spiral/roadrunner/v2/util"
-	"golang.org/x/net/http2"
-	"golang.org/x/net/http2/h2c"
-	"golang.org/x/sys/cpu"
-)
-
-const (
-	// PluginName declares plugin name.
-	PluginName = "http"
-
-	// EventInitSSL thrown at moment of https initialization. SSL server passed as context.
-	EventInitSSL = 750
-)
-
-// Middleware interface
-type Middleware interface {
-	Middleware(f http.Handler) http.HandlerFunc
-}
-
-type middleware map[string]Middleware
-
-// Service manages pool, http servers.
-type Plugin struct {
-	sync.Mutex
-
-	configurer config.Configurer
-	server     server.Server
-	log        log.Logger
-
-	cfg *Config
-	// middlewares to chain
-	mdwr middleware
-	// WorkerEvent listener to stdout
-	listener events.EventListener
-
-	// Pool which attached to all servers
-	pool pool.Pool
-
-	// servers RR handler
-	handler Handle
-
-	// servers
-	http  *http.Server
-	https *http.Server
-	fcgi  *http.Server
-}
-
-// AddListener attaches server event controller.
-func (s *Plugin) AddListener(listener events.EventListener) {
-	// save listeners for Reset
-	s.listener = listener
-	s.pool.AddListener(listener)
-}
-
-// Init must return configure svc and return true if svc hasStatus enabled. Must return error in case of
-// misconfiguration. Services must not be used without proper configuration pushed first.
-func (s *Plugin) Init(cfg config.Configurer, log log.Logger, server server.Server) error {
-	const op = errors.Op("http Init")
-	err := cfg.UnmarshalKey(PluginName, &s.cfg)
-	if err != nil {
-		return errors.E(op, err)
-	}
-
-	err = s.cfg.InitDefaults()
-	if err != nil {
-		return errors.E(op, err)
-	}
-
-	s.configurer = cfg
-	s.log = log
-	s.mdwr = make(map[string]Middleware)
-
-	if !s.cfg.EnableHTTP() && !s.cfg.EnableTLS() && !s.cfg.EnableFCGI() {
-		return errors.E(op, errors.Disabled)
-	}
-
-	s.pool, err = server.NewWorkerPool(context.Background(), poolImpl.Config{
-		Debug:           s.cfg.Pool.Debug,
-		NumWorkers:      s.cfg.Pool.NumWorkers,
-		MaxJobs:         s.cfg.Pool.MaxJobs,
-		AllocateTimeout: s.cfg.Pool.AllocateTimeout,
-		DestroyTimeout:  s.cfg.Pool.DestroyTimeout,
-		Supervisor:      s.cfg.Pool.Supervisor,
-	}, s.cfg.Env)
-	if err != nil {
-		return errors.E(op, err)
-	}
-
-	s.server = server
-
-	s.AddListener(s.logCallback)
-
-	return nil
-}
-
-func (s *Plugin) logCallback(event interface{}) {
-	switch ev := event.(type) {
-	case ResponseEvent:
-		s.log.Debug("http handler response received", "elapsed", ev.Elapsed().String(), "remote address", ev.Request.RemoteAddr)
-	case ErrorEvent:
-		s.log.Error("error event received", "elapsed", ev.Elapsed().String(), "error", ev.Error)
-	case events.WorkerEvent:
-		s.log.Debug("worker event received", "event", ev.Event, "worker state", ev.Worker.(worker.BaseProcess).State())
-	default:
-		fmt.Println(event)
-	}
-}
-
-// Serve serves the svc.
-func (s *Plugin) Serve() chan error {
-	s.Lock()
-	defer s.Unlock()
-
-	const op = errors.Op("serve http")
-	errCh := make(chan error, 2)
-
-	var err error
-	s.handler, err = NewHandler(
-		s.cfg.MaxRequestSize,
-		*s.cfg.Uploads,
-		s.cfg.cidrs,
-		s.pool,
-	)
-	if err != nil {
-		errCh <- errors.E(op, err)
-		return errCh
-	}
-
-	if s.listener != nil {
-		s.handler.AddListener(s.listener)
-	}
-
-	if s.cfg.EnableHTTP() {
-		if s.cfg.EnableH2C() {
-			s.http = &http.Server{Addr: s.cfg.Address, Handler: h2c.NewHandler(s, &http2.Server{})}
-		} else {
-			s.http = &http.Server{Addr: s.cfg.Address, Handler: s}
-		}
-	}
-
-	if s.cfg.EnableTLS() {
-		s.https = s.initSSL()
-		if s.cfg.SSL.RootCA != "" {
-			err = s.appendRootCa()
-			if err != nil {
-				errCh <- errors.E(op, err)
-				return errCh
-			}
-		}
-
-		if s.cfg.EnableHTTP2() {
-			if err := s.initHTTP2(); err != nil {
-				errCh <- errors.E(op, err)
-				return errCh
-			}
-		}
-	}
-
-	if s.cfg.EnableFCGI() {
-		s.fcgi = &http.Server{Handler: s}
-	}
-
-	// apply middlewares before starting the server
-	if len(s.mdwr) > 0 {
-		s.addMiddlewares()
-	}
-
-	if s.http != nil {
-		go func() {
-			httpErr := s.http.ListenAndServe()
-			if httpErr != nil && httpErr != http.ErrServerClosed {
-				errCh <- errors.E(op, httpErr)
-				return
-			}
-		}()
-	}
-
-	if s.https != nil {
-		go func() {
-			httpErr := s.https.ListenAndServeTLS(
-				s.cfg.SSL.Cert,
-				s.cfg.SSL.Key,
-			)
-
-			if httpErr != nil && httpErr != http.ErrServerClosed {
-				errCh <- errors.E(op, httpErr)
-				return
-			}
-		}()
-	}
-
-	if s.fcgi != nil {
-		go func() {
-			httpErr := s.serveFCGI()
-			if httpErr != nil && httpErr != http.ErrServerClosed {
-				errCh <- errors.E(op, httpErr)
-				return
-			}
-		}()
-	}
-
-	return errCh
-}
-
-// Stop stops the http.
-func (s *Plugin) Stop() error {
-	s.Lock()
-	defer s.Unlock()
-
-	var err error
-	if s.fcgi != nil {
-		err = s.fcgi.Shutdown(context.Background())
-		if err != nil && err != http.ErrServerClosed {
-			s.log.Error("error shutting down the fcgi server", "error", err)
-			// write error and try to stop other transport
-			err = multierror.Append(err)
-		}
-	}
-
-	if s.https != nil {
-		err = s.https.Shutdown(context.Background())
-		if err != nil && err != http.ErrServerClosed {
-			s.log.Error("error shutting down the https server", "error", err)
-			// write error and try to stop other transport
-			err = multierror.Append(err)
-		}
-	}
-
-	if s.http != nil {
-		err = s.http.Shutdown(context.Background())
-		if err != nil && err != http.ErrServerClosed {
-			s.log.Error("error shutting down the http server", "error", err)
-			// write error and try to stop other transport
-			err = multierror.Append(err)
-		}
-	}
-
-	return err
-}
-
-// ServeHTTP handles connection using set of middleware and pool PSR-7 server.
-func (s *Plugin) ServeHTTP(w http.ResponseWriter, r *http.Request) {
-	if headerContainsUpgrade(r, s) {
-		http.Error(w, "server does not support upgrade header", http.StatusInternalServerError)
-		return
-	}
-
-	if s.redirect(w, r) {
-		return
-	}
-
-	if s.https != nil && r.TLS != nil {
-		w.Header().Add("Strict-Transport-Security", "max-age=31536000; includeSubDomains; preload")
-	}
-
-	r = attributes.Init(r)
-	// protect the case, when user send Reset and we are replacing handler with pool
-	s.Lock()
-	s.handler.ServeHTTP(w, r)
-	s.Unlock()
-}
-
-// Server returns associated pool workers
-func (s *Plugin) Workers() []worker.BaseProcess {
-	return s.pool.Workers()
-}
-
-func (s *Plugin) Name() string {
-	return PluginName
-}
-
-func (s *Plugin) Reset() error {
-	s.Lock()
-	defer s.Unlock()
-	const op = errors.Op("http reset")
-	s.log.Info("HTTP plugin got restart request. Restarting...")
-	s.pool.Destroy(context.Background())
-
-	// re-read the config
-	err := s.configurer.UnmarshalKey(PluginName, &s.cfg)
-	if err != nil {
-		return errors.E(op, err)
-	}
-
-	s.pool, err = s.server.NewWorkerPool(context.Background(), poolImpl.Config{
-		Debug:           s.cfg.Pool.Debug,
-		NumWorkers:      s.cfg.Pool.NumWorkers,
-		MaxJobs:         s.cfg.Pool.MaxJobs,
-		AllocateTimeout: s.cfg.Pool.AllocateTimeout,
-		DestroyTimeout:  s.cfg.Pool.DestroyTimeout,
-		Supervisor:      s.cfg.Pool.Supervisor,
-	}, s.cfg.Env)
-	if err != nil {
-		return errors.E(op, err)
-	}
-
-	s.log.Info("HTTP workers Pool successfully restarted")
-	s.handler, err = NewHandler(
-		s.cfg.MaxRequestSize,
-		*s.cfg.Uploads,
-		s.cfg.cidrs,
-		s.pool,
-	)
-	if err != nil {
-		return errors.E(op, err)
-	}
-
-	// restore original listeners
-	s.pool.AddListener(s.listener)
-	s.log.Info("HTTP listeners successfully re-added")
-
-	s.log.Info("HTTP plugin successfully restarted")
-	return nil
-}
-
-func (s *Plugin) Collects() []interface{} {
-	return []interface{}{
-		s.AddMiddleware,
-	}
-}
-
-func (s *Plugin) AddMiddleware(name endure.Named, m Middleware) {
-	s.mdwr[name.Name()] = m
-}
-
-// Status return status of the particular plugin
-func (s *Plugin) Status() status.Status {
-	workers := s.Workers()
-	for i := 0; i < len(workers); i++ {
-		if workers[i].State().IsActive() {
-			return status.Status{
-				Code: http.StatusOK,
-			}
-		}
-	}
-	// if there are no workers, threat this as error
-	return status.Status{
-		Code: http.StatusInternalServerError,
-	}
-}
-
-func (s *Plugin) redirect(w http.ResponseWriter, r *http.Request) bool {
-	if s.https != nil && r.TLS == nil && s.cfg.SSL.Redirect {
-		target := &url.URL{
-			Scheme:   "https",
-			Host:     s.tlsAddr(r.Host, false),
-			Path:     r.URL.Path,
-			RawQuery: r.URL.RawQuery,
-		}
-
-		http.Redirect(w, r, target.String(), http.StatusTemporaryRedirect)
-		return true
-	}
-	return false
-}
-
-func headerContainsUpgrade(r *http.Request, s *Plugin) bool {
-	if _, ok := r.Header["Upgrade"]; ok {
-		// https://golang.org/pkg/net/http/#Hijacker
-		s.log.Error("server does not support Upgrade header")
-		return true
-	}
-	return false
-}
-
-// append RootCA to the https server TLS config
-func (s *Plugin) appendRootCa() error {
-	const op = errors.Op("append root CA")
-	rootCAs, err := x509.SystemCertPool()
-	if err != nil {
-		return nil
-	}
-	if rootCAs == nil {
-		rootCAs = x509.NewCertPool()
-	}
-
-	CA, err := ioutil.ReadFile(s.cfg.SSL.RootCA)
-	if err != nil {
-		return err
-	}
-
-	// should append our CA cert
-	ok := rootCAs.AppendCertsFromPEM(CA)
-	if !ok {
-		return errors.E(op, errors.Str("could not append Certs from PEM"))
-	}
-	// disable "G402 (CWE-295): TLS MinVersion too low. (Confidence: HIGH, Severity: HIGH)"
-	// #nosec G402
-	cfg := &tls.Config{
-		InsecureSkipVerify: false,
-		RootCAs:            rootCAs,
-	}
-	s.http.TLSConfig = cfg
-
-	return nil
-}
-
-// Init https server
-func (s *Plugin) initSSL() *http.Server {
-	var topCipherSuites []uint16
-	var defaultCipherSuitesTLS13 []uint16
-
-	hasGCMAsmAMD64 := cpu.X86.HasAES && cpu.X86.HasPCLMULQDQ
-	hasGCMAsmARM64 := cpu.ARM64.HasAES && cpu.ARM64.HasPMULL
-	// Keep in sync with crypto/aes/cipher_s390x.go.
-	hasGCMAsmS390X := cpu.S390X.HasAES && cpu.S390X.HasAESCBC && cpu.S390X.HasAESCTR && (cpu.S390X.HasGHASH || cpu.S390X.HasAESGCM)
-
-	hasGCMAsm := hasGCMAsmAMD64 || hasGCMAsmARM64 || hasGCMAsmS390X
-
-	if hasGCMAsm {
-		// If AES-GCM hardware is provided then prioritise AES-GCM
-		// cipher suites.
-		topCipherSuites = []uint16{
-			tls.TLS_ECDHE_RSA_WITH_AES_128_GCM_SHA256,
-			tls.TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384,
-			tls.TLS_ECDHE_ECDSA_WITH_AES_128_GCM_SHA256,
-			tls.TLS_ECDHE_ECDSA_WITH_AES_256_GCM_SHA384,
-			tls.TLS_ECDHE_RSA_WITH_CHACHA20_POLY1305,
-			tls.TLS_ECDHE_ECDSA_WITH_CHACHA20_POLY1305,
-		}
-		defaultCipherSuitesTLS13 = []uint16{
-			tls.TLS_AES_128_GCM_SHA256,
-			tls.TLS_CHACHA20_POLY1305_SHA256,
-			tls.TLS_AES_256_GCM_SHA384,
-		}
-	} else {
-		// Without AES-GCM hardware, we put the ChaCha20-Poly1305
-		// cipher suites first.
-		topCipherSuites = []uint16{
-			tls.TLS_ECDHE_RSA_WITH_CHACHA20_POLY1305,
-			tls.TLS_ECDHE_ECDSA_WITH_CHACHA20_POLY1305,
-			tls.TLS_ECDHE_RSA_WITH_AES_128_GCM_SHA256,
-			tls.TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384,
-			tls.TLS_ECDHE_ECDSA_WITH_AES_128_GCM_SHA256,
-			tls.TLS_ECDHE_ECDSA_WITH_AES_256_GCM_SHA384,
-		}
-		defaultCipherSuitesTLS13 = []uint16{
-			tls.TLS_CHACHA20_POLY1305_SHA256,
-			tls.TLS_AES_128_GCM_SHA256,
-			tls.TLS_AES_256_GCM_SHA384,
-		}
-	}
-
-	DefaultCipherSuites := make([]uint16, 0, 22)
-	DefaultCipherSuites = append(DefaultCipherSuites, topCipherSuites...)
-	DefaultCipherSuites = append(DefaultCipherSuites, defaultCipherSuitesTLS13...)
-
-	server := &http.Server{
-		Addr:    s.tlsAddr(s.cfg.Address, true),
-		Handler: s,
-		TLSConfig: &tls.Config{
-			CurvePreferences: []tls.CurveID{
-				tls.CurveP256,
-				tls.CurveP384,
-				tls.CurveP521,
-				tls.X25519,
-			},
-			CipherSuites:             DefaultCipherSuites,
-			MinVersion:               tls.VersionTLS12,
-			PreferServerCipherSuites: true,
-		},
-	}
-
-	return server
-}
-
-// init http/2 server
-func (s *Plugin) initHTTP2() error {
-	return http2.ConfigureServer(s.https, &http2.Server{
-		MaxConcurrentStreams: s.cfg.HTTP2.MaxConcurrentStreams,
-	})
-}
-
-// serveFCGI starts FastCGI server.
-func (s *Plugin) serveFCGI() error {
-	l, err := util.CreateListener(s.cfg.FCGI.Address)
-	if err != nil {
-		return err
-	}
-
-	err = fcgi.Serve(l, s.fcgi.Handler)
-	if err != nil {
-		return err
-	}
-
-	return nil
-}
-
-// tlsAddr replaces listen or host port with port configured by SSL config.
-func (s *Plugin) tlsAddr(host string, forcePort bool) string {
-	// remove current forcePort first
-	host = strings.Split(host, ":")[0]
-
-	if forcePort || s.cfg.SSL.Port != 443 {
-		host = fmt.Sprintf("%s:%v", host, s.cfg.SSL.Port)
-	}
-
-	return host
-}
-
-func (s *Plugin) addMiddlewares() {
-	if s.http != nil {
-		applyMiddlewares(s.http, s.mdwr, s.cfg.Middleware, s.log)
-	}
-	if s.https != nil {
-		applyMiddlewares(s.https, s.mdwr, s.cfg.Middleware, s.log)
-	}
-
-	if s.fcgi != nil {
-		applyMiddlewares(s.fcgi, s.mdwr, s.cfg.Middleware, s.log)
-	}
-}
-
-func applyMiddlewares(server *http.Server, middlewares map[string]Middleware, order []string, log log.Logger) {
-	for i := 0; i < len(order); i++ {
-		if mdwr, ok := middlewares[order[i]]; ok {
-			server.Handler = mdwr.Middleware(server.Handler)
-		} else {
-			log.Warn("requested middleware does not exist", "requested", order[i])
-		}
-	}
-}
diff --git a/plugins/http/request.go b/plugins/http/request.go
deleted file mode 100644
index d613bcf6..00000000
--- a/plugins/http/request.go
+++ /dev/null
@@ -1,186 +0,0 @@
-package http
-
-import (
-	"fmt"
-	"io/ioutil"
-	"net"
-	"net/http"
-	"net/url"
-	"strings"
-
-	j "github.com/json-iterator/go"
-	"github.com/spiral/roadrunner/v2/interfaces/log"
-	"github.com/spiral/roadrunner/v2/pkg/payload"
-	"github.com/spiral/roadrunner/v2/plugins/http/attributes"
-)
-
-var json = j.ConfigCompatibleWithStandardLibrary
-
-const (
-	defaultMaxMemory = 32 << 20 // 32 MB
-	contentNone      = iota + 900
-	contentStream
-	contentMultipart
-	contentFormData
-)
-
-// Request maps net/http requests to PSR7 compatible structure and managed state of temporary uploaded files.
-type Request struct {
-	// RemoteAddr contains ip address of client, make sure to check X-Real-Ip and X-Forwarded-For for real client address.
-	RemoteAddr string `json:"remoteAddr"`
-
-	// Protocol includes HTTP protocol version.
-	Protocol string `json:"protocol"`
-
-	// Method contains name of HTTP method used for the request.
-	Method string `json:"method"`
-
-	// URI contains full request URI with scheme and query.
-	URI string `json:"uri"`
-
-	// Header contains list of request headers.
-	Header http.Header `json:"headers"`
-
-	// Cookies contains list of request cookies.
-	Cookies map[string]string `json:"cookies"`
-
-	// RawQuery contains non parsed query string (to be parsed on php end).
-	RawQuery string `json:"rawQuery"`
-
-	// Parsed indicates that request body has been parsed on RR end.
-	Parsed bool `json:"parsed"`
-
-	// Uploads contains list of uploaded files, their names, sized and associations with temporary files.
-	Uploads *Uploads `json:"uploads"`
-
-	// Attributes can be set by chained mdwr to safely pass value from Golang to PHP. See: GetAttribute, SetAttribute functions.
-	Attributes map[string]interface{} `json:"attributes"`
-
-	// request body can be parsedData or []byte
-	body interface{}
-}
-
-func fetchIP(pair string) string {
-	if !strings.ContainsRune(pair, ':') {
-		return pair
-	}
-
-	addr, _, _ := net.SplitHostPort(pair)
-	return addr
-}
-
-// NewRequest creates new PSR7 compatible request using net/http request.
-func NewRequest(r *http.Request, cfg UploadsConfig) (*Request, error) {
-	req := &Request{
-		RemoteAddr: fetchIP(r.RemoteAddr),
-		Protocol:   r.Proto,
-		Method:     r.Method,
-		URI:        uri(r),
-		Header:     r.Header,
-		Cookies:    make(map[string]string),
-		RawQuery:   r.URL.RawQuery,
-		Attributes: attributes.All(r),
-	}
-
-	for _, c := range r.Cookies() {
-		if v, err := url.QueryUnescape(c.Value); err == nil {
-			req.Cookies[c.Name] = v
-		}
-	}
-
-	switch req.contentType() {
-	case contentNone:
-		return req, nil
-
-	case contentStream:
-		var err error
-		req.body, err = ioutil.ReadAll(r.Body)
-		return req, err
-
-	case contentMultipart:
-		if err := r.ParseMultipartForm(defaultMaxMemory); err != nil {
-			return nil, err
-		}
-
-		req.Uploads = parseUploads(r, cfg)
-		fallthrough
-	case contentFormData:
-		if err := r.ParseForm(); err != nil {
-			return nil, err
-		}
-
-		req.body = parseData(r)
-	}
-
-	req.Parsed = true
-	return req, nil
-}
-
-// Open moves all uploaded files to temporary directory so it can be given to php later.
-func (r *Request) Open(log log.Logger) {
-	if r.Uploads == nil {
-		return
-	}
-
-	r.Uploads.Open(log)
-}
-
-// Close clears all temp file uploads
-func (r *Request) Close(log log.Logger) {
-	if r.Uploads == nil {
-		return
-	}
-
-	r.Uploads.Clear(log)
-}
-
-// Payload request marshaled RoadRunner payload based on PSR7 data. values encode method is JSON. Make sure to open
-// files prior to calling this method.
-func (r *Request) Payload() (payload.Payload, error) {
-	p := payload.Payload{}
-
-	var err error
-	if p.Context, err = json.Marshal(r); err != nil {
-		return payload.Payload{}, err
-	}
-
-	if r.Parsed {
-		if p.Body, err = json.Marshal(r.body); err != nil {
-			return payload.Payload{}, err
-		}
-	} else if r.body != nil {
-		p.Body = r.body.([]byte)
-	}
-
-	return p, nil
-}
-
-// contentType returns the payload content type.
-func (r *Request) contentType() int {
-	if r.Method == "HEAD" || r.Method == "OPTIONS" {
-		return contentNone
-	}
-
-	ct := r.Header.Get("content-type")
-	if strings.Contains(ct, "application/x-www-form-urlencoded") {
-		return contentFormData
-	}
-
-	if strings.Contains(ct, "multipart/form-data") {
-		return contentMultipart
-	}
-
-	return contentStream
-}
-
-// uri fetches full uri from request in a form of string (including https scheme if TLS connection is enabled).
-func uri(r *http.Request) string {
-	if r.URL.Host != "" {
-		return r.URL.String()
-	}
-	if r.TLS != nil {
-		return fmt.Sprintf("https://%s%s", r.Host, r.URL.String())
-	}
-
-	return fmt.Sprintf("http://%s%s", r.Host, r.URL.String())
-}
diff --git a/plugins/http/response.go b/plugins/http/response.go
deleted file mode 100644
index 17049ce1..00000000
--- a/plugins/http/response.go
+++ /dev/null
@@ -1,105 +0,0 @@
-package http
-
-import (
-	"io"
-	"net/http"
-	"strings"
-	"sync"
-
-	"github.com/spiral/roadrunner/v2/pkg/payload"
-)
-
-// Response handles PSR7 response logic.
-type Response struct {
-	// Status contains response status.
-	Status int `json:"status"`
-
-	// Header contains list of response headers.
-	Headers map[string][]string `json:"headers"`
-
-	// associated Body payload.
-	Body interface{}
-	sync.Mutex
-}
-
-// NewResponse creates new response based on given pool payload.
-func NewResponse(p payload.Payload) (*Response, error) {
-	r := &Response{Body: p.Body}
-	if err := json.Unmarshal(p.Context, r); err != nil {
-		return nil, err
-	}
-
-	return r, nil
-}
-
-// Write writes response headers, status and body into ResponseWriter.
-func (r *Response) Write(w http.ResponseWriter) error {
-	// INFO map is the reference type in golang
-	p := handlePushHeaders(r.Headers)
-	if pusher, ok := w.(http.Pusher); ok {
-		for _, v := range p {
-			err := pusher.Push(v, nil)
-			if err != nil {
-				return err
-			}
-		}
-	}
-
-	handleTrailers(r.Headers)
-	for n, h := range r.Headers {
-		for _, v := range h {
-			w.Header().Add(n, v)
-		}
-	}
-
-	w.WriteHeader(r.Status)
-
-	if data, ok := r.Body.([]byte); ok {
-		_, err := w.Write(data)
-		if err != nil {
-			return handleWriteError(err)
-		}
-	}
-
-	if rc, ok := r.Body.(io.Reader); ok {
-		if _, err := io.Copy(w, rc); err != nil {
-			return err
-		}
-	}
-
-	return nil
-}
-
-func handlePushHeaders(h map[string][]string) []string {
-	var p []string
-	pushHeader, ok := h[http2pushHeaderKey]
-	if !ok {
-		return p
-	}
-
-	p = append(p, pushHeader...)
-
-	delete(h, http2pushHeaderKey)
-
-	return p
-}
-
-func handleTrailers(h map[string][]string) {
-	trailers, ok := h[TrailerHeaderKey]
-	if !ok {
-		return
-	}
-
-	for _, tr := range trailers {
-		for _, n := range strings.Split(tr, ",") {
-			n = strings.Trim(n, "\t ")
-			if v, ok := h[n]; ok {
-				h["Trailer:"+n] = v
-
-				delete(h, n)
-			}
-		}
-	}
-
-	delete(h, TrailerHeaderKey)
-}
diff --git a/plugins/http/tests/config_test.go b/plugins/http/tests/config_test.go
deleted file mode 100644
index 068bd66e..00000000
--- a/plugins/http/tests/config_test.go
+++ /dev/null
@@ -1,330 +0,0 @@
-package tests
-
-//import (
-//	"os"
-//	"testing"
-//	"time"
-//
-//	json "github.com/json-iterator/go"
-//	"github.com/stretchr/testify/assert"
-//)
-//
-//type mockCfg struct{ cfg string }
-//
-//func (cfg *mockCfg) Get(name string) service.Config  { return nil }
-//func (cfg *mockCfg) Unmarshal(out interface{}) error {
-//	j := json.ConfigCompatibleWithStandardLibrary
-//	return j.Unmarshal([]byte(cfg.cfg), out)
-//}
-//
-//func Test_Config_Hydrate_Error1(t *testing.T) {
-//	cfg := &mockCfg{`{"address": "localhost:8080"}`}
-//	c := &Config{}
-//
-//	assert.NoError(t, c.Hydrate(cfg))
-//}
-//
-//func Test_Config_Hydrate_Error2(t *testing.T) {
-//	cfg := &mockCfg{`{"dir": "/dir/"`}
-//	c := &Config{}
-//
-//	assert.Error(t, c.Hydrate(cfg))
-//}
-//
-//func Test_Config_Valid(t *testing.T) {
-//	cfg := &Config{
-//		Address:        ":8080",
-//		MaxRequestSize: 1024,
-//		HTTP2: &HTTP2Config{
-//			Enabled: true,
-//		},
-//		Uploads: &UploadsConfig{
-//			Dir:    os.TempDir(),
-//			Forbid: []string{".go"},
-//		},
-//		Workers: &roadrunner.ServerConfig{
-//			Command: "php tests/client.php echo pipes",
-//			Relay:   "pipes",
-//			Pool: &roadrunner.Config{
-//				NumWorkers:      1,
-//				AllocateTimeout: time.Second,
-//				DestroyTimeout:  time.Second,
-//			},
-//		},
-//	}
-//
-//	assert.NoError(t, cfg.Valid())
-//}
-//
-//func Test_Trusted_Subnets(t *testing.T) {
-//	cfg := &Config{
-//		Address:        ":8080",
-//		MaxRequestSize: 1024,
-//		Uploads: &UploadsConfig{
-//			Dir:    os.TempDir(),
-//			Forbid: []string{".go"},
-//		},
-//		HTTP2: &HTTP2Config{
-//			Enabled: true,
-//		},
-//		TrustedSubnets: []string{"200.1.0.0/16"},
-//		Workers: &roadrunner.ServerConfig{
-//			Command: "php tests/client.php echo pipes",
-//			Relay:   "pipes",
-//			Pool: &roadrunner.Config{
-//				NumWorkers:      1,
-//				AllocateTimeout: time.Second,
-//				DestroyTimeout:  time.Second,
-//			},
-//		},
-//	}
-//
-//	assert.NoError(t, cfg.parseCIDRs())
-//
-//	assert.True(t, cfg.IsTrusted("200.1.0.10"))
-//	assert.False(t, cfg.IsTrusted("127.0.0.0.1"))
-//}
-//
-//func Test_Trusted_Subnets_Err(t *testing.T) {
-//	cfg := &Config{
-//		Address:        ":8080",
-//		MaxRequestSize: 1024,
-//		Uploads: &UploadsConfig{
-//			Dir:    os.TempDir(),
-//			Forbid: []string{".go"},
-//		},
-//		HTTP2: &HTTP2Config{
-//			Enabled: true,
-//		},
-//		TrustedSubnets: []string{"200.1.0.0"},
-//		Workers: &roadrunner.ServerConfig{
-//			Command: "php tests/client.php echo pipes",
-//			Relay:   "pipes",
-//			Pool: &roadrunner.Config{
-//				NumWorkers:      1,
-//				AllocateTimeout: time.Second,
-//				DestroyTimeout:  time.Second,
-//			},
-//		},
-//	}
-//
-//	assert.Error(t, cfg.parseCIDRs())
-//}
-//
-//func Test_Config_Valid_SSL(t *testing.T) {
-//	cfg := &Config{
-//		Address: ":8080",
-//		SSL: SSLConfig{
-//			Cert: "fixtures/server.crt",
-//			Key:  "fixtures/server.key",
-//		},
-//		MaxRequestSize: 1024,
-//		Uploads: &UploadsConfig{
-//			Dir:    os.TempDir(),
-//			Forbid: []string{".go"},
-//		},
-//		HTTP2: &HTTP2Config{
-//			Enabled: true,
-//		},
-//		Workers: &roadrunner.ServerConfig{
-//			Command: "php tests/client.php echo pipes",
-//			Relay:   "pipes",
-//			Pool: &roadrunner.Config{
-//				NumWorkers:      1,
-//				AllocateTimeout: time.Second,
-//				DestroyTimeout:  time.Second,
-//			},
-//		},
-//	}
-//
-//	assert.Error(t, cfg.Hydrate(&testCfg{httpCfg: "{}"}))
-//
-//	assert.NoError(t, cfg.Valid())
-//	assert.True(t, cfg.EnableTLS())
-//	assert.Equal(t, 443, cfg.SSL.Port)
-//}
-//
-//func Test_Config_SSL_No_key(t *testing.T) {
-//	cfg := &Config{
-//		Address: ":8080",
-//		SSL: SSLConfig{
-//			Cert: "fixtures/server.crt",
-//		},
-//		MaxRequestSize: 1024,
-//		Uploads: &UploadsConfig{
-//			Dir:    os.TempDir(),
-//			Forbid: []string{".go"},
-//		},
-//		HTTP2: &HTTP2Config{
-//			Enabled: true,
-//		},
-//		Workers: &roadrunner.ServerConfig{
-//			Command: "php tests/client.php echo pipes",
-//			Relay:   "pipes",
-//			Pool: &roadrunner.Config{
-//				NumWorkers:      1,
-//				AllocateTimeout: time.Second,
-//				DestroyTimeout:  time.Second,
-//			},
-//		},
-//	}
-//
-//	assert.Error(t, cfg.Valid())
-//}
-//
-//func Test_Config_SSL_No_Cert(t *testing.T) {
-//	cfg := &Config{
-//		Address: ":8080",
-//		SSL: SSLConfig{
-//			Key: "fixtures/server.key",
-//		},
-//		MaxRequestSize: 1024,
-//		Uploads: &UploadsConfig{
-//			Dir:    os.TempDir(),
-//			Forbid: []string{".go"},
-//		},
-//		HTTP2: &HTTP2Config{
-//			Enabled: true,
-//		},
-//		Workers: &roadrunner.ServerConfig{
-//			Command: "php tests/client.php echo pipes",
-//			Relay:   "pipes",
-//			Pool: &roadrunner.Config{
-//				NumWorkers:      1,
-//				AllocateTimeout: time.Second,
-//				DestroyTimeout:  time.Second,
-//			},
-//		},
-//	}
-//
-//	assert.Error(t, cfg.Valid())
-//}
-//
-//func Test_Config_NoUploads(t *testing.T) {
-//	cfg := &Config{
-//		Address:        ":8080",
-//		MaxRequestSize: 1024,
-//		HTTP2: &HTTP2Config{
-//			Enabled: true,
-//		},
-//		Workers: &roadrunner.ServerConfig{
-//			Command: "php tests/client.php echo pipes",
-//			Relay:   "pipes",
-//			Pool: &roadrunner.Config{
-//				NumWorkers:      1,
-//				AllocateTimeout: time.Second,
-//				DestroyTimeout:  time.Second,
-//			},
-//		},
-//	}
-//
-//	assert.Error(t, cfg.Valid())
-//}
-//
-//func Test_Config_NoHTTP2(t *testing.T) {
-//	cfg := &Config{
-//		Address:        ":8080",
-//		MaxRequestSize: 1024,
-//		Uploads: &UploadsConfig{
-//			Dir:    os.TempDir(),
-//			Forbid: []string{".go"},
-//		},
-//		Workers: &roadrunner.ServerConfig{
-//			Command: "php tests/client.php echo pipes",
-//			Relay:   "pipes",
-//			Pool: &roadrunner.Config{
-//				NumWorkers:      0,
-//				AllocateTimeout: time.Second,
-//				DestroyTimeout:  time.Second,
-//			},
-//		},
-//	}
-//
-//	assert.Error(t, cfg.Valid())
-//}
-//
-//func Test_Config_NoWorkers(t *testing.T) {
-//	cfg := &Config{
-//		Address:        ":8080",
-//		MaxRequestSize: 1024,
-//		HTTP2: &HTTP2Config{
-//			Enabled: true,
-//		},
-//		Uploads: &UploadsConfig{
-//			Dir:    os.TempDir(),
-//			Forbid: []string{".go"},
-//		},
-//	}
-//
-//	assert.Error(t, cfg.Valid())
-//}
-//
-//func Test_Config_NoPool(t *testing.T) {
-//	cfg := &Config{
-//		Address:        ":8080",
-//		MaxRequestSize: 1024,
-//		Uploads: &UploadsConfig{
-//			Dir:    os.TempDir(),
-//			Forbid: []string{".go"},
-//		},
-//		HTTP2: &HTTP2Config{
-//			Enabled: true,
-//		},
-//		Workers: &roadrunner.ServerConfig{
-//			Command: "php tests/client.php echo pipes",
-//			Relay:   "pipes",
-//			Pool: &roadrunner.Config{
-//				NumWorkers:      0,
-//				AllocateTimeout: time.Second,
-//				DestroyTimeout:  time.Second,
-//			},
-//		},
-//	}
-//
-//	assert.Error(t, cfg.Valid())
-//}
-//
-//func Test_Config_DeadPool(t *testing.T) {
-//	cfg := &Config{
-//		Address:        ":8080",
-//		MaxRequestSize: 1024,
-//		Uploads: &UploadsConfig{
-//			Dir:    os.TempDir(),
-//			Forbid: []string{".go"},
-//		},
-//		HTTP2: &HTTP2Config{
-//			Enabled: true,
-//		},
-//		Workers: &roadrunner.ServerConfig{
-//			Command: "php tests/client.php echo pipes",
-//			Relay:   "pipes",
-//		},
-//	}
-//
-//	assert.Error(t, cfg.Valid())
-//}
-//
-//func Test_Config_InvalidAddress(t *testing.T) {
-//	cfg := &Config{
-//		Address:        "unexpected_address",
-//		MaxRequestSize: 1024,
-//		Uploads: &UploadsConfig{
-//			Dir:    os.TempDir(),
-//			Forbid: []string{".go"},
-//		},
-//		HTTP2: &HTTP2Config{
-//			Enabled: true,
-//		},
-//		Workers: &roadrunner.ServerConfig{
-//			Command: "php tests/client.php echo pipes",
-//			Relay:   "pipes",
-//			Pool: &roadrunner.Config{
-//				NumWorkers:      1,
-//				AllocateTimeout: time.Second,
-//				DestroyTimeout:  time.Second,
-//			},
-//		},
-//	}
-//
-//	assert.Error(t, cfg.Valid())
-//}
diff --git a/plugins/http/tests/configs/.rr-broken-pipes.yaml b/plugins/http/tests/configs/.rr-broken-pipes.yaml
deleted file mode 100644
index e57d0b86..00000000
--- a/plugins/http/tests/configs/.rr-broken-pipes.yaml
+++ /dev/null
@@ -1,31 +0,0 @@
-rpc:
-  listen: tcp://127.0.0.1:6001
-  disabled: false
-
-server:
-  command: "php ../../../tests/http/client.php broken pipes"
-  user: ""
-  group: ""
-  env:
-    "RR_HTTP": "true"
-  relay: "pipes"
-  relayTimeout: "20s"
-
-http:
-  debug: true
-  address: 127.0.0.1:12384
-  maxRequestSize: 1024
-  middleware: [ "" ]
-  uploads:
-    forbid: [ ".php", ".exe", ".bat" ]
-  trustedSubnets: [ "10.0.0.0/8", "127.0.0.0/8", "172.16.0.0/12", "192.168.0.0/16", "::1/128", "fc00::/7", "fe80::/10" ]
-  pool:
-    numWorkers: 2
-    maxJobs: 0
-    allocateTimeout: 60s
-    destroyTimeout: 60s
-logs:
-  mode: development
-  level: error
-
-
diff --git a/plugins/http/tests/configs/.rr-echoErr.yaml b/plugins/http/tests/configs/.rr-echoErr.yaml
deleted file mode 100644
index 24946c88..00000000
--- a/plugins/http/tests/configs/.rr-echoErr.yaml
+++ /dev/null
@@ -1,30 +0,0 @@
-rpc:
-  listen: tcp://127.0.0.1:6001
-  disabled: false
-
-server:
-  command: "php ../../../tests/http/client.php echoerr pipes"
-  user: ""
-  group: ""
-  env:
-    "RR_HTTP": "true"
-  relay: "pipes"
-  relayTimeout: "20s"
-
-http:
-  debug: true
-  address: 127.0.0.1:8080
-  maxRequestSize: 1024
-  middleware: [ "pluginMiddleware", "pluginMiddleware2" ]
-  uploads:
-    forbid: [ "" ]
-  trustedSubnets: [ "10.0.0.0/8", "127.0.0.0/8", "172.16.0.0/12", "192.168.0.0/16", "::1/128", "fc00::/7", "fe80::/10" ]
-  pool:
-    numWorkers: 2
-    maxJobs: 0
-    allocateTimeout: 60s
-    destroyTimeout: 60s
-logs:
-  mode: development
-  level: error
-
diff --git a/plugins/http/tests/configs/.rr-env.yaml b/plugins/http/tests/configs/.rr-env.yaml
deleted file mode 100644
index e29f66cc..00000000
--- a/plugins/http/tests/configs/.rr-env.yaml
+++ /dev/null
@@ -1,33 +0,0 @@
-rpc:
-  listen: tcp://127.0.0.1:6001
-  disabled: false
-
-server:
-  command: "php ../../../tests/http/client.php env pipes"
-  user: ""
-  group: ""
-  env:
-    "env_key": "ENV_VALUE"
-  relay: "pipes"
-  relayTimeout: "20s"
-
-http:
-  debug: true
-  address: 127.0.0.1:12084
-  maxRequestSize: 1024
-  middleware: [ "" ]
-  env:
-    "RR_HTTP": "true"
-    "env_key": "ENV_VALUE"
-  uploads:
-    forbid: [ ".php", ".exe", ".bat" ]
-  trustedSubnets: [ "10.0.0.0/8", "127.0.0.0/8", "172.16.0.0/12", "192.168.0.0/16", "::1/128", "fc00::/7", "fe80::/10" ]
-  pool:
-    numWorkers: 2
-    maxJobs: 0
-    allocateTimeout: 60s
-    destroyTimeout: 60s
-logs:
-  mode: development
-  level: error
-
diff --git a/plugins/http/tests/configs/.rr-fcgi-reqUri.yaml b/plugins/http/tests/configs/.rr-fcgi-reqUri.yaml
deleted file mode 100644
index 3009c30e..00000000
--- a/plugins/http/tests/configs/.rr-fcgi-reqUri.yaml
+++ /dev/null
@@ -1,38 +0,0 @@
-server:
-  command: "php ../../../tests/http/client.php request-uri pipes"
-  user: ""
-  group: ""
-  env:
-    "RR_HTTP": "true"
-  relay: "pipes"
-  relayTimeout: "20s"
-
-http:
-  debug: true
-  address: :8082
-  maxRequestSize: 1024
-  middleware: [ "" ]
-  uploads:
-    forbid: [ ".php", ".exe", ".bat" ]
-  trustedSubnets: [ "10.0.0.0/8", "127.0.0.0/8", "172.16.0.0/12", "192.168.0.0/16", "::1/128", "fc00::/7", "fe80::/10" ]
-  pool:
-    numWorkers: 1
-    maxJobs: 0
-    allocateTimeout: 60s
-    destroyTimeout: 60s
-
-  ssl:
-    port: 8890
-    redirect: false
-    cert: fixtures/server.crt
-    key: fixtures/server.key
-  #    rootCa: root.crt
-  fcgi:
-    address: tcp://127.0.0.1:6921
-  http2:
-    enabled: false
-    h2c: false
-    maxConcurrentStreams: 128
-logs:
-  mode: development
-  level: error
\ No newline at end of file
diff --git a/plugins/http/tests/configs/.rr-fcgi.yaml b/plugins/http/tests/configs/.rr-fcgi.yaml
deleted file mode 100644
index 45b6dbd0..00000000
--- a/plugins/http/tests/configs/.rr-fcgi.yaml
+++ /dev/null
@@ -1,38 +0,0 @@
-server:
-  command: "php ../../../tests/http/client.php echo pipes"
-  user: ""
-  group: ""
-  env:
-    "RR_HTTP": "true"
-  relay: "pipes"
-  relayTimeout: "20s"
-
-http:
-  debug: true
-  address: :8081
-  maxRequestSize: 1024
-  middleware: [ "" ]
-  uploads:
-    forbid: [ ".php", ".exe", ".bat" ]
-  trustedSubnets: [ "10.0.0.0/8", "127.0.0.0/8", "172.16.0.0/12", "192.168.0.0/16", "::1/128", "fc00::/7", "fe80::/10" ]
-  pool:
-    numWorkers: 1
-    maxJobs: 0
-    allocateTimeout: 60s
-    destroyTimeout: 60s
-
-  ssl:
-    port: 8889
-    redirect: false
-    cert: fixtures/server.crt
-    key: fixtures/server.key
-  #    rootCa: root.crt
-  fcgi:
-    address: tcp://0.0.0.0:6920
-  http2:
-    enabled: false
-    h2c: false
-    maxConcurrentStreams: 128
-logs:
-  mode: development
-  level: error
\ No newline at end of file
diff --git a/plugins/http/tests/configs/.rr-h2c.yaml b/plugins/http/tests/configs/.rr-h2c.yaml
deleted file mode 100644
index cc42e3bf..00000000
--- a/plugins/http/tests/configs/.rr-h2c.yaml
+++ /dev/null
@@ -1,29 +0,0 @@
-server:
-  command: "php ../../../tests/http/client.php echo pipes"
-  user: ""
-  group: ""
-  env:
-    "RR_HTTP": "true"
-  relay: "pipes"
-  relayTimeout: "20s"
-
-http:
-  debug: true
-  address: :8083
-  maxRequestSize: 1024
-  middleware: [ "" ]
-  uploads:
-    forbid: [ ".php", ".exe", ".bat" ]
-  trustedSubnets: [ "10.0.0.0/8", "127.0.0.0/8", "172.16.0.0/12", "192.168.0.0/16", "::1/128", "fc00::/7", "fe80::/10" ]
-  pool:
-    numWorkers: 1
-    maxJobs: 0
-    allocateTimeout: 60s
-    destroyTimeout: 60s
-  http2:
-    enabled: true
-    h2c: true
-    maxConcurrentStreams: 128
-logs:
-  mode: development
-  level: error
\ No newline at end of file
diff --git a/plugins/http/tests/configs/.rr-http.yaml b/plugins/http/tests/configs/.rr-http.yaml
deleted file mode 100644
index e2e361cf..00000000
--- a/plugins/http/tests/configs/.rr-http.yaml
+++ /dev/null
@@ -1,31 +0,0 @@
-rpc:
-  listen: tcp://127.0.0.1:6001
-  disabled: false
-
-server:
-  command: "php ../../../tests/http/client.php echo pipes"
-  user: ""
-  group: ""
-  env:
-    "RR_HTTP": "true"
-  relay: "pipes"
-  relayTimeout: "20s"
-
-http:
-  debug: true
-  address: 127.0.0.1:18903
-  maxRequestSize: 1024
-  middleware: [ "pluginMiddleware", "pluginMiddleware2" ]
-  uploads:
-    forbid: [ ".php", ".exe", ".bat" ]
-  trustedSubnets: [ "10.0.0.0/8", "127.0.0.0/8", "172.16.0.0/12", "192.168.0.0/16", "::1/128", "fc00::/7", "fe80::/10" ]
-  pool:
-    numWorkers: 2
-    maxJobs: 0
-    allocateTimeout: 60s
-    destroyTimeout: 60s
-logs:
-  mode: development
-  level: error
-
-
diff --git a/plugins/http/tests/configs/.rr-init.yaml b/plugins/http/tests/configs/.rr-init.yaml
deleted file mode 100644
index 70b9642b..00000000
--- a/plugins/http/tests/configs/.rr-init.yaml
+++ /dev/null
@@ -1,43 +0,0 @@
-rpc:
-  listen: tcp://127.0.0.1:6001
-  disabled: false
-
-server:
-  command: "php ../../../tests/http/client.php echo pipes"
-  user: ""
-  group: ""
-  env:
-    "RR_HTTP": "true"
-  relay: "pipes"
-  relayTimeout: "20s"
-
-http:
-  debug: true
-  address: 127.0.0.1:15395
-  maxRequestSize: 1024
-  middleware: [ "" ]
-  uploads:
-    forbid: [ ".php", ".exe", ".bat" ]
-  trustedSubnets: [ "10.0.0.0/8", "127.0.0.0/8", "172.16.0.0/12", "192.168.0.0/16", "::1/128", "fc00::/7", "fe80::/10" ]
-  pool:
-    numWorkers: 2
-    maxJobs: 0
-    allocateTimeout: 60s
-    destroyTimeout: 60s
-
-  ssl:
-    port: 8892
-    redirect: false
-    cert: fixtures/server.crt
-    key: fixtures/server.key
-  #    rootCa: root.crt
-  fcgi:
-    address: tcp://0.0.0.0:7921
-  http2:
-    enabled: false
-    h2c: false
-    maxConcurrentStreams: 128
-logs:
-  mode: development
-  level: error
-
diff --git a/plugins/http/tests/configs/.rr-resetter.yaml b/plugins/http/tests/configs/.rr-resetter.yaml
deleted file mode 100644
index f2134812..00000000
--- a/plugins/http/tests/configs/.rr-resetter.yaml
+++ /dev/null
@@ -1,30 +0,0 @@
-rpc:
-  listen: tcp://127.0.0.1:6001
-  disabled: false
-
-server:
-  command: "php ../../../tests/http/client.php echo pipes"
-  user: ""
-  group: ""
-  env:
-    "RR_HTTP": "true"
-  relay: "pipes"
-  relayTimeout: "20s"
-
-http:
-  debug: true
-  address: 127.0.0.1:10084
-  maxRequestSize: 1024
-  middleware: [ "" ]
-  uploads:
-    forbid: [ ".php", ".exe", ".bat" ]
-  trustedSubnets: [ "10.0.0.0/8", "127.0.0.0/8", "172.16.0.0/12", "192.168.0.0/16", "::1/128", "fc00::/7", "fe80::/10" ]
-  pool:
-    numWorkers: 2
-    maxJobs: 0
-    allocateTimeout: 60s
-    destroyTimeout: 60s
-logs:
-  mode: development
-  level: error
-
diff --git a/plugins/http/tests/configs/.rr-ssl-push.yaml b/plugins/http/tests/configs/.rr-ssl-push.yaml
deleted file mode 100644
index 3aea683c..00000000
--- a/plugins/http/tests/configs/.rr-ssl-push.yaml
+++ /dev/null
@@ -1,31 +0,0 @@
-server:
-  command: "php ../../../tests/http/client.php push pipes"
-  user: ""
-  group: ""
-  env:
-    "RR_HTTP": "true"
-  relay: "pipes"
-  relayTimeout: "20s"
-
-http:
-  debug: true
-  address: :8086
-  maxRequestSize: 1024
-  middleware: [ "" ]
-  uploads:
-    forbid: [ ".php", ".exe", ".bat" ]
-  trustedSubnets: [ "10.0.0.0/8", "127.0.0.0/8", "172.16.0.0/12", "192.168.0.0/16", "::1/128", "fc00::/7", "fe80::/10" ]
-  pool:
-    numWorkers: 1
-    maxJobs: 0
-    allocateTimeout: 60s
-    destroyTimeout: 60s
-
-  ssl:
-    port: 8894
-    redirect: true
-    cert: fixtures/server.crt
-    key: fixtures/server.key
-logs:
-  mode: development
-  level: error
\ No newline at end of file
diff --git a/plugins/http/tests/configs/.rr-ssl-redirect.yaml b/plugins/http/tests/configs/.rr-ssl-redirect.yaml
deleted file mode 100644
index 4d889734..00000000
--- a/plugins/http/tests/configs/.rr-ssl-redirect.yaml
+++ /dev/null
@@ -1,31 +0,0 @@
-server:
-  command: "php ../../../tests/http/client.php echo pipes"
-  user: ""
-  group: ""
-  env:
-    "RR_HTTP": "true"
-  relay: "pipes"
-  relayTimeout: "20s"
-
-http:
-  debug: true
-  address: :8087
-  maxRequestSize: 1024
-  middleware: [ "" ]
-  uploads:
-    forbid: [ ".php", ".exe", ".bat" ]
-  trustedSubnets: [ "10.0.0.0/8", "127.0.0.0/8", "172.16.0.0/12", "192.168.0.0/16", "::1/128", "fc00::/7", "fe80::/10" ]
-  pool:
-    numWorkers: 1
-    maxJobs: 0
-    allocateTimeout: 60s
-    destroyTimeout: 60s
-
-  ssl:
-    port: 8895
-    redirect: true
-    cert: fixtures/server.crt
-    key: fixtures/server.key
-logs:
-  mode: development
-  level: error
\ No newline at end of file
diff --git a/plugins/http/tests/configs/.rr-ssl.yaml b/plugins/http/tests/configs/.rr-ssl.yaml
deleted file mode 100644
index 83b5a2dc..00000000
--- a/plugins/http/tests/configs/.rr-ssl.yaml
+++ /dev/null
@@ -1,38 +0,0 @@
-server:
-  command: "php ../../../tests/http/client.php echo pipes"
-  user: ""
-  group: ""
-  env:
-    "RR_HTTP": "true"
-  relay: "pipes"
-  relayTimeout: "20s"
-
-http:
-  debug: true
-  address: :8085
-  maxRequestSize: 1024
-  middleware: [ "" ]
-  uploads:
-    forbid: [ ".php", ".exe", ".bat" ]
-  trustedSubnets: [ "10.0.0.0/8", "127.0.0.0/8", "172.16.0.0/12", "192.168.0.0/16", "::1/128", "fc00::/7", "fe80::/10" ]
-  pool:
-    numWorkers: 1
-    maxJobs: 0
-    allocateTimeout: 60s
-    destroyTimeout: 60s
-
-  ssl:
-    port: 8893
-    redirect: false
-    cert: fixtures/server.crt
-    key: fixtures/server.key
-  #    rootCa: root.crt
-  fcgi:
-    address: tcp://0.0.0.0:16920
-  http2:
-    enabled: false
-    h2c: false
-    maxConcurrentStreams: 128
-logs:
-  mode: development
-  level: error
\ No newline at end of file
diff --git a/plugins/http/tests/fixtures/server.crt b/plugins/http/tests/fixtures/server.crt
deleted file mode 100644
index 24d67fd7..00000000
--- a/plugins/http/tests/fixtures/server.crt
+++ /dev/null
@@ -1,15 +0,0 @@
------BEGIN CERTIFICATE-----
-MIICTTCCAdOgAwIBAgIJAOKyUd+llTRKMAoGCCqGSM49BAMCMGMxCzAJBgNVBAYT
-AlVTMRMwEQYDVQQIDApDYWxpZm9ybmlhMRYwFAYDVQQHDA1TYW4gRnJhbmNpc2Nv
-MRMwEQYDVQQKDApSb2FkUnVubmVyMRIwEAYDVQQDDAlsb2NhbGhvc3QwHhcNMTgw
-OTMwMTMzNDUzWhcNMjgwOTI3MTMzNDUzWjBjMQswCQYDVQQGEwJVUzETMBEGA1UE
-CAwKQ2FsaWZvcm5pYTEWMBQGA1UEBwwNU2FuIEZyYW5jaXNjbzETMBEGA1UECgwK
-Um9hZFJ1bm5lcjESMBAGA1UEAwwJbG9jYWxob3N0MHYwEAYHKoZIzj0CAQYFK4EE
-ACIDYgAEVnbShsM+l5RR3wfWWmGhzuFGwNzKCk7i9xyobDIyBUxG/UUSfj7KKlUX
-puDnDEtF5xXcepl744CyIAYFLOXHb5WqI4jCOzG0o9f/00QQ4bQudJOdbqV910QF
-C2vb7Fxro1MwUTAdBgNVHQ4EFgQU9xUexnbB6ORKayA7Pfjzs33otsAwHwYDVR0j
-BBgwFoAU9xUexnbB6ORKayA7Pfjzs33otsAwDwYDVR0TAQH/BAUwAwEB/zAKBggq
-hkjOPQQDAgNoADBlAjEAue3HhR/MUhxoa9tSDBtOJT3FYbDQswrsdqBTz97CGKst
-e7XeZ3HMEvEXy0hGGEMhAjAqcD/4k9vViVppgWFtkk6+NFbm+Kw/QeeAiH5FgFSj
-8xQcb+b7nPwNLp3JOkXkVd4=
------END CERTIFICATE-----
diff --git a/plugins/http/tests/fixtures/server.key b/plugins/http/tests/fixtures/server.key
deleted file mode 100644
index 7501dd46..00000000
--- a/plugins/http/tests/fixtures/server.key
+++ /dev/null
@@ -1,9 +0,0 @@
------BEGIN EC PARAMETERS-----
-BgUrgQQAIg==
------END EC PARAMETERS-----
------BEGIN EC PRIVATE KEY-----
-MIGkAgEBBDCQP8utxNbHR6xZOLAJgUhn88r6IrPqmN0MsgGJM/jePB+T9UhkmIU8
-PMm2HeScbcugBwYFK4EEACKhZANiAARWdtKGwz6XlFHfB9ZaYaHO4UbA3MoKTuL3
-HKhsMjIFTEb9RRJ+PsoqVRem4OcMS0XnFdx6mXvjgLIgBgUs5cdvlaojiMI7MbSj
-1//TRBDhtC50k51upX3XRAULa9vsXGs=
------END EC PRIVATE KEY-----
diff --git a/plugins/http/tests/handler_test.go b/plugins/http/tests/handler_test.go
deleted file mode 100644
index 54a4ae80..00000000
--- a/plugins/http/tests/handler_test.go
+++ /dev/null
@@ -1,1860 +0,0 @@
-package tests
-
-import (
-	"bytes"
-	"context"
-	"io/ioutil"
-	"mime/multipart"
-	"net/url"
-	"os/exec"
-	"runtime"
-	"strings"
-
-	"github.com/spiral/roadrunner/v2/pkg/pipe"
-	poolImpl "github.com/spiral/roadrunner/v2/pkg/pool"
-	httpPlugin "github.com/spiral/roadrunner/v2/plugins/http"
-	"github.com/stretchr/testify/assert"
-
-	"net/http"
-	"os"
-	"testing"
-	"time"
-)
-
-func TestHandler_Echo(t *testing.T) {
-	pool, err := poolImpl.NewPool(context.Background(),
-		func() *exec.Cmd { return exec.Command("php", "../../../tests/http/client.php", "echo", "pipes") },
-		pipe.NewPipeFactory(),
-		poolImpl.Config{
-			NumWorkers:      1,
-			AllocateTimeout: time.Second * 1000,
-			DestroyTimeout:  time.Second * 1000,
-		})
-	if err != nil {
-		t.Fatal(err)
-	}
-
-	h, err := httpPlugin.NewHandler(1024, httpPlugin.UploadsConfig{
-		Dir:    os.TempDir(),
-		Forbid: []string{},
-	}, nil, pool)
-	assert.NoError(t, err)
-
-	hs := &http.Server{Addr: ":8177", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-	go func(server *http.Server) {
-		err := server.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}(hs)
-	time.Sleep(time.Millisecond * 10)
-
-	body, r, err := get("http://localhost:8177/?hello=world")
-	assert.NoError(t, err)
-	defer func() {
-		_ = r.Body.Close()
-	}()
-	assert.Equal(t, 201, r.StatusCode)
-	assert.Equal(t, "WORLD", body)
-}
-
-func Test_HandlerErrors(t *testing.T) {
-	_, err := httpPlugin.NewHandler(1024, httpPlugin.UploadsConfig{
-		Dir:    os.TempDir(),
-		Forbid: []string{},
-	}, nil, nil)
-	assert.Error(t, err)
-}
-
-func TestHandler_Headers(t *testing.T) {
-	pool, err := poolImpl.NewPool(context.Background(),
-		func() *exec.Cmd { return exec.Command("php", "../../../tests/http/client.php", "header", "pipes") },
-		pipe.NewPipeFactory(),
-		poolImpl.Config{
-			NumWorkers:      1,
-			AllocateTimeout: time.Second * 1000,
-			DestroyTimeout:  time.Second * 1000,
-		})
-	if err != nil {
-		t.Fatal(err)
-	}
-	defer func() {
-		pool.Destroy(context.Background())
-	}()
-
-	h, err := httpPlugin.NewHandler(1024, httpPlugin.UploadsConfig{
-		Dir:    os.TempDir(),
-		Forbid: []string{},
-	}, nil, pool)
-	assert.NoError(t, err)
-
-	hs := &http.Server{Addr: ":8078", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err := hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 100)
-
-	req, err := http.NewRequest("GET", "http://localhost:8078?hello=world", nil)
-	assert.NoError(t, err)
-
-	req.Header.Add("input", "sample")
-
-	r, err := http.DefaultClient.Do(req)
-	assert.NoError(t, err)
-	defer func() {
-		err := r.Body.Close()
-		if err != nil {
-			t.Errorf("error during the closing Body: error %v", err)
-		}
-	}()
-
-	b, err := ioutil.ReadAll(r.Body)
-	assert.NoError(t, err)
-
-	assert.NoError(t, err)
-	assert.Equal(t, 200, r.StatusCode)
-	assert.Equal(t, "world", r.Header.Get("Header"))
-	assert.Equal(t, "SAMPLE", string(b))
-}
-
-func TestHandler_Empty_User_Agent(t *testing.T) {
-	pool, err := poolImpl.NewPool(context.Background(),
-		func() *exec.Cmd { return exec.Command("php", "../../../tests/http/client.php", "user-agent", "pipes") },
-		pipe.NewPipeFactory(),
-		poolImpl.Config{
-			NumWorkers:      1,
-			AllocateTimeout: time.Second * 1000,
-			DestroyTimeout:  time.Second * 1000,
-		})
-	if err != nil {
-		t.Fatal(err)
-	}
-	defer func() {
-		pool.Destroy(context.Background())
-	}()
-
-	h, err := httpPlugin.NewHandler(1024, httpPlugin.UploadsConfig{
-		Dir:    os.TempDir(),
-		Forbid: []string{},
-	}, nil, pool)
-	assert.NoError(t, err)
-
-	hs := &http.Server{Addr: ":8088", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err := hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 10)
-
-	req, err := http.NewRequest("GET", "http://localhost:8088?hello=world", nil)
-	assert.NoError(t, err)
-
-	req.Header.Add("user-agent", "")
-
-	r, err := http.DefaultClient.Do(req)
-	assert.NoError(t, err)
-	defer func() {
-		err := r.Body.Close()
-		if err != nil {
-			t.Errorf("error during the closing Body: error %v", err)
-		}
-	}()
-
-	b, err := ioutil.ReadAll(r.Body)
-	assert.NoError(t, err)
-
-	assert.NoError(t, err)
-	assert.Equal(t, 200, r.StatusCode)
-	assert.Equal(t, "", string(b))
-}
-
-func TestHandler_User_Agent(t *testing.T) {
-	pool, err := poolImpl.NewPool(context.Background(),
-		func() *exec.Cmd { return exec.Command("php", "../../../tests/http/client.php", "user-agent", "pipes") },
-		pipe.NewPipeFactory(),
-		poolImpl.Config{
-			NumWorkers:      1,
-			AllocateTimeout: time.Second * 1000,
-			DestroyTimeout:  time.Second * 1000,
-		})
-	if err != nil {
-		t.Fatal(err)
-	}
-	defer func() {
-		pool.Destroy(context.Background())
-	}()
-
-	h, err := httpPlugin.NewHandler(1024, httpPlugin.UploadsConfig{
-		Dir:    os.TempDir(),
-		Forbid: []string{},
-	}, nil, pool)
-	assert.NoError(t, err)
-
-	hs := &http.Server{Addr: ":8088", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err := hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 10)
-
-	req, err := http.NewRequest("GET", "http://localhost:8088?hello=world", nil)
-	assert.NoError(t, err)
-
-	req.Header.Add("User-Agent", "go-agent")
-
-	r, err := http.DefaultClient.Do(req)
-	assert.NoError(t, err)
-	defer func() {
-		err := r.Body.Close()
-		if err != nil {
-			t.Errorf("error during the closing Body: error %v", err)
-		}
-	}()
-
-	b, err := ioutil.ReadAll(r.Body)
-	assert.NoError(t, err)
-
-	assert.NoError(t, err)
-	assert.Equal(t, 200, r.StatusCode)
-	assert.Equal(t, "go-agent", string(b))
-}
-
-func TestHandler_Cookies(t *testing.T) {
-	pool, err := poolImpl.NewPool(context.Background(),
-		func() *exec.Cmd { return exec.Command("php", "../../../tests/http/client.php", "cookie", "pipes") },
-		pipe.NewPipeFactory(),
-		poolImpl.Config{
-			NumWorkers:      1,
-			AllocateTimeout: time.Second * 1000,
-			DestroyTimeout:  time.Second * 1000,
-		})
-	if err != nil {
-		t.Fatal(err)
-	}
-	defer func() {
-		pool.Destroy(context.Background())
-	}()
-
-	h, err := httpPlugin.NewHandler(1024, httpPlugin.UploadsConfig{
-		Dir:    os.TempDir(),
-		Forbid: []string{},
-	}, nil, pool)
-	assert.NoError(t, err)
-
-	hs := &http.Server{Addr: ":8079", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err := hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 10)
-
-	req, err := http.NewRequest("GET", "http://localhost:8079", nil)
-	assert.NoError(t, err)
-
-	req.AddCookie(&http.Cookie{Name: "input", Value: "input-value"})
-
-	r, err := http.DefaultClient.Do(req)
-	assert.NoError(t, err)
-	defer func() {
-		err := r.Body.Close()
-		if err != nil {
-			t.Errorf("error during the closing Body: error %v", err)
-		}
-	}()
-
-	b, err := ioutil.ReadAll(r.Body)
-	assert.NoError(t, err)
-
-	assert.NoError(t, err)
-	assert.Equal(t, 200, r.StatusCode)
-	assert.Equal(t, "INPUT-VALUE", string(b))
-
-	for _, c := range r.Cookies() {
-		assert.Equal(t, "output", c.Name)
-		assert.Equal(t, "cookie-output", c.Value)
-	}
-}
-
-func TestHandler_JsonPayload_POST(t *testing.T) {
-	pool, err := poolImpl.NewPool(context.Background(),
-		func() *exec.Cmd { return exec.Command("php", "../../../tests/http/client.php", "payload", "pipes") },
-		pipe.NewPipeFactory(),
-		poolImpl.Config{
-			NumWorkers:      1,
-			AllocateTimeout: time.Second * 1000,
-			DestroyTimeout:  time.Second * 1000,
-		})
-	if err != nil {
-		t.Fatal(err)
-	}
-	defer func() {
-		pool.Destroy(context.Background())
-	}()
-
-	h, err := httpPlugin.NewHandler(1024, httpPlugin.UploadsConfig{
-		Dir:    os.TempDir(),
-		Forbid: []string{},
-	}, nil, pool)
-	assert.NoError(t, err)
-
-	hs := &http.Server{Addr: ":8090", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err := hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 10)
-
-	req, err := http.NewRequest(
-		"POST",
-		"http://localhost"+hs.Addr,
-		bytes.NewBufferString(`{"key":"value"}`),
-	)
-	assert.NoError(t, err)
-
-	req.Header.Add("Content-Type", "application/json")
-
-	r, err := http.DefaultClient.Do(req)
-	assert.NoError(t, err)
-	defer func() {
-		err := r.Body.Close()
-		if err != nil {
-			t.Errorf("error during the closing Body: error %v", err)
-		}
-	}()
-
-	b, err := ioutil.ReadAll(r.Body)
-	assert.NoError(t, err)
-
-	assert.NoError(t, err)
-	assert.Equal(t, 200, r.StatusCode)
-	assert.Equal(t, `{"value":"key"}`, string(b))
-}
-
-func TestHandler_JsonPayload_PUT(t *testing.T) {
-	pool, err := poolImpl.NewPool(context.Background(),
-		func() *exec.Cmd { return exec.Command("php", "../../../tests/http/client.php", "payload", "pipes") },
-		pipe.NewPipeFactory(),
-		poolImpl.Config{
-			NumWorkers:      1,
-			AllocateTimeout: time.Second * 1000,
-			DestroyTimeout:  time.Second * 1000,
-		})
-	if err != nil {
-		t.Fatal(err)
-	}
-	defer func() {
-		pool.Destroy(context.Background())
-	}()
-
-	h, err := httpPlugin.NewHandler(1024, httpPlugin.UploadsConfig{
-		Dir:    os.TempDir(),
-		Forbid: []string{},
-	}, nil, pool)
-	assert.NoError(t, err)
-
-	hs := &http.Server{Addr: ":8081", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err := hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 10)
-
-	req, err := http.NewRequest("PUT", "http://localhost"+hs.Addr, bytes.NewBufferString(`{"key":"value"}`))
-	assert.NoError(t, err)
-
-	req.Header.Add("Content-Type", "application/json")
-
-	r, err := http.DefaultClient.Do(req)
-	assert.NoError(t, err)
-	defer func() {
-		err := r.Body.Close()
-		if err != nil {
-			t.Errorf("error during the closing Body: error %v", err)
-		}
-	}()
-
-	b, err := ioutil.ReadAll(r.Body)
-	assert.NoError(t, err)
-
-	assert.NoError(t, err)
-	assert.Equal(t, 200, r.StatusCode)
-	assert.Equal(t, `{"value":"key"}`, string(b))
-}
-
-func TestHandler_JsonPayload_PATCH(t *testing.T) {
-	pool, err := poolImpl.NewPool(context.Background(),
-		func() *exec.Cmd { return exec.Command("php", "../../../tests/http/client.php", "payload", "pipes") },
-		pipe.NewPipeFactory(),
-		poolImpl.Config{
-			NumWorkers:      1,
-			AllocateTimeout: time.Second * 1000,
-			DestroyTimeout:  time.Second * 1000,
-		})
-	if err != nil {
-		t.Fatal(err)
-	}
-	defer func() {
-		pool.Destroy(context.Background())
-	}()
-
-	h, err := httpPlugin.NewHandler(1024, httpPlugin.UploadsConfig{
-		Dir:    os.TempDir(),
-		Forbid: []string{},
-	}, nil, pool)
-	assert.NoError(t, err)
-
-	hs := &http.Server{Addr: ":8082", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err := hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 10)
-
-	req, err := http.NewRequest("PATCH", "http://localhost"+hs.Addr, bytes.NewBufferString(`{"key":"value"}`))
-	assert.NoError(t, err)
-
-	req.Header.Add("Content-Type", "application/json")
-
-	r, err := http.DefaultClient.Do(req)
-	assert.NoError(t, err)
-	defer func() {
-		err := r.Body.Close()
-		if err != nil {
-			t.Errorf("error during the closing Body: error %v", err)
-		}
-	}()
-
-	b, err := ioutil.ReadAll(r.Body)
-	assert.NoError(t, err)
-
-	assert.NoError(t, err)
-	assert.Equal(t, 200, r.StatusCode)
-	assert.Equal(t, `{"value":"key"}`, string(b))
-}
-
-func TestHandler_FormData_POST(t *testing.T) {
-	pool, err := poolImpl.NewPool(context.Background(),
-		func() *exec.Cmd { return exec.Command("php", "../../../tests/http/client.php", "data", "pipes") },
-		pipe.NewPipeFactory(),
-		poolImpl.Config{
-			NumWorkers:      1,
-			AllocateTimeout: time.Second * 1000,
-			DestroyTimeout:  time.Second * 1000,
-		})
-	if err != nil {
-		t.Fatal(err)
-	}
-	defer func() {
-		pool.Destroy(context.Background())
-	}()
-
-	h, err := httpPlugin.NewHandler(1024, httpPlugin.UploadsConfig{
-		Dir:    os.TempDir(),
-		Forbid: []string{},
-	}, nil, pool)
-	assert.NoError(t, err)
-
-	hs := &http.Server{Addr: ":8083", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err := hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 500)
-
-	form := url.Values{}
-
-	form.Add("key", "value")
-	form.Add("name[]", "name1")
-	form.Add("name[]", "name2")
-	form.Add("name[]", "name3")
-	form.Add("arr[x][y][z]", "y")
-	form.Add("arr[x][y][e]", "f")
-	form.Add("arr[c]p", "l")
-	form.Add("arr[c]z", "")
-
-	req, err := http.NewRequest("POST", "http://localhost"+hs.Addr, strings.NewReader(form.Encode()))
-	assert.NoError(t, err)
-
-	req.Header.Add("Content-Type", "application/x-www-form-urlencoded")
-
-	r, err := http.DefaultClient.Do(req)
-	assert.NoError(t, err)
-	defer func() {
-		err := r.Body.Close()
-		if err != nil {
-			t.Errorf("error during the closing Body: error %v", err)
-		}
-	}()
-
-	b, err := ioutil.ReadAll(r.Body)
-	assert.NoError(t, err)
-
-	assert.NoError(t, err)
-	assert.Equal(t, 200, r.StatusCode)
-
-	// Sorted
-	assert.Equal(t, "{\"arr\":{\"c\":{\"p\":\"l\",\"z\":\"\"},\"x\":{\"y\":{\"e\":\"f\",\"z\":\"y\"}}},\"key\":\"value\",\"name\":[\"name1\",\"name2\",\"name3\"]}", string(b))
-}
-
-func TestHandler_FormData_POST_Overwrite(t *testing.T) {
-	pool, err := poolImpl.NewPool(context.Background(),
-		func() *exec.Cmd { return exec.Command("php", "../../../tests/http/client.php", "data", "pipes") },
-		pipe.NewPipeFactory(),
-		poolImpl.Config{
-			NumWorkers:      1,
-			AllocateTimeout: time.Second * 1000,
-			DestroyTimeout:  time.Second * 1000,
-		})
-	if err != nil {
-		t.Fatal(err)
-	}
-	defer func() {
-		pool.Destroy(context.Background())
-	}()
-
-	h, err := httpPlugin.NewHandler(1024, httpPlugin.UploadsConfig{
-		Dir:    os.TempDir(),
-		Forbid: []string{},
-	}, nil, pool)
-	assert.NoError(t, err)
-
-	hs := &http.Server{Addr: ":8083", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err := hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 10)
-
-	form := url.Values{}
-
-	form.Add("key", "value")
-	form.Add("key", "value2")
-	form.Add("name[]", "name1")
-	form.Add("name[]", "name2")
-	form.Add("name[]", "name3")
-	form.Add("arr[x][y][z]", "y")
-	form.Add("arr[x][y][e]", "f")
-	form.Add("arr[c]p", "l")
-	form.Add("arr[c]z", "")
-
-	req, err := http.NewRequest("POST", "http://localhost"+hs.Addr, strings.NewReader(form.Encode()))
-	assert.NoError(t, err)
-
-	req.Header.Add("Content-Type", "application/x-www-form-urlencoded")
-
-	r, err := http.DefaultClient.Do(req)
-	assert.NoError(t, err)
-	defer func() {
-		err := r.Body.Close()
-		if err != nil {
-			t.Errorf("error during the closing Body: error %v", err)
-		}
-	}()
-
-	b, err := ioutil.ReadAll(r.Body)
-	assert.NoError(t, err)
-
-	assert.NoError(t, err)
-	assert.Equal(t, 200, r.StatusCode)
-
-	assert.Equal(t, `{"arr":{"c":{"p":"l","z":""},"x":{"y":{"e":"f","z":"y"}}},"key":"value2","name":["name1","name2","name3"]}`, string(b))
-}
-
-func TestHandler_FormData_POST_Form_UrlEncoded_Charset(t *testing.T) {
-	pool, err := poolImpl.NewPool(context.Background(),
-		func() *exec.Cmd { return exec.Command("php", "../../../tests/http/client.php", "data", "pipes") },
-		pipe.NewPipeFactory(),
-		poolImpl.Config{
-			NumWorkers:      1,
-			AllocateTimeout: time.Second * 1000,
-			DestroyTimeout:  time.Second * 1000,
-		})
-	if err != nil {
-		t.Fatal(err)
-	}
-	defer func() {
-		pool.Destroy(context.Background())
-	}()
-
-	h, err := httpPlugin.NewHandler(1024, httpPlugin.UploadsConfig{
-		Dir:    os.TempDir(),
-		Forbid: []string{},
-	}, nil, pool)
-	assert.NoError(t, err)
-
-	hs := &http.Server{Addr: ":8083", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err := hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 10)
-
-	form := url.Values{}
-
-	form.Add("key", "value")
-	form.Add("name[]", "name1")
-	form.Add("name[]", "name2")
-	form.Add("name[]", "name3")
-	form.Add("arr[x][y][z]", "y")
-	form.Add("arr[x][y][e]", "f")
-	form.Add("arr[c]p", "l")
-	form.Add("arr[c]z", "")
-
-	req, err := http.NewRequest("POST", "http://localhost"+hs.Addr, strings.NewReader(form.Encode()))
-	assert.NoError(t, err)
-
-	req.Header.Add("Content-Type", "application/x-www-form-urlencoded; charset=UTF-8")
-
-	r, err := http.DefaultClient.Do(req)
-	assert.NoError(t, err)
-	defer func() {
-		err := r.Body.Close()
-		if err != nil {
-			t.Errorf("error during the closing Body: error %v", err)
-		}
-	}()
-
-	b, err := ioutil.ReadAll(r.Body)
-	assert.NoError(t, err)
-
-	assert.NoError(t, err)
-	assert.Equal(t, 200, r.StatusCode)
-
-	assert.Equal(t, `{"arr":{"c":{"p":"l","z":""},"x":{"y":{"e":"f","z":"y"}}},"key":"value","name":["name1","name2","name3"]}`, string(b))
-}
-
-func TestHandler_FormData_PUT(t *testing.T) {
-	pool, err := poolImpl.NewPool(context.Background(),
-		func() *exec.Cmd { return exec.Command("php", "../../../tests/http/client.php", "data", "pipes") },
-		pipe.NewPipeFactory(),
-		poolImpl.Config{
-			NumWorkers:      1,
-			AllocateTimeout: time.Second * 1000,
-			DestroyTimeout:  time.Second * 1000,
-		})
-	if err != nil {
-		t.Fatal(err)
-	}
-	defer func() {
-		pool.Destroy(context.Background())
-	}()
-
-	h, err := httpPlugin.NewHandler(1024, httpPlugin.UploadsConfig{
-		Dir:    os.TempDir(),
-		Forbid: []string{},
-	}, nil, pool)
-	assert.NoError(t, err)
-
-	hs := &http.Server{Addr: ":17834", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err := hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 500)
-
-	form := url.Values{}
-
-	form.Add("key", "value")
-	form.Add("name[]", "name1")
-	form.Add("name[]", "name2")
-	form.Add("name[]", "name3")
-	form.Add("arr[x][y][z]", "y")
-	form.Add("arr[x][y][e]", "f")
-	form.Add("arr[c]p", "l")
-	form.Add("arr[c]z", "")
-
-	req, err := http.NewRequest("PUT", "http://localhost"+hs.Addr, strings.NewReader(form.Encode()))
-	assert.NoError(t, err)
-
-	req.Header.Add("Content-Type", "application/x-www-form-urlencoded")
-
-	r, err := http.DefaultClient.Do(req)
-	assert.NoError(t, err)
-	defer func() {
-		err := r.Body.Close()
-		if err != nil {
-			t.Errorf("error during the closing Body: error %v", err)
-		}
-	}()
-
-	b, err := ioutil.ReadAll(r.Body)
-	assert.NoError(t, err)
-
-	assert.NoError(t, err)
-	assert.Equal(t, 200, r.StatusCode)
-
-	assert.Equal(t, `{"arr":{"c":{"p":"l","z":""},"x":{"y":{"e":"f","z":"y"}}},"key":"value","name":["name1","name2","name3"]}`, string(b))
-}
-
-func TestHandler_FormData_PATCH(t *testing.T) {
-	pool, err := poolImpl.NewPool(context.Background(),
-		func() *exec.Cmd { return exec.Command("php", "../../../tests/http/client.php", "data", "pipes") },
-		pipe.NewPipeFactory(),
-		poolImpl.Config{
-			NumWorkers:      1,
-			AllocateTimeout: time.Second * 1000,
-			DestroyTimeout:  time.Second * 1000,
-		})
-	if err != nil {
-		t.Fatal(err)
-	}
-	defer func() {
-		pool.Destroy(context.Background())
-	}()
-
-	h, err := httpPlugin.NewHandler(1024, httpPlugin.UploadsConfig{
-		Dir:    os.TempDir(),
-		Forbid: []string{},
-	}, nil, pool)
-	assert.NoError(t, err)
-
-	hs := &http.Server{Addr: ":8085", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err := hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 10)
-
-	form := url.Values{}
-
-	form.Add("key", "value")
-	form.Add("name[]", "name1")
-	form.Add("name[]", "name2")
-	form.Add("name[]", "name3")
-	form.Add("arr[x][y][z]", "y")
-	form.Add("arr[x][y][e]", "f")
-	form.Add("arr[c]p", "l")
-	form.Add("arr[c]z", "")
-
-	req, err := http.NewRequest("PATCH", "http://localhost"+hs.Addr, strings.NewReader(form.Encode()))
-	assert.NoError(t, err)
-
-	req.Header.Add("Content-Type", "application/x-www-form-urlencoded")
-
-	r, err := http.DefaultClient.Do(req)
-	assert.NoError(t, err)
-	defer func() {
-		err := r.Body.Close()
-		if err != nil {
-			t.Errorf("error during the closing Body: error %v", err)
-		}
-	}()
-
-	b, err := ioutil.ReadAll(r.Body)
-	assert.NoError(t, err)
-
-	assert.NoError(t, err)
-	assert.Equal(t, 200, r.StatusCode)
-
-	assert.Equal(t, "{\"arr\":{\"c\":{\"p\":\"l\",\"z\":\"\"},\"x\":{\"y\":{\"e\":\"f\",\"z\":\"y\"}}},\"key\":\"value\",\"name\":[\"name1\",\"name2\",\"name3\"]}", string(b))
-}
-
-func TestHandler_Multipart_POST(t *testing.T) {
-	pool, err := poolImpl.NewPool(context.Background(),
-		func() *exec.Cmd { return exec.Command("php", "../../../tests/http/client.php", "data", "pipes") },
-		pipe.NewPipeFactory(),
-		poolImpl.Config{
-			NumWorkers:      1,
-			AllocateTimeout: time.Second * 1000,
-			DestroyTimeout:  time.Second * 1000,
-		})
-	if err != nil {
-		t.Fatal(err)
-	}
-	defer func() {
-		pool.Destroy(context.Background())
-	}()
-
-	h, err := httpPlugin.NewHandler(1024, httpPlugin.UploadsConfig{
-		Dir:    os.TempDir(),
-		Forbid: []string{},
-	}, nil, pool)
-	assert.NoError(t, err)
-
-	hs := &http.Server{Addr: ":8019", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err := hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 10)
-
-	var mb bytes.Buffer
-	w := multipart.NewWriter(&mb)
-	err = w.WriteField("key", "value")
-	if err != nil {
-		t.Errorf("error writing the field: error %v", err)
-	}
-
-	err = w.WriteField("key", "value")
-	if err != nil {
-		t.Errorf("error writing the field: error %v", err)
-	}
-
-	err = w.WriteField("name[]", "name1")
-	if err != nil {
-		t.Errorf("error writing the field: error %v", err)
-	}
-
-	err = w.WriteField("name[]", "name2")
-	if err != nil {
-		t.Errorf("error writing the field: error %v", err)
-	}
-
-	err = w.WriteField("name[]", "name3")
-	if err != nil {
-		t.Errorf("error writing the field: error %v", err)
-	}
-
-	err = w.WriteField("arr[x][y][z]", "y")
-	if err != nil {
-		t.Errorf("error writing the field: error %v", err)
-	}
-
-	err = w.WriteField("arr[x][y][e]", "f")
-
-	if err != nil {
-		t.Errorf("error writing the field: error %v", err)
-	}
-
-	err = w.WriteField("arr[c]p", "l")
-	if err != nil {
-		t.Errorf("error writing the field: error %v", err)
-	}
-
-	err = w.WriteField("arr[c]z", "")
-	if err != nil {
-		t.Errorf("error writing the field: error %v", err)
-	}
-
-	err = w.Close()
-	if err != nil {
-		t.Errorf("error closing the writer: error %v", err)
-	}
-
-	req, err := http.NewRequest("POST", "http://localhost"+hs.Addr, &mb)
-	assert.NoError(t, err)
-
-	req.Header.Set("Content-Type", w.FormDataContentType())
-
-	r, err := http.DefaultClient.Do(req)
-	assert.NoError(t, err)
-	defer func() {
-		err := r.Body.Close()
-		if err != nil {
-			t.Errorf("error during the closing Body: error %v", err)
-		}
-	}()
-
-	b, err := ioutil.ReadAll(r.Body)
-	assert.NoError(t, err)
-
-	assert.NoError(t, err)
-	assert.Equal(t, 200, r.StatusCode)
-
-	assert.Equal(t, "{\"arr\":{\"c\":{\"p\":\"l\",\"z\":\"\"},\"x\":{\"y\":{\"e\":\"f\",\"z\":\"y\"}}},\"key\":\"value\",\"name\":[\"name1\",\"name2\",\"name3\"]}", string(b))
-}
-
-func TestHandler_Multipart_PUT(t *testing.T) {
-	pool, err := poolImpl.NewPool(context.Background(),
-		func() *exec.Cmd { return exec.Command("php", "../../../tests/http/client.php", "data", "pipes") },
-		pipe.NewPipeFactory(),
-		poolImpl.Config{
-			NumWorkers:      1,
-			AllocateTimeout: time.Second * 1000,
-			DestroyTimeout:  time.Second * 1000,
-		})
-	if err != nil {
-		t.Fatal(err)
-	}
-	defer func() {
-		pool.Destroy(context.Background())
-	}()
-
-	h, err := httpPlugin.NewHandler(1024, httpPlugin.UploadsConfig{
-		Dir:    os.TempDir(),
-		Forbid: []string{},
-	}, nil, pool)
-	assert.NoError(t, err)
-
-	hs := &http.Server{Addr: ":8020", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err := hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 500)
-
-	var mb bytes.Buffer
-	w := multipart.NewWriter(&mb)
-	err = w.WriteField("key", "value")
-	if err != nil {
-		t.Errorf("error writing the field: error %v", err)
-	}
-
-	err = w.WriteField("key", "value")
-	if err != nil {
-		t.Errorf("error writing the field: error %v", err)
-	}
-
-	err = w.WriteField("name[]", "name1")
-
-	if err != nil {
-		t.Errorf("error writing the field: error %v", err)
-	}
-
-	err = w.WriteField("name[]", "name2")
-	if err != nil {
-		t.Errorf("error writing the field: error %v", err)
-	}
-
-	err = w.WriteField("name[]", "name3")
-	if err != nil {
-		t.Errorf("error writing the field: error %v", err)
-	}
-
-	err = w.WriteField("arr[x][y][z]", "y")
-	if err != nil {
-		t.Errorf("error writing the field: error %v", err)
-	}
-
-	err = w.WriteField("arr[x][y][e]", "f")
-	if err != nil {
-		t.Errorf("error writing the field: error %v", err)
-	}
-
-	err = w.WriteField("arr[c]p", "l")
-	if err != nil {
-		t.Errorf("error writing the field: error %v", err)
-	}
-
-	err = w.WriteField("arr[c]z", "")
-	if err != nil {
-		t.Errorf("error writing the field: error %v", err)
-	}
-
-	err = w.Close()
-	if err != nil {
-		t.Errorf("error closing the writer: error %v", err)
-	}
-
-	req, err := http.NewRequest("PUT", "http://localhost"+hs.Addr, &mb)
-	assert.NoError(t, err)
-
-	req.Header.Set("Content-Type", w.FormDataContentType())
-
-	r, err := http.DefaultClient.Do(req)
-	assert.NoError(t, err)
-	defer func() {
-		err := r.Body.Close()
-		if err != nil {
-			t.Errorf("error during the closing Body: error %v", err)
-		}
-	}()
-
-	b, err := ioutil.ReadAll(r.Body)
-	assert.NoError(t, err)
-
-	assert.NoError(t, err)
-	assert.Equal(t, 200, r.StatusCode)
-
-	assert.Equal(t, `{"arr":{"c":{"p":"l","z":""},"x":{"y":{"e":"f","z":"y"}}},"key":"value","name":["name1","name2","name3"]}`, string(b))
-}
-
-func TestHandler_Multipart_PATCH(t *testing.T) {
-	pool, err := poolImpl.NewPool(context.Background(),
-		func() *exec.Cmd { return exec.Command("php", "../../../tests/http/client.php", "data", "pipes") },
-		pipe.NewPipeFactory(),
-		poolImpl.Config{
-			NumWorkers:      1,
-			AllocateTimeout: time.Second * 1000,
-			DestroyTimeout:  time.Second * 1000,
-		})
-	if err != nil {
-		t.Fatal(err)
-	}
-	defer func() {
-		pool.Destroy(context.Background())
-	}()
-
-	h, err := httpPlugin.NewHandler(1024, httpPlugin.UploadsConfig{
-		Dir:    os.TempDir(),
-		Forbid: []string{},
-	}, nil, pool)
-	assert.NoError(t, err)
-
-	hs := &http.Server{Addr: ":8021", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err := hs.ListenAndServe()
-
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 500)
-
-	var mb bytes.Buffer
-	w := multipart.NewWriter(&mb)
-	err = w.WriteField("key", "value")
-	if err != nil {
-		t.Errorf("error writing the field: error %v", err)
-	}
-
-	err = w.WriteField("key", "value")
-	if err != nil {
-		t.Errorf("error writing the field: error %v", err)
-	}
-
-	err = w.WriteField("name[]", "name1")
-	if err != nil {
-		t.Errorf("error writing the field: error %v", err)
-	}
-
-	err = w.WriteField("name[]", "name2")
-
-	if err != nil {
-		t.Errorf("error writing the field: error %v", err)
-	}
-
-	err = w.WriteField("name[]", "name3")
-
-	if err != nil {
-		t.Errorf("error writing the field: error %v", err)
-	}
-
-	err = w.WriteField("arr[x][y][z]", "y")
-	if err != nil {
-		t.Errorf("error writing the field: error %v", err)
-	}
-
-	err = w.WriteField("arr[x][y][e]", "f")
-	if err != nil {
-		t.Errorf("error writing the field: error %v", err)
-	}
-
-	err = w.WriteField("arr[c]p", "l")
-	if err != nil {
-		t.Errorf("error writing the field: error %v", err)
-	}
-
-	err = w.WriteField("arr[c]z", "")
-	if err != nil {
-		t.Errorf("error writing the field: error %v", err)
-	}
-
-	err = w.Close()
-	if err != nil {
-		t.Errorf("error closing the writer: error %v", err)
-	}
-
-	req, err := http.NewRequest("PATCH", "http://localhost"+hs.Addr, &mb)
-	assert.NoError(t, err)
-
-	req.Header.Set("Content-Type", w.FormDataContentType())
-
-	r, err := http.DefaultClient.Do(req)
-	assert.NoError(t, err)
-	defer func() {
-		err := r.Body.Close()
-		if err != nil {
-			t.Errorf("error during the closing Body: error %v", err)
-		}
-	}()
-
-	b, err := ioutil.ReadAll(r.Body)
-	assert.NoError(t, err)
-
-	assert.NoError(t, err)
-	assert.Equal(t, 200, r.StatusCode)
-
-	assert.Equal(t, `{"arr":{"c":{"p":"l","z":""},"x":{"y":{"e":"f","z":"y"}}},"key":"value","name":["name1","name2","name3"]}`, string(b))
-}
-
-func TestHandler_Error(t *testing.T) {
-	pool, err := poolImpl.NewPool(context.Background(),
-		func() *exec.Cmd { return exec.Command("php", "../../../tests/http/client.php", "error", "pipes") },
-		pipe.NewPipeFactory(),
-		poolImpl.Config{
-			NumWorkers:      1,
-			AllocateTimeout: time.Second * 1000,
-			DestroyTimeout:  time.Second * 1000,
-		})
-	if err != nil {
-		t.Fatal(err)
-	}
-	defer func() {
-		pool.Destroy(context.Background())
-	}()
-
-	h, err := httpPlugin.NewHandler(1024, httpPlugin.UploadsConfig{
-		Dir:    os.TempDir(),
-		Forbid: []string{},
-	}, nil, pool)
-	assert.NoError(t, err)
-
-	hs := &http.Server{Addr: ":8177", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err := hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 10)
-
-	_, r, err := get("http://localhost:8177/?hello=world")
-	assert.NoError(t, err)
-	defer func() {
-		_ = r.Body.Close()
-	}()
-	assert.Equal(t, 500, r.StatusCode)
-}
-
-func TestHandler_Error2(t *testing.T) {
-	pool, err := poolImpl.NewPool(context.Background(),
-		func() *exec.Cmd { return exec.Command("php", "../../../tests/http/client.php", "error2", "pipes") },
-		pipe.NewPipeFactory(),
-		poolImpl.Config{
-			NumWorkers:      1,
-			AllocateTimeout: time.Second * 1000,
-			DestroyTimeout:  time.Second * 1000,
-		})
-	if err != nil {
-		t.Fatal(err)
-	}
-	defer func() {
-		pool.Destroy(context.Background())
-	}()
-
-	h, err := httpPlugin.NewHandler(1024, httpPlugin.UploadsConfig{
-		Dir:    os.TempDir(),
-		Forbid: []string{},
-	}, nil, pool)
-	assert.NoError(t, err)
-
-	hs := &http.Server{Addr: ":8177", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err := hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 10)
-
-	_, r, err := get("http://localhost:8177/?hello=world")
-	assert.NoError(t, err)
-	defer func() {
-		_ = r.Body.Close()
-	}()
-	assert.Equal(t, 500, r.StatusCode)
-}
-
-func TestHandler_Error3(t *testing.T) {
-	pool, err := poolImpl.NewPool(context.Background(),
-		func() *exec.Cmd { return exec.Command("php", "../../../tests/http/client.php", "pid", "pipes") },
-		pipe.NewPipeFactory(),
-		poolImpl.Config{
-			NumWorkers:      1,
-			AllocateTimeout: time.Second * 1000,
-			DestroyTimeout:  time.Second * 1000,
-		})
-	if err != nil {
-		t.Fatal(err)
-	}
-	defer func() {
-		pool.Destroy(context.Background())
-	}()
-
-	h, err := httpPlugin.NewHandler(1, httpPlugin.UploadsConfig{
-		Dir:    os.TempDir(),
-		Forbid: []string{},
-	}, nil, pool)
-	assert.NoError(t, err)
-
-	hs := &http.Server{Addr: ":8177", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err = hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 10)
-
-	b2 := &bytes.Buffer{}
-	for i := 0; i < 1024*1024; i++ {
-		b2.Write([]byte("  "))
-	}
-
-	req, err := http.NewRequest("POST", "http://localhost"+hs.Addr, b2)
-	assert.NoError(t, err)
-
-	r, err := http.DefaultClient.Do(req)
-	assert.NoError(t, err)
-	defer func() {
-		err = r.Body.Close()
-		if err != nil {
-			t.Errorf("error during the closing Body: error %v", err)
-		}
-	}()
-
-	assert.NoError(t, err)
-	assert.Equal(t, 500, r.StatusCode)
-}
-
-func TestHandler_ResponseDuration(t *testing.T) {
-	pool, err := poolImpl.NewPool(context.Background(),
-		func() *exec.Cmd { return exec.Command("php", "../../../tests/http/client.php", "echo", "pipes") },
-		pipe.NewPipeFactory(),
-		poolImpl.Config{
-			NumWorkers:      1,
-			AllocateTimeout: time.Second * 1000,
-			DestroyTimeout:  time.Second * 1000,
-		})
-	if err != nil {
-		t.Fatal(err)
-	}
-	defer func() {
-		pool.Destroy(context.Background())
-	}()
-
-	h, err := httpPlugin.NewHandler(1024, httpPlugin.UploadsConfig{
-		Dir:    os.TempDir(),
-		Forbid: []string{},
-	}, nil, pool)
-	assert.NoError(t, err)
-
-	hs := &http.Server{Addr: ":8177", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err := hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 10)
-
-	gotresp := make(chan interface{})
-	h.AddListener(func(event interface{}) {
-		switch t := event.(type) {
-		case httpPlugin.ResponseEvent:
-			if t.Elapsed() > 0 {
-				close(gotresp)
-			}
-		default:
-		}
-	})
-
-	body, r, err := get("http://localhost:8177/?hello=world")
-	assert.NoError(t, err)
-	defer func() {
-		_ = r.Body.Close()
-	}()
-
-	<-gotresp
-
-	assert.Equal(t, 201, r.StatusCode)
-	assert.Equal(t, "WORLD", body)
-}
-
-func TestHandler_ResponseDurationDelayed(t *testing.T) {
-	pool, err := poolImpl.NewPool(context.Background(),
-		func() *exec.Cmd { return exec.Command("php", "../../../tests/http/client.php", "echoDelay", "pipes") },
-		pipe.NewPipeFactory(),
-		poolImpl.Config{
-			NumWorkers:      1,
-			AllocateTimeout: time.Second * 1000,
-			DestroyTimeout:  time.Second * 1000,
-		})
-	if err != nil {
-		t.Fatal(err)
-	}
-	defer func() {
-		pool.Destroy(context.Background())
-	}()
-
-	h, err := httpPlugin.NewHandler(1024, httpPlugin.UploadsConfig{
-		Dir:    os.TempDir(),
-		Forbid: []string{},
-	}, nil, pool)
-	assert.NoError(t, err)
-
-	hs := &http.Server{Addr: ":8177", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err := hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 10)
-
-	gotresp := make(chan interface{})
-	h.AddListener(func(event interface{}) {
-		switch tp := event.(type) {
-		case httpPlugin.ResponseEvent:
-			if tp.Elapsed() > time.Second {
-				close(gotresp)
-			}
-		default:
-		}
-	})
-
-	body, r, err := get("http://localhost:8177/?hello=world")
-	assert.NoError(t, err)
-	defer func() {
-		_ = r.Body.Close()
-	}()
-	<-gotresp
-
-	assert.Equal(t, 201, r.StatusCode)
-	assert.Equal(t, "WORLD", body)
-}
-
-func TestHandler_ErrorDuration(t *testing.T) {
-	pool, err := poolImpl.NewPool(context.Background(),
-		func() *exec.Cmd { return exec.Command("php", "../../../tests/http/client.php", "error", "pipes") },
-		pipe.NewPipeFactory(),
-		poolImpl.Config{
-			NumWorkers:      1,
-			AllocateTimeout: time.Second * 1000,
-			DestroyTimeout:  time.Second * 1000,
-		})
-	if err != nil {
-		t.Fatal(err)
-	}
-	defer func() {
-		pool.Destroy(context.Background())
-	}()
-
-	h, err := httpPlugin.NewHandler(1024, httpPlugin.UploadsConfig{
-		Dir:    os.TempDir(),
-		Forbid: []string{},
-	}, nil, pool)
-	assert.NoError(t, err)
-
-	hs := &http.Server{Addr: ":8177", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err = hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 10)
-
-	goterr := make(chan interface{})
-	h.AddListener(func(event interface{}) {
-		switch tp := event.(type) {
-		case httpPlugin.ErrorEvent:
-			if tp.Elapsed() > 0 {
-				close(goterr)
-			}
-		default:
-		}
-	})
-
-	_, r, err := get("http://localhost:8177/?hello=world")
-	assert.NoError(t, err)
-	defer func() {
-		_ = r.Body.Close()
-	}()
-
-	<-goterr
-
-	assert.Equal(t, 500, r.StatusCode)
-}
-
-func TestHandler_IP(t *testing.T) {
-	trusted := []string{
-		"10.0.0.0/8",
-		"127.0.0.0/8",
-		"172.16.0.0/12",
-		"192.168.0.0/16",
-		"::1/128",
-		"fc00::/7",
-		"fe80::/10",
-	}
-
-	cidrs, err := httpPlugin.ParseCIDRs(trusted)
-	assert.NoError(t, err)
-	assert.NotNil(t, cidrs)
-
-	pool, err := poolImpl.NewPool(context.Background(),
-		func() *exec.Cmd { return exec.Command("php", "../../../tests/http/client.php", "ip", "pipes") },
-		pipe.NewPipeFactory(),
-		poolImpl.Config{
-			NumWorkers:      1,
-			AllocateTimeout: time.Second * 1000,
-			DestroyTimeout:  time.Second * 1000,
-		})
-	if err != nil {
-		t.Fatal(err)
-	}
-	defer func() {
-		pool.Destroy(context.Background())
-	}()
-
-	h, err := httpPlugin.NewHandler(1024, httpPlugin.UploadsConfig{
-		Dir:    os.TempDir(),
-		Forbid: []string{},
-	}, cidrs, pool)
-	assert.NoError(t, err)
-
-	hs := &http.Server{Addr: "127.0.0.1:8177", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err := hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 10)
-
-	body, r, err := get("http://127.0.0.1:8177/")
-	assert.NoError(t, err)
-	defer func() {
-		_ = r.Body.Close()
-	}()
-	assert.Equal(t, 200, r.StatusCode)
-	assert.Equal(t, "127.0.0.1", body)
-}
-
-func TestHandler_XRealIP(t *testing.T) {
-	trusted := []string{
-		"10.0.0.0/8",
-		"127.0.0.0/8",
-		"172.16.0.0/12",
-		"192.168.0.0/16",
-		"::1/128",
-		"fc00::/7",
-		"fe80::/10",
-	}
-
-	cidrs, err := httpPlugin.ParseCIDRs(trusted)
-	assert.NoError(t, err)
-	assert.NotNil(t, cidrs)
-
-	pool, err := poolImpl.NewPool(context.Background(),
-		func() *exec.Cmd { return exec.Command("php", "../../../tests/http/client.php", "ip", "pipes") },
-		pipe.NewPipeFactory(),
-		poolImpl.Config{
-			NumWorkers:      1,
-			AllocateTimeout: time.Second * 1000,
-			DestroyTimeout:  time.Second * 1000,
-		})
-	if err != nil {
-		t.Fatal(err)
-	}
-	defer func() {
-		pool.Destroy(context.Background())
-	}()
-
-	h, err := httpPlugin.NewHandler(1024, httpPlugin.UploadsConfig{
-		Dir:    os.TempDir(),
-		Forbid: []string{},
-	}, cidrs, pool)
-	assert.NoError(t, err)
-
-	hs := &http.Server{Addr: "127.0.0.1:8179", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err := hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 10)
-
-	body, r, err := getHeader("http://127.0.0.1:8179/", map[string]string{
-		"X-Real-Ip": "200.0.0.1",
-	})
-
-	assert.NoError(t, err)
-	defer func() {
-		_ = r.Body.Close()
-	}()
-	assert.Equal(t, 200, r.StatusCode)
-	assert.Equal(t, "200.0.0.1", body)
-}
-
-func TestHandler_XForwardedFor(t *testing.T) {
-	trusted := []string{
-		"10.0.0.0/8",
-		"127.0.0.0/8",
-		"172.16.0.0/12",
-		"192.168.0.0/16",
-		"100.0.0.0/16",
-		"200.0.0.0/16",
-		"::1/128",
-		"fc00::/7",
-		"fe80::/10",
-	}
-
-	cidrs, err := httpPlugin.ParseCIDRs(trusted)
-	assert.NoError(t, err)
-	assert.NotNil(t, cidrs)
-
-	pool, err := poolImpl.NewPool(context.Background(),
-		func() *exec.Cmd { return exec.Command("php", "../../../tests/http/client.php", "ip", "pipes") },
-		pipe.NewPipeFactory(),
-		poolImpl.Config{
-			NumWorkers:      1,
-			AllocateTimeout: time.Second * 1000,
-			DestroyTimeout:  time.Second * 1000,
-		})
-	if err != nil {
-		t.Fatal(err)
-	}
-	defer func() {
-		pool.Destroy(context.Background())
-	}()
-
-	h, err := httpPlugin.NewHandler(1024, httpPlugin.UploadsConfig{
-		Dir:    os.TempDir(),
-		Forbid: []string{},
-	}, cidrs, pool)
-	assert.NoError(t, err)
-
-	hs := &http.Server{Addr: "127.0.0.1:8177", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err := hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 10)
-
-	body, r, err := getHeader("http://127.0.0.1:8177/", map[string]string{
-		"X-Forwarded-For": "100.0.0.1, 200.0.0.1, invalid, 101.0.0.1",
-	})
-
-	assert.NoError(t, err)
-	assert.Equal(t, 200, r.StatusCode)
-	assert.Equal(t, "101.0.0.1", body)
-	_ = r.Body.Close()
-
-	body, r, err = getHeader("http://127.0.0.1:8177/", map[string]string{
-		"X-Forwarded-For": "100.0.0.1, 200.0.0.1, 101.0.0.1, invalid",
-	})
-
-	assert.NoError(t, err)
-	_ = r.Body.Close()
-	assert.Equal(t, 200, r.StatusCode)
-	assert.Equal(t, "101.0.0.1", body)
-}
-
-func TestHandler_XForwardedFor_NotTrustedRemoteIp(t *testing.T) {
-	trusted := []string{
-		"10.0.0.0/8",
-	}
-
-	cidrs, err := httpPlugin.ParseCIDRs(trusted)
-	assert.NoError(t, err)
-	assert.NotNil(t, cidrs)
-
-	pool, err := poolImpl.NewPool(context.Background(),
-		func() *exec.Cmd { return exec.Command("php", "../../../tests/http/client.php", "ip", "pipes") },
-		pipe.NewPipeFactory(),
-		poolImpl.Config{
-			NumWorkers:      1,
-			AllocateTimeout: time.Second * 1000,
-			DestroyTimeout:  time.Second * 1000,
-		})
-	if err != nil {
-		t.Fatal(err)
-	}
-	defer func() {
-		pool.Destroy(context.Background())
-	}()
-
-	h, err := httpPlugin.NewHandler(1024, httpPlugin.UploadsConfig{
-		Dir:    os.TempDir(),
-		Forbid: []string{},
-	}, cidrs, pool)
-	assert.NoError(t, err)
-
-	hs := &http.Server{Addr: "127.0.0.1:8177", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err := hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 10)
-
-	body, r, err := getHeader("http://127.0.0.1:8177/", map[string]string{
-		"X-Forwarded-For": "100.0.0.1, 200.0.0.1, invalid, 101.0.0.1",
-	})
-
-	assert.NoError(t, err)
-	_ = r.Body.Close()
-	assert.Equal(t, 200, r.StatusCode)
-	assert.Equal(t, "127.0.0.1", body)
-}
-
-func BenchmarkHandler_Listen_Echo(b *testing.B) {
-	pool, err := poolImpl.NewPool(context.Background(),
-		func() *exec.Cmd { return exec.Command("php", "../../../tests/http/client.php", "echo", "pipes") },
-		pipe.NewPipeFactory(),
-		poolImpl.Config{
-			NumWorkers:      int64(runtime.NumCPU()),
-			AllocateTimeout: time.Second * 1000,
-			DestroyTimeout:  time.Second * 1000,
-		})
-	if err != nil {
-		b.Fatal(err)
-	}
-	defer func() {
-		pool.Destroy(context.Background())
-	}()
-
-	h, err := httpPlugin.NewHandler(1024, httpPlugin.UploadsConfig{
-		Dir:    os.TempDir(),
-		Forbid: []string{},
-	}, nil, pool)
-	assert.NoError(b, err)
-
-	hs := &http.Server{Addr: ":8177", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			b.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err = hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			b.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 10)
-
-	b.ResetTimer()
-	b.ReportAllocs()
-	bb := "WORLD"
-	for n := 0; n < b.N; n++ {
-		r, err := http.Get("http://localhost:8177/?hello=world")
-		if err != nil {
-			b.Fail()
-		}
-		// Response might be nil here
-		if r != nil {
-			br, err := ioutil.ReadAll(r.Body)
-			if err != nil {
-				b.Errorf("error reading Body: error %v", err)
-			}
-			if string(br) != bb {
-				b.Fail()
-			}
-			err = r.Body.Close()
-			if err != nil {
-				b.Errorf("error closing the Body: error %v", err)
-			}
-		} else {
-			b.Errorf("got nil response")
-		}
-	}
-}
diff --git a/plugins/http/tests/http_test.go b/plugins/http/tests/http_test.go
deleted file mode 100644
index d7818981..00000000
--- a/plugins/http/tests/http_test.go
+++ /dev/null
@@ -1,1131 +0,0 @@
-package tests
-
-import (
-	"bytes"
-	"crypto/tls"
-	"io/ioutil"
-	"net"
-	"net/http"
-	"net/http/httptest"
-	"net/rpc"
-	"os"
-	"os/signal"
-	"sync"
-	"syscall"
-	"testing"
-	"time"
-
-	"github.com/golang/mock/gomock"
-	"github.com/spiral/endure"
-	goridgeRpc "github.com/spiral/goridge/v3/pkg/rpc"
-	"github.com/spiral/roadrunner/v2"
-	"github.com/spiral/roadrunner/v2/interfaces/events"
-	"github.com/spiral/roadrunner/v2/mocks"
-	"github.com/spiral/roadrunner/v2/plugins/config"
-	httpPlugin "github.com/spiral/roadrunner/v2/plugins/http"
-	"github.com/spiral/roadrunner/v2/plugins/informer"
-	"github.com/spiral/roadrunner/v2/plugins/logger"
-	"github.com/spiral/roadrunner/v2/plugins/resetter"
-	"github.com/yookoala/gofast"
-
-	rpcPlugin "github.com/spiral/roadrunner/v2/plugins/rpc"
-	"github.com/spiral/roadrunner/v2/plugins/server"
-	"github.com/stretchr/testify/assert"
-)
-
-var sslClient = &http.Client{
-	Transport: &http.Transport{
-		TLSClientConfig: &tls.Config{
-			InsecureSkipVerify: true,
-		},
-	},
-}
-
-func TestHTTPInit(t *testing.T) {
-	cont, err := endure.NewContainer(nil, endure.SetLogLevel(endure.ErrorLevel))
-	assert.NoError(t, err)
-
-	cfg := &config.Viper{
-		Path:   "configs/.rr-init.yaml",
-		Prefix: "rr",
-	}
-
-	err = cont.RegisterAll(
-		cfg,
-		&logger.ZapLogger{},
-		&server.Plugin{},
-		&httpPlugin.Plugin{},
-	)
-	assert.NoError(t, err)
-
-	err = cont.Init()
-	if err != nil {
-		t.Fatal(err)
-	}
-
-	ch, err := cont.Serve()
-	assert.NoError(t, err)
-
-	sig := make(chan os.Signal, 1)
-	signal.Notify(sig, os.Interrupt, syscall.SIGINT, syscall.SIGTERM)
-
-	wg := &sync.WaitGroup{}
-	wg.Add(1)
-
-	tt := time.NewTimer(time.Second * 5)
-
-	go func() {
-		defer wg.Done()
-		for {
-			select {
-			case e := <-ch:
-				assert.Fail(t, "error", e.Error.Error())
-				err = cont.Stop()
-				if err != nil {
-					assert.FailNow(t, "error", err.Error())
-				}
-			case <-sig:
-				err = cont.Stop()
-				if err != nil {
-					assert.FailNow(t, "error", err.Error())
-				}
-				return
-			case <-tt.C:
-				// timeout
-				err = cont.Stop()
-				if err != nil {
-					assert.FailNow(t, "error", err.Error())
-				}
-				return
-			}
-		}
-	}()
-
-	wg.Wait()
-}
-
-func TestHTTPInformerReset(t *testing.T) {
-	cont, err := endure.NewContainer(nil, endure.SetLogLevel(endure.ErrorLevel))
-	assert.NoError(t, err)
-
-	cfg := &config.Viper{
-		Path:   "configs/.rr-resetter.yaml",
-		Prefix: "rr",
-	}
-
-	err = cont.RegisterAll(
-		cfg,
-		&rpcPlugin.Plugin{},
-		&logger.ZapLogger{},
-		&server.Plugin{},
-		&httpPlugin.Plugin{},
-		&informer.Plugin{},
-		&resetter.Plugin{},
-	)
-	assert.NoError(t, err)
-
-	err = cont.Init()
-	if err != nil {
-		t.Fatal(err)
-	}
-
-	ch, err := cont.Serve()
-	assert.NoError(t, err)
-
-	sig := make(chan os.Signal, 1)
-	signal.Notify(sig, os.Interrupt, syscall.SIGINT, syscall.SIGTERM)
-
-	wg := &sync.WaitGroup{}
-	wg.Add(1)
-
-	go func() {
-		tt := time.NewTimer(time.Second * 10)
-		defer wg.Done()
-		for {
-			select {
-			case e := <-ch:
-				assert.Fail(t, "error", e.Error.Error())
-				err = cont.Stop()
-				if err != nil {
-					assert.FailNow(t, "error", err.Error())
-				}
-			case <-sig:
-				err = cont.Stop()
-				if err != nil {
-					assert.FailNow(t, "error", err.Error())
-				}
-				return
-			case <-tt.C:
-				// timeout
-				err = cont.Stop()
-				if err != nil {
-					assert.FailNow(t, "error", err.Error())
-				}
-				return
-			}
-		}
-	}()
-
-	time.Sleep(time.Second * 1)
-	t.Run("HTTPInformerTest", informerTest)
-	t.Run("HTTPEchoTestBefore", echoHTTP)
-	t.Run("HTTPResetTest", resetTest)
-	t.Run("HTTPEchoTestAfter", echoHTTP)
-
-	wg.Wait()
-}
-
-func echoHTTP(t *testing.T) {
-	req, err := http.NewRequest("GET", "http://localhost:10084?hello=world", nil)
-	assert.NoError(t, err)
-
-	r, err := http.DefaultClient.Do(req)
-	assert.NoError(t, err)
-	b, err := ioutil.ReadAll(r.Body)
-	assert.NoError(t, err)
-	assert.Equal(t, 201, r.StatusCode)
-	assert.Equal(t, "WORLD", string(b))
-
-	err = r.Body.Close()
-	assert.NoError(t, err)
-}
-
-func resetTest(t *testing.T) {
-	conn, err := net.Dial("tcp", "127.0.0.1:6001")
-	assert.NoError(t, err)
-	client := rpc.NewClientWithCodec(goridgeRpc.NewClientCodec(conn))
-	// WorkerList contains list of workers.
-
-	var ret bool
-	err = client.Call("resetter.Reset", "http", &ret)
-	assert.NoError(t, err)
-	assert.True(t, ret)
-	ret = false
-
-	var services []string
-	err = client.Call("resetter.List", nil, &services)
-	assert.NoError(t, err)
-	if services[0] != "http" {
-		t.Fatal("no enough services")
-	}
-}
-
-func informerTest(t *testing.T) {
-	conn, err := net.Dial("tcp", "127.0.0.1:6001")
-	assert.NoError(t, err)
-	client := rpc.NewClientWithCodec(goridgeRpc.NewClientCodec(conn))
-	// WorkerList contains list of workers.
-	list := struct {
-		// Workers is list of workers.
-		Workers []roadrunner.ProcessState `json:"workers"`
-	}{}
-
-	err = client.Call("informer.Workers", "http", &list)
-	assert.NoError(t, err)
-	assert.Len(t, list.Workers, 2)
-}
-
-func TestSSL(t *testing.T) {
-	cont, err := endure.NewContainer(nil, endure.SetLogLevel(endure.ErrorLevel))
-	assert.NoError(t, err)
-
-	cfg := &config.Viper{
-		Path:   "configs/.rr-ssl.yaml",
-		Prefix: "rr",
-	}
-
-	err = cont.RegisterAll(
-		cfg,
-		&rpcPlugin.Plugin{},
-		&logger.ZapLogger{},
-		&server.Plugin{},
-		&httpPlugin.Plugin{},
-	)
-	assert.NoError(t, err)
-
-	err = cont.Init()
-	if err != nil {
-		t.Fatal(err)
-	}
-
-	ch, err := cont.Serve()
-	assert.NoError(t, err)
-
-	sig := make(chan os.Signal, 1)
-	signal.Notify(sig, os.Interrupt, syscall.SIGINT, syscall.SIGTERM)
-
-	wg := &sync.WaitGroup{}
-	wg.Add(1)
-	tt := time.NewTimer(time.Second * 10)
-
-	go func() {
-		defer wg.Done()
-		for {
-			select {
-			case e := <-ch:
-				assert.Fail(t, "error", e.Error.Error())
-				err = cont.Stop()
-				if err != nil {
-					assert.FailNow(t, "error", err.Error())
-				}
-			case <-sig:
-				err = cont.Stop()
-				if err != nil {
-					assert.FailNow(t, "error", err.Error())
-				}
-				return
-			case <-tt.C:
-				// timeout
-				err = cont.Stop()
-				if err != nil {
-					assert.FailNow(t, "error", err.Error())
-				}
-				return
-			}
-		}
-	}()
-
-	time.Sleep(time.Second * 1)
-	t.Run("SSLEcho", sslEcho)
-	t.Run("SSLNoRedirect", sslNoRedirect)
-	t.Run("fCGIecho", fcgiEcho)
-	wg.Wait()
-}
-
-func sslNoRedirect(t *testing.T) {
-	req, err := http.NewRequest("GET", "http://localhost:8085?hello=world", nil)
-	assert.NoError(t, err)
-
-	r, err := sslClient.Do(req)
-	assert.NoError(t, err)
-
-	assert.Nil(t, r.TLS)
-
-	b, err := ioutil.ReadAll(r.Body)
-	assert.NoError(t, err)
-
-	assert.NoError(t, err)
-	assert.Equal(t, 201, r.StatusCode)
-	assert.Equal(t, "WORLD", string(b))
-
-	err2 := r.Body.Close()
-	if err2 != nil {
-		t.Errorf("fail to close the Body: error %v", err2)
-	}
-}
-
-func sslEcho(t *testing.T) {
-	req, err := http.NewRequest("GET", "https://localhost:8893?hello=world", nil)
-	assert.NoError(t, err)
-
-	r, err := sslClient.Do(req)
-	assert.NoError(t, err)
-
-	b, err := ioutil.ReadAll(r.Body)
-	assert.NoError(t, err)
-
-	assert.NoError(t, err)
-	assert.Equal(t, 201, r.StatusCode)
-	assert.Equal(t, "WORLD", string(b))
-
-	err2 := r.Body.Close()
-	if err2 != nil {
-		t.Errorf("fail to close the Body: error %v", err2)
-	}
-}
-
-func fcgiEcho(t *testing.T) {
-	fcgiConnFactory := gofast.SimpleConnFactory("tcp", "0.0.0.0:16920")
-
-	fcgiHandler := gofast.NewHandler(
-		gofast.BasicParamsMap(gofast.BasicSession),
-		gofast.SimpleClientFactory(fcgiConnFactory, 0),
-	)
-
-	w := httptest.NewRecorder()
-	req := httptest.NewRequest("GET", "http://site.local/?hello=world", nil)
-	fcgiHandler.ServeHTTP(w, req)
-
-	body, err := ioutil.ReadAll(w.Result().Body)
-
-	assert.NoError(t, err)
-	assert.Equal(t, 201, w.Result().StatusCode)
-	assert.Equal(t, "WORLD", string(body))
-}
-
-func TestSSLRedirect(t *testing.T) {
-	cont, err := endure.NewContainer(nil, endure.SetLogLevel(endure.ErrorLevel))
-	assert.NoError(t, err)
-
-	cfg := &config.Viper{
-		Path:   "configs/.rr-ssl-redirect.yaml",
-		Prefix: "rr",
-	}
-
-	err = cont.RegisterAll(
-		cfg,
-		&rpcPlugin.Plugin{},
-		&logger.ZapLogger{},
-		&server.Plugin{},
-		&httpPlugin.Plugin{},
-	)
-	assert.NoError(t, err)
-
-	err = cont.Init()
-	if err != nil {
-		t.Fatal(err)
-	}
-
-	ch, err := cont.Serve()
-	assert.NoError(t, err)
-
-	sig := make(chan os.Signal, 1)
-	signal.Notify(sig, os.Interrupt, syscall.SIGINT, syscall.SIGTERM)
-
-	wg := &sync.WaitGroup{}
-	wg.Add(1)
-
-	tt := time.NewTimer(time.Second * 10)
-	go func() {
-		defer wg.Done()
-		for {
-			select {
-			case e := <-ch:
-				assert.Fail(t, "error", e.Error.Error())
-				err = cont.Stop()
-				if err != nil {
-					assert.FailNow(t, "error", err.Error())
-				}
-			case <-sig:
-				err = cont.Stop()
-				if err != nil {
-					assert.FailNow(t, "error", err.Error())
-				}
-				return
-			case <-tt.C:
-				// timeout
-				err = cont.Stop()
-				if err != nil {
-					assert.FailNow(t, "error", err.Error())
-				}
-				return
-			}
-		}
-	}()
-
-	time.Sleep(time.Second * 1)
-	t.Run("SSLRedirect", sslRedirect)
-	wg.Wait()
-}
-
-func sslRedirect(t *testing.T) {
-	req, err := http.NewRequest("GET", "http://localhost:8087?hello=world", nil)
-	assert.NoError(t, err)
-
-	r, err := sslClient.Do(req)
-	assert.NoError(t, err)
-	assert.NotNil(t, r.TLS)
-
-	b, err := ioutil.ReadAll(r.Body)
-	assert.NoError(t, err)
-
-	assert.NoError(t, err)
-	assert.Equal(t, 201, r.StatusCode)
-	assert.Equal(t, "WORLD", string(b))
-
-	err2 := r.Body.Close()
-	if err2 != nil {
-		t.Errorf("fail to close the Body: error %v", err2)
-	}
-}
-
-func TestSSLPushPipes(t *testing.T) {
-	cont, err := endure.NewContainer(nil, endure.SetLogLevel(endure.ErrorLevel))
-	assert.NoError(t, err)
-
-	cfg := &config.Viper{
-		Path:   "configs/.rr-ssl-push.yaml",
-		Prefix: "rr",
-	}
-
-	err = cont.RegisterAll(
-		cfg,
-		&rpcPlugin.Plugin{},
-		&logger.ZapLogger{},
-		&server.Plugin{},
-		&httpPlugin.Plugin{},
-	)
-	assert.NoError(t, err)
-
-	err = cont.Init()
-	if err != nil {
-		t.Fatal(err)
-	}
-
-	ch, err := cont.Serve()
-	assert.NoError(t, err)
-
-	sig := make(chan os.Signal, 1)
-	signal.Notify(sig, os.Interrupt, syscall.SIGINT, syscall.SIGTERM)
-
-	wg := &sync.WaitGroup{}
-	wg.Add(1)
-	tt := time.NewTimer(time.Second * 10)
-	go func() {
-		defer wg.Done()
-		for {
-			select {
-			case e := <-ch:
-				assert.Fail(t, "error", e.Error.Error())
-				err = cont.Stop()
-				if err != nil {
-					assert.FailNow(t, "error", err.Error())
-				}
-			case <-sig:
-				err = cont.Stop()
-				if err != nil {
-					assert.FailNow(t, "error", err.Error())
-				}
-				return
-			case <-tt.C:
-				// timeout
-				err = cont.Stop()
-				if err != nil {
-					assert.FailNow(t, "error", err.Error())
-				}
-				return
-			}
-		}
-	}()
-
-	time.Sleep(time.Second * 1)
-	t.Run("SSLPush", sslPush)
-	wg.Wait()
-}
-
-func sslPush(t *testing.T) {
-	req, err := http.NewRequest("GET", "https://localhost:8894?hello=world", nil)
-	assert.NoError(t, err)
-
-	r, err := sslClient.Do(req)
-	assert.NoError(t, err)
-
-	assert.NotNil(t, r.TLS)
-
-	b, err := ioutil.ReadAll(r.Body)
-	assert.NoError(t, err)
-
-	assert.Equal(t, "", r.Header.Get("Http2-Push"))
-
-	assert.NoError(t, err)
-	assert.Equal(t, 201, r.StatusCode)
-	assert.Equal(t, "WORLD", string(b))
-
-	err2 := r.Body.Close()
-	if err2 != nil {
-		t.Errorf("fail to close the Body: error %v", err2)
-	}
-}
-
-func TestFastCGI_RequestUri(t *testing.T) {
-	cont, err := endure.NewContainer(nil, endure.SetLogLevel(endure.ErrorLevel))
-	assert.NoError(t, err)
-
-	cfg := &config.Viper{
-		Path:   "configs/.rr-fcgi-reqUri.yaml",
-		Prefix: "rr",
-	}
-
-	err = cont.RegisterAll(
-		cfg,
-		&logger.ZapLogger{},
-		&server.Plugin{},
-		&httpPlugin.Plugin{},
-	)
-	assert.NoError(t, err)
-
-	err = cont.Init()
-	if err != nil {
-		t.Fatal(err)
-	}
-
-	ch, err := cont.Serve()
-	assert.NoError(t, err)
-
-	sig := make(chan os.Signal, 1)
-	signal.Notify(sig, os.Interrupt, syscall.SIGINT, syscall.SIGTERM)
-
-	wg := &sync.WaitGroup{}
-	wg.Add(1)
-
-	tt := time.NewTimer(time.Second * 10)
-
-	go func() {
-		defer wg.Done()
-		for {
-			select {
-			case e := <-ch:
-				assert.Fail(t, "error", e.Error.Error())
-				err = cont.Stop()
-				if err != nil {
-					assert.FailNow(t, "error", err.Error())
-				}
-			case <-sig:
-				err = cont.Stop()
-				if err != nil {
-					assert.FailNow(t, "error", err.Error())
-				}
-				return
-			case <-tt.C:
-				// timeout
-				err = cont.Stop()
-				if err != nil {
-					assert.FailNow(t, "error", err.Error())
-				}
-				return
-			}
-		}
-	}()
-
-	time.Sleep(time.Second * 1)
-	t.Run("FastCGIServiceRequestUri", fcgiReqURI)
-	wg.Wait()
-}
-
-func fcgiReqURI(t *testing.T) {
-	time.Sleep(time.Second * 2)
-	fcgiConnFactory := gofast.SimpleConnFactory("tcp", "127.0.0.1:6921")
-
-	fcgiHandler := gofast.NewHandler(
-		gofast.BasicParamsMap(gofast.BasicSession),
-		gofast.SimpleClientFactory(fcgiConnFactory, 0),
-	)
-
-	w := httptest.NewRecorder()
-	req := httptest.NewRequest("GET", "http://site.local/hello-world", nil)
-	fcgiHandler.ServeHTTP(w, req)
-
-	body, err := ioutil.ReadAll(w.Result().Body)
-	assert.NoError(t, err)
-	assert.Equal(t, 200, w.Result().StatusCode)
-	assert.Equal(t, "http://site.local/hello-world", string(body))
-}
-
-func TestH2CUpgrade(t *testing.T) {
-	cont, err := endure.NewContainer(nil, endure.SetLogLevel(endure.ErrorLevel))
-	assert.NoError(t, err)
-
-	cfg := &config.Viper{
-		Path:   "configs/.rr-h2c.yaml",
-		Prefix: "rr",
-	}
-
-	err = cont.RegisterAll(
-		cfg,
-		&rpcPlugin.Plugin{},
-		&logger.ZapLogger{},
-		&server.Plugin{},
-		&httpPlugin.Plugin{},
-	)
-	assert.NoError(t, err)
-
-	err = cont.Init()
-	if err != nil {
-		t.Fatal(err)
-	}
-
-	ch, err := cont.Serve()
-	assert.NoError(t, err)
-
-	sig := make(chan os.Signal, 1)
-	signal.Notify(sig, os.Interrupt, syscall.SIGINT, syscall.SIGTERM)
-
-	wg := &sync.WaitGroup{}
-	wg.Add(1)
-
-	tt := time.NewTimer(time.Second * 10)
-
-	go func() {
-		defer wg.Done()
-		for {
-			select {
-			case e := <-ch:
-				assert.Fail(t, "error", e.Error.Error())
-				err = cont.Stop()
-				if err != nil {
-					assert.FailNow(t, "error", err.Error())
-				}
-			case <-sig:
-				err = cont.Stop()
-				if err != nil {
-					assert.FailNow(t, "error", err.Error())
-				}
-				return
-			case <-tt.C:
-				// timeout
-				err = cont.Stop()
-				if err != nil {
-					assert.FailNow(t, "error", err.Error())
-				}
-				return
-			}
-		}
-	}()
-
-	time.Sleep(time.Second * 1)
-	t.Run("H2cUpgrade", h2cUpgrade)
-	wg.Wait()
-}
-
-func h2cUpgrade(t *testing.T) {
-	req, err := http.NewRequest("PRI", "http://localhost:8083?hello=world", nil)
-	if err != nil {
-		t.Fatal(err)
-	}
-
-	req.Header.Add("Upgrade", "h2c")
-	req.Header.Add("Connection", "HTTP2-Settings")
-	req.Header.Add("HTTP2-Settings", "")
-
-	r, err2 := http.DefaultClient.Do(req)
-	if err2 != nil {
-		t.Fatal(err)
-	}
-
-	assert.Equal(t, "101 Switching Protocols", r.Status)
-
-	err3 := r.Body.Close()
-	if err3 != nil {
-		t.Fatal(err)
-	}
-}
-
-func TestH2C(t *testing.T) {
-	cont, err := endure.NewContainer(nil, endure.SetLogLevel(endure.ErrorLevel))
-	assert.NoError(t, err)
-
-	cfg := &config.Viper{
-		Path:   "configs/.rr-h2c.yaml",
-		Prefix: "rr",
-	}
-
-	err = cont.RegisterAll(
-		cfg,
-		&rpcPlugin.Plugin{},
-		&logger.ZapLogger{},
-		&server.Plugin{},
-		&httpPlugin.Plugin{},
-	)
-	assert.NoError(t, err)
-
-	err = cont.Init()
-	if err != nil {
-		t.Fatal(err)
-	}
-
-	ch, err := cont.Serve()
-	assert.NoError(t, err)
-
-	sig := make(chan os.Signal, 1)
-	signal.Notify(sig, os.Interrupt, syscall.SIGINT, syscall.SIGTERM)
-
-	wg := &sync.WaitGroup{}
-	wg.Add(1)
-
-	tt := time.NewTimer(time.Second * 10)
-
-	go func() {
-		defer wg.Done()
-		for {
-			select {
-			case e := <-ch:
-				assert.Fail(t, "error", e.Error.Error())
-				err = cont.Stop()
-				if err != nil {
-					assert.FailNow(t, "error", err.Error())
-				}
-			case <-sig:
-				err = cont.Stop()
-				if err != nil {
-					assert.FailNow(t, "error", err.Error())
-				}
-				return
-			case <-tt.C:
-				// timeout
-				err = cont.Stop()
-				if err != nil {
-					assert.FailNow(t, "error", err.Error())
-				}
-				return
-			}
-		}
-	}()
-
-	time.Sleep(time.Second * 1)
-	t.Run("H2c", h2c)
-	wg.Wait()
-}
-
-func h2c(t *testing.T) {
-	req, err := http.NewRequest("PRI", "http://localhost:8083?hello=world", nil)
-	if err != nil {
-		t.Fatal(err)
-	}
-
-	req.Header.Add("Connection", "HTTP2-Settings")
-	req.Header.Add("HTTP2-Settings", "")
-
-	r, err2 := http.DefaultClient.Do(req)
-	if err2 != nil {
-		t.Fatal(err)
-	}
-
-	assert.Equal(t, "201 Created", r.Status)
-
-	err3 := r.Body.Close()
-	if err3 != nil {
-		t.Fatal(err)
-	}
-}
-
-func TestHttpMiddleware(t *testing.T) {
-	cont, err := endure.NewContainer(nil, endure.SetLogLevel(endure.ErrorLevel))
-	assert.NoError(t, err)
-
-	cfg := &config.Viper{
-		Path:   "configs/.rr-http.yaml",
-		Prefix: "rr",
-	}
-
-	err = cont.RegisterAll(
-		cfg,
-		&rpcPlugin.Plugin{},
-		&logger.ZapLogger{},
-		&server.Plugin{},
-		&httpPlugin.Plugin{},
-		&PluginMiddleware{},
-		&PluginMiddleware2{},
-	)
-	assert.NoError(t, err)
-
-	err = cont.Init()
-	if err != nil {
-		t.Fatal(err)
-	}
-
-	ch, err := cont.Serve()
-	assert.NoError(t, err)
-
-	sig := make(chan os.Signal, 1)
-	signal.Notify(sig, os.Interrupt, syscall.SIGINT, syscall.SIGTERM)
-
-	wg := &sync.WaitGroup{}
-	wg.Add(1)
-
-	tt := time.NewTimer(time.Second * 20)
-
-	go func() {
-		defer wg.Done()
-		for {
-			select {
-			case e := <-ch:
-				assert.Fail(t, "error", e.Error.Error())
-				err = cont.Stop()
-				if err != nil {
-					assert.FailNow(t, "error", err.Error())
-				}
-			case <-sig:
-				err = cont.Stop()
-				if err != nil {
-					assert.FailNow(t, "error", err.Error())
-				}
-				return
-			case <-tt.C:
-				// timeout
-				err = cont.Stop()
-				if err != nil {
-					assert.FailNow(t, "error", err.Error())
-				}
-				return
-			}
-		}
-	}()
-
-	time.Sleep(time.Second * 1)
-	t.Run("MiddlewareTest", middleware)
-	wg.Wait()
-}
-
-func middleware(t *testing.T) {
-	req, err := http.NewRequest("GET", "http://localhost:18903?hello=world", nil)
-	assert.NoError(t, err)
-
-	r, err := http.DefaultClient.Do(req)
-	assert.NoError(t, err)
-
-	b, err := ioutil.ReadAll(r.Body)
-	assert.NoError(t, err)
-
-	assert.Equal(t, 201, r.StatusCode)
-	assert.Equal(t, "WORLD", string(b))
-
-	err = r.Body.Close()
-	assert.NoError(t, err)
-
-	req, err = http.NewRequest("GET", "http://localhost:18903/halt", nil)
-	assert.NoError(t, err)
-
-	r, err = http.DefaultClient.Do(req)
-	assert.NoError(t, err)
-	b, err = ioutil.ReadAll(r.Body)
-	assert.NoError(t, err)
-
-	assert.Equal(t, 500, r.StatusCode)
-	assert.Equal(t, "halted", string(b))
-
-	err = r.Body.Close()
-	assert.NoError(t, err)
-}
-
-func TestHttpEchoErr(t *testing.T) {
-	cont, err := endure.NewContainer(nil, endure.SetLogLevel(endure.ErrorLevel))
-	assert.NoError(t, err)
-
-	cfg := &config.Viper{
-		Path:   "configs/.rr-echoErr.yaml",
-		Prefix: "rr",
-	}
-
-	controller := gomock.NewController(t)
-	mockLogger := mocks.NewMockLogger(controller)
-
-	mockLogger.EXPECT().Debug("http handler response received", "elapsed", gomock.Any(), "remote address", "127.0.0.1")
-	mockLogger.EXPECT().Debug("WORLD", "pid", gomock.Any())
-	mockLogger.EXPECT().Debug("worker event received", "event", events.EventWorkerLog, "worker state", gomock.Any())
-
-	err = cont.RegisterAll(
-		cfg,
-		mockLogger,
-		&server.Plugin{},
-		&httpPlugin.Plugin{},
-		&PluginMiddleware{},
-		&PluginMiddleware2{},
-	)
-	assert.NoError(t, err)
-
-	err = cont.Init()
-	if err != nil {
-		t.Fatal(err)
-	}
-
-	ch, err := cont.Serve()
-	assert.NoError(t, err)
-
-	sig := make(chan os.Signal, 1)
-	signal.Notify(sig, os.Interrupt, syscall.SIGINT, syscall.SIGTERM)
-
-	wg := &sync.WaitGroup{}
-	wg.Add(1)
-
-	tt := time.NewTimer(time.Second * 10)
-
-	go func() {
-		defer wg.Done()
-		for {
-			select {
-			case e := <-ch:
-				assert.Fail(t, "error", e.Error.Error())
-				err = cont.Stop()
-				if err != nil {
-					assert.FailNow(t, "error", err.Error())
-				}
-			case <-sig:
-				err = cont.Stop()
-				if err != nil {
-					assert.FailNow(t, "error", err.Error())
-				}
-				return
-			case <-tt.C:
-				// timeout
-				err = cont.Stop()
-				if err != nil {
-					assert.FailNow(t, "error", err.Error())
-				}
-				return
-			}
-		}
-	}()
-
-	time.Sleep(time.Second * 1)
-	t.Run("HttpEchoError", echoError)
-	wg.Wait()
-}
-
-func echoError(t *testing.T) {
-	req, err := http.NewRequest("GET", "http://localhost:8080?hello=world", nil)
-	assert.NoError(t, err)
-
-	r, err := http.DefaultClient.Do(req)
-	assert.NoError(t, err)
-
-	b, err := ioutil.ReadAll(r.Body)
-	assert.NoError(t, err)
-
-	assert.Equal(t, 201, r.StatusCode)
-	assert.Equal(t, "WORLD", string(b))
-	err = r.Body.Close()
-	assert.NoError(t, err)
-}
-
-func TestHttpEnvVariables(t *testing.T) {
-	cont, err := endure.NewContainer(nil, endure.SetLogLevel(endure.ErrorLevel))
-	assert.NoError(t, err)
-
-	cfg := &config.Viper{
-		Path:   "configs/.rr-env.yaml",
-		Prefix: "rr",
-	}
-
-	err = cont.RegisterAll(
-		cfg,
-		&logger.ZapLogger{},
-		&server.Plugin{},
-		&httpPlugin.Plugin{},
-		&PluginMiddleware{},
-		&PluginMiddleware2{},
-	)
-	assert.NoError(t, err)
-
-	err = cont.Init()
-	if err != nil {
-		t.Fatal(err)
-	}
-
-	ch, err := cont.Serve()
-	assert.NoError(t, err)
-
-	sig := make(chan os.Signal, 1)
-	signal.Notify(sig, os.Interrupt, syscall.SIGINT, syscall.SIGTERM)
-
-	wg := &sync.WaitGroup{}
-	wg.Add(1)
-
-	tt := time.NewTimer(time.Second * 10)
-
-	go func() {
-		defer wg.Done()
-		for {
-			select {
-			case e := <-ch:
-				assert.Fail(t, "error", e.Error.Error())
-				err = cont.Stop()
-				if err != nil {
-					assert.FailNow(t, "error", err.Error())
-				}
-			case <-sig:
-				err = cont.Stop()
-				if err != nil {
-					assert.FailNow(t, "error", err.Error())
-				}
-				return
-			case <-tt.C:
-				// timeout
-				err = cont.Stop()
-				if err != nil {
-					assert.FailNow(t, "error", err.Error())
-				}
-				return
-			}
-		}
-	}()
-
-	time.Sleep(time.Second * 1)
-	t.Run("EnvVariablesTest", envVarsTest)
-	wg.Wait()
-}
-
-func envVarsTest(t *testing.T) {
-	req, err := http.NewRequest("GET", "http://localhost:12084", nil)
-	assert.NoError(t, err)
-
-	r, err := http.DefaultClient.Do(req)
-	assert.NoError(t, err)
-
-	b, err := ioutil.ReadAll(r.Body)
-	assert.NoError(t, err)
-
-	assert.Equal(t, 200, r.StatusCode)
-	assert.Equal(t, "ENV_VALUE", string(b))
-
-	err = r.Body.Close()
-	assert.NoError(t, err)
-}
-
-func TestHttpBrokenPipes(t *testing.T) {
-	cont, err := endure.NewContainer(nil, endure.SetLogLevel(endure.ErrorLevel))
-	assert.NoError(t, err)
-
-	cfg := &config.Viper{
-		Path:   "configs/.rr-broken-pipes.yaml",
-		Prefix: "rr",
-	}
-
-	err = cont.RegisterAll(
-		cfg,
-		&logger.ZapLogger{},
-		&server.Plugin{},
-		&httpPlugin.Plugin{},
-		&PluginMiddleware{},
-		&PluginMiddleware2{},
-	)
-	assert.NoError(t, err)
-
-	err = cont.Init()
-	assert.Error(t, err)
-
-	_, err = cont.Serve()
-	assert.Error(t, err)
-}
-
-func get(url string) (string, *http.Response, error) {
-	r, err := http.Get(url)
-	if err != nil {
-		return "", nil, err
-	}
-	b, err := ioutil.ReadAll(r.Body)
-	if err != nil {
-		return "", nil, err
-	}
-	defer func() {
-		_ = r.Body.Close()
-	}()
-	return string(b), r, err
-}
-
-// get request and return body
-func getHeader(url string, h map[string]string) (string, *http.Response, error) {
-	req, err := http.NewRequest("GET", url, bytes.NewBuffer(nil))
-	if err != nil {
-		return "", nil, err
-	}
-
-	for k, v := range h {
-		req.Header.Set(k, v)
-	}
-
-	r, err := http.DefaultClient.Do(req)
-	if err != nil {
-		return "", nil, err
-	}
-
-	b, err := ioutil.ReadAll(r.Body)
-	if err != nil {
-		return "", nil, err
-	}
-
-	err = r.Body.Close()
-	if err != nil {
-		return "", nil, err
-	}
-	return string(b), r, err
-}
diff --git a/plugins/http/tests/parse_test.go b/plugins/http/tests/parse_test.go
deleted file mode 100644
index a93bc059..00000000
--- a/plugins/http/tests/parse_test.go
+++ /dev/null
@@ -1,54 +0,0 @@
-package tests
-
-import (
-	"testing"
-
-	"github.com/spiral/roadrunner/v2/plugins/http"
-)
-
-var samples = []struct {
-	in  string
-	out []string
-}{
-	{"key", []string{"key"}},
-	{"key[subkey]", []string{"key", "subkey"}},
-	{"key[subkey]value", []string{"key", "subkey", "value"}},
-	{"key[subkey][value]", []string{"key", "subkey", "value"}},
-	{"key[subkey][value][]", []string{"key", "subkey", "value", ""}},
-	{"key[subkey] [value][]", []string{"key", "subkey", "value", ""}},
-	{"key [ subkey ] [ value ] [ ]", []string{"key", "subkey", "value", ""}},
-}
-
-func Test_FetchIndexes(t *testing.T) {
-	for i := 0; i < len(samples); i++ {
-		r := http.FetchIndexes(samples[i].in)
-		if !same(r, samples[i].out) {
-			t.Errorf("got %q, want %q", r, samples[i].out)
-		}
-	}
-}
-
-func BenchmarkConfig_FetchIndexes(b *testing.B) {
-	for _, tt := range samples {
-		for n := 0; n < b.N; n++ {
-			r := http.FetchIndexes(tt.in)
-			if !same(r, tt.out) {
-				b.Fail()
-			}
-		}
-	}
-}
-
-func same(in, out []string) bool {
-	if len(in) != len(out) {
-		return false
-	}
-
-	for i, v := range in {
-		if v != out[i] {
-			return false
-		}
-	}
-
-	return true
-}
diff --git a/plugins/http/tests/plugin1.go b/plugins/http/tests/plugin1.go
deleted file mode 100644
index 7e5c03da..00000000
--- a/plugins/http/tests/plugin1.go
+++ /dev/null
@@ -1,27 +0,0 @@
-package tests
-
-import (
-	"github.com/spiral/roadrunner/v2/interfaces/config"
-)
-
-type Plugin1 struct {
-	config config.Configurer
-}
-
-func (p1 *Plugin1) Init(cfg config.Configurer) error {
-	p1.config = cfg
-	return nil
-}
-
-func (p1 *Plugin1) Serve() chan error {
-	errCh := make(chan error, 1)
-	return errCh
-}
-
-func (p1 *Plugin1) Stop() error {
-	return nil
-}
-
-func (p1 *Plugin1) Name() string {
-	return "http_test.plugin1"
-}
diff --git a/plugins/http/tests/plugin_middleware.go b/plugins/http/tests/plugin_middleware.go
deleted file mode 100644
index 9003c0ad..00000000
--- a/plugins/http/tests/plugin_middleware.go
+++ /dev/null
@@ -1,61 +0,0 @@
-package tests
-
-import (
-	"net/http"
-
-	"github.com/spiral/roadrunner/v2/interfaces/config"
-)
-
-type PluginMiddleware struct {
-	config config.Configurer
-}
-
-func (p *PluginMiddleware) Init(cfg config.Configurer) error {
-	p.config = cfg
-	return nil
-}
-
-func (p *PluginMiddleware) Middleware(next http.Handler) http.HandlerFunc {
-	return func(w http.ResponseWriter, r *http.Request) {
-		if r.URL.Path == "/halt" {
-			w.WriteHeader(500)
-			_, err := w.Write([]byte("halted"))
-			if err != nil {
-				panic("error writing the data to the http reply")
-			}
-		} else {
-			next.ServeHTTP(w, r)
-		}
-	}
-}
-
-func (p *PluginMiddleware) Name() string {
-	return "pluginMiddleware"
-}
-
-type PluginMiddleware2 struct {
-	config config.Configurer
-}
-
-func (p *PluginMiddleware2) Init(cfg config.Configurer) error {
-	p.config = cfg
-	return nil
-}
-
-func (p *PluginMiddleware2) Middleware(next http.Handler) http.HandlerFunc {
-	return func(w http.ResponseWriter, r *http.Request) {
-		if r.URL.Path == "/boom" {
-			w.WriteHeader(555)
-			_, err := w.Write([]byte("boom"))
-			if err != nil {
-				panic("error writing the data to the http reply")
-			}
-		} else {
-			next.ServeHTTP(w, r)
-		}
-	}
-}
-
-func (p *PluginMiddleware2) Name() string {
-	return "pluginMiddleware2"
-}
diff --git a/plugins/http/tests/response_test.go b/plugins/http/tests/response_test.go
deleted file mode 100644
index 7901a0d1..00000000
--- a/plugins/http/tests/response_test.go
+++ /dev/null
@@ -1,163 +0,0 @@
-package tests
-
-import (
-	"bytes"
-	"errors"
-	"net/http"
-	"testing"
-
-	"github.com/spiral/roadrunner/v2/pkg/payload"
-	http2 "github.com/spiral/roadrunner/v2/plugins/http"
-	"github.com/stretchr/testify/assert"
-)
-
-type testWriter struct {
-	h           http.Header
-	buf         bytes.Buffer
-	wroteHeader bool
-	code        int
-	err         error
-	pushErr     error
-	pushes      []string
-}
-
-func (tw *testWriter) Header() http.Header { return tw.h }
-
-func (tw *testWriter) Write(p []byte) (int, error) {
-	if !tw.wroteHeader {
-		tw.WriteHeader(http.StatusOK)
-	}
-
-	n, e := tw.buf.Write(p)
-	if e == nil {
-		e = tw.err
-	}
-
-	return n, e
-}
-
-func (tw *testWriter) WriteHeader(code int) { tw.wroteHeader = true; tw.code = code }
-
-func (tw *testWriter) Push(target string, opts *http.PushOptions) error {
-	tw.pushes = append(tw.pushes, target)
-
-	return tw.pushErr
-}
-
-func TestNewResponse_Error(t *testing.T) {
-	r, err := http2.NewResponse(payload.Payload{Context: []byte(`invalid payload`)})
-	assert.Error(t, err)
-	assert.Nil(t, r)
-}
-
-func TestNewResponse_Write(t *testing.T) {
-	r, err := http2.NewResponse(payload.Payload{
-		Context: []byte(`{"headers":{"key":["value"]},"status": 301}`),
-		Body:    []byte(`sample body`),
-	})
-
-	assert.NoError(t, err)
-	assert.NotNil(t, r)
-
-	w := &testWriter{h: http.Header(make(map[string][]string))}
-	assert.NoError(t, r.Write(w))
-
-	assert.Equal(t, 301, w.code)
-	assert.Equal(t, "value", w.h.Get("key"))
-	assert.Equal(t, "sample body", w.buf.String())
-}
-
-func TestNewResponse_Stream(t *testing.T) {
-	r, err := http2.NewResponse(payload.Payload{
-		Context: []byte(`{"headers":{"key":["value"]},"status": 301}`),
-	})
-
-	// r is pointer, so, it might be nil
-	if r == nil {
-		t.Fatal("response is nil")
-	}
-
-	r.Body = &bytes.Buffer{}
-	r.Body.(*bytes.Buffer).WriteString("hello world")
-
-	assert.NoError(t, err)
-	assert.NotNil(t, r)
-
-	w := &testWriter{h: http.Header(make(map[string][]string))}
-	assert.NoError(t, r.Write(w))
-
-	assert.Equal(t, 301, w.code)
-	assert.Equal(t, "value", w.h.Get("key"))
-	assert.Equal(t, "hello world", w.buf.String())
-}
-
-func TestNewResponse_StreamError(t *testing.T) {
-	r, err := http2.NewResponse(payload.Payload{
-		Context: []byte(`{"headers":{"key":["value"]},"status": 301}`),
-	})
-
-	// r is pointer, so, it might be nil
-	if r == nil {
-		t.Fatal("response is nil")
-	}
-
-	r.Body = &bytes.Buffer{}
-	r.Body.(*bytes.Buffer).WriteString("hello world")
-
-	assert.NoError(t, err)
-	assert.NotNil(t, r)
-
-	w := &testWriter{h: http.Header(make(map[string][]string)), err: errors.New("error")}
-	assert.Error(t, r.Write(w))
-}
-
-func TestWrite_HandlesPush(t *testing.T) {
-	r, err := http2.NewResponse(payload.Payload{
-		Context: []byte(`{"headers":{"Http2-Push":["/test.js"],"content-type":["text/html"]},"status": 200}`),
-	})
-
-	assert.NoError(t, err)
-	assert.NotNil(t, r)
-
-	w := &testWriter{h: http.Header(make(map[string][]string))}
-	assert.NoError(t, r.Write(w))
-
-	assert.Nil(t, w.h["Http2-Push"])
-	assert.Equal(t, []string{"/test.js"}, w.pushes)
-}
-
-func TestWrite_HandlesTrailers(t *testing.T) {
-	r, err := http2.NewResponse(payload.Payload{
-		Context: []byte(`{"headers":{"Trailer":["foo, bar", "baz"],"foo":["test"],"bar":["demo"]},"status": 200}`),
-	})
-
-	assert.NoError(t, err)
-	assert.NotNil(t, r)
-
-	w := &testWriter{h: http.Header(make(map[string][]string))}
-	assert.NoError(t, r.Write(w))
-
-	assert.Nil(t, w.h[http2.TrailerHeaderKey])
-	assert.Nil(t, w.h["foo"]) //nolint:golint,staticcheck
-	assert.Nil(t, w.h["baz"]) //nolint:golint,staticcheck
-
-	assert.Equal(t, "test", w.h.Get("Trailer:foo"))
-	assert.Equal(t, "demo", w.h.Get("Trailer:bar"))
-}
-
-func TestWrite_HandlesHandlesWhitespacesInTrailer(t *testing.T) {
-	r, err := http2.NewResponse(payload.Payload{
-		Context: []byte(
-			`{"headers":{"Trailer":["foo\t,bar  ,    baz"],"foo":["a"],"bar":["b"],"baz":["c"]},"status": 200}`),
-	})
-
-	assert.NoError(t, err)
-	assert.NotNil(t, r)
-
-	w := &testWriter{h: http.Header(make(map[string][]string))}
-	assert.NoError(t, r.Write(w))
-
-	assert.Equal(t, "a", w.h.Get("Trailer:foo"))
-	assert.Equal(t, "b", w.h.Get("Trailer:bar"))
-	assert.Equal(t, "c", w.h.Get("Trailer:baz"))
-}
diff --git a/plugins/http/tests/uploads_config_test.go b/plugins/http/tests/uploads_config_test.go
deleted file mode 100644
index 497cd54f..00000000
--- a/plugins/http/tests/uploads_config_test.go
+++ /dev/null
@@ -1,26 +0,0 @@
-package tests
-
-import (
-	"os"
-	"testing"
-
-	"github.com/spiral/roadrunner/v2/plugins/http"
-	"github.com/stretchr/testify/assert"
-)
-
-func TestFsConfig_Forbids(t *testing.T) {
-	cfg := http.UploadsConfig{Forbid: []string{".php"}}
-
-	assert.True(t, cfg.Forbids("index.php"))
-	assert.True(t, cfg.Forbids("index.PHP"))
-	assert.True(t, cfg.Forbids("phpadmin/index.bak.php"))
-	assert.False(t, cfg.Forbids("index.html"))
-}
-
-func TestFsConfig_TmpFallback(t *testing.T) {
-	cfg := http.UploadsConfig{Dir: "test"}
-	assert.Equal(t, "test", cfg.TmpDir())
-
-	cfg = http.UploadsConfig{Dir: ""}
-	assert.Equal(t, os.TempDir(), cfg.TmpDir())
-}
diff --git a/plugins/http/tests/uploads_test.go b/plugins/http/tests/uploads_test.go
deleted file mode 100644
index f255ec91..00000000
--- a/plugins/http/tests/uploads_test.go
+++ /dev/null
@@ -1,432 +0,0 @@
-package tests
-
-import (
-	"bytes"
-	"context"
-	"crypto/sha512"
-	"encoding/hex"
-	"fmt"
-	"io"
-	"io/ioutil"
-	"mime/multipart"
-	"net/http"
-	"os"
-	"os/exec"
-	"testing"
-	"time"
-
-	j "github.com/json-iterator/go"
-	"github.com/spiral/roadrunner/v2/pkg/pipe"
-	poolImpl "github.com/spiral/roadrunner/v2/pkg/pool"
-	httpPlugin "github.com/spiral/roadrunner/v2/plugins/http"
-	"github.com/stretchr/testify/assert"
-)
-
-var json = j.ConfigCompatibleWithStandardLibrary
-
-const testFile = "uploads_test.go"
-
-func TestHandler_Upload_File(t *testing.T) {
-	pool, err := poolImpl.NewPool(context.Background(),
-		func() *exec.Cmd { return exec.Command("php", "../../../tests/http/client.php", "upload", "pipes") },
-		pipe.NewPipeFactory(),
-		poolImpl.Config{
-			NumWorkers:      1,
-			AllocateTimeout: time.Second * 1000,
-			DestroyTimeout:  time.Second * 1000,
-		})
-	if err != nil {
-		t.Fatal(err)
-	}
-
-	h, err := httpPlugin.NewHandler(1024, httpPlugin.UploadsConfig{
-		Dir:    os.TempDir(),
-		Forbid: []string{},
-	}, nil, pool)
-	assert.NoError(t, err)
-
-	hs := &http.Server{Addr: ":8021", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err := hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 10)
-
-	var mb bytes.Buffer
-	w := multipart.NewWriter(&mb)
-
-	f := mustOpen(testFile)
-	defer func() {
-		err := f.Close()
-		if err != nil {
-			t.Errorf("failed to close a file: error %v", err)
-		}
-	}()
-	fw, err := w.CreateFormFile("upload", f.Name())
-	assert.NotNil(t, fw)
-	assert.NoError(t, err)
-	_, err = io.Copy(fw, f)
-	if err != nil {
-		t.Errorf("error copying the file: error %v", err)
-	}
-
-	err = w.Close()
-	if err != nil {
-		t.Errorf("error closing the file: error %v", err)
-	}
-
-	req, err := http.NewRequest("POST", "http://localhost"+hs.Addr, &mb)
-	assert.NoError(t, err)
-
-	req.Header.Set("Content-Type", w.FormDataContentType())
-
-	r, err := http.DefaultClient.Do(req)
-	assert.NoError(t, err)
-	defer func() {
-		err := r.Body.Close()
-		if err != nil {
-			t.Errorf("error closing the Body: error %v", err)
-		}
-	}()
-
-	b, err := ioutil.ReadAll(r.Body)
-	assert.NoError(t, err)
-
-	assert.NoError(t, err)
-	assert.Equal(t, 200, r.StatusCode)
-
-	fs := fileString(testFile, 0, "application/octet-stream")
-
-	assert.Equal(t, `{"upload":`+fs+`}`, string(b))
-}
-
-func TestHandler_Upload_NestedFile(t *testing.T) {
-	pool, err := poolImpl.NewPool(context.Background(),
-		func() *exec.Cmd { return exec.Command("php", "../../../tests/http/client.php", "upload", "pipes") },
-		pipe.NewPipeFactory(),
-		poolImpl.Config{
-			NumWorkers:      1,
-			AllocateTimeout: time.Second * 1000,
-			DestroyTimeout:  time.Second * 1000,
-		})
-	if err != nil {
-		t.Fatal(err)
-	}
-
-	h, err := httpPlugin.NewHandler(1024, httpPlugin.UploadsConfig{
-		Dir:    os.TempDir(),
-		Forbid: []string{},
-	}, nil, pool)
-	assert.NoError(t, err)
-
-	hs := &http.Server{Addr: ":8021", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err := hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 10)
-
-	var mb bytes.Buffer
-	w := multipart.NewWriter(&mb)
-
-	f := mustOpen(testFile)
-	defer func() {
-		err := f.Close()
-		if err != nil {
-			t.Errorf("failed to close a file: error %v", err)
-		}
-	}()
-	fw, err := w.CreateFormFile("upload[x][y][z][]", f.Name())
-	assert.NotNil(t, fw)
-	assert.NoError(t, err)
-	_, err = io.Copy(fw, f)
-	if err != nil {
-		t.Errorf("error copying the file: error %v", err)
-	}
-
-	err = w.Close()
-	if err != nil {
-		t.Errorf("error closing the file: error %v", err)
-	}
-
-	req, err := http.NewRequest("POST", "http://localhost"+hs.Addr, &mb)
-	assert.NoError(t, err)
-
-	req.Header.Set("Content-Type", w.FormDataContentType())
-
-	r, err := http.DefaultClient.Do(req)
-	assert.NoError(t, err)
-	defer func() {
-		err := r.Body.Close()
-		if err != nil {
-			t.Errorf("error closing the Body: error %v", err)
-		}
-	}()
-
-	b, err := ioutil.ReadAll(r.Body)
-	assert.NoError(t, err)
-
-	assert.NoError(t, err)
-	assert.Equal(t, 200, r.StatusCode)
-
-	fs := fileString(testFile, 0, "application/octet-stream")
-
-	assert.Equal(t, `{"upload":{"x":{"y":{"z":[`+fs+`]}}}}`, string(b))
-}
-
-func TestHandler_Upload_File_NoTmpDir(t *testing.T) {
-	pool, err := poolImpl.NewPool(context.Background(),
-		func() *exec.Cmd { return exec.Command("php", "../../../tests/http/client.php", "upload", "pipes") },
-		pipe.NewPipeFactory(),
-		poolImpl.Config{
-			NumWorkers:      1,
-			AllocateTimeout: time.Second * 1000,
-			DestroyTimeout:  time.Second * 1000,
-		})
-	if err != nil {
-		t.Fatal(err)
-	}
-
-	h, err := httpPlugin.NewHandler(1024, httpPlugin.UploadsConfig{
-		Dir:    "-------",
-		Forbid: []string{},
-	}, nil, pool)
-	assert.NoError(t, err)
-
-	hs := &http.Server{Addr: ":8021", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err := hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 10)
-
-	var mb bytes.Buffer
-	w := multipart.NewWriter(&mb)
-
-	f := mustOpen(testFile)
-	defer func() {
-		err := f.Close()
-		if err != nil {
-			t.Errorf("failed to close a file: error %v", err)
-		}
-	}()
-	fw, err := w.CreateFormFile("upload", f.Name())
-	assert.NotNil(t, fw)
-	assert.NoError(t, err)
-	_, err = io.Copy(fw, f)
-	if err != nil {
-		t.Errorf("error copying the file: error %v", err)
-	}
-
-	err = w.Close()
-	if err != nil {
-		t.Errorf("error closing the file: error %v", err)
-	}
-
-	req, err := http.NewRequest("POST", "http://localhost"+hs.Addr, &mb)
-	assert.NoError(t, err)
-
-	req.Header.Set("Content-Type", w.FormDataContentType())
-
-	r, err := http.DefaultClient.Do(req)
-	assert.NoError(t, err)
-	defer func() {
-		err := r.Body.Close()
-		if err != nil {
-			t.Errorf("error closing the Body: error %v", err)
-		}
-	}()
-
-	b, err := ioutil.ReadAll(r.Body)
-	assert.NoError(t, err)
-
-	assert.NoError(t, err)
-	assert.Equal(t, 200, r.StatusCode)
-
-	fs := fileString(testFile, 6, "application/octet-stream")
-
-	assert.Equal(t, `{"upload":`+fs+`}`, string(b))
-}
-
-func TestHandler_Upload_File_Forbids(t *testing.T) {
-	pool, err := poolImpl.NewPool(context.Background(),
-		func() *exec.Cmd { return exec.Command("php", "../../../tests/http/client.php", "upload", "pipes") },
-		pipe.NewPipeFactory(),
-		poolImpl.Config{
-			NumWorkers:      1,
-			AllocateTimeout: time.Second * 1000,
-			DestroyTimeout:  time.Second * 1000,
-		})
-	if err != nil {
-		t.Fatal(err)
-	}
-
-	h, err := httpPlugin.NewHandler(1024, httpPlugin.UploadsConfig{
-		Dir:    os.TempDir(),
-		Forbid: []string{".go"},
-	}, nil, pool)
-	assert.NoError(t, err)
-
-	hs := &http.Server{Addr: ":8021", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err := hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 10)
-
-	var mb bytes.Buffer
-	w := multipart.NewWriter(&mb)
-
-	f := mustOpen(testFile)
-	defer func() {
-		err := f.Close()
-		if err != nil {
-			t.Errorf("failed to close a file: error %v", err)
-		}
-	}()
-	fw, err := w.CreateFormFile("upload", f.Name())
-	assert.NotNil(t, fw)
-	assert.NoError(t, err)
-	_, err = io.Copy(fw, f)
-	if err != nil {
-		t.Errorf("error copying the file: error %v", err)
-	}
-
-	err = w.Close()
-	if err != nil {
-		t.Errorf("error closing the file: error %v", err)
-	}
-
-	req, err := http.NewRequest("POST", "http://localhost"+hs.Addr, &mb)
-	assert.NoError(t, err)
-
-	req.Header.Set("Content-Type", w.FormDataContentType())
-
-	r, err := http.DefaultClient.Do(req)
-	assert.NoError(t, err)
-	defer func() {
-		err := r.Body.Close()
-		if err != nil {
-			t.Errorf("error closing the Body: error %v", err)
-		}
-	}()
-
-	b, err := ioutil.ReadAll(r.Body)
-	assert.NoError(t, err)
-
-	assert.NoError(t, err)
-	assert.Equal(t, 200, r.StatusCode)
-
-	fs := fileString(testFile, 8, "application/octet-stream")
-
-	assert.Equal(t, `{"upload":`+fs+`}`, string(b))
-}
-
-func Test_FileExists(t *testing.T) {
-	assert.True(t, exists(testFile))
-	assert.False(t, exists("uploads_test."))
-}
-
-func mustOpen(f string) *os.File {
-	r, err := os.Open(f)
-	if err != nil {
-		panic(err)
-	}
-	return r
-}
-
-type fInfo struct {
-	Name   string `json:"name"`
-	Size   int64  `json:"size"`
-	Mime   string `json:"mime"`
-	Error  int    `json:"error"`
-	Sha512 string `json:"sha512,omitempty"`
-}
-
-func fileString(f string, errNo int, mime string) string {
-	s, err := os.Stat(f)
-	if err != nil {
-		fmt.Println(fmt.Errorf("error stat the file, error: %v", err))
-	}
-
-	ff, err := os.Open(f)
-	if err != nil {
-		fmt.Println(fmt.Errorf("error opening the file, error: %v", err))
-	}
-
-	defer func() {
-		er := ff.Close()
-		if er != nil {
-			fmt.Println(fmt.Errorf("error closing the file, error: %v", er))
-		}
-	}()
-
-	h := sha512.New()
-	_, err = io.Copy(h, ff)
-	if err != nil {
-		fmt.Println(fmt.Errorf("error copying the file, error: %v", err))
-	}
-
-	v := &fInfo{
-		Name:   s.Name(),
-		Size:   s.Size(),
-		Error:  errNo,
-		Mime:   mime,
-		Sha512: hex.EncodeToString(h.Sum(nil)),
-	}
-
-	if errNo != 0 {
-		v.Sha512 = ""
-		v.Size = 0
-	}
-
-	r, err := json.Marshal(v)
-	if err != nil {
-		fmt.Println(fmt.Errorf("error marshalling fInfo, error: %v", err))
-	}
-	return string(r)
-}
-
-// exists if file exists.
-func exists(path string) bool {
-	if _, err := os.Stat(path); os.IsNotExist(err) {
-		return false
-	}
-	return true
-}
diff --git a/plugins/http/uploads.go b/plugins/http/uploads.go
deleted file mode 100644
index aeb41591..00000000
--- a/plugins/http/uploads.go
+++ /dev/null
@@ -1,158 +0,0 @@
-package http
-
-import (
-	"github.com/spiral/roadrunner/v2/interfaces/log"
-
-	"io"
-	"io/ioutil"
-	"mime/multipart"
-	"os"
-	"sync"
-)
-
-const (
-	// UploadErrorOK - no error, the file uploaded with success.
-	UploadErrorOK = 0
-
-	// UploadErrorNoFile - no file was uploaded.
-	UploadErrorNoFile = 4
-
-	// UploadErrorNoTmpDir - missing a temporary folder.
-	UploadErrorNoTmpDir = 6
-
-	// UploadErrorCantWrite - failed to write file to disk.
-	UploadErrorCantWrite = 7
-
-	// UploadErrorExtension - forbidden file extension.
-	UploadErrorExtension = 8
-)
-
-// Uploads tree manages uploaded files tree and temporary files.
-type Uploads struct {
-	// associated temp directory and forbidden extensions.
-	cfg UploadsConfig
-
-	// pre processed data tree for Uploads.
-	tree fileTree
-
-	// flat list of all file Uploads.
-	list []*FileUpload
-}
-
-// MarshalJSON marshal tree tree into JSON.
-func (u *Uploads) MarshalJSON() ([]byte, error) {
-	return json.Marshal(u.tree)
-}
-
-// Open moves all uploaded files to temp directory, return error in case of issue with temp directory. File errors
-// will be handled individually.
-func (u *Uploads) Open(log log.Logger) {
-	var wg sync.WaitGroup
-	for _, f := range u.list {
-		wg.Add(1)
-		go func(f *FileUpload) {
-			defer wg.Done()
-			err := f.Open(u.cfg)
-			if err != nil && log != nil {
-				log.Error("error opening the file", "err", err)
-			}
-		}(f)
-	}
-
-	wg.Wait()
-}
-
-// Clear deletes all temporary files.
-func (u *Uploads) Clear(log log.Logger) {
-	for _, f := range u.list {
-		if f.TempFilename != "" && exists(f.TempFilename) {
-			err := os.Remove(f.TempFilename)
-			if err != nil && log != nil {
-				log.Error("error removing the file", "err", err)
-			}
-		}
-	}
-}
-
-// FileUpload represents singular file NewUpload.
-type FileUpload struct {
-	// ID contains filename specified by the client.
-	Name string `json:"name"`
-
-	// Mime contains mime-type provided by the client.
-	Mime string `json:"mime"`
-
-	// Size of the uploaded file.
-	Size int64 `json:"size"`
-
-	// Error indicates file upload error (if any). See http://php.net/manual/en/features.file-upload.errors.php
-	Error int `json:"error"`
-
-	// TempFilename points to temporary file location.
-	TempFilename string `json:"tmpName"`
-
-	// associated file header
-	header *multipart.FileHeader
-}
-
-// NewUpload wraps net/http upload into PRS-7 compatible structure.
-func NewUpload(f *multipart.FileHeader) *FileUpload {
-	return &FileUpload{
-		Name:   f.Filename,
-		Mime:   f.Header.Get("Content-Type"),
-		Error:  UploadErrorOK,
-		header: f,
-	}
-}
-
-// Open moves file content into temporary file available for PHP.
-// NOTE:
-// There is 2 deferred functions, and in case of getting 2 errors from both functions
-// error from close of temp file would be overwritten by error from the main file
-// STACK
-// DEFER FILE CLOSE (2)
-// DEFER TMP CLOSE  (1)
-func (f *FileUpload) Open(cfg UploadsConfig) (err error) {
-	if cfg.Forbids(f.Name) {
-		f.Error = UploadErrorExtension
-		return nil
-	}
-
-	file, err := f.header.Open()
-	if err != nil {
-		f.Error = UploadErrorNoFile
-		return err
-	}
-
-	defer func() {
-		// close the main file
-		err = file.Close()
-	}()
-
-	tmp, err := ioutil.TempFile(cfg.TmpDir(), "upload")
-	if err != nil {
-		// most likely cause of this issue is missing tmp dir
-		f.Error = UploadErrorNoTmpDir
-		return err
-	}
-
-	f.TempFilename = tmp.Name()
-	defer func() {
-		// close the temp file
-		err = tmp.Close()
-	}()
-
-	if f.Size, err = io.Copy(tmp, file); err != nil {
-		f.Error = UploadErrorCantWrite
-	}
-
-	return err
-}
-
-// exists if file exists.
-func exists(path string) bool {
-	if _, err := os.Stat(path); os.IsNotExist(err) {
-		return false
-	}
-	return true
-}
diff --git a/plugins/http/uploads_config.go b/plugins/http/uploads_config.go
deleted file mode 100644
index 4c20c8e8..00000000
--- a/plugins/http/uploads_config.go
+++ /dev/null
@@ -1,46 +0,0 @@
-package http
-
-import (
-	"os"
-	"path"
-	"strings"
-)
-
-// UploadsConfig describes file location and controls access to them.
-type UploadsConfig struct {
-	// Dir contains name of directory to control access to.
-	Dir string
-
-	// Forbid specifies list of file extensions which are forbidden for access.
-	// Example: .php, .exe, .bat, .htaccess and etc.
-	Forbid []string
-}
-
-// InitDefaults sets missing values to their default values.
-func (cfg *UploadsConfig) InitDefaults() error {
-	cfg.Forbid = []string{".php", ".exe", ".bat"}
-	cfg.Dir = os.TempDir()
-	return nil
-}
-
-// TmpDir returns temporary directory.
-func (cfg *UploadsConfig) TmpDir() string {
-	if cfg.Dir != "" {
-		return cfg.Dir
-	}
-
-	return os.TempDir()
-}
-
-// Forbids must return true if file extension is not allowed for the upload.
-func (cfg *UploadsConfig) Forbids(filename string) bool {
-	ext := strings.ToLower(path.Ext(filename))
-
-	for _, v := range cfg.Forbid {
-		if ext == v {
-			return true
-		}
-	}
-
-	return false
-}