diff --git a/packages/backend/src/apps/github/triggers/new-issues/new-issues.ts b/packages/backend/src/apps/github/triggers/new-issues/new-issues.ts index 15e84840..8a52fabc 100644 --- a/packages/backend/src/apps/github/triggers/new-issues/new-issues.ts +++ b/packages/backend/src/apps/github/triggers/new-issues/new-issues.ts @@ -44,7 +44,7 @@ const newIssues = async ($: IGlobalVariable) => { }, }; - $.triggerOutput.data.push(dataItem); + $.pushTriggerItem(dataItem); } } } while (links.next && !$.execution.testRun); diff --git a/packages/backend/src/apps/github/triggers/new-stargazers/new-stargazers.ts b/packages/backend/src/apps/github/triggers/new-stargazers/new-stargazers.ts index fa1d5636..d0ee4092 100644 --- a/packages/backend/src/apps/github/triggers/new-stargazers/new-stargazers.ts +++ b/packages/backend/src/apps/github/triggers/new-stargazers/new-stargazers.ts @@ -55,7 +55,7 @@ const newStargazers = async ($: IGlobalVariable) => { }, }; - $.triggerOutput.data.push(dataItem); + $.pushTriggerItem(dataItem); } } } while (pathname && !$.execution.testRun); diff --git a/packages/backend/src/apps/scheduler/triggers/every-day/index.ts b/packages/backend/src/apps/scheduler/triggers/every-day/index.ts index 70fd947e..67f923ed 100644 --- a/packages/backend/src/apps/scheduler/triggers/every-day/index.ts +++ b/packages/backend/src/apps/scheduler/triggers/every-day/index.ts @@ -171,6 +171,6 @@ export default defineTrigger({ }, }; - $.triggerOutput.data.push(dataItem); + $.pushTriggerItem(dataItem); }, }); diff --git a/packages/backend/src/apps/scheduler/triggers/every-hour/index.ts b/packages/backend/src/apps/scheduler/triggers/every-hour/index.ts index 8ed3aeeb..81f56571 100644 --- a/packages/backend/src/apps/scheduler/triggers/every-hour/index.ts +++ b/packages/backend/src/apps/scheduler/triggers/every-hour/index.ts @@ -65,6 +65,6 @@ export default defineTrigger({ }, }; - $.triggerOutput.data.push(dataItem); + $.pushTriggerItem(dataItem); }, }); diff --git a/packages/backend/src/apps/scheduler/triggers/every-month/index.ts b/packages/backend/src/apps/scheduler/triggers/every-month/index.ts index d88b68a1..0e48c3c7 100644 --- a/packages/backend/src/apps/scheduler/triggers/every-month/index.ts +++ b/packages/backend/src/apps/scheduler/triggers/every-month/index.ts @@ -287,6 +287,6 @@ export default defineTrigger({ }, }; - $.triggerOutput.data.push(dataItem); + $.pushTriggerItem(dataItem); }, }); diff --git a/packages/backend/src/apps/scheduler/triggers/every-week/index.ts b/packages/backend/src/apps/scheduler/triggers/every-week/index.ts index d28d4f52..590daa90 100644 --- a/packages/backend/src/apps/scheduler/triggers/every-week/index.ts +++ b/packages/backend/src/apps/scheduler/triggers/every-week/index.ts @@ -191,6 +191,6 @@ export default defineTrigger({ }, }; - $.triggerOutput.data.push(dataItem); + $.pushTriggerItem(dataItem); }, }); diff --git a/packages/backend/src/apps/twitter/common/get-user-tweets.ts b/packages/backend/src/apps/twitter/common/get-user-tweets.ts index 415a6a13..6d0f2807 100644 --- a/packages/backend/src/apps/twitter/common/get-user-tweets.ts +++ b/packages/backend/src/apps/twitter/common/get-user-tweets.ts @@ -30,12 +30,14 @@ const fetchTweets = async ($: IGlobalVariable, username: string) => { if (response.data.meta.result_count > 0) { response.data.data.forEach((tweet: IJSONObject) => { - $.triggerOutput.data.push({ + const dataItem = { raw: tweet, meta: { internalId: tweet.id as string, }, - }); + }; + + $.pushTriggerItem(dataItem); }); } } while (response.data.meta.next_token && !$.execution.testRun); diff --git a/packages/backend/src/apps/twitter/triggers/search-tweets/search-tweets.ts b/packages/backend/src/apps/twitter/triggers/search-tweets/search-tweets.ts index b25ef36b..b79481e6 100644 --- a/packages/backend/src/apps/twitter/triggers/search-tweets/search-tweets.ts +++ b/packages/backend/src/apps/twitter/triggers/search-tweets/search-tweets.ts @@ -35,7 +35,7 @@ const searchTweets = async ($: IGlobalVariable) => { }, }; - $.triggerOutput.data.push(dataItem); + $.pushTriggerItem(dataItem); }); } } while (response.data.meta.next_token && !$.execution.testRun);