@@ -73,15 +73,19 @@ public async Task ProcessIssues(string organization, string repository, int dura
73
73
int totalSkipped = 0 ;
74
74
75
75
Console . WriteLine ( "----- Starting processing issues. --------" ) ;
76
- var issueQueryEnumerable = QueryIssuesOrPullRequests < QuestIssue > ( ) ;
76
+ var issueQueryEnumerable = ( duration == - 1 ) ?
77
+ QueryAllOpenIssuesOrPullRequests < QuestIssue > ( ) :
78
+ QueryIssuesOrPullRequests < QuestIssue > ( ) ;
77
79
await ProcessItems ( issueQueryEnumerable ) ;
78
80
Console . WriteLine ( "----- Finished processing issues. --------" ) ;
79
81
Console . WriteLine ( " ----- Regenerating bearer token ------" ) ;
80
82
await ghClient . RegenerateBearerToken ( ) ;
81
83
try
82
84
{
83
85
Console . WriteLine ( "----- Starting processing pull requests. --------" ) ;
84
- var prQueryEnumerable = QueryIssuesOrPullRequests < QuestPullRequest > ( ) ;
86
+ var prQueryEnumerable = ( duration == - 1 ) ?
87
+ QueryAllOpenIssuesOrPullRequests < QuestPullRequest > ( ) :
88
+ QueryIssuesOrPullRequests < QuestPullRequest > ( ) ;
85
89
await ProcessItems ( prQueryEnumerable ) ;
86
90
Console . WriteLine ( "----- Finished processing pull requests. --------" ) ;
87
91
} catch ( InvalidOperationException e )
@@ -124,7 +128,7 @@ async Task ProcessItems(IAsyncEnumerable<QuestIssueOrPullRequest> items)
124
128
async IAsyncEnumerable < QuestIssueOrPullRequest > QueryIssuesOrPullRequests < T > ( ) where T : QuestIssueOrPullRequest , IGitHubQueryResult < T , QuestIssueOrPullRequestVariables >
125
129
{
126
130
var query = new EnumerationQuery < T , QuestIssueOrPullRequestVariables > ( ghClient ) ;
127
- var queryEnumerable = query . PerformQuery ( new QuestIssueOrPullRequestVariables ( organization , repository , importTriggerLabelText : importTriggerLabelText , importedLabelText : importedLabelText ) ) ;
131
+ var queryEnumerable = query . PerformQuery ( new QuestIssueOrPullRequestVariables ( organization , repository , [ ] , importTriggerLabelText : importTriggerLabelText , importedLabelText : importedLabelText ) ) ;
128
132
await foreach ( QuestIssueOrPullRequest item in queryEnumerable )
129
133
{
130
134
if ( item . UpdatedAt < historyThreshold )
@@ -133,6 +137,16 @@ async IAsyncEnumerable<QuestIssueOrPullRequest> QueryIssuesOrPullRequests<T>() w
133
137
yield return item ;
134
138
}
135
139
}
140
+
141
+ async IAsyncEnumerable < QuestIssueOrPullRequest > QueryAllOpenIssuesOrPullRequests < T > ( ) where T : QuestIssueOrPullRequest , IGitHubQueryResult < T , QuestIssueOrPullRequestVariables >
142
+ {
143
+ var query = new EnumerationQuery < T , QuestIssueOrPullRequestVariables > ( ghClient ) ;
144
+ var queryEnumerable = query . PerformQuery ( new QuestIssueOrPullRequestVariables ( organization , repository , [ "OPEN" ] , importTriggerLabelText : importTriggerLabelText , importedLabelText : importedLabelText ) ) ;
145
+ await foreach ( QuestIssueOrPullRequest item in queryEnumerable )
146
+ {
147
+ yield return item ;
148
+ }
149
+ }
136
150
}
137
151
138
152
/// <summary>
@@ -221,13 +235,13 @@ public void Dispose()
221
235
private Task < QuestIssue ? > RetrieveIssueAsync ( string org , string repo , int issueNumber )
222
236
{
223
237
var query = new ScalarQuery < QuestIssue , QuestIssueOrPullRequestVariables > ( ghClient ) ;
224
- return query . PerformQuery ( new QuestIssueOrPullRequestVariables ( org , repo , issueNumber ) ) ;
238
+ return query . PerformQuery ( new QuestIssueOrPullRequestVariables ( org , repo , [ ] , issueNumber ) ) ;
225
239
}
226
240
227
241
private Task < QuestPullRequest ? > RetrievePullRequestAsync ( string org , string repo , int issueNumber )
228
242
{
229
243
var query = new ScalarQuery < QuestPullRequest , QuestIssueOrPullRequestVariables > ( ghClient ) ;
230
- return query . PerformQuery ( new QuestIssueOrPullRequestVariables ( org , repo , issueNumber ) ) ;
244
+ return query . PerformQuery ( new QuestIssueOrPullRequestVariables ( org , repo , [ ] , issueNumber ) ) ;
231
245
}
232
246
private async Task < QuestIteration [ ] > RetrieveIterationLabelsAsync ( )
233
247
{
0 commit comments