CinemaPress/lib/CP_cron.js

'use strict';

var active = {
  num: 0,
  process: {}
};

setTimeout(function() {
  console.log('[FORCE STOP]', active);
  setTimeout(function() {
    return process.exit(0);
  }, 1000 * 60 * 2);
}, 1000 * 60 * 54);

/**
 * Node dependencies.
 */

var op = require('object-path');
var adop = require('adop');
var request = require('request');
var sinoni = require('sinoni');
var async = require('async');
var _eval = require('eval');
var util = require('util');
var td = new util.TextDecoder('utf8', { fatal: true });
var path = require('path');
var fs = require('fs');
var os = require('os-utils');
var Imap = require('imap');
var MP = require('mailparser-mit').MailParser;
var nodemailer = require('nodemailer');
var mimemessage = require('mimemessage');

/**
 * Global env.
 */

try {
  var p = tryParseJSON(
    fs.readFileSync(
      path.join(path.dirname(__filename), '..', 'process.json'),
      'utf8'
    )
  );
  var e = p.apps[0].env;
  for (var prop in e) {
    if (e.hasOwnProperty(prop)) {
      process.env[prop] = e[prop];
    }
  }
} catch (err) {
  return console.log('NOT FILE PROCESS DATA');
}

process.env['NO_CACHE'] = true;

/**
 * Module dependencies.
 */

var CP_get = require('./CP_get');
var CP_save = require('./CP_save');
var CP_sub = require('../lib/CP_sub');
var CP_translit = require('../lib/CP_translit');
var CP_structure = require('../lib/CP_structure');

/**
 * Configuration dependencies.
 */

var config = require('../config/production/config');
Object.keys(config).length === 0 &&
  (config = require('../config/production/config.backup'));
var modules = require('../config/production/modules');
Object.keys(modules).length === 0 &&
  (modules = require('../config/production/modules.backup'));

/**
 * Route dependencies.
 */

var movie = require('../routes/paths/movie');

var timeZone = new Date();

console.log(
  timeZone,
  '[',
  Math.ceil(os.freemem()),
  'MB ]',
  '1min:',
  os.loadavg(1).toFixed(2),
  '5min:',
  os.loadavg(5).toFixed(2),
  '15min:',
  os.loadavg(15).toFixed(2)
);

if (Math.ceil(os.freemem()) < 50) {
  console.log('The server is overloaded to start cron.');
  return process.exit(0);
}

var hour = new Date(timeZone).getHours() + 1;

console.time('DONE');

/**
 * Parser new movie ids.
 */

if (
  modules.content.status &&
  modules.content.data.scraper &&
  modules.content.data.scraper.split('\n').length &&
  modules.content.data.scraper.split('\n').filter(function(s) {
    var sl = s
      .replace(/(^\s*)|(\s*)$/g, '')
      .replace(/\s*~\s*/g, '~')
      .split('~');
    return !(
      s.charAt(0) === '#' ||
      sl.length < 5 ||
      hour % parseInt((sl && sl[0]) || '0')
    );
  }).length &&
  hour > 6
) {
  active.num++;
  active.process.scraper = true;

  setTimeout(function() {
    active.num--;
    active.process.scraper = false;
  }, 1000 * 60 * 55);

  async.eachOfLimit(
    modules.content.data.scraper.split('\n'),
    1,
    function(task, index, callback) {
      task = task.trim();
      var parse = task
        .replace(/(^\s*)|(\s*)$/g, '')
        .replace(/\s*~\s*/g, '~')
        .split('~');
      if (task.charAt(0) === '#' || parse.length < 5) {
        return callback();
      }
      var pre_regex_id = parse[3].split('<>')[0].trim();
      var key =
        parse &&
        parse[3] &&
        parse[3].split('<>') &&
        parse[3].split('<>')[1] &&
        parse[3].split('<>')[1].trim()
          ? parse[3].split('<>')[1].trim()
          : 'id';
      if (
        pre_regex_id === '' ||
        pre_regex_id === 'kp' ||
        pre_regex_id === 'kp_id' ||
        pre_regex_id === 'kinopoisk' ||
        pre_regex_id === 'kinopoisk_id'
      ) {
        pre_regex_id =
          '(?:' +
          '/level/1/film/([0-9]{3,8})|' +
          'kinopoisk\\.ru/([0-9]{3,8})\\.gif|' +
          'rating/([0-9]{3,8})\\.gif|' +
          '/film/([0-9]{3,8})|' +
          '/series/([0-9]{3,8})' +
          ')';
        key = 'id';
      }
      if (
        pre_regex_id &&
        (pre_regex_id === 'imdb' || pre_regex_id === 'imdb_id')
      ) {
        pre_regex_id = '(?:' + '/tt([0-9]{1,9})' + ')';
        key = 'custom.imdb_id';
      }
      if (
        pre_regex_id &&
        (pre_regex_id === 'tmdb' ||
          pre_regex_id === 'tmdb_id' ||
          pre_regex_id === 'themoviedb' ||
          pre_regex_id === 'themoviedb_id')
      ) {
        pre_regex_id =
          '(?:' +
          'themoviedb\\.org/movie/([0-9]{1,9})|themoviedb\\.org/tv/([0-9]{1,9})' +
          ')';
        key = 'custom.tmdb_id';
      }
      if (
        pre_regex_id &&
        (pre_regex_id === 'douban' || pre_regex_id === 'douban_id')
      ) {
        pre_regex_id = '(?:' + 'douban\\.com/subject/([0-9]{1,9})' + ')';
        key = 'custom.douban_id';
      }
      if (
        pre_regex_id &&
        (pre_regex_id === 'wa' ||
          pre_regex_id === 'wa_id' ||
          pre_regex_id === 'world-art' ||
          pre_regex_id === 'world-art_id' ||
          pre_regex_id === 'world_art' ||
          pre_regex_id === 'world_art_id')
      ) {
        pre_regex_id = '(?:' + 'animation\\.php\\?id=([0-9]{1,9})' + ')';
        key = 'custom.wa_id';
      }
      if (
        pre_regex_id &&
        (pre_regex_id === 'tvmaze' || pre_regex_id === 'tvmaze_id')
      ) {
        pre_regex_id = '(?:' + 'tvmaze\\.com/shows/([0-9]{1,9})' + ')';
        key = 'custom.tvmaze_id';
      }
      var p = {
        every: parseInt(parse[0]),
        url: parse[1],
        regex_url: parse[2] && parse[2] !== 'post' ? parse[2] : '',
        regex_id: pre_regex_id,
        collection: parse[4]
      };
      if (hour % p.every) return callback();
      request(
        {
          url: p.url,
          method: 'GET',
          timeout: 15000,
          headers: {
            'User-Agent':
              'Mozilla/5.0 (Windows NT 10.0; Win64; x64) ' +
              'AppleWebKit/537.36 (KHTML, like Gecko) ' +
              'Chrome/79.0.' +
              (Math.floor(Math.random() * 600) + 1) +
              '.100 Safari/537.36'
          }
        },
        function(error, response, body) {
          if (error || response.statusCode !== 200 || !body) {
            console.error(task, (error && error.code) || '', body);
            return callback();
          }
          var ids = [];
          var urls = [];
          if (p.regex_url) {
            var u;
            var regex_url = new RegExp(p.regex_url, 'ig');
            while ((u = regex_url.exec(body))) {
              if (!u[1]) {
                break;
              }
              if (/(\/\/|http)/i.test(u[1])) {
                urls.push(u[1]);
              } else if (/\//i.test(u[1])) {
                urls.push(
                  require('url').parse(p.url).protocol +
                    '//' +
                    require('url').parse(p.url).host +
                    u[1]
                );
              } else {
                var s = p.url.split('/');
                s.pop();
                var slash = s.join('/');
                urls.push(slash + '/' + u[1]);
              }
            }
          }
          if (!urls.length) urls.push(p.url);
          urls = urls.filter(function(item, pos) {
            return urls.indexOf(item) === pos;
          });
          if (urls.length <= 0) {
            return callback();
          }
          active.process.scraper = 'URLs: 0 / ' + urls.length + ' IDs: 0';
          async.eachOfLimit(
            urls,
            1,
            function(url, i, callback) {
              request(
                {
                  url: url,
                  method: 'GET',
                  timeout: 5000,
                  headers: {
                    'User-Agent':
                      'Mozilla/5.0 (Windows NT 10.0; Win64; x64) ' +
                      'AppleWebKit/537.36 (KHTML, like Gecko) ' +
                      'Chrome/54.0.' +
                      (Math.floor(Math.random() * 600) + 1) +
                      '.100 Safari/537.36'
                  }
                },
                function(error2, response2, body2) {
                  if (active.num <= 0) {
                    console.log('[FORCE STOP]', 'scraper');
                    return process.exit(0);
                  }
                  active.process.scraper =
                    'URLs: ' +
                    (i + 1) +
                    ' / ' +
                    urls.length +
                    ' IDs: ' +
                    ids.length;
                  if (error2 || response2.statusCode !== 200 || !body2) {
                    console.error(task, error2.code, body2);
                    return callback();
                  }
                  var found;
                  var regex_id = new RegExp(p.regex_id, 'ig');
                  while ((found = regex_id.exec(body2))) {
                    var find_id =
                      found[1] || found[2] || found[3] || found[4] || found[5];
                    if (find_id) {
                      if (
                        ids.indexOf(find_id) === -1 &&
                        modules.abuse.data.movies.indexOf(find_id) === -1
                      ) {
                        ids.push(find_id);
                      }
                    } else {
                      break;
                    }
                  }
                  setTimeout(function() {
                    callback();
                  }, Math.floor(Math.random() * 2000 + 1000));
                }
              );
            },
            function() {
              if (!ids.length) return callback();
              try {
                fs.writeFileSync(
                  path.join(
                    path.dirname(__filename),
                    '..',
                    'files',
                    'scraper',
                    p.collection + '.json'
                  ),
                  JSON.stringify(
                    {
                      date: new Date().toJSON(),
                      type:
                        key === 'kp_id' || key === 'id'
                          ? 'kinopoisk'
                          : key.replace('custom.', '').replace('_id', ''),
                      movies: ids
                    },
                    null,
                    2
                  )
                );
              } catch (e) {
                console.error(e);
              }
              saveData(
                p.collection,
                ids.map(function(id) {
                  var r = {};
                  r['id'] = id;
                  r['key'] = key;
                  return r;
                }),
                function() {
                  callback();
                }
              );
            }
          );
        }
      );
    },
    function() {
      active.num--;
      active.process.scraper = false;
    }
  );
} else {
  console.log(
    'NOT START:',
    'CONTENT',
    'status',
    !!modules.content.status,
    'scraper',
    modules.content.data.scraper.split('\n').filter(Boolean).length,
    'tasks'
  );
}

/**
 * API new movie ids.
 */

if (
  modules.content.status &&
  modules.content.data.custom &&
  modules.content.data.custom.length
) {
  active.num++;
  active.process.content = true;

  setTimeout(function() {
    active.num--;
    active.process.content = false;
  }, 1000 * 60 * 55);

  var task_groups = {};
  modules.content.data.custom.forEach(function(task) {
    var parse = task
      .replace(/(^\s*)|(\s*)$/g, '')
      .replace(/\s*~\s*/g, '~')
      .split('~');
    if (task.charAt(0) === '#' || parse.length < 3) return;
    if (task_groups[parse[2]]) {
      task_groups[parse[2]].push(task);
    } else {
      task_groups[parse[2]] = [task];
    }
  });

  async.eachOfLimit(
    task_groups,
    1,
    function(group, group_index, callback) {
      var movies = [];
      async.eachOfLimit(
        group,
        1,
        function(task, index, callback) {
          var parse = task
            .replace(/(^\s*)|(\s*)$/g, '')
            .replace(/\s*~\s*/g, '~')
            .split('~');
          if (task.charAt(0) === '#' || parse.length < 3) {
            return callback();
          }
          var obj = [
            {
              name: 'id',
              path: parse[1].split('<>')[0].trim(),
              type: 'number'
            }
          ];
          if (parse[3]) {
            obj.push({
              name: 'translate',
              path: parse[3],
              type: 'string'
            });
          }
          if (parse[4]) {
            obj.push({
              name: 'quality',
              path: parse[4],
              type: 'string'
            });
          }
          if (parse[5]) {
            obj.push({
              name: 'date',
              path: parse[5],
              type: 'string'
            });
          }
          var req_url = (parse[0] || '').replace(/POST>/i, '').trim();
          req_url =
            req_url && /^(http|\/\/)/i.test(req_url)
              ? req_url
              : config.protocol + config.subdomain + config.domain + req_url;
          request(
            {
              url: req_url,
              method: /POST>/i.test(parse[0] || '') ? 'POST' : 'GET',
              timeout: 5000
            },
            function(error, response, body) {
              if (active.num <= 0) {
                console.log('[FORCE STOP]', 'custom');
                return process.exit(0);
              }
              if (error || response.statusCode !== 200 || !body) {
                console.error(
                  task,
                  (error && error.code) || (response && response.statusCode)
                );
                return callback();
              }
              movies = movies && movies.length ? movies : [];
              var sorting = [];
              var all = adop(tryParseJSON(body), obj);
              var ids = all
                .filter(function(id) {
                  return id && id.id && parseInt(id.id);
                })
                .reduce(function(r, a) {
                  if (sorting.indexOf(parseInt(a['id'])) === -1) {
                    sorting.push(parseInt(a['id']));
                  }
                  r[a['id']] = r[a['id']] || [];
                  r[a['id']].push(a);
                  return r;
                }, {});
              Object.keys(ids).forEach(function(id) {
                var key =
                  parse[1] && parse[1].split('<>') && parse[1].split('<>')[1]
                    ? parse[1].split('<>')[1].trim()
                    : 'id';
                var m = { id: parseInt(id) };
                m['key'] = key;
                if (
                  parse[1] &&
                  parse[1].split('<>') &&
                  parse[1].split('<>')[2]
                ) {
                  m['type'] = parse[1].split('<>')[2].trim();
                }
                if (
                  ids[id][0] &&
                  ids[id][0].translate &&
                  ids[id][0].translate.toString().toLowerCase() !== 'null' &&
                  ids[id][0].translate.toString().toLowerCase() !==
                    'undefined' &&
                  ids[id][0].translate.toString().toLowerCase() !== 'false' &&
                  ids[id][0].translate.toString().toLowerCase() !== 'none' &&
                  ids[id][0].translate.toString().toLowerCase() !== 'nan' &&
                  ids[id][0].translate.toString().toLowerCase() !== 'n/a'
                ) {
                  var reg = /[^(]+\s*\([^)]+\)\s*\(([^)]+)\)/i.exec(
                    ids[id][0].translate.toString()
                  );
                  m.translate = reg && reg[1] ? reg[1] : ids[id][0].translate;
                }
                if (
                  ids[id][0] &&
                  ids[id][0].quality &&
                  ids[id][0].quality.toString().toLowerCase() !== 'null' &&
                  ids[id][0].quality.toString().toLowerCase() !== 'undefined' &&
                  ids[id][0].quality.toString().toLowerCase() !== 'false' &&
                  ids[id][0].quality.toString().toLowerCase() !== 'none' &&
                  ids[id][0].quality.toString().toLowerCase() !== 'nan' &&
                  ids[id][0].quality.toString().toLowerCase() !== 'n/a'
                ) {
                  m.quality = ids[id][0].quality.toString();
                }
                if (
                  ids[id][0] &&
                  ids[id][0].date &&
                  !isNaN(Date.parse(ids[id][0].date))
                ) {
                  m.date = Date.parse(ids[id][0].date);
                }
                movies.push(m);
              });
              movies
                .sort(function(a, b) {
                  return sorting.indexOf(a.id) - sorting.indexOf(b.id);
                })
                .sort(function(a, b) {
                  return a.date && b.date ? b.date - a.date : 0;
                });
              if (group.length > index + 1) {
                return callback();
              }
              if (!movies.length) return callback();
              try {
                var file_scraper = path.join(
                  path.dirname(__filename),
                  '..',
                  'files',
                  'scraper',
                  parse[2] + '.json'
                );
                var old_scraper = fs.existsSync(file_scraper)
                  ? tryParseJSON(fs.readFileSync(file_scraper, 'utf8'))
                  : {};
                var key =
                  parse[1] && parse[1].split('<>') && parse[1].split('<>')[1]
                    ? parse[1].split('<>')[1].trim()
                    : 'id';
                var movie_ids = movies.map(function(movie) {
                  return movie.id;
                });
                if (
                  old_scraper &&
                  old_scraper.date &&
                  new Date(old_scraper.date).getHours() ===
                    new Date().getHours()
                ) {
                  old_scraper.movies.forEach(function(movie) {
                    if (movie_ids.indexOf(movie) === -1) {
                      movie_ids.push(movie);
                    }
                  });
                }
                fs.writeFileSync(
                  file_scraper,
                  JSON.stringify(
                    {
                      date: new Date().toJSON(),
                      type:
                        key === 'kp_id' || key === 'id'
                          ? 'kinopoisk'
                          : key.replace('custom.', '').replace('_id', ''),
                      movies: movie_ids
                    },
                    null,
                    2
                  )
                );
              } catch (e) {
                console.error(e);
              }
              saveData(parse[2], movies, function() {
                movies = [];
                return callback();
              });
            }
          );
        },
        function() {
          callback();
        }
      );
    },
    function() {
      active.num--;
      active.process.content = false;
    }
  );
} else {
  console.log(
    'NOT START:',
    'CONTENT',
    'status',
    !!modules.content.status,
    'custom',
    modules.content.data.custom.length
  );
}

/**
 * API new episodes.
 */

if (
  modules.episode.status &&
  modules.episode.data.index.custom &&
  modules.episode.data.index.custom.length
) {
  active.num++;
  active.process.episode = true;

  setTimeout(function() {
    active.num--;
    active.process.episode = false;
  }, 1000 * 60 * 55);

  async.eachOfLimit(
    modules.episode.data.index.custom,
    1,
    function(task, index, callback) {
      var parse = task
        .replace(/(^\s*)|(\s*)$/g, '')
        .replace(/\s*~\s*/g, '~')
        .split('~');
      if (task.charAt(0) === '#' || parse.length < 4) {
        return callback();
      }
      var date = new Date();
      date.setDate(date.getDate() - 1);
      var req_method = /^POST>/i.test(parse[0].split('<>')[0].trim());
      var req_url = parse[0]
        .split('<>')[0]
        .trim()
        .replace('[yesterday]', yyyy_mm_dd(date))
        .replace('POST>', '');
      req_url =
        req_url && /^(http|\/\/)/i.test(req_url)
          ? req_url
          : config.protocol + config.subdomain + config.domain + req_url;
      var changes = (parse[0].split('<>')[1] || '').split(',');
      var obj = [
        {
          name: 'id',
          path: parse[1].split('<>')[0],
          type: 'number'
        },
        {
          name: 'season',
          path: parse[2],
          type: 'number',
          regex: /([0-9]{1,4})/
        },
        {
          name: 'episode',
          path: parse[3],
          type: 'number',
          regex: /([0-9]{1,4})/
        }
      ];
      if (parse[4]) {
        obj.push({
          name: 'translate',
          path: parse[4],
          type: 'string'
        });
      }
      request(
        {
          url: req_url,
          method: req_method ? 'POST' : 'GET',
          timeout: 15000
        },
        function(error, response, body) {
          if (error || response.statusCode !== 200 || !body) {
            console.error(task, (error && error.code) || '', body);
            return callback();
          }
          var results = [];
          var sorting = [];
          var body_json = tryParseJSON(body);
          if (typeof body_json !== 'object') {
            return callback();
          }
          function zero(first_path, id, key_paths) {
            var add_path = id && key_paths[id] ? key_paths[id] : '';
            var next_id = key_paths[id + 1] ? id + 1 : 0;
            var array_key_path = op.get(body_json, first_path);
            if (typeof array_key_path !== 'object') return;
            if (!Array.isArray(array_key_path)) {
              var key_array = [];
              Object.keys(array_key_path).forEach(function(key) {
                key_array.push({
                  key: key,
                  value: array_key_path[key]
                });
              });
              op.set(body_json, first_path, key_array);
            } else {
              array_key_path.forEach(function(akp, i) {
                var curr_key_path = [first_path, i, add_path]
                  .filter(function(p) {
                    return p !== '';
                  })
                  .join('.');
                var key_object = op.get(body_json, curr_key_path);
                if (typeof key_object !== 'object') return;
                zero(curr_key_path, next_id, key_paths);
              });
            }
          }
          if (changes && changes.length) {
            changes.forEach(function(change) {
              var key_path = change.trim();
              if (!key_path) return;
              var key_paths = key_path.split('0').map(function(p) {
                return p.replace(/\.+/g, '.').replace(/(^\.*)|(\.*)$/g, '');
              });
              zero(key_paths[0], key_paths[1] ? 1 : 0, key_paths);
            });
          }
          var all = adop(body_json, obj);
          var ids = all.reduce(function(r, a) {
            if (sorting.indexOf(a['id']) === -1) {
              sorting.push(a['id']);
            }
            r[a['id']] = r[a['id']] || [];
            r[a['id']].push(a);
            return r;
          }, {});

          Object.keys(ids)
            .filter(function(id) {
              return id && id !== '0';
            })
            .forEach(function(id) {
              var t = ids[id]
                .sort(function(a, b) {
                  return parseFloat(b.season) - parseFloat(a.season);
                })
                .filter(function(episode, i, a) {
                  return a[0].season <= episode.season;
                })
                .sort(function(a, b) {
                  return parseFloat(b.episode) - parseFloat(a.episode);
                })
                .filter(function(episode, i, a) {
                  return a[0].episode === episode.episode;
                });
              var translates = Object.assign({}, t[0], {
                translate_url: (t && t[0] && t[0].translate) || '',
                translate: t
                  ? t
                      .map(function(episode) {
                        return episode.translate;
                      })
                      .join(' ')
                  : ''
              });
              results.push(translates);
            });

          results.sort(function(a, b) {
            return sorting.indexOf(a.id) - sorting.indexOf(b.id);
          });

          if (!results.length) return callback();

          var key =
            parse[1].split('<>') && parse[1].split('<>')[1]
              ? parse[1].split('<>')[1].trim()
              : 'id';
          var queries = results
            .filter(function(result) {
              return (
                result.id &&
                result.season &&
                result.episode &&
                parseInt(result.id) &&
                parseInt(result.season) &&
                parseInt(result.episode)
              );
            })
            .map(function(result) {
              result['key'] = key;
              return result;
            });

          var file_episodes = [];
          try {
            file_episodes = tryParseJSON(
              fs.readFileSync(
                path.join(
                  path.dirname(__filename),
                  '..',
                  'files',
                  'episodes.json'
                ),
                'utf8'
              )
            );
          } catch (e) {}

          process.env['CP_VER'] = new Date().getTime().toString();

          var tvs = [];
          async.eachOfLimit(
            queries,
            1,
            function(tv, tv_index, callback) {
              if (active.num <= 0) {
                console.log('[FORCE STOP]', 'episode');
                return process.exit(0);
              }
              var req = {};
              if (tv.key.indexOf('custom.') + 1) {
                req['id'] = tv.key;
                req[tv.key] = tv.id;
                if (tv.key.indexOf('custom.tmdb_id') + 1) {
                  req['type'] = 1;
                }
              } else {
                req['id'] = tv.id;
              }
              CP_get.movies(Object.assign({}, req), 1, '', 1, true, function(
                err,
                rt
              ) {
                if (err) {
                  console.error(err);
                  return callback('STOP');
                }
                if (rt && rt.length) {
                  var new_tv = Object.assign({}, rt[0]);
                  if (tv.translate) new_tv.translate = tv.translate;
                  if (tv.season) new_tv.season = tv.season;
                  if (tv.episode) new_tv.episode = tv.episode;
                  if (tv.translate_url) new_tv.translate_url = tv.translate_url;
                  tvs.push(new_tv);
                }
                callback();
              });
            },
            function() {
              if (!tvs || !tvs.length) {
                console.log(
                  '[CP_get.movies]',
                  JSON.stringify(queries),
                  'NOT SERIES'
                );
                return callback(null);
              }
              var episodes = tvs.map(function(episode) {
                episode.url =
                  episode.url +
                  '/s' +
                  episode.season +
                  'e' +
                  episode.episode +
                  (episode.translate && episode.translate_url
                    ? '_' +
                      CP_translit.text(
                        episode.translate_url,
                        undefined,
                        'translate'
                      )
                    : '');
                episode.pathname =
                  episode.pathname +
                  '/s' +
                  episode.season +
                  'e' +
                  episode.episode +
                  (episode.translate && episode.translate_url
                    ? '_' +
                      CP_translit.text(
                        episode.translate_url,
                        undefined,
                        'translate'
                      )
                    : '');
                episode.year2 =
                  episode.season +
                  ' ' +
                  config.l.season +
                  ' ' +
                  episode.episode +
                  ' ' +
                  config.l.episode;
                episode.year3 = 'S' + episode.season + 'E' + episode.episode;
                delete episode.translate_url;
                return episode;
              });
              file_episodes.forEach(function(file_episode) {
                if (episodes.length >= modules.episode.data.index.max) {
                  return;
                }
                var set_episode_id = true;
                episodes.forEach(function(episode) {
                  if (file_episode.id === episode.id) {
                    set_episode_id = false;
                  }
                });
                if (set_episode_id) {
                  episodes.push(file_episode);
                } else {
                  var set_episode = true;
                  episodes.forEach(function(episode) {
                    if (
                      file_episode.season < episode.season ||
                      (file_episode.season === episode.season &&
                        file_episode.episode <= episode.episode)
                    ) {
                      set_episode = false;
                    }
                  });
                  if (set_episode) {
                    episodes.push(file_episode);
                  }
                }
              });
              fs.writeFileSync(
                path.join(
                  path.dirname(__filename),
                  '..',
                  'files',
                  'episodes.json'
                ),
                JSON.stringify(episodes, null, 2)
              );
              setTimeout(function() {
                callback();
              }, 1000);
            }
          );
        }
      );
    },
    function() {
      active.num--;
      active.process.episode = false;
    }
  );
} else {
  console.log(
    'NOT START:',
    'EPISODE',
    'status',
    !!modules.episode.status,
    'custom',
    modules.episode.data.index.custom.length
  );
}

/**
 * Publish new movies.
 */

if (
  config.publish.every.hours &&
  config.publish.every.movies &&
  !(config.publish.start === 298 && config.publish.stop === 10000000) &&
  !(hour % config.publish.every.hours)
) {
  active.num++;
  active.process.publish = true;

  setTimeout(function() {
    active.num--;
    active.process.publish = false;
  }, 1000 * 60 * 55);

  process.env['CP_VER'] = new Date().getTime().toString();

  CP_get.publishIds(function(err, ids) {
    var log = '';

    if (!ids) {
      log = '[publish] Not Movies.';
      config.publish.every.hours = 0;
      config.publish.every.movies = 0;
      config.publish.start = 298;
      config.publish.stop = 10000000;
    } else if (
      ((ids.start_id < 298 ? 298 : ids.start_id) ===
        (config.publish.start < 298 ? 298 : config.publish.start) &&
        (ids.stop_id > 10000000 ? 10000000 : ids.stop_id) ===
          (config.publish.stop > 10000000 ? 10000000 : config.publish.stop)) ||
      (config.publish.start === 298 && config.publish.stop === 10000000)
    ) {
      log = '[publish] Repeated values.';
      config.publish.every.hours = 0;
      config.publish.every.movies = 0;
      config.publish.start = 298;
      config.publish.stop = 10000000;
    } else {
      if (config.publish.start === 298) {
        ids.start_id = 298;
      }
      if (config.publish.stop === 10000000) {
        ids.stop_id = 10000000;
      }
      if (ids.start_id < 298) {
        ids.start_id = 298;
      }
      if (ids.stop_id > 10000000) {
        ids.stop_id = 10000000;
      }
      if (ids.start_id === 298 && ids.stop_id === 10000000) {
        log = '[publish] All movies published.';
        config.publish.every.hours = 0;
        config.publish.every.movies = 0;
        config.publish.start = 298;
        config.publish.stop = 10000000;
      } else {
        log = '[publish] New IDs: ' + ids.start_id + ' - ' + ids.stop_id;
        config.publish.start = ids.start_id;
        config.publish.stop = ids.stop_id;
      }
    }

    if (
      modules.rewrite.status &&
      modules.rewrite.data.token &&
      ids &&
      ids.soon_id
    ) {
      active.num++;
      active.process.rewrite = true;

      console.log('CP_XMLPIPE2', ids.soon_id.join('|'));
      CP_get.movies(
        { query_id: ids.soon_id.join('|'), from: process.env.CP_XMLPIPE2 },
        ids.soon_id.length,
        '',
        1,
        false,
        function(err, movies_CP_XMLPIPE2) {
          if (err) {
            active.num--;
            active.process.rewrite = '[CP_get.movies] ERR';
            return console.log('[CP_get.movies]', err);
          }
          if (movies_CP_XMLPIPE2 && movies_CP_XMLPIPE2.length) {
            movies_CP_XMLPIPE2 = movies_CP_XMLPIPE2.filter(function(m) {
              return m.description && m.description.length >= 100;
            });
            var rewrites = [];
            async.eachOfLimit(
              movies_CP_XMLPIPE2,
              1,
              function(movie_CP_XMLPIPE2, i, callback) {
                movie_CP_XMLPIPE2.description = movie_CP_XMLPIPE2.description.trim();
                CP_get.movies(
                  {
                    query_id: movie_CP_XMLPIPE2.query_id,
                    from: process.env.CP_XMLPIPE2
                  },
                  1,
                  '',
                  1,
                  true,
                  function(err, structures_CP_XMLPIPE2) {
                    if (err) {
                      console.log(movie_CP_XMLPIPE2.query_id, err);
                      return callback();
                    }
                    if (modules.rewrite.data.condition) {
                      var condition = _eval(
                        'module.exports=function(movie){return !!(' +
                          modules.rewrite.data.condition.toString() +
                          ');}'
                      );
                      if (!condition(structures_CP_XMLPIPE2[0])) {
                        return callback();
                      }
                    }
                    CP_get.movies(
                      {
                        query_id: movie_CP_XMLPIPE2.query_id,
                        from: process.env.CP_RT
                      },
                      1,
                      '',
                      1,
                      false,
                      function(err, movies_CP_RT) {
                        if (err) {
                          console.log(movie_CP_XMLPIPE2.query_id, err);
                          return callback();
                        }
                        if (
                          movies_CP_RT &&
                          movies_CP_RT[0] &&
                          movies_CP_RT[0].description &&
                          movie_CP_XMLPIPE2.description.toLowerCase() !==
                            movies_CP_RT[0].description.trim().toLowerCase()
                        ) {
                          console.log(
                            movie_CP_XMLPIPE2.query_id,
                            movie_CP_XMLPIPE2.description.length +
                              ' !== ' +
                              movies_CP_RT[0].description.trim().length
                          );
                          return callback();
                        }
                        sinoni({
                          token: modules.rewrite.data.token,
                          double: modules.rewrite.data.double,
                          unique: modules.rewrite.data.unique,
                          text: movie_CP_XMLPIPE2.description,
                          lang: config.language
                        })
                          .then(function(res) {
                            var custom = {};
                            if (movie_CP_XMLPIPE2.custom) {
                              custom = JSON.parse(movie_CP_XMLPIPE2.custom);
                            }
                            if (typeof res.percent !== 'undefined') {
                              custom.rewrite = {};
                              if (typeof res.percent !== 'undefined') {
                                custom.rewrite.percent = res.percent;
                              }
                              if (typeof res.words !== 'undefined') {
                                custom.rewrite.words = res.words;
                              }
                              if (typeof res.spam !== 'undefined') {
                                custom.rewrite.spam = res.spam;
                              }
                              if (typeof res.water !== 'undefined') {
                                custom.rewrite.water = res.water;
                              }
                            }
                            if (typeof res.rewrite !== 'undefined') {
                              custom.unique = true;
                              movie_CP_XMLPIPE2.custom = JSON.stringify(custom);
                              movie_CP_XMLPIPE2.description = res.rewrite;
                              CP_save.save(movie_CP_XMLPIPE2, 'rt', function(
                                err
                              ) {
                                rewrites.push(movie_CP_XMLPIPE2.query_id);
                                callback(err);
                              });
                            } else {
                              callback();
                            }
                          })
                          .catch(function(err) {
                            callback(err);
                          });
                      }
                    );
                  }
                );
              },
              function(err) {
                if (err) console.log('[sinoni]', err);
                active.num--;
                active.process.rewrite = rewrites.length
                  ? 'Movies ' + rewrites.join(',')
                  : false;
              }
            );
          } else {
            active.num--;
            active.process.rewrite = 'Movies 0';
          }
        }
      );
    } else {
      console.log(
        'NOT START:',
        'REWRITE',
        'status',
        !!modules.rewrite.status,
        'token',
        !!modules.rewrite.data.token
      );
    }

    CP_save.save(config, 'config', function(err) {
      if (err) {
        console.log('[CP_save.save]', err);
      } else {
        console.log(log);
      }
      active.num--;
      active.process.publish = false;
    });
  });
} else {
  console.log(
    'NOT START:',
    'PUBLISH',
    'hours',
    config.publish.every.hours,
    'movies',
    config.publish.every.movies,
    '(' + hour + ' hour)'
  );
}

/**
 * Rotate domains.
 */

if (
  config.rotate &&
  config.rotate.list &&
  config.rotate.list.length &&
  hour === 3
) {
  active.num++;
  active.process.rotate = true;

  var log_list = [];

  var list_domains = config.rotate.list;

  var current_domains = [
    config.bomain,
    config.alt.bomain,
    config.ru.domain,
    config.ru.bomain
  ];

  if (
    config.bomain &&
    list_domains[0] &&
    config.rotate.area.indexOf('domain.for.bots') + 1
  ) {
    config.bomain = list_domains.splice(0, 1)[0];
    log_list.push(current_domains[0] + ' » ' + config.bomain);
  }

  if (
    config.alt.bomain &&
    list_domains[0] &&
    config.rotate.area.indexOf('domain2.for.bots') + 1
  ) {
    config.alt.bomain = list_domains.splice(0, 1)[0];
    log_list.push(current_domains[1] + ' » ' + config.alt.bomain);
  }

  if (
    config.ru.domain &&
    list_domains[0] &&
    config.rotate.area.indexOf('domain.for.ru.people') + 1
  ) {
    config.ru.domain = list_domains.splice(0, 1)[0];
    log_list.push(current_domains[2] + ' » ' + config.ru.domain);
  }

  if (
    config.ru.bomain &&
    list_domains[0] &&
    config.rotate.area.indexOf('domain.for.ru.bots') + 1
  ) {
    config.ru.bomain = list_domains.splice(0, 1)[0];
    log_list.push(current_domains[3] + ' » ' + config.ru.bomain);
  }

  config.rotate.list = list_domains.concat(current_domains.filter(Boolean));

  CP_save.save(config, 'config', function(err) {
    if (err) console.log('[CP_save.save]', err);
    if (config.bomain && config.botdomain) {
      CP_sub.add(config.botdomain, config.bomain);
    }
    if (config.alt.bomain && config.alt.botdomain) {
      CP_sub.add(config.alt.botdomain, config.alt.bomain);
    }
    if (config.ru.domain && config.ru.subdomain) {
      CP_sub.add(config.ru.subdomain, config.ru.domain);
    }
    if (config.ru.bomain && config.ru.botdomain) {
      CP_sub.add(config.ru.botdomain, config.ru.bomain);
    }
    console.log(log_list.join('\n'));
    active.num--;
    active.process.rotate = false;
  });
} else {
  console.log(
    'NOT START:',
    'ROTATE',
    'config',
    !!(config.rotate && config.rotate.list && config.rotate.list.length),
    'hour',
    '3 !=',
    hour
  );
}

/**
 * Create random subdomain.
 */

if ((config.random || config.ru.random) && hour === 3) {
  active.num++;
  active.process.random = true;

  setTimeout(function() {
    config.subdomain = config.random ? dayToLetter() : config.subdomain;
    config.ru.subdomain = config.ru.random
      ? dayToLetter(
          null,
          config.ru.domain,
          config.ru.subdomain,
          config.ru.random
        )
          .replace(/\./g, '')
          .split('')
          .reverse()
          .join('') + '.'
      : config.ru.subdomain;

    CP_save.save(config, 'config', function(err) {
      if (err) console.log('[CP_save.save]', err);
      CP_sub.add(config.subdomain, config.domain);
      CP_sub.add(config.ru.subdomain, config.ru.domain);
      active.num--;
      active.process.random = false;
    });
  }, 30000);
} else {
  console.log(
    'NOT START:',
    'RANDOM',
    'config',
    !!config.random,
    'hour',
    '3 !=',
    hour
  );
}

/**
 * Check domain in BlackList.
 */

if (
  (config.botdomain ||
    config.subdomain ||
    config.ru.botdomain ||
    config.ru.subdomain) &&
  config.blacklist &&
  ((!(hour % 6) && hour !== 6) || hour === 3)
) {
  active.num++;
  active.process.checkdomain = true;

  setTimeout(function() {
    active.num--;
    active.process.checkdomain = false;
  }, 1000 * 60 * 55);

  setTimeout(function() {
    request(
      {
        url: 'https://reestr.rublacklist.net/api/v2/domains/json',
        method: 'GET',
        timeout: 15000
      },
      function(error, response, body) {
        if (error || response.statusCode !== 200 || !body) {
          console.error((error && error.code) || '', body);
          active.num--;
          active.process.checkdomain = false;
        }
        var dms = [];
        try {
          dms = JSON.parse(body);
        } catch (e) {
          console.error(e);
        }
        async.eachOfLimit(
          ['*', 'ru'],
          1,
          function(lang, index, callback) {
            if (lang === '*' && !config.botdomain && !config.subdomain) {
              return callback();
            }
            if (lang === 'ru' && !config.ru.botdomain && !config.ru.subdomain) {
              return callback();
            }
            var danger = false;
            var subs =
              lang === 'ru'
                ? config.ru.subdomain
                  ? config.ru.subdomain.split('.').filter(Boolean)
                  : []
                : config.subdomain
                ? config.subdomain.split('.').filter(Boolean)
                : [];
            var bots =
              lang === 'ru'
                ? config.ru.botdomain
                  ? config.ru.botdomain.split('.').filter(Boolean)
                  : []
                : config.botdomain
                ? config.botdomain.split('.').filter(Boolean)
                : [];
            var domains = {
              sub: {
                domain: lang === 'ru' ? config.ru.domain : config.domain,
                main: subs[1] ? subs[1] + '.' : subs[0] ? subs[0] + '.' : '',
                second: subs[1] ? subs[0] + '.' : ''
              },
              bot: {
                domain:
                  lang === 'ru'
                    ? config.ru.bomain || config.ru.domain
                    : config.bomain || config.domain,
                main: bots[1] ? bots[1] + '.' : bots[0] ? bots[0] + '.' : '',
                second: bots[1] ? bots[0] + '.' : ''
              }
            };
            for (var i = 0; i < dms.length; i++) {
              ['sub', 'bot'].forEach(function(name) {
                if (name === 'bot' && config.blacklist === 3) {
                  return;
                }
                if (name === 'sub' && config.blacklist === 2) {
                  return;
                }
                if (
                  (dms[i] === '*.' + domains.bot.domain ||
                    dms[i] === domains.bot.domain) &&
                  (lang === 'ru'
                    ? config.ru.alt.bomain &&
                      config.ru.bomain &&
                      config.ru.alt.bomain !== config.ru.bomain
                    : config.alt.bomain &&
                      config.bomain &&
                      config.alt.bomain !== config.bomain)
                ) {
                  domains.bot.domain =
                    lang === 'ru' ? config.ru.alt.bomain : config.alt.bomain;
                  if (
                    lang === 'ru'
                      ? config.ru.alt.botdomain
                      : config.alt.botdomain
                  ) {
                    domains.bot.main =
                      lang === 'ru'
                        ? config.ru.alt.botdomain
                        : config.alt.botdomain;
                    if (lang === 'ru') {
                      config.ru.alt.botdomain =
                        config.ru.alt.botdomain
                          .replace(/\./g, '')
                          .replace(/[0-9]/g, '') +
                        (parseInt(
                          config.ru.alt.botdomain.replace(/[^0-9]/g, '') || '0'
                        ) +
                          1) +
                        '.';
                    } else {
                      config.alt.botdomain =
                        config.alt.botdomain
                          .replace(/\./g, '')
                          .replace(/[0-9]/g, '') +
                        (parseInt(
                          config.alt.botdomain.replace(/[^0-9]/g, '') || '0'
                        ) +
                          1) +
                        '.';
                    }
                  }
                  danger = true;
                } else if (
                  domains[name].main &&
                  (dms[i] === domains[name].main + domains[name].domain ||
                    dms[i] === '*.' + domains[name].main + domains[name].domain)
                ) {
                  domains[name].main =
                    domains[name].main
                      .replace(/\./g, '')
                      .replace(/[0-9]/g, '') +
                    (parseInt(
                      domains[name].main.replace(/[^0-9]/g, '') || '0'
                    ) +
                      1) +
                    '.';
                  if (
                    name === 'bot' &&
                    (lang === 'ru'
                      ? config.ru.alt.botdomain
                      : config.alt.botdomain)
                  ) {
                    domains.bot.main =
                      lang === 'ru'
                        ? config.ru.alt.botdomain
                        : config.alt.botdomain;
                    if (lang === 'ru') {
                      config.ru.alt.botdomain =
                        config.ru.alt.botdomain
                          .replace(/\./g, '')
                          .replace(/[0-9]/g, '') +
                        (parseInt(
                          config.ru.alt.botdomain.replace(/[^0-9]/g, '') || '0'
                        ) +
                          1) +
                        '.';
                    } else {
                      config.alt.botdomain =
                        config.alt.botdomain
                          .replace(/\./g, '')
                          .replace(/[0-9]/g, '') +
                        (parseInt(
                          config.alt.botdomain.replace(/[^0-9]/g, '') || '0'
                        ) +
                          1) +
                        '.';
                    }
                  }
                  danger = true;
                } else if (
                  domains[name].second &&
                  (dms[i] ===
                    domains[name].second +
                      domains[name].main +
                      domains[name].domain ||
                    dms[i] ===
                      '*.' +
                        domains[name].second +
                        domains[name].main +
                        domains[name].domain)
                ) {
                  domains[name].second =
                    domains[name].second
                      .replace(/\./g, '')
                      .replace(/[0-9]/g, '') +
                    (parseInt(
                      domains[name].second.replace(/[^0-9]/g, '') || '0'
                    ) +
                      1) +
                    '.';
                  danger = true;
                }
              });
            }
            if (danger) {
              if (lang === 'ru') {
                config.ru.botdomain = config.ru.botdomain
                  ? domains.bot.second + domains.bot.main
                  : config.ru.botdomain;
                config.ru.subdomain = config.ru.subdomain
                  ? domains.sub.second + domains.sub.main
                  : config.ru.subdomain;
                config.ru.bomain = config.ru.bomain
                  ? domains.bot.domain
                  : config.ru.bomain;

                console.log(
                  'NEW RU SUBDOMAIN:',
                  config.ru.subdomain + domains.sub.domain
                );
                console.log(
                  'NEW RU BOTDOMAIN:',
                  config.ru.botdomain + domains.bot.domain
                );
              } else {
                config.botdomain = config.botdomain
                  ? domains.bot.second + domains.bot.main
                  : config.botdomain;
                config.subdomain = config.subdomain
                  ? domains.sub.second + domains.sub.main
                  : config.subdomain;
                config.bomain = config.bomain
                  ? domains.bot.domain
                  : config.bomain;

                console.log(
                  'NEW SUBDOMAIN:',
                  config.subdomain + domains.sub.domain
                );
                console.log(
                  'NEW BOTDOMAIN:',
                  config.botdomain + domains.bot.domain
                );
              }

              CP_save.save(config, 'config', function(err) {
                if (err) console.log('[CP_save.save]', err);
                callback();
              });
            } else {
              callback();
            }
          },
          function(err) {
            if (err) console.error(err);
            CP_sub.all(function() {
              active.num--;
              active.process.checkdomain = false;
            });
          }
        );
      }
    );
  }, 60000);
} else {
  console.log(
    'NOT START:',
    'CHECKDOMAIN',
    'config',
    !!config.botdomain ||
      !!config.subdomain ||
      !!config.ru.botdomain ||
      !!config.ru.subdomain,
    'hour',
    '12,18,24 !=',
    hour
  );
}

/**
 * Delete abuse movies.
 */

if (
  modules.abuse.data.imap.user &&
  modules.abuse.data.imap.password &&
  modules.abuse.data.imap.host &&
  hour === 3
) {
  active.num++;
  active.process.imap = true;

  setTimeout(function() {
    active.num--;
    active.process.imap = false;
  }, 1000 * 60 * 55);

  var options_imap = JSON.stringify(modules.abuse.data.imap);
  options_imap = JSON.parse(options_imap);
  options_imap.tls = options_imap.tls !== 0;
  delete options_imap.from;
  delete options_imap.subdomain;

  var options_smtp = JSON.stringify(modules.abuse.data.smtp);
  options_smtp = JSON.parse(options_smtp);
  options_smtp.secure = options_smtp.secure !== 0;
  if (options_smtp.dkim) {
    options_smtp.dkim = JSON.parse(options_smtp.dkim);
  } else {
    delete options_smtp.dkim;
  }
  var message = options_smtp.message;
  delete options_smtp.message;

  var date = new Date();
  var search = [
    [
      'or',
      ['SINCE', formatDate(new Date(date.setDate(date.getDate() - 1)))],
      ['UNSEEN']
    ]
  ];

  if (modules.abuse.data.imap.from && modules.abuse.data.imap.from.length) {
    if (modules.abuse.data.imap.from.length === 1) {
      modules.abuse.data.imap.from.forEach(function(email) {
        search.push(['FROM', email.trim()]);
      });
    } else if (modules.abuse.data.imap.from.length > 1) {
      var search_or = [];
      search_or.push('or');
      modules.abuse.data.imap.from.forEach(function(email) {
        search_or.push(['FROM', email.trim()]);
      });
      search.push(search_or);
    } else {
      search.push(['ALL']);
    }
  }

  var headers_ = [];

  var transporter =
    options_smtp && options_smtp.host
      ? nodemailer.createTransport(options_smtp)
      : null;
  var imap = new Imap(options_imap);

  var si_i = 0;
  var si = setInterval(function() {
    if (si_i >= 6) {
      clearInterval(si);
      console.error('ERROR: IMAP Timeout');
      active.num--;
      active.process.imap = false;
    }
    si_i++;
  }, 11000);

  imap.once('ready', function() {
    imap.openBox('INBOX', false, function(err) {
      if (err) {
        console.error('imap.openBox', err);
        return imap.end();
      }
      imap.search(search, function(err, results) {
        if (err || !results || !results.length) {
          console.log('imap.search', search, err || results);
          return imap.end();
        }
        var f = imap.fetch(results, { bodies: '', markSeen: true });
        f.on('message', function(msg) {
          var parser = new MP();
          parser.on('end', function(data) {
            var to =
              data['from'] && data['from'][0] && data['from'][0]['address']
                ? data['from'][0]['address']
                : '';
            var subject = data['subject'] ? data['subject'] : '';
            var text = data['text']
              ? data['text']
              : data['html']
              ? data['html']
                  .replace(/<blockquote>[^]*<\/blockquote>/gi, '')
                  .replace(/<q>[^]*<\/q>/gi, '')
              : '';
            var html = data['html']
              ? data['html']
                  .replace(/<blockquote>[^]*?<\/blockquote>/gi, '')
                  .replace(/<q>[^]*?<\/q>/gi, '')
              : data['text']
              ? data['text']
              : '';
            if (to && subject && (text || html)) {
              headers_.push({
                to: to,
                subject: subject,
                text: text,
                html: html
              });
            }
          });
          msg.on('body', function(stream) {
            stream.on('data', function(chunk) {
              parser.write(td.decode(chunk));
            });
          });
          msg.once('end', function() {
            parser.end();
          });
        });
        f.once('error', function(err) {
          console.error('f.once', err);
        });
        f.once('end', function() {
          imap.end();
        });
      });
    });
  });
  imap.once('error', function(err) {
    clearInterval(si);
    console.error('imap.once', err);
    active.num--;
    active.process.imap = false;
  });
  imap.once('close', function() {
    clearInterval(si);
    if (headers_ && headers_.length) {
      var save = false;
      async.eachOfLimit(
        headers_,
        1,
        function(d, i, callback) {
          var re = new RegExp(
            '(' +
              config.domain +
              '|' +
              config.bomain +
              ')' +
              '(\\/mobile-version|\\/tv-version|)\\/[a-z0-9._-]*?' +
              (config.urls.slash === '/' ? '\\/' : '-') +
              '[a-z0-9._-]*',
            'ig'
          );
          var urls = headers_[i].html
            .replace(/<br>/gi, '')
            .replace(/\n/gi, '')
            .replace(/\r\n/gi, '')
            .replace(/\r/gi, '')
            .match(re);
          if (!urls) {
            console.log('NOT ID', headers_[i]);
            return callback();
          } else {
            var unique = urls.filter(function(v, i, a) {
              return a.indexOf(v) === i;
            });
            console.log('URLS', unique);
          }
          var send = false;
          headers_[i].id = [];
          unique.forEach(function(u) {
            var id = movie.id(u);
            if (id >= 1 && id <= 99999999) {
              send = !!transporter;
              if (!(headers_[i].id.indexOf('' + id) + 1)) {
                headers_[i].id.push(id.toString());
              }
              if (modules.abuse.data.movies.indexOf('' + id) + 1) {
                console.log('ABUSE ONLY EMAIL', headers_[i].to, id, send);
              } else {
                console.log('ABUSE', headers_[i].to, id, send);
                modules.abuse.data.movies.unshift('' + id);
                save = true;
              }
            }
          });
          console.log('SEND', send, headers_[i].id);
          if (send) {
            send = false;
            var dateNow = new Date();
            var dateString =
              ('0' + dateNow.getDate()).slice(-2) +
              '-' +
              ('0' + (dateNow.getMonth() + 1)).slice(-2) +
              '-' +
              dateNow.getFullYear() +
              ' ' +
              ('0' + dateNow.getHours()).slice(-2) +
              ':' +
              ('0' + dateNow.getMinutes()).slice(-2);
            var mailMessage =
              message && message.indexOf('[id]') + 1
                ? message.replace(/\[id]/gi, headers_[i].id.join(','))
                : message;
            while (true) {
              var p = new RegExp('\\[([^]*?)\\]', 'g');
              var parts = p.exec(mailMessage);
              if (parts) {
                var search = parts[0];
                if (parts[1] && parts[1].indexOf('|') + 1) {
                  var part = parts[1].split('|');
                  var replace = part[Math.floor(Math.random() * part.length)];
                  mailMessage = mailMessage.replace(search, replace);
                } else {
                  mailMessage = mailMessage.replace(search, '');
                }
              } else {
                break;
              }
            }
            mailMessage = mailMessage
              .replace(/\s+/g, ' ')
              .replace(/(^\s*)|(\s*)$/g, '');
            var mailOptions = {
              name: options_smtp.auth.user.split('@')[1],
              from: options_smtp.auth.user,
              to: headers_[i].to,
              textEncoding: 'base64',
              date: dateNow,
              subject: 'RE: ' + headers_[i].subject,
              text: (
                mailMessage
                  .replace(/<br>/gi, '\n')
                  .replace(/(<([^>]+)>)/gi, '') +
                '\n\n' +
                '---- ' +
                dateString +
                ' <' +
                headers_[i].to +
                '> ----\n' +
                headers_[i].text
                  .replace(/<br>/gi, '\n')
                  .replace(/(<([^>]+)>)/gi, '')
              ).replace(/(^\s*)|(\s*)$/g, ''),
              html: (
                mailMessage +
                '<br><br>' +
                '---- ' +
                dateString +
                ' <' +
                headers_[i].to +
                '> ----<br>' +
                '<blockquote>' +
                headers_[i].html.replace(/\n/g, '<br>') +
                '</blockquote>'
              )
                .replace(/\s+/g, ' ')
                .replace(/(^\s*)|(\s*)$/g, '')
            };
            setTimeout(function() {
              console.log(
                'START sendMail',
                headers_[i].to,
                headers_[i].subject
              );
              transporter.sendMail(mailOptions, function(err) {
                if (err) console.error('sendMail', err);
                console.log(
                  'REPLY',
                  headers_[i].to,
                  'RE: ' + headers_[i].subject
                );
                if (
                  !err &&
                  modules.abuse.data.smtp.host.indexOf('zoho') === -1
                ) {
                  var imap2 = new Imap(options_imap);
                  var si_i2 = 0;
                  var si2 = setInterval(function() {
                    if (si_i2 >= 6) {
                      clearInterval(si2);
                      console.error('ERROR: IMAP2 Timeout');
                      callback();
                    }
                    si_i2++;
                  }, 11000);
                  imap2.once('ready', function() {
                    imap2.openBox('Sent', false, function(err, box) {
                      if (err) {
                        console.error('openBox Sent', err);
                        imap2.end();
                        callback();
                      }
                      let msg, htmlEntity;
                      msg = mimemessage.factory({
                        contentType: 'multipart/alternate',
                        body: []
                      });
                      htmlEntity = mimemessage.factory({
                        contentType: 'text/html;charset=utf-8',
                        body: mailOptions.html
                      });
                      msg.header(
                        'Message-ID',
                        '<' +
                          Math.random()
                            .toString(36)
                            .substr(2, 5) +
                          '>'
                      );
                      msg.header('From', mailOptions.from);
                      msg.header('To', mailOptions.to);
                      msg.header('Subject', mailOptions.subject);
                      msg.body.push(htmlEntity);
                      imap2.append(
                        msg.toString(),
                        {
                          mailbox: 'Sent',
                          flags: ['Seen']
                        },
                        function(err) {
                          if (err) {
                            console.error('APPEND', err);
                          }
                          imap2.end();
                        }
                      );
                    });
                  });
                  imap2.once('error', function(err) {
                    clearInterval(si2);
                    console.error('SENT FOLDER', err);
                    callback();
                  });
                  imap2.once('close', function() {
                    clearInterval(si2);
                    console.error('SENT', mailOptions.to, mailOptions.subject);
                    callback();
                  });
                  imap2.connect();
                } else {
                  callback();
                }
              });
            }, 330000 * i);
            console.log('TIMEOUT', headers_[i].subject, 330000 * i, 'sec');
          } else {
            callback();
          }
        },
        function(err) {
          if (err) console.error(err);
          if (save) {
            CP_save.save(modules, 'modules', function(err) {
              if (err) console.log('[CP_save.save]', err);
              if (modules.abuse.data.imap.subdomain) {
                config.subdomain = dayToLetter();
                CP_save.save(config, 'config', function(err) {
                  if (err) console.log('[CP_save.save]', err);
                  CP_sub.add(config.subdomain, config.domain);
                  active.num--;
                  active.process.imap = false;
                });
              } else {
                active.num--;
                active.process.imap = false;
              }
            });
          } else {
            active.num--;
            active.process.imap = false;
          }
        }
      );
    } else {
      active.num--;
      active.process.imap = false;
      console.log('headers:', headers_.length, 'data:', headers_.length);
    }
  });
  imap.connect();

  function formatDate(date) {
    var monthNames = [
      'January',
      'February',
      'March',
      'April',
      'May',
      'June',
      'July',
      'August',
      'September',
      'October',
      'November',
      'December'
    ];

    var day = date.getDate();
    var monthIndex = date.getMonth();
    var year = date.getFullYear();

    return monthNames[monthIndex] + ' ' + day + ', ' + ' ' + year;
  }
} else {
  console.log(
    'NOT START:',
    'IMAP',
    'user',
    !!modules.abuse.data.imap.user,
    'password',
    !!modules.abuse.data.imap.password,
    'host',
    !!modules.abuse.data.imap.host,
    '3 !=',
    hour
  );
}

/**
 * Sitemap generator.
 */

if (hour === 1 || hour === 2 || hour === 4 || hour === 5) {
  active.num++;
  active.process.sitemap = true;

  setTimeout(function() {
    active.num--;
    active.process.sitemap = false;
  }, 1000 * 60 * 55);

  var year_start = new Date(timeZone).getFullYear() + 10;
  var year_stop = 1890;

  if (hour === 1) {
    year_stop = 2010;
  } else if (hour === 2) {
    year_start = 2009;
    year_stop = 1995;
  } else if (hour === 4) {
    year_start = 1994;
    year_stop = 1980;
  } else if (hour === 5) {
    year_start = 1979;
  }

  var years = [];

  for (var i = year_start; i >= year_stop; i--) {
    years.push('' + i);
  }

  var start = new Date();

  async.eachOfLimit(
    years,
    1,
    function(year, key, callback) {
      process.env['CP_VER'] = new Date().getTime().toString();

      var sitemap_movies = [];

      var N = parseInt('' + parseInt(config.default.loc) / 100);
      var a = Array(N),
        i = 0;

      while (i < N) a[i++] = i;

      async.eachOfLimit(
        a,
        1,
        function(movie, page, callback) {
          CP_get.movies(
            { year: year },
            -11,
            'kinopoisk-vote-up',
            page + 1,
            true,
            function(err, m) {
              if (err || Math.ceil(os.freemem()) < 50) {
                console.log(
                  '[CP_get.movies]',
                  'Year',
                  year,
                  'Mem',
                  Math.ceil(os.freemem()),
                  'MB',
                  err
                );
                return callback('STOP');
              }
              if (m && m.length) {
                m.forEach(function(one_movie) {
                  sitemap_movies.push(one_movie);
                });
                return callback(null);
              } else {
                return callback('STOP');
              }
            }
          );
        },
        function() {
          var render = {};
          render.urls = [];

          var dir = path.join(
            __dirname,
            '..',
            'themes',
            config.theme,
            'views',
            config.urls.sitemap
          );

          if (sitemap_movies && sitemap_movies.length) {
            for (var i = 0; i < sitemap_movies.length; i++) {
              if (
                (config.urls.noindex &&
                  sitemap_movies[i].url.indexOf(
                    '/' + config.urls.noindex + config.urls.slash
                  ) + 1) ||
                (modules.abuse.data.status_code_list === '404' &&
                  modules.abuse.data.movies.indexOf(
                    sitemap_movies[i].kp_id + ''
                  ) + 1)
              ) {
                continue;
              }
              render.urls[render.urls.length] = {
                loc:
                  config.protocol +
                  (config.botdomain + config.bomain ||
                    config.ru.botdomain + config.ru.bomain ||
                    config.subdomain + config.domain) +
                  sitemap_movies[i].pathname,
                lastmod:
                  sitemap_movies[i].custom && sitemap_movies[i].custom.lastmod
                    ? sitemap_movies[i].custom.lastmod.substr(0, 10)
                    : '',
                image: sitemap_movies[i].poster
                  ? /^(http|\/\/)/i.test(sitemap_movies[i].poster)
                    ? sitemap_movies[i].poster
                    : config.protocol +
                      (config.botdomain + config.bomain ||
                        config.ru.botdomain + config.ru.bomain ||
                        config.subdomain + config.domain) +
                      sitemap_movies[i].poster
                  : '',
                title: (sitemap_movies[i].title || '')
                  .replace(/&/g, '&amp;')
                  .replace(/'/g, '&apos;')
                  .replace(/"/g, '&quot;')
                  .replace(/>/g, '&gt;')
                  .replace(/</g, '&lt;')
              };
            }

            var tq = new Date() - start;
            var la = parseFloat(os.loadavg(1).toFixed(2));
            active.process.sitemap = '[ ' + year + ' ] ' + tq + 'ms';
            if (Math.ceil(os.freemem()) < 50) {
              callback('STOP');
            } else {
              setTimeout(function() {
                start = new Date();
                callback(null, render);
              }, tq * la);
            }
          } else {
            fs.mkdirSync(dir, { recursive: true });
            fs.writeFile(
              path.join(dir, config.urls.year + '-' + year + '.json'),
              JSON.stringify({ urls: [] }, null, 2),
              function(err) {
                if (err) console.error('Write File Error:', err);
              }
            );
            return callback(null, render);
          }

          fs.mkdirSync(dir, { recursive: true });
          fs.writeFile(
            path.join(dir, config.urls.year + '-' + year + '.json'),
            JSON.stringify(render, null, 2),
            function(err) {
              if (err) console.error('Write File Error:', err);
            }
          );
        }
      );
    },
    function() {
      active.num--;
      active.process.sitemap = false;
    }
  );
} else {
  console.log('NOT START:', 'SITEMAP', 'hour', '1,2,4,5 !=', hour);
}

/**
 * Categories generator.
 */

if (hour === 6) {
  active.num++;
  active.process.categories = true;

  setTimeout(function() {
    active.num--;
    active.process.categories = false;
  }, 1000 * 60 * 55);

  var categories = ['year', 'genre', 'country', 'actor', 'director'];

  var suc_categories = [];

  async.eachOfLimit(
    categories,
    1,
    function(category, key, callback) {
      process.env['CP_VER'] = new Date().getTime().toString();

      var query = {};
      query[category] = '!_empty';

      var category_movies = [];

      var N = parseInt('' + parseInt(config.default.tag) / 100);
      var a = Array(N),
        i = 0;

      while (i < N) a[i++] = i;

      async.eachOfLimit(
        a,
        1,
        function(movie, page, callback) {
          CP_get.movies(
            query,
            -22,
            'kinopoisk-vote-up',
            page + 1,
            false,
            function(err, m) {
              if (err || Math.ceil(os.freemem()) < 50) {
                console.log(
                  '[CP_get.movies]',
                  'Category',
                  category,
                  'Mem',
                  Math.ceil(os.freemem()),
                  'MB',
                  err
                );
                return callback('STOP');
              }
              active.process.categories =
                '[ ' + suc_categories.join(', ') + ' ] SUCCESS';
              if (m && m.length) {
                m.forEach(function(one_movie) {
                  category_movies.push(one_movie);
                });
                return callback(null);
              } else {
                return callback('STOP');
              }
            }
          );
        },
        function() {
          if (
            category_movies &&
            category_movies.length &&
            category === 'year'
          ) {
            category_movies.push({
              year: new Date().getFullYear() + ''
            });
          }

          var render = CP_structure.categories(category, category_movies);

          var file = path.join(__dirname, '..', 'files', category + '.json');

          fs.writeFile(file, JSON.stringify(render, null, 2), function(err) {
            if (err) console.error('Write File Error:', err);
          });

          suc_categories.push(category);

          callback(null);
        }
      );
    },
    function() {
      active.num--;
      active.process.categories = false;
    }
  );
} else {
  console.log('NOT START:', 'CATEGORIES', 'hour', '6 !=', hour);
}

/**
 * Generate WORLD and RU subdomains.
 */

if (config.random || config.ru.random) {
  (function fileSubdomains() {
    request('https://api.ipify.org', function(error, response, body) {
      if (error || !body) return;
      var dns = '.' + config.domain + '.\t1\tIN\tA\t' + body;
      var dns_ru = '.' + config.ru.domain + '.\t1\tIN\tA\t' + body;
      var subdomains = {};
      subdomains[config.domain] = [dayToLetter().replace(/\./g, '') + dns];
      if (config.ru.domain) {
        if (config.domain === config.ru.domain) {
          subdomains[config.domain].push(
            dayToLetter()
              .replace(/\./g, '')
              .split('')
              .reverse()
              .join('') + dns
          );
        } else {
          subdomains[config.ru.domain] = [
            dayToLetter()
              .replace(/\./g, '')
              .split('')
              .reverse()
              .join('') + dns_ru
          ];
        }
      }
      for (var i = 1; i <= 365; i++) {
        var tomorrow = new Date();
        tomorrow.setDate(tomorrow.getDate() + i);
        subdomains[config.domain].push(
          dayToLetter(tomorrow).replace(/\./g, '') + dns
        );
        if (config.ru.domain) {
          subdomains[config.ru.domain].push(
            dayToLetter(tomorrow)
              .replace(/\./g, '')
              .split('')
              .reverse()
              .join('') + dns_ru
          );
        }
      }
      fs.writeFileSync(
        path.join(
          path.dirname(__filename),
          '..',
          'files',
          config.domain +
            (config.dns.cloudflare.proxied === 'true' ? '.proxied' : '') +
            '.sub.txt'
        ),
        subdomains[config.domain].join('\n') + '\n'
      );
      if (config.ru.domain) {
        fs.writeFileSync(
          path.join(
            path.dirname(__filename),
            '..',
            'files',
            config.ru.domain +
              (config.dns.cloudflare.proxied === 'true' ? '.proxied' : '') +
              '.sub.txt'
          ),
          subdomains[config.ru.domain].join('\n') + '\n'
        );
      }
    });
  })();
}

/**
 * Save data.
 *
 * @param {String} collection
 * @param {Object} movies
 * @param {Callback} callback
 */

function saveData(collection, movies, callback) {
  if (active.num <= 0) {
    console.log('[FORCE STOP]', 'saveData 1');
    return process.exit(0);
  }
  CP_get.contents({ content_url: collection }, 1, 1, false, function(
    err,
    contents
  ) {
    if (err) {
      console.log('[CP_get.contents]', collection, err);
      return callback(null);
    }
    if (contents && contents.length && contents[0].id) {
      console.log('API', movies.length, 'movies');
      var content = contents[0];
      var sort_movies = [];
      async.eachOfLimit(
        movies,
        1,
        function(movie, key, callback) {
          var req = {
            id_where: true
          };
          if (movie.key && movie.key.indexOf('custom.') + 1) {
            req['id'] = movie.key;
            req[movie.key] = movie.id;
          } else if (movie.id) {
            req['id'] = movie.id;
          } else {
            console.log('NOT ID', movie);
            return callback();
          }
          CP_get.movies(req, 1, '', 1, false, function(err, m) {
            if (err) {
              console.log('[CP_get.movies]', movie.id, err);
              return callback(null);
            }
            if (m && m.length) {
              var cur_movie = Object.assign({}, m[0]);
              var new_movie = {};
              new_movie.kp_id = cur_movie.kp_id;
              new_movie.custom = cur_movie.custom;
              if (movie.quality && cur_movie.quality !== movie.quality) {
                new_movie.quality = movie.quality;
              }
              if (
                cur_movie.quality.toString().toLowerCase() === 'null' ||
                cur_movie.quality.toString().toLowerCase() === 'undefined' ||
                cur_movie.quality.toString().toLowerCase() === 'false' ||
                cur_movie.quality.toString().toLowerCase() === 'none' ||
                cur_movie.quality.toString().toLowerCase() === 'nan' ||
                cur_movie.quality.toString().toLowerCase() === 'n/a'
              ) {
                new_movie.quality = movie.quality || '';
              }
              if (movie.translate && cur_movie.translate !== movie.translate) {
                new_movie.translate = movie.translate;
              }
              if (
                cur_movie.translate.toString().toLowerCase() === 'null' ||
                cur_movie.translate.toString().toLowerCase() === 'undefined' ||
                cur_movie.translate.toString().toLowerCase() === 'false' ||
                cur_movie.translate.toString().toLowerCase() === 'none' ||
                cur_movie.translate.toString().toLowerCase() === 'nan' ||
                cur_movie.translate.toString().toLowerCase() === 'n/a'
              ) {
                new_movie.translate = movie.translate || '';
              }
              sort_movies.push(new_movie);
            }
            return callback(null);
          });
        },
        function() {
          console.log('WEB', sort_movies.length, 'movies');
          if (sort_movies && sort_movies.length) {
            if (!sort_movies.length) return callback(null);
            var content_movies = content.content_movies
              .replace(/^,*|,*$/, '')
              .split(',');
            sort_movies.reverse().forEach(function(m) {
              if (!m.kp_id) return;
              return content_movies.unshift('' + m.kp_id);
            });
            content.content_movies = content_movies
              .filter(function(value, index, self) {
                return self.indexOf(value) === index;
              })
              .filter(Boolean)
              .filter(function(id) {
                return (
                  parseInt(id) &&
                  modules.abuse.data.movies.indexOf(id + '') === -1
                );
              })
              .join(',');
            var noMore = 0;
            if (content.content_tags.indexOf('NoMore') + 1) {
              content.content_tags.split(',').forEach(function(tag) {
                if (tag.indexOf('NoMore') + 1) {
                  noMore = parseInt(tag.replace(/[^0-9]/g, '') || '200');
                }
              });
            }
            if (noMore && content.content_movies.split(',').length > noMore) {
              content.content_movies = content.content_movies
                .split(',')
                .slice(0, noMore);
            }
            if (!noMore && content.content_movies.split(',').length > 200) {
              content.content_tags =
                content.content_tags.indexOf('NoSorting') + 1
                  ? content.content_tags
                  : content.content_tags
                  ? content.content_tags + ',NoSorting'
                  : 'NoSorting';
            }
            if (Math.ceil(os.freemem()) < 50) {
              console.log(
                '[CONTENT ' + (content.content_url || '') + ']',
                'NOT UPDATE',
                '(FREE MEM ' + Math.ceil(os.freemem()) + 'MB < 50MB)'
              );
              return callback(null);
            }
            if (active.num <= 0) {
              console.log('[FORCE STOP]', 'saveData 2');
              return process.exit(0);
            }
            CP_save.save(content, 'content', function(err, result) {
              console.log(
                '[CP_save.save]',
                collection,
                content.content_movies,
                err,
                result
              );
              var readOnly = false;
              setTimeout(function() {
                if (readOnly) {
                  return console.error('readOnly', err);
                }
                readOnly = true;
                var saved = {};
                async.eachOfLimit(
                  sort_movies,
                  1,
                  function(movie, key, callback) {
                    if (
                      (!movie.translate && !movie.quality) ||
                      active.num === 0
                    ) {
                      return callback(null);
                    }
                    if (Math.ceil(os.freemem()) < 50) {
                      console.log(
                        '[KP ID ' + movie.kp_id + ']',
                        'NOT UPDATE',
                        '(FREE MEM ' + Math.ceil(os.freemem()) + 'MB < 50MB)'
                      );
                      return callback(null);
                    }
                    if (active.num <= 0) {
                      console.log('[FORCE STOP]', 'saveData 3');
                      return process.exit(0);
                    }
                    var rt = {};
                    rt.id = movie.kp_id;
                    rt.kp_id = movie.kp_id;
                    rt.translate = movie.translate;
                    rt.quality = movie.quality.toUpperCase();
                    if (
                      movie.custom &&
                      typeof movie.custom === 'string' &&
                      /"unique":true|"unique":"true"|"unique":false|"unique":"false"/i.test(
                        '' + movie.custom
                      )
                    ) {
                      rt.custom = movie.custom;
                    } else {
                      try {
                        var c =
                          movie.custom && typeof movie.custom === 'string'
                            ? JSON.parse(movie.custom)
                            : typeof movie.custom === 'object'
                            ? movie.custom
                            : {};
                        c.unique = c.unique ? c.unique : false;
                        rt.custom = JSON.stringify(c);
                      } catch (e) {
                        rt.custom = JSON.stringify({ unique: false });
                      }
                    }
                    if (
                      typeof rt.translate === 'undefined' ||
                      (typeof rt.translate === 'string' &&
                        (rt.translate.toString().toLowerCase() === 'null' ||
                          rt.translate.toString().toLowerCase() ===
                            'undefined' ||
                          rt.translate.toString().toLowerCase() === 'false' ||
                          rt.translate.toString().toLowerCase() === 'none' ||
                          rt.translate.toString().toLowerCase() === 'nan' ||
                          rt.translate.toString().toLowerCase() === 'n/a'))
                    ) {
                      rt.translate = '';
                    }
                    if (
                      typeof rt.quality === 'undefined' ||
                      (typeof rt.quality === 'string' &&
                        (rt.quality.toString().toLowerCase() === 'null' ||
                          rt.quality.toString().toLowerCase() === 'undefined' ||
                          rt.quality.toString().toLowerCase() === 'false' ||
                          rt.quality.toString().toLowerCase() === 'none' ||
                          rt.quality.toString().toLowerCase() === 'nan' ||
                          rt.quality.toString().toLowerCase() === 'n/a'))
                    ) {
                      rt.quality = '';
                    }
                    CP_save.save(rt, 'rt', function(save_e) {
                      setTimeout(function() {
                        CP_get.movies(
                          {
                            from: process.env.CP_RT,
                            ids: rt.id
                          },
                          1,
                          '',
                          1,
                          false,
                          function(get_e, available) {
                            if (err || !available || !available.length) {
                              console.log(rt.id, 'CRASH INDEXER!');
                            } else {
                              saved[rt.id] = 1;
                              console.log(
                                rt.id,
                                available[0].title_ru +
                                  ' - [' +
                                  (rt.quality === available[0].quality
                                    ? rt.quality
                                    : rt.quality +
                                      '] != [' +
                                      available[0].quality) +
                                  ']' +
                                  ' ' +
                                  '[' +
                                  (rt.translate === available[0].translate
                                    ? rt.translate
                                    : rt.translate +
                                      '] != [' +
                                      available[0].translate) +
                                  ']'
                              );
                            }
                            return callback(null);
                          }
                        );
                      }, 500);
                    });
                  },
                  function() {
                    CP_get.count(
                      {
                        certainly: true,
                        full: true,
                        from: process.env.CP_RT
                      },
                      function(err, count) {
                        if (err) console.error(err);
                        console.log(
                          'CHANGED:',
                          Object.keys(saved).length,
                          'MOVIES:',
                          count ? parseInt(count) || 0 : 0
                        );
                        return callback(null);
                      }
                    );
                  }
                );
              }, 1000);
            });
          } else {
            console.log('[CP_get.movies] NOT IDs', collection, err);
            return callback(null);
          }
        }
      );
    } else {
      console.log('[CP_get.contents] NOT', collection, err);
      callback(null);
    }
  });
}

/**
 * Valid JSON.
 *
 * @param {String} jsonString
 */

function tryParseJSON(jsonString) {
  try {
    var o = JSON.parse(jsonString);
    if (o && typeof o === 'object') {
      return o;
    }
  } catch (e) {}
  return {};
}

/**
 * Current day to letter.
 */

function dayToLetter(now, domain, subdomain, random) {
  now = now || new Date();
  var year = now.getFullYear();
  var start = new Date(year, 0, 0);
  var diff = now - start;
  var oneDay = 86400000;
  var day = ('00' + Math.floor(diff / oneDay)).slice(-3);
  var letter1 = ['a', 'e', 'i', 'o', 'u'];
  var letter2 = ['b', 'c', 'd', 'f', 'g', 'h', 'z', 'k', 'l', 'm'];
  var letter3 = ['n', 'p', 'q', 'r', 's', 't', 'v', 'w', 'x', 'y']; // j
  if ((domain || config.domain).split('.')[0].length % 2) {
    letter1 = letter1.reverse();
  }
  if ((domain || config.domain).split('.')[1].length % 2) {
    letter2 = letter2.reverse();
  }
  var result =
    letter2[parseInt(day[0])] +
    letter1[parseInt(day[1]) % 5] +
    letter3[parseInt(day[2])] +
    ((random || config.random) === 3 ? '' : letter1[year % 5]);
  if (parseInt(day[1]) >= 5) {
    result =
      letter1[parseInt(day[0]) % 5] +
      (parseInt(day[0] + day[2]) % 2 ? letter2 : letter3)[parseInt(day[1])] +
      letter1[parseInt(day[2]) % 5] +
      ((random || config.random) === 3 ? '' : letter2[year % 10]);
  }
  if (now.getDate() % 2) {
    result = result
      .split('')
      .reverse()
      .join('');
  }
  var words = (subdomain || config.subdomain).split('.').filter(Boolean);
  words[0] = result;
  return words.join('.') + '.';
}

/**
 * yyyy-mm-dd date.
 */

function yyyy_mm_dd(date) {
  var d = new Date(date),
    month = '' + (d.getMonth() + 1),
    day = '' + d.getDate(),
    year = d.getFullYear();

  if (month.length < 2) month = '0' + month;
  if (day.length < 2) day = '0' + day;

  return [year, month, day].join('-');
}

/**
 * Check active process.
 */

var interval = 0;
var sint = setInterval(function() {
  if (!(interval % 10)) {
    if (Object.keys(active.process).length) {
      console.log(
        new Date()
          .toJSON()
          .replace('T', ' ')
          .split('.')[0],
        '[',
        Math.ceil(os.freemem()),
        'MB ]',
        os.loadavg(1).toFixed(2),
        os.loadavg(5).toFixed(2),
        os.loadavg(15).toFixed(2),
        active.process
      );
    }
  }
  if (active.num <= 0) {
    clearInterval(sint);
    if (Object.keys(active.process).length === 0) {
      return process.exit(0);
    }
    var rand = Math.floor(Math.random() * 10) + 10;
    setTimeout(function() {
      request(
        'http://localhost:3000/flush-cache-' + config.urls.admin,
        function(error, response, body) {
          if (error || body !== 'OK') {
            console.error('Flush Cache Error', error);
            return process.exit(0);
          }
          setTimeout(function() {
            console.log(
              new Date()
                .toJSON()
                .replace('T', ' ')
                .split('.')[0],
              '[',
              Math.ceil(os.freemem()),
              'MB ]',
              os.loadavg(1).toFixed(2),
              os.loadavg(5).toFixed(2),
              os.loadavg(15).toFixed(2)
            );
            console.timeEnd('DONE');
            return process.exit(0);
          }, 3000);
        }
      );
    }, rand * 1000);
  }
  interval++;
}, 1000);

process.stdout.on('error', function(err) {
  if (err.code === 'ENOMEM') {
    console.error(
      '---------------',
      'ERROR ENOMEM',
      Math.ceil(os.freemem()),
      '---------------'
    );
  }
  process.exit(0);
});