From 5189e5b1312b119f16e6b7d70550ea38756fc646 Mon Sep 17 00:00:00 2001
From: Faruk AYDIN <omerfaruk26@gmail.com>
Date: Fri, 28 Oct 2022 00:22:30 +0200
Subject: [PATCH] refactor: Adjust pagination and test run for search tweets

---
 .../backend/src/apps/twitter/triggers/search-tweets/index.ts  | 4 ----
 .../src/apps/twitter/triggers/search-tweets/search-tweets.ts  | 4 ++--
 2 files changed, 2 insertions(+), 6 deletions(-)

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;