fix: fixed port issue with mx forwarding, added safeguard for port (int)

forwardemail · Dec 7, 2024 · 86ad862 · 86ad862
1 parent b6b3476
commit 86ad862
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 4 deletions.
diff --git a/app/controllers/api/v1/inquiries.js b/app/controllers/api/v1/inquiries.js
@@ -10,10 +10,10 @@ const _ = require('lodash');
 const { isEmail } = require('validator');
 const { Headers } = require('mailsplit');
 
-const { decrypt } = require('./encrypt-decrypt');
 const config = require('#config');
 const env = require('#config/env');
 const { Inquiries, Users } = require('#models');
+const { decrypt } = require('#helpers/encrypt-decrypt');
 
 const webhookSignatureKey = env.WEBHOOK_SIGNATURE_KEY;
 const WEBHOOK_SIGNATURE_HEADER = 'X-Webhook-Signature';

diff --git a/helpers/get-recipients.js b/helpers/get-recipients.js
@@ -40,7 +40,7 @@ async function getRecipients(session, scan) {
     session.envelope.rcptTo,
     // eslint-disable-next-line complexity
     async (to) => {
-      let port = '25';
+      let port = 25;
       try {
         let hasAdultContentProtection = true;
         let hasPhishingProtection = true;
@@ -146,7 +146,7 @@ async function getRecipients(session, scan) {
         if (_.isObject(body)) {
           // `port` (String) - a valid port number, defaults to 25
           if (isSANB(body.port) && isPort(body.port) && body.port !== '25') {
-            port = body.port;
+            port = Number.parseInt(body.port, 10);
             logger.debug(`Custom port for ${to.address} detected`, {
               port,
               session

diff --git a/helpers/get-transporter.js b/helpers/get-transporter.js
@@ -98,6 +98,9 @@ async function getTransporter(options = {}, err) {
     // client
   } = options;
 
+  // safeguard to ensure port is always a number
+  if (typeof port === 'string') throw new TypeError('Port must be a number');
+
   let mx = {
     host: target,
     port
@@ -109,7 +112,7 @@ async function getTransporter(options = {}, err) {
   //
 
   // this is required since custom port forwarding would be recursive otherwise
-  if (env.NODE_ENV === 'test' || port === 25) {
+  if (port === 25) {
     // <https://github.com/zone-eu/mx-connect#configuration-options>
     mx = await asyncMxConnect({
       ignoreMXHosts,