sc-manager/api/server.mjs

88 lines
2.1 KiB
JavaScript
Raw Normal View History

import path from 'path'
import fs from 'fs/promises'
2020-09-08 07:53:42 +00:00
import socket from 'socket.io-serveronly'
import { Flaska, FileResponse } from 'flaska'
import coremonitor from './core/coremonitor.mjs'
import * as routes from './core/routes.mjs'
2020-09-08 07:53:42 +00:00
import onConnection from './routerio.mjs'
export function run(http, port, orgCtx) {
let localUtil = new orgCtx.sc.Util(import.meta.url)
const staticRoot = localUtil.getPathFromRoot('../public')
2020-09-08 07:53:42 +00:00
const flaska = new Flaska({
log: orgCtx.log,
}, http)
2020-09-08 07:53:42 +00:00
flaska.before(function(ctx) {
ctx.core = orgCtx.core
ctx.state.started = new Date().getTime()
})
2020-09-08 07:53:42 +00:00
flaska.onreqerror(function(err, ctx) {
if (ctx.aborted) {
flaska.log.info('Request aborted')
} else {
flaska.log.error(err)
}
})
2020-09-08 07:53:42 +00:00
flaska.after(function(ctx) {
let ended = new Date().getTime()
var requestTime = ended - ctx.state.started
2020-09-08 07:53:42 +00:00
let status = ''
let level = 'debug'
if (ctx.status >= 400) {
status = ctx.status + ' '
level = 'warn'
}
if (ctx.status >= 500) {
level = 'error'
}
2020-09-08 07:53:42 +00:00
ctx.log[level]({
duration: requestTime,
status: ctx.status,
}, `<-- ${status}${ctx.method} ${ctx.url}`)
})
2020-09-08 07:53:42 +00:00
flaska.on404(function(ctx) {
if (ctx.method !== 'GET' && ctx.method !== 'HEAD') {
ctx.status = 404
ctx.body = {
status: 404,
message: 'Not Found',
}
return
}
let file = path.resolve(path.join(staticRoot, ctx.url === '/' ? 'index.html' : ctx.url))
if (!file.startsWith(staticRoot)) {
ctx.status = 404
ctx.body = 'HTTP 404 Error'
return
}
2020-09-08 07:53:42 +00:00
return fs.stat(file).then(function(stat) {
if (!stat) {
ctx.status = 404
ctx.body = 'HTTP 404 Error'
return
}
ctx.body = new FileResponse(file, stat)
})
})
2020-09-08 07:53:42 +00:00
flaska.post('/update/:name', routes.updateApp)
return flaska.listenAsync(port).then(function() {
orgCtx.log.info('Server is listening on port ' + port)
2020-09-08 07:53:42 +00:00
const io = new socket(flaska.server)
io.on('connection', onConnection.bind(this, io, orgCtx))
coremonitor(io, orgCtx)
})
2020-09-08 07:53:42 +00:00
}