This repository has been archived on 2025-12-25. You can view files and clone it. You cannot open issues or pull requests or push a commit.
Files
qmi-cloud/server/server.js
Manuel Romero ad9436f630 refactor
2019-12-12 18:15:24 +01:00

129 lines
3.7 KiB
JavaScript

const url = require("url");
const express = require("express");
import Arena from 'bull-arena';
import { TF_APPLY_QUEUE, TF_APPLY_QSEOK_QUEUE, TF_DESTROY_QUEUE } from './queues';
const app = express();
const routesApiScenarios = require('./routes/api-scenarios');
const routesApiUsers = require('./routes/api-users');
const routesApiProvisions = require('./routes/api-provisions');
const routesApiDestroyProvisions = require('./routes/api-destroyprovisions');
const swaggerUi = require('swagger-ui-express');
const swaggerJsdoc = require('swagger-jsdoc');
const cookieParser = require('cookie-parser');
const bodyParser = require('body-parser');
const https = require('https');
const fs = require('fs');
const path = require('path');
const passport = require('./passport');
function _getRedisConfig(redisUrl) {
const redisConfig = url.parse(redisUrl);
return {
host: redisConfig.hostname || 'localhost',
port: Number(redisConfig.port || 6379),
database: (redisConfig.pathname || '/0').substr(1) || '0',
password: redisConfig.auth ? redisConfig.auth.split(':')[1] : undefined
};
}
app.use('/arena', Arena(
{
queues: [
{
name: TF_APPLY_QUEUE,
hostId: 'Worker',
redis: _getRedisConfig(process.env.REDIS_URL)
},
{
name: TF_APPLY_QSEOK_QUEUE,
hostId: 'Worker',
redis: _getRedisConfig(process.env.REDIS_URL)
},
{
name: TF_DESTROY_QUEUE,
hostId: 'Worker',
redis: _getRedisConfig(process.env.REDIS_URL)
}
]
},
{
basePath: '/',
disableListen: true
}
));
//-----------------------------------------------------------------------------
// Config the app, include middlewares
//-----------------------------------------------------------------------------
//app.set('views', __dirname + '/views');
//app.set('view engine', 'ejs');
app.use(cookieParser());
// parse application/json
// parse application/x-www-form-urlencoded
app.use(bodyParser.urlencoded({ extended: false }))
// parse application/json
app.use(bodyParser.json())
app.use(express.static(__dirname + '/../dist/qmi-cloud'));
passport.init(app);
app.use("/api/scenarios", routesApiScenarios);
app.use("/api/users", routesApiUsers);
app.use("/api/provisions", routesApiProvisions);
app.use("/api/destroyprovisions", routesApiDestroyProvisions);
app.get('/*',(req, res, next) =>{
if (req.originalUrl.indexOf("/api-docs") !== -1 || req.originalUrl.indexOf("/arena") !== -1 ) {
return next();
} else {
res.sendFile(path.join(__dirname,'/../dist/qmi-cloud/index.html'));
}
});
app.get('/login', passport.ensureAuthenticatedDoLogin, function(req, res) {
res.redirect("/");
});
app.get('/logout', function(req, res) {
res.redirect("/");
});
const options = {
swaggerDefinition: {
// Like the one described here: https://swagger.io/specification/#infoObject
info: {
title: 'QMI Cloud - API',
version: '1.0.0',
//description: 'Test Express API with autogenerated swagger doc',
},
basePath: "/api"
},
// List of files to be processes. You can also set globs './routes/*.js'
apis: [
'server/routes/api-scenarios.js',
'server/routes/api-users.js',
'server/routes/api-provisions.js',
'server/routes/api-destroyprovisions.js',
],
};
const specs = swaggerJsdoc(options);
app.use('/api-docs', passport.ensureAuthenticatedDoLogin, swaggerUi.serve, swaggerUi.setup(specs));
app.listen(3000, () => {
console.log(`Server listening on port 3000`)
});
https.createServer({
key: fs.readFileSync(path.resolve(__dirname, 'certs', 'fake_server.key')),
cert: fs.readFileSync(path.resolve(__dirname, 'certs', 'fake_server.cert'))
}, app).listen(3100, function(){
console.log(`Secure server listening on port 3100`);
});