equal
deleted
inserted
replaced
136 token, id, data string) <-chan string { |
136 token, id, data string) <-chan string { |
137 ch := make(chan string) |
137 ch := make(chan string) |
138 go func() { |
138 go func() { |
139 resp, err := rspamdPost(headers, data) |
139 resp, err := rspamdPost(headers, data) |
140 if err != nil { |
140 if err != nil { |
141 log.Fatal(err) |
141 ch <- "421 Temporary failure" |
|
142 return |
142 } |
143 } |
143 log.Printf("%v\n", resp) |
144 log.Printf("%v\n", resp) |
144 m, err := mail.ReadMessage(strings.NewReader(data)) |
145 m, err := mail.ReadMessage(strings.NewReader(data)) |
145 if err != nil { |
146 if err != nil { |
146 log.Fatal(err) |
147 ch <- "421 Temporary failure" |
|
148 return |
147 } |
149 } |
148 rejectReason := "" |
150 rejectReason := "" |
149 switch resp.Action { |
151 switch resp.Action { |
150 case "add header": |
152 case "add header": |
151 m.Header["X-Spam"] = []string{"yes"} |
153 m.Header["X-Spam"] = []string{"yes"} |