From 87fdc02224e053f698e2c10ab6ee89eca55b2136 Mon Sep 17 00:00:00 2001 From: Faruk AYDIN Date: Fri, 28 Oct 2022 00:46:32 +0200 Subject: [PATCH] refactor: Remove test run and completion logic from new watchers --- .../backend/src/apps/github/triggers/new-watchers/index.ts | 4 ---- .../src/apps/github/triggers/new-watchers/new-watchers.ts | 7 ++----- 2 files changed, 2 insertions(+), 9 deletions(-) diff --git a/packages/backend/src/apps/github/triggers/new-watchers/index.ts b/packages/backend/src/apps/github/triggers/new-watchers/index.ts index a7f744d1..03204e7f 100644 --- a/packages/backend/src/apps/github/triggers/new-watchers/index.ts +++ b/packages/backend/src/apps/github/triggers/new-watchers/index.ts @@ -44,8 +44,4 @@ export default defineTrigger({ async run($) { await newWatchers($); }, - - sort() { - return -1; - }, }); diff --git a/packages/backend/src/apps/github/triggers/new-watchers/new-watchers.ts b/packages/backend/src/apps/github/triggers/new-watchers/new-watchers.ts index 69753514..f7e13035 100644 --- a/packages/backend/src/apps/github/triggers/new-watchers/new-watchers.ts +++ b/packages/backend/src/apps/github/triggers/new-watchers/new-watchers.ts @@ -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 parseLinkHeader from '../../../../helpers/parse-header-link'; @@ -34,9 +34,6 @@ const newWatchers = async ($: IGlobalVariable) => { for (const watcher of response.data) { const watcherId = watcher.id.toString(); - if ($.flow.isAlreadyProcessed(watcherId) && !$.execution.testRun) - return; - const dataItem = { raw: watcher, meta: { @@ -47,7 +44,7 @@ const newWatchers = async ($: IGlobalVariable) => { $.pushTriggerItem(dataItem); } } - } while (pathname && !$.execution.testRun); + } while (pathname); }; export default newWatchers;