Adding boilerplate code to easily migrate grpc endpoints

.github/workflows/ci.yml

@@ -22,6 +22,32 @@ jobs:
     - name: Test
       run: make test
 
+
+  generated-files-integrity:
+    runs-on: ubuntu-20.04
+    steps:
+      - name: Install Go
+        uses: actions/setup-go@v2
+        with:
+          go-version: 1.14.x
+      - uses: actions/checkout@v2
+      - name: Install dependencies
+        run: |
+          cd code/go/0chain.net/blobbercore
+          sudo apt-get update
+          sudo apt-get install -y protobuf-compiler
+          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
+          git reset --hard
+      - name: Generate Files
+        run: |
+          cd code/go/0chain.net/blobbercore
+          ./scripts/generate-grpc.sh
+      - name: Fail if any file has changed
+        run: if output=$(git status --porcelain) && [ -z "$output" ]; then exit 0; else git status; exit 1; fi;
+
   dockerize_blobber:
     runs-on: ubuntu-20.04
     needs: test

code/go/0chain.net/blobber/go.mod

@@ -15,6 +15,9 @@ require (
 	github.com/gorilla/mux v1.7.3
 	github.com/spf13/viper v1.7.0
 	go.uber.org/zap v1.15.0
+	golang.org/x/sys v0.0.0-20200420163511-1957bb5e6d1f // indirect
+	golang.org/x/tools v0.0.0-20200207183749-b753a1ba74fa // indirect
+	google.golang.org/grpc v1.33.1
 )
 
 go 1.13

code/go/0chain.net/blobber/main.go

@@ -6,6 +6,7 @@ import (
 	"fmt"
 	"io"
 	"log"
+	"net"
 	"net/http"
 	"net/url"
 	"os"
@@ -232,6 +233,7 @@ func main() {
 	metadataDB = flag.String("db_dir", "", "db_dir")
 	logDir := flag.String("log_dir", "", "log_dir")
 	portString := flag.String("port", "", "port")
+	grpcPortString := flag.String("grpc_port", "", "grpc_port")
 	hostname := flag.String("hostname", "", "hostname")
 
 	flag.Parse()
@@ -266,6 +268,10 @@ func main() {
 		panic("Please specify --port which is the port on which requests are accepted")
 	}
 
+	if *grpcPortString == "" {
+		panic("Please specify --grpc_port which is the grpc port on which requests are accepted")
+	}
+
 	reader, err := os.Open(*keysFile)
 	if err != nil {
 		panic(err)
@@ -346,6 +352,9 @@ func main() {
 	initHandlers(r)
 	initServer()
 
+	grpcServer := handler.NewServerWithMiddlewares()
+	handler.RegisterGRPCServices(r, grpcServer)
+
 	rHandler := handlers.CORS(originsOk, headersOk, methodsOk)(r)
 	if config.Development() {
 		// No WriteTimeout setup to enable pprof
@@ -370,6 +379,13 @@ func main() {
 
 	Logger.Info("Ready to listen to the requests")
 	startTime = time.Now().UTC()
+	go func(grpcPort string) {
+		lis, err := net.Listen("tcp", fmt.Sprintf(":%s", grpcPort))
+		if err != nil {
+			log.Fatalf("failed to listen: %v", err)
+		}
+		log.Fatal(grpcServer.Serve(lis))
+	}(*grpcPortString)
 	log.Fatal(server.ListenAndServe())
 }