filter_rspamd.go
changeset 1 8a09170cd1e0
parent 0 7671ae88de2a
child 2 6f4d7e13e987
--- a/filter_rspamd.go	Thu Jan 10 14:10:38 2019 +0500
+++ b/filter_rspamd.go	Tue Jan 15 09:58:14 2019 +0500
@@ -90,7 +90,7 @@
 }
 
 func filterCommit(s *session, args []string) {
-	token := args[5]
+	token := args[6]
 	reason := <-s.ch
 	if reason != "" {
 		stdout.Printf("filter-result|%s|%s|reject|%s\n",
@@ -101,7 +101,7 @@
 }
 
 func filterDataLine(s *session, args []string) {
-	token, line := args[5], args[7]
+	token, line := args[6], args[7]
 	if line != "." {
 		s.payload.WriteString(line)
 		s.payload.WriteString("\n")
@@ -213,15 +213,7 @@
 	stdin := bufio.NewScanner(os.Stdin)
 	for stdin.Scan() {
 		fields := strings.Split(stdin.Text(), "|")
-		switch fields[0] {
-		case "report":
-			id = fields[5]
-		case "filter":
-			id = fields[6]
-		default:
-			log.Fatalf("Unknown kind: %s", fields[0])
-		}
-		event = fields[4]
+		event, id = fields[4], fields[5]
 		switch event {
 		case "link-disconnect":
 			delete(sessions, id)