add test case for invoke in process gateway

examples/internal/integration/integration_test.go

@@ -1660,13 +1660,19 @@ func testResponseStrings(t *testing.T, port int) {
 }
 
 func TestRequestQueryParams(t *testing.T) {
+	testRequestQueryParams(t, 8088)
+}
+
+func TestRequestQueryParamsInProcessGateway(t *testing.T) {
+	testRequestQueryParams(t, 8089)
+}
+
+func testRequestQueryParams(t *testing.T, port int) {
 	if testing.Short() {
 		t.Skip()
 		return
 	}
 
-	port := 8088
-
 	formValues := url.Values{}
 	formValues.Set("string_value", "hello-world")
 	formValues.Add("repeated_string_value", "demo1")

examples/internal/integration/main_test.go

@@ -57,7 +57,7 @@ func waitForGateway(ctx context.Context, port uint16) error {
 }
 
 func runServers(ctx context.Context) <-chan error {
-	ch := make(chan error, 2)
+	ch := make(chan error, 3)
 	go func() {
 		if err := server.Run(ctx, *network, *endpoint); err != nil {
 			ch <- fmt.Errorf("cannot run grpc service: %v", err)
@@ -68,6 +68,11 @@ func runServers(ctx context.Context) <-chan error {
 			ch <- fmt.Errorf("cannot run gateway service: %v", err)
 		}
 	}()
+	go func() {
+		if err := server.RunInProcessGateway(ctx, ":8089"); err != nil {
+			ch <- fmt.Errorf("cannot run in process gateway service: %v", err)
+		}
+	}()
 	return ch
 }
 

examples/internal/server/main.go

@@ -3,9 +3,11 @@ package server
 import (
 	"context"
 	"net"
+	"net/http"
 
 	"github.com/golang/glog"
 	examples "github.com/grpc-ecosystem/grpc-gateway/examples/internal/proto/examplepb"
+	"github.com/grpc-ecosystem/grpc-gateway/runtime"
 	"google.golang.org/grpc"
 )
 
@@ -38,3 +40,37 @@ func Run(ctx context.Context, network, address string) error {
 	}()
 	return s.Serve(l)
 }
+
+// RunInProcessGateway starts the invoke in process http gateway.
+func RunInProcessGateway(ctx context.Context, addr string, opts ...runtime.ServeMuxOption) error {
+	mux := runtime.NewServeMux(opts...)
+
+	examples.RegisterEchoServiceHandlerServer(ctx, mux, newEchoServer())
+	examples.RegisterFlowCombinationHandlerServer(ctx, mux, newFlowCombinationServer())
+	examples.RegisterNonStandardServiceHandlerServer(ctx, mux, newNonStandardServer())
+
+	abe := newABitOfEverythingServer()
+	examples.RegisterABitOfEverythingServiceHandlerServer(ctx, mux, abe)
+	examples.RegisterStreamServiceHandlerServer(ctx, mux, abe)
+	examples.RegisterResponseBodyServiceHandlerServer(ctx, mux, newResponseBodyServer())
+
+	s := &http.Server{
+		Addr:    addr,
+		Handler: mux,
+	}
+
+	go func() {
+		<-ctx.Done()
+		glog.Infof("Shutting down the http gateway server")
+		if err := s.Shutdown(context.Background()); err != nil {
+			glog.Errorf("Failed to shutdown http gateway server: %v", err)
+		}
+	}()
+
+	if err := s.ListenAndServe(); err != http.ErrServerClosed {
+		glog.Errorf("Failed to listen and serve: %v", err)
+		return err
+	}
+	return nil
+
+}