ezpaarse-project/ezpaarse

'use strict';

var fs = require('fs-extra');
var path = require('path');
var os = require('os');
var Boom = require('boom');
var bodyParser = require('body-parser');
var request = require('request');
var mailer = require('../lib/mailer.js');
var git = require('../lib/git-tools.js');
var config = require('../lib/config.js');
var pkg = require('../package.json');
var execFile   = require('child_process').execFile;

var { Router } = require('express');
var app = Router();

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

/**
 * POST route on /
 * To submit a feedback
 */
app.post('/', async function (req, res, next) {
  if (!config.EZPAARSE_ADMIN_MAIL || !config.EZPAARSE_FEEDBACK_RECIPIENTS) {
    return next(Boom.badImplementation('no mail configuration'));
  }

  res.header('Access-Control-Allow-Origin', '*');
  res.header('Access-Control-Allow-Headers', 'X-Requested-With');

  const feedback = req.body;

  if (!feedback || !feedback.comment) {
    return next(Boom.badRequest('missingComment'));
  }

  let usermail;
  if (req.user) {
    usermail = req.user.username;
  } else if (feedback.mail) {
    usermail = feedback.mail;
  }

  let versions = {
    platforms: null,
    resources: null,
    middlewares: null,
    ezpaarse: null
  };
  const directories = ['platforms', 'resources', 'middlewares', '.'];

  for (let directory of directories) {
    try {
      const tmp = await getVersion(directory);
      versions[directory === '.' ? 'ezpaarse' : directory] = JSON.parse(tmp).current;
    } catch (e) {
      return next(e);
    }
  }

  const label = config.EZPAARSE_APP_NAME || 'ezPAARSE';
  let subject = `[${label}] Feedback `;
  subject += usermail ? 'de ' + usermail : 'anonyme';
  let text = 'Utilisateur : ' + (usermail || 'anonyme');

  if (feedback.browser) { text += '\nNavigateur : ' + feedback.browser; }

  text += '\nVersions :';
  text += '\n\t- ezPAARSE ' + versions.ezpaarse + ' / ' + os.platform() + ' ' + os.release();
  text += ' (' + os.arch() + ')';
  text += '\n\t- Middlewares : ' + versions.middlewares;
  text += '\n\t- Resources : ' + versions.resources;
  text += '\n\t- Platforms : ' + versions.platforms;
  text += '\n===============================\n\n';
  text += feedback.comment;

  let mail = mailer.mail();
  mail.subject(subject)
    .text(text)
    .from(config.EZPAARSE_ADMIN_MAIL)
    .to(config.EZPAARSE_FEEDBACK_RECIPIENTS)
    .cc(usermail);

  var sendMail = function () {
    mail.send(function (error) {
      if (error) { return next(error); }
      return res.status(200).end();
    });
  };

  if (feedback.report) {
    mail.attach('report.json', feedback.report);
    return sendMail();
  }

  if (!req.body.jobID) { return sendMail(); }

  const jobID = req.body.jobID;
  const reportFile = path.join(__dirname, '/../tmp/jobs/',
    jobID.charAt(0),
    jobID.charAt(1),
    jobID,
    'report.json'
  );

  fs.readFile(reportFile, 'utf-8', function (err, content) {
    if (err) {
      return next(err.code !== 'ENOENT' ? err : Boom.conflict('reportDoesNotExist'));
    }
    mail.attach('report.json', content);
    sendMail();
  });
});

function getVersion (directory) {
  const gitScript = path.join(__dirname, '../bin/git-status');
  const cwd = path.join(__dirname, '..', directory);

  return new Promise((resolve, reject) => {
    return execFile(gitScript, { cwd }, (error, stdout) => {
      if (error || !stdout) { return reject(error); }

      return resolve(stdout);
    });
  });
}

/**
 * POST route on /feedback/freshinstall
 * To inform the team about a fresh installation
 */
app.post('/freshinstall', function (req, res, next) {
  if (!config.EZPAARSE_FEEDBACK_RECIPIENTS || !config.EZPAARSE_ADMIN_MAIL) {
    return next(Boom.badImplementation());
  }

  res.header('Access-Control-Allow-Origin', '*');
  res.header('Access-Control-Allow-Headers', 'X-Requested-With');

  if (!req.body.mail) {
    return next(Boom.badRequest('missingMailField'));
  }

  git.exec('describe', function (err, stdout) {

    var text = 'Une nouvelle instance d\'ezPAARSE vient d\'être installée.';
    text += '\n\nPremier compte : ' + req.body.mail;
    text += ' | http://' + req.body.mail.split('@')[1];
    text += '\nPlateforme : ' + os.platform() + ' ' + os.release() + ' (' + os.arch() + ')';
    text += '\nVersion :';
    text += '\n- package : ' + pkg.version || 'inconnue';
    text += '\n- git : ' + (!err && stdout ? stdout : 'inconnue');

    const label = config.EZPAARSE_APP_NAME || 'ezPAARSE';

    mailer.mail()
      .subject(`[${label}] Nouvelle installation`)
      .text(text)
      .from(config.EZPAARSE_ADMIN_MAIL)
      .to(config.EZPAARSE_FEEDBACK_RECIPIENTS)
      .send(function (error, response) {
        if (error) { return next(error); }
        res.status(200).end();
      });
  });
});

/**
 * GET route on /feedback/status
 * To know if sending a feedback is possible
 */
app.get('/status', function (req, res, next) {
  if (!config.EZPAARSE_FEEDBACK_RECIPIENTS || !config.EZPAARSE_ADMIN_MAIL) {
    return next(Boom.notImplemented());
  }

  if (mailer.canSendMail) {
    mailer.checkServer(function (online) {
      if (online) {
        res.status(200).send(config.EZPAARSE_FEEDBACK_RECIPIENTS);
      } else {
        return next(Boom.notImplemented());
      }
    });
  } else if (config.EZPAARSE_PARENT_URL) {
    request.get(config.EZPAARSE_PARENT_URL + '/api/feedback/status',
      function (err, response, body) {
        if (err || !response || response.statusCode != 200) {
          return next(Boom.notImplemented());
        }
        if (!/^\S+@\S+$/.test(body)) {
          return next(Boom.notImplemented());
        }
        res.status(200).json(config.EZPAARSE_FEEDBACK_RECIPIENTS);
      });
  } else {
    return next(Boom.notImplemented());
  }
});

module.exports = app;