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

refactor: Remove test run and completion logic from new watchers

Browse Source
This commit is contained in:
Faruk AYDIN
2022-10-28 00:46:32 +02:00
parent 3308a44c2b
commit 87fdc02224
2 changed files with 2 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
packages/backend/src/apps/github/triggers/new-watchers/index.ts
View File

@@ -44,8 +44,4 @@ export default defineTrigger({
async run($) { async run($) {
await newWatchers($); await newWatchers($);
}, },
sort() {
return -1;
},
}); });

7
packages/backend/src/apps/github/triggers/new-watchers/new-watchers.ts
View File

@@ -1,4 +1,4 @@
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';
@@ -34,9 +34,6 @@ const newWatchers = async ($: IGlobalVariable) => {
for (const watcher of response.data) { for (const watcher of response.data) {
const watcherId = watcher.id.toString(); const watcherId = watcher.id.toString();
if ($.flow.isAlreadyProcessed(watcherId) && !$.execution.testRun)
return;
const dataItem = { const dataItem = {
raw: watcher, raw: watcher,
meta: { meta: {
@@ -47,7 +44,7 @@ const newWatchers = async ($: IGlobalVariable) => {
$.pushTriggerItem(dataItem); $.pushTriggerItem(dataItem);
} }
} }
} while (pathname && !$.execution.testRun); } while (pathname);
}; };
export default newWatchers; export default newWatchers;