feat(server): add visualizer internal api [VIZ-1517, VIZ-1604] (#1574)

Author: hexaforce

server/.env.example

@@ -28,6 +28,9 @@ REEARTH_COGNITO_CLIENTID=
 # Local Mock Auth
 REEARTH_MOCKAUTH=
 
+# Internal API
+REEARTH_VISUALIZER_INTERNALAPI_ACTIVE=false
+
 # Auth client
 #REEARTH_AUTH_ISS=https://hoge.com
 #REEARTH_AUTH_AUD=https://api.reearth.example.com

server/Makefile

@@ -114,6 +114,17 @@ deep-copy:
 error-msg:
 	go generate ./pkg/i18n/...
 
+grpc:
+	protoc --go_out=./internal/adapter/internalapi/ --go_opt=paths=source_relative \
+      --go-grpc_out=./internal/adapter/internalapi/ --go-grpc_opt=paths=source_relative  \
+        ./schemas/internalapi/v1/schema.proto
+
+grpc-doc:
+	protoc -I . \
+	  --doc_out=schemas/internalapi/docs \
+	  --doc_opt=markdown,schema.md \
+	  schemas/internalapi/v1/schema.proto
+
 # =======================
 # Tools
 # =======================

server/e2e/common.go

@@ -33,13 +33,26 @@ import (
 )
 
 var (
-	fr                 *gateway.File
+	fr *gateway.File
+
 	disabledAuthConfig = &config.Config{
 		Origins: []string{"https://example.com"},
 		AuthSrv: config.AuthSrvConfig{
 			Disabled: true,
 		},
 	}
+
+	internalApiConfig = &config.Config{
+		Origins: []string{"https://example.com"},
+		AuthSrv: config.AuthSrvConfig{
+			Disabled: true,
+		},
+		Visualizer: config.VisualizerConfig{
+			InternalApi: config.InternalApiConfig{
+				Active: true,
+			},
+		},
+	}
 )
 
 type Seeder func(ctx context.Context, r *repo.Container, f gateway.File) error
@@ -109,20 +122,38 @@ func StartGQLServerWithRepos(t *testing.T, cfg *config.Config, repos *repo.Conta
 	}
 
 	ctx := context.Background()
-	l, err := net.Listen("tcp", ":0")
-	if err != nil {
-		t.Fatalf("server failed to listen: %v", err)
-	}
 
 	srv, gateways, accountGateway := initServerWithAccountGateway(cfg, repos, ctx)
 
 	ch := make(chan error)
-	go func() {
-		if err := srv.Serve(l); err != http.ErrServerClosed {
-			ch <- err
+
+	var l net.Listener
+	var err error
+
+	if cfg.Visualizer.InternalApi.Active {
+		l, err = net.Listen("tcp", ":8080")
+		if err != nil {
+			t.Fatalf("server failed to listen: %v", err)
 		}
-		close(ch)
-	}()
+		go func() {
+			if err := srv.ServeGRPC(l); err != http.ErrServerClosed {
+				ch <- err
+			}
+			close(ch)
+		}()
+	} else {
+		l, err = net.Listen("tcp", ":0")
+		if err != nil {
+			t.Fatalf("server failed to listen: %v", err)
+		}
+		go func() {
+			if err := srv.Serve(l); err != http.ErrServerClosed {
+				ch <- err
+			}
+			close(ch)
+		}()
+	}
+
 	t.Cleanup(func() {
 		if err := srv.Shutdown(context.Background()); err != nil {
 			t.Fatalf("server shutdown: %v", err)
@@ -132,6 +163,7 @@ func StartGQLServerWithRepos(t *testing.T, cfg *config.Config, repos *repo.Conta
 			t.Fatalf("server serve: %v", err)
 		}
 	})
+
 	return httpexpect.Default(t, "http://"+l.Addr().String()), gateways, accountGateway
 }
 
@@ -151,6 +183,10 @@ func ServerAndRepos(t *testing.T, seeder Seeder) (*httpexpect.Expect, *repo.Cont
 	return startServer(t, disabledAuthConfig, true, seeder)
 }
 
+func GRPCServer(t *testing.T, seeder Seeder) (*httpexpect.Expect, *repo.Container, *gateway.Container) {
+	return startServer(t, internalApiConfig, true, seeder)
+}
+
 func Server(t *testing.T, seeder Seeder) *httpexpect.Expect {
 	e, _, _ := startServer(t, disabledAuthConfig, true, seeder)
 	return e