msb-public
/
Open-IM-Server
mirror of https://github.com/OpenIMSDK/Open-IM-Server
2
0
Code Issues Projects Releases Wiki Activity

add log

Browse Source
pull/2473/head
withchao 1 year ago
parent a56c20bdcf
commit 04f440f1ef
3 changed files with 14 additions and 14 deletions
Show Stats Download Patch File Download Diff File

8
pkg/rpccache/conversation.go
Unescape View File

@ -59,9 +59,9 @@ func (c *ConversationLocalCache) GetConversationIDs(ctx context.Context, ownerUs
log.ZDebug(ctx, "ConversationLocalCache GetConversationIDs req", "ownerUserID", ownerUserID) log.ZDebug(ctx, "ConversationLocalCache GetConversationIDs req", "ownerUserID", ownerUserID)
defer func() { defer func() {
if err == nil { if err == nil {
log.ZDebug(ctx, "ConversationLocalCache GetConversationIDs return", "value", val) log.ZDebug(ctx, "ConversationLocalCache GetConversationIDs return", "ownerUserID", ownerUserID, "value", val)
} else { } else {
log.ZError(ctx, "ConversationLocalCache GetConversationIDs return", err) log.ZError(ctx, "ConversationLocalCache GetConversationIDs return", err, "ownerUserID", ownerUserID)
} }
}() }()
return localcache.AnyValue[[]string](c.local.Get(ctx, cachekey.GetConversationIDsKey(ownerUserID), func(ctx context.Context) (any, error) { return localcache.AnyValue[[]string](c.local.Get(ctx, cachekey.GetConversationIDsKey(ownerUserID), func(ctx context.Context) (any, error) {
@ -74,9 +74,9 @@ func (c *ConversationLocalCache) GetConversation(ctx context.Context, userID, co
log.ZDebug(ctx, "ConversationLocalCache GetConversation req", "userID", userID, "conversationID", conversationID) log.ZDebug(ctx, "ConversationLocalCache GetConversation req", "userID", userID, "conversationID", conversationID)
defer func() { defer func() {
if err == nil { if err == nil {
log.ZDebug(ctx, "ConversationLocalCache GetConversation return", "value", val) log.ZDebug(ctx, "ConversationLocalCache GetConversation return", "userID", userID, "conversationID", conversationID, "value", val)
} else { } else {
log.ZError(ctx, "ConversationLocalCache GetConversation return", err) log.ZError(ctx, "ConversationLocalCache GetConversation return", err, "userID", userID, "conversationID", conversationID)
} }
}() }()
return localcache.AnyValue[*pbconversation.Conversation](c.local.Get(ctx, cachekey.GetConversationKey(userID, conversationID), func(ctx context.Context) (any, error) { return localcache.AnyValue[*pbconversation.Conversation](c.local.Get(ctx, cachekey.GetConversationKey(userID, conversationID), func(ctx context.Context) (any, error) {

8
pkg/rpccache/friend.go
Unescape View File

@ -53,9 +53,9 @@ func (f *FriendLocalCache) IsFriend(ctx context.Context, possibleFriendUserID, u
log.ZDebug(ctx, "FriendLocalCache IsFriend req", "possibleFriendUserID", possibleFriendUserID, "userID", userID) log.ZDebug(ctx, "FriendLocalCache IsFriend req", "possibleFriendUserID", possibleFriendUserID, "userID", userID)
defer func() { defer func() {
if err == nil { if err == nil {
log.ZDebug(ctx, "FriendLocalCache IsFriend return", "value", val) log.ZDebug(ctx, "FriendLocalCache IsFriend return", "possibleFriendUserID", possibleFriendUserID, "userID", userID, "value", val)
} else { } else {
log.ZError(ctx, "FriendLocalCache IsFriend return", err) log.ZError(ctx, "FriendLocalCache IsFriend return", err, "possibleFriendUserID", possibleFriendUserID, "userID", userID)
} }
}() }()
return localcache.AnyValue[bool](f.local.GetLink(ctx, cachekey2.GetIsFriendKey(possibleFriendUserID, userID), func(ctx context.Context) (any, error) { return localcache.AnyValue[bool](f.local.GetLink(ctx, cachekey2.GetIsFriendKey(possibleFriendUserID, userID), func(ctx context.Context) (any, error) {
@ -69,9 +69,9 @@ func (f *FriendLocalCache) IsBlack(ctx context.Context, possibleBlackUserID, use
log.ZDebug(ctx, "FriendLocalCache IsBlack req", "possibleBlackUserID", possibleBlackUserID, "userID", userID) log.ZDebug(ctx, "FriendLocalCache IsBlack req", "possibleBlackUserID", possibleBlackUserID, "userID", userID)
defer func() { defer func() {
if err == nil { if err == nil {
log.ZDebug(ctx, "FriendLocalCache IsBlack return", "value", val) log.ZDebug(ctx, "FriendLocalCache IsBlack return", "possibleBlackUserID", possibleBlackUserID, "userID", userID, "value", val)
} else { } else {
log.ZError(ctx, "FriendLocalCache IsBlack return", err) log.ZError(ctx, "FriendLocalCache IsBlack return", err, "possibleBlackUserID", possibleBlackUserID, "userID", userID)
} }
}() }()
return localcache.AnyValue[bool](f.local.GetLink(ctx, cachekey2.GetIsBlackIDsKey(possibleBlackUserID, userID), func(ctx context.Context) (any, error) { return localcache.AnyValue[bool](f.local.GetLink(ctx, cachekey2.GetIsBlackIDsKey(possibleBlackUserID, userID), func(ctx context.Context) (any, error) {

12
pkg/rpccache/group.go
Unescape View File

@ -55,9 +55,9 @@ func (g *GroupLocalCache) getGroupMemberIDs(ctx context.Context, groupID string)
log.ZDebug(ctx, "GroupLocalCache getGroupMemberIDs req", "groupID", groupID) log.ZDebug(ctx, "GroupLocalCache getGroupMemberIDs req", "groupID", groupID)
defer func() { defer func() {
if err == nil { if err == nil {
log.ZDebug(ctx, "GroupLocalCache getGroupMemberIDs return", "value", val) log.ZDebug(ctx, "GroupLocalCache getGroupMemberIDs return", "groupID", groupID, "value", val)
} else { } else {
log.ZError(ctx, "GroupLocalCache getGroupMemberIDs return", err) log.ZError(ctx, "GroupLocalCache getGroupMemberIDs return", err, "groupID", groupID)
} }
}() }()
return localcache.AnyValue[*listMap[string]](g.local.Get(ctx, cachekey.GetGroupMemberIDsKey(groupID), func(ctx context.Context) (any, error) { return localcache.AnyValue[*listMap[string]](g.local.Get(ctx, cachekey.GetGroupMemberIDsKey(groupID), func(ctx context.Context) (any, error) {
@ -70,9 +70,9 @@ func (g *GroupLocalCache) GetGroupMember(ctx context.Context, groupID, userID st
log.ZDebug(ctx, "GroupLocalCache GetGroupInfo req", "groupID", groupID, "userID", userID) log.ZDebug(ctx, "GroupLocalCache GetGroupInfo req", "groupID", groupID, "userID", userID)
defer func() { defer func() {
if err == nil { if err == nil {
log.ZDebug(ctx, "GroupLocalCache GetGroupInfo return", "value", val) log.ZDebug(ctx, "GroupLocalCache GetGroupInfo return", "groupID", groupID, "userID", userID, "value", val)
} else { } else {
log.ZError(ctx, "GroupLocalCache GetGroupInfo return", err) log.ZError(ctx, "GroupLocalCache GetGroupInfo return", err, "groupID", groupID, "userID", userID)
} }
}() }()
return localcache.AnyValue[*sdkws.GroupMemberFullInfo](g.local.Get(ctx, cachekey.GetGroupMemberInfoKey(groupID, userID), func(ctx context.Context) (any, error) { return localcache.AnyValue[*sdkws.GroupMemberFullInfo](g.local.Get(ctx, cachekey.GetGroupMemberInfoKey(groupID, userID), func(ctx context.Context) (any, error) {
@ -85,9 +85,9 @@ func (g *GroupLocalCache) GetGroupInfo(ctx context.Context, groupID string) (val
log.ZDebug(ctx, "GroupLocalCache GetGroupInfo req", "groupID", groupID) log.ZDebug(ctx, "GroupLocalCache GetGroupInfo req", "groupID", groupID)
defer func() { defer func() {
if err == nil { if err == nil {
log.ZDebug(ctx, "GroupLocalCache GetGroupInfo return", "value", val) log.ZDebug(ctx, "GroupLocalCache GetGroupInfo return", "groupID", groupID, "value", val)
} else { } else {
log.ZError(ctx, "GroupLocalCache GetGroupInfo return", err) log.ZError(ctx, "GroupLocalCache GetGroupInfo return", err, "groupID", groupID)
} }
}() }()
return localcache.AnyValue[*sdkws.GroupInfo](g.local.Get(ctx, cachekey.GetGroupInfoKey(groupID), func(ctx context.Context) (any, error) { return localcache.AnyValue[*sdkws.GroupInfo](g.local.Get(ctx, cachekey.GetGroupInfoKey(groupID), func(ctx context.Context) (any, error) {

Write Preview
Loading…
Cancel
Save