2014-12-04 22:50:30 +00:00
|
|
|
"use strict";
|
|
|
|
|
var path = require('path');
|
2014-12-13 00:10:41 +00:00
|
|
|
var Promise = require('bluebird');
|
2014-12-13 15:56:52 +00:00
|
|
|
var util = require('util');
|
2014-12-15 12:49:17 +00:00
|
|
|
|
|
|
|
|
var browserify = require('connect-browserify');
|
|
|
|
|
var React = require('react');
|
|
|
|
|
var nodejsx = require('node-jsx').install();
|
|
|
|
|
var Share = React.createFactory(require('../client/share').Share);
|
|
|
|
|
|
2014-12-04 22:50:30 +00:00
|
|
|
var services = {};
|
|
|
|
|
|
|
|
|
|
require("fs").readdirSync(path.join(__dirname, "..", "lib", "services")).forEach(function(file) {
|
|
|
|
|
var service = require("../lib/services/" + file);
|
|
|
|
|
if (service.search) {
|
|
|
|
|
services[service.id] = service;
|
|
|
|
|
}
|
|
|
|
|
});
|
|
|
|
|
|
2014-12-05 13:44:42 +00:00
|
|
|
|
2014-12-13 15:56:52 +00:00
|
|
|
module.exports.html = function(req, res, next) {
|
2014-12-04 22:50:30 +00:00
|
|
|
var serviceId = req.params.service;
|
|
|
|
|
var type = req.params.type;
|
|
|
|
|
var itemId = req.params.id;
|
|
|
|
|
var promises = [];
|
|
|
|
|
|
2014-12-05 17:40:07 +00:00
|
|
|
if (!services[serviceId] || (type != "album" && type != "track")) {
|
|
|
|
|
next();
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
|
2014-12-13 15:56:52 +00:00
|
|
|
req.db.matches.findOne({_id:serviceId + "$$" + itemId}, function(err, doc) {
|
|
|
|
|
if (err) {
|
|
|
|
|
return next(new Error());
|
|
|
|
|
}
|
|
|
|
|
var items = [];
|
|
|
|
|
for (var docService in Object.keys(services)) {
|
|
|
|
|
var loopServiceId = Object.keys(services)[docService];
|
|
|
|
|
items.push(doc.services[loopServiceId]);
|
|
|
|
|
if (doc.services[loopServiceId].id === undefined) {
|
|
|
|
|
services[loopServiceId].search(doc.services[serviceId]).timeout(15000).then(function(item) {
|
|
|
|
|
if (!item.id) {
|
|
|
|
|
item.id = null;
|
2014-12-05 16:26:01 +00:00
|
|
|
}
|
|
|
|
|
|
2014-12-13 15:56:52 +00:00
|
|
|
var set = {};
|
|
|
|
|
set["services." + item.service] = item;
|
|
|
|
|
req.db.matches.update({_id: serviceId + "$$" + itemId}, {$set: set});
|
|
|
|
|
}).catch(function(err) {
|
|
|
|
|
console.log(err)
|
2014-12-05 16:26:01 +00:00
|
|
|
});
|
2014-12-13 15:56:52 +00:00
|
|
|
}
|
2014-12-05 16:26:01 +00:00
|
|
|
}
|
2014-12-13 15:56:52 +00:00
|
|
|
|
|
|
|
|
var items = items.filter(function(item) {
|
|
|
|
|
return item.service != serviceId;
|
|
|
|
|
});
|
|
|
|
|
|
|
|
|
|
items.sort(function(a, b) {
|
|
|
|
|
return !a.id || !b.id;
|
|
|
|
|
}).sort(function(a, b) {
|
|
|
|
|
return !a.streamUrl || b.streamUrl;
|
|
|
|
|
}).sort(function(a, b) {
|
|
|
|
|
return a.type == "video" && b.type != "video";
|
|
|
|
|
});
|
|
|
|
|
|
|
|
|
|
items.unshift(doc.services[serviceId]);
|
|
|
|
|
|
2014-12-15 12:49:17 +00:00
|
|
|
var share = Share({items: items});
|
|
|
|
|
res.send('<!doctype html>\n' + React.renderToString(share).replace("</body></html>", "<script>var items = " + JSON.stringify(items) + "</script></body></html>"));
|
|
|
|
|
|
|
|
|
|
// res.render(type, {
|
|
|
|
|
// page: type,
|
|
|
|
|
// title: doc.services[serviceId].name + " by " + doc.services[serviceId].artist.name,
|
|
|
|
|
// matching: doc.services[serviceId],
|
|
|
|
|
// matches: items,
|
|
|
|
|
// thisUrl: req.userProtocol + '://' + req.get('host') + req.originalUrl
|
|
|
|
|
// });
|
2014-12-04 22:50:30 +00:00
|
|
|
});
|
|
|
|
|
};
|
2014-12-13 15:56:52 +00:00
|
|
|
|
|
|
|
|
module.exports.json = function(req, res, next) {
|
|
|
|
|
var serviceId = req.params.service;
|
|
|
|
|
var type = req.params.type;
|
|
|
|
|
var itemId = req.params.id;
|
|
|
|
|
var promises = [];
|
|
|
|
|
|
|
|
|
|
if (!services[serviceId] || (type != "album" && type != "track")) {
|
|
|
|
|
next();
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
req.db.matches.findOne({_id:serviceId + "$$" + itemId}, function(err, doc) {
|
|
|
|
|
res.json(doc);
|
|
|
|
|
});
|
|
|
|
|
};
|
