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

const Config = require('so.base/Config.js')
if (!Config || Object.keys(Config).length===0) {
  Config = { // 默认配置，如果用户什么也没有提供
    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('so.base/Webtoken')
  const greenlock = (Config.ssl && Config.ssl.type==='greenlock') 
     ? require('greenlock-express').create(Object.assign(Config.ssl.greenlockOptions, {app: server}))
     : null

  /*** 通用中间件 ***/
  server.use(require('morgan')('development'===server.get('env')?'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 ${server.settings.env} environment`)
    })
  } else if ('https' === Config.protocol) {
    webServer = require('https').createServer(Config.ssl.type === 'greenlock' ? greenlock.httpsOptions : {
      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 ${server.settings.env} environment`)
    })
  } else if ('httpall' === Config.protocol) {
    portHttp = 80
    if (Config.ssl.type === 'greenlock') {
      webServer = greenlock.listen(portHttp, portHttps, function (err) {
        if (err) console.log(err)
        else console.log(`[${new Date().toJSON()}] Server listening on [${Config.protocol}] http=>https://${Config.host}:${portHttp}=>${portHttps} with IPv4=${ipv4} for ${server.settings.env} environment`)
      })
    } else {
      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 ${server.settings.env} 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 ${server.settings.env} 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 ${server.settings.env} 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
}