optimize the freeze caused by too many friends and group applications (#852)

* feat: code adjustment

* feat: Cmd2Value carry caller

* feat: Cmd2Value carry caller

* feat: Cmd2Value carry caller

* feat: Cmd2Value carry caller

* fix: SearchLocalMessages no such table

* fix: optimize the freeze caused by too many friends and group applications

Author: withchao

internal/group/full_sync.go

@@ -29,6 +29,10 @@ func (g *Group) SyncAllJoinedGroupsAndMembers(ctx context.Context) error {
 }
 
 func (g *Group) SyncAllSelfGroupApplication(ctx context.Context) error {
+	if !g.groupRequestSyncerLock.TryLock() {
+		return nil
+	}
+	defer g.groupRequestSyncerLock.Unlock()
 	list, err := g.GetServerSelfGroupApplication(ctx)
 	if err != nil {
 		return err
@@ -45,6 +49,10 @@ func (g *Group) SyncAllSelfGroupApplication(ctx context.Context) error {
 }
 
 func (g *Group) SyncAllSelfGroupApplicationWithoutNotice(ctx context.Context) error {
+	if !g.groupRequestSyncerLock.TryLock() {
+		return nil
+	}
+	defer g.groupRequestSyncerLock.Unlock()
 	list, err := g.GetServerSelfGroupApplication(ctx)
 	if err != nil {
 		return err
@@ -64,6 +72,10 @@ func (g *Group) SyncSelfGroupApplications(ctx context.Context, groupIDs ...strin
 }
 
 func (g *Group) SyncAllAdminGroupApplication(ctx context.Context) error {
+	if !g.groupAdminRequestSyncerLock.TryLock() {
+		return nil
+	}
+	defer g.groupAdminRequestSyncerLock.Unlock()
 	requests, err := g.GetServerAdminGroupApplicationList(ctx)
 	if err != nil {
 		return err
@@ -76,6 +88,10 @@ func (g *Group) SyncAllAdminGroupApplication(ctx context.Context) error {
 }
 
 func (g *Group) SyncAllAdminGroupApplicationWithoutNotice(ctx context.Context) error {
+	if !g.groupAdminRequestSyncerLock.TryLock() {
+		return nil
+	}
+	defer g.groupAdminRequestSyncerLock.Unlock()
 	requests, err := g.GetServerAdminGroupApplicationList(ctx)
 	if err != nil {
 		return err

internal/group/group.go

@@ -69,6 +69,9 @@ type Group struct {
 	listenerForService open_im_sdk_callback.OnListenerForService
 
 	groupMemberCache *cache.Cache[string, *model_struct.LocalGroupMember]
+
+	groupRequestSyncerLock      sync.Mutex
+	groupAdminRequestSyncerLock sync.Mutex
 }
 
 func (g *Group) initSyncer() {

internal/relation/relation.go

@@ -42,6 +42,9 @@ type Relation struct {
 	conversationCh     chan common.Cmd2Value
 	listenerForService open_im_sdk_callback.OnListenerForService
 	relationSyncMutex  sync.Mutex
+
+	requestRecvSyncerLock sync.Mutex
+	requestSendSyncerLock sync.Mutex
 }
 
 func (r *Relation) initSyncer() {

internal/relation/sync.go

@@ -13,6 +13,17 @@ import (
 )
 
 func (r *Relation) SyncBothFriendRequest(ctx context.Context, fromUserID, toUserID string) error {
+	if toUserID == r.loginUserID {
+		if !r.requestRecvSyncerLock.TryLock() {
+			return nil
+		}
+		defer r.requestRecvSyncerLock.Unlock()
+	} else {
+		if !r.requestSendSyncerLock.TryLock() {
+			return nil
+		}
+		defer r.requestSendSyncerLock.Unlock()
+	}
 	req := &relation.GetDesignatedFriendsApplyReq{FromUserID: fromUserID, ToUserID: toUserID}
 	friendRequests, err := r.getDesignatedFriendsApply(ctx, req)
 	if err != nil {
@@ -32,6 +43,10 @@ func (r *Relation) SyncBothFriendRequest(ctx context.Context, fromUserID, toUser
 
 // SyncAllSelfFriendApplication send
 func (r *Relation) SyncAllSelfFriendApplication(ctx context.Context) error {
+	if !r.requestSendSyncerLock.TryLock() {
+		return nil
+	}
+	defer r.requestSendSyncerLock.Unlock()
 	req := &relation.GetPaginationFriendsApplyFromReq{UserID: r.loginUserID, Pagination: &sdkws.RequestPagination{}}
 	requests, err := r.getSelfFriendApplicationList(ctx, req)
 	if err != nil {
@@ -45,6 +60,10 @@ func (r *Relation) SyncAllSelfFriendApplication(ctx context.Context) error {
 }
 
 func (r *Relation) SyncAllSelfFriendApplicationWithoutNotice(ctx context.Context) error {
+	if !r.requestSendSyncerLock.TryLock() {
+		return nil
+	}
+	defer r.requestSendSyncerLock.Unlock()
 	req := &relation.GetPaginationFriendsApplyFromReq{UserID: r.loginUserID, Pagination: &sdkws.RequestPagination{}}
 	requests, err := r.getSelfFriendApplicationList(ctx, req)
 	if err != nil {
@@ -59,6 +78,10 @@ func (r *Relation) SyncAllSelfFriendApplicationWithoutNotice(ctx context.Context
 
 // SyncAllFriendApplication recv
 func (r *Relation) SyncAllFriendApplication(ctx context.Context) error {
+	if !r.requestRecvSyncerLock.TryLock() {
+		return nil
+	}
+	defer r.requestRecvSyncerLock.Unlock()
 	req := &relation.GetPaginationFriendsApplyToReq{UserID: r.loginUserID, Pagination: &sdkws.RequestPagination{}}
 	requests, err := r.getFriendApplicationList(ctx, req)
 	if err != nil {
@@ -71,6 +94,10 @@ func (r *Relation) SyncAllFriendApplication(ctx context.Context) error {
 	return r.requestRecvSyncer.Sync(ctx, datautil.Batch(ServerFriendRequestToLocalFriendRequest, requests), localData, nil)
 }
 func (r *Relation) SyncAllFriendApplicationWithoutNotice(ctx context.Context) error {
+	if !r.requestRecvSyncerLock.TryLock() {
+		return nil
+	}
+	defer r.requestRecvSyncerLock.Unlock()
 	req := &relation.GetPaginationFriendsApplyToReq{UserID: r.loginUserID, Pagination: &sdkws.RequestPagination{}}
 	requests, err := r.getFriendApplicationList(ctx, req)
 	if err != nil {