Accept streaming if ?stream_key=xxxx is present

server.coffee

url = require 'url'

config = require './config'
StreamServer = require './stream_server'
Bits = require './bits'
logger = require './logger'

Bits.set_warning_fatal true
logger.setLevel logger.LEVEL_INFO

streamServer = new StreamServer
streamServer.setLivePathConsumer (uri, callback) ->
  uriInfo = url.parse uri, true
  if uriInfo.query.stream_key is 'xxxx'
    return callback null  # Accept access
  else
    return callback new Error 'Unauthorized'  # Deny access

if config.recordedDir?
  streamServer.attachRecordedDir config.recordedDir

process.on 'SIGINT', =>
  console.log 'Got SIGINT'
  streamServer.stop ->
    process.kill process.pid, 'SIGTERM'

process.on 'uncaughtException', (err) ->
  streamServer.stop()
  throw err

streamServer.start()