Compile ts to js

gunhoflash · gunhoflash · commit 878da0d10a5a · 2021-11-17T03:27:55.000+09:00
diff --git a/.eslintrc.json b/.eslintrc.json
@@ -1,4 +1,5 @@
 {
+  "files": ["src/**/*.ts"],
   "env": {
     "browser": true,
     "es2021": true
diff --git a/.gitignore b/.gitignore
@@ -1,4 +1,6 @@
 config/
 credentials/
 node_modules/
-token/
+token/
+
+whitelist.json
diff --git a/README.md b/README.md
@@ -5,11 +5,11 @@ Send emails using Gmail API
 1. Place your credential file in `credentials` folder with name `credentials.{{account}}.json`.
 2. Create `.env` file in `config` folder.
    - You can set value of HTTP_PORT and HTTPS_PORT.
-3. (Optional) Edit the `whitelist.json` file to config CORS.
-4. Run `npm run i` or `npm run ci`.
-5. Run `npm run init`.
+3. Run `npm run init`.
    - Enter the account name to create an token file.
    - Token file will be created in `token` folder.
+4. (Optional) Edit the `whitelist.json` file to config CORS.
+5. Run `npm run build`.
 
 ## Run Mailer
 Just run `npm start`.
diff --git a/dist/index.js b/dist/index.js
@@ -0,0 +1,83 @@
+"use strict";
+var __importDefault = (this && this.__importDefault) || function (mod) {
+    return (mod && mod.__esModule) ? mod : { "default": mod };
+};
+Object.defineProperty(exports, "__esModule", { value: true });
+const cors_1 = __importDefault(require("cors"));
+const dotenv_1 = __importDefault(require("dotenv"));
+const express_1 = __importDefault(require("express"));
+const http_1 = __importDefault(require("http"));
+const https_1 = __importDefault(require("https"));
+const mailer_1 = __importDefault(require("./mailer"));
+const whitelist_json_1 = __importDefault(require("../whitelist.json"));
+dotenv_1.default.config({ path: './config/.env' });
+const mailers = new Map();
+const app = (0, express_1.default)();
+app.use(express_1.default.json());
+app.use(express_1.default.urlencoded({ extended: true }));
+if (whitelist_json_1.default.length) {
+    console.log('Use whitelist:', whitelist_json_1.default);
+    app.use((0, cors_1.default)({
+        origin: function (origin, callback) {
+            if (origin && whitelist_json_1.default.indexOf(origin) !== -1) {
+                callback(null, true);
+            }
+            else {
+                callback(new Error('Not allowed by CORS'));
+            }
+        }
+    }));
+}
+else {
+    console.log('Whitelist not found, allow all origin.');
+    app.use((0, cors_1.default)());
+}
+app.post('/send-mail', (req, res) => {
+    const { account, from, to, subject, message, contentType } = req.body;
+    if (!mailers.has(account))
+        mailers.set(account, new mailer_1.default(account));
+    const nMailSent = mailers.get(account).sendMail({ from, to, subject, message, contentType });
+    res.send(nMailSent);
+});
+app.get('/mail-queue/:account', (req, res) => {
+    const { account } = req.params;
+    if (!account) {
+        return res.status(400).send('Account is required');
+    }
+    if (!mailers.has(account))
+        mailers.set(account, new mailer_1.default(account));
+    res.json({
+        result: mailers.get(account).getMailQueue(),
+    });
+});
+app.get('/failed-mail/:account', (req, res) => {
+    const { account } = req.params;
+    if (!account) {
+        return res.status(400).send('Account is required');
+    }
+    if (!mailers.has(account))
+        mailers.set(account, new mailer_1.default(account));
+    res.json({
+        result: mailers.get(account).getFailedMails(),
+    });
+});
+const HTTP_PORT = process.env.HTTP_PORT;
+const HTTPS_PORT = process.env.HTTPS_PORT;
+if (!HTTP_PORT && !HTTPS_PORT) {
+    console.error('HTTP_PORT or HTTPS_PORT are required');
+    process.exit(1);
+}
+if (HTTP_PORT) {
+    http_1.default.createServer(app).listen(HTTP_PORT, () => {
+        console.log(`http server listen: ${HTTP_PORT}`);
+    });
+}
+if (HTTPS_PORT) {
+    const options = {
+        key: process.env.SSL_KEY,
+        cert: process.env.SSL_CERT,
+    };
+    https_1.default.createServer(options, app).listen(HTTPS_PORT, () => {
+        console.log(`https server listen: ${HTTPS_PORT} with options: ${JSON.stringify(options)}`);
+    });
+}
diff --git a/dist/mailer.js b/dist/mailer.js
@@ -0,0 +1,135 @@
+"use strict";
+var __importDefault = (this && this.__importDefault) || function (mod) {
+    return (mod && mod.__esModule) ? mod : { "default": mod };
+};
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.getOAuth2Client = void 0;
+const promises_1 = require("fs/promises");
+const readline_1 = __importDefault(require("readline"));
+const googleapis_1 = require("googleapis");
+const SCOPES = [
+    'https://mail.google.com/',
+    'https://www.googleapis.com/auth/gmail.send',
+];
+const base64Encode = (message) => Buffer.from(message).toString('base64').replace(/\+/g, '-').replace(/\//g, '_');
+const getOAuth2Client = async (credentialsName, tokenName, noTokenInitialize = false) => {
+    const credentialsPath = `credentials/credentials.${credentialsName}.json`;
+    const tokenPath = `token/token.${tokenName}.json`;
+    try {
+        const content = await (0, promises_1.readFile)(credentialsPath);
+        return await authorize(JSON.parse(content), tokenPath, noTokenInitialize);
+    }
+    catch (e) {
+        console.error('Error on getOAuth2Client():', e);
+        return null;
+    }
+};
+exports.getOAuth2Client = getOAuth2Client;
+const authorize = async (credentials, tokenPath, noTokenInitialize = false) => {
+    const { client_secret, client_id, redirect_uris } = credentials.installed;
+    const oAuth2Client = new googleapis_1.google.auth.OAuth2(client_id, client_secret, redirect_uris[0]);
+    try {
+        const token = await (0, promises_1.readFile)(tokenPath);
+        oAuth2Client.setCredentials(JSON.parse(token));
+        return oAuth2Client;
+    }
+    catch (e) {
+        if (noTokenInitialize) {
+            throw 'Token file not found!';
+        }
+        return await getNewToken(oAuth2Client, tokenPath);
+    }
+};
+const getNewToken = (oAuth2Client, tokenPath) => new Promise((resolve, reject) => {
+    const authUrl = oAuth2Client.generateAuthUrl({
+        access_type: 'offline',
+        scope: SCOPES,
+    });
+    console.log('Authorize this app by visiting this url:', authUrl);
+    const rl = readline_1.default.createInterface({
+        input: process.stdin,
+        output: process.stdout,
+    });
+    rl.question('Enter the code from that page here: ', code => {
+        rl.close();
+        oAuth2Client.getToken(code, async (err, token) => {
+            if (err) {
+                console.error('Error retrieving access token', err);
+                return reject();
+            }
+            if (!token) {
+                console.error('No token retrieved');
+                return reject();
+            }
+            oAuth2Client.setCredentials(token);
+            try {
+                await (0, promises_1.writeFile)(tokenPath, JSON.stringify(token));
+                console.log('Token stored to', tokenPath);
+                return resolve(oAuth2Client);
+            }
+            catch (e) {
+                console.error(e);
+                return reject();
+            }
+        });
+    });
+});
+class Mailer {
+    #gmail = null;
+    #account;
+    #mailQueue;
+    #failedMails;
+    constructor(account) {
+        this.#account = account;
+        this.#mailQueue = [];
+        this.#failedMails = [];
+        this.initClient();
+    }
+    async initClient() {
+        this.#gmail = null;
+        const oAuth2Client = await (0, exports.getOAuth2Client)(this.#account, this.#account, true);
+        if (oAuth2Client) {
+            this.#gmail = googleapis_1.google.gmail({ version: 'v1', auth: oAuth2Client });
+            this.sendMail();
+        }
+    }
+    sendMail(mail) {
+        if (mail)
+            this.#mailQueue.push(mail);
+        if (!this.#gmail)
+            return 0;
+        let nMailSent = 0;
+        for (const mail of this.#mailQueue) {
+            const { from, to, subject, message, contentType = 'text/plain' } = mail;
+            this.#gmail.users.messages.send({
+                userId: 'me',
+                requestBody: {
+                    raw: base64Encode(`From: ${from}\n` +
+                        `To: ${to}\n` +
+                        `Subject: ${subject}\n` +
+                        'MIME-Version: 1.0\n' +
+                        `Content-Type: ${contentType}; charset="UTF-8"\n` +
+                        'Content-Transfer-Encoding: message/rfc2822\n' +
+                        '\n' +
+                        `${message}\n`),
+                },
+            }, (err, res) => {
+                if (err) {
+                    this.#failedMails.push({ ...mail, failReason: err, timestamp: Date.now() });
+                    return console.log('The API returned an error: ' + err);
+                }
+                nMailSent++;
+                console.log(`Message sent with ID: ${res?.data.id}`);
+            });
+        }
+        this.#mailQueue = [];
+        return nMailSent;
+    }
+    getMailQueue() {
+        return this.#mailQueue;
+    }
+    getFailedMails() {
+        return this.#failedMails;
+    }
+}
+exports.default = Mailer;
diff --git a/dist/tokenInitializer.js b/dist/tokenInitializer.js
@@ -0,0 +1,26 @@
+"use strict";
+var __importDefault = (this && this.__importDefault) || function (mod) {
+    return (mod && mod.__esModule) ? mod : { "default": mod };
+};
+Object.defineProperty(exports, "__esModule", { value: true });
+const readline_1 = __importDefault(require("readline"));
+const mailer_1 = require("./mailer");
+const rl = readline_1.default.createInterface({
+    input: process.stdin,
+    output: process.stdout,
+});
+const prompt = () => {
+    rl.question('Enter an account to initialize(Enter \'exit\' to exit): ', async (input) => {
+        const account = input.trim();
+        if (account) {
+            if (account === 'exit') {
+                rl.close();
+                return;
+            }
+            await (0, mailer_1.getOAuth2Client)(account, account);
+            console.log(`Token for ${account} initialized.`);
+        }
+        prompt();
+    });
+};
+prompt();
diff --git a/package.json b/package.json
@@ -5,9 +5,10 @@
   "main": "index.js",
   "scripts": {
     "test": "echo \"Error: no test specified\" && exit 1",
-    "start": "npm run dev",
-    "dev": "nodemon --exec ts-node src/index.ts",
-    "init": "ts-node tokenInitializer.ts"
+    "start": "nodemon --exec node dist/index.js",
+    "build": "tsc",
+    "init": "npm i && echo [] > whitelist.json && npm run init-token",
+    "init-token": "node dist/tokenInitializer.js"
   },
   "repository": {
     "type": "git",
diff --git a/src/index.ts b/src/index.ts
@@ -16,11 +16,11 @@ app.use(express.json());
 app.use(express.urlencoded({ extended: true }));
 
 // CORS
-if (whitelist?.length) {
+if (whitelist.length) {
   console.log('Use whitelist:', whitelist);
   app.use(cors({
     origin: function (origin, callback) {
-      if (origin && whitelist.indexOf(origin) !== -1) {
+      if (origin && (whitelist as string[]).indexOf(origin) !== -1) {
         callback(null, true);
       } else {
         callback(new Error('Not allowed by CORS'));
diff --git a/src/tokenInitializer.ts b/src/tokenInitializer.ts
@@ -1,5 +1,5 @@
 import readline from 'readline';
-import { getOAuth2Client } from './src/mailer';
+import { getOAuth2Client } from './mailer';
 
 const rl = readline.createInterface({
   input: process.stdin,
@@ -26,4 +26,3 @@ const prompt = () => {
 };
 
 prompt();
-
diff --git a/tsconfig.json b/tsconfig.json
@@ -11,7 +11,7 @@
     // "disableReferencedProjectLoad": true,             /* Reduce the number of projects loaded automatically by TypeScript. */
 
     /* Language and Environment */
-    "target": "es6",                                     /* Set the JavaScript language version for emitted JavaScript and include compatible library declarations. */
+    "target": "esnext",                                     /* Set the JavaScript language version for emitted JavaScript and include compatible library declarations. */
     // "lib": [],                                        /* Specify a set of bundled library declaration files that describe the target runtime environment. */
     // "jsx": "preserve",                                /* Specify what JSX code is generated. */
     // "experimentalDecorators": true,                   /* Enable experimental support for TC39 stage 2 draft decorators. */
@@ -25,7 +25,7 @@
 
     /* Modules */
     "module": "commonjs",                                /* Specify what module code is generated. */
-    // "rootDir": "./",                                  /* Specify the root folder within your source files. */
+    "rootDir": "./src",                                  /* Specify the root folder within your source files. */
     "moduleResolution": "node",                       /* Specify how TypeScript looks up a file from a given module specifier. */
     // "baseUrl": "./",                                  /* Specify the base directory to resolve non-relative module names. */
     // "paths": {},                                      /* Specify a set of entries that re-map imports to additional lookup locations. */
@@ -45,10 +45,10 @@
     // "declaration": true,                              /* Generate .d.ts files from TypeScript and JavaScript files in your project. */
     // "declarationMap": true,                           /* Create sourcemaps for d.ts files. */
     // "emitDeclarationOnly": true,                      /* Only output d.ts files and not JavaScript files. */
-    "sourceMap": true,                                /* Create source map files for emitted JavaScript files. */
+    // "sourceMap": true,                                /* Create source map files for emitted JavaScript files. */
     // "outFile": "./",                                  /* Specify a file that bundles all outputs into one JavaScript file. If `declaration` is true, also designates a file that bundles all .d.ts output. */
-    // "outDir": "./",                                   /* Specify an output folder for all emitted files. */
-    // "removeComments": true,                           /* Disable emitting comments. */
+    "outDir": "./dist",                                   /* Specify an output folder for all emitted files. */
+    "removeComments": true,                           /* Disable emitting comments. */
     // "noEmit": true,                                   /* Disable emitting files from a compilation. */
     // "importHelpers": true,                            /* Allow importing helper functions from tslib once per project, instead of including them per-file. */
     // "importsNotUsedAsValues": "remove",               /* Specify emit/checking behavior for imports that are only used for types */
@@ -74,7 +74,7 @@
 
     /* Type Checking */
     "strict": true,                                      /* Enable all strict type-checking options. */
-    // "noImplicitAny": true,                            /* Enable error reporting for expressions and declarations with an implied `any` type.. */
+    "noImplicitAny": false,                            /* Enable error reporting for expressions and declarations with an implied `any` type.. */
     // "strictNullChecks": true,                         /* When type checking, take into account `null` and `undefined`. */
     // "strictFunctionTypes": true,                      /* When assigning functions, check to ensure parameters and the return values are subtype-compatible. */
     // "strictBindCallApply": true,                      /* Check that the arguments for `bind`, `call`, and `apply` methods match the original function. */
diff --git a/whitelist.json b/whitelist.json
@@ -1,2 +1 @@
-[
-]
+[]  

Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,5 @@`
`1`	`1`	`{`
	`2`	`+ "files": ["src/*/.ts"],`
`2`	`3`	`"env": {`
`3`	`4`	`"browser": true,`
`4`	`5`	`"es2021": true`