API tools faq
paste
Advertisement
kyroskoh

twitch.js

kyroskoh
Jun 29th, 2017
300
0
Never
Add comment
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
JavaScript 25.23 KB | None | 0 0
raw download clone embed print report
  1. 'use strict'
  2.  
  3. var constants = require('./constants')
  4. var moment = require('moment')
  5. var request = require('request-promise')
  6. var _ = require('lodash')
  7. require('moment-precise-range-plugin')
  8.  
  9. function Twitch () {
  10.   this.isOnline = false
  11.  
  12.   this.currentViewers = 0
  13.   this.currentFollowers = 0
  14.   this.currentViews = 0
  15.   this.currentHosts = 0
  16.   this.maxViewers = 0
  17.   this.chatMessagesAtStart = global.parser.linesParsed
  18.   this.maxRetries = 12
  19.   this.curRetries = 0
  20.   this.newChatters = 0
  21.   this.currentStatus = ''
  22.   this.currentGame = ''
  23.  
  24.   this.cached = {
  25.     followers: [],
  26.     subscribers: []
  27.   }
  28.  
  29.   this.when = {
  30.     online: null,
  31.     offline: null
  32.   }
  33.  
  34.   this.cGamesTitles = {} // cached Games and Titles
  35.   global.watcher.watch(this, 'cGamesTitles', this._save)
  36.   global.watcher.watch(this, 'when', this._save)
  37.   global.watcher.watch(this, 'cached', this._save)
  38.   this._load(this)
  39.  
  40.   var self = this
  41.   setInterval(function () {
  42.     let options = {
  43.       url: 'https://api.twitch.tv/kraken/streams/' + global.channelId,
  44.       headers: {
  45.         Accept: 'application/vnd.twitchtv.v5+json',
  46.         'Client-ID': global.configuration.get().twitch.clientId
  47.       }
  48.     }
  49.  
  50.     if (global.configuration.get().bot.debug) {
  51.       global.log.debug('Get current stream data from twitch', options)
  52.     }
  53.     global.client.api(options, function (err, res, body) {
  54.       if (err) {
  55.         if (err.code !== 'ETIMEDOUT' && err.code !== 'ECONNRESET') global.log.error(err, { fnc: 'Twitch#1' })
  56.         return
  57.       }
  58.  
  59.       if (global.configuration.get().bot.debug) {
  60.         global.log.debug('Response: Get current stream data from twitch', body)
  61.       }
  62.  
  63.       if (res.statusCode === 200 && !_.isNull(body.stream)) {
  64.         self.curRetries = 0
  65.         if (!self.isOnline) { // if we are switching from offline - bots restarts? We want refresh to correct data for start as well
  66.           self.chatMessagesAtStart = global.parser.linesParsed
  67.           self.currentViewers = 0
  68.           self.maxViewers = 0
  69.           self.newChatters = 0
  70.           self.chatMessagesAtStart = global.parser.linesParsed
  71.           global.events.fire('stream-started')
  72.           global.events.fire('every-x-seconds', { reset: true })
  73.         }
  74.         self.saveStream(body.stream)
  75.         self.isOnline = true
  76.         self.when.offline = null
  77.         global.events.fire('number-of-viewers-is-at-least-x')
  78.         global.events.fire('stream-is-running-x-minutes')
  79.         global.events.fire('every-x-seconds')
  80.       } else {
  81.         if (self.isOnline && self.curRetries < self.maxRetries) { self.curRetries = self.curRetries + 1; return } // we want to check if stream is _REALLY_ offline
  82.         // reset everything
  83.         self.curRetries = 0
  84.         self.isOnline = false
  85.         if (_.isNil(self.when.offline)) {
  86.           self.when.offline = new Date().getTime()
  87.           global.events.fire('stream-stopped')
  88.           global.events.fire('stream-is-running-x-minutes', { reset: true })
  89.           global.events.fire('number-of-viewers-is-at-least-x', { reset: true })
  90.         }
  91.         self.when.online = null
  92.       }
  93.     })
  94.  
  95.     options = {
  96.       url: 'https://api.twitch.tv/kraken/channels/' + global.channelId + '/follows?limit=100',
  97.       headers: {
  98.         Accept: 'application/vnd.twitchtv.v5+json',
  99.         'Client-ID': global.configuration.get().twitch.clientId
  100.       }
  101.     }
  102.     if (global.configuration.get().bot.debug) {
  103.       global.log.debug('Get last 100 followers from twitch', options)
  104.     }
  105.     global.client.api(options, function (err, res, body) {
  106.       if (err) {
  107.         if (err.code !== 'ETIMEDOUT' && err.code !== 'ECONNRESET') global.log.error(err, { fnc: 'Twitch#2' })
  108.         return
  109.       }
  110.       if (global.configuration.get().bot.debug) {
  111.         global.log.debug('Response: Get last 100 followers from twitch', body)
  112.       }
  113.       if (res.statusCode === 200 && !_.isNull(body)) {
  114.         self.currentFollowers = body._total
  115.  
  116.         self.cached.followers = []
  117.         _.each(body.follows, function (follower) {
  118.           if (!global.users.get(follower.user.name).is.follower) {
  119.             if (new Date().getTime() - moment(follower.created_at).format('X') * 1000 < 60000 * 60) global.events.fire('follow', { username: follower.user.name })
  120.           }
  121.           global.users.set(follower.user.name, { id: follower.user._id, is: { follower: true }, time: { followCheck: new Date().getTime(), follow: moment(follower.created_at).format('X') * 1000 } })
  122.           self.cached.followers.push(follower.user.name)
  123.         })
  124.       }
  125.     })
  126.  
  127.     // count watching time when stream is online
  128.     if (self.isOnline) {
  129.       const users = global.users.getAll({ is: { online: true } })
  130.       _.each(users, function (user) {
  131.         // add user as a new chatter in a stream
  132.         if (_.isUndefined(user.time.watched) || user.time.watched === 0) self.newChatters = self.newChatters + 1
  133.         const time = (!_.isUndefined(user.time.watched)) ? 15000 + user.time.watched : 15000
  134.         global.users.set(user.username, { time: { watched: time } })
  135.       })
  136.     }
  137.   }, 15000)
  138.  
  139.   setInterval(function () {
  140.     let options = {
  141.       url: 'https://api.twitch.tv/kraken/channels/' + global.channelId + '?timestamp=' + new Date().getTime(),
  142.       headers: {
  143.         Accept: 'application/vnd.twitchtv.v5+json',
  144.         'Client-ID': global.configuration.get().twitch.clientId
  145.       }
  146.     }
  147.     if (global.configuration.get().bot.debug) {
  148.       global.log.debug('Get current channel data from twitch', options)
  149.     }
  150.     global.client.api(options, function (err, res, body) {
  151.       if (err) {
  152.         if (err.code !== 'ETIMEDOUT' && err.code !== 'ECONNRESET') global.log.error(err, { fnc: 'Twitch#3' })
  153.         return
  154.       }
  155.       if (global.configuration.get().bot.debug) {
  156.         global.log.debug('Response: Get current channel data from twitch', body)
  157.       }
  158.       if (res.statusCode === 200 && !_.isNull(body)) {
  159.         self.currentGame = body.game
  160.         self.currentStatus = body.status
  161.         self.currentViews = body.views
  162.       }
  163.     })
  164.  
  165.     if (!_.isNull(global.channelId)) {
  166.       options = {
  167.         url: 'http://tmi.twitch.tv/hosts?include_logins=1&target=' + global.channelId
  168.       }
  169.       if (global.configuration.get().bot.debug) {
  170.         global.log.debug('Get current hosts', options)
  171.       }
  172.       global.client.api(options, function (err, res, body) {
  173.         if (err) {
  174.           if (err.code !== 'ETIMEDOUT' && err.code !== 'ECONNRESET') global.log.error(err, { fnc: 'Twitch#4' })
  175.           return
  176.         }
  177.         if (global.configuration.get().bot.debug) {
  178.           global.log.debug('Response: Get current hosts', body)
  179.         }
  180.         if (res.statusCode === 200 && !_.isNull(body)) {
  181.           self.currentHosts = body.hosts.length
  182.         }
  183.       })
  184.     }
  185.  
  186.     options = {
  187.       url: 'https://api.twitch.tv/kraken',
  188.       headers: {
  189.         'Client-ID': global.configuration.get().twitch.clientId
  190.       }
  191.     }
  192.     if (global.configuration.get().bot.debug) {
  193.       global.log.debug('Get API connection status', options)
  194.     }
  195.     global.client.api(options, function (err, res, body) {
  196.       if (err) {
  197.         global.status.API = constants.DISCONNECTED
  198.         return
  199.       }
  200.       if (global.configuration.get().bot.debug) {
  201.         global.log.debug('Response: Get API connection status', body)
  202.       }
  203.       global.status.API = res.statusCode === 200 ? constants.CONNECTED : constants.DISCONNECTED
  204.     })
  205.   }, 10000)
  206.  
  207.   global.parser.register(this, '!uptime', this.uptime, constants.VIEWERS)
  208.   global.parser.register(this, '!lastseen', this.lastseen, constants.VIEWERS)
  209.   global.parser.register(this, '!watched', this.watched, constants.VIEWERS)
  210.   global.parser.register(this, '!followage', this.followage, constants.VIEWERS)
  211.   global.parser.register(this, '!age', this.age, constants.VIEWERS)
  212.   global.parser.register(this, '!me', this.showMe, constants.VIEWERS)
  213.   global.parser.register(this, '!top', this.showTop, constants.OWNER_ONLY)
  214.   global.parser.register(this, '!title', this.setTitle, constants.OWNER_ONLY)
  215.   global.parser.register(this, '!game', this.setGame, constants.OWNER_ONLY)
  216.  
  217.   global.parser.registerParser(this, 'lastseen', this.lastseenUpdate, constants.VIEWERS)
  218.  
  219.   global.configuration.register('uptimeFormat', 'core.settings.uptime-format', 'string', '(days)(hours)(minutes)(seconds)')
  220.  
  221.   this.webPanel()
  222. }
  223.  
  224. Twitch.prototype._load = function (self) {
  225.   global.botDB.findOne({ _id: 'cachedGamesTitles' }, function (err, item) {
  226.     if (err) return global.log.error(err, { fnc: 'Twitch.prototype._load' })
  227.     if (_.isNull(item)) return
  228.     self.cGamesTitles = item
  229.   })
  230.   global.botDB.findOne({ _id: 'when' }, function (err, item) {
  231.     if (err) return global.log.error(err, { fnc: 'Twitch.prototype._load#2' })
  232.     if (_.isNull(item)) return
  233.     self.when = item
  234.   })
  235.   global.botDB.findOne({ _id: 'cached' }, function (err, item) {
  236.     if (err) return global.log.error(err, { fnc: 'Twitch.prototype._load#3' })
  237.     if (_.isNull(item)) return
  238.     self.cached = item
  239.   })
  240. }
  241.  
  242. Twitch.prototype._save = function (self) {
  243.   var cachedGamesTitles = self.cGamesTitles
  244.   cachedGamesTitles._id = 'cachedGamesTitles'
  245.   global.botDB.remove({ _id: cachedGamesTitles._id })
  246.   global.botDB.insert(cachedGamesTitles)
  247.   global.botDB.update({ _id: 'when' }, { $set: self.when }, { upsert: true })
  248.   global.botDB.update({ _id: 'cached' }, { $set: self.cached }, { upsert: true })
  249.   self.timestamp = new Date().getTime()
  250. }
  251.  
  252. Twitch.prototype.saveStream = function (stream) {
  253.   this.currentViewers = stream.viewers
  254.   this.when.online = stream.created_at
  255.   this.maxViewers = this.maxViewers < this.currentViewers ? this.currentViewers : this.maxViewers
  256.  
  257.   var messages = global.parser.linesParsed - this.chatMessagesAtStart
  258.   global.stats.save({
  259.     timestamp: new Date().getTime(),
  260.     whenOnline: this.when.online,
  261.     currentViewers: this.currentViewers,
  262.     chatMessages: messages,
  263.     currentFollowers: this.currentFollowers,
  264.     currentViews: this.currentViews,
  265.     maxViewers: this.maxViewers,
  266.     newChatters: this.newChatters,
  267.     game: this.currentGame,
  268.     status: this.currentStatus,
  269.     currentHosts: this.currentHosts
  270.   })
  271. }
  272.  
  273. Twitch.prototype.webPanel = function () {
  274.   global.panel.addWidget('twitch', 'widget-title-monitor', 'facetime-video')
  275.   global.panel.socketListening(this, 'getTwitchVideo', this.sendTwitchVideo)
  276.   global.panel.socketListening(this, 'getStats', this.sendStats)
  277. }
  278.  
  279. Twitch.prototype.sendStats = function (self, socket) {
  280.   var messages = self.isOnline ? global.parser.linesParsed - self.chatMessagesAtStart : 0
  281.   var data = {
  282.     uptime: self.getTime(self.when.online, false),
  283.     currentViewers: self.currentViewers,
  284.     maxViewers: self.maxViewers,
  285.     chatMessages: messages > 20000 ? (messages / 1000) + 'k' : messages,
  286.     currentFollowers: self.currentFollowers,
  287.     currentViews: self.currentViews,
  288.     newChatters: self.newChatters,
  289.     game: self.currentGame,
  290.     status: self.currentStatus,
  291.     currentHosts: self.currentHosts
  292.   }
  293.   socket.emit('stats', data)
  294. }
  295.  
  296. Twitch.prototype.sendTwitchVideo = function (self, socket) {
  297.   socket.emit('twitchVideo', global.configuration.get().twitch.channel.toLowerCase())
  298. }
  299.  
  300. Twitch.prototype.isOnline = function () {
  301.   return this.isOnline
  302. }
  303.  
  304. Twitch.prototype.getTime = function (time, isChat) {
  305.   var now, days, hours, minutes, seconds
  306.   now = _.isNull(time) || !time ? {days: 0, hours: 0, minutes: 0, seconds: 0} : moment().preciseDiff(time, true)
  307.   if (isChat) {
  308.     days = now.days > 0 ? now.days + 'd' : ''
  309.     hours = now.hours > 0 ? now.hours + 'h' : ''
  310.     minutes = now.minutes > 0 ? now.minutes + 'm' : ''
  311.     seconds = now.seconds > 0 ? now.seconds + 's' : ''
  312.     return { days: days,
  313.       hours: hours,
  314.       minutes: minutes,
  315.       seconds: seconds }
  316.   } else {
  317.     days = now.days > 0 ? now.days + 'd' : ''
  318.     hours = now.hours >= 0 && now.hours < 10 ? '0' + now.hours + ':' : now.hours + ':'
  319.     minutes = now.minutes >= 0 && now.minutes < 10 ? '0' + now.minutes + ':' : now.minutes + ':'
  320.     seconds = now.seconds >= 0 && now.seconds < 10 ? '0' + now.seconds : now.seconds
  321.     return days + hours + minutes + seconds
  322.   }
  323. }
  324.  
  325. Twitch.prototype.uptime = function (self, sender) {
  326.   const time = self.getTime(self.isOnline ? self.when.online : self.when.offline, true)
  327.   global.commons.sendMessage(global.translate(self.isOnline ? 'core.online' : 'core.offline')
  328.     .replace('(time)', global.configuration.getValue('uptimeFormat')
  329.     .replace('(days)', time.days)
  330.     .replace('(hours)', time.hours)
  331.     .replace('(minutes)', time.minutes)
  332.     .replace('(seconds)', time.seconds)), sender)
  333. }
  334.  
  335. Twitch.prototype.lastseenUpdate = function (self, id, sender, text) {
  336.   if (_.isNull(sender)) {
  337.     global.updateQueue(id, true)
  338.     return
  339.   }
  340.   global.users.set(sender.username, { time: { message: new Date().getTime() } }, true)
  341.   if (_.isUndefined(global.users.get(sender.username).is) || !global.users.get(sender.username).is.online) global.users.set(sender.username, { is: { online: true } }, true)
  342.   global.users.set(sender.username, { is: { subscriber: sender.subscriber } }, true) // save subscriber status
  343.   global.updateQueue(id, true)
  344. }
  345.  
  346. Twitch.prototype.followage = function (self, sender, text) {
  347.   let username
  348.   let parsed = text.match(/^(\S?)+$/g)
  349.   if (parsed[0].length > 0) username = parsed[0]
  350.   else username = sender.username
  351.  
  352.   global.users.isFollower(username)
  353.  
  354.   const user = global.users.get(username)
  355.   if (_.isNil(user) || _.isNil(user.time) || _.isNil(user.time.follow) || _.isNil(user.is.follower) || !user.is.follower) {
  356.     global.commons.sendMessage(global.translate('followage.success.never').replace('(username)', username), sender)
  357.   } else {
  358.     let diff = moment.preciseDiff(user.time.follow, moment(), true)
  359.     let output = []
  360.     if (diff.years) output.push(diff.years + ' ' + global.parser.getLocalizedName(diff.years, 'core.years'))
  361.     if (diff.months) output.push(diff.months + ' ' + global.parser.getLocalizedName(diff.months, 'core.months'))
  362.     if (diff.days) output.push(diff.days + ' ' + global.parser.getLocalizedName(diff.days, 'core.days'))
  363.     if (diff.hours) output.push(diff.hours + ' ' + global.parser.getLocalizedName(diff.hours, 'core.hours'))
  364.     global.commons.sendMessage(global.translate('followage.success.time')
  365.       .replace('(username)', username)
  366.       .replace('(diff)', output.join(', ')), sender)
  367.   }
  368. }
  369.  
  370. Twitch.prototype.age = function (self, sender, text) {
  371.   let username
  372.   let parsed = text.match(/^(\S?)+$/g)
  373.   if (parsed[0].length > 0) username = parsed[0].toLowerCase()
  374.   else username = sender.username
  375.  
  376.   const user = global.users.get(username)
  377.   if (_.isNil(user) || _.isNil(user.time) || _.isNil(user.time.created_at)) {
  378.     global.commons.sendMessage(global.translate('age.failed').replace('(username)', username), sender)
  379.   } else {
  380.     let diff = moment.preciseDiff(user.time.created_at, moment(), true)
  381.     let output = []
  382.     if (diff.years) output.push(diff.years + ' ' + global.parser.getLocalizedName(diff.years, 'core.years'))
  383.     if (diff.months) output.push(diff.months + ' ' + global.parser.getLocalizedName(diff.months, 'core.months'))
  384.     if (diff.days) output.push(diff.days + ' ' + global.parser.getLocalizedName(diff.days, 'core.days'))
  385.     if (diff.hours) output.push(diff.hours + ' ' + global.parser.getLocalizedName(diff.hours, 'core.hours'))
  386.     global.commons.sendMessage(global.translate(sender.username.toLowerCase() !== username.toLowerCase() ? 'age.success.withUsername' : 'age.success.withoutUsername')
  387.       .replace('(username)', username)
  388.       .replace('(diff)', output.join(', ')), sender)
  389.   }
  390. }
  391.  
  392. Twitch.prototype.lastseen = function (self, sender, text) {
  393.   try {
  394.     var parsed = text.match(/^([\u0500-\u052F\u0400-\u04FF\w]+)$/)
  395.     const user = global.users.get(parsed[0])
  396.     if (_.isNil(user) || _.isNil(user.time) || _.isNil(user.time.message)) {
  397.       global.commons.sendMessage(global.translate('lastseen.success.never').replace('(username)', parsed[0]), sender)
  398.     } else {
  399.       global.commons.sendMessage(global.translate('lastseen.success.time')
  400.         .replace('(username)', parsed[0])
  401.         .replace('(when)', moment.unix(user.time.message / 1000).format('DD-MM-YYYY HH:mm:ss')), sender)
  402.     }
  403.   } catch (e) {
  404.     global.commons.sendMessage(global.translate('lastseen.failed.parse'), sender)
  405.   }
  406. }
  407.  
  408. Twitch.prototype.watched = function (self, sender, text) {
  409.   try {
  410.     let watched, parsed
  411.     parsed = text.match(/^([\u0500-\u052F\u0400-\u04FF\w]+)$/)
  412.     const user = global.users.get(text.trim() < 1 ? sender.username : parsed[0])
  413.     watched = parseInt(!_.isNil(user) && !_.isNil(user.time) && !_.isNil(user.time.watched) ? user.time.watched : 0) / 1000 / 60 / 60
  414.  
  415.     let username = (global.configuration.getValue('atUsername') ? '@' : '') + user.username
  416.     global.commons.sendMessage(global.translate('watched.success.time')
  417.       .replace('(time)', watched.toFixed(1))
  418.       .replace('(username)', username), sender)
  419.   } catch (e) {
  420.     global.commons.sendMessage(global.translate('watched.failed.parse'), sender)
  421.   }
  422. }
  423.  
  424. Twitch.prototype.showMe = function (self, sender, text) {
  425.   try {
  426.     const user = global.users.get(sender.username)
  427.     var message = ['(sender)']
  428.     // rank
  429.     var rank = !_.isUndefined(user.rank) ? user.rank : null
  430.     rank = !_.isNil(user.custom.rank) ? user.custom.rank : null
  431.     if (global.configuration.get().systems.ranks === true && !_.isNull(rank)) message.push(rank)
  432.  
  433.     // watchTime
  434.     var watchTime = _.isFinite(parseInt(user.time.watched, 10)) && _.isNumber(parseInt(user.time.watched, 10)) ? user.time.watched : 0
  435.     message.push((watchTime / 1000 / 60 / 60).toFixed(1) + 'h')
  436.  
  437.     // points
  438.     var points = !_.isUndefined(user.points) ? user.points : 0
  439.     if (global.configuration.get().systems.points === true) message.push(points + ' ' + global.systems.points.getPointsName(points))
  440.  
  441.     // message count
  442.     var messages = !_.isUndefined(user.stats.messages) ? user.stats.messages : 0
  443.     message.push(messages + ' ' + global.parser.getLocalizedName(messages, 'core.messages'))
  444.  
  445.     global.commons.sendMessage(message.join(' | '), sender)
  446.   } catch (e) {
  447.     global.log.error(e, { fnc: 'Twitch.prototype.showMe' })
  448.   }
  449. }
  450.  
  451. Twitch.prototype.showTop = function (self, sender, text) {
  452.   try {
  453.     let sorted, message
  454.     let type = text.trim().match(/^(time|points)$/)
  455.  
  456.     if (_.isNil(type)) type = 'time'
  457.     else type = type[1]
  458.  
  459.     if (type === 'points' && global.commons.isSystemEnabled('points')) {
  460.       sorted = _.orderBy(_.filter(global.users.users, function (o) { return !_.isNil(o.points) && !global.parser.isOwner(o.username) && o.username !== global.configuration.get().twitch.username }), 'points', 'desc')
  461.     } else {
  462.       sorted = _.orderBy(_.filter(global.users.users, function (o) { return !_.isNil(o.time.watched) && !global.parser.isOwner(o.username) && o.username !== global.configuration.get().twitch.username }), 'time.watched', 'desc')
  463.     }
  464.  
  465.     sorted = _.chunk(_.map(sorted, 'username'), 10)[0]
  466.  
  467.     message = global.translate(type === 'points' ? 'top.listPoints' : 'top.listWatched').replace('(amount)', 10)
  468.     _.each(sorted, function (username, index) {
  469.       message += (index + 1) + '. ' + (global.configuration.getValue('atUsername') ? '@' : '') + username + ' - '
  470.       if (type === 'time') message += (global.users.get(username).time.watched / 1000 / 60 / 60).toFixed(1) + 'h'
  471.       else message += global.users.get(username).points + ' ' + global.systems.points.getPointsName(global.users.get(username).points)
  472.       if (index + 1 < 10) message += ', '
  473.     })
  474.     global.commons.sendMessage(message, sender)
  475.   } catch (e) {
  476.     console.log(e)
  477.     global.log.error(e)
  478.   }
  479. }
  480.  
  481. Twitch.prototype.setTitleAndGame = async function (self, sender, args) {
  482.   args = _.defaults(args, { title: null }, { game: null })
  483.  
  484.   const options = {
  485.     url: 'https://api.twitch.tv/kraken/channels/' + global.channelId,
  486.     json: true,
  487.     method: 'PUT',
  488.     body: {
  489.       channel: {
  490.         game: !_.isNull(args.game) ? args.game : self.currentGame,
  491.         status: !_.isNull(args.title) ? args.title : self.currentStatus
  492.       }
  493.     },
  494.     headers: {
  495.       Accept: 'application/vnd.twitchtv.v5+json',
  496.       Authorization: 'OAuth ' + global.configuration.get().twitch.password.split(':')[1]
  497.     }
  498.   }
  499.   if (global.configuration.get().bot.debug) {
  500.     global.log.debug('Updating game and title ', options)
  501.   }
  502.  
  503.   try {
  504.     const response = await request(options)
  505.     if (global.configuration.get().bot.debug) {
  506.       global.log.debug('Response: Updating game and title ', response)
  507.     }
  508.  
  509.     if (!_.isNull(args.game)) {
  510.       if (response.game === args.game.trim()) {
  511.         global.commons.sendMessage(global.translate('game.change.success')
  512.           .replace('(game)', response.game), sender)
  513.         self.currentGame = response.game
  514.       } else {
  515.         global.commons.sendMessage(global.translate('game.change.failed')
  516.           .replace('(game)', self.currentGame), sender)
  517.       }
  518.     }
  519.  
  520.     if (!_.isNull(args.title)) {
  521.       if (response.status === args.title.trim()) {
  522.         global.commons.sendMessage(global.translate('title.change.success')
  523.           .replace('(status)', response.status), sender)
  524.         self.currentStatus = response.status
  525.       } else {
  526.         global.commons.sendMessage(global.translate('title.change.failed')
  527.           .replace('(status)', self.currentStatus), sender)
  528.       }
  529.     }
  530.   } catch (e) {
  531.     if (global.configuration.get().bot.debug) {
  532.       global.log.debug('Response: Updating game and title ', e.message)
  533.     }
  534.   }
  535.   /*
  536.   global.client.api(options, function (err, res, body) {
  537.     if (err) { return global.log.error(err, { fnc: 'Twitch.prototype.setTitleAndGame' }) }
  538.  
  539.     if (global.configuration.get().bot.debug) {
  540.       global.log.debug('Response: Updating game and title ', body)
  541.     }
  542.  
  543.     if (!_.isNull(args.game)) {
  544.       if (body.game === args.game.trim()) {
  545.         global.commons.sendMessage(global.translate('game.change.success')
  546.           .replace('(game)', body.game), sender)
  547.         self.currentGame = body.game
  548.       } else {
  549.         global.commons.sendMessage(global.translate('game.change.failed')
  550.           .replace('(game)', self.currentGame), sender)
  551.       }
  552.     }
  553.  
  554.     if (!_.isNull(args.title)) {
  555.       if (body.status === args.title.trim()) {
  556.         global.commons.sendMessage(global.translate('title.change.success')
  557.           .replace('(status)', body.status), sender)
  558.         self.currentStatus = body.status
  559.       } else {
  560.         global.commons.sendMessage(global.translate('title.change.failed')
  561.           .replace('(status)', self.currentStatus), sender)
  562.       }
  563.     }
  564.   })
  565.   */
  566. }
  567.  
  568. Twitch.prototype.setTitle = function (self, sender, text) {
  569.   if (text.trim().length === 0) {
  570.     global.commons.sendMessage(global.translate('title.current')
  571.       .replace('(title)', self.currentStatus), sender)
  572.     return
  573.   }
  574.   self.setTitleAndGame(self, sender, { title: text })
  575. }
  576.  
  577. Twitch.prototype.setGame = function (self, sender, text) {
  578.   if (text.trim().length === 0) {
  579.     global.commons.sendMessage(global.translate('game.current')
  580.       .replace('(game)', self.currentGame), sender)
  581.     return
  582.   }
  583.   self.setTitleAndGame(self, sender, { game: text })
  584. }
  585.  
  586. Twitch.prototype.sendGameFromTwitch = function (self, socket, game) {
  587.   const options = {
  588.     url: 'https://api.twitch.tv/kraken/search/games?query=' + encodeURIComponent(game) + '&type=suggest',
  589.     json: true,
  590.     headers: {
  591.       Accept: 'application/vnd.twitchtv.v5+json',
  592.       'Client-ID': global.configuration.get().twitch.clientId
  593.     }
  594.   }
  595.  
  596.   if (global.configuration.get().bot.debug) {
  597.     global.log.debug('Search game on twitch ', options)
  598.   }
  599.  
  600.   global.client.api(options, function (err, res, body) {
  601.     if (err) { return global.log.error(err, { fnc: 'Twitch.prototype.sendGameFromTwitch' }) }
  602.  
  603.     if (global.configuration.get().bot.debug) {
  604.       global.log.debug('Response: Search game on twitch ', body)
  605.     }
  606.  
  607.     if (_.isNull(body.games)) {
  608.       socket.emit('sendGameFromTwitch', false)
  609.     } else {
  610.       socket.emit('sendGameFromTwitch', _.map(body.games, 'name'))
  611.     }
  612.   })
  613. }
  614.  
  615. Twitch.prototype.deleteUserTwitchGame = function (self, socket, game) {
  616.   delete self.cGamesTitles[game]
  617.   self.sendUserTwitchGamesAndTitles(self, socket)
  618. }
  619.  
  620. Twitch.prototype.deleteUserTwitchTitle = function (self, socket, data) {
  621.   _.remove(self.cGamesTitles[data.game], function (aTitle) {
  622.     return aTitle === data.title
  623.   })
  624.   self.sendUserTwitchGamesAndTitles(self, socket)
  625. }
  626.  
  627. Twitch.prototype.sendUserTwitchGamesAndTitles = function (self, socket) {
  628.   socket.emit('sendUserTwitchGamesAndTitles', self.cGamesTitles)
  629. }
  630.  
  631. Twitch.prototype.updateGameAndTitle = function (self, socket, data) {
  632.   self.setTitleAndGame(self, null, data)
  633.  
  634.   if (_.isUndefined(self.cGamesTitles[data.game])) { // create key if doesnt exists
  635.     self.cGamesTitles[data.game] = []
  636.   }
  637.  
  638.   if (self.cGamesTitles[data.game].indexOf(data.title) === -1) { // if unique
  639.     self.cGamesTitles[data.game].push(data.title) // also, we need to add game and title to cached property
  640.   }
  641.   self.sendStats(self, global.panel.io) // force dashboard update
  642. }
  643.  
  644. module.exports = Twitch
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement
Public Pastes
Advertisement
We use cookies for various purposes including analytics. By continuing to use Pastebin, you agree to our use of cookies as described in the Cookies Policy.  OK, I Understand
Not a member of Pastebin yet?
Sign Up, it unlocks many cool features!