forked from GitHub/dbot
527 lines
23 KiB
JavaScript
527 lines
23 KiB
JavaScript
/**
|
|
* Module Name: Last.FM
|
|
* Description: Various lastfm functionality.
|
|
*/
|
|
|
|
var _ = require('underscore')._,
|
|
request = require('request'),
|
|
async = require('async'),
|
|
moment = require('moment');
|
|
|
|
var lastfm = function(dbot) {
|
|
this.ApiRoot = 'http://ws.audioscrobbler.com/2.0/';
|
|
|
|
this.internalAPI = {
|
|
'getLastFM': function(server, nick, callback) {
|
|
dbot.api.profile.getProfile(server, nick, function(err, user, profile) {
|
|
if(user) {
|
|
if(profile && _.has(profile.profile, 'lastfm') && _.isString(profile.profile.lastfm)) {
|
|
callback(user, profile.profile.lastfm.toLowerCase());
|
|
} else {
|
|
callback(user, null);
|
|
}
|
|
} else {
|
|
callback(null, null);
|
|
}
|
|
});
|
|
}
|
|
};
|
|
|
|
this.api = {
|
|
'getRandomArtistTrack': function(mbid, callback) {
|
|
request.get(this.ApiRoot, {
|
|
'qs': {
|
|
'method': 'artist.gettoptracks',
|
|
'mbid': mbid,
|
|
'api_key': this.config.api_key,
|
|
'format': 'json',
|
|
'limit': 10
|
|
},
|
|
'json': true
|
|
}, function(err, res, body) {
|
|
if(_.has(body, 'toptracks') && _.has(body.toptracks, 'track')) {
|
|
var tracks = body.toptracks.track;
|
|
choice = _.random(0, tracks.length - 1),
|
|
track = tracks[choice];
|
|
callback(null, track);
|
|
} else {
|
|
callback('idk', body);
|
|
}
|
|
});
|
|
},
|
|
|
|
'getSimilarArtists': function(mbid, callback) {
|
|
request.get(this.ApiRoot, {
|
|
'qs': {
|
|
'method': 'artist.getsimilar',
|
|
'mbid': mbid,
|
|
'api_key': this.config.api_key,
|
|
'format': 'json',
|
|
'limit': 10
|
|
},
|
|
'json': true
|
|
}, function(err, res, body) {
|
|
if(_.has(body, 'similarartists') && _.has(body.similarartists, 'artist')) {
|
|
callback(null, body.similarartists.artist);
|
|
} else {
|
|
callback('idk', body);
|
|
}
|
|
});
|
|
},
|
|
|
|
'getListening': function(username, callback) {
|
|
request.get(this.ApiRoot, {
|
|
'qs': {
|
|
'user': username,
|
|
'limit': 2,
|
|
'nowplaying': true,
|
|
'method': 'user.getrecenttracks',
|
|
'api_key': this.config.api_key,
|
|
'format': 'json'
|
|
},
|
|
'json': true
|
|
}, function(err, res, body) {
|
|
if(_.has(body, 'error') && body.error == 6) {
|
|
callback('no_user', null);
|
|
} else if(_.has(body, 'recenttracks') && _.has(body.recenttracks, 'track')
|
|
&& !_.isUndefined(body.recenttracks.track[0])) {
|
|
callback(null, body.recenttracks.track[0]);
|
|
} else {
|
|
callback('no_listen', null);
|
|
}
|
|
});
|
|
},
|
|
|
|
/*
|
|
'tasteCompare': function(user, oUser, callback) {
|
|
request.get(this.ApiRoot, {
|
|
'qs': {
|
|
'type1': 'user',
|
|
'type2': 'user',
|
|
'value1': user,
|
|
'value2': oUser,
|
|
'method': 'tasteometer.compare',
|
|
'api_key': this.config.api_key,
|
|
'format': 'json'
|
|
},
|
|
'json': true
|
|
}, function(err, res, body) {
|
|
console.log(body);
|
|
if(_.has(body, 'error') && body.error == 6 || body.error == 7) {
|
|
callback('no_user', user, null);
|
|
} else if(_.has(body, 'comparison') && _.has(body.comparison, 'result')) {
|
|
callback(null, body.comparison.result);
|
|
} else {
|
|
callback('idk', null);
|
|
}
|
|
});
|
|
},
|
|
*/
|
|
|
|
'getInfo': function(lfm, callback) {
|
|
request.get(this.ApiRoot, {
|
|
'qs': {
|
|
'user': lfm,
|
|
'method': 'user.getinfo',
|
|
'api_key': this.config.api_key,
|
|
'format': 'json'
|
|
},
|
|
'json': true
|
|
}, function(err, res, body) {
|
|
if(_.has(body, 'error') && body.error == 6 || body.error == 7) {
|
|
callback('no_user', null);
|
|
} else if(_.has(body, 'user')) {
|
|
callback(null, body.user);
|
|
} else {
|
|
callback('idk', null);
|
|
}
|
|
});
|
|
|
|
}
|
|
};
|
|
|
|
this.commands = {
|
|
'~lastfm': function(event) {
|
|
var user = event.rUser,
|
|
lfm = event.rProfile.lastfm;
|
|
if(event.res[0]) {
|
|
user = event.res[0].user;
|
|
lfm = event.res[0].lfm;
|
|
}
|
|
|
|
this.api.getInfo(lfm, function(err, profile) {
|
|
if(!err) {
|
|
console.log(profile);
|
|
event.reply(dbot.t('lfm_profile', {
|
|
'user': user.currentNick,
|
|
'plays': profile.playcount.toString().replace(/(\d)(?=(\d\d\d)+(?!\d))/g, "$1,"),
|
|
'date': moment(profile.registered['#text'] * 1000).format('DD/MM/YYYY'),
|
|
'link': profile.url
|
|
}));
|
|
} else {
|
|
if(err == 'no_user') {
|
|
event.reply(dbot.t('lfm_unknown'));
|
|
} else if(err == 'no_listen') {
|
|
event.reply(dbot.t('no_listen', { 'user': event.user }));
|
|
}
|
|
}
|
|
});
|
|
},
|
|
|
|
'~scrobbliest': function(event) {
|
|
dbot.api.profile.getAllProfilesWith('lastfm', function(profiles) {
|
|
if(profiles) {
|
|
var plays = [];
|
|
async.each(profiles, function(profile, done) {
|
|
this.api.getInfo(profile.profile.lastfm, function(err, lProfile) {
|
|
if(!err) {
|
|
plays.push({
|
|
'user': profile.id,
|
|
'plays': parseInt(lProfile.playcount)
|
|
});
|
|
}
|
|
done();
|
|
});
|
|
}.bind(this), function() {
|
|
var scrobbliest = _.chain(plays)
|
|
.sortBy(function(p) { return p.plays; })
|
|
.reverse()
|
|
.first(10)
|
|
.value();
|
|
|
|
async.each(scrobbliest, function(item, done) {
|
|
dbot.api.users.getUser(item.user, function(err, user) {
|
|
item.user = user;
|
|
done();
|
|
});
|
|
}, function() {
|
|
var output = dbot.t('lfm_scrobbliest');
|
|
_.each(scrobbliest, function(item) {
|
|
output += item.user.currentNick + ' (' +
|
|
item.plays.toString().replace(/(\d)(?=(\d\d\d)+(?!\d))/g, "$1,")+ '), ';
|
|
});
|
|
event.reply(output.slice(0, -2));
|
|
});
|
|
}.bind(this));
|
|
} else {
|
|
event.reply('no suitable profiles');
|
|
}
|
|
}.bind(this));
|
|
},
|
|
|
|
'~suggestion': function(event) {
|
|
this.api.getListening(event.rProfile.lastfm, function(err, track) {
|
|
if(!err) {
|
|
this.api.getSimilarArtists(track.artist.mbid, function(err, similar) {
|
|
if(!err) {
|
|
var choice = _.random(0, similar.length - 1);
|
|
this.api.getRandomArtistTrack(similar[choice].mbid, function(err, track) {
|
|
if(!err) {
|
|
var output = dbot.t('lfm_suggestion', {
|
|
'user': event.user,
|
|
'name': track.name,
|
|
'artist': track.artist.name
|
|
});
|
|
var term = track.name + ' ' + track.artist.name;
|
|
|
|
async.parallel({
|
|
youtube: function(cb) {
|
|
dbot.api.youtube.search(term, function(body) {
|
|
if(_.isObject(body) && _.has(body, 'items') && body.items.length > 0) {
|
|
var link = body.items[0].id.videoId
|
|
if(link) {
|
|
cb(null,"https://youtu.be/" + link);
|
|
} else {
|
|
cb(null, undefined);
|
|
}
|
|
}
|
|
});
|
|
},
|
|
spotify: function(cb) {
|
|
dbot.api.spotify.spotifySearch(term, function(body, url, uri) {
|
|
if(body) {
|
|
if (!dbot.modules.minify) {
|
|
cb(null, { url: url, uri:uri });
|
|
} else {
|
|
dbot.modules.minify.api.minify(url, "bitly", function(mini) {
|
|
cb(null, { url:mini || url, uri:uri });
|
|
});
|
|
}
|
|
} else {
|
|
cb(null, undefined);
|
|
}
|
|
});
|
|
}
|
|
}, function(err, results) {
|
|
if (results.youtube || results.spotify) output += " - "
|
|
|
|
if (results.youtube) output += results.youtube;
|
|
if (results.spotify) {
|
|
if (results.youtube) output += " | ";
|
|
output += results.spotify.url + " - " + results.spotify.uri;
|
|
}
|
|
|
|
event.reply(output);
|
|
});
|
|
} else {
|
|
event.reply('Couldn\'t get any suggested tracks.');
|
|
console.log(err);
|
|
}
|
|
});
|
|
} else {
|
|
event.reply('Couldn\'t find any similar artists to what you\'re listening to.');
|
|
console.log(err);
|
|
}
|
|
}.bind(this));
|
|
} else {
|
|
if(err == 'no_user') {
|
|
event.reply(dbot.t('lfm_unknown'));
|
|
} else if(err == 'no_listen') {
|
|
event.reply(dbot.t('no_listen', { 'user': event.user }));
|
|
}
|
|
}
|
|
}.bind(this));
|
|
},
|
|
|
|
'~listening': function(event) {
|
|
var user = event.rUser,
|
|
lfm = event.rProfile.lastfm;
|
|
if(event.res[0]) {
|
|
user = event.res[0].user;
|
|
lfm = event.res[0].lfm;
|
|
}
|
|
|
|
this.api.getListening(lfm, function(err, track) {
|
|
if(!err) {
|
|
var term = track.name + ' ' + track.artist['#text'],
|
|
output = '';
|
|
if(_.has(track, '@attr') && _.has(track['@attr'], 'nowplaying') && track['@attr'].nowplaying == 'true') {
|
|
output = dbot.t('now_listening', {
|
|
'user': user.currentNick,
|
|
'track': track.name,
|
|
'artist': track.artist['#text']
|
|
});
|
|
} else {
|
|
output = dbot.t('last_listened', {
|
|
'user': user.currentNick,
|
|
'track': track.name,
|
|
'artist': track.artist['#text']
|
|
});
|
|
}
|
|
|
|
async.parallel({
|
|
youtube: function(cb) {
|
|
dbot.api.youtube.search(term, function(body) {
|
|
if(_.isObject(body) && _.has(body, 'items') && body.items.length > 0) {
|
|
var link = body.items[0].id.videoId
|
|
if(link) {
|
|
cb(null,"https://youtu.be/" + link);
|
|
} else {
|
|
cb(null, undefined);
|
|
}
|
|
}
|
|
});
|
|
},
|
|
spotify: function(cb) {
|
|
dbot.api.spotify.spotifySearch(term, function(body, url, uri) {
|
|
if(body) {
|
|
if (!dbot.modules.minify) {
|
|
cb(null, { url: url, uri:uri });
|
|
} else {
|
|
dbot.modules.minify.api.minify(url, "bitly", function(mini) {
|
|
cb(null, { url:mini || url, uri:uri });
|
|
});
|
|
}
|
|
} else {
|
|
cb(null, undefined);
|
|
}
|
|
});
|
|
}
|
|
}, function(err, results) {
|
|
if (results.youtube || results.spotify) output += " - "
|
|
|
|
if (results.youtube) output += results.youtube;
|
|
if (results.spotify) {
|
|
if (results.youtube) output += " | ";
|
|
output += results.spotify.url + " - " + results.spotify.uri;
|
|
}
|
|
|
|
event.reply(output);
|
|
});
|
|
|
|
} else {
|
|
if(err == 'no_user') {
|
|
event.reply(dbot.t('lfm_unknown'));
|
|
} else if(err == 'no_listen') {
|
|
event.reply(dbot.t('no_listen', { 'user': user.currentNick }));
|
|
}
|
|
console.log(err);
|
|
}
|
|
});
|
|
},
|
|
|
|
/*
|
|
'~taste': function(event) {
|
|
var u1 = event.rUser,
|
|
lfm1 = event.rProfile.lastfm,
|
|
u2 = event.res[0].user,
|
|
lfm2 = event.res[0].lfm;
|
|
|
|
this.api.tasteCompare(event.rProfile.lastfm, lfm2, function(err, comp) {
|
|
if(!err) {
|
|
var score = Math.floor(comp.score * 100);
|
|
event.reply(dbot.t('taste_compat', {
|
|
'user1': event.user,
|
|
'user2': u2.currentNick,
|
|
'score': score
|
|
}));
|
|
} else {
|
|
if(err == 'no_user') {
|
|
event.reply('Unknown Last.FM user.');
|
|
} else {
|
|
event.reply('Well something went wrong and I don\'t know what it means');
|
|
}
|
|
}
|
|
});
|
|
},
|
|
|
|
'~tastiest': function(event) {
|
|
var sortGoodScores = function(goodScores) {
|
|
var tastiest = _.chain(goodScores)
|
|
.sortBy(function(p) { return p.score; })
|
|
.reverse()
|
|
.first(10)
|
|
.value();
|
|
|
|
async.each(tastiest, function(pair, done) {
|
|
if(!_.isObject(pair.p1)) { // fix this
|
|
dbot.api.users.getUser(pair.p1, function(err, user) {
|
|
pair.p1 = user;
|
|
dbot.api.users.getUser(pair.p2, function(err, user) {
|
|
pair.p2 = user;
|
|
done();
|
|
});
|
|
});
|
|
} else {
|
|
done();
|
|
}
|
|
}, function() {
|
|
var output = 'Most musically compatible users: ';
|
|
_.each(tastiest, function(pair) {
|
|
output += pair.p1.currentNick + ' & ' +
|
|
pair.p2.currentNick + ' (' + pair.score +
|
|
'%), ';
|
|
});
|
|
event.reply(output.slice(0, -2));
|
|
});
|
|
};
|
|
|
|
if(this.tastyCache && Date.now() - this.tastyCacheStamp <= 1800000) {
|
|
sortGoodScores(this.tastyCache);
|
|
} else {
|
|
event.reply('Updating tasty cache... Hold onto your coconuts...');
|
|
dbot.api.profile.getAllProfilesWith('lastfm', function(profiles) {
|
|
if(profiles) {
|
|
var scores = {}; // Using this structure first for easier testing in the async
|
|
async.eachSeries(profiles, function(p1, next) {
|
|
scores[p1.id] = {};
|
|
async.eachSeries(profiles, function(p2, subnext) {
|
|
if(p1.id == p2.id || p1.profile.lastfm == p2.profile.lastfm || _.has(scores, p2.id) && _.has(scores[p2.id], p1.id)) {
|
|
subnext();
|
|
} else {
|
|
this.api.tasteCompare(p1.profile.lastfm, p2.profile.lastfm, function(err, comp) {
|
|
if(!err) {
|
|
var score = Math.floor(comp.score * 100);
|
|
scores[p1.id][p2.id] = score;
|
|
}
|
|
subnext();
|
|
});
|
|
}
|
|
}.bind(this), function() { next(); });
|
|
}.bind(this), function(err) {
|
|
// Now we better structure the scores for sorting
|
|
var goodScores = [];
|
|
_.each(scores, function(subscores, p1) {
|
|
_.each(subscores, function(aScore, p2) {
|
|
goodScores.push({
|
|
'p1': p1,
|
|
'p2': p2,
|
|
'score': aScore
|
|
});
|
|
});
|
|
});
|
|
|
|
this.tastyCache = goodScores;
|
|
this.tastyCacheStamp = new Date().getTime();
|
|
sortGoodScores(goodScores);
|
|
}.bind(this));
|
|
} else {
|
|
event.reply('No suitable profiles');
|
|
}
|
|
}.bind(this));
|
|
}
|
|
},
|
|
*/
|
|
|
|
'~artists': function(event) {
|
|
var u1 = event.rUser,
|
|
lfm1 = event.rProfile.lastfm,
|
|
u2 = event.res[0].user,
|
|
lfm2 = event.res[0].lfm;
|
|
|
|
this.api.tasteCompare(event.rProfile.lastfm, lfm2, function(err, comp) {
|
|
if(!err) {
|
|
var artists = _.pluck(comp.artists.artist, 'name').join(', ');
|
|
event.reply(dbot.t('common_artists', {
|
|
'user1': event.user,
|
|
'user2': u2.currentNick,
|
|
'common': artists
|
|
}));
|
|
} else {
|
|
if(err == 'no_user') {
|
|
event.reply(dbot.t('lfm_unknown'));
|
|
} else {
|
|
event.reply('Well something went wrong and I don\'t know what it means');
|
|
}
|
|
}
|
|
});
|
|
}
|
|
};
|
|
//this.commands['~taste'].regex = [/^taste ([\d\w[\]{}^|\\`_-]+?)/, 2];
|
|
this.commands['~artists'].regex = [/^artists ([\d\w[\]{}^|\\`_-]+?)/, 2];
|
|
|
|
_.each(this.commands, function(command) {
|
|
command.resolver = function(event, callback) {
|
|
if(event.rProfile && _.has(event.rProfile, 'lastfm')) {
|
|
if(event.params[1]) {
|
|
this.internalAPI.getLastFM(event.server, event.params[1], function(user, lfm) {
|
|
if(user && lfm) {
|
|
event.res.push({
|
|
'user': user,
|
|
'lfm': lfm
|
|
});
|
|
callback(false);
|
|
} else {
|
|
if(!user) {
|
|
event.reply('Unknown user.');
|
|
} else {
|
|
event.reply(user.currentNick + ': Set a lastfm username with "~set lastfm username"');
|
|
}
|
|
callback(true);
|
|
}
|
|
});
|
|
} else {
|
|
callback(false);
|
|
}
|
|
} else {
|
|
event.reply(event.user + ': Set a lastfm username with "~set lastfm username"');
|
|
callback(true);
|
|
}
|
|
}.bind(this);
|
|
}, this);
|
|
};
|
|
|
|
exports.fetch = function(dbot) {
|
|
return new lastfm(dbot);
|
|
};
|