From 9d439521793c98bbad393feb5020d24ace78b509 Mon Sep 17 00:00:00 2001 From: withchao <993506633@qq.com> Date: Tue, 12 Dec 2023 18:15:49 +0800 Subject: [PATCH] friend user --- internal/rpc/friend/friend.go | 4 ++++ internal/rpc/user/user.go | 16 ++++++++++++++++ 2 files changed, 20 insertions(+) diff --git a/internal/rpc/friend/friend.go b/internal/rpc/friend/friend.go index 224efe3ed..21422fae3 100644 --- a/internal/rpc/friend/friend.go +++ b/internal/rpc/friend/friend.go @@ -52,6 +52,10 @@ type friendServer struct { RegisterCenter registry.SvcDiscoveryRegistry } +func (s *friendServer) PinFriends(ctx context.Context, req *pbfriend.PinFriendsReq) (*pbfriend.PinFriendsResp, error) { + return nil, errs.ErrInternalServer.Wrap("not implemented") +} + func Start(client registry.SvcDiscoveryRegistry, server *grpc.Server) error { // Initialize MongoDB mongo, err := unrelation.NewMongo() diff --git a/internal/rpc/user/user.go b/internal/rpc/user/user.go index 77da408aa..a2fa14c7a 100644 --- a/internal/rpc/user/user.go +++ b/internal/rpc/user/user.go @@ -56,6 +56,22 @@ type userServer struct { RegisterCenter registry.SvcDiscoveryRegistry } +func (s *userServer) ProcessUserCommandAdd(ctx context.Context, req *pbuser.ProcessUserCommandAddReq) (*pbuser.ProcessUserCommandAddResp, error) { + return nil, errs.ErrInternalServer.Wrap("not implemented") +} + +func (s *userServer) ProcessUserCommandUpdate(ctx context.Context, req *pbuser.ProcessUserCommandUpdateReq) (*pbuser.ProcessUserCommandUpdateResp, error) { + return nil, errs.ErrInternalServer.Wrap("not implemented") +} + +func (s *userServer) ProcessUserCommandDelete(ctx context.Context, req *pbuser.ProcessUserCommandDeleteReq) (*pbuser.ProcessUserCommandDeleteResp, error) { + return nil, errs.ErrInternalServer.Wrap("not implemented") +} + +func (s *userServer) ProcessUserCommandGet(ctx context.Context, req *pbuser.ProcessUserCommandGetReq) (*pbuser.ProcessUserCommandGetResp, error) { + return nil, errs.ErrInternalServer.Wrap("not implemented") +} + func Start(client registry.SvcDiscoveryRegistry, server *grpc.Server) error { rdb, err := cache.NewRedis() if err != nil {