368 lines
9.8 KiB
JavaScript
368 lines
9.8 KiB
JavaScript
'use strict';
|
|
|
|
/**
|
|
* Module dependencies.
|
|
*/
|
|
|
|
var CP_cache = require('../lib/CP_cache');
|
|
var CP_get = require('../lib/CP_get');
|
|
var CP_regexp = require('../lib/CP_regexp');
|
|
|
|
/**
|
|
* Configuration dependencies.
|
|
*/
|
|
|
|
var config = require('../config/production/config');
|
|
Object.keys(config).length === 0 &&
|
|
(config = require('../config/production/config.backup'));
|
|
var config_md5 = require('md5')(JSON.stringify(config));
|
|
|
|
var modules = require('../config/production/modules');
|
|
Object.keys(modules).length === 0 &&
|
|
(modules = require('../config/production/modules.backup'));
|
|
var modules_md5 = require('md5')(JSON.stringify(modules));
|
|
|
|
setInterval(function() {
|
|
if (
|
|
config_md5 &&
|
|
process.env['CP_CONFIG_MD5'] &&
|
|
config_md5 !== process.env['CP_CONFIG_MD5']
|
|
) {
|
|
config = require('../config/production/config');
|
|
Object.keys(config).length === 0 &&
|
|
(config = require('../config/production/config.backup'));
|
|
config_md5 = process.env['CP_CONFIG_MD5'];
|
|
}
|
|
if (
|
|
modules_md5 &&
|
|
process.env['CP_MODULES_MD5'] &&
|
|
modules_md5 !== process.env['CP_MODULES_MD5']
|
|
) {
|
|
modules = require('../config/production/modules');
|
|
Object.keys(modules).length === 0 &&
|
|
(modules = require('../config/production/modules.backup'));
|
|
modules_md5 = process.env['CP_MODULES_MD5'];
|
|
}
|
|
}, 3333);
|
|
|
|
/**
|
|
* Node dependencies.
|
|
*/
|
|
|
|
var md5 = require('md5');
|
|
var _eval = require('eval');
|
|
var express = require('express');
|
|
var router = express.Router();
|
|
|
|
/**
|
|
* RSS.
|
|
*/
|
|
|
|
router.get('/?', function(req, res, next) {
|
|
var url =
|
|
req.userinfo && req.userinfo.origin
|
|
? req.userinfo.origin + req.originalUrl
|
|
: config.protocol +
|
|
(config.ru.bomain
|
|
? config.ru.botdomain + config.ru.bomain
|
|
: config.bomain
|
|
? config.botdomain + config.bomain
|
|
: config.subdomain + config.domain) +
|
|
req.originalUrl;
|
|
var urlHash = md5(url.toLowerCase() + process.env['CP_VER']);
|
|
|
|
getRender(function(err, render) {
|
|
renderData(err, render);
|
|
});
|
|
|
|
/**
|
|
* Get render.
|
|
*
|
|
* @param {Callback} callback
|
|
*/
|
|
|
|
function getRender(callback) {
|
|
return config.cache.time
|
|
? getCache(function(err, render) {
|
|
return err ? callback(err) : callback(null, render);
|
|
})
|
|
: getSphinx(function(err, render) {
|
|
return err ? callback(err) : callback(null, render);
|
|
});
|
|
}
|
|
|
|
/**
|
|
* Get cache.
|
|
*
|
|
* @param {Callback} callback
|
|
*/
|
|
|
|
function getCache(callback) {
|
|
CP_cache.get(urlHash, function(err, render) {
|
|
return render
|
|
? callback(null, render)
|
|
: getSphinx(function(err, render) {
|
|
return err ? callback(err) : callback(null, render);
|
|
});
|
|
});
|
|
}
|
|
|
|
/**
|
|
* Get sphinx.
|
|
*
|
|
* @param {Callback} callback
|
|
*/
|
|
|
|
function getSphinx(callback) {
|
|
if (!modules.rss.status) {
|
|
return callback('RSS is disabled!');
|
|
}
|
|
|
|
var options = {};
|
|
options.protocol =
|
|
req.userinfo && req.userinfo.protocol
|
|
? req.userinfo.protocol
|
|
: config.protocol;
|
|
options.domain =
|
|
req.userinfo && req.userinfo.domain
|
|
? req.userinfo.domain
|
|
: config.ru.bomain
|
|
? config.ru.botdomain + config.ru.bomain
|
|
: config.bomain
|
|
? config.botdomain + config.bomain
|
|
: config.subdomain + config.domain;
|
|
options.origin =
|
|
req.userinfo && req.userinfo.origin
|
|
? req.userinfo.origin
|
|
: config.protocol +
|
|
(config.ru.bomain
|
|
? config.ru.botdomain + config.ru.bomain
|
|
: config.bomain
|
|
? config.botdomain + config.bomain
|
|
: config.subdomain + config.domain);
|
|
options.content_image = config.default.image;
|
|
|
|
var render = {};
|
|
render.config = config;
|
|
render.origin = options.origin;
|
|
render.movies = [];
|
|
var collection = req.query.collection
|
|
? CP_regexp.str(req.query.collection)
|
|
: '';
|
|
var page = req.query.page ? CP_regexp.str(req.query.page) : 1;
|
|
var tag = req.query.tag
|
|
? { content_tags: CP_regexp.str(req.query.tag) }
|
|
: '';
|
|
var ids =
|
|
typeof req.query.ids !== 'undefined'
|
|
? req.query.ids
|
|
? req.query.ids
|
|
: 'ids'
|
|
: '';
|
|
|
|
if (modules.content.status && collection) {
|
|
CP_get.contents({ content_url: collection }, function(err, contents) {
|
|
if (err) {
|
|
return callback(err);
|
|
}
|
|
if (contents && contents.length && contents[0].movies) {
|
|
var query_id = [];
|
|
contents[0].movies
|
|
.slice(
|
|
config.default.count * (page ? page - 1 : 0),
|
|
config.default.count * (!page ? 1 : page)
|
|
)
|
|
.forEach(function(item) {
|
|
query_id.push(item);
|
|
});
|
|
var query = { query_id: query_id.join('|') };
|
|
CP_get.movies(
|
|
query,
|
|
config.default.count,
|
|
'',
|
|
1,
|
|
true,
|
|
options,
|
|
function(err, movies) {
|
|
if (err) {
|
|
return callback(err);
|
|
}
|
|
|
|
render.movies = sortingIds(query_id, movies);
|
|
callback(null, render);
|
|
}
|
|
);
|
|
} else {
|
|
return callback('Collection is empty!');
|
|
}
|
|
});
|
|
} else if (ids) {
|
|
var items = (ids.replace(/[0-9,\s]/g, '')
|
|
? ids === 'abuse' &&
|
|
modules.abuse.status &&
|
|
modules.abuse.data.movies &&
|
|
modules.abuse.data.movies.length
|
|
? modules.abuse.data.movies.join(',')
|
|
: config.index.ids.keys
|
|
: ids.replace(/[^0-9,]/g, '')
|
|
)
|
|
.split(',')
|
|
.map(function(key) {
|
|
return key ? parseInt(key.trim()) : '';
|
|
})
|
|
.filter(Boolean);
|
|
if (items && items.length) {
|
|
var query_id = [];
|
|
items.forEach(function(item, i, arr) {
|
|
if (arr.length >= 2) {
|
|
query_id.push(item + '^' + (arr.length - i));
|
|
} else {
|
|
query_id.push(item);
|
|
}
|
|
});
|
|
var query = { query_id: query_id.join('|') };
|
|
CP_get.movies(query, items.length, '', 1, true, options, function(
|
|
err,
|
|
movies
|
|
) {
|
|
if (err) {
|
|
return callback(err);
|
|
}
|
|
|
|
render.movies = sortingIds(query_id, movies);
|
|
callback(null, render);
|
|
});
|
|
} else {
|
|
return callback('No data!');
|
|
}
|
|
} else if (modules.content.status && tag) {
|
|
CP_get.contents(tag, 100, 1, true, options, function(err, contents) {
|
|
if (err) return callback(err);
|
|
|
|
if (contents && contents.length) {
|
|
render.movies = contents;
|
|
callback(null, render);
|
|
} else {
|
|
return callback('Tag does not exist!');
|
|
}
|
|
});
|
|
} else {
|
|
CP_get.publishIds(true, function(err, ids) {
|
|
if (err) {
|
|
return callback(err);
|
|
} else if (!ids) {
|
|
return callback('Publication is over!');
|
|
}
|
|
render.movies = ids.movies;
|
|
callback(null, render);
|
|
});
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Render data.
|
|
*
|
|
* @param {Object} err
|
|
* @param {Object} render
|
|
*/
|
|
|
|
function renderData(err, render) {
|
|
if (err) {
|
|
console.log('[routes/rss.js] Error:', url, err);
|
|
|
|
return next({
|
|
status: 404,
|
|
message: err
|
|
});
|
|
}
|
|
|
|
if (typeof render === 'object') {
|
|
if (typeof req.query.json !== 'undefined') {
|
|
res.json(render);
|
|
} else {
|
|
if (
|
|
render.movies &&
|
|
render.movies.length &&
|
|
config.publish.indexing.condition
|
|
) {
|
|
var condition = _eval(
|
|
'module.exports=function(movie){return !!(' +
|
|
config.publish.indexing.condition.toString() +
|
|
');}'
|
|
);
|
|
render.movies = render.movies.filter(function(movie) {
|
|
return !condition(movie);
|
|
});
|
|
}
|
|
if (render.movies && render.movies.length) {
|
|
render.movies = render.movies.map(function(movie) {
|
|
if (typeof req.query.abuse !== 'undefined') {
|
|
movie.turbo_false = 1;
|
|
}
|
|
if (
|
|
typeof movie.turbo_false === 'undefined' &&
|
|
modules.abuse.data.movies &&
|
|
modules.abuse.data.movies.length
|
|
) {
|
|
for (var i = 0; i < modules.abuse.data.movies.length; i++) {
|
|
if (modules.abuse.data.movies[i] + '' === movie.kp_id + '') {
|
|
movie.turbo_false = 1;
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
if (
|
|
typeof movie.turbo_false === 'undefined' &&
|
|
modules.abuse.data.turbo &&
|
|
modules.abuse.data.turbo.length
|
|
) {
|
|
for (var ii = 0; ii < modules.abuse.data.turbo.length; ii++) {
|
|
if (modules.abuse.data.turbo[ii] + '' === movie.kp_id + '') {
|
|
movie.turbo_false = 1;
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
return movie;
|
|
});
|
|
}
|
|
res.header('Content-Type', 'application/xml');
|
|
res.render('desktop/rss', render, function(err, html) {
|
|
if (err) console.log('[renderData] Render Error:', err);
|
|
|
|
res.send(html);
|
|
|
|
if (config.cache.time && html) {
|
|
CP_cache.set(urlHash, html, function(err) {});
|
|
}
|
|
});
|
|
}
|
|
} else {
|
|
res.header('Content-Type', 'application/xml');
|
|
res.send(render);
|
|
}
|
|
}
|
|
});
|
|
|
|
/**
|
|
* Sort films are turned by id list.
|
|
*
|
|
* @param {Object} ids
|
|
* @param {Object} movies
|
|
* @return {Array}
|
|
*/
|
|
|
|
function sortingIds(ids, movies) {
|
|
var result = [];
|
|
for (var id = 0; id < ids.length; id++) {
|
|
for (var i = 0; i < movies.length; i++) {
|
|
if (parseInt(movies[i].kp_id) === parseInt(('' + ids[id]).trim())) {
|
|
result.push(movies[i]);
|
|
}
|
|
}
|
|
}
|
|
return result;
|
|
}
|
|
|
|
module.exports = router;
|