routes.js

var fs = require('fs')
var hyperglue = require('hyperglue')
var cookieCutter = require('cookie-cutter')
var path = require('path')
var indexHtml = fs.readFileSync(path.join(__dirname, '/index.html'))
var tracksHtml = fs.readFileSync(path.join(__dirname, '/tracks.html'))
var searchTrack = require('./search/search')
var childProcess = require('child_process')
var hyperquest = require('hyperquest')
var debug = require('debug')('routes.js')
var querystring = require('querystring')
var player = null

module.exports = {
  emptyFavicon: emptyFavicon,
  main: main,
  appCss: appCss,
  search: search,
  authenticate: authenticate,
  stream: stream,
  play: play
}

function emptyFavicon (q, r, next) {
  r.writeHead(200, {'Content-Type': 'image/x-icon'})
  r.end()
}

function main (q, r, next) {
  var cookie = cookieCutter(q.headers.cookie)
  r.writeHead(200, {'Content-Type': 'text/html'})
  var searchTerm = cookie.get('search-track')
  if (searchTerm) debug('search %s', searchTerm)
  if (searchTerm) return addTracksToResponse(searchTerm, r)
  fs.createReadStream(path.join(__dirname, '/index.html')).pipe(r)
}

function addTracksToResponse (searchTerm, r) {
  searchTerm = encodeURIComponent(searchTerm)
  searchTrack(searchTerm, function (tracks) {
    var trackResponse = hyperglue(tracksHtml, {
      '.track': tracks.map(function (x) {
        var playUrl = '/play/' + new Buffer(JSON.stringify(x)).toString('base64')
        var track = {
          '.track-title': x.title,
          '.track-duration': x.duration,
          '.track-source': x.source
        }
        track['a'] = {href: playUrl}
        track['.track-player'] = {
          _html: '<p><span class="track-tap"></span></p>'
        }
        return track
      })
    }).innerHTML
    r.end(
      hyperglue(indexHtml, {
        '.search-query': {
          value: decodeURIComponent(searchTerm)
        },
        '#content': {_html: trackResponse}
      }).innerHTML
    )
  })
}

function appCss (q, r, next) {
  r.writeHead(200, {'Content-Type': 'text/css'})
  return fs.createReadStream(path.join(__dirname, '/app.css')).pipe(r)
}

function search (q, r, next) {
  var formData = ''
  q
    .on('data', data)
    .on('end', end)

  function data (x) {
    formData += x.toString()
  }

  function end () {
    var track = querystring.parse(formData).track
    r.writeHead(302, {'Location': '/', 'Set-Cookie': 'search-track=' + encodeURIComponent(track) + '; path=/; HttpOnly'})
    r.end()
  }
}

function authenticate (q, r, next) {
  if (!process.env.SERVICE_CREDENTIALS) return next()
  var credentials = q.headers.authorization
  if (credentials) {
    credentials = new Buffer(credentials.slice(6), 'base64').toString()
    if (credentials === process.env.SERVICE_CREDENTIALS) return next()
  }
  r.writeHead(401, {'WWW-Authenticate': 'Basic'})
  r.end('authentication required')
}

function play (q, r, next) {
  var remotePlayer = process.env.REMOTE_PLAYER
  if (remotePlayer) {
    hyperquest(remotePlayer + '/' + q.params[0])
  } else {
    if (player) player.kill()
    player = childProcess.fork(path.join(__dirname, '/player'))
    player.send(q.params[0])
  }
  r.writeHead(302, {'Location': '/'})
  r.end()
}

function stream (q, r, next) {
  var track = JSON.parse(new Buffer(q.params[0], 'base64').toString())
  debug('playing %s', track.uri)
  require('./stream/' + track.source)(track.uri).pipe(r)
}