octoblu/meshblu-server-http

_      = require 'lodash'
Server = require './src/server'
UUID   = require 'uuid'

class Command
  constructor: ->
    @serverOptions =
      port:              parseInt process.env.PORT ? 80
      aliasServerUri:    process.env.ALIAS_SERVER_URI ? ''
      redisUri:          process.env.REDIS_URI
      cacheRedisUri:     process.env.CACHE_REDIS_URI ? process.env.REDIS_URI
      namespace:         process.env.NAMESPACE ? 'meshblu'
      jobTimeoutSeconds: parseInt process.env.JOB_TIMEOUT_SECONDS ? 30
      maxConnections:    parseInt process.env.CONNECTION_POOL_MAX_CONNECTIONS ? 100
      disableLogging:    (process.env.DISABLE_LOGGING ? 'true') == "true"
      jobLogRedisUri:    process.env.JOB_LOG_REDIS_URI ? process.env.REDIS_URI
      jobLogQueue:       process.env.JOB_LOG_QUEUE ? 'sample-rate:1.00'
      jobLogSampleRate:  parseFloat(process.env.JOB_LOG_SAMPLE_RATE ? 0)
      jobLogSampleRateOverrideUuids:  _.split process.env.JOB_LOG_SAMPLE_RATE_OVERRIDE_UUIDS, ','
      requestQueueName:  process.env.REQUEST_QUEUE_NAME ? 'v2:request:queue'
      responseQueueBaseName: process.env.RESPONSE_QUEUE_BASE_NAME ? 'v2:response:queue'

  panic: (error) =>
    console.error error.stack
    process.exit 1

  run: =>
    @panic new Error('Missing environment variable: ALIAS_SERVER_URI') unless @serverOptions.aliasServerUri?
    @panic new Error('Missing environment variable: REDIS_URI') if _.isEmpty @serverOptions.redisUri
    @panic new Error('Missing environment variable: CACHE_REDIS_URI') if _.isEmpty @serverOptions.cacheRedisUri
    @panic new Error('Missing environment variable: JOB_LOG_REDIS_URI') if _.isEmpty @serverOptions.jobLogRedisUri
    @panic new Error('Missing environment variable: JOB_LOG_SAMPLE_RATE') unless @serverOptions.jobLogSampleRate?
    @panic new Error('Missing environment variable: JOB_LOG_QUEUE') if _.isEmpty @serverOptions.jobLogQueue
    @panic new Error('Missing environment variable: REQUEST_QUEUE_NAME') if _.isEmpty @serverOptions.requestQueueName
    @panic new Error('Missing environment variable: RESPONSE_QUEUE_BASE_NAME') if _.isEmpty @serverOptions.responseQueueBaseName

    responseQueueId = UUID.v4()
    @serverOptions.responseQueueName = "#{@serverOptions.responseQueueBaseName}:#{responseQueueId}"

    server = new Server @serverOptions
    server.run (error) =>
      return @panic error if error?

      {address,port} = server.address()
      console.log "Server listening on #{address}:#{port}"

    process.on 'SIGTERM', =>
      console.log 'SIGTERM caught, exiting'
      return process.exit 0 unless server?.stop?
      server.stop =>
        process.exit 0

command = new Command()
command.run()