Function TestMiddlewareWithPrettify

middleware_test.go:130–154

(t *testing.T)

}

func TestMiddlewareWithPrettify(t *testing.T) {
	Settings.PrettifyHTTP = true
	quit := make(chan struct{})
	in := NewTestInput()
	cmd, cancl := initCmd(echoSh, noDebug)
	midd := initMiddleware(cmd, cancl, in, func(err error) {})
	var b1 = []byte("POST / HTTP/1.1\r\nHost: example.org\r\nTransfer-Encoding: chunked\r\n\r\n4\r\nWiki\r\n5\r\npedia\r\nE\r\n in\r\n\r\nchunks.\r\n0\r\n\r\n")
	var b2 = []byte("POST / HTTP/1.1\r\nHost: example.org\r\nContent-Length: 25\r\n\r\nWikipedia in\r\n\r\nchunks.")
	out := NewTestOutput(func(msg *Message) {
		if !bytes.Equal(proto.Body(b2), proto.Body(msg.Data)) {
			t.Errorf("expected %q body to equal %q body", b2, msg.Data)
		}
		quit <- struct{}{}
	})
	pl := &InOutPlugins{}
	pl.Inputs = []PluginReader{midd, in}
	pl.Outputs = []PluginWriter{out}
	pl.All = []interface{}{midd, out, in}
	e := NewEmitter()
	go e.Start(pl, "")
	in.EmitBytes(b1)
	<-quit
	midd.Close()
	Settings.PrettifyHTTP = false
}