mirror of
https://github.com/ragestudio/linebridge.git
synced 2025-06-09 10:34:17 +00:00
Support multiple http engines
This commit is contained in:
parent
869c0dcf36
commit
aaf104a5d4
@ -1,7 +1,6 @@
|
|||||||
const fs = require("fs")
|
const fs = require("fs")
|
||||||
const path = require("path")
|
const path = require("path")
|
||||||
|
|
||||||
const HyperExpress = require("hyper-express")
|
|
||||||
const io = require("socket.io")
|
const io = require("socket.io")
|
||||||
|
|
||||||
const tokenizer = require("corenode/libs/tokenizer")
|
const tokenizer = require("corenode/libs/tokenizer")
|
||||||
@ -9,6 +8,20 @@ const { randomWord } = require("@corenode/utils")
|
|||||||
|
|
||||||
const { serverManifest, outputServerError } = require("./lib")
|
const { serverManifest, outputServerError } = require("./lib")
|
||||||
|
|
||||||
|
const HTTPEngines = {
|
||||||
|
"hyper-express": () => {
|
||||||
|
const engine = require("hyper-express")
|
||||||
|
return new engine.Server()
|
||||||
|
},
|
||||||
|
"nano-express": () => {
|
||||||
|
// fix delete http method
|
||||||
|
global.FIXED_HTTP_METHODS["del"] = "del"
|
||||||
|
global.FIXED_HTTP_METHODS["delete"] = "del"
|
||||||
|
|
||||||
|
return require("nanoexpress")()
|
||||||
|
},
|
||||||
|
}
|
||||||
|
|
||||||
class Server {
|
class Server {
|
||||||
constructor(params = {}, controllers = [], middlewares = {}) {
|
constructor(params = {}, controllers = [], middlewares = {}) {
|
||||||
this.params = {
|
this.params = {
|
||||||
@ -35,7 +48,7 @@ class Server {
|
|||||||
this.WSAddress = `ws://${global.LOCALHOST_ADDRESS}:${this.WSListenPort}`
|
this.WSAddress = `ws://${global.LOCALHOST_ADDRESS}:${this.WSListenPort}`
|
||||||
|
|
||||||
//* set server basics
|
//* set server basics
|
||||||
this.httpInterface = global.httpInterface = new HyperExpress.Server()
|
this.httpInterface = global.httpInterface = HTTPEngines[this.params.httpEngine]()
|
||||||
this.wsInterface = global.wsInterface = {
|
this.wsInterface = global.wsInterface = {
|
||||||
io: new io.Server(this.WSListenPort),
|
io: new io.Server(this.WSListenPort),
|
||||||
map: {},
|
map: {},
|
||||||
@ -77,10 +90,10 @@ class Server {
|
|||||||
req.query = {}
|
req.query = {}
|
||||||
}
|
}
|
||||||
|
|
||||||
// if server has enabled urlencoded parser, parse the body
|
// // if server has enabled urlencoded parser, parse the body
|
||||||
if (this.params.urlencoded) {
|
// if (this.params.urlencoded) {
|
||||||
req.body = await req.urlencoded()
|
// req.body = await req.urlencoded()
|
||||||
}
|
// }
|
||||||
})
|
})
|
||||||
|
|
||||||
return this
|
return this
|
||||||
|
Loading…
x
Reference in New Issue
Block a user