AverageMarcus/tank
1
0
Fork 0
Code Releases Activity

Compare commits

base: AverageMarcus:538673281e07e8f0fc62ae32abdace1c91eb8958
Branches Tags
AverageMarcus:main
..
compare: AverageMarcus:8529033bc44e13de0cac1d5a3769cbe10d438594
Branches Tags
AverageMarcus:main

1 Commits
538673281e ... 8529033bc4

Author SHA1 Message Date
Marcus Noble
8529033bc4
Added some debugging 
Signed-off-by: Marcus Noble <github@marcusnoble.co.uk>
 2021-12-05 15:02:46 +00:00
1 changed files with 6 additions and 2 deletions
Show Stats Expand all files Collapse all files

8
alertmanager.go
View File

@ -12,14 +12,19 @@ import (
func HandleAlertmanagerPayloadPost(c *fiber.Ctx) error { func HandleAlertmanagerPayloadPost(c *fiber.Ctx) error {
payload := template.Data{} payload := template.Data{}
if err := c.BodyParser(&payload); err != nil { if err := c.BodyParser(&payload); err != nil {
fmt.Println("Failed to parse payload", err)
return err return err
} }
fmt.Println("Got alertmanager payload") fmt.Println("Got alertmanager payload")
fmt.Println(len(payload.Alerts))
fmt.Println(payload.Alerts)
for _, alert := range payload.Alerts { for _, alert := range payload.Alerts {
message := "" message := ""
fmt.Printf("Status - %s", alert.Status)
fmt.Printf("Severity - %s", alert.Labels["severity"])
if alert.Status == "firing" { if alert.Status == "firing" {
switch alert.Labels["severity"] { switch alert.Labels["severity"] {
case "warning": case "warning":
@ -33,7 +38,6 @@ func HandleAlertmanagerPayloadPost(c *fiber.Ctx) error {
_, err := matrixClient.SendText(id.RoomID(*defaultRoom), message) _, err := matrixClient.SendText(id.RoomID(*defaultRoom), message)
if err != nil { if err != nil {
fmt.Println("Failed sending to Matrix", err)
if httpErr, ok := err.(mautrix.HTTPError); ok { if httpErr, ok := err.(mautrix.HTTPError); ok {
return c.Status(httpErr.Response.StatusCode).SendString(httpErr.RespError.Err) return c.Status(httpErr.Response.StatusCode).SendString(httpErr.RespError.Err)
} }