gadael/gadael

'use strict';

const crypto = require('crypto');
const util = require('util');
const invitationEmail = require('../../../../modules/emails/invitation');

/**
 * Validate params fields
 * @param {apiService} service
 * @param {Object} params
 */
function validate(service, params) {

    if (service.needRequiredFields(params, ['email', 'createdBy'])) {
        return;
    }

    saveRightType(service, params);
}


/**
 * Update/create the invitation document
 *
 * @param {apiService} service
 * @param {Object} params
 */
function saveRightType(service, params) {

    const gt = service.app.utility.gettext;

    const InvitationModel = service.app.db.models.Invitation;
    const UserModel = service.app.db.models.User;

    var fieldsToSet = {
        email: params.email,
        department: params.department,
        nonWorkingDaysCalendar: params.nonWorkingDaysCalendar
    };


    if (params.id)
    {
        // Update the invitation, not used

        InvitationModel.findOne({ _id: params._id })
        .exec((err, invitation) => {
            if (service.handleMongoError(err)) {

                invitation.set(fieldsToSet);

                invitation.save((err, document) => {
                    if (service.handleMongoError(err))
                    {
                        service.resolveSuccessGet(
                            document._id,
                            gt.gettext('The invitation has been modified')
                        );
                    }
                });
            }
        });


    } else {

        crypto.randomBytes(48, function(err, tokenBuffer) {

            if (err) {
                return service.error(err);
            }

            let invitation = new InvitationModel();
            invitation.set(fieldsToSet);
            invitation.emailToken = tokenBuffer.toString('hex');
            invitation.createdBy = {
                id: params.createdBy._id,
                name: params.createdBy.getName()
            };

            UserModel.find({ email: invitation.email })
            .exec()
            .then(arr => {
                if (0 !== arr.length) {
                    throw new Error(gt.gettext('This email address already exists in users list'));
                }

                return invitationEmail(service.app, invitation);
            })

            .then(mail => {
                return mail.send();
            })
            .then(message => {
                invitation.message = message._id;
                return invitation.save();
            })
            .then(document => {
                service.resolveSuccessGet(
                    document._id,
                    util.format(gt.gettext('The invitation for %s has been sent'), document.email)
                );
            })
            .catch(service.error);
        });
    }

}










/**
 * Construct the invitation save service
 * @param   {object}          services list of base classes from apiService
 * @param   {express|object}  app      express or headless app
 * @returns {saveItemService}
 */
exports = module.exports = function(services, app) {

    var service = new services.save(app);

    /**
     * Call the invitation save service
     *
     * @param {Object} params
     *
     * @return {Promise}
     */
    service.getResultPromise = function(params) {
        validate(service, params);
        return service.deferred.promise;
    };


    return service;
};