Separate out http listener endpoints

httplistener/grafana.go

@@ -0,0 +1,42 @@
+package httplistener
+
+import (
+	"bytes"
+	"encoding/json"
+	"fmt"
+	"github.com/spf13/viper"
+	"net/http"
+)
+
+type grafanaMatch struct {
+	Metric string
+	Value  float32
+}
+
+type grafanaAlert struct {
+	Title       string
+	RuleName    string
+	RuleUrl     string
+	State       string
+	ImageUrl    string
+	Message     string
+	EvalMatches []grafanaMatch
+}
+
+func (hl *HTTPListener) grafanaAlertHandler(w http.ResponseWriter, request *http.Request) {
+	if request.Method != "POST" {
+		http.NotFound(w, request)
+		return
+	}
+
+	var alert grafanaAlert
+	buf := new(bytes.Buffer)
+	buf.ReadFrom(request.Body)
+	json.Unmarshal(buf.Bytes(), &alert)
+	msg := fmt.Sprintf("[Grafana] [%s] %s: %s.", alert.State, alert.RuleName, alert.Message)
+	for _, match := range alert.EvalMatches {
+		msg += fmt.Sprintf(" %s:%f", match.Metric, match.Value)
+	}
+	msg += " " + alert.RuleUrl
+	hl.irc.Privmsgf(viper.GetString("http.listeners.grafana"), msg)
+}

httplistener/httplistener.go

@@ -1,9 +1,6 @@
 package httplistener
 
 import (
-	"bytes"
-	"encoding/json"
-	"fmt"
 	"github.com/juju/loggo"
 	"github.com/spf13/viper"
 	"github.com/thoj/go-ircevent"
@@ -32,36 +29,3 @@ func New(irc *irc.Connection) (*HTTPListener, error) {
 	go hl.http.ListenAndServe()
 	return &hl, nil
 }
-
-type grafanaMatch struct {
-	Metric string
-	Value  float32
-}
-
-type grafanaAlert struct {
-	Title       string
-	RuleName    string
-	RuleUrl     string
-	State       string
-	ImageUrl    string
-	Message     string
-	EvalMatches []grafanaMatch
-}
-
-func (hl *HTTPListener) grafanaAlertHandler(w http.ResponseWriter, request *http.Request) {
-	if request.Method != "POST" {
-		http.NotFound(w, request)
-		return
-	}
-
-	var alert grafanaAlert
-	buf := new(bytes.Buffer)
-	buf.ReadFrom(request.Body)
-	json.Unmarshal(buf.Bytes(), &alert)
-	msg := fmt.Sprintf("[Grafana] [%s] %s: %s.", alert.State, alert.RuleName, alert.Message)
-	for _, match := range alert.EvalMatches {
-		msg += fmt.Sprintf(" %s:%f", match.Metric, match.Value)
-	}
-	msg += " " + alert.RuleUrl
-	hl.irc.Privmsgf(viper.GetString("http.listeners.grafana"), msg)
-}