init openapi

Author: huan

openapi/.gitignore

@@ -0,0 +1,3 @@
+gen/
+gateway
+go.sum

openapi/Makefile

@@ -0,0 +1,46 @@
+PROTOC=protoc \
+	-I ../proto/ \
+	-I ../proto/wechaty/ \
+	../proto/wechaty/puppet.proto \
+
+.PHONY: all
+all: clean generate reverse_proxy_server
+
+.PHONY: clean
+clean:
+	rm -fr gen/*
+
+.PHONY: install
+install:
+	[ -d gen ] || mkdir gen
+	go install \
+		github.com/grpc-ecosystem/grpc-gateway/v2/protoc-gen-grpc-gateway \
+		github.com/grpc-ecosystem/grpc-gateway/v2/protoc-gen-openapiv2 \
+		google.golang.org/protobuf/cmd/protoc-gen-go \
+		google.golang.org/grpc/cmd/protoc-gen-go-grpc
+	go mod tidy
+
+.PHONY: generate
+generate: gen_protobuf gen_gateway gen_openapi
+
+.PHONY: gen_protobuf
+gen_protobuf:
+	${PROTOC} \
+		--go_out ./gen/ --go_opt paths=source_relative \
+		--go-grpc_out ./gen/ --go-grpc_opt paths=source_relative \
+		../proto/wechaty/puppet.proto
+
+.PHONY: gen_gateway
+gen_gateway:
+	${PROTOC} \
+		--grpc-gateway_out ./gen/ \
+		--grpc-gateway_opt logtostderr=true \
+		--grpc-gateway_opt paths=source_relative \
+		--grpc-gateway_opt generate_unbound_methods=true \
+
+.PHONY: gen_openapi
+gen_openapi:
+	${PROTOC} \
+		--openapiv2_out ./gen/ \
+		--openapiv2_opt logtostderr=true \
+

openapi/README.md

@@ -0,0 +1,2 @@
+
+gRPC Gateway: <https://github.com/grpc-ecosystem/grpc-gateway>

openapi/gateway.go

@@ -0,0 +1,46 @@
+package main
+
+import (
+	"context"
+	"flag"
+	"net/http"
+
+	"github.com/golang/glog"
+	"github.com/grpc-ecosystem/grpc-gateway/v2/runtime"
+	"google.golang.org/grpc"
+
+	"github.com/wechaty/go-grpc/openapi/gen/wechaty" // Update
+)
+
+var (
+	// command-line options:
+	// gRPC server endpoint
+	grpcServerEndpoint = flag.String("grpc-server-endpoint", "localhost:9090", "gRPC server endpoint")
+)
+
+func run() error {
+	ctx := context.Background()
+	ctx, cancel := context.WithCancel(ctx)
+	defer cancel()
+
+	// Register gRPC server endpoint
+	// Note: Make sure the gRPC server is running properly and accessible
+	mux := runtime.NewServeMux()
+	opts := []grpc.DialOption{grpc.WithInsecure()}
+	err := wechaty.RegisterPuppetHandlerFromEndpoint(ctx, mux, *grpcServerEndpoint, opts)
+	if err != nil {
+		return err
+	}
+
+	// Start HTTP server (and proxy calls to gRPC server endpoint)
+	return http.ListenAndServe(":8081", mux)
+}
+
+func main() {
+	flag.Parse()
+	defer glog.Flush()
+
+	if err := run(); err != nil {
+		glog.Fatal(err)
+	}
+}

openapi/go.mod

@@ -0,0 +1,13 @@
+module github.com/wechaty/go-grpc/openapi
+
+go 1.16
+
+require (
+	github.com/golang/glog v0.0.0-20160126235308-23def4e6c14b
+	github.com/golang/protobuf v1.4.3
+	github.com/grpc-ecosystem/grpc-gateway/v2 v2.1.0
+	github.com/wechaty/go-grpc v0.18.12
+	google.golang.org/grpc v1.34.0
+	google.golang.org/grpc/cmd/protoc-gen-go-grpc v1.1.0
+	google.golang.org/protobuf v1.25.0
+)

openapi/main.go

@@ -0,0 +1,10 @@
+// +build tools
+
+package tools
+
+import (
+	_ "github.com/grpc-ecosystem/grpc-gateway/v2/protoc-gen-grpc-gateway"
+	_ "github.com/grpc-ecosystem/grpc-gateway/v2/protoc-gen-openapiv2"
+	_ "google.golang.org/grpc/cmd/protoc-gen-go-grpc"
+	_ "google.golang.org/protobuf/cmd/protoc-gen-go"
+)