Initial commit

README.md

@@ -0,0 +1,3 @@
+A hasty re-implementation of [irccat](https://github.com/RJ/irccat) in Go.
+
+Supports HTTP POST endpoints as well as the traditional TCP protocol.

httplistener/httplistener.go

@@ -0,0 +1,67 @@
+package httplistener
+
+import (
+	"bytes"
+	"encoding/json"
+	"fmt"
+	"github.com/juju/loggo"
+	"github.com/spf13/viper"
+	"github.com/thoj/go-ircevent"
+	"net/http"
+)
+
+var log = loggo.GetLogger("HTTPListener")
+
+type HTTPListener struct {
+	http http.Server
+	irc  *irc.Connection
+}
+
+func New(irc *irc.Connection) (*HTTPListener, error) {
+	hl := HTTPListener{}
+	hl.irc = irc
+	hl.http = http.Server{Addr: viper.GetString("http.listen")}
+
+	mux := http.NewServeMux()
+	if viper.IsSet("http.listeners.grafana") {
+		mux.HandleFunc("/grafana", hl.grafanaAlertHandler)
+	}
+
+	hl.http.Handler = mux
+	log.Infof("Listening for HTTP requests on %s", viper.GetString("http.listen"))
+	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)
+}

irccat.json

@@ -1,11 +1,16 @@
 {
   "tcp_listen": ":12345",
-  "http_listen": ":8045",
+  "http": {
+    "listen": ":8045",
+    "listeners": {
+      "grafana": "#russtest"
+    }
+  },
   "irc": {
     "server": "irc.irccloud.com:6667",
     "tls": false,
     "tls_skip_verify": true,
-    "nick": "gocat",
+    "nick": "irccat2",
     "realname": "IRCCat",
     "channels": ["#russtest"]
   }

main.go

@@ -2,6 +2,7 @@ package main
 
 import (
 	"crypto/tls"
+	"github.com/irccloud/irccat/httplistener"
 	"github.com/irccloud/irccat/tcplistener"
 	"github.com/juju/loggo"
 	"github.com/spf13/viper"
@@ -29,7 +30,7 @@ func main() {
 
 	irccat := IRCCat{}
 
-	irccat.tcp, err = tcplistener.Bind()
+	irccat.tcp, err = tcplistener.New()
 	if err != nil {
 		return
 	}
@@ -41,6 +42,8 @@ func main() {
 		return
 	}
 
+	httplistener.New(irccat.irc)
+
 	irccat.tcp.Run(irccat.irc)
 	irccat.irc.Loop()
 }

tcplistener/tcplistener.go

@@ -16,7 +16,7 @@ type TCPListener struct {
 	irc    *irc.Connection
 }
 
-func Bind() (*TCPListener, error) {
+func New() (*TCPListener, error) {
 	var err error
 
 	listener := TCPListener{}