From 18ccb25b29c592b8888e079eedee21e7b80a93ce Mon Sep 17 00:00:00 2001 From: Faruk AYDIN Date: Fri, 28 Oct 2022 01:14:19 +0200 Subject: [PATCH] refactor: Remove is already processed from new feed items --- .../triggers/new-items-in-feed/new-items-in-feed.ts | 11 ++++------- 1 file changed, 4 insertions(+), 7 deletions(-) diff --git a/packages/backend/src/apps/rss/triggers/new-items-in-feed/new-items-in-feed.ts b/packages/backend/src/apps/rss/triggers/new-items-in-feed/new-items-in-feed.ts index 6111929d..cdc76791 100644 --- a/packages/backend/src/apps/rss/triggers/new-items-in-feed/new-items-in-feed.ts +++ b/packages/backend/src/apps/rss/triggers/new-items-in-feed/new-items-in-feed.ts @@ -1,5 +1,5 @@ import { IGlobalVariable } from '@automatisch/types'; -import { XMLParser } from 'fast-xml-parser';[] +import { XMLParser } from 'fast-xml-parser'; const newItemsInFeed = async ($: IGlobalVariable) => { const { data } = await $.http.get($.step.parameters.feedUrl as string); @@ -7,15 +7,12 @@ const newItemsInFeed = async ($: IGlobalVariable) => { const parsedData = parser.parse(data); for (const item of parsedData.rss.channel.item) { - if ($.flow.isAlreadyProcessed(item.guid)) - return; - const dataItem = { raw: item, meta: { - internalId: item.guid - } - } + internalId: item.guid, + }, + }; $.pushTriggerItem(dataItem); }