add bot to announce playlist and current track

.gitignore

@@ -2,5 +2,3 @@ node_modules
 old
 .env
 playlists/*
-
-test

src/irc-bot.js

@@ -2,16 +2,13 @@ const IRC = require('irc-framework')
 const bot = new IRC.Client()
 
 const { searchTrack, requestTrack, deleteTrack } = require('./spotify')
-const { getCurrentTrack, skipTrack, reset, poll } = require('./mpc-commands')
+const { getCurrentTrack, skipTrack, reset } = require('./mpc-commands')
 const { getMyPlaylist } = require('./linx-commands')
 const chalk = require('chalk')
 
 const owners = ['notnull']
-const helpers = ['notnull', 'rfa', 'substack']
-
 const autojoin = ['#anarchybots']
 
-setInterval(poll, 60000)
 const host = process.env.HOST || 'localhost'
 const port = process.env.PORT || 6667
 const nick = process.env.NICK || 'radiobot'
@@ -60,7 +57,7 @@ const handleQuit = event => {
 }
 
 const handleReset = event => {
-  if (!helpers.includes(event.nick)) return
+  if (!owners.includes(event.nick)) return
   reset(event)
 }
 

src/mpc-commands.js

@@ -1,22 +1,11 @@
 const { spawnSync } = require('child_process')
 const fs = require('fs')
 
-let playing = null
-
 const getPlaylist = () => {
   const { stderr, stdout } = spawnSync('mpc', ['playlist'])
   return { error: stderr.toString(), playlist: stdout.toString() }
 }
 
-const poll = () => {
-  const { stdout } = spawnSync('mpc', ['status'])
-  const nowPlaying = stdout.toString()
-  if (playing === nowPlaying) {
-    console.log('Song stopped playing. Skipping\n', nowPlaying)
-    spawnSync('mpc', ['next'])
-  } else playing = nowPlaying
-}
-
 const getCurrentTrack = () => {
   const { stderr, stdout } = spawnSync('mpc', ['current'])
   return { error: stderr.toString(), track: stdout.toString() }
@@ -64,7 +53,6 @@ const addAllPlaylists = async event => {
     ).then(() => {
       shuffleAllPlaylists()
       play()
-      return event.reply('Successfully reset playlists.')
     })
   } catch (e) {
     return handleError(e, event)
@@ -119,5 +107,4 @@ module.exports = {
   insertTrack,
   removeTrack,
   reset,
-  poll,
 }

src/playlistbot.js

@@ -0,0 +1,140 @@
+const icy = require('icy')
+const devnull = require('dev-null')
+const IRC = require('irc-framework')
+const bot = new IRC.Client()
+const chalk = require('chalk')
+
+const radioUrl = 'https://radio.anarchyplanet.org/live'
+const owners = ['data', 'notnull']
+var channels = ['#traumschule', '#apradio', '#anarchyplanet']
+var announcing = ['#apradio']
+const host = process.env.HOST || 'irc.anarchyplanet.org'
+const port = process.env.PORT || 6667
+const nick = process.env.NICK || 'playlist'
+
+var currentTrack = {}
+process.env.NODE_TLS_REJECT_UNAUTHORIZED = '0'
+
+// TODO on new streams to /live w/o metadata !np will give outdated data
+
+const log = message => {
+  console.log(chalk.magenta(message))
+}
+
+const announceTrack = msg => {
+  announcing.map(channel => bot.say(channel, msg))
+}
+
+const connectRadio = () => {
+  log('[ICY] Connecting')
+  try {
+    icy.get(radioUrl, function(res) {
+      console.error(res.headers)
+
+      res.on('metadata', metadata => {
+        const parsed = icy.parse(metadata)
+        const track = parsed.StreamTitle
+        currentTrack = { track }
+        console.error(track)
+        announceTrack(track)
+      })
+
+      res.pipe(devnull())
+    })
+  } catch (e) {
+    log(`[ICY]  Failed to connect: $(e.message)`)
+  }
+}
+
+const connectIRC = () => {
+  log(`[IRC] Connecting to ${host}`)
+  try {
+    bot.connect({ host, port, nick })
+    bot.on('connected', () => {
+      log(`[IRC] Joining ${channels.join(', ')}`)
+      channels.map(c => bot.join(c))
+      connectRadio()
+    })
+    bot.on('socket close', () => {
+      log('[IRC] Reconnecting ..')
+      bot.connect({ host, port, nick })
+    })
+
+    // handle commands
+    bot.matchMessage(/^\?np/, event => sendCurrentTrack(event))
+    bot.matchMessage(/^\?help/, event => sendHelp(event))
+    bot.matchMessage(/^\?join/, event => handleJoin(event))
+    bot.matchMessage(/^\?part/, event => handlePart(event))
+    bot.matchMessage(/^\?quit/, event => handleQuit(event))
+    bot.matchMessage(/^\?announce/, event => handleAnnounce(event))
+    bot.matchMessage(/^\?unannounce/, event => handleUnannounce(event))
+    bot.matchMessage(/^\?channels/, event => sendChannels(event))
+  } catch (e) {
+    log(`[IRC] Failed to connect: ${e.message}`)
+  }
+}
+
+const sendHelp = event => {
+  const chans = announcing.join(', ')
+  const helpMsg = `Announcing radio playlist in ${chans} | ?np shows current track.`
+  const adminMsg =
+    ' ?[un]announce [OPTIONAL #chan] shows playlist in current or supplied channel. Other comamnds: ?channels ?join ?part ?quit'
+  if (owners.includes(event.nick)) return event.reply(helpMsg + adminMsg)
+  event.reply(helpMsg)
+}
+
+const sendCurrentTrack = event => {
+  const { error, track } = currentTrack
+  if (error) return event.reply('Something went wrong.')
+  if (track.length === 0) return event.reply('Nothing is currently playing.')
+  event.reply(track)
+}
+
+const sendChannels = event => {
+  if (!owners.includes(event.nick)) return
+  const str = [announcing.join(' '), channels.join(' ')]
+  event.reply(`Announcing radio playlist in ${str[0]}. Joined ${str[1]}.`)
+}
+
+const handleJoin = event => {
+  if (!owners.includes(event.nick)) return
+  const channel = event.message.split(' ')[1]
+  log(`Joining ${channel} (${event.nick})`)
+  bot.join(channel)
+  channels.concat(channel)
+}
+
+const handlePart = event => {
+  if (!owners.includes(event.nick)) return
+  const channel = event.message.split(' ')[1]
+  log(`Parting ${channel} (${event.nick})`)
+  bot.part(channel)
+  channels.filter(c => c !== channel)
+}
+
+const handleQuit = event => {
+  if (!owners.includes(event.nick)) return
+  log(`${event.nick} requested to quit.`)
+  bot.quit('time to die')
+  process.exit()
+}
+
+const handleAnnounce = event => {
+  console.log(event)
+  if (!owners.includes(event.nick)) return
+  const arg = event.message.split(' ')[1]
+  const channel = arg ? arg : event.target
+  log(`Announcing in ${channel} (${event.nick})`)
+  announcing = announcing.concat(channel)
+  if (!arg) sendCurrentTrack(event)
+}
+
+const handleUnannounce = event => {
+  if (!owners.includes(event.nick)) return
+  const arg = event.message.split(' ')[1]
+  const channel = arg ? arg : event.target
+  log(`Unannouncing in ${channel} (${event.nick})`)
+  announcing = announcing.filter(c => c !== channel)
+}
+
+connectIRC()