'use strict'
/**
 * Copyright (c) 2018, OBCon Inc.
 * All rights reserved.
 */

/**
 * @file
 * @copyright OBCon Inc. Korea 2018
 * @author gye hyun james kim [pnuskgh@gmail.com]
 */

let fs = require('fs');
let nodemailer = require('nodemailer');

class Emails {
    constructor() {
        this.templateTitle = 'zzEmailTitlezz';              //--- Email Template에 제목을 채우기 위해 사용 한다.
        this.templateHtml  = 'zzEmailHtmlzz';               //--- Email Template에 본문을 채우기 위해 사용 한다.
        this.templateSignature = 'zzEmailSignaturezz';      //--- Email Template에 서명을 채우기 위해 사용 한다.
        this.templateCopyright = 'zzEmailCopyRightzz';              //--- Email Template에 Copyright를 채우기 위해 사용 한다.

        this._transporter = {};
        this._from = {};                                    //--- 보낸 사람
        this._signature = {};                               //--- 서명              : 명명 규칙 - ${service}_signature.htm
        this._template = {};                                //--- Email Template    : 명명 규칙 - ${service}_template.htm

        //--- Service 관리자용 이메일 서비스를 생성 한다.
        this.createService(config.email.service, {
            host: config.email.host,                        //--- Email Host
            port: config.email.port,                        //--- Email Port : 25, 587 (TLS)
            secure: config.email.secure,                    //--- true. 보안 이메일
            auth: {
                user: config.email.username,                //--- 로그인 아이디
                pass: config.email.password                 //--- 로그인 비밀번호
            }        
        }, null, null)
        // }, 'admin_signature.htm', null)
    }

    // init() {
    //     global.sendNotification = function(subject, html) {
    //         if (process.platform == 'linux') {                      //--- linux, win32
    //             config.notification.emails.forEach(function(emailTo) {
    //                 emails.sendEmail(config.email.service, config.email.username, emailTo, subject, html);
    //             });
    //         }
    //     };        
    // }

    _readFile(signatureFile) {
        let file = utils.getPath('files', 'emailTemplate', signatureFile);
        if (fs.existsSync(file)) {
            return fs.readFileSync(file, 'utf8');
        } else {
            return '';
        }
    }

    //--- Site 모듈에서 ajaxTestEmail()에서만 사용중
    createService(service, options, signatureFile, templateFile, rebuild=false) {
        let file = null;

        if (rebuild) {
            if (this._transporter.hasOwnProperty(service)) {
                delete this._transporter[service];
            }
        }

        if ((!this._transporter.hasOwnProperty(service)) || (rebuild)) {
            this._transporter[service] = nodemailer.createTransport(options);
            this._from[service] = options.auth.user;

            if (templateFile == null) {
                file = utils.getPath('files', 'emailTemplate', service + '_template.htm');
                if (fs.existsSync(file)) {
                    this._template[service] = this._readFile(service + '_template.htm');
                } else {
                    this._template[service] = null;
                }
            } else {
                this._template[service] = this._readFile(templateFile);
            }

            if (signatureFile == null) {
                file = utils.getPath('files', 'emailTemplate', service + '_signature.htm');
                if (fs.existsSync(file)) {
                    this._signature[service] = this._readFile(service + '_signature.htm');
                } else {
                    this._signature[service] = null;
                }
            } else {
                this._signature[service] = this._readFile(signatureFile);
            }
        }
    }

    //--- createService() 함수를 통해서 이메일 service를 먼저 생성한 후 sendEmail() 함수를 호출 한다.
    sendEmail(service, from, to, subject, html, callback=null) {
        let options = {
            from: from,
            to: to,
            subject: subject,
        };

        if (service == null) {
            service = 'OBCon';
        }

        if (from == null) {
            options.from = this._from[service];
        }

        //--- template와 signature를 사용하여 이메일을 작성 한다.
        if (this._template[service] == null) {
            // options.html = `${service}<br/><br/>${html}<br/><br/><br/><br/>${this.templateSignature}<br/><br/>`;
            options.html = `<br/><br/>${html}<br/><br/><br/><br/>${this.templateSignature}<br/><br/>`;
        } else {
            options.html = this._template[service].replace(this.templateTitle, subject).replace(this.templateHtml, html);
        }

        if (this._signature[service] == null) {
            options.html = options.html.replace(this.templateSignature, '');
        } else {
            options.html = options.html.replace(this.templateSignature, this._signature[service]);
        }

        options.html = options.html.replace(this.templateCopyright, config.service.copyright);

        //--- createService() 함수에 의해서 생성된 transporter를 사용하여 이메일을 발송 한다.
        this._transporter[service].sendMail(options, function(error, info) {
            if (error) {
                logger.error('include/emails.js : ' + JSON.stringify(error));
            } else {
                logger.info(`include/emails.js : Message send: ${info.messageId}`);
                logger.info(`include/emails.js : Message send: ${info.response}`);
            }
            this._transporter[service].close();
            if (callback != null) {
                callback(error, info);
            }
        }.bind(this));     
    }

    //--- Service 관리자에게 이메일 발송
    sendNotificationAdmin(subject, html) {
        if (process.platform == 'linux') {                      //--- linux, win32
            config.notification.emails.forEach(function(emailTo) {
                this.sendEmail(config.email.service, config.email.sender, emailTo, subject, html);
            }.bind(this));
        }
    } 

    sendNotification(siteId, siteKey, type, pos, title, msg) {
        // logger.info('include/emails.js : Start sendNotification');
        if (siteKey == null) {
            let query = { where: { id: siteId, deleted: false } };
            modules.sites.model.table.findOne(query)
            .then(function(site) {
                if (site == null) {
                    logger.error('include/emails.js : ' + siteId + ' Site not found.');
                    return;
                }
    
                this._sendNotification(siteId, site.siteKey, type, pos, title, msg);
            }.bind(this)).catch(utils.obj.loggerError);
        } else {
            this._sendNotification(siteId, siteKey, type, pos, title, msg);
        }
    }

    _sendNotification(siteId, siteKey, type, pos, title, msg) {
        logger.info('include/emails.js : site - ' + siteId + ', type - ' + type + ', pos - ' + pos + ', msg - ' + msg);

        let email = settingSync.getSetting(siteKey, null, 'email', config.email);
        if (email.use == false) {
            logger.info('include/emails.js : Email 사용 설정이 되어 있지 않습니다.');
            return;
        }

        let query = { 
            where: { 
                site: siteId, 
                moduleName: 'user',
                // moduleId: userId, 
                category: 'Notification Setting',
                name: 'email_sms',
                deleted: false 
            } 
        };
        modules.settings.model.table.findAll(query)
        .then(function(data) {
            if (data == null) {
                return;
            }
            // logger.info('include/emails.js : emails send start');

            let count = 0;
            let receiver = [];
            for (let idx = 0; idx < data.length; idx++) {
                let item = JSON.parse(data[idx].custom);
                let emailWork = item.emailWork;
                
                emailWork = emailWork.trim();
                if (emailWork == '') {
                    continue;
                }

                if (item.status == '0') {
                    //--- 모든 알람을 수신하지 않습니다.
                    continue;
                }

                let deviceCondition = '';
                if (utils.existField(item, 'deviceCondition' + type)) {
                    deviceCondition = item['deviceCondition' + type];
                } 

                let flag = utils.getFlagString(deviceCondition, pos);
                if ((flag != '1') && (flag != '3')) {
                    //--- 해당되는 Email을 수신하지 않습니다.
                    continue;
                }

                count = count + 1;
                receiver.push(emailWork);
            }

            if (count == 0) {
                return;
            }
            logger.info('include/emails.js : email receivers : ' + receiver.join(','));

            //--- Site를 위한 이메일 서비스 생성
            this.createService(email.service, {
                host: email.host,                               //--- Email Host
                port: email.port,                               //--- Email Port : 25, 587 (TLS)
                secure: email.secure,                           //--- true. 보안 이메일
                auth: {
                    user: email.username,                       //--- 로그인 아이디
                    pass: email.password                        //--- 로그인 비밀번호
                }        
            }, null, config.service.name + '_notification.htm', true);

            receiver.forEach(function(emailTo) {
                this.sendEmail(email.service, email.sender, emailTo, title, msg);
            }.bind(this));

        }.bind(this)).catch(utils.obj.loggerError);
    }
}

module.exports = Emails;