Function TestHttp

tests/http_test.go:18–63

(t *testing.T)

const httpTestAddr = "127.0.0.1:8081"

func TestHttp(t *testing.T) {

	p := peer.NewGenericPeer("http.Acceptor", "httpserver", httpTestAddr, nil)

	proc.BindProcessorHandler(p, "http", func(raw cellnet.Event) {

		if matcher, ok := raw.Session().(httppeer.RequestMatcher); ok {
			switch {
			case matcher.Match("GET", "/hello_get"):

				// 默认返回json
				raw.Session().Send(&httppeer.MessageRespond{
					Msg: &HttpEchoACK{
						Token: "get",
					},
				})
			case matcher.Match("POST", "/hello_post"):

				// 默认返回json
				raw.Session().Send(&httppeer.MessageRespond{
					Msg: &HttpEchoACK{
						Token: "post",
					},
				})

			}
		}

	})

	p.Start()

	requestThenValid(t, "GET", "/hello_get", &HttpEchoREQ{
		UserName: "kitty_get",
	}, &HttpEchoACK{
		Token: "get",
	})

	requestThenValid(t, "POST", "/hello_post", &HttpEchoREQ{
		UserName: "kitty_post",
	}, &HttpEchoACK{
		Token: "post",
	})

	p.Stop()
}

func requestThenValid(t *testing.T, method, path string, req, expectACK interface{}) {