index.js

const express = require('express');
const morgan = require('morgan');
const http = require('http');
const fs = require('fs');
const path = require('path');
const cors = require('cors');
const cron = require('node-cron');
const { getSales, saveSales } = require('./services/util');
const routes = require('./routes');
const { initiateDB } = require('./services');
const { createLogger, transports, format } = require('winston');

const PORT = 5000;

/**
 * express application
 */
const app = express();
initiateDB();
const server = http.Server(app);
const logDate = new Date().toISOString().substring(0, 10);
if (!fs.existsSync('logs')) {
  fs.mkdirSync('logs');
}

// Create log file
const accessLogStream = fs.createWriteStream(
  path.join(__dirname, `./logs/${logDate}.log`),
  { flags: 'a+' }
);

// Create cron log file
const cronLogs = path.join(__dirname, `./logs/cron/${logDate}.log`);
const logger = createLogger({
  level: 'info',
  format: format.combine(format.json(), format.timestamp()),
  transports: [new transports.File({ filename: cronLogs, level: 'info' })],
});

// Send specific information to morgan for logging
app.use(
  morgan(
    ':remote-addr\t\t:remote-user\t\t:date\t\t":method :url HTTP/:http-version"\t\t:status\t\t:response-time ms\t\t:res[content-length]\t\t":referrer"\t\t":user-agent"',
    { stream: accessLogStream }
  )
);

app.use(cors({ origin: true, credentials: true }));
app.use(express.json());
app.use(express.urlencoded({ extended: true }));

app.use('/api/v1', routes);

// Catch none-existing routes and other errors
app.use((req, res, next) => {
  return res.status(404).json({
    status: 'error',
    message: 'Route not found.',
  });
});

// Schedule tasks to run daily on the server.
cron.schedule('0 0 * * *', async () => {
// cron.schedule('* * * * *', async () => {
  const { ps5Sales, xboxSales, date, responseTime } = await getSales();
  const salesLog = await saveSales(ps5Sales, xboxSales, date, responseTime);
  logger.log('info', salesLog);
});

server.listen(PORT, () => {
  console.error(`Server running on http://localhost:${PORT}.`);
});