Skip to content

Commit b4ebba7

Browse files
committed
fix missed sleep
1 parent 6ac563a commit b4ebba7

File tree

1 file changed

+9
-3
lines changed

1 file changed

+9
-3
lines changed

modules/migrations/github.go

Lines changed: 9 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -363,13 +363,15 @@ func (g *GithubDownloaderV3) GetIssues(page, perPage int) ([]*base.Issue, bool,
363363
// get reactions
364364
var reactions []*base.Reaction
365365
for i := 0; ; i++ {
366-
res, _, err := g.client.Reactions.ListIssueReactions(g.ctx, g.repoOwner, g.repoName, issue.GetNumber(), &github.ListOptions{
366+
g.sleep()
367+
res, resp, err := g.client.Reactions.ListIssueReactions(g.ctx, g.repoOwner, g.repoName, issue.GetNumber(), &github.ListOptions{
367368
Page: i,
368369
PerPage: perPage,
369370
})
370371
if err != nil {
371372
return nil, false, err
372373
}
374+
g.rate = &resp.Rate
373375
if len(res) == 0 {
374376
break
375377
}
@@ -429,13 +431,15 @@ func (g *GithubDownloaderV3) GetComments(issueNumber int64) ([]*base.Comment, er
429431
// get reactions
430432
var reactions []*base.Reaction
431433
for i := 0; ; i++ {
432-
res, _, err := g.client.Reactions.ListIssueCommentReactions(g.ctx, g.repoOwner, g.repoName, comment.GetID(), &github.ListOptions{
434+
g.sleep()
435+
res, resp, err := g.client.Reactions.ListIssueCommentReactions(g.ctx, g.repoOwner, g.repoName, comment.GetID(), &github.ListOptions{
433436
Page: i,
434437
PerPage: 100,
435438
})
436439
if err != nil {
437440
return nil, err
438441
}
442+
g.rate = &resp.Rate
439443
if len(res) == 0 {
440444
break
441445
}
@@ -541,13 +545,15 @@ func (g *GithubDownloaderV3) GetPullRequests(page, perPage int) ([]*base.PullReq
541545
// get reactions
542546
var reactions []*base.Reaction
543547
for i := 0; ; i++ {
544-
res, _, err := g.client.Reactions.ListIssueReactions(g.ctx, g.repoOwner, g.repoName, pr.GetNumber(), &github.ListOptions{
548+
g.sleep()
549+
res, resp, err := g.client.Reactions.ListIssueReactions(g.ctx, g.repoOwner, g.repoName, pr.GetNumber(), &github.ListOptions{
545550
Page: i,
546551
PerPage: perPage,
547552
})
548553
if err != nil {
549554
return nil, err
550555
}
556+
g.rate = &resp.Rate
551557
if len(res) == 0 {
552558
break
553559
}

0 commit comments

Comments
 (0)