const fs = require('fs');
const path = require('path');
const express = require('express');
const bodyParser = require('body-parser');
const request = require('./util/request');
const packageJSON = require('./package.json');
const exec = require('child_process').exec;
const cache = require('./util/apicache').middleware;
const { cookieToJson } = require('./util/index');
const fileUpload = require('express-fileupload');
// version check
exec('npm info NeteaseCloudMusicApi version', (err, stdout, stderr) => {
  if (!err) {
    let version = stdout.trim();
    if (packageJSON.version < version) {
      console.log(
        `最新版本: ${version}, 当前版本: ${packageJSON.version}, 请及时更新`,
      );
    }
  }
});

const app = express();

// CORS & Preflight request
app.use((req, res, next) => {
  if (req.path !== '/' && !req.path.includes('.')) {
    res.set({
      'Access-Control-Allow-Credentials': true,
      'Access-Control-Allow-Origin': req.headers.origin || '*',
      'Access-Control-Allow-Headers': 'X-Requested-With,Content-Type',
      'Access-Control-Allow-Methods': 'PUT,POST,GET,DELETE,OPTIONS',
      'Content-Type': 'application/json; charset=utf-8',
    });
  }
  req.method === 'OPTIONS' ? res.status(204).end() : next();
});

// cookie parser
app.use((req, res, next) => {
  req.cookies = {};
  (req.headers.cookie || '').split(/\s*;\s*/).forEach((pair) => {
    let crack = pair.indexOf('=');
    if (crack < 1 || crack == pair.length - 1) return;
    req.cookies[
      decodeURIComponent(pair.slice(0, crack)).trim()
    ] = decodeURIComponent(pair.slice(crack + 1)).trim();
  });
  next();
});

// body parser
app.use(bodyParser.json());
app.use(bodyParser.urlencoded({ extended: false }));

app.use(fileUpload());

// static
app.use(express.static(path.join(__dirname, 'public')));

// cache
app.use(cache('2 minutes', (req, res) => res.statusCode === 200));
// router
const special = {
  'daily_signin.js': '/daily_signin',
  'fm_trash.js': '/fm_trash',
  'personal_fm.js': '/personal_fm',
};

fs.readdirSync(path.join(__dirname, 'module'))
  .reverse()
  .forEach((file) => {
    if (!file.endsWith('.js')) return;
    let route =
      file in special
        ? special[file]
        : '/' + file.replace(/\.js$/i, '').replace(/_/g, '/');
    let question = require(path.join(__dirname, 'module', file));

    app.use(route, (req, res) => {
      if (typeof req.query.cookie === 'string') {
        req.query.cookie = cookieToJson(req.query.cookie);
      }
      let query = Object.assign(
        {},
        { cookie: req.cookies },
        req.query,
        req.body,
        req.files,
      );

      question(query, request)
        .then((answer) => {
          console.log('[OK]', decodeURIComponent(req.originalUrl));
          res.append('Set-Cookie', answer.cookie);
          res.status(answer.status).send(answer.body);
        })
        .catch((answer) => {
          console.log('[ERR]', decodeURIComponent(req.originalUrl), {
            status: answer.status,
            body: answer.body,
          });
          if (answer.body.code == '301') answer.body.msg = '需要登录';
          res.append('Set-Cookie', answer.cookie);
          res.status(answer.status).send(answer.body);
        });
    });
  });

const port = process.env.PORT || 3000;
const host = process.env.HOST || '';

app.server = app.listen(port, host, () => {
  console.log(`server running @ http://${host ? host : 'localhost'}:${port}`);
});

module.exports = app;