2019-12-31 10:50:19 -05:00
|
|
|
import http from 'http'
|
|
|
|
import routers from './routerManager'
|
|
|
|
import {
|
|
|
|
handleResponse
|
|
|
|
} from './utils'
|
|
|
|
|
|
|
|
class Server {
|
|
|
|
private httpServer: http.Server
|
|
|
|
private port: number = 36677
|
|
|
|
constructor () {
|
|
|
|
this.httpServer = http.createServer(this.handleRequest)
|
|
|
|
}
|
|
|
|
private handleRequest = (request: http.IncomingMessage, response: http.ServerResponse) => {
|
|
|
|
if (request.method === 'POST') {
|
|
|
|
if (!routers.getHandler(request.url!)) {
|
|
|
|
handleResponse({
|
|
|
|
response,
|
|
|
|
statusCode: 404,
|
|
|
|
header: {},
|
|
|
|
body: {
|
|
|
|
success: false
|
|
|
|
}
|
|
|
|
})
|
|
|
|
} else {
|
|
|
|
let body: string = ''
|
|
|
|
let postObj: IObj
|
|
|
|
request.on('data', chunk => {
|
|
|
|
body += chunk
|
|
|
|
})
|
|
|
|
request.on('end', () => {
|
|
|
|
try {
|
2019-12-31 11:06:48 -05:00
|
|
|
postObj = (body === '') ? {} : JSON.parse(body)
|
2019-12-31 10:50:19 -05:00
|
|
|
} catch (err) {
|
|
|
|
return handleResponse({
|
|
|
|
response,
|
|
|
|
body: {
|
|
|
|
success: false,
|
|
|
|
message: 'Not sending data in JSON format'
|
|
|
|
}
|
|
|
|
})
|
|
|
|
}
|
|
|
|
const handler = routers.getHandler(request.url!)
|
|
|
|
handler!({
|
|
|
|
...postObj,
|
|
|
|
response
|
|
|
|
})
|
|
|
|
})
|
|
|
|
}
|
|
|
|
} else {
|
|
|
|
response.statusCode = 404
|
|
|
|
response.end()
|
|
|
|
}
|
|
|
|
}
|
|
|
|
private listen = (port: number) => {
|
|
|
|
console.log(`server listen at ${port}`)
|
2019-12-31 11:06:48 -05:00
|
|
|
this.httpServer.listen(port, '0.0.0.0').on('error', (err: ErrnoException) => {
|
2019-12-31 10:50:19 -05:00
|
|
|
if (err.errno === 'EADDRINUSE') {
|
|
|
|
console.log(`----- Port ${port} is busy, trying with port ${port + 1} -----`)
|
|
|
|
this.port += 1
|
|
|
|
this.listen(this.port)
|
|
|
|
}
|
|
|
|
})
|
|
|
|
}
|
|
|
|
startup () {
|
|
|
|
this.listen(this.port)
|
|
|
|
}
|
|
|
|
shutdown () {
|
|
|
|
this.httpServer.close()
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
export default new Server()
|