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 eb9b9e7a..0d10ed8c 100644 --- a/packages/backend/src/apps/twitter/triggers/search-tweets/index.ts +++ b/packages/backend/src/apps/twitter/triggers/search-tweets/index.ts @@ -31,8 +31,6 @@ export default { ], async run($: IGlobalVariable) { - return await searchTweets($, { - searchTerm: $.step.parameters.searchTerm as string, - }); + return await searchTweets($); }, }; 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 a9d38636..475403b5 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 @@ -7,15 +7,9 @@ import qs from 'qs'; import generateRequest from '../../common/generate-request'; import { omitBy, isEmpty } from 'lodash'; -type ISearchTweetsOptions = { - searchTerm: string; - lastInternalId?: string; -}; +const searchTweets = async ($: IGlobalVariable) => { + const searchTerm = $.step.parameters.searchTerm as string; -const searchTweets = async ( - $: IGlobalVariable, - options: ISearchTweetsOptions -) => { let response; const tweets: ITriggerOutput = { @@ -24,7 +18,7 @@ const searchTweets = async ( do { const params: IJSONObject = { - query: options.searchTerm, + query: searchTerm, since_id: $.execution.testRun ? null : $.flow.lastInternalId, pagination_token: response?.data?.meta?.next_token, };