supernets/hardlounge
supernets/hardlounge
4
Fork 0
Code Issues 1 Pull Requests Packages Projects Releases Wiki Activity

Split pull request query into chunks

Browse Source 
Otherwise github api chokes when asking about too many pull requests at once
This commit is contained in:
Pavel Djundik 2018-09-19 14:31:25 +03:00
parent 62cb252933
commit d326435fe7
1 changed files with 14 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
scripts/changelog.js
View File

@ -340,13 +340,25 @@ class RepositoryFetcher {
return data.repository.milestones.nodes.find(({title}) => title === targetVersion); return data.repository.milestones.nodes.find(({title}) => title === targetVersion);
} }
async fetchChunkedPullRequests(numbers) {
const chunks = _.chunk(numbers, 100);
let result = {};
for (const chunk of chunks) {
const data = await this.fetchPullRequests(chunk);
result = _.merge(result, data);
}
return result;
}
// Given a list of PR numbers, retrieve information for all those PRs. They // Given a list of PR numbers, retrieve information for all those PRs. They
// are returned as a hash whose keys are `PR<number>`. // are returned as a hash whose keys are `PR<number>`.
// This is a bit wonky (generating a dynamic GraphQL query) but the GitHub API // This is a bit wonky (generating a dynamic GraphQL query) but the GitHub API
// does not have a way to retrieve multiple PRs given a list of IDs. // does not have a way to retrieve multiple PRs given a list of IDs.
async fetchPullRequests(numbers) { async fetchPullRequests(numbers) {
if (numbers.length === 0) { if (numbers.length === 0) {
return []; return {};
} }
const prQuery = `query fetchPullRequests($repositoryName: String!) { const prQuery = `query fetchPullRequests($repositoryName: String!) {
@ -386,7 +398,7 @@ class RepositoryFetcher {
const taggedCommit = await this.fetchTaggedCommit(tag); const taggedCommit = await this.fetchTaggedCommit(tag);
const commits = await this.fetchCommitsSince(taggedCommit); const commits = await this.fetchCommitsSince(taggedCommit);
const pullRequestIds = pullRequestNumbersInCommits(commits); const pullRequestIds = pullRequestNumbersInCommits(commits);
const pullRequests = await this.fetchPullRequests(pullRequestIds); const pullRequests = await this.fetchChunkedPullRequests(pullRequestIds);
return combine(commits, pullRequests); return combine(commits, pullRequests);
} }
} }