fix: init online status

1 year ago · a51b088982
parent 206871d9b3
commit a51b088982
1 changed files with 3 additions and 1 deletions
--- a/pkg/rpccache/online.go
+++ b/pkg/rpccache/online.go
@ -110,9 +110,10 @@ func (o *OnlineCache) initUsersOnlineStatus(ctx context.Context) (err error) {
 		return err
 	}

+	cursor := uint64(0)
 	for resp == nil || resp.NextCursor != 0 {
 		if err = retryOperation(func() error {
-			resp, err = o.user.GetAllOnlineUsers(ctx, 0)
+			resp, err = o.user.GetAllOnlineUsers(ctx, cursor)
 			if err != nil {
 				return err
 			}
@ -123,6 +124,7 @@ func (o *OnlineCache) initUsersOnlineStatus(ctx context.Context) (err error) {
 				}
 				totalSet.Add(1)
 			}
+			cursor = resp.NextCursor
 			return nil
 		}, "getAllOnlineUsers"); err != nil {
 			return err