|
@@ -271,15 +271,18 @@ class default_1 {
|
|
promise.then((tweets) => {
|
|
promise.then((tweets) => {
|
|
logger.debug(`api returned ${JSON.stringify(tweets)} for feed ${currentFeed}`);
|
|
logger.debug(`api returned ${JSON.stringify(tweets)} for feed ${currentFeed}`);
|
|
const currentThread = lock.threads[currentFeed];
|
|
const currentThread = lock.threads[currentFeed];
|
|
|
|
+ const setOffset = (offset) => currentThread.offset = offset;
|
|
const updateDate = () => currentThread.updatedAt = new Date().toString();
|
|
const updateDate = () => currentThread.updatedAt = new Date().toString();
|
|
if (!tweets || tweets.length === 0) {
|
|
if (!tweets || tweets.length === 0) {
|
|
|
|
+ if (currentThread.offset < -1) {
|
|
|
|
+ setOffset(utils_1.BigNumOps.plus('1', currentThread.offset));
|
|
|
|
+ }
|
|
updateDate();
|
|
updateDate();
|
|
return;
|
|
return;
|
|
}
|
|
}
|
|
const topOfFeed = tweets[0].id_str;
|
|
const topOfFeed = tweets[0].id_str;
|
|
logger.info(`current offset: ${currentThread.offset}, current top of feed: ${topOfFeed}`);
|
|
logger.info(`current offset: ${currentThread.offset}, current top of feed: ${topOfFeed}`);
|
|
const bottomOfFeed = tweets[tweets.length - 1].id_str;
|
|
const bottomOfFeed = tweets[tweets.length - 1].id_str;
|
|
- const setOffset = (offset) => currentThread.offset = offset;
|
|
|
|
const updateOffset = () => setOffset(topOfFeed);
|
|
const updateOffset = () => setOffset(topOfFeed);
|
|
tweets = tweets.filter(twi => !twi.retweeted_status && twi.extended_entities);
|
|
tweets = tweets.filter(twi => !twi.retweeted_status && twi.extended_entities);
|
|
logger.info(`found ${tweets.length} tweets with extended entities`);
|
|
logger.info(`found ${tweets.length} tweets with extended entities`);
|