CinemaPress/routes/rss.js

'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.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.domain;
    options.origin =
      req.userinfo && req.userinfo.origin
        ? req.userinfo.origin
        : config.protocol + config.subdomain + config.domain;
    options.content_image = config.default.image;

    var render = {};
    render.config = config;
    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 parseInt(key.trim());
        });
      if (items && items.length) {
        var query_id = [];
        items.forEach(function(item, i, arr) {
          query_id.push(item + '^' + (arr.length - i));
        });
        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;