Node Mail

const fs = require("fs");
const path = require("path");
const nodemailer = require("nodemailer");
const ejs = require("ejs");
const { MAIL_TRANSPORT_CONFIG, MAIL_FROM, MAIL_TO } = require("./config");
const usersService = require("./services/users");

const renderHtml = async function () {
    const users = await usersService.query({ ename: null, deptno: null });
    const template = ejs.compile(
        fs.readFileSync(
            path.resolve(__dirname, "template", "email.ejs"),
            "utf8"
        ),
        { async: false }
    );
    const html = template({
        title: "EDI Group",
        users: users,
    });

    return html;
};

// async..await is not allowed in global scope, must use a wrapper
async function mail() {
    // create reusable transporter object using the default SMTP transport
    let transporter = nodemailer.createTransport(MAIL_TRANSPORT_CONFIG);

    // send mail with defined transport object
    let info = await transporter.sendMail({
        from: MAIL_FROM, // sender address
        to: MAIL_TO, // list of receivers
        subject: "Hello ✔", // Subject line
        text: "Hello world?", // plain text body
        html: await renderHtml(), // html body
        attachments: [
            {
                // file on disk as an attachment
                filename: "data.json",
                path: "./data.json", // stream this file
            },
        ],
    });

    console.log("Message sent: %s", info.messageId);
    // Message sent: <b658f8ca-6296-ccf4-8306-87d57a0b4321@example.com>
}

mail().catch(console.error);

const MAIL_CONFIG = {
    MAIL_TRANSPORT_CONFIG: {
        host: "xxx",
        port: xx,
    },
    MAIL_FROM: "Babb_Chen@xx.com",
    MAIL_TO: "Babb_Chen@xx.com",
};

module.exports = MAIL_CONFIG;

const oracledb = require("oracledb");

oracledb.outFormat = oracledb.OBJECT;

function query(queryObj) {
    return new Promise(async function (resolve, reject) {
        let connection;

        try {
            connection = await oracledb.getConnection({
                user: "xxx",
                password: "xxx",
                connectString: "DEV",
            });

            const sql = `SELECT empno, ename, job, mgr, hiredate, sal, comm, deptno FROM scott.emp
                  WHERE ename = nvl(:ename, ename)
                    AND deptno = nvl(:deptno, deptno)`;

            const result = await connection.execute(sql, [
                queryObj.ename,
                queryObj.deptno,
            ]);

            resolve(result.rows);
        } catch (err) {
            // catches errors in getConnection and the query
            reject(err);
        } finally {
            if (connection) {
                // the connection assignment worked, must release
                try {
                    await connection.release();
                } catch (e) {
                    console.error(e);
                }
            }
        }
    });
}

module.exports = {
    query,
};