npm/wo-base-webserver
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

u

Browse Source
This commit is contained in:
陆柯 2021-06-19 22:00:33 +08:00
parent 9a76d044d8
commit 6cc40dda52
2 changed files with 95 additions and 70 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
package.json
View File

@ -11,11 +11,13 @@
"deepmerge": "^2.1.1", "deepmerge": "^2.1.1",
"errorhandler": "^1.5.0", "errorhandler": "^1.5.0",
"express": "^4.16.2", "express": "^4.16.2",
"http-proxy": "^1.17.0",
"method-override": "^2.3.10", "method-override": "^2.3.10",
"morgan": "^1.9.0", "morgan": "^1.9.0",
"multer": "^1.4.2", "multer": "^1.4.2",
"serve-favicon": "^2.5.0", "serve-favicon": "^2.5.0",
"sol.enviconfig": "git+https://git.faronear.org/npm/sol.enviconfig", "sol.enviconfig": "git+https://git.faronear.org/npm/sol.enviconfig",
"sol.tool": "git+https://git.faronear.org/npm/sol.tool",
"sol.webtoken": "git+https://git.faronear.org/npm/sol.webtoken", "sol.webtoken": "git+https://git.faronear.org/npm/sol.webtoken",
"vhost": "^3.0.2" "vhost": "^3.0.2"
}, },

163
server.js
View File

@ -1,38 +1,54 @@
const fs = require('fs') const fs = require('fs')
const path = require('path') const path = require('path')
const tool = require('sol.tool')
const webtoken = require('sol.webtoken')
const express = require('express')
const Config = require('sol.enviconfig')({ const wo = (global.wo = {
commanderOptions: [ envi : require('sol.enviconfig')({
// 命令行里可以接受的参数。将传给 config.js 里的 commander。每个参数的定义格式是 [参数名，参数键，描述]，后两者用于传给commander，取值后覆盖掉Config里的同名变量。 commanderOptions: [
['protocol', '-P, --protocol <string>', 'Web Server protocol: http|https|httpall.'], // 命令行里可以接受的参数。将传给 config.js 里的 commander。每个参数的定义格式是 [参数名，参数键，描述]，后两者用于传给commander，取值后覆盖掉Config里的同名变量。
['host', '-H, --host <string>', 'Host IP or domain name, default to localhost.'], ['protocol', '-P, --protocol <string>', 'Web Server protocol: http|https|httpall.'],
['port', '-p, --port <number>', 'HTTP port number.'], ['host', '-H, --host <string>', 'Host IP or domain name, default to localhost.'],
['from', '-f, --from <string>', 'Path to serve as website'], ['port', '-p, --port <number>', 'HTTP port number.'],
], ['from', '-f, --from <string>', 'Path to serve as website'],
// 最基础的必须的默认配置，如果用户什么也没有提供 ['ssl', '--ssl <string>', 'SSL options in JSON string.'],
protocol: 'http',
host: 'localhost',
from: './dist', // local path to serve as webroot
// 如果使用虚拟主机
/*
vhosts: [
{ webroot: 'dist', webindex: 'index.html', domainList: ['']}
], ],
*/ // 最基础的必须的默认配置，如果用户什么也没有提供
protocol: 'http',
host: 'localhost',
from: './dist', // local path to serve as webroot
// 如果使用虚拟主机
/*
vhosts: [
{ webroot: 'dist', webindex: 'index.html', domainList: ['']}
],
*/
})
}) })
if (typeof Config.ssl === 'string') { if (typeof wo.envi.ssl === 'string') {
Config.ssl = eval(`(${Config.ssl})`) wo.envi.ssl = eval(`(${wo.envi.ssl})`)
} }
;(function serve() { ;(function serve() {
console.log('★★★★★★★★ Starting Server ★★★★★★★★') console.log('★★★★★★★★ Starting Server ★★★★★★★★')
const express = require('express')
const server = express() const server = express()
const webtoken = require('sol.webtoken')
// 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' === Config.prodev ? 'dev' : 'combined')) server.use(require('morgan')('development' === wo.envi.prodev ? 'dev' : 'combined'))
server.use(require('body-parser').json()) server.use(require('body-parser').json())
server.use(require('body-parser').urlencoded({ extended: false })) server.use(require('body-parser').urlencoded({ extended: false }))
server.use(require('cookie-parser')()) server.use(require('cookie-parser')())
@ -50,7 +66,7 @@ if (typeof Config.ssl === 'string') {
filename: function (req, file, cb) { filename: function (req, file, cb) {
// 注意，req.body 也许还没有信息，因为这取决于客户端发送body和file的顺序。 // 注意，req.body 也许还没有信息，因为这取决于客户端发送body和file的顺序。
let ext = file.originalname.replace(/^.*\.(\w+)$/, '$1') let ext = file.originalname.replace(/^.*\.(\w+)$/, '$1')
let _passtokenSource = webtoken.verifyToken(req.headers._passtoken, Config.tokenKey) || {} let _passtokenSource = webtoken.verifyToken(req.headers._passtoken, wo.envi.tokenKey) || {}
let filename = `${req.path.replace(/^\/api\d*/, '')}_${_passtokenSource.uuid}_${Date.now()}.${ext}` let filename = `${req.path.replace(/^\/api\d*/, '')}_${_passtokenSource.uuid}_${Date.now()}.${ext}`
cb(null, filename) cb(null, filename)
}, },
@ -64,16 +80,16 @@ if (typeof Config.ssl === 'string') {
// vhost 匹配了域名，就执行；不匹配，就next() // vhost 匹配了域名，就执行；不匹配，就next()
// express.static 找到了具体文件，就返回；找不到，就next() // express.static 找到了具体文件，就返回；找不到，就next()
// 所以，如果 vhost匹配了域名，且static找到了文件，就结束了。如果 vhost 匹配了域名，但static找不到文件，就继续往下。 // 所以，如果 vhost匹配了域名，且static找到了文件，就结束了。如果 vhost 匹配了域名，但static找不到文件，就继续往下。
if (!Config.vhosts) { if (!wo.envi.vhosts) {
server.use( server.use(
express.static(path.join(process.cwd(), Config.from), { express.static(path.join(process.cwd(), wo.envi.from), {
index: 'index.html', index: 'index.html',
}) })
) )
// server.use(require('serve-favicon')(path.join(process.cwd(), 'public', 'favicon.ico'))) // uncomment after placing your favicon in /public // server.use(require('serve-favicon')(path.join(process.cwd(), 'public', 'favicon.ico'))) // uncomment after placing your favicon in /public
} else { } else {
let vhost = require('vhost') let vhost = require('vhost')
for (let h of Config.vhosts) { for (let h of wo.envi.vhosts) {
for (let domain of h.domainList) { for (let domain of h.domainList) {
server.use( server.use(
vhost( vhost(
@ -94,26 +110,27 @@ if (typeof Config.ssl === 'string') {
/*** 启动 Web 服务 ***/ /*** 启动 Web 服务 ***/
let webServer let webServer
let ipv4 = getMyIp() let ipv4 = tool.getMyIp()
let portHttp = Config.port || 80 let portHttp = wo.envi.port || 80
let portHttps = Config.port || 443 let portHttps = wo.envi.port || 443
if ('http' === Config.protocol) { if ('http' === wo.envi.protocol) {
webServer = require('http') webServer = require('http')
.createServer(server) .createServer(server)
.listen(portHttp, function (err) { .listen(portHttp, function (err) {
if (err) console.log(err) if (err) console.log(err)
else else
console.log( console.log(
`[${new Date().toJSON()}] Server listening on ${Config.protocol}://${Config.host}:${portHttp} with IPv4=${ipv4} for ${Config.prodev} environment` `[${new Date().toJSON()}] Server listening on ${wo.envi.protocol}://${wo.envi.host}:${portHttp} with IPv4=${ipv4} for ${wo.envi.prodev} environment`
) )
}) })
} else if ('https' === Config.protocol) { } else if ('https' === wo.envi.protocol) {
webServer = require('https') webServer = require('https')
.createServer( .createServer(
// wo.wo.envi.ssl.type==='greenlock' ? greenlock.httpsOptions :
{ {
key: fs.readFileSync(Config.ssl.file.key), key: fs.readFileSync(wo.envi.ssl.file.key),
cert: fs.readFileSync(Config.ssl.file.cert), cert: fs.readFileSync(wo.envi.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 // 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 server
) )
@ -121,32 +138,38 @@ if (typeof Config.ssl === 'string') {
if (err) console.log(err) if (err) console.log(err)
else else
console.log( console.log(
`[${new Date().toJSON()}] Server listening on ${Config.protocol}://${Config.host}:${portHttps} with IPv4=${ipv4} for ${Config.prodev} environment` `[${new Date().toJSON()}] Server listening on ${wo.envi.protocol}://${wo.envi.host}:${portHttps} with IPv4=${ipv4} for ${wo.envi.prodev} environment`
) )
}) })
} else if ('httpall' === Config.protocol) { } else if ('httpall' === wo.envi.protocol) {
portHttp = 80 portHttp = 80
require('http') // if (wo.wo.envi.ssl.type==='greenlock') {
// greenlock.listen(portHttp, portHttps, function (err) {
// if (err) console.log(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( .createServer(
server.all('*', function (ask, reply) { server.all('*', function (ask, reply) {
reply.redirect(`https://${Config.host}:${portHttps}`) reply.redirect(`https://${wo.envi.host}:${portHttps}`)
}) })
) )
.listen(portHttp, function (err) { .listen(portHttp, function (err) {
if (err) console.log(err) if (err) console.log(err)
else else
console.log( console.log(
`[${new Date().toJSON()}] Server redirecting from [${Config.protocol}] http://${Config.host}:${portHttp} with IPv4=${ipv4} for ${ `[${new Date().toJSON()}] Server redirecting from [${wo.envi.protocol}] http://${wo.envi.host}:${portHttp} with IPv4=${ipv4} for ${
Config.prodev wo.envi.prodev
} environment` } environment`
) )
}) })
webServer = require('https') webServer = require('https')
.createServer( .createServer(
{ {
key: fs.readFileSync(Config.ssl.file.key), key: fs.readFileSync(wo.envi.ssl.file.key),
cert: fs.readFileSync(Config.ssl.file.cert), cert: fs.readFileSync(wo.envi.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 // 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 server
) )
@ -154,47 +177,47 @@ if (typeof Config.ssl === 'string') {
if (err) console.log(err) if (err) console.log(err)
else else
console.log( console.log(
`[${new Date().toJSON()}] Server listening on [${Config.protocol}] https://${Config.host}:${portHttps} with IPv4=${ipv4} for ${ `[${new Date().toJSON()}] Server listening on [${wo.envi.protocol}] https://${wo.envi.host}:${portHttps} with IPv4=${ipv4} for ${
Config.prodev wo.envi.prodev
} environment` } environment`
) )
}) })
} else if ('http2https' === Config.protocol) { // }
} else if ('http2https' === wo.envi.protocol) {
webServer = require('http') webServer = require('http')
.createServer( .createServer(
server.all('*', function (ask, reply) { server.all('*', function (ask, reply) {
/* 错误的API调用进入这里。*/ reply.redirect(`https://${Config.host}`) reply.redirect(`https://${wo.envi.host}`)
}) })
// 或者 require('redirect-https')() // https://www.npmjs.com/package/redirect-https
) )
.listen(portHttp, function (err) { .listen(portHttp, function (err) {
if (err) console.log(err) if (err) console.log(err)
else else
console.log( console.log(
`[${new Date().toJSON()}] Server listening on ${Config.protocol}://${Config.host}:${portHttp} with IPv4=${ipv4} for ${Config.prodev} environment` `[${new Date().toJSON()}] Server listening on ${wo.envi.protocol}://${wo.envi.host}:${portHttp} with IPv4=${ipv4} for ${wo.envi.prodev} environment`
) )
}) })
}else if ('proxy' === wo.envi.protocol) {
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:${wo.envi.proxyPort}`, // 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.')
})
wo.envi.port=443
proxy.listen(wo.envi.port)
console.info('server listening on %s://%s:%d as proxy', wo.envi.protocol, wo.envi.host, wo.envi.port)
} }
return webServer 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
}