index.js

require('dotenv').config();
const {retweet, search, getLatestRetweet, replyToTweet, findUserById} = require("./src/service/twitterService");
const {
    upsertTimeEntry,
    getNumbersFromTweet,
    getLastEnteredTweetId,
    upsertLatestEnteredTweetId, getTotalCampaignMinutes
} = require("./src/service/campaignService");
const {mongodb} = require("./src/service/mongodbService");

async function iterateOverInterval(interval, data, callback) {
    return new Promise((resolve) => {
        let index = 0;
        const intervalId = setInterval(async () => {
            if (data.length < 1 || index === data.length - 1) {
                clearInterval(intervalId);
                resolve();
            }
            if (!data[index]) {
                //prevent continuation with empty data
                return;
            }

            await callback(data[index])
            index++;

        }, interval);
    });
}

async function startBot(req, res) {
    console.log("Starting bot");

    const response = await getLatestRetweet({
        exclude: "replies",
        "tweet.fields": "referenced_tweets",
        expansions: "referenced_tweets.id"
    });

    if (!response) {
        res.send("Failed to get latest retweet, not starting bot");
        console.error("Failed to start bot. Couldn't fetch latest retweet");
        return;
    }

    const latestId = response.tweets?.[0]?.referenced_tweets[0]?.id;
    const sortedTweets = [];
    const data = await search("#FitDevs -is:retweet", latestId);

    for await (const result of data) {
        sortedTweets.push(result);
    }

    //To ensure that the tweet we last RT'd is always the most recent
    sortedTweets.reverse();

    //15 mins / 50 requests = 1 request every 18 seconds
    //+ 1 to avoid hitting rate limit
    await iterateOverInterval(19000, sortedTweets, async function (tweet) {
        console.info('Retweeting tweet ID', tweet?.id);
        await retweet(tweet.id);
    });
    res.send("Bot Done");

    console.log("Done")
}

async function runCampaign(req, res) {
    console.log("Starting campaign updates...");

    await mongodb.connect();

    const tweets = [];
    const lastEntered = await getLastEnteredTweetId();

    //Most recent will be first in the array
    const data = await search('#OneMillionMinutes -is:retweet', lastEntered?.tweetId, {
        expansions: 'author_id'
    });
    for await (const result of data) {
        const numbersFromTweet = getNumbersFromTweet(result);
        if (numbersFromTweet) {
            tweets.push(numbersFromTweet);
        } else {
            const response = await findUserById(result.author_id, {'user.fields': ['name']});
            const username = response.data.username;
            await replyToTweet(result.id, `@${username}, Your tweet was skipped because the bot couldn't parse your entry. @dev_nerd_2 will investigate and follow up.`);
        }
    }
    if (tweets.length === 0) {
        await mongodb.disconnect();
        console.log("Done");
        res.send("Bot Started but terminated early because there are no new tweets.");
        return;
    }
    //15 mins / 200 requests = 1 request every 4.5 seconds
    //+ 1 to avoid hitting rate limit
    await iterateOverInterval(5500, tweets, async function (tweet) {
        const response = await findUserById(tweet.twitterUserId, {'user.fields': ['name']});
        const username = response.data.username;

        //TODO: upsertTimeEntry was failing, claiming the  Client must be connected before running operations.
        // Need to have someone investigate what's going on
        await mongodb.connect();

        const {total} = await upsertTimeEntry(tweet.twitterUserId, tweet.number, username);
        const communityTotal = await getTotalCampaignMinutes();
        await replyToTweet(tweet.id, `Your entry has been logged. You have logged ${total} total minutes! The community has logged ${communityTotal} minutes toward our goal of one million.`);
    });

    //Update entry with the most recent tweetId so we know where to start our search next time
    await upsertLatestEnteredTweetId(tweets[0].id);
    await mongodb.disconnect();
    res.send("Bot started");
    console.log("Done");
}

module.exports = {
    startBot,
    runCampaign
}