diff --git a/packages/backend/src/apps/twitter/triggers/search-tweets/index.ts b/packages/backend/src/apps/twitter/triggers/search-tweets/index.ts index 506bbe83..d97e565d 100644 --- a/packages/backend/src/apps/twitter/triggers/search-tweets/index.ts +++ b/packages/backend/src/apps/twitter/triggers/search-tweets/index.ts @@ -33,8 +33,4 @@ export default defineTrigger({ async run($) { await searchTweets($); }, - - sort(tweet, nextTweet) { - return Number(nextTweet.meta.internalId) - Number(tweet.meta.internalId); - }, }); 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 b79481e6..929bfac3 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 @@ -10,7 +10,7 @@ const searchTweets = async ($: IGlobalVariable) => { do { const params: IJSONObject = { query: searchTerm, - since_id: $.execution.testRun ? null : $.flow.lastInternalId, + since_id: $.flow.lastInternalId, pagination_token: response?.data?.meta?.next_token, }; @@ -38,7 +38,7 @@ const searchTweets = async ($: IGlobalVariable) => { $.pushTriggerItem(dataItem); }); } - } while (response.data.meta.next_token && !$.execution.testRun); + } while (response.data.meta.next_token); }; export default searchTweets;