139 lines
3.3 KiB
Go
139 lines
3.3 KiB
Go
package main
|
|
|
|
import (
|
|
"errors"
|
|
"flag"
|
|
"fmt"
|
|
"os"
|
|
|
|
"github.com/gofiber/fiber"
|
|
flog "github.com/gofiber/logger"
|
|
"github.com/slack-go/slack"
|
|
"go.uber.org/zap"
|
|
)
|
|
|
|
var slackURL string
|
|
var tektonDashboadUrl string
|
|
|
|
type slackMessage struct {
|
|
Blocks []slack.MessageBlockType
|
|
}
|
|
|
|
func main() {
|
|
versionFlag := flag.Bool("version", false, "print version information")
|
|
flag.Parse()
|
|
if *versionFlag {
|
|
fmt.Printf("(version=%s, branch=%s, gitcommit=%s)\n", Version, Branch, GitCommit)
|
|
fmt.Printf("(go=%s, user=%s, date=%s)\n", GoVersion, BuildUser, BuildDate)
|
|
os.Exit(0)
|
|
}
|
|
logger, _ := zap.NewProduction()
|
|
defer logger.Sync()
|
|
log := logger.Sugar()
|
|
log.Infow("Startup", "version", Version)
|
|
app := fiber.New()
|
|
app.Use(flog.New())
|
|
|
|
slackURL = os.Getenv("slackURL")
|
|
if slackURL == "" {
|
|
log.Fatalw("slackURL ENV value missing")
|
|
}
|
|
|
|
tektonDashboadUrl = os.Getenv("tektonDashboadUrl")
|
|
if tektonDashboadUrl == "" {
|
|
log.Fatalw("tektonDashboadUrl ENV value missing")
|
|
}
|
|
|
|
app.Get("/", func(c *fiber.Ctx) {
|
|
c.Send("cloudlog!")
|
|
})
|
|
|
|
app.Post("/inbox", func(c *fiber.Ctx) {
|
|
var message map[string]interface{}
|
|
|
|
if err := c.BodyParser(&message); err != nil {
|
|
log.Error(err)
|
|
c.Status(500).Send(err)
|
|
return
|
|
}
|
|
log.Infow("Got an inbox message!", "message", message)
|
|
cloudEvent, err := coerceCloudEvent(message)
|
|
if err != nil {
|
|
log.Error(err)
|
|
c.Status(500).Send(err)
|
|
return
|
|
}
|
|
|
|
if err := sendSlackMessage(cloudEvent, log); err != nil {
|
|
log.Error(err)
|
|
c.Status(500).Send(err)
|
|
return
|
|
}
|
|
c.JSON(message)
|
|
})
|
|
|
|
app.Listen(3000)
|
|
}
|
|
|
|
func coerceCloudEvent(message map[string]interface{}) (te *TektonCloudEvent, err error) {
|
|
var taskRun, status, condition map[string]interface{}
|
|
var conditions []interface{}
|
|
var ok bool
|
|
var podName, reason, cMessage string
|
|
if taskRun, ok = message["taskRun"].(map[string]interface{}); !ok {
|
|
return nil, errors.New("taskRun not found in message")
|
|
}
|
|
|
|
if status, ok = taskRun["status"].(map[string]interface{}); !ok {
|
|
return nil, errors.New("status not found in taskRun")
|
|
}
|
|
|
|
if podName, ok = status["podName"].(string); !ok {
|
|
return nil, errors.New("podName not found in status")
|
|
}
|
|
|
|
if conditions, ok = status["conditions"].([]interface{}); !ok {
|
|
return nil, errors.New("conditions not found in status")
|
|
}
|
|
if condition, ok = conditions[0].(map[string]interface{}); !ok {
|
|
fmt.Println("condition not found in conditions")
|
|
}
|
|
if reason, ok = condition["reason"].(string); !ok {
|
|
fmt.Println("reason not found in condition")
|
|
}
|
|
if cMessage, ok = condition["message"].(string); !ok {
|
|
fmt.Println("message not found in condition")
|
|
}
|
|
|
|
te = &TektonCloudEvent{
|
|
Title: podName + " " + reason,
|
|
Reason: reason,
|
|
Message: cMessage,
|
|
PodName: podName,
|
|
}
|
|
|
|
return te, nil
|
|
}
|
|
|
|
type TektonCloudEvent struct {
|
|
Title string `json:"string"`
|
|
Reason string `json:"reason"`
|
|
Message string `json:"message"`
|
|
PodName string `json:"pod_name"`
|
|
}
|
|
|
|
func sendSlackMessage(cloudEvent *TektonCloudEvent, log *zap.SugaredLogger) error {
|
|
text := fmt.Sprintf("*%s*\n\n```%s```\nPodName: %s/%s", cloudEvent.Title, cloudEvent.Message, tektonDashboadUrl, cloudEvent.PodName)
|
|
log.Infow("Sending slack message!", "text", text)
|
|
msg := slack.WebhookMessage{
|
|
Text: text,
|
|
}
|
|
|
|
err := slack.PostWebhook(slackURL, &msg)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
return nil
|
|
}
|