-
Notifications
You must be signed in to change notification settings - Fork 1
/
main.go
104 lines (91 loc) · 1.87 KB
/
main.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
package main
import (
"bufio"
"bytes"
"encoding/json"
"io"
"log"
"mime"
"net/http"
"os"
"strings"
"github.com/emersion/go-message/mail"
)
type Mail struct {
From string
Date string
ReplyTo string
Body string
Parts map[string]string
}
func makeReq(j []byte) {
req, err := http.NewRequest("POST", "http://localhost:8001/webhook", bytes.NewBuffer(j))
req.Header.Set("Content-Type", "application/json")
client := http.Client{}
res, err := client.Do(req)
if err != nil {
log.Fatal(err)
}
defer res.Body.Close()
}
// Decodes a RFC 2047 encoded word.
func decode(s string) (string, error) {
dec := mime.WordDecoder{}
header, err := dec.DecodeHeader(s)
if err != nil {
return "", err
}
return header, nil
}
func main() {
f, err := os.OpenFile("mdawh.log", os.O_RDWR|os.O_CREATE|os.O_APPEND, 0666)
if err != nil {
log.Fatal(err)
}
defer f.Close()
log.SetOutput(f)
r := bufio.NewReader(os.Stdin)
mr, err := mail.CreateReader(r)
m := Mail{}
m.Date = mr.Header.Get("Date")
from, err := decode(mr.Header.Get("From"))
if err != nil {
m.From = mr.Header.Get("From")
} else {
m.From = from
}
m.ReplyTo = mr.Header.Get("Reply-To")
if err != nil {
log.Fatal(err)
}
parts := make(map[string]string)
for {
p, err := mr.NextPart()
if err == io.EOF {
break
} else if err != nil {
log.Fatal(err)
}
switch h := p.Header.(type) {
case *mail.InlineHeader:
ct := strings.Split(p.Header.Get("Content-Type"), ";")[0]
// We didn't find any Content-Type header.
b, _ := io.ReadAll(p.Body)
if len(ct) == 0 {
m.Body = string(b)
} else {
parts[ct] = string(b)
m.Parts = parts
}
case *mail.AttachmentHeader:
filename, _ := h.Filename()
log.Printf("got attachment: %v\n", filename)
}
}
j, err := json.Marshal(m)
if err != nil {
log.Fatal(err)
}
makeReq(j)
log.Printf("sent webhook: %v\n", m.From)
}