(ctx context.Context)
| 85 | } |
| 86 | |
| 87 | func (mm *importMediator) fillImportEvents(ctx context.Context) { |
| 88 | initialCursor := githubv4.String("") |
| 89 | issues, hasIssues := mm.queryIssue(ctx, initialCursor) |
| 90 | for hasIssues { |
| 91 | for _, node := range issues.Nodes { |
| 92 | select { |
| 93 | case <-ctx.Done(): |
| 94 | return |
| 95 | case mm.importEvents <- IssueEvent{node.issue}: |
| 96 | } |
| 97 | |
| 98 | // issue edit events follow the issue event |
| 99 | mm.fillIssueEditEvents(ctx, &node) |
| 100 | // last come the timeline events |
| 101 | mm.fillTimelineEvents(ctx, &node) |
| 102 | } |
| 103 | if !issues.PageInfo.HasNextPage { |
| 104 | break |
| 105 | } |
| 106 | issues, hasIssues = mm.queryIssue(ctx, issues.PageInfo.EndCursor) |
| 107 | } |
| 108 | } |
| 109 | |
| 110 | func (mm *importMediator) fillIssueEditEvents(ctx context.Context, issueNode *issueNode) { |
| 111 | edits := &issueNode.UserContentEdits |
no test coverage detected