Add support for testing SMTP connections in the settings UI.

cmd/handlers.go

@@ -68,6 +68,7 @@ func initHTTPHandlers(e *echo.Echo, app *App) {
 
 	g.GET("/api/settings", handleGetSettings)
 	g.PUT("/api/settings", handleUpdateSettings)
+	g.POST("/api/settings/smtp/test", handleTestSMTPSettings)
 	g.POST("/api/admin/reload", handleReloadApp)
 	g.GET("/api/logs", handleGetLogs)
 

cmd/settings.go

@@ -1,13 +1,20 @@
 package main
 
 import (
+	"bytes"
+	"io/ioutil"
 	"net/http"
 	"regexp"
 	"strings"
 	"syscall"
 	"time"
 
 	"github.com/gofrs/uuid"
+	"github.com/knadh/koanf"
+	"github.com/knadh/koanf/parsers/json"
+	"github.com/knadh/koanf/providers/rawbytes"
+	"github.com/knadh/listmonk/internal/messenger"
+	"github.com/knadh/listmonk/internal/messenger/email"
 	"github.com/knadh/listmonk/models"
 	"github.com/labstack/echo/v4"
 )
@@ -193,3 +200,62 @@ func handleGetLogs(c echo.Context) error {
 	app := c.Get("app").(*App)
 	return c.JSON(http.StatusOK, okResp{app.bufLog.Lines()})
 }
+
+// handleTestSMTPSettings returns the log entries stored in the log buffer.
+func handleTestSMTPSettings(c echo.Context) error {
+	app := c.Get("app").(*App)
+
+	// Copy the raw JSON post body.
+	reqBody, err := ioutil.ReadAll(c.Request().Body)
+	if err != nil {
+		app.log.Printf("error reading SMTP test: %v", err)
+		return echo.NewHTTPError(http.StatusBadRequest, app.i18n.Ts("globals.messages.internalError"))
+	}
+
+	// Load the JSON into koanf to parse SMTP settings properly including timestrings.
+	ko := koanf.New(".")
+	if err := ko.Load(rawbytes.Provider(reqBody), json.Parser()); err != nil {
+		app.log.Printf("error unmarshalling SMTP test request: %v", err)
+		return echo.NewHTTPError(http.StatusBadRequest, app.i18n.Ts("globals.messages.internalError"))
+	}
+
+	req := email.Server{}
+	if err := ko.UnmarshalWithConf("", &req, koanf.UnmarshalConf{Tag: "json"}); err != nil {
+		app.log.Printf("error scanning SMTP test request: %v", err)
+		return echo.NewHTTPError(http.StatusBadRequest, app.i18n.Ts("globals.messages.internalError"))
+	}
+
+	to := ko.String("email")
+	if to == "" {
+		return echo.NewHTTPError(http.StatusBadRequest, app.i18n.Ts("globals.messages.missingFields", "name", "email"))
+	}
+
+	// Initialize a new SMTP pool.
+	req.MaxConns = 1
+	req.IdleTimeout = time.Second * 2
+	req.PoolWaitTimeout = time.Second * 2
+	msgr, err := email.New(req)
+	if err != nil {
+		return echo.NewHTTPError(http.StatusBadRequest,
+			app.i18n.Ts("globals.messages.errorCreating", "name", "SMTP", "error", err.Error()))
+	}
+
+	var b bytes.Buffer
+	if err := app.notifTpls.tpls.ExecuteTemplate(&b, "smtp-test", nil); err != nil {
+		app.log.Printf("error compiling notification template '%s': %v", "smtp-test", err)
+		return err
+	}
+
+	m := messenger.Message{}
+	m.ContentType = app.notifTpls.contentType
+	m.From = app.constants.FromEmail
+	m.To = []string{to}
+	m.Subject = app.i18n.T("settings.smtp.testConnection")
+	m.Body = b.Bytes()
+	if err := msgr.Push(m); err != nil {
+		app.log.Printf("error sending SMTP test (%s): %v", m.Subject, err)
+		return echo.NewHTTPError(http.StatusInternalServerError, err.Error())
+	}
+
+	return c.JSON(http.StatusOK, okResp{app.bufLog.Lines()})
+}

frontend/src/api/index.js

@@ -277,6 +277,9 @@ export const getSettings = async () => http.get('/api/settings',
 export const updateSettings = async (data) => http.put('/api/settings', data,
   { loading: models.settings });
 
+export const testSMTP = async (data) => http.post('/api/settings/smtp/test', data,
+  { loading: models.settings, disableToast: true });
+
 export const getLogs = async () => http.get('/api/logs',
   { loading: models.logs, camelCase: false });
 

frontend/src/utils.js

@@ -141,12 +141,14 @@ export default class Utils {
     });
   };
 
-  prompt = (msg, inputAttrs, onConfirm, onCancel) => {
+  prompt = (msg, inputAttrs, onConfirm, onCancel, params) => {
+    const p = params || {};
+
     Dialog.prompt({
       scroll: 'keep',
       message: this.escapeHTML(msg),
-      confirmText: this.i18n.t('globals.buttons.ok'),
-      cancelText: this.i18n.t('globals.buttons.cancel'),
+      confirmText: p.confirmText || this.i18n.t('globals.buttons.ok'),
+      cancelText: p.cancelText || this.i18n.t('globals.buttons.cancel'),
       inputAttrs: {
         type: 'string',
         maxlength: 200,

frontend/src/views/settings/smtp.vue

@@ -134,29 +134,63 @@
                 </b-field>
               </div>
             </div>
-            <hr />
 
-            <div>
-              <p v-if="item.email_headers.length === 0 && !item.showHeaders">
-                <a href="#" class="is-size-7" @click.prevent="() => showSMTPHeaders(n)">
-                  <b-icon icon="plus" />{{ $t('settings.smtp.setCustomHeaders') }}</a>
-              </p>
-              <b-field v-if="item.email_headers.length > 0 || item.showHeaders"
-                label-position="on-border"
-                :message="$t('settings.smtp.customHeadersHelp')">
-                <b-input v-model="item.strEmailHeaders" name="email_headers" type="textarea"
-                  placeholder='[{"X-Custom": "value"}, {"X-Custom2": "value"}]' />
-              </b-field>
+            <div class="columns">
+              <div class="column">
+                <p v-if="item.email_headers.length === 0 && !item.showHeaders">
+                  <a href="#" class="is-size-7" @click.prevent="() => showSMTPHeaders(n)">
+                    <b-icon icon="plus" />{{ $t('settings.smtp.setCustomHeaders') }}</a>
+                </p>
+                <b-field v-if="item.email_headers.length > 0 || item.showHeaders"
+                  label-position="on-border"
+                  :message="$t('settings.smtp.customHeadersHelp')">
+                  <b-input v-model="item.strEmailHeaders" name="email_headers" type="textarea"
+                    placeholder='[{"X-Custom": "value"}, {"X-Custom2": "value"}]' />
+                </b-field>
+              </div>
             </div>
+            <hr />
+
+            <form @submit.prevent="() => doSMTPTest(item)">
+              <div class="columns">
+                <template v-if="smtpTestItem === n">
+                  <div class="column is-5">
+                    <strong>{{ $t('settings.general.fromEmail') }}</strong>
+                    <br />
+                    {{ settings['app.from_email'] }}
+                  </div>
+                  <div class="column is-4">
+                    <b-field :label="$t('settings.smtp.toEmail')" label-position="on-border">
+                      <b-input type="email" required v-model="testEmail"
+                        :ref="'testEmailTo'" placeholder="[email protected]"
+                        :custom-class="`test-email-${n}`" />
+                    </b-field>
+                  </div>
+                </template>
+                <div class="column has-text-right">
+                  <b-button v-if="smtpTestItem === n" class="is-primary"
+                    :disabled="isTestEnabled(item)" @click.prevent="() => doSMTPTest(item)">
+                    {{ $t('settings.smtp.sendTest') }}
+                  </b-button>
+                  <a href="#" v-else class="is-primary" @click.prevent="showTestForm(n)">
+                    <b-icon icon="rocket-launch-outline" /> {{ $t('settings.smtp.testConnection') }}
+                  </a>
+                </div>
+                <div class="columns">
+                  <div class="column">
+                  </div>
+                </div>
+              </div>
+              <div v-if="errMsg && smtpTestItem === n">
+                <b-field class="mt-4" type="is-danger">
+                  <b-input v-model="errMsg" type="textarea"
+                    custom-class="has-text-danger is-size-6" readonly />
+                </b-field>
+              </div>
+            </form><!-- smtp test -->
+
           </div>
         </div><!-- second container column -->
-        <div class="columns">
-          <div class="column has-text-right">
-            <b-button class="is-primary" @click.prevent="testConnection(item)">
-              {{ $t('settings.smtp.testConnection') }}
-            </b-button>
-          </div>
-        </div>
       </div><!-- block -->
     </div><!-- mail-servers -->
 
@@ -168,6 +202,7 @@
 
 <script>
 import Vue from 'vue';
+import { mapState } from 'vuex';
 import { regDuration } from '../../constants';
 
 export default Vue.extend({
@@ -181,6 +216,11 @@ export default Vue.extend({
     return {
       data: this.form,
       regDuration,
+      // Index of the SMTP block item in the array to show the
+      // test form in.
+      smtpTestItem: null,
+      testEmail: '',
+      errMsg: '',
     };
   },
 
@@ -219,9 +259,48 @@ export default Vue.extend({
       this.data.smtp.splice(i, 1, s);
     },
 
-    testConnection(c) {
-      alert(c);
+    testConnection() {
+      let em = this.settings['app.from_email'].replace('>', '').split('<');
+      if (em.length > 1) {
+        em = `<${em[em.length - 1]}>`;
+      }
     },
+
+    doSMTPTest(item) {
+      this.errMsg = '';
+      this.$api.testSMTP({ ...item, email: this.testEmail }).then(() => {
+        this.$utils.toast(this.$t('campaigns.testSent'));
+      }).catch((err) => {
+        if (err.response?.data?.message) {
+          this.errMsg = err.response.data.message;
+        }
+      });
+    },
+
+    showTestForm(n) {
+      this.smtpTestItem = n;
+      this.testItem = this.form.smtp[n];
+      this.errMsg = '';
+
+      this.$nextTick(() => {
+        document.querySelector(`.test-email-${n}`).focus();
+      });
+    },
+
+    isTestEnabled(item) {
+      if (!item.host || !item.port) {
+        return true;
+      }
+      if (item.auth_protocol !== 'none' && !item.password.trim()) {
+        return true;
+      }
+
+      return false;
+    },
+  },
+
+  computed: {
+    ...mapState(['settings']),
   },
 });
 </script>

go.mod

@@ -15,7 +15,7 @@ require (
 	github.com/knadh/go-pop3 v0.3.0
 	github.com/knadh/goyesql/v2 v2.1.2
 	github.com/knadh/koanf v1.2.3
-	github.com/knadh/smtppool v0.4.0
+	github.com/knadh/smtppool v1.0.0
 	github.com/knadh/stuffbin v1.1.0
 	github.com/labstack/echo/v4 v4.6.1
 	github.com/labstack/gommon v0.3.1 // indirect

go.sum

@@ -84,6 +84,8 @@ github.com/knadh/koanf v1.2.3 h1:2Rkr0YhhYk+4QEOm800Q3Pu0Wi87svTxM6uuEb4WhYw=
 github.com/knadh/koanf v1.2.3/go.mod h1:xpPTwMhsA/aaQLAilyCCqfpEiY1gpa160AiCuWHJUjY=
 github.com/knadh/smtppool v0.4.0 h1:335iXPwZ6katJVhauV4O6e8uPvvPmO6YLrfDQhb6UvE=
 github.com/knadh/smtppool v0.4.0/go.mod h1:3DJHouXAgPDBz0kC50HukOsdapYSwIEfJGwuip46oCA=
+github.com/knadh/smtppool v1.0.0 h1:1c8A7+nD8WdMMzvd3yY5aoY9QBgyGTA+Iq1IdlgKGJw=
+github.com/knadh/smtppool v1.0.0/go.mod h1:3DJHouXAgPDBz0kC50HukOsdapYSwIEfJGwuip46oCA=
 github.com/knadh/stuffbin v1.1.0 h1:f5S5BHzZALjuJEgTIOMC9NidEnBJM7Ze6Lu1GHR/lwU=
 github.com/knadh/stuffbin v1.1.0/go.mod h1:yVCFaWaKPubSNibBsTAJ939q2ABHudJQxRWZWV5yh+4=
 github.com/kr/pty v1.1.1/go.mod h1:pFQYn66WHrOpPYNljwOMqo10TkYh1fy3cYio2l3bCsQ=

i18n/cs-cz.json

@@ -452,7 +452,10 @@
     "settings.smtp.name": "SMTP",
     "settings.smtp.retries": "Opakování",
     "settings.smtp.retriesHelp": "Počet opakovaných pokusů, když zpráva selže.",
+    "settings.smtp.sendTest": "Send e-mail",
     "settings.smtp.setCustomHeaders": "Nastavit vlastní záhlaví",
+    "settings.smtp.testConnection": "Test connection",
+    "settings.smtp.toEmail": "To e-mail",
     "settings.title": "Nastavení",
     "settings.updateAvailable": "Nová aktualizace {version} je k dispozici.",
     "subscribers.advancedQuery": "Rozšířené",

i18n/de.json

@@ -452,7 +452,10 @@
     "settings.smtp.name": "SMTP",
     "settings.smtp.retries": "Wiederholungen",
     "settings.smtp.retriesHelp": "Maximale Anzahl an Wiederholungen, wenn eine Machricht fehlschlägt.",
+    "settings.smtp.sendTest": "Send e-mail",
     "settings.smtp.setCustomHeaders": "Benutzerdefinierten Header verwenden",
+    "settings.smtp.testConnection": "Test connection",
+    "settings.smtp.toEmail": "To e-mail",
     "settings.title": "Einstellungen",
     "settings.updateAvailable": "Ein neues Update auf {version} ist verfügbar.",
     "subscribers.advancedQuery": "Erweitert",

i18n/en.json

@@ -452,8 +452,10 @@
     "settings.smtp.name": "SMTP",
     "settings.smtp.retries": "Retries",
     "settings.smtp.retriesHelp": "Number of times to retry when a message fails.",
+    "settings.smtp.sendTest": "Send e-mail",
     "settings.smtp.setCustomHeaders": "Set custom headers",
     "settings.smtp.testConnection": "Test connection",
+    "settings.smtp.toEmail": "To e-mail",
     "settings.title": "Settings",
     "settings.updateAvailable": "A new update {version} is available.",
     "subscribers.advancedQuery": "Advanced",

i18n/es.json

@@ -452,7 +452,10 @@
     "settings.smtp.name": "SMTP",
     "settings.smtp.retries": "Reintentos",
     "settings.smtp.retriesHelp": "Número de reintentos cuando un mensaje falla.",
+    "settings.smtp.sendTest": "Send e-mail",
     "settings.smtp.setCustomHeaders": "Configurar encabezados personalizados.",
+    "settings.smtp.testConnection": "Test connection",
+    "settings.smtp.toEmail": "To e-mail",
     "settings.title": "Configuraciones",
     "settings.updateAvailable": "Una actualización {version} está disponible.",
     "subscribers.advancedQuery": "Avanzado",

i18n/fi.json

@@ -452,7 +452,10 @@
     "settings.smtp.name": "SMTP",
     "settings.smtp.retries": "Retries",
     "settings.smtp.retriesHelp": "Number of times to retry when a message fails.",
+    "settings.smtp.sendTest": "Send e-mail",
     "settings.smtp.setCustomHeaders": "Set custom headers",
+    "settings.smtp.testConnection": "Test connection",
+    "settings.smtp.toEmail": "To e-mail",
     "settings.title": "Settings",
     "settings.updateAvailable": "A new update {version} is available.",
     "subscribers.advancedQuery": "Advanced",

i18n/fr.json

@@ -452,7 +452,10 @@
     "settings.smtp.name": "SMTP",
     "settings.smtp.retries": "Tentatives de renvoi",
     "settings.smtp.retriesHelp": "Nombre de tentatives de renvoi d'un message en cas d'échec",
+    "settings.smtp.sendTest": "Send e-mail",
     "settings.smtp.setCustomHeaders": "Définir des en-têtes personnalisés",
+    "settings.smtp.testConnection": "Test connection",
+    "settings.smtp.toEmail": "To e-mail",
     "settings.title": "Paramètres",
     "settings.updateAvailable": "Une nouvelle version ({version}) est disponible.",
     "subscribers.advancedQuery": "Requête avancée",

i18n/hu.json

@@ -452,7 +452,10 @@
     "settings.smtp.name": "SMTP",
     "settings.smtp.retries": "Újrapróbálkozások",
     "settings.smtp.retriesHelp": "Az újrapróbálkozások száma, ha az üzenet sikertelen.",
+    "settings.smtp.sendTest": "Send e-mail",
     "settings.smtp.setCustomHeaders": "Egyéni fejlécek beállítása",
+    "settings.smtp.testConnection": "Test connection",
+    "settings.smtp.toEmail": "To e-mail",
     "settings.title": "Beállítások",
     "settings.updateAvailable": "Új frissítés {version} elérhető.",
     "subscribers.advancedQuery": "További beállítások",

i18n/it.json

@@ -452,7 +452,10 @@
     "settings.smtp.name": "SMTP",
     "settings.smtp.retries": "Tentativi",
     "settings.smtp.retriesHelp": "Numero di tentativi in caso di errore invio messaggio.",
+    "settings.smtp.sendTest": "Send e-mail",
     "settings.smtp.setCustomHeaders": "Definisci intestazioni personalizzate",
+    "settings.smtp.testConnection": "Test connection",
+    "settings.smtp.toEmail": "To e-mail",
     "settings.title": "Impostazioni",
     "settings.updateAvailable": "È a disposizione una nuova versione {version}.",
     "subscribers.advancedQuery": "Avanzate",

i18n/jp.json

@@ -452,7 +452,10 @@
     "settings.smtp.name": "SMTP",
     "settings.smtp.retries": "再トライ",
     "settings.smtp.retriesHelp": "メッセージ送信失敗時の再試行数",
+    "settings.smtp.sendTest": "Send e-mail",
     "settings.smtp.setCustomHeaders": "カスタムヘッダー設定",
+    "settings.smtp.testConnection": "Test connection",
+    "settings.smtp.toEmail": "To e-mail",
     "settings.title": "設定",
     "settings.updateAvailable": "新しい {バージョン} の更新が可能です。",
     "subscribers.advancedQuery": "アドバンスド",