const config = require('./config');

global.client_id_b64 = Buffer.from(`${config.reddit_app_id}:`).toString(
  'base64'
);
global.reddit_access_token = null;
global.reddit_refresh_token = null;
global.ratelimit_counts = {};
global.ratelimit_timestamps = {};

const pug = require('pug');
const compression = require('compression');
const express = require('express');
const cookieParser = require('cookie-parser');
const r = require('redis');

const redis = (() => {
  if (!config.redis_enabled) {
    // Stub Redis if disabled
    return {
      get: (_, callback) => callback(null, null),
      setex: (_, _1, _2, callback) => callback(null),
      on: () => {},
    };
  }

  const redisOptions = {
    host: '127.0.0.1',
    port: 6379,
  };

  if (config.redis_db) {
    redisOptions.db = config.redis_db;
  }

  if (config.redis_host) {
    redisOptions.host = config.redis_host;
  }

  if (config.redis_port && config.redis_port > 0) {
    redisOptions.port = config.redis_port;
  }

  if (config.redis_password) {
    redisOptions.password = config.redis_password;
  }

  return r.createClient(redisOptions);
})();

const nodeFetch = require('node-fetch');
const fetch = config.http_proxy
  ? (() => {
      const agent = require('https-proxy-agent')(config.http_proxy);
      return (url, options) => {
        const instanceOptions = {
          agent,
          ...options,
        };
        return nodeFetch(url, instanceOptions);
      };
    })()
  : nodeFetch;

const helmet = require('helmet');
const bodyParser = require('body-parser');
const fs = require('fs');
const app = express();
const request = require('postman-request');
const commons = require('./inc/commons.js')(request, fs);
const dlAndSave = require('./inc/downloadAndSave.js')(commons);

['pics/thumbs', 'pics/flairs', 'pics/icons', 'vids']
  .map((d) => `./static/${d}`)
  .filter((d) => !fs.existsSync(d))
  .forEach((d) => fs.mkdirSync(d, { recursive: true }));

if (!config.https_enabled && config.redirect_http_to_https) {
  console.error(`Cannot redirect HTTP=>HTTPS while "https_enabled" is false.`);
}

let https = null;
if (config.https_enabled) {
  const privateKey = fs.readFileSync(`${config.cert_dir}/privkey.pem`, 'utf8');
  const certificate = fs.readFileSync(`${config.cert_dir}/cert.pem`, 'utf8');
  const ca = fs.readFileSync(`${config.cert_dir}/chain.pem`, 'utf8');
  const credentials = {
    key: privateKey,
    cert: certificate,
    ca: ca,
  };
  https = require('https').Server(credentials, app);
  global.protocol = 'https://';
} else {
  global.protocol = 'http://';
}

const http = require('http').Server(app);

if (config.redirect_www) {
  app.use((req, res, next) => {
    if (req.headers.host) {
      if (req.headers.host.slice(0, 4) === 'www.') {
        let newhost = req.headers.host.slice(4);
        return res.redirect(
          301,
          `${req.protocol}://${newhost}${req.originalUrl}`
        );
      }
    }
    next();
  });
}

if (config.use_helmet && config.https_enabled) {
  app.use(helmet());
  if (config.use_helmet_hsts) {
    app.use(helmet.hsts({ maxAge: 31536000, preload: true }));
  }
}

if (config.use_compression) {
  app.use(compression());
}

app.use(cookieParser());

if (config.use_view_cache) {
  app.set('view cache', true);
}

if (config.trust_proxy) {
  app.set('trust proxy', config.trust_proxy_address);
}

app.use(bodyParser.urlencoded({ extended: true, limit: '10mb' }));
app.use(bodyParser.json({ limit: '10mb' }));
app.use(express.static(`${__dirname}/static`));

app.set('views', './views');
app.set('view engine', 'pug');

const redditAPI = require('./inc/initRedditApi.js')(fetch);

/*
This is temporary. It's needed for the routes to work.
It can be removed once these functions are made more modular.
*/
module.exports = { redis, fetch, RedditAPI: redditAPI };

const allRoutes = require('./routes/index');

app.use('/', allRoutes);

// The old routes
//require('./routes')(app, redis, fetch, redditAPI);

if (config.redirect_http_to_https) {
  app.use((req, res, next) => {
    if (req.secure) next();
    else res.redirect(`https://${req.headers.host}${req.url}`);
  });
}

redis.on('error', (error) => {
  if (error) {
    console.error(`Redis error: ${error}`);
  }
});

const cacheControl = require('./cacheControl.js');
cacheControl.removeCacheFiles();

if (config.https_enabled) {
  https.listen(config.ssl_port, config.listen_address, () =>
    console.log(`Teddit running on https://${config.domain}:${config.ssl_port}`)
  );
}
http.listen(config.nonssl_port, config.listen_address, () =>
  console.log(`Teddit running on http://${config.domain}:${config.nonssl_port}`)
);