groot/automatisch
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: Adjust sorting for new pull requests

Browse Source
This commit is contained in:
Faruk AYDIN
2022-10-22 21:47:21 +02:00
parent b0dc0adf0e
commit d5cecde0e1
1 changed files with 4 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
packages/backend/src/apps/github/triggers/new-pull-requests/new-pull-requests.ts
View File

@@ -1,8 +1,8 @@
import { IGlobalVariable, ITriggerOutput } from '@automatisch/types'; import { IGlobalVariable } from '@automatisch/types';
import getRepoOwnerAndRepo from '../../common/get-repo-owner-and-repo'; import getRepoOwnerAndRepo from '../../common/get-repo-owner-and-repo';
import parseLinkHeader from '../../../../helpers/parse-header-link'; import parseLinkHeader from '../../../../helpers/parse-header-link';
const fetchPullRequests = async ($: IGlobalVariable) => { const newPullRequests = async ($: IGlobalVariable) => {
const repoParameter = $.step.parameters.repo as string; const repoParameter = $.step.parameters.repo as string;
if (!repoParameter) throw new Error('A repo must be set!'); if (!repoParameter) throw new Error('A repo must be set!');
@@ -17,10 +17,6 @@ const fetchPullRequests = async ($: IGlobalVariable) => {
per_page: 100, per_page: 100,
}; };
const pullRequests: ITriggerOutput = {
data: [],
};
let links; let links;
do { do {
const response = await $.http.get(pathname, { params }); const response = await $.http.get(pathname, { params });
@@ -34,7 +30,7 @@ const fetchPullRequests = async ($: IGlobalVariable) => {
pullRequestId <= Number($.flow.lastInternalId) && pullRequestId <= Number($.flow.lastInternalId) &&
!$.execution.testRun !$.execution.testRun
) )
return pullRequests; return;
const dataItem = { const dataItem = {
raw: pullRequest, raw: pullRequest,
@@ -43,20 +39,10 @@ const fetchPullRequests = async ($: IGlobalVariable) => {
}, },
}; };
pullRequests.data.push(dataItem); $.pushTriggerItem(dataItem);
} }
} }
} while (links.next && !$.execution.testRun); } while (links.next && !$.execution.testRun);
return pullRequests;
};
const newPullRequests = async ($: IGlobalVariable) => {
const pullRequests = await fetchPullRequests($);
pullRequests.data.reverse();
return pullRequests;
}; };
export default newPullRequests; export default newPullRequests;