mirror of
https://github.com/codeninjasllc/codecombat.git
synced 2024-11-24 16:17:57 -05:00
64 lines
1.9 KiB
CoffeeScript
64 lines
1.9 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/resimulateAllSessions', (req, res) ->
|
|
handler = loadQueueHandler 'scoring'
|
|
handler.resimulateAllSessions 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}")
|
|
|
|
|