forked from GitHub/dbot
63 lines
1.8 KiB
JavaScript
63 lines
1.8 KiB
JavaScript
var _ = require('underscore')._;
|
||
|
||
var cspeed = function(dbot) {
|
||
this.watches = dbot.db.cspeed;
|
||
this.outputChannel = dbot.config.modules.cspeed.outputChannel;
|
||
this.counts = {};
|
||
|
||
this.api = {
|
||
'getCounts': function(callback) {
|
||
callback(this.counts);
|
||
}
|
||
};
|
||
this.api['getCounts'].external = true;
|
||
this.api['getCounts'].extMap = [ 'callback' ];
|
||
|
||
this.commands = {
|
||
'addlpmwatch': function(event) {
|
||
var channel = event.params[1];
|
||
var key = event.server + '.' + channel;
|
||
|
||
if(!_.has(this.watches, key)) {
|
||
this.watches[key] = {
|
||
'server': event.server,
|
||
'channel': channel
|
||
}; // to be extended with warn nums etc
|
||
|
||
this.counts[key] = 0;
|
||
dbot.api.timers.addTimer(60000, function() {
|
||
dbot.say(event.server, this.outputChannel + ' :' + channel + ' currently : ' + this.counts[key] + ' LPM');
|
||
this.counts[key] = 0;
|
||
}.bind(this));
|
||
|
||
event.reply('Added speed watch for ' + channel);
|
||
} else {
|
||
event.reply('Already watching that channel');
|
||
}
|
||
}
|
||
};
|
||
|
||
this.listener = function(event) {
|
||
var key = event.server + '.' + event.channel;
|
||
if(_.has(this.watches, key)) {
|
||
this.counts[key]++;
|
||
}
|
||
}.bind(this);
|
||
this.on = 'PRIVMSG';
|
||
|
||
this.onLoad = function() {
|
||
var watches = dbot.db.cspeed;
|
||
_.each(watches, function(watch) {
|
||
var key = watch.server + '.' + watch.channel;
|
||
this.counts[key] = 0;
|
||
dbot.api.timers.addTimer(60000, function() {
|
||
dbot.say(watch.server, this.outputChannel + ' :' + watch.channel + ' : ' + this.counts[key] + 'LPM');
|
||
}.bind(this));
|
||
}.bind(this));
|
||
}.bind(this);
|
||
};
|
||
|
||
exports.fetch = function(dbot) {
|
||
return new cspeed(dbot);
|
||
};
|