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

const wo = (global.wo = { 
  envi : require('base.enviconfig').mergeConfig({
    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.'],
      ['port', '-p, --port <number>', 'HTTP port number.'],
      ['webroot', '-w, --webroot <string>', 'Path to serve as website.'],
      ['ssl', '--ssl <string>', 'SSL options in JSON string.'],
    ],
    // 最基础的必须的默认配置，如果用户什么也没有提供
    protocol: 'http',
    host: 'localhost',
    webroot: 'webroot', // local path to serve as webroot
    webindex: 'index.html',
    // 如果使用虚拟主机
    /*
      vhosts: [
        { webroot: 'dist', webindex: 'index.html', domainList: ['']}
      ],
      */
  })
})
if (typeof wo.envi.ssl === 'string') {
  wo.envi.ssl = eval(`(${wo.envi.ssl})`)
}

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

  const server = express()

// const greenlock = require('greenlock-express').create({
//   version: 'draft-11',
//   server: 'https://acme-v02.api.letsencrypt.org/directory', // for test: acme-staging-v02
//   agreeTos: true,
//   communityMember: false,
//   store: require('greenlock-store-fs'),
//   email: 'ssl@faronear.org',
//   approvedDomains: wo.wo.envi.sslDomains,
//   configDir: path.resolve(__dirname, 'ssl'),
//   app: server,
// })

  /*** 通用中间件 ***/
  server.use(require('morgan')('development' === wo.envi.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')())

  /*** 路由 ***/
  // vhost 匹配了域名，就执行；不匹配，就next()
  // express.static 找到了具体文件，就返回；找不到，就next()
  // 所以，如果 vhost匹配了域名，且static找到了文件，就结束了。如果 vhost 匹配了域名，但static找不到文件，就继续往下。
  if (!wo.envi.vhosts) {
    server.use(
      express.static(path.join(process.cwd(), wo.envi.webroot).replace('\\', '/'), { index: wo.envi.webindex }) // 可以指定到 node应用之外的目录上。windows里要把 \ 换成 /。
    )
    //server.use(require('serve-favicon')(path.join(process.cwd(), wo.envi.webroot, 'favicon.ico')))
} else {
    let vhost = require('vhost')
    for (let h of wo.envi.vhosts) {
      for (let domain of h.domainList) {
        server.use(
          vhost(
            domain,
            express.static(path.join(process.cwd(), h.webroot).replace('\\', '/'), { index: h.webindex }) // 可以指定到 node应用之外的目录上。windows里要把 \ 换成 /。
          )
        )
      }
    }
  }

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

  /*** 启动 Web 服务 ***/
  let webServer
  if ('http' === wo.envi.protocol) {
    let portHttp = wo.envi.port || 80
    webServer = require('http')
      .createServer(server)
      .listen(portHttp, function (err) {
        if (err) { 
          console.error(err) 
        } else {
          console.log({time: new Date().toJSON()},
            `Server listening on ${wo.envi.protocol}://${wo.envi.host}:${portHttp} for ${wo.envi.prodev} environment`
          )
        }
      })
  } else if ('https' === wo.envi.protocol) {
    let portHttps = wo.envi.port || 443
    webServer = require('https')
      .createServer(
//        wo.wo.envi.ssl.type==='greenlock' ? greenlock.httpsOptions : 
        {
          key: fs.readFileSync(wo.envi.ssl.file.key),
          cert: fs.readFileSync(wo.envi.ssl.file.cert),
          // ca: [ fs.readFileSync(wo.envi.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.error(err)
        } else {
          console.log({time: new Date().toJSON()},
            `Server listening on ${wo.envi.protocol}://${wo.envi.host}:${portHttps} for ${wo.envi.prodev} environment`
          )
        }
      })
  } else if ('httpall' === wo.envi.protocol) {
    let portHttp = wo.envi.port?.portHttp || 80
    let portHttps = wo.envi.port?.portHttps || 443
//    if (wo.wo.envi.ssl.type==='greenlock') {
//      greenlock.listen(portHttp, portHttps, function (err) {
//        if (err) console.error(err)
//        else console.log(`Server listening on [${wo.wo.envi.protocol}] http=>https://${wo.wo.envi.host}:${portHttp}=>${portHttps} for ${server.settings.env} environment`)
//      })
//    }else {
    require('http')
    .createServer(function (ask, reply) {
        reply.writeHead(301, { Location: `https://${ask.headers.host.replace(`:${portHttp}`, `:${portHttps}`)}${ask.url}` })
        reply.end()
      }
    )
    .listen(portHttp, function (err) {
      if (err) {
        console.error(err)
      } else {
        console.log({time: new Date().toJSON()},
          `Server redirecting from http://${wo.envi.host}:${portHttp} for ${
            wo.envi.prodev
          } environment`
        )
      }
    })
    webServer = require('https')
      .createServer(
        {
          key: fs.readFileSync(wo.envi.ssl.file.key),
          cert: fs.readFileSync(wo.envi.ssl.file.cert),
          // ca: [ fs.readFileSync(wo.envi.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.error(err)
        } else {
          console.log({time: new Date().toJSON()},
            `Server listening on https://${wo.envi.host}:${portHttps} for ${
              wo.envi.prodev
            } environment`
          )
        }
      })
//    }
  } else if ('redirectHttp2Https' === wo.envi.protocol) {
    let portHttp = wo.envi.port?.portHttp || 80
    let portHttps = wo.envi.port?.portHttps || 443
    webServer = server.all('*', function (ask, reply) {
      reply.redirect(301, `https://${ask.headers.host.replace(`:${portHttp}`, `:${portHttps}`)}${ask.url}`)
    })
    .listen(portHttp, function (err) {
      if (err) {
        console.error(err)
      } else {
        console.log({time: new Date().toJSON()},
          `Server listening on ${wo.envi.protocol}://${wo.envi.host}:${portHttp} for ${wo.envi.prodev} environment`
        )
      }
    })
  }else if ('proxyHttps2Http' === wo.envi.protocol) {
    let portHttp = wo.envi.port?.portHttp || 80
    let portHttps = wo.envi.port?.portHttps || 443
    var proxy=require('http-proxy').createProxyServer({
      ssl: {
        key: fs.readFileSync(wo.envi.ssl.file.key),
        cert: fs.readFileSync(wo.envi.ssl.file.cert),
        // ca: [ fs.readFileSync(wo.envi.sslCA) ] // https://nodejs.org/api/tls.html#tls_tls_createserver_options_secureconnectionlistener
      },
      target: `http://127.0.0.1:${portHttp}`, // iOS 的 AppStore 要求支持IPv6，只能用国外的vultr.com服务器，因此再代理回国内的solet主机。
//      secure: true, // proxying https to https
      ws: true // proxying websockets
    })
    proxy.on('error', function (err, req, res) {
      res.writeHead(500, {   'Content-Type': 'text/plain' })
      res.end('Proxy Error.')
    })
    proxy.listen(portHttps, function (err) {
      if (err) {
        console.error(err)
      } else { 
        console.log({time: new Date().toJSON()},
          `Server listening on ${wo.envi.protocol}://${wo.envi.host}:${portHttps} for ${wo.envi.prodev} environment`
        )
      }
    })
  }


  return webServer
})()