|
@@ -8,8 +8,9 @@ module.exports =
|
|
|
mergeUpdate: (req, res)->
|
|
mergeUpdate: (req, res)->
|
|
|
metrics.inc("tpds.merge-update")
|
|
metrics.inc("tpds.merge-update")
|
|
|
{filePath, user_id, projectName} = parseParams(req)
|
|
{filePath, user_id, projectName} = parseParams(req)
|
|
|
- logger.log user_id:user_id, filePath:filePath, fullPath:req.params[0], projectName:projectName, "reciving update request from tpds"
|
|
|
|
|
- tpdsUpdateHandler.newUpdate user_id, projectName, filePath, req, (err)->
|
|
|
|
|
|
|
+ source = req.headers["x-sl-update-source"] or "unknown"
|
|
|
|
|
+ logger.log user_id:user_id, filePath:filePath, fullPath:req.params[0], projectName:projectName, source: source, "reciving update request from tpds"
|
|
|
|
|
+ tpdsUpdateHandler.newUpdate user_id, projectName, filePath, req, source, (err)->
|
|
|
logger.log user_id:user_id, filePath:filePath, fullPath:req.params[0], "sending response that tpdsUpdate has been completed"
|
|
logger.log user_id:user_id, filePath:filePath, fullPath:req.params[0], "sending response that tpdsUpdate has been completed"
|
|
|
if err?
|
|
if err?
|
|
|
logger.err err:err, user_id:user_id, filePath:filePath, "error reciving update from tpds"
|
|
logger.err err:err, user_id:user_id, filePath:filePath, "error reciving update from tpds"
|
|
@@ -23,8 +24,9 @@ module.exports =
|
|
|
deleteUpdate: (req, res)->
|
|
deleteUpdate: (req, res)->
|
|
|
metrics.inc("tpds.delete-update")
|
|
metrics.inc("tpds.delete-update")
|
|
|
{filePath, user_id, projectName} = parseParams(req)
|
|
{filePath, user_id, projectName} = parseParams(req)
|
|
|
- logger.log user_id:user_id, filePath:filePath, projectName:projectName, fullPath:req.params[0], "reciving delete request from tpds"
|
|
|
|
|
- tpdsUpdateHandler.deleteUpdate user_id, projectName, filePath, (err)->
|
|
|
|
|
|
|
+ source = req.headers["x-sl-update-source"] or "unknown"
|
|
|
|
|
+ logger.log user_id:user_id, filePath:filePath, projectName:projectName, fullPath:req.params[0], source: source, "reciving delete request from tpds"
|
|
|
|
|
+ tpdsUpdateHandler.deleteUpdate user_id, projectName, filePath, source, (err)->
|
|
|
if err?
|
|
if err?
|
|
|
logger.err err:err, user_id:user_id, filePath:filePath, "error reciving update from tpds"
|
|
logger.err err:err, user_id:user_id, filePath:filePath, "error reciving update from tpds"
|
|
|
res.send(500)
|
|
res.send(500)
|
|
@@ -36,7 +38,7 @@ module.exports =
|
|
|
updateProjectContents: (req, res, next = (error) ->) ->
|
|
updateProjectContents: (req, res, next = (error) ->) ->
|
|
|
{project_id} = req.params
|
|
{project_id} = req.params
|
|
|
path = "/" + req.params[0] # UpdateMerger expects leading slash
|
|
path = "/" + req.params[0] # UpdateMerger expects leading slash
|
|
|
- source = req.headers["x-sl-update-source"]
|
|
|
|
|
|
|
+ source = req.headers["x-sl-update-source"] or "unknown"
|
|
|
logger.log project_id: project_id, path: path, source: source, "received project contents update"
|
|
logger.log project_id: project_id, path: path, source: source, "received project contents update"
|
|
|
UpdateMerger.mergeUpdate project_id, path, req, source, (error) ->
|
|
UpdateMerger.mergeUpdate project_id, path, req, source, (error) ->
|
|
|
return next(error) if error?
|
|
return next(error) if error?
|
|
@@ -46,7 +48,7 @@ module.exports =
|
|
|
deleteProjectContents: (req, res, next = (error) ->) ->
|
|
deleteProjectContents: (req, res, next = (error) ->) ->
|
|
|
{project_id} = req.params
|
|
{project_id} = req.params
|
|
|
path = "/" + req.params[0] # UpdateMerger expects leading slash
|
|
path = "/" + req.params[0] # UpdateMerger expects leading slash
|
|
|
- source = req.headers["x-sl-update-source"]
|
|
|
|
|
|
|
+ source = req.headers["x-sl-update-source"] or "unknown"
|
|
|
logger.log project_id: project_id, path: path, source: source, "received project contents delete request"
|
|
logger.log project_id: project_id, path: path, source: source, "received project contents delete request"
|
|
|
UpdateMerger.deleteUpdate project_id, path, source, (error) ->
|
|
UpdateMerger.deleteUpdate project_id, path, source, (error) ->
|
|
|
return next(error) if error?
|
|
return next(error) if error?
|