mirror of
https://github.com/codeninjasllc/codecombat.git
synced 2024-11-23 23:58:02 -05:00
61 lines
2 KiB
CoffeeScript
61 lines
2 KiB
CoffeeScript
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/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, ['GET', 'POST', 'PUT'], 'Queues do not support the HTTP method used.' )
|
|
|
|
sendQueueError = (req, res, error) -> errors.serverError(res, "Route #{req.path} had a problem: #{error}")
|