main.js

function array_contains(arr, obj) {
    for (var i = 0; i < arr.length; ++i) {
        if (arr[i] === obj){
            return true;
        }
    }
    return false;
}

module.exports = function (nodecg, Twitch) {
    
    var RepsAndNames = require('./reps-and-names.js')(nodecg);

    function PollForFollowers() {
        Twitch.api({method: `channels/${nodecg.bundleConfig.channel}/follows?random=${Math.random()}`}, function(error, data) {
            if (error === null) {
                RepsAndNames.ReplicantData.channel.numFollowers.value = data._total;

                var storedTimestamp = new Date(RepsAndNames.ReplicantData.channel.mostRecentFollowerTimestamp.value);
                var updatedTimestamp = null;

                for (var i = 0; i < data.follows.length; ++i) {
                    var followerTimestamp = new Date(data.follows[i].created_at);
                    if (followerTimestamp > storedTimestamp) {
                        if (updatedTimestamp === null || followerTimestamp > updatedTimestamp) {
                            updatedTimestamp = followerTimestamp;
                        }
                        var refollowing = array_contains(RepsAndNames.ReplicantData.channel.announcedFollowers.value, data.follows[i].user.display_name);
                        if (RepsAndNames.ReplicantData.dashboard.allowRefollow.value || !refollowing) {
                            if (!refollowing) {
                                RepsAndNames.ReplicantData.channel.announcedFollowers.value.push(data.follows[i].user.display_name);
                            }
                            nodecg.sendMessage(RepsAndNames.MessageNames.channel.followed, data.follows[i].user);
                        }
                    } else {
                        break;
                    }
                }

                if (updatedTimestamp !== null) {
                    RepsAndNames.ReplicantData.channel.mostRecentFollowerTimestamp.value = updatedTimestamp.toISOString();
                }
            }             
        });
    }

    function PollForStreamDetails() {
        Twitch.api({method: `streams/${nodecg.bundleConfig.channel}?random=${Math.random()}`}, function(error, data) {
            if (error === null) {
               if (data.stream === null) {
                    RepsAndNames.ReplicantData.channel.online.value = false;
                    RepsAndNames.ReplicantData.channel.viewersCurrent.value = 0;
                } else {
                    RepsAndNames.ReplicantData.channel.online.value = true;
                    RepsAndNames.ReplicantData.channel.viewersCurrent.value = data.stream.viewers;
                    RepsAndNames.ReplicantData.channel.viewersTotal.value = data.stream.channel.views;
                    RepsAndNames.ReplicantData.channel.name.value = data.stream.channel.status;
                    RepsAndNames.ReplicantData.channel.audience.value = data.stream.channel.mature ? "mature" : "everyone";
                } 
            }
        });
    }

    // Set up polling
    setInterval(PollForFollowers, RepsAndNames.ReplicantData.dashboard.followerPollInterval.value * 1000);
    setTimeout(() => { setInterval(PollForStreamDetails, RepsAndNames.ReplicantData.dashboard.streamPollInterval.value * 1000); }, 1000);

};