group sync

internal/rpc/group/group.go

@@ -104,7 +104,7 @@ func Start(ctx context.Context, config *Config, client discovery.SvcDiscoveryReg
 	msgRpcClient := rpcclient.NewMessageRpcClient(client, config.Share.RpcRegisterName.Msg)
 	conversationRpcClient := rpcclient.NewConversationRpcClient(client, config.Share.RpcRegisterName.Conversation)
 	var gs groupServer
-	database := controller.NewGroupDatabase(rdb, &config.LocalCacheConfig, groupDB, groupMemberDB, groupRequestDB, mgocli.GetTx(), grouphash.NewGroupHashFromGroupServer(&gs))
+	database := controller.NewGroupDatabase(rdb, &config.LocalCacheConfig, groupDB, groupMemberDB, groupRequestDB, mgocli.GetTx(), grouphash.NewGroupHashFromGroupServer(&gs), config.RpcConfig.GroupSyncCount)
 	gs.db = database
 	gs.user = userRpcClient
 	gs.notification = NewGroupNotificationSender(database, &msgRpcClient, &userRpcClient, config, func(ctx context.Context, userIDs []string) ([]notification.CommonUser, error) {

pkg/common/storage/cache/redis/group.go

@@ -57,6 +57,7 @@ func NewGroupCacheRedis(
 	groupRequestDB database.GroupRequest,
 	hashCode cache.GroupHash,
 	opts *rockscache.Options,
+	syncCount int,
 ) cache.GroupCache {
 	batchHandler := NewBatchDeleterRedis(rdb, opts, []string{localCache.Group.Topic})
 	g := localCache.Group
@@ -70,6 +71,7 @@ func NewGroupCacheRedis(
 		groupMemberDB:  groupMemberDB,
 		groupRequestDB: groupRequestDB,
 		groupHash:      hashCode,
+		syncCount:      syncCount,
 	}
 }
 

pkg/common/storage/controller/group.go

@@ -123,13 +123,14 @@ func NewGroupDatabase(
 	groupRequestDB database.GroupRequest,
 	ctxTx tx.Tx,
 	groupHash cache.GroupHash,
+	syncCount int,
 ) GroupDatabase {
 	return &groupDatabase{
 		groupDB:        groupDB,
 		groupMemberDB:  groupMemberDB,
 		groupRequestDB: groupRequestDB,
 		ctxTx:          ctxTx,
-		cache:          redis2.NewGroupCacheRedis(rdb, localCache, groupDB, groupMemberDB, groupRequestDB, groupHash, redis2.GetRocksCacheOptions()),
+		cache:          redis2.NewGroupCacheRedis(rdb, localCache, groupDB, groupMemberDB, groupRequestDB, groupHash, redis2.GetRocksCacheOptions(), syncCount),
 	}
 }