This commit is contained in:
wangchuxiao 2023-02-01 17:11:44 +08:00
parent 4ad6b74d75
commit d4952ebc16
2 changed files with 36 additions and 24 deletions

View File

@ -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{}
}

View File

@ -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{}
}