fixes #164, migrated CollaboratorHandler to gRPC

code/go/0chain.net/blobbercore/blobbergrpc/proto/blobber.proto

@@ -63,6 +63,26 @@ service Blobber {
       body: "*"
     };
   }
+
+  rpc Collaborator(CollaboratorRequest) returns (CollaboratorResponse) {
+    option (google.api.http) = {
+      post: "/v2/file/collaborator/{allocation}"
+      body: "*"
+    };
+  }
+}
+
+message CollaboratorRequest {
+  string allocation = 1;
+  string collab_id = 2;
+  string method = 3;
+  string path = 4;
+  string path_hash = 5;
+}
+
+message CollaboratorResponse {
+  string message = 1;
+  repeated Collaborator Collaborators = 2;
 }
 
 message CalculateHashRequest {

code/go/0chain.net/blobbercore/convert/responseHandler.go

@@ -122,3 +122,22 @@ func GetCommitMetaTxnHandlerResponse(response *blobbergrpc.CommitMetaTxnResponse
 
 	return result
 }
+
+func CollaboratorResponse(response *blobbergrpc.CollaboratorResponse) interface{} {
+	if msg := response.GetMessage(); msg != "" {
+		return struct {
+			Msg string `json:"msg"`
+		}{Msg: msg}
+	}
+
+	if collaborators := response.GetCollaborators(); collaborators != nil {
+		collabs := make([]reference.Collaborator, 0, len(collaborators))
+		for _, c := range collaborators {
+			collabs = append(collabs, *GRPCCollaboratorToCollaborator(c))
+		}
+
+		return collabs
+	}
+
+	return nil
+}

code/go/0chain.net/blobbercore/handler/grpc_commit_handler.go

@@ -6,18 +6,16 @@ import (
 	"encoding/json"
 	"strconv"
 
-	"gorm.io/gorm"
-
-	"github.com/0chain/blobber/code/go/0chain.net/blobbercore/convert"
-	"github.com/0chain/blobber/code/go/0chain.net/blobbercore/datastore"
-
 	"github.com/0chain/blobber/code/go/0chain.net/blobbercore/allocation"
 	"github.com/0chain/blobber/code/go/0chain.net/blobbercore/blobbergrpc"
+	"github.com/0chain/blobber/code/go/0chain.net/blobbercore/convert"
+	"github.com/0chain/blobber/code/go/0chain.net/blobbercore/datastore"
 	"github.com/0chain/blobber/code/go/0chain.net/blobbercore/reference"
 	"github.com/0chain/blobber/code/go/0chain.net/blobbercore/writemarker"
 	"github.com/0chain/blobber/code/go/0chain.net/core/common"
 	"github.com/0chain/blobber/code/go/0chain.net/core/encryption"
 	"github.com/0chain/blobber/code/go/0chain.net/core/lock"
+	"gorm.io/gorm"
 )
 
 func (b *blobberGRPCService) Commit(ctx context.Context, req *blobbergrpc.CommitRequest) (*blobbergrpc.CommitResponse, error) {