codecombat/server/routes/queue.coffee

log = require 'winston'
errors = require '../commons/errors'
scoringQueue = require '../queues/scoring'


module.exports.setup = (app) ->
  scoringQueue.setup()

  #app.post '/queue/scoring/pairwise', (req, res) ->
  #  handler = loadQueueHandler 'scoring'
  #  handler.addPairwiseTaskToQueue req, res
  
  app.get '/queue/messagesInQueueCount', (req, res) ->
    handler = loadQueueHandler 'scoring'
    handler.messagesInQueueCount req, res
    
  app.post '/queue/scoring/resimulateAllSessions', (req, res) ->
    handler = loadQueueHandler 'scoring'
    handler.resimulateAllSessions req, res
    
  app.post '/queue/scoring/getTwoGames', (req, res) ->
    handler = loadQueueHandler 'scoring'
    handler.getTwoGames req, res    
  
  app.put '/queue/scoring/recordTwoGames', (req, res) ->
    handler = loadQueueHandler 'scoring'
    handler.recordTwoGames req, res
    
  app.all '/queue/*', (req, res) ->
    setResponseHeaderToJSONContentType res
      
    queueName = getQueueNameFromPath req.path
    try
      handler = loadQueueHandler queueName
      if isHTTPMethodGet req
        handler.dispatchTaskToConsumer req,res
      else if isHTTPMethodPut req
        handler.processTaskResult req,res
      else if isHTTPMethodPost req
        handler.createNewTask req, res #TODO: do not use this in production
      else
        sendMethodNotSupportedError req, res
    catch error
      log.error error
      sendQueueError req, res, error
  

setResponseHeaderToJSONContentType = (res) -> res.setHeader('Content-Type', 'application/json')

getQueueNameFromPath = (path) ->
  pathPrefix = '/queue/'
  pathAfterPrefix = path[pathPrefix.length..]
  partsOfURL = pathAfterPrefix.split '/'
  queueName = partsOfURL[0]
  queueName

loadQueueHandler = (queueName) -> require ('../queues/' + queueName)


isHTTPMethodGet = (req) -> return req.route.method is 'get'

isHTTPMethodPost = (req) -> return req.route.method is 'post'

isHTTPMethodPut = (req) -> return req.route.method is 'put'


sendMethodNotSupportedError = (req, res) -> errors.badMethod(res,"Queues do not support the HTTP method used." )

sendQueueError = (req,res, error) -> errors.serverError(res, "Route #{req.path} had a problem: #{error}")