kredits/hubot-kredits
9
0
Fork 0
Code Issues 8 Pull Requests Releases 9 Activity

Only fetch wiki changes since last processing

Browse Source
This commit is contained in:
Basti 2018-04-19 19:04:20 +02:00
parent d4a3a9c9df
commit c97cc82817
1 changed files with 14 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
integrations/mediawiki.js
View File

@ -65,6 +65,12 @@ module.exports = async function(robot, kredits) {
'rcprop=ids|title|timestamp|user|sizes|comment|flags'
];
let endTime = robot.brain.get('kredits:mediawiki:last_processed_at');
if (endTime) {
robot.logger.debug(`[hubot-kredits] Fetching wiki edits since ${endTime}`);
params.push(`rcend=${endTime}`);
}
const url = `${apiURL}?${params.join('&')}`;
return fetch(url).then(res => {
@ -83,7 +89,7 @@ module.exports = async function(robot, kredits) {
}
function groupChangesByUser (changes) {
return groupArray(changes, 'user');
return Promise.resolve(groupArray(changes, 'user'));
}
function analyzeUserChanges (user, changes) {
@ -154,8 +160,14 @@ module.exports = async function(robot, kredits) {
return createProposal(user, amount, desc, url, details);
}
function updateTimestampForNextFetch () {
robot.logger.debug(`[hubot-kredits] Set timestamp for wiki changes fetch`);
robot.brain.set('kredits:mediawiki:last_processed_at', new Date().toISOString());
}
fetchChanges()
.then(res => groupChangesByUser(res))
.then(res => createProposals(res));
.then(res => createProposals(res))
.then(() => updateTimestampForNextFetch());
};