twitch-helix.js

const twitch = require('./twitch-helix-api');
const EventEmitter = require('events');

const streamEmitter = new EventEmitter();
let startup = false;
let streams = { };
function streamLoop () {
  // Uncomment for logging.
  //console.log("Get streams...");
  //console.log(".--current streams--.");
  //console.log(streams)
  //console.log("'-------------------'");
  twitch.streams.getStreams({
    "game_id": [
      process.env.GAME_ID
    ],
    "type": 'live'
  }).then((data) => {
    let res = data.data.data;
    if (res === undefined) {
      console.log('ERROR: ' + data.data.error);
      return null;
    }

    let user_ids = [];
    for (let stream of res) {
      user_ids.push(stream["user_id"]);
      if (!streams[stream["user_id"]]) {
        streams[stream["user_id"]] = {};
      }
      streams[stream["user_id"]] = {
          ...streams[stream["user_id"]],
          ...stream,
      };
      streams[stream["user_id"]]["timer"] = 15;
      streams[stream["user_id"]]["url"] = 'https://www.twitch.tv/' + stream["user_login"];
      streams[stream["user_id"]]["login"] = stream["user_login"];

   
    }
    if (user_ids.length > 0) {
      return twitch.users.getUsers({
        "id": user_ids
      });
    }
    return null;
  }).then((data) => {
    if (data === null) {
      return;
    }
    const res = data.data.data;
    if (res === undefined) {
      console.log('ERROR: ' + data.data.error);
      return null;
    } else {
      // console.log('request successful');
    }
    for (const user of res) {
        
        streams[user["id"]].user= user;
        if (!streams[user["id"]].send ) {
            streams[user["id"]].send = true
            if (startup) {
                streamEmitter.emit('messageStreamStarted', streams[user["id"]]);
            }
        }
    }
    return;
  })  
  .catch((e) => {
    console.error(e);
  }).finally(() => {
    if (!startup) {
      startup = true;
    }
    setTimeout(streamLoop, 30000);
  });
}
setTimeout(streamLoop, 5000);
setInterval(() => {
  for (let stream of Object.keys(streams)) {
    streams[stream]["timer"]--;
    if (streams[stream]["timer"] < 1) {
      if (typeof streams[stream]["url"] !== 'undefined' && typeof streams[stream]["title"] !== 'undefined') {
        streamEmitter.emit('messageStreamDeleted', {
          "url": streams[stream]["url"],
          "title": streams[stream]["title"],
          "id": stream
        });
      }
      delete streams[stream];
    }
  }
}, 20000);
streamEmitter.getStreams = () => {
  return streams;
}
module.exports = streamEmitter;