update idx.go.

idx.go

@@ -153,11 +153,6 @@ func (p *PageUsers) Request(tweetId string, next string, f req) ([]UserTask, err
 	//	}
 	//}
 
-	// wait rate limit.
-	if rt != nil && rt.Remaining == 0 {
-		time.Sleep(time.Until(rt.Reset.Time().Add(500 * time.Millisecond)))
-	}
-
 	taskUser := userObjectToUserTask(users)
 
 	// 查询最新的一页 followers, 去历史中匹配。
@@ -172,6 +167,14 @@ func (p *PageUsers) Request(tweetId string, next string, f req) ([]UserTask, err
 		}
 		return res, nil
 	}
+	slog.Info("Task to be continued", "tweet id", tweetId, "next", newNext)
+	// Check if we need to respect rate limits
+	if rt != nil && rt.Remaining <= 0 {
+		// Wait until the rate limit resets (plus a small buffer)
+		waitTime := time.Until(rt.Reset.Time().Add(500 * time.Millisecond))
+		time.Sleep(waitTime)
+	}
+
 	return p.Request(tweetId, newNext, f)
 }