21 Commits

Author SHA1 Message Date
88a3f1f3a5 „gomilter.go“ ändern 2018-12-29 13:21:33 +00:00
Dolf Schimmel
ec6c4f3113 Merge branch 'master' of https://github.com/davrux/gomilter into HEAD 2015-12-31 23:08:11 +01:00
Dolf Schimmel (Freeaqingme)
c60841ef06 Revert "Make gobencode() optional in SetPriv(), return errors instead of integers"
This reverts commit 6a57e8c3fc.
2015-11-25 20:42:41 +01:00
Dolf Schimmel (Freeaqingme)
01964e5391 Merge with upstream 2015-11-24 17:49:00 +01:00
Dolf Schimmel (Freeaqingme)
0c9e549560 go fmt 2015-11-24 17:46:44 +01:00
Dolf Schimmel (Freeaqingme)
d6bf69609f Merge branch 'master' of https://github.com/leonrbaker/gomilter 2015-11-24 17:44:53 +01:00
Dolf Schimmel (Freeaqingme)
6a57e8c3fc Make gobencode() optional in SetPriv(), return errors instead of integers 2015-11-24 17:39:31 +01:00
Dolf Schimmel (Freeaqingme)
39a4baf02e Recover from errors in Go_xxfi_connect()
There appears to be a race condition in libmilter in which
hostaddr is set to nil before or while calling the connect
callback if the client aborts its connection during that
window.
2015-11-24 17:38:59 +01:00
Meik Kreyenkoetter
f724fd7bcb Linker path for Debian/Ubuntu.
Libmilter is installed in /usr/lib/libmilter on Debian and Ubuntu
systems. Added additional Linker path for cgo.
2015-10-02 11:51:58 +02:00
Leon Baker
c99ec2226f Merge pull request #7 from Freeaqingme/master
Fix IPv6 addresses that sometimes caused memory stomping
2015-09-25 09:36:22 +02:00
Dolf Schimmel
00d59ae5ab Fix IPv6 addresses that sometimes caused memory stomping 2015-09-16 19:42:24 +02:00
Leon Baker
dc84b56af1 Merge pull request #6 from leonrbaker/logging
Implemented the Log package for logging
2015-09-03 12:14:40 +02:00
Leon Baker
64fb9af89b Merge pull request #5 from Freeaqingme/master
Max IPv6 address length is 45 characters, not 16
2015-09-03 12:07:19 +02:00
Dolf Schimmel (Freeaqingme)
385e5106c2 Max IPv6 address length is 45 characters, not 16
The idea was to reserve 16 bytes for an IPv6 address. But given that a human representation is used rather than a
128 bit integer, we need 45 characters at most.
2015-09-01 21:15:14 +02:00
Leon Baker
882ca25f76 Implemented the Log package for logging 2015-06-16 12:34:30 +02:00
Leon Baker
8746179952 Update README and fix sample filter 2015-06-15 16:44:41 +02:00
Leon Baker
4dc71bdbbc Merge pull request #4 from Freeaqingme/master
Implement stop(), Support IPv6, Custom log callbacks, reformatted code
2015-06-13 18:22:12 +02:00
Dolf Schimmel
a6870a91fe Also include netinet/in.h necessary for FreeBSD 2015-06-11 11:40:55 +02:00
Dolf Schimmel (Freeaqingme)
24ed8dcbc3 Add support for ipv6 2015-06-01 22:16:02 +02:00
Dolf Schimmel (Freeaqingme)
c0f4b47c5e Implement stop() 2015-06-01 00:04:36 +02:00
Dolf Schimmel (Freeaqingme)
13b82e7dd5 Reformatted code 2015-05-31 01:02:17 +02:00
5 changed files with 730 additions and 611 deletions

3
.gitignore vendored Normal file
View File

@@ -0,0 +1,3 @@
# Compiled test programs
samplefilter
samplefilter2

View File

@@ -1,2 +1,95 @@
# gomilter
Go Bindings for libmilter
Go Bindings for Sendmail's libmilter
Tested on Linux and FreeBSD
## Installation
The Sendmail header file libmilter/mfapi.h is required. For Redhat/CentOS, install the sendmail-devel package:
```sh
yum install sendmail-devel
```
Install the gomilter package:
```sh
go get github.com/leonrbaker/gomilter
```
##Usage
The milter is implemented in a struct. Start by defining your own struct type and embeding the gomilter MilterRaw struct.
```go
type Mymilter struct {
gomilter.MilterRaw // Embed the basic functionality.
}
```
Milter callbacks are added by implementing methods for the struct with matching predefined names.
### Callbacks
* Connect
* Helo
* EnvFrom
* EnvRcpt
* Header
* Eoh
* Body
* Eom
* Abort
* Close
Not all the callbacks need to be defined. The callbacks are explained on the milter.org site. Unfortunately the milter.org site has been shut down but it is still on [web.archive.org](http://web.archive.org/web/20150510034154/https://www.milter.org/developers/api/index)
### Message Modification Functions
* AddHeader
* ChgHeader
* InsHeader
* ChgFrom
* AddRcpt
* AddRcpt_Par
* DelRcpt
* ReplaceBody
### Other Message Handling Functions
* progress
### Startup
The Socket field of the milter struct must be set. For example:
```go
mymilter.Socket = "unix:/var/gomilter/socket"
```
Control is handed over to the libmilter smfi_main function by calling the Run method and passing it a pointer to your milter struct
```go
gomilter.Run(mymilter)
```
The milter has a Stop method which calls the libmilter smfi_stop function.
### Private Data
libmilter is able to store private data for a connection. This data can be accessed from other functions and callbacks for the same connection. You can pass a pointer to any data structure to SetPriv. The data is retrieved with GetPriv
```go
t := T{1, 2, 3}
m.SetPriv(ctx, &t)
```
Retrieve the data with
```go
var t T
m.GetPriv(ctx, &t))
```
GetPriv should only be called once. If the private data is needed in another function or callback then call SetPriv again.
## Sample Programs
There are two sample programs included, samplefilter.go and samplefilter2.go
##Other Libraries
A usefull MIME parsing library is [go.enmime](https://github.com/jhillyerd/go.enmime)

File diff suppressed because it is too large Load Diff

View File

@@ -15,36 +15,34 @@ Sample Milter
package main
import (
"."
"fmt"
"."
"fmt"
)
type Mymilter struct {
gomilter.MilterRaw // Embed the basic functionality. No callbacks yet
gomilter.MilterRaw // Embed the basic functionality. No callbacks yet
}
// Define the callback functions we are going to use
func (m *Mymilter) Connect(ctx uintptr, hostname, ip string) (sfsistat int8) {
fmt.Println("mymilter.connect was called")
fmt.Printf("hostname: %s\n", hostname)
fmt.Printf("ip: %s\n", ip)
return gomilter.Reject
fmt.Println("mymilter.connect was called")
fmt.Printf("hostname: %s\n", hostname)
fmt.Printf("ip: %s\n", ip)
return gomilter.Reject
}
func (m *Mymilter) Helo(ctx uintptr, helohost string) (sfsistat int8) {
fmt.Println("mymilter.helo was called")
return
fmt.Println("mymilter.helo was called")
return
}
func main() {
mymilter := new(Mymilter)
mymilter.FilterName = "TestFilter"
mymilter.Debug = true
mymilter.Flags = gomilter.AddHdrs|gomilter.AddRcpt
mymilter := new(Mymilter)
mymilter.FilterName = "TestFilter"
mymilter.Debug = true
mymilter.Flags = gomilter.ADDHDRS | gomilter.ADDRCPT
mymilter.Socket = "unix:/var/milterattachcheck/socket"
// Start Milter
gomilter.Run(mymilter)
// Start Milter
gomilter.Run(mymilter)
}

View File

@@ -7,109 +7,114 @@ Copyright (c) 2015 Leon Baker
package main
import (
m "github.com/leonrbaker/gomilter"
"fmt"
m "github.com/leonrbaker/gomilter"
"log"
"os"
)
type Mymilter struct {
m.MilterRaw // Embed the basic functionality. No callbacks defined yet
m.MilterRaw // Embed the basic functionality. No callbacks defined yet
}
// Data type I want use for private data. Can be any type
type T struct {
A uint8
B string
C string
A uint8
B string
C string
}
var logger *log.Logger
// Define the callback functions we are going to use
func (milter *Mymilter) Connect(ctx uintptr, hostname, ip string) (sfsistat int8) {
fmt.Println("mymilter.Connect was called")
fmt.Printf("hostname: %s\n", hostname)
fmt.Printf("ip: %s\n", ip)
logger.Println("mymilter.Connect was called")
logger.Printf("hostname: %s\n", hostname)
logger.Printf("ip: %s\n", ip)
t := T{1, hostname, "Test"}
m.SetPriv(ctx, &t)
t := T{1, hostname, "Test"}
m.SetPriv(ctx, &t)
return m.Continue
return m.Continue
}
func (milter *Mymilter) Helo(ctx uintptr, helohost string) (sfsistat int8) {
fmt.Println("mymilter.Helo was called")
fmt.Printf("helohost: %s\n", helohost)
return
logger.Println("mymilter.Helo was called")
logger.Printf("helohost: %s\n", helohost)
return
}
func (milter *Mymilter) EnvFrom(ctx uintptr, myargv []string) (sfsistat int8) {
fmt.Println("mymilter.EnvFrom was called")
fmt.Printf("myargv: %s\n", myargv)
// Show the value of a symbol
fmt.Printf("{mail_addr}: %v\n", m.GetSymVal(ctx, "{mail_addr}"))
return
logger.Println("mymilter.EnvFrom was called")
logger.Printf("myargv: %s\n", myargv)
// Show the value of a symbol
logger.Printf("{mail_addr}: %v\n", m.GetSymVal(ctx, "{mail_addr}"))
return
}
func (milter *Mymilter) EnvRcpt(ctx uintptr, myargv []string) (sfsistat int8) {
fmt.Println("mymilter.EnvRcpt was called")
fmt.Printf("myargv: %s\n", myargv)
// Show the value of a symbol
fmt.Printf("{rcpt_addr}: %v\n", m.GetSymVal(ctx, "{rcpt_addr}"))
return
logger.Println("mymilter.EnvRcpt was called")
logger.Printf("myargv: %s\n", myargv)
// Show the value of a symbol
logger.Printf("{rcpt_addr}: %v\n", m.GetSymVal(ctx, "{rcpt_addr}"))
return
}
func (milter *Mymilter) Header(ctx uintptr, headerf, headerv string) (sfsistat int8) {
fmt.Println("mymilter.Header was called")
fmt.Printf("header field: %s\n", headerf)
fmt.Printf("header value: %s\n", headerv)
return
logger.Println("mymilter.Header was called")
logger.Printf("header field: %s\n", headerf)
logger.Printf("header value: %s\n", headerv)
return
}
func (milter *Mymilter) Eoh(ctx uintptr) (sfsistat int8) {
fmt.Println("mymilter.Eoh was called")
return
logger.Println("mymilter.Eoh was called")
return
}
func (milter *Mymilter) Body(ctx uintptr, body []byte) (sfsistat int8) {
// Be careful as a conversion of body to string will make a copy of body
fmt.Println("mymilter.Body was called")
fmt.Println(string(body))
fmt.Printf("Body Length: %d\n", len(body))
return
// Be careful as a conversion of body to string will make a copy of body
logger.Println("mymilter.Body was called")
logger.Println(string(body))
logger.Printf("Body Length: %d\n", len(body))
return
}
func (milter *Mymilter) Eom(ctx uintptr) (sfsistat int8) {
fmt.Println("mymilter.Eom was called")
logger.Println("mymilter.Eom was called")
var t T
fmt.Println("m.GetPri:", m.GetPriv(ctx, &t))
fmt.Println("t:", t)
var t T
logger.Println("m.GetPri:", m.GetPriv(ctx, &t))
logger.Println("t:", t)
m.AddHeader(ctx, "LEONUX-Mailer",
"test server;\n\ttest1=\"foobar\"")
m.AddHeader(ctx, "LEONUX-Mailer",
"test server;\n\ttest1=\"foobar\"")
newBody := []byte("This is a new body")
m.ReplaceBody(ctx, newBody)
return
newBody := []byte("This is a new body")
m.ReplaceBody(ctx, newBody)
return
}
func (milter *Mymilter) Abort(ctx uintptr) (sfsistat int8) {
fmt.Println("mymilter.Abort was called")
return
logger.Println("mymilter.Abort was called")
return
}
func (milter *Mymilter) Close(ctx uintptr) (sfsistat int8) {
fmt.Println("mymilter.Close was called")
return
logger.Println("mymilter.Close was called")
return
}
func main() {
mymilter := new(Mymilter)
mymilter.FilterName = "TestFilter"
mymilter.Debug = true
mymilter.Flags = m.ADDHDRS|m.ADDRCPT|m.CHGFROM|m.CHGBODY
mymilter.Socket = "unix:/var/milterattachcheck/socket"
mymilter := new(Mymilter)
mymilter.FilterName = "TestFilter"
// Start Milter
m.Run(mymilter)
logger = log.New(os.Stdout, "", log.LstdFlags)
mymilter.Logger = logger
mymilter.Debug = true
mymilter.Flags = m.ADDHDRS | m.ADDRCPT | m.CHGFROM | m.CHGBODY
mymilter.Socket = "unix:/var/milterattachcheck/socket"
// Start Milter
m.Run(mymilter)
}