[mail] integrate mail bug reporting

.gitignore

@@ -8,3 +8,7 @@ server/node_modules/
 backend/node_modules/
 
 backend/log/
+
+backend/src/secrets.js
+
+backend/src/secrets.json

backend/package.json

@@ -12,6 +12,7 @@
   "license": "ISC",
   "dependencies": {
     "@babel/preset-env": "^7.9.6",
+    "nodemailer": "^6.4.17",
     "two.js": "^0.7.0-stable.1",
     "uuid": "^8.3.2",
     "ws": "^7.2.5"

backend/src/mail.js

@@ -0,0 +1,27 @@
+const nodemailer = require('nodemailer');
+const secrets = require('./secrets.json');
+const { getUnixTime } = require('./websocket/helpers');
+
+const sendMail = (subject, body) => {
+    const mailTransporter = nodemailer.createTransport({
+        host: secrets.emailSmtp,
+        port: secrets.emailPort,
+        secure: false, // true for 465, false for other ports
+        auth: {
+            user: secrets.emailUsername,
+            pass: secrets.emailPassword,
+        },
+        pool: true
+    });
+    mailTransporter.sendMail({
+        from: '"' + secrets.emailName + '" <' + secrets.emailUsername  + '>',
+        to: '"David" <[email protected]>',
+        subject: `Kingscastle.io - ${subject}`,
+        text: body,
+    });
+    console.log(`${getUnixTime()} [MAIL] Mail send`);
+};
+
+module.exports = {
+    sendMail,
+};

backend/src/main.js

@@ -3,27 +3,34 @@ const fs = require('fs');
 const process = require('process');
 const SocketActions = require('./websocket');
 const { ROOT_FOLDER } = require('./config');
+const { sendMail } = require('./mail');
+const { getUnixTime } = require('./websocket/helpers');
 
 const socketPort = 3031;
 const websocket = new WebSocket.Server({ port: socketPort });
 
-const access = fs.createWriteStream(`${ROOT_FOLDER}/log/node.access.log`, { flags: 'a+' });
-const error = fs.createWriteStream(`${ROOT_FOLDER}/log/node.error.log`, { flags: 'a+' });
+const accessStream = fs.createWriteStream(`${ROOT_FOLDER}/log/node.access.log`, { flags: 'a+' });
+const errorStream = fs.createWriteStream(`${ROOT_FOLDER}/log/node.error.log`, { flags: 'a+' });
 
 // redirect stdout / stderr
-process.__defineGetter__('stdout', () => { return access});
-process.__defineGetter__('stderr', () => { return error});
+process.__defineGetter__('stdout', () => { return accessStream});
+process.__defineGetter__('stderr', () => { return errorStream});
 
-console.log(`Websocket Server started on ${socketPort}`);
+console.log(`${getUnixTime()} [START] Websocket Server started on ${socketPort}`);
 
 websocket.on('connection', (connection) => {
-  SocketActions.onConnect(websocket, connection);
+    SocketActions.onConnect(websocket, connection);
 
-  connection.on('message', (message) => {
-    SocketActions.onMessage(websocket, connection, message);
-  });
-
-  connection.on('close', () => {
-    SocketActions.onClose(websocket, connection);
-  });
+    connection.on('message', (message) => {
+      try {
+        SocketActions.onMessage(websocket, connection, message);
+      } catch (error) {
+        console.log(`${getUnixTime()} [ERROR] ${error}`);
+        sendMail('[ERROR]', error);
+      }
+    });
+
+    connection.on('close', () => {
+      SocketActions.onClose(websocket, connection);
+    });
 });

backend/src/websocket/sessions.js

@@ -10,6 +10,8 @@ const User = require('./user');
 const Session = require('./session');
 const fs = require('fs');
 const { ROOT_FOLDER } = require('../config');
+const { sendMail } = require('../mail');
+const { timeStamp } = require('console');
 
 const sessions = {};
 
@@ -39,8 +41,10 @@ const checkSessionsAlive = () => {
     const session = sessions[sessionKey];
     if ((session.userA && session.userA.lastAction < currentTime - 2400)
       || (session.userB && session.userB.lastAction < currentTime - 2400)
-    )
+    ) {
+      sendMail('[Timeout]', JSON.stringify(session));
       endGame(session, 'none after timeout');
+    }
   });
 }