coopgo-platform/groups-management
7
0
Fork 0
Code Issues Pull Requests Actions Projects Releases Wiki Activity

code to create and delete groupMmber collection in DB

Browse Source
This commit is contained in:
soukainna
2023-01-17 15:07:16 +01:00
parent 57540f2587
commit 312200e210
11 changed files with 350 additions and 154 deletions
Download Patch File Download Diff File Expand all files Collapse all files

29
grpcapi/grpcapi.go
View File

@@ -94,8 +94,14 @@ func (s GroupsManagementServerImpl) Subscribe(ctx context.Context, req *Subscrib
}, nil
}
func (s GroupsManagementServerImpl) Unsubscribe(context.Context, *UnsubscribeRequest) (*UnsubscribeResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method Unsubscribe not implemented")
func (s GroupsManagementServerImpl) Unsubscribe(ctx context.Context, req *UnsubscribeRequest) (*UnsubscribeResponse, error) {
err := s.handler.Unsubscribe(req.Groupid, req.Memberid)
if err != nil {
return nil, status.Errorf(codes.AlreadyExists, "could not subscribe : %v", err)
}
return &UnsubscribeResponse{
Ok: true,
}, nil
}
func (s GroupsManagementServerImpl) mustEmbedUnimplementedGroupsManagementServer() {}
@@ -123,9 +129,7 @@ func Run(done chan error, cfg *viper.Viper, handler handlers.GroupsManagementHan
}
}
////////////////////////////////////////////////////////////////
/////////////////////////////////////////////////////////////////
//////////////////////////////////////////////////////////////////////////
////////////////////////////////////Code for the new DB groupMember//////////////////////////////////////
func (s GroupsManagementServerImpl) AddGroupMember(ctx context.Context, req *AddGroupMemberRequest) (*AddGroupMemberResponse, error) {
g := req.Group.ToStorageType()
@@ -189,13 +193,6 @@ func (s GroupsManagementServerImpl) GetGroupsBatchMember(ctx context.Context, re
func (s GroupsManagementServerImpl) SubscribeMember(ctx context.Context, req *SubscribeMemberRequest) (*SubscribeMemberResponse, error) {
g := req.Group.ToStorageType()
// err := s.handler.SubscribeMember(g)
// if err != nil {
// return nil, status.Errorf(codes.AlreadyExists, "could not subscribe : %v", err)
// }
// return &SubscribeMemberResponse{
// Ok: true,
// }, nil
group, err := s.handler.SubscribeMember(g)
if err != nil {
@@ -210,3 +207,11 @@ func (s GroupsManagementServerImpl) SubscribeMember(ctx context.Context, req *Su
return &SubscribeMemberResponse{Group: response}, nil
}
func (s GroupsManagementServerImpl) UnsubscribeMember(ctx context.Context, req *UnsubscribeMemberRequest) (*UnsubscribeMemberResponse, error) {
err := s.handler.UnsubscribeMember(req.Id)
if err != nil {
return nil, status.Errorf(codes.AlreadyExists, "could not unsubscribe : %v", err)
}
return &UnsubscribeMemberResponse{}, nil
}