2014-12-10 19:11:52 +01:00
|
|
|
var Promise = require("bluebird");
|
|
|
|
var eventStore = require('./eventStore');
|
|
|
|
var eventType = require('./eventType');
|
|
|
|
var strategyDb = require('./strategyDb');
|
|
|
|
var logger = require('./logger');
|
|
|
|
var NameExistsError = require('./error/NameExistsError');
|
|
|
|
var ValidationError = require('./error/ValidationError');
|
|
|
|
var validateRequest = require('./error/validateRequest');
|
2014-11-17 22:39:04 +01:00
|
|
|
|
2014-10-30 21:10:48 +01:00
|
|
|
module.exports = function (app) {
|
|
|
|
|
|
|
|
app.get('/strategies', function (req, res) {
|
2014-11-17 22:39:04 +01:00
|
|
|
strategyDb.getStrategies().then(function (strategies) {
|
|
|
|
res.json({strategies: strategies});
|
|
|
|
});
|
2014-10-30 21:10:48 +01:00
|
|
|
});
|
|
|
|
|
|
|
|
app.get('/strategies/:name', function (req, res) {
|
2014-11-25 15:28:08 +01:00
|
|
|
strategyDb.getStrategy(req.params.name)
|
|
|
|
.then(function (strategy) { res.json(strategy); })
|
2014-12-05 17:20:17 +01:00
|
|
|
.catch(function () { res.status(404).json({error: 'Could not find strategy'}); });
|
2014-10-30 21:10:48 +01:00
|
|
|
});
|
|
|
|
|
2014-12-08 20:56:22 +01:00
|
|
|
app.delete('/strategies/:name', function (req, res) {
|
|
|
|
eventStore.create({
|
|
|
|
type: eventType.strategyDeleted,
|
|
|
|
createdBy: req.connection.remoteAddress,
|
|
|
|
data: {
|
|
|
|
name: req.params.name
|
|
|
|
}
|
|
|
|
})
|
|
|
|
.then(function () { res.status(200).end(); })
|
|
|
|
.catch(function () { res.status(500).end(); });
|
|
|
|
});
|
|
|
|
|
2014-10-30 21:10:48 +01:00
|
|
|
app.post('/strategies', function (req, res) {
|
2014-11-25 15:28:08 +01:00
|
|
|
req.checkBody('name', 'Name is required').notEmpty();
|
|
|
|
req.checkBody('name', 'Name must match format ^[a-zA-Z\\.\\-]+$').matches(/^[a-zA-Z\\.\\-]+$/i);
|
|
|
|
|
|
|
|
var newStrategy = req.body;
|
|
|
|
|
2014-12-10 19:11:52 +01:00
|
|
|
validateRequest(req)
|
|
|
|
.then(validateStrategyName)
|
|
|
|
.then(function() {
|
|
|
|
return eventStore.create({
|
|
|
|
type: eventType.strategyCreated,
|
|
|
|
createdBy: req.connection.remoteAddress,
|
|
|
|
data: newStrategy
|
|
|
|
});
|
2014-11-25 15:28:08 +01:00
|
|
|
})
|
2014-12-10 19:11:52 +01:00
|
|
|
.then(function () {
|
|
|
|
res.status(201).end();
|
|
|
|
})
|
|
|
|
.catch(NameExistsError, function() {
|
|
|
|
res.status(403).json([{msg: "A strategy named '" + req.body.name + "' already exists."}]).end();
|
|
|
|
})
|
|
|
|
.catch(ValidationError, function() {
|
|
|
|
res.status(400).json(req.validationErrors());
|
|
|
|
})
|
|
|
|
.catch(function(err) {
|
|
|
|
logger.error("Could not create strategy", err);
|
|
|
|
res.status(500).end();
|
|
|
|
});
|
2014-10-30 21:10:48 +01:00
|
|
|
});
|
|
|
|
|
2014-12-10 19:11:52 +01:00
|
|
|
function validateStrategyName(req) {
|
|
|
|
return new Promise(function(resolve, reject) {
|
|
|
|
strategyDb.getStrategy(req.body.name)
|
|
|
|
.then(function() {
|
|
|
|
reject(new NameExistsError("Feature name already exist"));
|
|
|
|
}, function() {
|
|
|
|
resolve(req);
|
|
|
|
});
|
|
|
|
});
|
|
|
|
}
|
|
|
|
|
2014-10-30 21:10:48 +01:00
|
|
|
};
|
|
|
|
|