Work in progress.

.gitignore

@@ -0,0 +1 @@
+.project

cmd/jiralert/main.go

@@ -0,0 +1,153 @@
+package main
+
+import (
+	"encoding/json"
+	"flag"
+	"fmt"
+	"log"
+	"net/http"
+	"os"
+	"strconv"
+	"strings"
+
+	"github.com/alin-sinpalean/jiralert"
+	"github.com/prometheus/alertmanager/template"
+	"github.com/prometheus/client_golang/prometheus"
+)
+
+var (
+	listenAddress = flag.String("listen-address", ":2197", "The address to listen on for HTTP requests.")
+	configFile    = flag.String("config", "config.yaml", "The configuration file")
+)
+
+func main() {
+	flag.Parse()
+	log.SetFlags(log.LstdFlags | log.Lshortfile)
+
+	LoadConfig(*configFile)
+
+	http.HandleFunc("/alert", func(w http.ResponseWriter, r *http.Request) {
+		defer r.Body.Close()
+
+		// https://godoc.org/github.com/prometheus/alertmanager/template#Data
+		data := template.Data{}
+		if err := json.NewDecoder(r.Body).Decode(&data); err != nil {
+			errorHandler(w, http.StatusBadRequest, err, "?")
+			return
+		}
+
+		receiverConf := receiverConfByReceiver(data.Receiver)
+		if receiverConf == nil {
+			errorHandler(w, http.StatusBadRequest, fmt.Errorf("Receiver missing: %s", data.Receiver), "?")
+			return
+		}
+		provider, err := providerByName(receiverConf.Provider)
+		if err != nil {
+			errorHandler(w, http.StatusInternalServerError, err, receiverConf.Provider)
+			return
+		}
+
+		var text string
+		if len(data.Alerts) > 1 {
+			labelAlerts := map[string]template.Alerts{
+				"Firing":   data.Alerts.Firing(),
+				"Resolved": data.Alerts.Resolved(),
+			}
+			for label, alerts := range labelAlerts {
+				if len(alerts) > 0 {
+					text += label + ": \n"
+					for _, alert := range alerts {
+						text += alert.Labels["alertname"] + " @" + alert.Labels["instance"]
+						if len(alert.Labels["exported_instance"]) > 0 {
+							text += " (" + alert.Labels["exported_instance"] + ")"
+						}
+						text += "\n"
+					}
+				}
+			}
+		} else if len(data.Alerts) == 1 {
+			alert := data.Alerts[0]
+			tuples := []string{}
+			for k, v := range alert.Labels {
+				tuples = append(tuples, k+"= "+v)
+			}
+			text = strings.ToUpper(data.Status) + " \n" + strings.Join(tuples, "\n")
+		} else {
+			text = "Alert \n" + strings.Join(data.CommonLabels.Values(), " | ")
+		}
+
+		message := sachet.Message{
+			To:   receiverConf.To,
+			From: receiverConf.From,
+			Text: text,
+		}
+
+		if err = provider.Send(message); err != nil {
+			errorHandler(w, http.StatusBadRequest, err, receiverConf.Provider)
+			return
+		}
+
+		requestTotal.WithLabelValues("200", receiverConf.Provider).Inc()
+	})
+
+	http.Handle("/metrics", prometheus.Handler())
+
+	if os.Getenv("PORT") != "" {
+		*listenAddress = ":" + os.Getenv("PORT")
+	}
+
+	log.Fatal(http.ListenAndServe(*listenAddress, nil))
+}
+
+// receiverConfByReceiver loops the receiver conf list and returns the first instance with that name
+func receiverConfByReceiver(name string) *ReceiverConf {
+	for i := range config.Receivers {
+		rc := &config.Receivers[i]
+		if rc.Name == name {
+			return rc
+		}
+	}
+	return nil
+}
+
+func providerByName(name string) (sachet.Provider, error) {
+	switch name {
+	case "messagebird":
+		return sachet.NewMessageBird(config.Providers.MessageBird), nil
+	case "nexmo":
+		return sachet.NewNexmo(config.Providers.Nexmo)
+	case "twilio":
+		return sachet.NewTwilio(config.Providers.Twilio), nil
+	case "infobip":
+		return sachet.NewInfobip(config.Providers.Infobip), nil
+	case "turbosms":
+		return sachet.NewTurbosms(config.Providers.Turbosms), nil
+	case "exotel":
+		return sachet.NewExotel(config.Providers.Exotel), nil
+	case "cm":
+		return sachet.NewCM(config.Providers.CM), nil
+	}
+
+	return nil, fmt.Errorf("%s: Unknown provider", name)
+}
+
+func errorHandler(w http.ResponseWriter, status int, err error, provider string) {
+	w.WriteHeader(status)
+
+	data := struct {
+		Error   bool
+		Status  int
+		Message string
+	}{
+		true,
+		status,
+		err.Error(),
+	}
+	// respond json
+	bytes, _ := json.Marshal(data)
+	json := string(bytes[:])
+	fmt.Fprint(w, json)
+
+	log.Println("Error: " + json)
+	requestTotal.WithLabelValues(strconv.FormatInt(int64(status), 10), provider).Inc()
+}

cmd/jiralert/telemetry.go

@@ -0,0 +1,17 @@
+package main
+
+import "github.com/prometheus/client_golang/prometheus"
+
+var (
+	requestTotal = prometheus.NewCounterVec(
+		prometheus.CounterOpts{
+			Name: "jiralert_requests_total",
+			Help: "Requests processed, by status code and provider.",
+		},
+		[]string{"code", "provider"},
+	)
+)
+
+func init() {
+	prometheus.MustRegister(requestTotal)
+}