mirror of
https://github.com/decke/smtprelay.git
synced 2025-12-26 08:52:33 -07:00
Compare commits
85 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
5ba64c5c6e | ||
|
|
7f34fcbc99 | ||
|
|
97943c87e7 | ||
|
|
fefeccec39 | ||
|
|
c781938999 | ||
|
|
009ae8f73a | ||
|
|
70dfe6b128 | ||
|
|
7fa0eebf95 | ||
|
|
ecf830865c | ||
|
|
4fd6bb1004 | ||
|
|
fd3f513b18 | ||
|
|
b202a2209e | ||
|
|
0e8986ca79 | ||
|
|
5c2e28ac36 | ||
|
|
f33105f83c | ||
|
|
9040a456cf | ||
|
|
d5c5e25d03 | ||
|
|
999cfea307 | ||
|
|
f166c13350 | ||
|
|
ed1c3a9888 | ||
|
|
6f3bd16988 | ||
|
|
4e0bf0908d | ||
|
|
6662fb7155 | ||
|
|
076fd65dea | ||
|
|
880c3c365c | ||
|
|
36673ae3f0 | ||
|
|
b42ad6ddc9 | ||
|
|
999ccab778 | ||
|
|
53c2c27647 | ||
|
|
2afbe67407 | ||
|
|
00b96161b3 | ||
|
|
e10cbcdbb0 | ||
|
|
0e643f7230 | ||
|
|
324585c63c | ||
|
|
92cb02e46b | ||
|
|
62fcc11f61 | ||
|
|
bfe8d39bb3 | ||
|
|
cbb6f523c5 | ||
|
|
eb4a6b9eb6 | ||
|
|
45db4ef786 | ||
|
|
946effcbcf | ||
|
|
118d1b88c2 | ||
|
|
5fd6aad9b1 | ||
|
|
21b597f351 | ||
|
|
5f82b4736c | ||
|
|
de430286b3 | ||
|
|
769193ea4d | ||
|
|
0b65e904d8 | ||
|
|
2c9645ac68 | ||
|
|
770e819e2b | ||
|
|
d11f8d81ea | ||
|
|
6270d75571 | ||
|
|
92be537b25 | ||
|
|
b9d1663a18 | ||
|
|
3a96014c70 | ||
|
|
ade7cbca36 | ||
|
|
ab341c697d | ||
|
|
ab850e8765 | ||
|
|
a82b0faf96 | ||
|
|
76a04a2001 | ||
|
|
0df376e54a | ||
|
|
c05e5779a8 | ||
|
|
3c1d683edc | ||
|
|
83b558239a | ||
|
|
571e9ea942 | ||
|
|
38aa14ddbf | ||
|
|
72dad9fb70 | ||
|
|
e01895f25a | ||
|
|
a0e357c0de | ||
|
|
3d648a2ce7 | ||
|
|
66fb86be7a | ||
|
|
1d1c617161 | ||
|
|
e87b1e7168 | ||
|
|
926c681bdf | ||
|
|
dbe4c3bc50 | ||
|
|
6427f0ec23 | ||
|
|
a5f3c2bd3f | ||
|
|
b03ecbb02d | ||
|
|
3b643b3927 | ||
|
|
88d85458dc | ||
|
|
58d124b20d | ||
|
|
646103d157 | ||
|
|
5004734404 | ||
|
|
72fe85dea9 | ||
|
|
b55f5569b9 |
66
.github/workflows/codeql-analysis.yml
vendored
Normal file
66
.github/workflows/codeql-analysis.yml
vendored
Normal file
@@ -0,0 +1,66 @@
|
|||||||
|
name: "CodeQL"
|
||||||
|
|
||||||
|
on:
|
||||||
|
push:
|
||||||
|
branches: [master]
|
||||||
|
pull_request:
|
||||||
|
# The branches below must be a subset of the branches above
|
||||||
|
branches: [master]
|
||||||
|
schedule:
|
||||||
|
- cron: '0 15 * * 5'
|
||||||
|
|
||||||
|
jobs:
|
||||||
|
analyze:
|
||||||
|
name: Analyze
|
||||||
|
runs-on: ubuntu-latest
|
||||||
|
|
||||||
|
strategy:
|
||||||
|
fail-fast: false
|
||||||
|
matrix:
|
||||||
|
# Override automatic language detection by changing the below list
|
||||||
|
# Supported options are ['csharp', 'cpp', 'go', 'java', 'javascript', 'python']
|
||||||
|
language: ['go']
|
||||||
|
# Learn more...
|
||||||
|
# https://docs.github.com/en/github/finding-security-vulnerabilities-and-errors-in-your-code/configuring-code-scanning#overriding-automatic-language-detection
|
||||||
|
|
||||||
|
steps:
|
||||||
|
- name: Checkout repository
|
||||||
|
uses: actions/checkout@v2
|
||||||
|
with:
|
||||||
|
# We must fetch at least the immediate parents so that if this is
|
||||||
|
# a pull request then we can checkout the head.
|
||||||
|
fetch-depth: 2
|
||||||
|
|
||||||
|
# If this run was triggered by a pull request event, then checkout
|
||||||
|
# the head of the pull request instead of the merge commit.
|
||||||
|
- run: git checkout HEAD^2
|
||||||
|
if: ${{ github.event_name == 'pull_request' }}
|
||||||
|
|
||||||
|
# Initializes the CodeQL tools for scanning.
|
||||||
|
- name: Initialize CodeQL
|
||||||
|
uses: github/codeql-action/init@v1
|
||||||
|
with:
|
||||||
|
languages: ${{ matrix.language }}
|
||||||
|
# If you wish to specify custom queries, you can do so here or in a config file.
|
||||||
|
# By default, queries listed here will override any specified in a config file.
|
||||||
|
# Prefix the list here with "+" to use these queries and those in the config file.
|
||||||
|
# queries: ./path/to/local/query, your-org/your-repo/queries@main
|
||||||
|
|
||||||
|
# Autobuild attempts to build any compiled languages (C/C++, C#, or Java).
|
||||||
|
# If this step fails, then you should remove it and run the build manually (see below)
|
||||||
|
- name: Autobuild
|
||||||
|
uses: github/codeql-action/autobuild@v1
|
||||||
|
|
||||||
|
# ℹ️ Command-line programs to run using the OS shell.
|
||||||
|
# 📚 https://git.io/JvXDl
|
||||||
|
|
||||||
|
# ✏️ If the Autobuild fails above, remove it and uncomment the following three lines
|
||||||
|
# and modify them (or add more) to build your code if your project
|
||||||
|
# uses a compiled language
|
||||||
|
|
||||||
|
#- run: |
|
||||||
|
# make bootstrap
|
||||||
|
# make release
|
||||||
|
|
||||||
|
- name: Perform CodeQL Analysis
|
||||||
|
uses: github/codeql-action/analyze@v1
|
||||||
24
.github/workflows/go.yml
vendored
Normal file
24
.github/workflows/go.yml
vendored
Normal file
@@ -0,0 +1,24 @@
|
|||||||
|
name: Go
|
||||||
|
on: [push]
|
||||||
|
jobs:
|
||||||
|
|
||||||
|
build:
|
||||||
|
name: Build
|
||||||
|
runs-on: ubuntu-latest
|
||||||
|
steps:
|
||||||
|
|
||||||
|
- name: Set up Go 1.14
|
||||||
|
uses: actions/setup-go@v1
|
||||||
|
with:
|
||||||
|
go-version: 1.14
|
||||||
|
id: go
|
||||||
|
|
||||||
|
- name: Check out code into the Go module directory
|
||||||
|
uses: actions/checkout@v1
|
||||||
|
|
||||||
|
- name: Get dependencies
|
||||||
|
run: |
|
||||||
|
go get -v -t -d ./...
|
||||||
|
|
||||||
|
- name: Build
|
||||||
|
run: go build -v .
|
||||||
30
.github/workflows/release.yaml
vendored
Normal file
30
.github/workflows/release.yaml
vendored
Normal file
@@ -0,0 +1,30 @@
|
|||||||
|
name: Release Go Binaries
|
||||||
|
|
||||||
|
on:
|
||||||
|
release:
|
||||||
|
types: [created]
|
||||||
|
|
||||||
|
jobs:
|
||||||
|
releases-matrix:
|
||||||
|
name: Release Go Binary
|
||||||
|
runs-on: ubuntu-latest
|
||||||
|
strategy:
|
||||||
|
matrix:
|
||||||
|
goos: [freebsd, linux, windows]
|
||||||
|
goarch: ["386", amd64]
|
||||||
|
steps:
|
||||||
|
- uses: actions/checkout@v2
|
||||||
|
|
||||||
|
- name: Set APP_VERSION env
|
||||||
|
run: echo APP_VERSION=$(echo ${GITHUB_REF} | rev | cut -d'/' -f 1 | rev ) >> ${GITHUB_ENV}
|
||||||
|
- name: Set BUILD_TIME env
|
||||||
|
run: echo BUILD_TIME=$(date) >> ${GITHUB_ENV}
|
||||||
|
|
||||||
|
- uses: wangyoucao577/go-release-action@v1.14
|
||||||
|
with:
|
||||||
|
github_token: ${{ secrets.GITHUB_TOKEN }}
|
||||||
|
goos: ${{ matrix.goos }}
|
||||||
|
goarch: ${{ matrix.goarch }}
|
||||||
|
goversion: "https://golang.org/dl/go1.15.8.linux-amd64.tar.gz"
|
||||||
|
extra_files: LICENSE README.md smtprelay.ini
|
||||||
|
ldflags: -s -w -X "main.appVersion=${{ env.APP_VERSION }}" -X "main.buildTime=${{ env.BUILD_TIME }}"
|
||||||
31
README.md
31
README.md
@@ -1,10 +1,31 @@
|
|||||||
# smtp-proxy
|
# smtprelay
|
||||||
|
|
||||||
|
[](https://goreportcard.com/report/github.com/decke/smtprelay)
|
||||||
|
|
||||||
|
Simple Golang based SMTP relay/proxy server that accepts mail via SMTP
|
||||||
|
and forwards it directly to another SMTP server.
|
||||||
|
|
||||||
|
|
||||||
|
## Why another SMTP server?
|
||||||
|
|
||||||
|
Outgoing mails are usually send via SMTP to an MTA (Mail Transfer Agent)
|
||||||
|
which is one of Postfix, Exim, Sendmail or OpenSMTPD on UNIX/Linux in most
|
||||||
|
cases. You really don't want to setup and maintain any of those full blown
|
||||||
|
kitchensinks yourself because they are complex, fragile and hard to
|
||||||
|
configure.
|
||||||
|
|
||||||
|
My use case is simple. I need to send automatically generated mails from
|
||||||
|
cron via msmtp/sSMTP/dma, mails from various services and network printers
|
||||||
|
to GMail without giving away my GMail credentials to each device which
|
||||||
|
produces mail.
|
||||||
|
|
||||||
Simple Go SMTP relay/proxy server that accepts mails via SMTP
|
|
||||||
and forwards directly to another SMTP server.
|
|
||||||
|
|
||||||
## Main features
|
## Main features
|
||||||
|
|
||||||
* STARTTLS/TLS support
|
* Supports SMTPS/TLS (465), STARTTLS (587) and unencrypted SMTP (25)
|
||||||
|
* Checks for sender, receiver, client IP
|
||||||
|
* Authentication support with file (LOGIN, PLAIN)
|
||||||
|
* Enforce encryption for authentication
|
||||||
|
* Forwards all mail to a smarthost (GMail, MailGun or any other SMTP server)
|
||||||
|
* Small codebase
|
||||||
* IPv6 support
|
* IPv6 support
|
||||||
* Forward to GMail, MailGun or any other SMTP server
|
|
||||||
|
|||||||
100
auth.go
Normal file
100
auth.go
Normal file
@@ -0,0 +1,100 @@
|
|||||||
|
package main
|
||||||
|
|
||||||
|
import (
|
||||||
|
"bufio"
|
||||||
|
"errors"
|
||||||
|
"os"
|
||||||
|
"strings"
|
||||||
|
|
||||||
|
"golang.org/x/crypto/bcrypt"
|
||||||
|
)
|
||||||
|
|
||||||
|
var (
|
||||||
|
filename string
|
||||||
|
)
|
||||||
|
|
||||||
|
type AuthUser struct {
|
||||||
|
username string
|
||||||
|
passwordHash string
|
||||||
|
allowedAddresses []string
|
||||||
|
}
|
||||||
|
|
||||||
|
func AuthLoadFile(file string) error {
|
||||||
|
f, err := os.Open(file)
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
f.Close()
|
||||||
|
|
||||||
|
filename = file
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func AuthReady() bool {
|
||||||
|
return (filename != "")
|
||||||
|
}
|
||||||
|
|
||||||
|
// Split a string and ignore empty results
|
||||||
|
// https://stackoverflow.com/a/46798310/119527
|
||||||
|
func splitstr(s string, sep rune) []string {
|
||||||
|
return strings.FieldsFunc(s, func(c rune) bool { return c == sep })
|
||||||
|
}
|
||||||
|
|
||||||
|
func parseLine(line string) *AuthUser {
|
||||||
|
parts := strings.Fields(line)
|
||||||
|
|
||||||
|
if len(parts) < 2 || len(parts) > 3 {
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
user := AuthUser{
|
||||||
|
username: parts[0],
|
||||||
|
passwordHash: parts[1],
|
||||||
|
allowedAddresses: nil,
|
||||||
|
}
|
||||||
|
|
||||||
|
if len(parts) >= 3 {
|
||||||
|
user.allowedAddresses = splitstr(parts[2], ',')
|
||||||
|
}
|
||||||
|
|
||||||
|
return &user
|
||||||
|
}
|
||||||
|
|
||||||
|
func AuthFetch(username string) (*AuthUser, error) {
|
||||||
|
if !AuthReady() {
|
||||||
|
return nil, errors.New("Authentication file not specified. Call LoadFile() first")
|
||||||
|
}
|
||||||
|
|
||||||
|
file, err := os.Open(filename)
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
defer file.Close()
|
||||||
|
|
||||||
|
scanner := bufio.NewScanner(file)
|
||||||
|
for scanner.Scan() {
|
||||||
|
user := parseLine(scanner.Text())
|
||||||
|
if user == nil {
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
|
||||||
|
if strings.ToLower(username) != strings.ToLower(user.username) {
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
|
||||||
|
return user, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
return nil, errors.New("User not found")
|
||||||
|
}
|
||||||
|
|
||||||
|
func AuthCheckPassword(username string, secret string) error {
|
||||||
|
user, err := AuthFetch(username)
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
if bcrypt.CompareHashAndPassword([]byte(user.passwordHash), []byte(secret)) == nil {
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
return errors.New("Password invalid")
|
||||||
|
}
|
||||||
89
auth_test.go
Normal file
89
auth_test.go
Normal file
@@ -0,0 +1,89 @@
|
|||||||
|
package main
|
||||||
|
|
||||||
|
import (
|
||||||
|
"testing"
|
||||||
|
)
|
||||||
|
|
||||||
|
func stringsEqual(a, b []string) bool {
|
||||||
|
if len(a) != len(b) {
|
||||||
|
return false
|
||||||
|
}
|
||||||
|
for i := range a {
|
||||||
|
if a[i] != b[i] {
|
||||||
|
return false
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return true
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestParseLine(t *testing.T) {
|
||||||
|
var tests = []struct {
|
||||||
|
name string
|
||||||
|
expectFail bool
|
||||||
|
line string
|
||||||
|
username string
|
||||||
|
addrs []string
|
||||||
|
}{
|
||||||
|
{
|
||||||
|
name: "Empty line",
|
||||||
|
expectFail: true,
|
||||||
|
line: "",
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: "Too few fields",
|
||||||
|
expectFail: true,
|
||||||
|
line: "joe",
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: "Too many fields",
|
||||||
|
expectFail: true,
|
||||||
|
line: "joe xxx joe@example.com whatsthis",
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: "Normal case",
|
||||||
|
line: "joe xxx joe@example.com",
|
||||||
|
username: "joe",
|
||||||
|
addrs: []string{"joe@example.com"},
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: "No allowed addrs given",
|
||||||
|
line: "joe xxx",
|
||||||
|
username: "joe",
|
||||||
|
addrs: []string{},
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: "Trailing comma",
|
||||||
|
line: "joe xxx joe@example.com,",
|
||||||
|
username: "joe",
|
||||||
|
addrs: []string{"joe@example.com"},
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: "Multiple allowed addrs",
|
||||||
|
line: "joe xxx joe@example.com,@foo.example.com",
|
||||||
|
username: "joe",
|
||||||
|
addrs: []string{"joe@example.com", "@foo.example.com"},
|
||||||
|
},
|
||||||
|
}
|
||||||
|
|
||||||
|
for i, test := range tests {
|
||||||
|
t.Run(test.name, func(t *testing.T) {
|
||||||
|
user := parseLine(test.line)
|
||||||
|
if user == nil {
|
||||||
|
if !test.expectFail {
|
||||||
|
t.Errorf("parseLine() returned nil unexpectedly")
|
||||||
|
}
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
if user.username != test.username {
|
||||||
|
t.Errorf("Testcase %d: Incorrect username: expected %v, got %v",
|
||||||
|
i, test.username, user.username)
|
||||||
|
}
|
||||||
|
|
||||||
|
if !stringsEqual(user.allowedAddresses, test.addrs) {
|
||||||
|
t.Errorf("Testcase %d: Incorrect addresses: expected %v, got %v",
|
||||||
|
i, test.addrs, user.allowedAddresses)
|
||||||
|
}
|
||||||
|
})
|
||||||
|
}
|
||||||
|
}
|
||||||
6
cmd/README.md
Normal file
6
cmd/README.md
Normal file
@@ -0,0 +1,6 @@
|
|||||||
|
|
||||||
|
To run the hasher, do like this
|
||||||
|
|
||||||
|
```bash
|
||||||
|
$ go run hasher.go hunter2
|
||||||
|
```
|
||||||
22
cmd/hasher.go
Normal file
22
cmd/hasher.go
Normal file
@@ -0,0 +1,22 @@
|
|||||||
|
package main
|
||||||
|
|
||||||
|
import (
|
||||||
|
"fmt"
|
||||||
|
"os"
|
||||||
|
|
||||||
|
"golang.org/x/crypto/bcrypt"
|
||||||
|
)
|
||||||
|
|
||||||
|
func main() {
|
||||||
|
if len(os.Args) != 2 {
|
||||||
|
fmt.Fprintln(os.Stderr, "Usage: hasher PASSWORD")
|
||||||
|
os.Exit(1)
|
||||||
|
}
|
||||||
|
password := os.Args[1]
|
||||||
|
|
||||||
|
hash, err := bcrypt.GenerateFromPassword([]byte(password), bcrypt.DefaultCost)
|
||||||
|
if err != nil {
|
||||||
|
fmt.Fprintln(os.Stderr, "Error generating hash: %s", err)
|
||||||
|
}
|
||||||
|
fmt.Println(string(hash))
|
||||||
|
}
|
||||||
36
config.go
Normal file
36
config.go
Normal file
@@ -0,0 +1,36 @@
|
|||||||
|
package main
|
||||||
|
|
||||||
|
import (
|
||||||
|
"flag"
|
||||||
|
|
||||||
|
"github.com/vharitonsky/iniflags"
|
||||||
|
)
|
||||||
|
|
||||||
|
var (
|
||||||
|
appVersion = "unknown"
|
||||||
|
buildTime = "unknown"
|
||||||
|
)
|
||||||
|
|
||||||
|
var (
|
||||||
|
logFile = flag.String("logfile", "/var/log/smtprelay.log", "Path to logfile")
|
||||||
|
hostName = flag.String("hostname", "localhost.localdomain", "Server hostname")
|
||||||
|
welcomeMsg = flag.String("welcome_msg", "", "Welcome message for SMTP session")
|
||||||
|
listen = flag.String("listen", "127.0.0.1:25 [::1]:25", "Address and port to listen for incoming SMTP")
|
||||||
|
localCert = flag.String("local_cert", "", "SSL certificate for STARTTLS/TLS")
|
||||||
|
localKey = flag.String("local_key", "", "SSL private key for STARTTLS/TLS")
|
||||||
|
localForceTLS = flag.Bool("local_forcetls", false, "Force STARTTLS (needs local_cert and local_key)")
|
||||||
|
allowedNets = flag.String("allowed_nets", "127.0.0.1/8 ::1/128", "Networks allowed to send mails")
|
||||||
|
allowedSender = flag.String("allowed_sender", "", "Regular expression for valid FROM EMail addresses")
|
||||||
|
allowedRecipients = flag.String("allowed_recipients", "", "Regular expression for valid TO EMail addresses")
|
||||||
|
allowedUsers = flag.String("allowed_users", "", "Path to file with valid users/passwords")
|
||||||
|
remoteHost = flag.String("remote_host", "smtp.gmail.com:587", "Outgoing SMTP server")
|
||||||
|
remoteUser = flag.String("remote_user", "", "Username for authentication on outgoing SMTP server")
|
||||||
|
remotePass = flag.String("remote_pass", "", "Password for authentication on outgoing SMTP server")
|
||||||
|
remoteAuth = flag.String("remote_auth", "plain", "Auth method on outgoing SMTP server (plain, login)")
|
||||||
|
remoteSender = flag.String("remote_sender", "", "Sender e-mail address on outgoing SMTP server")
|
||||||
|
versionInfo = flag.Bool("version", false, "Show version information")
|
||||||
|
)
|
||||||
|
|
||||||
|
func ConfigLoad() {
|
||||||
|
iniflags.Parse()
|
||||||
|
}
|
||||||
7
go.mod
7
go.mod
@@ -1,6 +1,9 @@
|
|||||||
module code.bluelife.at/decke/smtp-proxy
|
module github.com/decke/smtprelay
|
||||||
|
|
||||||
require (
|
require (
|
||||||
github.com/chrj/smtpd v0.1.1
|
github.com/chrj/smtpd v0.2.0
|
||||||
github.com/vharitonsky/iniflags v0.0.0-20180513140207-a33cd0b5f3de
|
github.com/vharitonsky/iniflags v0.0.0-20180513140207-a33cd0b5f3de
|
||||||
|
golang.org/x/crypto v0.0.0-20201221181555-eec23a3978ad
|
||||||
)
|
)
|
||||||
|
|
||||||
|
go 1.13
|
||||||
|
|||||||
12
go.sum
12
go.sum
@@ -1,5 +1,13 @@
|
|||||||
github.com/chrj/smtpd v0.1.1 h1:Jk9ZimOh4njDpMbDLPmdQX+x9AUYGrfE68EyjuQDPjk=
|
github.com/chrj/smtpd v0.2.0 h1:QGbE4UQz7sKjvXpRgNLuiBOjcWTzBKu/dj0hyDLpD14=
|
||||||
github.com/chrj/smtpd v0.1.1/go.mod h1:jt4ydELuZmqhn9hn3YpEPV1dY00aOB+Q1nWXnBDFKeY=
|
github.com/chrj/smtpd v0.2.0/go.mod h1:1hmG9KbrE10JG1SmvG79Krh4F6713oUrw2+gRp1oSYk=
|
||||||
github.com/eaigner/dkim v0.0.0-20150301120808-6fe4a7ee9cfb/go.mod h1:FSCIHbrqk7D01Mj8y/jW+NS1uoCerr+ad+IckTHTFf4=
|
github.com/eaigner/dkim v0.0.0-20150301120808-6fe4a7ee9cfb/go.mod h1:FSCIHbrqk7D01Mj8y/jW+NS1uoCerr+ad+IckTHTFf4=
|
||||||
github.com/vharitonsky/iniflags v0.0.0-20180513140207-a33cd0b5f3de h1:fkw+7JkxF3U1GzQoX9h69Wvtvxajo5Rbzy6+YMMzPIg=
|
github.com/vharitonsky/iniflags v0.0.0-20180513140207-a33cd0b5f3de h1:fkw+7JkxF3U1GzQoX9h69Wvtvxajo5Rbzy6+YMMzPIg=
|
||||||
github.com/vharitonsky/iniflags v0.0.0-20180513140207-a33cd0b5f3de/go.mod h1:irMhzlTz8+fVFj6CH2AN2i+WI5S6wWFtK3MBCIxIpyI=
|
github.com/vharitonsky/iniflags v0.0.0-20180513140207-a33cd0b5f3de/go.mod h1:irMhzlTz8+fVFj6CH2AN2i+WI5S6wWFtK3MBCIxIpyI=
|
||||||
|
golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
|
||||||
|
golang.org/x/crypto v0.0.0-20201221181555-eec23a3978ad h1:DN0cp81fZ3njFcrLCytUHRSUkqBjfTo4Tx9RJTWs0EY=
|
||||||
|
golang.org/x/crypto v0.0.0-20201221181555-eec23a3978ad/go.mod h1:jdWPYTVW3xRLrWPugEBEK3UY2ZEsg3UU495nc5E+M+I=
|
||||||
|
golang.org/x/net v0.0.0-20190404232315-eb5bcb51f2a3/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
|
||||||
|
golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
|
||||||
|
golang.org/x/sys v0.0.0-20191026070338-33540a1f6037/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
|
||||||
|
golang.org/x/term v0.0.0-20201117132131-f5c789dd3221/go.mod h1:Nr5EML6q2oocZ2LXRh80K7BxOlk5/8JxuGnuhpl+muw=
|
||||||
|
golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
|
||||||
|
|||||||
303
main.go
303
main.go
@@ -2,88 +2,307 @@ package main
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
"crypto/tls"
|
"crypto/tls"
|
||||||
"flag"
|
"fmt"
|
||||||
|
"io"
|
||||||
"log"
|
"log"
|
||||||
"net"
|
"net"
|
||||||
"net/smtp"
|
"net/smtp"
|
||||||
|
"os"
|
||||||
|
"regexp"
|
||||||
"strings"
|
"strings"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
"github.com/chrj/smtpd"
|
"github.com/chrj/smtpd"
|
||||||
"github.com/vharitonsky/iniflags"
|
|
||||||
)
|
)
|
||||||
|
|
||||||
var (
|
func connectionChecker(peer smtpd.Peer) error {
|
||||||
hostName = flag.String("hostname", "localhost.localdomain", "Server hostname")
|
var peerIP net.IP
|
||||||
welcomeMsg = flag.String("welcome_msg", "", "Welcome message for SMTP session")
|
if addr, ok := peer.Addr.(*net.TCPAddr); ok {
|
||||||
listen = flag.String("listen", "127.0.0.1:25 [::1]:25", "Address and port to listen for incoming SMTP")
|
peerIP = net.ParseIP(addr.IP.String())
|
||||||
localCert = flag.String("local_cert", "", "SSL certificate for STARTTLS/TLS")
|
} else {
|
||||||
localKey = flag.String("local_key", "", "SSL private key for STARTTLS/TLS")
|
return smtpd.Error{Code: 421, Message: "Denied"}
|
||||||
localForceTLS = flag.Bool("local_forcetls", false, "Force STARTTLS (needs local_cert and local_key)")
|
}
|
||||||
remoteHost = flag.String("remote_host", "smtp.gmail.com:587", "Outgoing SMTP server")
|
|
||||||
remoteUser = flag.String("remote_user", "", "Username for authentication on outgoing SMTP server")
|
|
||||||
remotePass = flag.String("remote_pass", "", "Password for authentication on outgoing SMTP server")
|
|
||||||
)
|
|
||||||
|
|
||||||
func handler(peer smtpd.Peer, env smtpd.Envelope) error {
|
nets := strings.Split(*allowedNets, " ")
|
||||||
|
|
||||||
|
for i := range nets {
|
||||||
|
_, allowedNet, _ := net.ParseCIDR(nets[i])
|
||||||
|
|
||||||
|
if allowedNet.Contains(peerIP) {
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
log.Printf("Connection from peer=[%s] denied: Not in allowed_nets\n", peerIP)
|
||||||
|
return smtpd.Error{Code: 421, Message: "Denied"}
|
||||||
|
}
|
||||||
|
|
||||||
|
func addrAllowed(addr string, allowedAddrs []string) bool {
|
||||||
|
if allowedAddrs == nil {
|
||||||
|
// If absent, all addresses are allowed
|
||||||
|
return true
|
||||||
|
}
|
||||||
|
|
||||||
|
addr = strings.ToLower(addr)
|
||||||
|
|
||||||
|
// Extract optional domain part
|
||||||
|
domain := ""
|
||||||
|
if idx := strings.LastIndex(addr, "@"); idx != -1 {
|
||||||
|
domain = strings.ToLower(addr[idx+1:])
|
||||||
|
}
|
||||||
|
|
||||||
|
// Test each address from allowedUsers file
|
||||||
|
for _, allowedAddr := range allowedAddrs {
|
||||||
|
allowedAddr = strings.ToLower(allowedAddr)
|
||||||
|
|
||||||
|
// Three cases for allowedAddr format:
|
||||||
|
if idx := strings.Index(allowedAddr, "@"); idx == -1 {
|
||||||
|
// 1. local address (no @) -- must match exactly
|
||||||
|
if allowedAddr == addr {
|
||||||
|
return true
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
if idx != 0 {
|
||||||
|
// 2. email address (user@domain.com) -- must match exactly
|
||||||
|
if allowedAddr == addr {
|
||||||
|
return true
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
// 3. domain (@domain.com) -- must match addr domain
|
||||||
|
allowedDomain := allowedAddr[idx+1:]
|
||||||
|
if allowedDomain == domain {
|
||||||
|
return true
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return false
|
||||||
|
}
|
||||||
|
|
||||||
|
func senderChecker(peer smtpd.Peer, addr string) error {
|
||||||
|
// check sender address from auth file if user is authenticated
|
||||||
|
if *allowedUsers != "" && peer.Username != "" {
|
||||||
|
user, err := AuthFetch(peer.Username)
|
||||||
|
if err != nil {
|
||||||
|
// Shouldn't happen: authChecker already validated username+password
|
||||||
|
return smtpd.Error{Code: 451, Message: "Bad sender address"}
|
||||||
|
}
|
||||||
|
|
||||||
|
if !addrAllowed(addr, user.allowedAddresses) {
|
||||||
|
log.Printf("Mail from=<%s> not allowed for authenticated user %s (%v)\n",
|
||||||
|
addr, peer.Username, peer.Addr)
|
||||||
|
return smtpd.Error{Code: 451, Message: "Bad sender address"}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if *allowedSender == "" {
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
re, err := regexp.Compile(*allowedSender)
|
||||||
|
if err != nil {
|
||||||
|
log.Printf("allowed_sender invalid: %v\n", err)
|
||||||
|
return smtpd.Error{Code: 451, Message: "Bad sender address"}
|
||||||
|
}
|
||||||
|
|
||||||
|
if re.MatchString(addr) {
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
log.Printf("Mail from=<%s> not allowed by allowed_sender pattern for peer %v\n",
|
||||||
|
addr, peer.Addr)
|
||||||
|
return smtpd.Error{Code: 451, Message: "Bad sender address"}
|
||||||
|
}
|
||||||
|
|
||||||
|
func recipientChecker(peer smtpd.Peer, addr string) error {
|
||||||
|
if *allowedRecipients == "" {
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
re, err := regexp.Compile(*allowedRecipients)
|
||||||
|
if err != nil {
|
||||||
|
log.Printf("allowed_recipients invalid: %v\n", err)
|
||||||
|
return smtpd.Error{Code: 451, Message: "Bad recipient address"}
|
||||||
|
}
|
||||||
|
|
||||||
|
if re.MatchString(addr) {
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
log.Printf("Mail to=<%s> not allowed by allowed_recipients pattern for peer %v\n",
|
||||||
|
addr, peer.Addr)
|
||||||
|
return smtpd.Error{Code: 451, Message: "Bad recipient address"}
|
||||||
|
}
|
||||||
|
|
||||||
|
func authChecker(peer smtpd.Peer, username string, password string) error {
|
||||||
|
err := AuthCheckPassword(username, password)
|
||||||
|
if err != nil {
|
||||||
|
log.Printf("Auth error for peer %v: %v\n", peer.Addr, err)
|
||||||
|
return smtpd.Error{Code: 535, Message: "Authentication credentials invalid"}
|
||||||
|
}
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func mailHandler(peer smtpd.Peer, env smtpd.Envelope) error {
|
||||||
|
peerIP := ""
|
||||||
|
if addr, ok := peer.Addr.(*net.TCPAddr); ok {
|
||||||
|
peerIP = addr.IP.String()
|
||||||
|
}
|
||||||
|
|
||||||
|
log.Printf("new mail from=<%s> to=%s peer=[%s]\n", env.Sender,
|
||||||
|
env.Recipients, peerIP)
|
||||||
|
|
||||||
var auth smtp.Auth
|
var auth smtp.Auth
|
||||||
host, _, _ := net.SplitHostPort(*remoteHost)
|
host, _, _ := net.SplitHostPort(*remoteHost)
|
||||||
|
|
||||||
if *remoteUser != "" && *remotePass != "" {
|
if *remoteUser != "" && *remotePass != "" {
|
||||||
auth = smtp.PlainAuth("", *remoteUser, *remotePass, host)
|
switch *remoteAuth {
|
||||||
|
case "plain":
|
||||||
|
auth = smtp.PlainAuth("", *remoteUser, *remotePass, host)
|
||||||
|
case "login":
|
||||||
|
auth = LoginAuth(*remoteUser, *remotePass)
|
||||||
|
default:
|
||||||
|
return smtpd.Error{Code: 530, Message: "Authentication method not supported"}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
return smtp.SendMail(
|
env.AddReceivedLine(peer)
|
||||||
|
|
||||||
|
log.Printf("delivering using smarthost %s\n", *remoteHost)
|
||||||
|
|
||||||
|
var sender string
|
||||||
|
|
||||||
|
if *remoteSender == "" {
|
||||||
|
sender = env.Sender
|
||||||
|
} else {
|
||||||
|
sender = *remoteSender
|
||||||
|
}
|
||||||
|
|
||||||
|
err := SendMail(
|
||||||
*remoteHost,
|
*remoteHost,
|
||||||
auth,
|
auth,
|
||||||
env.Sender,
|
sender,
|
||||||
env.Recipients,
|
env.Recipients,
|
||||||
env.Data,
|
env.Data,
|
||||||
)
|
)
|
||||||
|
if err != nil {
|
||||||
|
log.Printf("delivery failed: %v\n", err)
|
||||||
|
return smtpd.Error{Code: 554, Message: "Forwarding failed"}
|
||||||
|
}
|
||||||
|
|
||||||
|
log.Printf("%s delivery successful\n", env.Recipients)
|
||||||
|
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func getTLSConfig() *tls.Config {
|
||||||
|
// Ciphersuites as defined in stock Go but without 3DES and RC4
|
||||||
|
// https://golang.org/src/crypto/tls/cipher_suites.go
|
||||||
|
var tlsCipherSuites = []uint16{
|
||||||
|
tls.TLS_AES_128_GCM_SHA256,
|
||||||
|
tls.TLS_AES_256_GCM_SHA384,
|
||||||
|
tls.TLS_CHACHA20_POLY1305_SHA256,
|
||||||
|
tls.TLS_ECDHE_RSA_WITH_CHACHA20_POLY1305_SHA256,
|
||||||
|
tls.TLS_ECDHE_ECDSA_WITH_CHACHA20_POLY1305_SHA256,
|
||||||
|
tls.TLS_ECDHE_RSA_WITH_AES_128_GCM_SHA256,
|
||||||
|
tls.TLS_ECDHE_ECDSA_WITH_AES_128_GCM_SHA256,
|
||||||
|
tls.TLS_ECDHE_RSA_WITH_AES_256_GCM_SHA384,
|
||||||
|
tls.TLS_ECDHE_ECDSA_WITH_AES_256_GCM_SHA384,
|
||||||
|
tls.TLS_RSA_WITH_AES_128_GCM_SHA256, // does not provide PFS
|
||||||
|
tls.TLS_RSA_WITH_AES_256_GCM_SHA384, // does not provide PFS
|
||||||
|
}
|
||||||
|
|
||||||
|
if *localCert == "" || *localKey == "" {
|
||||||
|
log.Fatal("TLS certificate/key not defined in config")
|
||||||
|
}
|
||||||
|
|
||||||
|
cert, err := tls.LoadX509KeyPair(*localCert, *localKey)
|
||||||
|
if err != nil {
|
||||||
|
log.Fatal(err)
|
||||||
|
}
|
||||||
|
|
||||||
|
return &tls.Config{
|
||||||
|
PreferServerCipherSuites: true,
|
||||||
|
MinVersion: tls.VersionTLS12,
|
||||||
|
CipherSuites: tlsCipherSuites,
|
||||||
|
Certificates: []tls.Certificate{cert},
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func main() {
|
func main() {
|
||||||
|
ConfigLoad()
|
||||||
|
|
||||||
iniflags.Parse()
|
if *versionInfo {
|
||||||
|
fmt.Printf("smtprelay/%s (%s)\n", appVersion, buildTime)
|
||||||
|
os.Exit(0)
|
||||||
|
}
|
||||||
|
|
||||||
listeners := strings.Split(*listen, " ")
|
if *logFile != "" {
|
||||||
|
f, err := os.OpenFile(*logFile, os.O_WRONLY|os.O_CREATE|os.O_APPEND, 0600)
|
||||||
|
if err != nil {
|
||||||
|
log.Fatalf("Error opening logfile: %v", err)
|
||||||
|
}
|
||||||
|
defer f.Close()
|
||||||
|
|
||||||
for i := range(listeners) {
|
log.SetOutput(io.MultiWriter(os.Stdout, f))
|
||||||
listener := listeners[i]
|
}
|
||||||
|
|
||||||
|
// Load allowed users file
|
||||||
|
if *allowedUsers != "" {
|
||||||
|
err := AuthLoadFile(*allowedUsers)
|
||||||
|
if err != nil {
|
||||||
|
log.Fatalf("Authentication file: %s\n", err)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// Create a server for each desired listen address
|
||||||
|
for _, listenAddr := range strings.Split(*listen, " ") {
|
||||||
server := &smtpd.Server{
|
server := &smtpd.Server{
|
||||||
Hostname: *hostName,
|
Hostname: *hostName,
|
||||||
WelcomeMessage: *welcomeMsg,
|
WelcomeMessage: *welcomeMsg,
|
||||||
Handler: handler,
|
ConnectionChecker: connectionChecker,
|
||||||
|
SenderChecker: senderChecker,
|
||||||
|
RecipientChecker: recipientChecker,
|
||||||
|
Handler: mailHandler,
|
||||||
}
|
}
|
||||||
|
|
||||||
if strings.Index(listeners[i], "://") == -1 {
|
if *allowedUsers != "" {
|
||||||
;
|
server.Authenticator = authChecker
|
||||||
} else if strings.HasPrefix(listeners[i], "tls://") || strings.HasPrefix(listeners[i], "starttls://") {
|
}
|
||||||
|
|
||||||
listener = strings.TrimPrefix(listener, "tls://")
|
var lsnr net.Listener
|
||||||
listener = strings.TrimPrefix(listener, "starttls://")
|
var err error
|
||||||
|
|
||||||
if *localCert == "" || *localKey == "" {
|
if strings.Index(listenAddr, "://") == -1 {
|
||||||
log.Fatal("TLS certificate/key not defined in config")
|
log.Printf("Listen on %s ...\n", listenAddr)
|
||||||
}
|
|
||||||
|
|
||||||
cert, err := tls.LoadX509KeyPair(*localCert, *localKey)
|
lsnr, err = net.Listen("tcp", listenAddr)
|
||||||
if err != nil {
|
} else if strings.HasPrefix(listenAddr, "starttls://") {
|
||||||
log.Fatal(err)
|
listenAddr = strings.TrimPrefix(listenAddr, "starttls://")
|
||||||
}
|
|
||||||
|
|
||||||
|
server.TLSConfig = getTLSConfig()
|
||||||
server.ForceTLS = *localForceTLS
|
server.ForceTLS = *localForceTLS
|
||||||
server.TLSConfig = &tls.Config {
|
|
||||||
Certificates: [] tls.Certificate{cert},
|
log.Printf("Listen on %s (STARTTLS) ...\n", listenAddr)
|
||||||
}
|
lsnr, err = net.Listen("tcp", listenAddr)
|
||||||
|
} else if strings.HasPrefix(listenAddr, "tls://") {
|
||||||
|
listenAddr = strings.TrimPrefix(listenAddr, "tls://")
|
||||||
|
|
||||||
|
server.TLSConfig = getTLSConfig()
|
||||||
|
|
||||||
|
log.Printf("Listen on %s (TLS) ...\n", listenAddr)
|
||||||
|
lsnr, err = tls.Listen("tcp", listenAddr, server.TLSConfig)
|
||||||
} else {
|
} else {
|
||||||
log.Fatal("Unknown protocol in listener ", listener)
|
log.Fatal("Unknown protocol in listen address ", listenAddr)
|
||||||
}
|
}
|
||||||
|
|
||||||
log.Printf("Listen on %s ...\n", listener)
|
if err != nil {
|
||||||
go server.ListenAndServe(listener)
|
log.Fatal(err)
|
||||||
|
}
|
||||||
|
defer lsnr.Close()
|
||||||
|
|
||||||
|
go server.Serve(lsnr)
|
||||||
}
|
}
|
||||||
|
|
||||||
for true {
|
for true {
|
||||||
|
|||||||
94
main_test.go
Normal file
94
main_test.go
Normal file
@@ -0,0 +1,94 @@
|
|||||||
|
package main
|
||||||
|
|
||||||
|
import (
|
||||||
|
"testing"
|
||||||
|
)
|
||||||
|
|
||||||
|
func TestAddrAllowedNoDomain(t *testing.T) {
|
||||||
|
allowedAddrs := []string{"joe@abc.com"}
|
||||||
|
if addrAllowed("bob.com", allowedAddrs) {
|
||||||
|
t.FailNow()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestAddrAllowedSingle(t *testing.T) {
|
||||||
|
allowedAddrs := []string{"joe@abc.com"}
|
||||||
|
|
||||||
|
if !addrAllowed("joe@abc.com", allowedAddrs) {
|
||||||
|
t.FailNow()
|
||||||
|
}
|
||||||
|
if addrAllowed("bob@abc.com", allowedAddrs) {
|
||||||
|
t.FailNow()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestAddrAllowedDifferentCase(t *testing.T) {
|
||||||
|
allowedAddrs := []string{"joe@abc.com"}
|
||||||
|
testAddrs := []string{
|
||||||
|
"joe@ABC.com",
|
||||||
|
"Joe@abc.com",
|
||||||
|
"JOE@abc.com",
|
||||||
|
"JOE@ABC.COM",
|
||||||
|
}
|
||||||
|
for _, addr := range testAddrs {
|
||||||
|
if !addrAllowed(addr, allowedAddrs) {
|
||||||
|
t.Errorf("Address %v not allowed, but should be", addr)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestAddrAllowedLocal(t *testing.T) {
|
||||||
|
allowedAddrs := []string{"joe"}
|
||||||
|
|
||||||
|
if !addrAllowed("joe", allowedAddrs) {
|
||||||
|
t.FailNow()
|
||||||
|
}
|
||||||
|
if addrAllowed("bob", allowedAddrs) {
|
||||||
|
t.FailNow()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestAddrAllowedMulti(t *testing.T) {
|
||||||
|
allowedAddrs := []string{"joe@abc.com", "bob@def.com"}
|
||||||
|
if !addrAllowed("joe@abc.com", allowedAddrs) {
|
||||||
|
t.FailNow()
|
||||||
|
}
|
||||||
|
if !addrAllowed("bob@def.com", allowedAddrs) {
|
||||||
|
t.FailNow()
|
||||||
|
}
|
||||||
|
if addrAllowed("bob@abc.com", allowedAddrs) {
|
||||||
|
t.FailNow()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestAddrAllowedSingleDomain(t *testing.T) {
|
||||||
|
allowedAddrs := []string{"@abc.com"}
|
||||||
|
if !addrAllowed("joe@abc.com", allowedAddrs) {
|
||||||
|
t.FailNow()
|
||||||
|
}
|
||||||
|
if addrAllowed("joe@def.com", allowedAddrs) {
|
||||||
|
t.FailNow()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestAddrAllowedMixed(t *testing.T) {
|
||||||
|
allowedAddrs := []string{"app", "app@example.com", "@appsrv.example.com"}
|
||||||
|
if !addrAllowed("app", allowedAddrs) {
|
||||||
|
t.FailNow()
|
||||||
|
}
|
||||||
|
if !addrAllowed("app@example.com", allowedAddrs) {
|
||||||
|
t.FailNow()
|
||||||
|
}
|
||||||
|
if addrAllowed("ceo@example.com", allowedAddrs) {
|
||||||
|
t.FailNow()
|
||||||
|
}
|
||||||
|
if !addrAllowed("root@appsrv.example.com", allowedAddrs) {
|
||||||
|
t.FailNow()
|
||||||
|
}
|
||||||
|
if !addrAllowed("dev@appsrv.example.com", allowedAddrs) {
|
||||||
|
t.FailNow()
|
||||||
|
}
|
||||||
|
if addrAllowed("appsrv@example.com", allowedAddrs) {
|
||||||
|
t.FailNow()
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -1,37 +0,0 @@
|
|||||||
; smtp-proxy configuration
|
|
||||||
|
|
||||||
; Hostname for this SMTP server
|
|
||||||
;hostname = "localhost.localdomain"
|
|
||||||
|
|
||||||
; Welcome message for clients
|
|
||||||
;welcome_msg = "<hostname> ESMTP ready."
|
|
||||||
|
|
||||||
; Listen on the following addresses for incoming
|
|
||||||
; unencrypted connections.
|
|
||||||
;listen = 127.0.0.1:25 [::1]:25
|
|
||||||
|
|
||||||
; STARTTLS and TLS are also supported but need a
|
|
||||||
; SSL certificate and key.
|
|
||||||
;listen = tls://127.0.0.1:465 tls://[::1]:465
|
|
||||||
;listen = starttls://127.0.0.1:587 starttls://[::1]:587
|
|
||||||
;local_cert = smtpd.pem
|
|
||||||
;local_key = smtpd.key
|
|
||||||
|
|
||||||
; Enforce encrypted connection on STARTTLS ports before
|
|
||||||
; accepting mails from client.
|
|
||||||
;local_forcetls = false
|
|
||||||
|
|
||||||
; Relay all mails to this SMTP server
|
|
||||||
|
|
||||||
; GMail
|
|
||||||
;remote_host = smtp.gmail.com:587
|
|
||||||
|
|
||||||
; Mailgun.org
|
|
||||||
;remote_host = smtp.mailgun.org:587
|
|
||||||
|
|
||||||
; Mailjet.com
|
|
||||||
;remote_host = in-v3.mailjet.com:587
|
|
||||||
|
|
||||||
; Authentication credentials on outgoing SMTP server
|
|
||||||
;remote_user =
|
|
||||||
;remote_pass =
|
|
||||||
480
smtp.go
Normal file
480
smtp.go
Normal file
@@ -0,0 +1,480 @@
|
|||||||
|
// Copyright 2010 The Go Authors. All rights reserved.
|
||||||
|
// Use of this source code is governed by a BSD-style
|
||||||
|
// license that can be found in the LICENSE file.
|
||||||
|
|
||||||
|
// Package smtp implements the Simple Mail Transfer Protocol as defined in RFC 5321.
|
||||||
|
// It also implements the following extensions:
|
||||||
|
// 8BITMIME RFC 1652
|
||||||
|
// AUTH RFC 2554
|
||||||
|
// STARTTLS RFC 3207
|
||||||
|
// Additional extensions may be handled by clients.
|
||||||
|
//
|
||||||
|
// The smtp package is frozen and is not accepting new features.
|
||||||
|
// Some external packages provide more functionality. See:
|
||||||
|
//
|
||||||
|
// https://godoc.org/?q=smtp
|
||||||
|
package main
|
||||||
|
|
||||||
|
import (
|
||||||
|
"crypto/tls"
|
||||||
|
"encoding/base64"
|
||||||
|
"errors"
|
||||||
|
"fmt"
|
||||||
|
"io"
|
||||||
|
"net"
|
||||||
|
"net/smtp"
|
||||||
|
"net/textproto"
|
||||||
|
"strings"
|
||||||
|
)
|
||||||
|
|
||||||
|
// A Client represents a client connection to an SMTP server.
|
||||||
|
type Client struct {
|
||||||
|
// Text is the textproto.Conn used by the Client. It is exported to allow for
|
||||||
|
// clients to add extensions.
|
||||||
|
Text *textproto.Conn
|
||||||
|
// keep a reference to the connection so it can be used to create a TLS
|
||||||
|
// connection later
|
||||||
|
conn net.Conn
|
||||||
|
// whether the Client is using TLS
|
||||||
|
tls bool
|
||||||
|
serverName string
|
||||||
|
// map of supported extensions
|
||||||
|
ext map[string]string
|
||||||
|
// supported auth mechanisms
|
||||||
|
auth []string
|
||||||
|
localName string // the name to use in HELO/EHLO
|
||||||
|
didHello bool // whether we've said HELO/EHLO
|
||||||
|
helloError error // the error from the hello
|
||||||
|
}
|
||||||
|
|
||||||
|
// Dial returns a new Client connected to an SMTP server at addr.
|
||||||
|
// The addr must include a port, as in "mail.example.com:smtp".
|
||||||
|
func Dial(addr string) (*Client, error) {
|
||||||
|
conn, err := net.Dial("tcp", addr)
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
host, _, _ := net.SplitHostPort(addr)
|
||||||
|
return NewClient(conn, host)
|
||||||
|
}
|
||||||
|
|
||||||
|
// NewClient returns a new Client using an existing connection and host as a
|
||||||
|
// server name to be used when authenticating.
|
||||||
|
func NewClient(conn net.Conn, host string) (*Client, error) {
|
||||||
|
text := textproto.NewConn(conn)
|
||||||
|
_, _, err := text.ReadResponse(220)
|
||||||
|
if err != nil {
|
||||||
|
text.Close()
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
c := &Client{Text: text, conn: conn, serverName: host, localName: *hostName}
|
||||||
|
_, c.tls = conn.(*tls.Conn)
|
||||||
|
return c, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
// Close closes the connection.
|
||||||
|
func (c *Client) Close() error {
|
||||||
|
return c.Text.Close()
|
||||||
|
}
|
||||||
|
|
||||||
|
// hello runs a hello exchange if needed.
|
||||||
|
func (c *Client) hello() error {
|
||||||
|
if !c.didHello {
|
||||||
|
c.didHello = true
|
||||||
|
err := c.ehlo()
|
||||||
|
if err != nil {
|
||||||
|
c.helloError = c.helo()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return c.helloError
|
||||||
|
}
|
||||||
|
|
||||||
|
// Hello sends a HELO or EHLO to the server as the given host name.
|
||||||
|
// Calling this method is only necessary if the client needs control
|
||||||
|
// over the host name used. The client will introduce itself as "localhost"
|
||||||
|
// automatically otherwise. If Hello is called, it must be called before
|
||||||
|
// any of the other methods.
|
||||||
|
func (c *Client) Hello(localName string) error {
|
||||||
|
if err := validateLine(localName); err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
if c.didHello {
|
||||||
|
return errors.New("smtp: Hello called after other methods")
|
||||||
|
}
|
||||||
|
c.localName = localName
|
||||||
|
return c.hello()
|
||||||
|
}
|
||||||
|
|
||||||
|
// cmd is a convenience function that sends a command and returns the response
|
||||||
|
func (c *Client) cmd(expectCode int, format string, args ...interface{}) (int, string, error) {
|
||||||
|
id, err := c.Text.Cmd(format, args...)
|
||||||
|
if err != nil {
|
||||||
|
return 0, "", err
|
||||||
|
}
|
||||||
|
c.Text.StartResponse(id)
|
||||||
|
defer c.Text.EndResponse(id)
|
||||||
|
code, msg, err := c.Text.ReadResponse(expectCode)
|
||||||
|
return code, msg, err
|
||||||
|
}
|
||||||
|
|
||||||
|
// helo sends the HELO greeting to the server. It should be used only when the
|
||||||
|
// server does not support ehlo.
|
||||||
|
func (c *Client) helo() error {
|
||||||
|
c.ext = nil
|
||||||
|
_, _, err := c.cmd(250, "HELO %s", c.localName)
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
// ehlo sends the EHLO (extended hello) greeting to the server. It
|
||||||
|
// should be the preferred greeting for servers that support it.
|
||||||
|
func (c *Client) ehlo() error {
|
||||||
|
_, msg, err := c.cmd(250, "EHLO %s", c.localName)
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
ext := make(map[string]string)
|
||||||
|
extList := strings.Split(msg, "\n")
|
||||||
|
if len(extList) > 1 {
|
||||||
|
extList = extList[1:]
|
||||||
|
for _, line := range extList {
|
||||||
|
args := strings.SplitN(line, " ", 2)
|
||||||
|
if len(args) > 1 {
|
||||||
|
ext[args[0]] = args[1]
|
||||||
|
} else {
|
||||||
|
ext[args[0]] = ""
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if mechs, ok := ext["AUTH"]; ok {
|
||||||
|
c.auth = strings.Split(mechs, " ")
|
||||||
|
}
|
||||||
|
c.ext = ext
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
// StartTLS sends the STARTTLS command and encrypts all further communication.
|
||||||
|
// Only servers that advertise the STARTTLS extension support this function.
|
||||||
|
func (c *Client) StartTLS(config *tls.Config) error {
|
||||||
|
if err := c.hello(); err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
_, _, err := c.cmd(220, "STARTTLS")
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
c.conn = tls.Client(c.conn, config)
|
||||||
|
c.Text = textproto.NewConn(c.conn)
|
||||||
|
c.tls = true
|
||||||
|
return c.ehlo()
|
||||||
|
}
|
||||||
|
|
||||||
|
// TLSConnectionState returns the client's TLS connection state.
|
||||||
|
// The return values are their zero values if StartTLS did
|
||||||
|
// not succeed.
|
||||||
|
func (c *Client) TLSConnectionState() (state tls.ConnectionState, ok bool) {
|
||||||
|
tc, ok := c.conn.(*tls.Conn)
|
||||||
|
if !ok {
|
||||||
|
return
|
||||||
|
}
|
||||||
|
return tc.ConnectionState(), true
|
||||||
|
}
|
||||||
|
|
||||||
|
// Verify checks the validity of an email address on the server.
|
||||||
|
// If Verify returns nil, the address is valid. A non-nil return
|
||||||
|
// does not necessarily indicate an invalid address. Many servers
|
||||||
|
// will not verify addresses for security reasons.
|
||||||
|
func (c *Client) Verify(addr string) error {
|
||||||
|
if err := validateLine(addr); err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
if err := c.hello(); err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
_, _, err := c.cmd(250, "VRFY %s", addr)
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
// Auth authenticates a client using the provided authentication mechanism.
|
||||||
|
// A failed authentication closes the connection.
|
||||||
|
// Only servers that advertise the AUTH extension support this function.
|
||||||
|
func (c *Client) Auth(a smtp.Auth) error {
|
||||||
|
if err := c.hello(); err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
encoding := base64.StdEncoding
|
||||||
|
mech, resp, err := a.Start(&smtp.ServerInfo{c.serverName, c.tls, c.auth})
|
||||||
|
if err != nil {
|
||||||
|
c.Quit()
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
resp64 := make([]byte, encoding.EncodedLen(len(resp)))
|
||||||
|
encoding.Encode(resp64, resp)
|
||||||
|
code, msg64, err := c.cmd(0, strings.TrimSpace(fmt.Sprintf("AUTH %s %s", mech, resp64)))
|
||||||
|
for err == nil {
|
||||||
|
var msg []byte
|
||||||
|
switch code {
|
||||||
|
case 334:
|
||||||
|
msg, err = encoding.DecodeString(msg64)
|
||||||
|
case 235:
|
||||||
|
// the last message isn't base64 because it isn't a challenge
|
||||||
|
msg = []byte(msg64)
|
||||||
|
default:
|
||||||
|
err = &textproto.Error{Code: code, Msg: msg64}
|
||||||
|
}
|
||||||
|
if err == nil {
|
||||||
|
resp, err = a.Next(msg, code == 334)
|
||||||
|
}
|
||||||
|
if err != nil {
|
||||||
|
// abort the AUTH
|
||||||
|
c.cmd(501, "*")
|
||||||
|
c.Quit()
|
||||||
|
break
|
||||||
|
}
|
||||||
|
if resp == nil {
|
||||||
|
break
|
||||||
|
}
|
||||||
|
resp64 = make([]byte, encoding.EncodedLen(len(resp)))
|
||||||
|
encoding.Encode(resp64, resp)
|
||||||
|
code, msg64, err = c.cmd(0, string(resp64))
|
||||||
|
}
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
// Mail issues a MAIL command to the server using the provided email address.
|
||||||
|
// If the server supports the 8BITMIME extension, Mail adds the BODY=8BITMIME
|
||||||
|
// parameter.
|
||||||
|
// This initiates a mail transaction and is followed by one or more Rcpt calls.
|
||||||
|
func (c *Client) Mail(from string) error {
|
||||||
|
if err := validateLine(from); err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
if err := c.hello(); err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
cmdStr := "MAIL FROM:<%s>"
|
||||||
|
if c.ext != nil {
|
||||||
|
if _, ok := c.ext["8BITMIME"]; ok {
|
||||||
|
cmdStr += " BODY=8BITMIME"
|
||||||
|
}
|
||||||
|
}
|
||||||
|
_, _, err := c.cmd(250, cmdStr, from)
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
// Rcpt issues a RCPT command to the server using the provided email address.
|
||||||
|
// A call to Rcpt must be preceded by a call to Mail and may be followed by
|
||||||
|
// a Data call or another Rcpt call.
|
||||||
|
func (c *Client) Rcpt(to string) error {
|
||||||
|
if err := validateLine(to); err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
_, _, err := c.cmd(25, "RCPT TO:<%s>", to)
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
type dataCloser struct {
|
||||||
|
c *Client
|
||||||
|
io.WriteCloser
|
||||||
|
}
|
||||||
|
|
||||||
|
func (d *dataCloser) Close() error {
|
||||||
|
d.WriteCloser.Close()
|
||||||
|
_, _, err := d.c.Text.ReadResponse(250)
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
// Data issues a DATA command to the server and returns a writer that
|
||||||
|
// can be used to write the mail headers and body. The caller should
|
||||||
|
// close the writer before calling any more methods on c. A call to
|
||||||
|
// Data must be preceded by one or more calls to Rcpt.
|
||||||
|
func (c *Client) Data() (io.WriteCloser, error) {
|
||||||
|
_, _, err := c.cmd(354, "DATA")
|
||||||
|
if err != nil {
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
return &dataCloser{c, c.Text.DotWriter()}, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
var testHookStartTLS func(*tls.Config) // nil, except for tests
|
||||||
|
|
||||||
|
// SendMail connects to the server at addr with TLS when port 465 or
|
||||||
|
// smtps is specified or unencrypted otherwise and switches to TLS if
|
||||||
|
// possible, authenticates with the optional mechanism a if possible,
|
||||||
|
// and then sends an email from address from, to addresses to, with
|
||||||
|
// message msg.
|
||||||
|
// The addr must include a port, as in "mail.example.com:smtp".
|
||||||
|
//
|
||||||
|
// The addresses in the to parameter are the SMTP RCPT addresses.
|
||||||
|
//
|
||||||
|
// The msg parameter should be an RFC 822-style email with headers
|
||||||
|
// first, a blank line, and then the message body. The lines of msg
|
||||||
|
// should be CRLF terminated. The msg headers should usually include
|
||||||
|
// fields such as "From", "To", "Subject", and "Cc". Sending "Bcc"
|
||||||
|
// messages is accomplished by including an email address in the to
|
||||||
|
// parameter but not including it in the msg headers.
|
||||||
|
//
|
||||||
|
// The SendMail function and the net/smtp package are low-level
|
||||||
|
// mechanisms and provide no support for DKIM signing, MIME
|
||||||
|
// attachments (see the mime/multipart package), or other mail
|
||||||
|
// functionality. Higher-level packages exist outside of the standard
|
||||||
|
// library.
|
||||||
|
func SendMail(addr string, a smtp.Auth, from string, to []string, msg []byte) error {
|
||||||
|
if err := validateLine(from); err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
for _, recp := range to {
|
||||||
|
if err := validateLine(recp); err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
}
|
||||||
|
host, port, err := net.SplitHostPort(addr)
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
var c *Client
|
||||||
|
if port == "465" || port == "smtps" {
|
||||||
|
config := &tls.Config{ServerName: host}
|
||||||
|
conn, err := tls.Dial("tcp", addr, config)
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
defer conn.Close()
|
||||||
|
c, err = NewClient(conn, host)
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
if err = c.hello(); err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
c, err = Dial(addr)
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
defer c.Close()
|
||||||
|
if err = c.hello(); err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
if ok, _ := c.Extension("STARTTLS"); ok {
|
||||||
|
config := &tls.Config{ServerName: c.serverName}
|
||||||
|
if testHookStartTLS != nil {
|
||||||
|
testHookStartTLS(config)
|
||||||
|
}
|
||||||
|
if err = c.StartTLS(config); err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if a != nil && c.ext != nil {
|
||||||
|
if _, ok := c.ext["AUTH"]; !ok {
|
||||||
|
return errors.New("smtp: server doesn't support AUTH")
|
||||||
|
}
|
||||||
|
if err = c.Auth(a); err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if err = c.Mail(from); err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
for _, addr := range to {
|
||||||
|
if err = c.Rcpt(addr); err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
}
|
||||||
|
w, err := c.Data()
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
_, err = w.Write(msg)
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
err = w.Close()
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
return c.Quit()
|
||||||
|
}
|
||||||
|
|
||||||
|
// Extension reports whether an extension is support by the server.
|
||||||
|
// The extension name is case-insensitive. If the extension is supported,
|
||||||
|
// Extension also returns a string that contains any parameters the
|
||||||
|
// server specifies for the extension.
|
||||||
|
func (c *Client) Extension(ext string) (bool, string) {
|
||||||
|
if err := c.hello(); err != nil {
|
||||||
|
return false, ""
|
||||||
|
}
|
||||||
|
if c.ext == nil {
|
||||||
|
return false, ""
|
||||||
|
}
|
||||||
|
ext = strings.ToUpper(ext)
|
||||||
|
param, ok := c.ext[ext]
|
||||||
|
return ok, param
|
||||||
|
}
|
||||||
|
|
||||||
|
// Reset sends the RSET command to the server, aborting the current mail
|
||||||
|
// transaction.
|
||||||
|
func (c *Client) Reset() error {
|
||||||
|
if err := c.hello(); err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
_, _, err := c.cmd(250, "RSET")
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
// Noop sends the NOOP command to the server. It does nothing but check
|
||||||
|
// that the connection to the server is okay.
|
||||||
|
func (c *Client) Noop() error {
|
||||||
|
if err := c.hello(); err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
_, _, err := c.cmd(250, "NOOP")
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
// Quit sends the QUIT command and closes the connection to the server.
|
||||||
|
func (c *Client) Quit() error {
|
||||||
|
if err := c.hello(); err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
_, _, err := c.cmd(221, "QUIT")
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
return c.Text.Close()
|
||||||
|
}
|
||||||
|
|
||||||
|
// validateLine checks to see if a line has CR or LF as per RFC 5321
|
||||||
|
func validateLine(line string) error {
|
||||||
|
if strings.ContainsAny(line, "\n\r") {
|
||||||
|
return errors.New("smtp: A line must not contain CR or LF")
|
||||||
|
}
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
// LOGIN authentication
|
||||||
|
type loginAuth struct {
|
||||||
|
username, password string
|
||||||
|
}
|
||||||
|
|
||||||
|
func LoginAuth(username, password string) smtp.Auth {
|
||||||
|
return &loginAuth{username, password}
|
||||||
|
}
|
||||||
|
|
||||||
|
func (a *loginAuth) Start(server *smtp.ServerInfo) (string, []byte, error) {
|
||||||
|
return "LOGIN", []byte{}, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (a *loginAuth) Next(fromServer []byte, more bool) ([]byte, error) {
|
||||||
|
if more {
|
||||||
|
switch string(fromServer) {
|
||||||
|
case "Username:":
|
||||||
|
return []byte(a.username), nil
|
||||||
|
case "Password:":
|
||||||
|
return []byte(a.password), nil
|
||||||
|
default:
|
||||||
|
return nil, errors.New("Unknown fromServer")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return nil, nil
|
||||||
|
}
|
||||||
70
smtprelay.ini
Normal file
70
smtprelay.ini
Normal file
@@ -0,0 +1,70 @@
|
|||||||
|
; smtprelay configuration
|
||||||
|
|
||||||
|
; Logfile
|
||||||
|
;logfile = /var/log/smtprelay.log
|
||||||
|
|
||||||
|
; Hostname for this SMTP server
|
||||||
|
;hostname = "localhost.localdomain"
|
||||||
|
|
||||||
|
; Welcome message for clients
|
||||||
|
;welcome_msg = "<hostname> ESMTP ready."
|
||||||
|
|
||||||
|
; Listen on the following addresses for incoming
|
||||||
|
; unencrypted connections.
|
||||||
|
;listen = 127.0.0.1:25 [::1]:25
|
||||||
|
|
||||||
|
; STARTTLS and TLS are also supported but need a
|
||||||
|
; SSL certificate and key.
|
||||||
|
;listen = tls://127.0.0.1:465 tls://[::1]:465
|
||||||
|
;listen = starttls://127.0.0.1:587 starttls://[::1]:587
|
||||||
|
;local_cert = smtpd.pem
|
||||||
|
;local_key = smtpd.key
|
||||||
|
|
||||||
|
; Enforce encrypted connection on STARTTLS ports before
|
||||||
|
; accepting mails from client.
|
||||||
|
;local_forcetls = false
|
||||||
|
|
||||||
|
; Networks that are allowed to send mails to us
|
||||||
|
;allowed_nets = 127.0.0.1/8 ::1/128
|
||||||
|
|
||||||
|
; Regular expression for valid FROM EMail addresses
|
||||||
|
; Example: ^(.*)@localhost.localdomain$
|
||||||
|
;allowed_sender =
|
||||||
|
|
||||||
|
; Regular expression for valid TO EMail addresses
|
||||||
|
; Example: ^(.*)@localhost.localdomain$
|
||||||
|
;allowed_recipients =
|
||||||
|
|
||||||
|
; File which contains username and password used for
|
||||||
|
; authentication before they can send mail.
|
||||||
|
; File format: username bcrypt-hash [email[,email[,...]]]
|
||||||
|
; username: The SMTP auth username
|
||||||
|
; bcrypt-hash: The bcrypt hash of the pasword (generate with "./hasher password")
|
||||||
|
; email: Comma-separated list of allowed "from" addresses:
|
||||||
|
; - If omitted, user can send from any address
|
||||||
|
; - If @domain.com is given, user can send from any address @domain.com
|
||||||
|
; - Otherwise, email address must match exactly (case-insensitive)
|
||||||
|
; E.g. "app@example.com,@appsrv.example.com"
|
||||||
|
;allowed_users =
|
||||||
|
|
||||||
|
; Relay all mails to this SMTP server
|
||||||
|
|
||||||
|
; GMail
|
||||||
|
;remote_host = smtp.gmail.com:587
|
||||||
|
|
||||||
|
; Mailgun.org
|
||||||
|
;remote_host = smtp.mailgun.org:587
|
||||||
|
|
||||||
|
; Mailjet.com
|
||||||
|
;remote_host = in-v3.mailjet.com:587
|
||||||
|
|
||||||
|
; Authentication credentials on outgoing SMTP server
|
||||||
|
;remote_user =
|
||||||
|
;remote_pass =
|
||||||
|
|
||||||
|
; Authentication method on outgoing SMTP server
|
||||||
|
; (plain, login)
|
||||||
|
;remote_auth = plain
|
||||||
|
|
||||||
|
; Sender e-mail address on outgoing SMTP server
|
||||||
|
;remote_sender =
|
||||||
Reference in New Issue
Block a user