server.js

var es = require('./es')
var http = require('http')
var rut = require('rut')
var stack = require('stack')

var port = process.env.PORT || process.argv[2] || 1039

stack.handler = function (req, res, err) {
  if (err) {
    if (err.status) {
      res.statusCode = err.status
      return res.send('{"message": "' + err.message + '"}')
    }
    console.error(err.stack)
    res.statusCode = 500
    return res.send('{"message": "Internal Server Error"}')
  }
  console.warn('Warning: Not Found')
  res.statusCode = 404
  res.send('{"message": "Not Found"}')
}

var cors = function (req, res, next) {
  res.setHeader('Access-Control-Allow-Origin', '*')
  next()
}

var jsonContent = function (req, res, next) {
  res.setHeader('Content-Type', 'application/json')

  // Provide a method that sets content length to avoid 
  // transer-encoding: chunked in old nginx
  res.send = function (content) {
    content = content + '\n'
    res.setHeader('Content-Length', Buffer.byteLength(content))
    res.end(content)
  }

  next()
}

var reqLog = function (req, res, next) {
  console.log(req.method, req.url)
  next()
}

var reqUser = function (req, res, next) {
  var token = req.headers.authorization
  //var token = req.headers.authorization
  //console.log(req.headers);
  if (!token) return next()

  es.search({_type: 'user'}, {
    query: {filtered: {filter: {term: {token: token}}}}
  }, function (err, data) {
    if (err) return next(err)
    if (!data.hits.hits.length) return next({status: 401, message: 'Unauthorized'})
    req.user = data.hits.hits[0]._source
    next()
  })
}

http.createServer(stack(
  cors,
  jsonContent,
  reqLog,
  reqUser,
  rut.get('/', require('./routes')),
  rut.get('/search', require('./routes/search')),
  rut.get('/schemas', require('./routes/schemas')),
  rut.get('/wgxc/schedule/*', require('./routes/wgxc/schedule')),
  rut.get('/ta/schedule/*', require('./routes/ta/schedule')),
  rut.get('/wgxc/index-gallery', require('./routes/wgxc/index-gallery')),
  rut.get('/ta/index-gallery', require('./routes/ta/index-gallery')),
  rut.get('/ta/artists/*', require('./routes/ta/artist-index')),
  rut.get('/ta/artists', require('./routes/ta/artist-index')),
  rut.get('/ta/works/*', require('./routes/ta/work-index')),
  rut.get('/ta/works', require('./routes/ta/work-index')),
  rut.post('/add-event', require('./routes/add-event')),
  //rut.get('/related-items/*/*/*', require('./routes/related-items')),
  rut.post('/login', require('./routes/login')),
  rut.post('/bulk', require('./routes/bulk')),
  rut.post('/', require('./routes/item-set')),
  rut.get(/^\/(\w{6})$/, require('./routes/item-get')),
  rut.put(/^\/(\w{6})$/, require('./routes/item-set')),
  rut.delete(/^\/(\w{6})$/, require('./routes/item-delete')),
  //rut.get(/^\/genb\/(\w{6})\/(\w{4}-\w{2}-\w{2})\/(\w{4}-\w{2}-\w{2})$/, require('./routes/show-genb'))
  rut.post('/genb', require('./routes/show-genb'))
  
)).listen(port, function () {
  console.log('Listening on port', port)
  if (process.send) process.send('online')
})