Add integration tests for the grpc endpoints

.github/workflows/ci.yml

@@ -11,7 +11,7 @@ env:
   VALIDATOR_REGISTRY: ${{ secrets.VALIDATOR_REGISTRY }}
 
 jobs:
-  build:
+  test:
     runs-on: ubuntu-20.04
     steps:
       - name: Install Go
@@ -25,22 +25,15 @@ jobs:
       - uses: satackey/action-docker-layer-caching@v0.0.11
         # Ignore the failure of a step and avoid terminating the job.
         continue-on-error: true
-      - name: Build
+      - name: Build test environment and run tests
         run: |
+          ./docker.local/bin/blobber.init.setup.sh
           docker network create --driver=bridge --subnet=198.18.0.0/15 --gateway=198.18.0.255 testnet0
           ./docker.local/bin/build.blobber.sh
-
-  test:
-    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: Test
-      run: make test
-
+          cd docker.local/blobber1
+          ../bin/blobber.start_bls.sh </dev/null &>/dev/null &
+          cd ../..
+          make integration-tests
   lint:
     runs-on: ubuntu-20.04
     steps:

Makefile

@@ -1,7 +1,10 @@
-.PHONY: test lint
+.PHONY: test lint integration-tests
 
 test:
 	go test ./...;
 
 lint:
-	golangci-lint run;
+	golangci-lint run;
+
+integration-tests:
+	go test ./... -args integration;

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

@@ -227,7 +227,7 @@ func main() {
 	flag.Parse()
 
 	config.SetupDefaultConfig()
-	config.SetupConfig()
+	config.SetupConfig("./config")
 
 	config.Configuration.DeploymentMode = byte(*deploymentMode)
 
@@ -339,10 +339,11 @@ func main() {
 	methodsOk := handlers.AllowedMethods([]string{"GET", "HEAD", "POST", "PUT",
 		"DELETE", "OPTIONS"})
 
+	common.ConfigRateLimits()
 	initHandlers(r)
 	initServer()
 
-	grpcServer := handler.NewServerWithMiddlewares(common.ConfigRateLimits())
+	grpcServer := handler.NewServerWithMiddlewares(common.NewGRPCRateLimiter())
 	handler.RegisterGRPCServices(r, grpcServer)
 
 	rHandler := handlers.CORS(originsOk, headersOk, methodsOk)(r)

code/go/0chain.net/blobbercore/config/config.go

@@ -44,12 +44,12 @@ func SetupDefaultConfig() {
 }
 
 /*SetupConfig - setup the configuration system */
-func SetupConfig() {
+func SetupConfig(configPath string) {
 	replacer := strings.NewReplacer(".", "_")
 	viper.SetEnvKeyReplacer(replacer)
 	viper.AutomaticEnv()
 	viper.SetConfigName("0chain_blobber")
-	viper.AddConfigPath("./config")
+	viper.AddConfigPath(configPath)
 	err := viper.ReadInConfig() // Find and read the config file
 	if err != nil {             // Handle errors reading the config file
 		panic(fmt.Errorf("fatal error config file: %s", err))