refactor: Remove pagination and test run checks from user tweets
This commit is contained in:
@@ -16,7 +16,7 @@ const fetchTweets = async ($: IGlobalVariable, username: string) => {
|
|||||||
|
|
||||||
do {
|
do {
|
||||||
const params: IJSONObject = {
|
const params: IJSONObject = {
|
||||||
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,
|
||||||
};
|
};
|
||||||
|
|
||||||
@@ -40,7 +40,7 @@ const fetchTweets = async ($: IGlobalVariable, username: string) => {
|
|||||||
$.pushTriggerItem(dataItem);
|
$.pushTriggerItem(dataItem);
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
} while (response.data.meta.next_token && !$.execution.testRun);
|
} while (response.data.meta.next_token);
|
||||||
|
|
||||||
return $.triggerOutput;
|
return $.triggerOutput;
|
||||||
};
|
};
|
||||||
|
@@ -20,8 +20,4 @@ export default defineTrigger({
|
|||||||
async run($) {
|
async run($) {
|
||||||
await getUserTweets($, { currentUser: true });
|
await getUserTweets($, { currentUser: true });
|
||||||
},
|
},
|
||||||
|
|
||||||
sort(tweet, nextTweet) {
|
|
||||||
return Number(nextTweet.meta.internalId) - Number(tweet.meta.internalId);
|
|
||||||
},
|
|
||||||
});
|
});
|
||||||
|
@@ -32,8 +32,4 @@ export default defineTrigger({
|
|||||||
async run($) {
|
async run($) {
|
||||||
await getUserTweets($, { currentUser: false });
|
await getUserTweets($, { currentUser: false });
|
||||||
},
|
},
|
||||||
|
|
||||||
sort(tweet, nextTweet) {
|
|
||||||
return Number(nextTweet.meta.internalId) - Number(tweet.meta.internalId);
|
|
||||||
},
|
|
||||||
});
|
});
|
||||||
|
Reference in New Issue
Block a user