diff --git a/pkg/common/db/localcache/group.go b/pkg/common/db/localcache/group.go new file mode 100644 index 000000000..a76bc6edb --- /dev/null +++ b/pkg/common/db/localcache/group.go @@ -0,0 +1,36 @@ +package localcache + +import ( + "Open_IM/pkg/proto/group" + "context" + "google.golang.org/grpc" +) + +type GroupLocalCache struct { + cache map[string]GroupMemberIDsHash + rpc *grpc.ClientConn + group group.GroupClient +} + +type GroupMemberIDsHash struct { + memberListHash uint64 + userIDs []string +} + +func NewGroupMemberIDsLocalCache(rpc *grpc.ClientConn) GroupLocalCache { + return GroupLocalCache{ + cache: make(map[string]GroupMemberIDsHash, 0), + rpc: rpc, + group: group.NewGroupClient(rpc), + } +} + +func (g *GroupLocalCache) GetGroupMemberIDs(ctx context.Context, groupID string) []string { + _, err := g.group.GetGroupAbstractInfo(ctx, &group.GetGroupAbstractInfoReq{ + GroupIDs: nil, + }) + if err != nil { + return nil + } + return []string{} +} diff --git a/pkg/common/db/localcache/localCache.go b/pkg/common/db/localcache/localCache.go deleted file mode 100644 index 9cfcec090..000000000 --- a/pkg/common/db/localcache/localCache.go +++ /dev/null @@ -1,24 +0,0 @@ -package localcache - -import "google.golang.org/grpc" - -type GroupLocalCache struct { - cache map[string]GroupMemberIDsHash - rpc *grpc.ClientConn -} - -type GroupMemberIDsHash struct { - MemberListHash uint64 - UserIDs []string -} - -func NewGroupMemberIDsLocalCache(rpc *grpc.ClientConn) GroupLocalCache { - return GroupLocalCache{ - cache: make(map[string]GroupMemberIDsHash, 0), - rpc: rpc, - } -} - -func (g *GroupMemberIDsHash) GetGroupMemberIDs(groupID string) []string { - return []string{} -}