bnjbvr/gitlab-to-irc
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Compare commits

base: bnjbvr:master
Branches Tags
bnjbvr:master
bnjbvr:fix-mr-opening
..
compare: bnjbvr:fix-mr-opening
Branches Tags
bnjbvr:master
bnjbvr:fix-mr-opening

No commits in common. "master" and "fix-mr-opening" have entirely different histories.
master ... fix-mr-ope

3 changed files with 11 additions and 106 deletions
Show Stats Expand all files Collapse all files

8
README.md
View File

@ -1,11 +1,3 @@
NOTICE
======
This project has been merged within
[meta-bot](https://github.com/bnjbvr/meta-bot), from the same author. It will
not be maintained anymore! It is highly recommended to migrate to meta-bot and
use the gitlab-notifications and gitlab-helpers modules instead.
gitlab-to-irc gitlab-to-irc
=== ===

7
config.example.js
View File

@ -8,15 +8,8 @@ module.exports = {
'somebody': ['push', 'merge_request', 'issue', 'build'] 'somebody': ['push', 'merge_request', 'issue', 'build']
}, },
// Project URL used for mentions of MR (e.g. !123) or issues (#122).
projectUrl: "https://framagit.org/bnjbvr/kresus/", projectUrl: "https://framagit.org/bnjbvr/kresus/",
// Amout of messages between which no other mentions to a same MR/issue
// will be done.
cacheDuration: 15,
branches: ['master'],
// IRC nick/names for the bot // IRC nick/names for the bot
nick: 'gitlab-bot', nick: 'gitlab-bot',
userName: 'gitlab-bot', userName: 'gitlab-bot',

102
index.js
View File

@ -69,32 +69,16 @@ if (config.lstu) {
}; };
} }
function conjugatePast(verb) {
// Make action displayable (e.g., open -> opened, close -> closed, merge -> merged).
return verb + (verb.substr(-1) === 'e' ? '' : 'e') + 'd';
}
var lastIssueActions = {};
var handlers = { var handlers = {
push: function(body, say) { push: function(body, say) {
var user = body.user_username; var user = body.user_name;
var projectName = body.project.name; var projectName = body.project.name;
var commits = body.commits; var commits = body.commits;
var numCommits = body.total_commits_count; var numCommits = body.total_commits_count;
var branchName = body.ref.replace('refs/heads/', ''); var branchName = body.ref.replace('refs/heads/', '');
var found = false;
for (var i = 0; i < config.branches.length; i++) {
if (branchName === config.branches[i]) {
found = true;
break;
}
}
if (!found)
return;
var msg = null; var msg = null;
if (!numCommits) { if (!numCommits) {
@ -102,26 +86,22 @@ var handlers = {
var action = 'created'; var action = 'created';
if (body.after === '0000000000000000000000000000000000000000') if (body.after === '0000000000000000000000000000000000000000')
action = 'deleted'; action = 'deleted';
msg = user + ' ' + action + ' branch ' + branchName + ' on ' + projectName + '.'; msg = projectName + ': ' + user + ' ' + action + ' branch ' + branchName;
say(msg); say(msg);
} else { } else {
var maybeS = numCommits === 1 ? '' : 's'; var maybeS = numCommits === 1 ? '' : 's';
var lastCommit = commits[commits.length - 1]; var lastCommit = commits[commits.length - 1];
var lastCommitMessage = lastCommit.message.trim().split('\n')[0].trim(); var lastCommitMessage = lastCommit.message.trim().split('\n')[0].trim();
shortenURL(lastCommit.url, function(shortUrl) { shortenURL(lastCommit.url, function(shortUrl) {
msg = user + ' pushed on ' + projectName + '@' + branchName + ': '; msg = 'push on ' + projectName + '@' + branchName + ' (by ' + user + '): ' +
if (numCommits === 1) { commits.length + ' commit' + maybeS + ' (last: ' + lastCommitMessage + ') ' + shortUrl;
msg += lastCommitMessage + ' ' + shortUrl;
} else {
msg += commits.length + ' commits (last: ' + lastCommitMessage + ') ' + shortUrl;
}
say(msg); say(msg);
}); });
} }
}, },
issue: function(body, say) { issue: function(body, say) {
var user = body.user.username; var user = body.user.name;
var projectName = body.project.name; var projectName = body.project.name;
var issue = body.object_attributes; var issue = body.object_attributes;
@ -134,21 +114,14 @@ var handlers = {
if (issue.action === 'update') if (issue.action === 'update')
return; return;
// Don't trigger several close event.
if (issue.action === lastIssueActions[issue.iid])
return;
lastIssueActions[issue.iid] = issue.action;
var displayedAction = conjugatePast(issue.action);
shortenURL(url, function(shortUrl) { shortenURL(url, function(shortUrl) {
var msg = user + ' ' + displayedAction + ' issue #' + issueNumber + ' ("' + issueTitle + '") on ' + projectName + ' ' + shortUrl; var msg = projectName + ': issue #' + issueNumber + ' ("' + issueTitle + '") changed state ("' + issueState + '") ' + shortUrl;
say(msg); say(msg);
}); });
}, },
merge_request: function(body, say) { merge_request: function(body, say) {
var user = body.user.username; var user = body.user.name;
var request = body.object_attributes; var request = body.object_attributes;
@ -167,11 +140,9 @@ var handlers = {
return; return;
} }
var displayedAction = conjugatePast(request.action);
shortenURL(url, function(shortUrl) { shortenURL(url, function(shortUrl) {
var msg = user + ' ' + displayedAction + ' MR !' + id + ' (' + from + '->' + to + ': ' + title + ') ' + var msg = projectName + ': MR# ' + id + ' (' + from + '->' + to + ': ' + title + ') ' +
' on ' + projectName + '; ' + shortUrl; ' has been ' + state + '; ' + shortUrl;
say(msg); say(msg);
}); });
}, },
@ -225,26 +196,7 @@ app.post('/', function(req, res) {
res.sendStatus(200); res.sendStatus(200);
}); });
var chanMessageCounters = {};
var mentionCache = {};
function makeCacheKey(isIssue, id, chan) {
return chan + '-' + (isIssue ? 'issue' : 'mr') + id;
}
function fetch_and_say(isIssue, id, from, chan) { function fetch_and_say(isIssue, id, from, chan) {
var cacheKey = makeCacheKey(isIssue, id, chan);
// Don't mention if it's been already mentioned in the last
// config.cacheDuration messages.
var mentionCounter = mentionCache[cacheKey];
if (typeof mentionCounter !== 'undefined') {
if (chanMessageCounters[chan] - mentionCounter <= config.cacheDuration) {
return;
}
}
var path, text_prefix; var path, text_prefix;
if (isIssue) { if (isIssue) {
path = 'issues/'; path = 'issues/';
@ -266,48 +218,16 @@ function fetch_and_say(isIssue, id, from, chan) {
} else { } else {
client.say(to, text_prefix + id + ": " + url); client.say(to, text_prefix + id + ": " + url);
} }
mentionCache[cacheKey] = chanMessageCounters[chan];
} }
}); });
} }
var issueRegexp = /(?:\s|^)#(\d+)/g;
var mergeRequestRegexp = /(?:\s|^)!(\d+)/g;
function testIssueRegexp(r) {
function test(input, expected) {
var match = r.exec(input);
var found = 0;
while (match !== null) {
if (match[1] !== expected[found].toString()) {
throw new Error('should have found ' + expected[found]);
}
found++;
match = r.exec(input);
}
if (expected.length !== found) {
throw new Error('missing expected occurrences: ' + expected.length + 'vs expected ' + found);
}
r.lastIndex = 0;
}
test('hello #301 jeej', [301]);
test('#302 lol', [302]);
test('lol#303', []);
test('lol #303', [303]);
test('\t#304', [304]);
test(' #305', [305]);
test('hello#305 #306 jeej#42 #307 #lol # #308', [306, 307, 308]);
};
testIssueRegexp(issueRegexp);
app.listen(config.port, config.hostname, function() { app.listen(config.port, config.hostname, function() {
console.log('gitlab-to-irc running.'); console.log('gitlab-to-irc running.');
var issueRegexp = /#(\d+)/g;
var mergeRequestRegexp = /!(\d+)/g;
client.on('message', function(from, chan, message) { client.on('message', function(from, chan, message) {
chanMessageCounters[chan] = (chanMessageCounters[chan] || 0) + 1;
var matches = null; var matches = null;
while ((matches = issueRegexp.exec(message)) !== null) { while ((matches = issueRegexp.exec(message)) !== null) {
var issueId = matches[1]; var issueId = matches[1];