Nemcio/NodeBB
1
0
Fork 0
mirror of https://github.com/NodeBB/NodeBB.git synced 2026-03-06 20:41:17 +01:00
Code Issues Packages Projects Releases Wiki Activity

Merge remote-tracking branch 'origin/master' into develop

Browse Source
This commit is contained in:
Julian Lam
2017-02-15 12:06:52 -05:00
parent 0667870286 9e23d09e5e
commit fcaefbadca
113 changed files with 2486 additions and 383 deletions
Download Patch File Download Diff File Expand all files Collapse all files

109
src/rewards/admin.js
View File

@@ -1,35 +1,14 @@
"use strict";
var rewards = {},
async = require('async'),
plugins = require('../plugins'),
db = require('../database');
var async = require('async');
var plugins = require('../plugins');
var db = require('../database');
var rewards = module.exports;
rewards.save = function (data, callback) {
function save(data, next) {
function commit(err, id) {
if (err) {
return callback(err);
}
data.id = id;
async.series([
function (next) {
rewards.delete(data, next);
},
function (next) {
db.setAdd('rewards:list', data.id, next);
},
function (next) {
db.setObject('rewards:id:' + data.id, data, next);
},
function (next) {
db.setObject('rewards:id:' + data.id + ':rewards', rewardsData, next);
}
], next);
}
async.each(data, function save(data, next) {
if (!Object.keys(data.rewards).length) {
return next();
@@ -38,14 +17,36 @@ rewards.save = function (data, callback) {
var rewardsData = data.rewards;
delete data.rewards;
if (!parseInt(data.id, 10)) {
db.incrObjectField('global', 'rewards:id', commit);
} else {
commit(false, data.id);
}
}
async.waterfall([
function (next) {
if (!parseInt(data.id, 10)) {
db.incrObjectField('global', 'rewards:id', next);
} else {
next(null, data.id);
}
},
function (rid, next) {
async.each(data, save, function (err) {
data.id = rid;
async.series([
function (next) {
rewards.delete(data, next);
},
function (next) {
db.setAdd('rewards:list', data.id, next);
},
function (next) {
db.setObject('rewards:id:' + data.id, data, next);
},
function (next) {
db.setObject('rewards:id:' + data.id + ':rewards', rewardsData, next);
}
], next);
}
], next);
}, function (err) {
if (err) {
return callback(err);
}
@@ -84,25 +85,29 @@ rewards.get = function (callback) {
};
function saveConditions(data, callback) {
db.delete('conditions:active', function (err) {
if (err) {
return callback(err);
var rewardsPerCondition = {};
async.waterfall([
function (next) {
db.delete('conditions:active', next);
},
function (next) {
var conditions = [];
data.forEach(function (reward) {
conditions.push(reward.condition);
rewardsPerCondition[reward.condition] = rewardsPerCondition[reward.condition] || [];
rewardsPerCondition[reward.condition].push(reward.id);
});
db.setAdd('conditions:active', conditions, next);
},
function (next) {
async.each(Object.keys(rewardsPerCondition), function (condition, next) {
db.setAdd('condition:' + condition + ':rewards', rewardsPerCondition[condition], next);
}, next);
}
var conditions = [],
rewardsPerCondition = {};
data.forEach(function (reward) {
conditions.push(reward.condition);
rewardsPerCondition[reward.condition] = rewardsPerCondition[reward.condition] || [];
rewardsPerCondition[reward.condition].push(reward.id);
});
db.setAdd('conditions:active', conditions, callback);
async.each(Object.keys(rewardsPerCondition), function (condition, next) {
db.setAdd('condition:' + condition + ':rewards', rewardsPerCondition[condition], next);
}, callback);
], function (err) {
callback(err);
});
}
@@ -138,5 +143,3 @@ function getActiveRewards(callback) {
});
});
}
module.exports = rewards;

60
src/rewards/index.js
View File

@@ -1,40 +1,36 @@
"use strict";
var rewards = {},
db = require('../database'),
plugins = require('../plugins'),
async = require('async');
var db = require('../database');
var plugins = require('../plugins');
var async = require('async');
var rewards = module.exports;
rewards.checkConditionAndRewardUser = function (uid, condition, method, callback) {
callback = callback || function () {};
async.waterfall([
function (next) {
isConditionActive(condition, function (err, isActive) {
if (!isActive) {
return back(err);
}
next(err);
});
isConditionActive(condition, next);
},
function (next) {
getIDsByCondition(condition, function (err, ids) {
next(err, ids);
});
function (isActive, next) {
if (!isActive) {
return callback();
}
getIDsByCondition(condition, next);
},
function (ids, next) {
getRewardDataByIDs(ids, next);
},
function (rewards, next) {
filterCompletedRewards(uid, rewards, function (err, filtered) {
if (!filtered || !filtered.length) {
return back(err);
}
next(err, filtered);
});
filterCompletedRewards(uid, rewards, next);
},
function (rewards, next) {
if (!rewards || !rewards.length) {
return callback();
}
async.filter(rewards, function (reward, next) {
if (!reward) {
return next(null, false);
@@ -51,14 +47,7 @@ rewards.checkConditionAndRewardUser = function (uid, condition, method, callback
giveRewards(uid, eligible, next);
});
}
], back);
function back(err) {
if (typeof callback === 'function') {
callback(err);
}
}
], callback);
};
function isConditionActive(condition, callback) {
@@ -88,14 +77,10 @@ function filterCompletedRewards(uid, rewards, callback) {
var claimable = parseInt(reward.claimable, 10);
if (claimable === 0) {
return true;
}
return (userRewards[reward.id] >= reward.claimable) ? false : true;
return claimable === 0 || (userRewards[reward.id] < reward.claimable);
});
callback(false, rewards);
callback(null, rewards);
});
}
@@ -135,6 +120,3 @@ function giveRewards(uid, rewards, callback) {
}, callback);
});
}
module.exports = rewards;