index.js

require('es6-promise').polyfill()

var itunes = require('playback')
var Hipchat = require('hipchatter')

var findMusic = require('./lib/find-music.js')
var detectCountry = require('./lib/detect-country.js')

var fetch = require('isomorphic-fetch')

module.exports = {
  listen: function run () {
    var prevTrack = {}
    itunes.on('playing', function (track) {
      if (isEqualTrack(track, prevTrack)) return

      if (process.env.AUTO_SEND === 'false') {
        return
      }

      findTrackAndNotify(track)
      prevTrack = track
    }) },

  sendNow: function sendNow () {
    itunes.currentTrack(function (track) {
      findTrackAndNotify(track)
    })
  }
}

function findTrackAndNotify (track) {
  detectCountry().then(function (country) {
    findMusic([ track.name, track.artist, track.album ], {
      country: country
    }).then(function (music) {
      if (music) return music

      return findMusic([track.name, track.artist], { country: country })
    }).then(function (music) {
      notify(track, music)
    }).catch(function (err) {
      console.error(err.stack)
    })
  })
}

function isEqualTrack (a, b) {
  if (!(typeof a === 'object' && typeof b === 'object')) return

  return a.name === b.name && a.artist === b.artist
}

function trackToString (track) {
  return track.name + ' - ' + track.artist
}

function messageForSlack (track, music) {
  function link (text, url) {
    return '<' + url + '|' + text + '>'
  }

  var trackStr = track.name

  var url = music && music.trackViewUrl
  var message = url ? link(trackStr, url) : trackStr

  return '🎵  ' + message
}

function messageForHipchat (track, music) {
  function link (text, url) {
    return '<a href="' + url + '">' + text + '</a>'
  }

  var trackStr = trackToString(track)
  var url = music && music.trackViewUrl

  var message = url ? link(trackStr, url) : trackStr
  return '🎵  ' + message
}

function notify (track, music) {
  console.log('🎵  ' + trackToString(track))
  if (process.env.HIPCHAT_TOKEN) {
    postToHipchat(messageForHipchat(track, music))
  }

  if (process.env.SLACK_WEBHOOK_URL) {
    postToSlack(messageForSlack(track, music), music, track)
  }
}

function postToSlack (message, music, track) {
  music = music || {}
  var webhookUrl = process.env.SLACK_WEBHOOK_URL
  var listenerName = process.env.LISTENER_NAME || 'somebody'
  var username = listenerName + ' playing ' + track.artist

  return fetch(webhookUrl, {
    method: 'post',
    body: JSON.stringify({
      text: message,
      username: username,
      icon_url: music.artworkUrl60
    })
  })
}

function postToHipchat (message) {
  var hipchat = new Hipchat(process.env.HIPCHAT_TOKEN)

  hipchat.notify(process.env.HIPCHAT_ROOM, {
    message: message,
    notify: true
  }, function (err) { if (err) console.error(err) })
}