/** * Name: Users * Description: Track known users */ var _ = require('underscore')._, uuid = require('node-uuid'), async = require('async'); var users = function(dbot) { this.userCache = {}; _.each(dbot.config.servers, function(v, k) { this.userCache[k] = {}; }.bind(this)); this.chanCache = {}; _.each(dbot.config.servers, function(v, k) { this.chanCache[k] = {}; }.bind(this)); /*** Internal API ***/ this.internalAPI = { 'createUser': function(server, nick, callback) { var id = uuid.v4(); this.db.create('users', id, { 'id': id, 'primaryNick': nick, 'currentNick': nick, 'server': server, 'channels': [], 'aliases': [], 'mobile': [] }, function(err, result) { if(!err) { dbot.api.event.emit('new_user', [ result ]); callback(result); } }); }.bind(this), 'createChannel': function(server, name, callback) { var id = uuid.v4(); this.db.create('channel_users', id, { 'id': id, 'server': server, 'name': name, 'users': [], 'op': [], 'voice': [] }, function(err, result) { if(!err) { dbot.api.event.emit('new_channel', [ result ]); callback(result); } }); }.bind(this), 'addChannelUser': function(channel, user, staff, callback) { if(!_.include(channel.users, user.id)) { channel.users.push(user.id); } if(!_.include(user.channels, channel.id)) { user.channels.push(channel.id); } if(!channel.op) channel.op = []; if(!channel.voice) channel.voice = []; if(staff.op) { channel.op.push(user.id); } else if(staff.voice) { channel.voice.push(user.id); } this.db.save('users', user.id, user, function(err) { this.db.save('channel_users', channel.id, channel, function(err) { dbot.api.event.emit('new_channel_user', [ user, channel ]); callback(err); }); }.bind(this)); }.bind(this), 'mergeChannelUsers': function(oldUser, newUser) { newUser.channels = _.union(oldUser.channels, newUser.channels); _.each(newUser.channels, function(uuid) { this.api.getChannel(uuid, function(channel) { if(_.include(channel.users, oldUser.id)) { channel.users = _.without(channel.users, oldUser.id); } if(!_.include(channel.users, newUser.id)) { channel.users.push(newUser.id); } this.db.save('channel_users', channel.id, channel, function(err) { if(err) { // QQ } }); }.bind(this)); }, this); }.bind(this) }; this.listener = function(event) { this.api.isKnownUser(event.server, event.newNick, function(isKnown) { event.rUser.currentNick = event.newNick; if(!isKnown) { event.rUser.aliases.push(event.newNick); } this.db.save('users', event.rUser.id, event.rUser, function(err) { if(!isKnown) { dbot.api.event.emit('new_user_alias', [ event.rUser, event.newNick ]); } dbot.api.event.emit('new_current_nick', [ event.rUser, event.user ]); }); }.bind(this)); }.bind(this); this.on = ['NICK']; this.onLoad = function() { dbot.instance.addPreEmitHook(function(event, callback) { // 1. Attempt to resolve channel // 2. Create channel if it doesn't exist // 3. Attempt to resolve user // 4. Create user if it doesn't exist // 5. Make sure channel objects are up to date // 6. Update staff channel lists var checkChannel = function(done) { if(event.channel) { this.api.resolveChannel(event.server, event.channel.name, function(channel) { if(!channel) { this.internalAPI.createChannel(event.server, event.channel.name, done); } else { done(channel); } }.bind(this)); } else { done(null); } }.bind(this); var checkUser = function(done) { this.api.resolveUser(event.server, event.user, function(user) { if(!user) { this.internalAPI.createUser(event.server, event.user, done); } else { if(event.user !== user.currentNick) { var oldNick = user.currentNick; user.currentNick = event.user; this.db.save('users', user.id, user, function() { dbot.api.event.emit('new_current_nick', [ user, oldNick ]); done(user); }); } else { done(user); } } }.bind(this)); }.bind(this); var checkChannelUsers = function(done) { var needsUpdating = false; if(!_.include(event.rUser.channels, event.rChannel.id)) { event.rUser.channels.push(event.rChannel.id); event.rChannel.users.push(event.rUser.id); dbot.api.event.emit('new_channel_user', [ event.rUser, event.rChannel ]); // since it's not in event.channel yet we have to do this here this.db.save('users', event.rUser.id, event.rUser, function() { this.db.save('channel_users', event.rChannel.id, event.rChannel, function() {}); }.bind(this)); return done(); } if(!_.has(event.channel, 'nicks') || !_.has(event.channel.nicks, event.rUser.currentNick)) { return done(); } var cUser = event.channel.nicks[event.rUser.currentNick]; if(!_.include(event.rChannel.op, event.rUser.id) && cUser.op) { event.rChannel.op.push(event.rUser.id); needsUpdating = true; } else if(!_.include(event.rChannel.voice, event.rUser.id) && cUser.voice) { event.rChannel.voice.push(event.rUser.id); needsUpdating = true; } else if(_.include(event.rChannel.op, event.rUser.id) && !cUser.op) { event.rChannel.op = _.without(event.rChannel.op, event.rUser.id); needsUpdating = true; } else if(_.include(event.rChannel.voice, event.rUser.id) && !cUser.voice) { event.rChannel.voice = _.without(event.rChannel.voice, event.rUser.id); needsUpdating = true; } if(needsUpdating) { this.db.save('users', event.rUser.id, event.rUser, function() { this.db.save('channel_users', event.rChannel.id, event.rChannel, done); }.bind(this)); } else { done(); } }.bind(this); if(event.user && _.include(['JOIN', 'MODE', 'NICK', 'PRIVMSG'], event.action)) { checkChannel(function(channel) { event.rChannel = channel; checkUser(function(user) { event.rUser = user; if(event.channel) { checkChannelUsers(function() { callback(); }); } else { callback(); } }.bind(this)); }.bind(this)); } else { callback(); } }.bind(this)); }; }; exports.fetch = function(dbot) { return new users(dbot); };