Comunic/comunicapiv2
1
0
Fork 0
mirror of https://gitlab.com/comunic/comunicapiv2 synced 2024-11-22 05:19:22 +00:00
Code Issues Projects Releases Wiki Activity

Simplify main.ts

Browse Source
This commit is contained in:
Pierre HUBERT 2020-05-25 18:14:46 +02:00
parent 1198e28696
commit e4ca702af8
2 changed files with 98 additions and 90 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

91
src/main.ts
View File

@ -1,11 +1,6 @@
import * as express from 'express'; import { ConfigurationHelper } from "./helpers/ConfigHelper";
import { ConfigurationHelper, conf } from "./helpers/ConfigHelper";
import { DatabaseHelper } from "./helpers/DatabaseHelper"; import { DatabaseHelper } from "./helpers/DatabaseHelper";
import { Routes, RouteType } from './controllers/Routes'; import { startServer } from "./server";
import { RequestHandler } from './entities/RequestHandler';
import * as fileUpload from 'express-fileupload';
import * as expressWs from 'express-ws';
import * as ws from 'ws';
/** /**
* Main project script * Main project script
@ -28,85 +23,3 @@ async function init() {
await startServer(); await startServer();
} }
init(); init();
/**
* Run the server
*/
async function startServer() {
// Start HTTP Server
const app = expressWs(express()).app;
app.use(express.urlencoded({extended: true}));
app.use(fileUpload());
// Check if the server is running behing a proxy
if(conf().proxy) {
console.info("Running behind proxy: " + conf().proxy);
app.set("trust proxy", conf().proxy);
}
// Process the list of routes
Routes.forEach(route => {
// Callback is common to all requests type
const cb = async (req : express.Request, res : express.Response)=> {
const handler = new RequestHandler(req, res);
try {
// Check API tokens
await handler.checkAPITokens();
// Check user tokens
await handler.checkUserTokens(route.needLogin);
const cb = route.cb(handler);
if(cb)
await cb;
} catch(e) {
console.error(e);
// Send a response to the server, if it has not
// been done yet
if(!handler.sentResponse)
res.status(500).send({
error: {
code: 500,
message: "Internal error"
}
})
}
};
// WebSocket callback
const wsCB = async (ws: ws, req: express.Request) => {
try {
await route.wsCallback(req, ws);
} catch(e) {
console.error(e);
}
}
// Call the appropriate function
switch(route.type) {
case RouteType.GET:
app.get(route.path, cb);
break;
case RouteType.WS:
app.ws(route.path, wsCB);
break;
default:
app.post(route.path, cb);
break;
}
})
app.listen(conf().port, () => {
console.info("Started server on http://127.0.0.1:" + conf().port);
});
}

95
src/server.ts Normal file
View File

@ -0,0 +1,95 @@
import * as express from 'express';
import { conf } from "./helpers/ConfigHelper";
import { Routes, RouteType } from './controllers/Routes';
import { RequestHandler } from './entities/RequestHandler';
import * as fileUpload from 'express-fileupload';
import * as expressWs from 'express-ws';
import * as ws from 'ws';
/**
* Main Comunic server
*
* @author Pierre Hubert
*/
/**
* Run the server
*/
export async function startServer() {
// Start HTTP Server
const app = expressWs(express()).app;
app.use(express.urlencoded({extended: true}));
app.use(fileUpload());
// Check if the server is running behing a proxy
if(conf().proxy) {
console.info("Running behind proxy: " + conf().proxy);
app.set("trust proxy", conf().proxy);
}
// Process the list of routes
Routes.forEach(route => {
// Callback is common to all requests type
const cb = async (req : express.Request, res : express.Response)=> {
const handler = new RequestHandler(req, res);
try {
// Check API tokens
await handler.checkAPITokens();
// Check user tokens
await handler.checkUserTokens(route.needLogin);
const cb = route.cb(handler);
if(cb)
await cb;
} catch(e) {
console.error(e);
// Send a response to the server, if it has not
// been done yet
if(!handler.sentResponse)
res.status(500).send({
error: {
code: 500,
message: "Internal error"
}
})
}
};
// WebSocket callback
const wsCB = async (ws: ws, req: express.Request) => {
try {
await route.wsCallback(req, ws);
} catch(e) {
console.error(e);
}
}
// Call the appropriate function
switch(route.type) {
case RouteType.GET:
app.get(route.path, cb);
break;
case RouteType.WS:
app.ws(route.path, wsCB);
break;
default:
app.post(route.path, cb);
break;
}
})
app.listen(conf().port, () => {
console.info("Started server on http://127.0.0.1:" + conf().port);
});
}