const fs = require('fs')
const path = require('path')

const Config = require('sol.enviconfig')({
  commanderOptions: [
    // 命令行里可以接受的参数。将传给 config.js 里的 commander。每个参数的定义格式是 [参数名，参数键，描述]，后两者用于传给commander，取值后覆盖掉Config里的同名变量。
    ['protocol', '-P, --protocol <string>', 'Web Server protocol: http|https|httpall.'],
    ['host', '-H, --host <string>', 'Host IP or domain name, default to localhost.'],
    ['port', '-p, --port <number>', 'HTTP port number.'],
    ['from', '-f, --from <string>', 'Path to serve as website'],
  ],
  // 最基础的必须的默认配置，如果用户什么也没有提供
  protocol: 'http',
  host: 'localhost',
  from: './dist', // local path to serve as webroot
  // 如果使用虚拟主机
  /*
    vhosts: [
      { webroot: 'dist', webindex: 'index.html', domainList: ['']}
    ],
    */
})
if (typeof Config.ssl === 'string') {
  Config.ssl = eval(`(${Config.ssl})`)
}

;(function serve() {
  console.log('★★★★★★★★ Starting Server ★★★★★★★★')

  const express = require('express')
  const server = express()
  const webtoken = require('sol.webtoken')

  /*** 通用中间件 ***/
  server.use(require('morgan')('development' === Config.prodev ? 'dev' : 'combined'))
  server.use(require('body-parser').json())
  server.use(require('body-parser').urlencoded({ extended: false }))
  server.use(require('cookie-parser')())
  server.use(require('compression')())
  const Multer = require('multer')
  server.use(
    Multer({
      //dest:'./File/', // 这样，不能自定义文件名。
      storage: Multer.diskStorage({
        destination: function (req, file, cb) {
          // 如果直接提供字符串，Multer会负责创建该目录。如果提供函数，你要负责确保该目录存在。
          let folder = './upload/' // 目录是相对于本应用的入口js的，即相对于 server.js 的位置。
          cb(null, folder)
        },
        filename: function (req, file, cb) {
          // 注意，req.body 也许还没有信息，因为这取决于客户端发送body和file的顺序。
          let ext = file.originalname.replace(/^.*\.(\w+)$/, '$1')
          let _passtokenSource = webtoken.verifyToken(req.headers._passtoken, Config.tokenKey) || {}
          let filename = `${req.path.replace(/^\/api\d*/, '')}_${_passtokenSource.uuid}_${Date.now()}.${ext}`
          cb(null, filename)
        },
      }),
      //fileFilter:function(req, file, cb) {},
      limits: { fileSize: 10485760 },
    }).single('file')
  )

  /*** 路由 ***/
  // vhost 匹配了域名，就执行；不匹配，就next()
  // express.static 找到了具体文件，就返回；找不到，就next()
  // 所以，如果 vhost匹配了域名，且static找到了文件，就结束了。如果 vhost 匹配了域名，但static找不到文件，就继续往下。
  if (!Config.vhosts) {
    server.use(
      express.static(path.join(process.cwd(), Config.from), {
        index: 'index.html',
      })
    )
    // server.use(require('serve-favicon')(path.join(process.cwd(), 'public', 'favicon.ico')))  // uncomment after placing your favicon in /public
  } else {
    let vhost = require('vhost')
    for (let h of Config.vhosts) {
      for (let domain of h.domainList) {
        server.use(
          vhost(
            domain,
            express.static(path.join(process.cwd(), h.webroot), {
              index: h.webindex,
            })
          )
        )
      }
    }
  }

  /*** 路由 ***/
  //var router = express.Router()
  //router.get('/path', function(req,res) { res.redirect('target') })
  //server.use(router)

  /*** 启动 Web 服务 ***/
  let webServer
  let ipv4 = getMyIp()
  let portHttp = Config.port || 80
  let portHttps = Config.port || 443
  if ('http' === Config.protocol) {
    webServer = require('http')
      .createServer(server)
      .listen(portHttp, function (err) {
        if (err) console.log(err)
        else
          console.log(
            `[${new Date().toJSON()}] Server listening on ${Config.protocol}://${Config.host}:${portHttp} with IPv4=${ipv4} for ${Config.prodev} environment`
          )
      })
  } else if ('https' === Config.protocol) {
    webServer = require('https')
      .createServer(
        {
          key: fs.readFileSync(Config.ssl.file.key),
          cert: fs.readFileSync(Config.ssl.file.cert),
          // ca: [ fs.readFileSync(Config.ssl.file.ca) ] // only for self-signed certificate: https://nodejs.org/api/tls.html#tls_tls_createserver_options_secureconnectionlistener
        },
        server
      )
      .listen(portHttps, function (err) {
        if (err) console.log(err)
        else
          console.log(
            `[${new Date().toJSON()}] Server listening on ${Config.protocol}://${Config.host}:${portHttps} with IPv4=${ipv4} for ${Config.prodev} environment`
          )
      })
  } else if ('httpall' === Config.protocol) {
    portHttp = 80
    require('http')
      .createServer(
        server.all('*', function (ask, reply) {
          reply.redirect(`https://${Config.host}:${portHttps}`)
        })
      )
      .listen(portHttp, function (err) {
        if (err) console.log(err)
        else
          console.log(
            `[${new Date().toJSON()}] Server redirecting from [${Config.protocol}] http://${Config.host}:${portHttp} with IPv4=${ipv4} for ${
              Config.prodev
            } environment`
          )
      })
    webServer = require('https')
      .createServer(
        {
          key: fs.readFileSync(Config.ssl.file.key),
          cert: fs.readFileSync(Config.ssl.file.cert),
          // ca: [ fs.readFileSync(Config.ssl.file.ca) ] // only for self-signed certificate: https://nodejs.org/api/tls.html#tls_tls_createserver_options_secureconnectionlistener
        },
        server
      )
      .listen(portHttps, function (err) {
        if (err) console.log(err)
        else
          console.log(
            `[${new Date().toJSON()}] Server listening on [${Config.protocol}] https://${Config.host}:${portHttps} with IPv4=${ipv4} for ${
              Config.prodev
            } environment`
          )
      })
  } else if ('http2https' === Config.protocol) {
    webServer = require('http')
      .createServer(
        server.all('*', function (ask, reply) {
          /* 错误的API调用进入这里。*/ reply.redirect(`https://${Config.host}`)
        })
      )
      .listen(portHttp, function (err) {
        if (err) console.log(err)
        else
          console.log(
            `[${new Date().toJSON()}] Server listening on ${Config.protocol}://${Config.host}:${portHttp} with IPv4=${ipv4} for ${Config.prodev} environment`
          )
      })
  }

  return webServer
})()

// ====================

function getMyIp() {
  const os = require('os')
  let ipv4 = null
  try {
    let ifaces = os.networkInterfaces()
    Object.keys(ifaces).forEach(function (ifname) {
      ifaces[ifname].forEach(function (iface) {
        if ('IPv4' === iface.family && iface.internal === false) {
          //            console.log('ip='+iface.address)
          ipv4 = iface.address
        }
      })
    })
  } catch (e) {
    console.log('ERROR in getMyIP(): ' + e.message)
  }
  return ipv4
}