server.js

/* eslint-disable no-console */
require('dotenv-flow').config({ silent: true });
require('./services/logger');

const mongoose = require('mongoose');
const express = require('express');
const bodyParser = require('body-parser');
const multer = require('multer');
const http = require('http');
const cluster = require('cluster');
const numCPUs = require('os').cpus().length;
const swaggerJsdoc = require('swagger-jsdoc');
const swaggerUi = require('swagger-ui-express');

const Constants = require('./constants/Constants');
const Messages = require('./constants/Messages');

const IssuerRoutes = require('./routes/IssuerRoutes');
const UserRoutes = require('./routes/UserRoutes');
const SmsRoutes = require('./routes/SmsRoutes');
const MailRoutes = require('./routes/MailRoutes');
const RenaperRoutes = require('./routes/RenaperRoutes');
const SemillasRoutes = require('./routes/SemillasRoutes');
const AppUserAuthRoutes = require('./routes/AppUserAuthRoutes');
const AdminRoutes = require('./routes/AdminRoutes');
const PresentationRoutes = require('./routes/PresentationRoutes');
const ShareRequestRoutes = require('./routes/ShareRequestRoutes');
const ServiceRoutes = require('./routes/ServiceRoutes');
const NotificationRoutes = require('./routes/NotificationRoutes');
const TranslateRoutes = require('./routes/TranslateRoutes');

const { permanentJob } = require('./jobs/jobs');
const {
  NAME, VERSION, ENVIRONMENT,
} = require('./constants/Constants');
// inicializar cluster para workers, uno por cpu disponible

const app = express();
const server = http.createServer(app);

// sobreescribir log para agregarle el timestamp
const { log } = console;
console.log = (data) => {
  process.stdout.write(`${new Date().toISOString()}: `);
  log(data);
};

// aumentar el tamaño de request permitido (fix renaper...)
app.use(bodyParser.json({ limit: '10mb' }));
app.use(bodyParser.urlencoded({ limit: '10mb', extended: true }));

app.use(
  bodyParser.urlencoded({
    extended: true,
  }),
);
app.use(bodyParser.json());

if (Constants.DEBUGG) console.log(Messages.INDEX.MSG.CONNECTING + Constants.MONGO_URL);

// configuracion de mongoose
mongoose
  .connect(Constants.MONGO_URL, {
    useCreateIndex: true,
    useFindAndModify: false,
    useUnifiedTopology: true,
    useNewUrlParser: true,
  })
  .then(() => console.log(Messages.INDEX.MSG.CONNECTED))
  .catch((err) => {
    console.log(Messages.INDEX.ERR.CONNECTION + err.message);
  });

/**
 * Config de Swagger
 */
const options = {
  definition: {
    openapi: '3.0.0',
    info: {
      title: NAME,
      description: `Corriendo en el ambiente: ${ENVIRONMENT}. Para más información, visite la [documentación](https://docs.didi.org.ar/).`,
      version: VERSION,
    },
    servers: [{
      url: '/',
    }],
  },
  apis: ['./*.js', './routes/*.js'], // files containing annotations as above
};
const apiSpecification = swaggerJsdoc(options);
/**
 * @openapi
 * /api-docs:
 *   get:
 *     description: Welcome to the jungle!
 *     responses:
 *       200:
 *         description: Returns a mysterious webpage.
 */
app.use('/api-docs', swaggerUi.serve, swaggerUi.setup(apiSpecification));

app.use(bodyParser.json());

// loggear llamadas
if (Constants.DEBUGG) {
  app.use((req, _, next) => {
    console.log(`${req.method} ${req.originalUrl}`);
    process.stdout.write('body: ');
    console.log(req.body);
    process.stdout.write('Headers: ');
    console.log(req.headers);
    next();
  });
}
// loggear errores
app.use((error, req, _, next) => {
  console.log(error);
  next();
});

app.use(
  multer({
    dest: './uploads/',
    rename: function rename(_fieldname, filename) {
      return filename;
    },
  }).single('file'),
);
app.use(ServiceRoutes);
app.use(IssuerRoutes);
app.use(UserRoutes);
app.use(SmsRoutes);
app.use(MailRoutes);
app.use(RenaperRoutes);
app.use(SemillasRoutes);
app.use(AppUserAuthRoutes);
app.use(AdminRoutes);
app.use(PresentationRoutes);
app.use(ShareRequestRoutes);
app.use(NotificationRoutes);
app.use(TranslateRoutes);
app.use('*', (req, res) => res.status(404).json({
  status: 'error',
  errorCode: 'INVALID_ROUTE',
  message: 'Route does not exist',
}));

// forkear workers
if (cluster.isMaster) {
  console.log(Messages.INDEX.MSG.STARTING_WORKERS(numCPUs));
  permanentJob();

  // eslint-disable-next-line no-plusplus
  for (let i = 0; i < numCPUs; i++) {
    cluster.fork();
  }

  cluster.on('online', (worker) => {
    console.log(Messages.INDEX.MSG.STARTED_WORKER(worker.process.pid));
  });

  cluster.on('exit', (worker, code, signal) => {
    console.log(Messages.INDEX.MSG.ENDED_WORKER(worker.process.pid, code, signal));
    console.log(Messages.INDEX.MSG.STARTING_WORKER);
    cluster.fork();
  });
} else {
  server.listen(Constants.PORT);
  console.log(Messages.INDEX.MSG.RUNNING_ON + Constants.PORT);
}