mirror of
https://github.com/Unleash/unleash.git
synced 2025-01-25 00:07:47 +01:00
strategies should be fetched from DB
This commit is contained in:
parent
e3b8a868d1
commit
7c5aa8e5bb
@ -1,3 +1,5 @@
|
|||||||
|
var strategyDb = require('./strategyDb');
|
||||||
|
|
||||||
var strategies = [
|
var strategies = [
|
||||||
{
|
{
|
||||||
name: "default",
|
name: "default",
|
||||||
@ -21,7 +23,9 @@ function byName(name) {
|
|||||||
module.exports = function (app) {
|
module.exports = function (app) {
|
||||||
|
|
||||||
app.get('/strategies', function (req, res) {
|
app.get('/strategies', function (req, res) {
|
||||||
res.json({strategies: strategies});
|
strategyDb.getStrategies().then(function (strategies) {
|
||||||
|
res.json({strategies: strategies});
|
||||||
|
});
|
||||||
});
|
});
|
||||||
|
|
||||||
app.get('/strategies/:name', function (req, res) {
|
app.get('/strategies/:name', function (req, res) {
|
||||||
|
56
lib/strategyDb.js
Normal file
56
lib/strategyDb.js
Normal file
@ -0,0 +1,56 @@
|
|||||||
|
var eventStore = require('./eventStore');
|
||||||
|
var eventType = require('./eventType');
|
||||||
|
var logger = require('./logger');
|
||||||
|
var knex = require('./dbPool');
|
||||||
|
var STRATEGY_COLUMNS = ['name', 'description', 'parameters_template'];
|
||||||
|
|
||||||
|
eventStore.on(eventType.strategyCreated, function (event) {
|
||||||
|
knex('strategies')
|
||||||
|
.insert(eventToRow(event))
|
||||||
|
.catch(function (err) {
|
||||||
|
logger.error('Could not insert strategy, error was: ', err);
|
||||||
|
});
|
||||||
|
});
|
||||||
|
|
||||||
|
function getStrategies() {
|
||||||
|
return knex
|
||||||
|
.select(STRATEGY_COLUMNS)
|
||||||
|
.from('strategies')
|
||||||
|
.orderBy('created_at', 'desc')
|
||||||
|
.map(rowToStrategy);
|
||||||
|
}
|
||||||
|
|
||||||
|
function getStrategy(name) {
|
||||||
|
return knex
|
||||||
|
.first(STRATEGY_COLUMNS)
|
||||||
|
.from('strategies')
|
||||||
|
.where({name: name})
|
||||||
|
.then(rowToStrategy);
|
||||||
|
}
|
||||||
|
|
||||||
|
function rowToStrategy(row) {
|
||||||
|
if (!row) {
|
||||||
|
throw new Error('invalid row');
|
||||||
|
}
|
||||||
|
|
||||||
|
return {
|
||||||
|
name: row.name,
|
||||||
|
description: row.description,
|
||||||
|
enabled: row.enabled > 0,
|
||||||
|
parametersTemplate: row.parameters_template // jshint ignore: line
|
||||||
|
};
|
||||||
|
}
|
||||||
|
|
||||||
|
function eventToRow(event) {
|
||||||
|
return {
|
||||||
|
name: event.data.name,
|
||||||
|
description: event.data.description,
|
||||||
|
parameters_template: event.data.parametersTemplate // jshint ignore: line
|
||||||
|
};
|
||||||
|
}
|
||||||
|
|
||||||
|
module.exports = {
|
||||||
|
getStrategies: getStrategies,
|
||||||
|
getStrategy: getStrategy
|
||||||
|
};
|
||||||
|
|
Loading…
Reference in New Issue
Block a user