support multiple events in one PUT separated by newlines

VERSION

@@ -1 +1 @@
-1.4.4
+1.4.5

event.go

@@ -1,6 +1,7 @@
 package main
 
 import (
+	"bytes"
 	"encoding/json"
 	"time"
 
@@ -55,3 +56,21 @@ func eventFromJSON(msg []byte) (ev *Event, err error) {
 
 	return
 }
+
+func eventsFromMultipleJSONs(msg []byte) (evs []*Event, err error) {
+	for _, p := range bytes.Split(msg, []byte("\n")) {
+		p = bytes.TrimSpace(p)
+		if len(p) == 0 {
+			continue
+		}
+
+		ev, err := eventFromJSON(p)
+		if err != nil {
+			return nil, err
+		}
+
+		evs = append(evs, ev)
+	}
+
+	return
+}

input.go

@@ -324,13 +324,13 @@ func (i *input) handleHTTPEvent(w http.ResponseWriter, r *http.Request) {
 		return
 	}
 
-	ev, err := eventFromJSON(buf)
+	evs, err := eventsFromMultipleJSONs(buf)
 	if err != nil {
 		i.Errorf("%s: Unable to parse event JSON: %s", r.RemoteAddr, err)
 		return
 	}
 
-	i.sendEvents([]*Event{ev})
+	i.sendEvents(evs)
 }
 
 func (i *input) readTCPMessage(c net.Conn) (err error) {