|
|
@ -16,6 +16,7 @@ package friend
|
|
|
|
|
|
|
|
|
|
|
|
import (
|
|
|
|
import (
|
|
|
|
"context"
|
|
|
|
"context"
|
|
|
|
|
|
|
|
"errors"
|
|
|
|
|
|
|
|
|
|
|
|
"github.com/OpenIMSDK/tools/tx"
|
|
|
|
"github.com/OpenIMSDK/tools/tx"
|
|
|
|
|
|
|
|
|
|
|
@ -53,6 +54,10 @@ type friendServer struct {
|
|
|
|
RegisterCenter registry.SvcDiscoveryRegistry
|
|
|
|
RegisterCenter registry.SvcDiscoveryRegistry
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
func (s *friendServer) PinFriends(ctx context.Context, req *pbfriend.PinFriendsReq) (*pbfriend.PinFriendsResp, error) {
|
|
|
|
|
|
|
|
return nil, errors.New("implement me")
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
func Start(client registry.SvcDiscoveryRegistry, server *grpc.Server) error {
|
|
|
|
func Start(client registry.SvcDiscoveryRegistry, server *grpc.Server) error {
|
|
|
|
// Initialize MongoDB
|
|
|
|
// Initialize MongoDB
|
|
|
|
mongo, err := unrelation.NewMongo()
|
|
|
|
mongo, err := unrelation.NewMongo()
|
|
|
|