feat: modified the close/open scripts

This commit is contained in:
Randell Dawson
2018-11-28 02:58:30 -08:00
committed by mrugesh mohapatra
parent 925a1d8a55
commit 37aceca8b0
3 changed files with 45 additions and 33 deletions

View File

@ -29,16 +29,16 @@ const getUserInput = async () => {
const lastPR = prs[prs.length - 1].number; const lastPR = prs[prs.length - 1].number;
log.setFirstLast({ firstPR, lastPR }); log.setFirstLast({ firstPR, lastPR });
for (let { number, data: { errorDesc } } of prs) { for (let { number, data: { errorDesc } } of prs) {
if (errorDesc !== "unknown error") { //if (errorDesc !== "unknown error") {
log.add(number, { closedOpened: true, errorDesc }); log.add(number, { closedOpened: true, errorDesc });
if (process.env.PRODUCTION_RUN === 'true') { if (process.env.PRODUCTION_RUN === 'true') {
await closeOpen(number); await closeOpen(number);
await rateLimiter(30000); await rateLimiter(2000);
}
}
else {
log.add(number, { closedOpened: false, errorDesc });
} }
//}
//else {
// log.add(number, { closedOpened: false, errorDesc });
//}
} }
}) })
.then(() => { .then(() => {

View File

@ -24,7 +24,7 @@ const errorsToFind = require(path.resolve(__dirname, '../input-files/failuresToF
(async () => { (async () => {
const { firstPR, lastPR } = await getUserInput(); const { firstPR, lastPR } = await getUserInput();
log.setFirstLast({ firstPR, lastPR }); log.setFirstLast({ firstPR, lastPR });
const prPropsToGet = ['number', 'head']; const prPropsToGet = ['number', 'labels', 'head'];
const { openPRs } = await getPRs(firstPR, lastPR, prPropsToGet); const { openPRs } = await getPRs(firstPR, lastPR, prPropsToGet);
if (openPRs.length) { if (openPRs.length) {
@ -32,9 +32,11 @@ const errorsToFind = require(path.resolve(__dirname, '../input-files/failuresToF
log.start(); log.start();
console.log('Starting error finding process...'); console.log('Starting error finding process...');
for (let count in openPRs) { for (let count in openPRs) {
let { number, head: { sha: ref } } = openPRs[count]; let { number, labels, head: { sha: ref } } = openPRs[count];
const { data: statuses } = await octokit.repos.listStatusesForRef({ owner, repo, ref }); const existingLabels = labels.map(({ name }) => name);
if (!existingLabels.includes('status: merge conflict') && !existingLabels.includes('status: needs update') && !existingLabels.includes('status: discussing')) {
const { data: statuses } = await octokit.repos.listStatusesForRef({ owner, repo, ref });
if (statuses.length) { if (statuses.length) {
const { state, target_url } = statuses[0]; // first element contain most recent status const { state, target_url } = statuses[0]; // first element contain most recent status
const hasProblem = state === 'failure' || state === 'error'; const hasProblem = state === 'failure' || state === 'error';
@ -61,6 +63,7 @@ const errorsToFind = require(path.resolve(__dirname, '../input-files/failuresToF
} }
} }
} }
}
})() })()
.then(() => { .then(() => {
log.finish(); log.finish();

View File

@ -11,15 +11,24 @@ octokit.authenticate(octokitAuth);
const closeOpen = async (number) => { const closeOpen = async (number) => {
const result = await octokit.pullRequests.update({ owner, repo , number, state: 'closed', base: 'master' }) const result = await octokit.pullRequests.update({ owner, repo , number, state: 'closed', base: 'master' })
.then(async () => { .then(async () => {
await rateLimiter(2000); await rateLimiter(10000);
return octokit.pullRequests.update({ owner, repo , number, state: 'open', base: 'master' }) return octokit.pullRequests.update({ owner, repo , number, state: 'open', base: 'master' })
}) })
.then(async () => { .then(async () => {
await rateLimiter(1000); await rateLimiter(2000);
await addComment(number, 'Closed and Reopened this PR to attempt to resolve a specific Travis build failure.'); await addComment(number, 'Closed and Reopened this PR to attempt to resolve a specific Travis build failure.');
}) })
.catch((err) => { .catch(async (err) => {
console.log(err) const { errors } = JSON.parse(err.message); // Octokit stores message as a stringified object
const errorMg = errors[0].message;
if (errorMg === "state cannot be changed. The repository that submitted this pull request has been deleted.") {
await rateLimiter(1000);
await addComment(number, `This PR was closed because user's repo was deleted.`);
console.log(`PR #${number} was closed because user's repo was deleted.`);
}
else {
console.log(err);
}
}) })
}; };