groot/automatisch
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

refactor: Adjust pagination and test run for search tweets

Browse Source
This commit is contained in:
Faruk AYDIN
2022-10-28 00:22:30 +02:00
parent 11dc650e0e
commit 5189e5b131
2 changed files with 2 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
packages/backend/src/apps/twitter/triggers/search-tweets/index.ts
View File

@@ -33,8 +33,4 @@ export default defineTrigger({
async run($) { async run($) {
await searchTweets($); await searchTweets($);
}, },
sort(tweet, nextTweet) {
return Number(nextTweet.meta.internalId) - Number(tweet.meta.internalId);
},
}); });

4
packages/backend/src/apps/twitter/triggers/search-tweets/search-tweets.ts
View File

@@ -10,7 +10,7 @@ const searchTweets = async ($: IGlobalVariable) => {
do { do {
const params: IJSONObject = { const params: IJSONObject = {
query: searchTerm, query: searchTerm,
since_id: $.execution.testRun ? null : $.flow.lastInternalId, since_id: $.flow.lastInternalId,
pagination_token: response?.data?.meta?.next_token, pagination_token: response?.data?.meta?.next_token,
}; };
@@ -38,7 +38,7 @@ const searchTweets = async ($: IGlobalVariable) => {
$.pushTriggerItem(dataItem); $.pushTriggerItem(dataItem);
}); });
} }
} while (response.data.meta.next_token && !$.execution.testRun); } while (response.data.meta.next_token);
}; };
export default searchTweets; export default searchTweets;