smon/notification_log.go

package main

import (
	// External
	werr "git.gibonuddevalla.se/go/wrappederror"
	"github.com/jmoiron/sqlx"

	// Internal
	"smon/notification"

	// Standard
	"database/sql"
	"encoding/json"
	"time"
)

type NotificationSend struct {
	Prio          int
	Service       string
	ID            int
	UUID          string
	Sent          time.Time `db:"send"`
	OK            bool
	Error         sql.NullString
	ErrorIndented string
	Acknowledged  bool
	TriggerName   string `db:"trigger_name"`
}

func notificationLog(notificationService *notification.Service, problemID int, err error) {
	if err == nil {
		logger.Info("notification", "service", (*notificationService).GetType(), "problemID", problemID, "prio", (*notificationService).GetPrio(), "ok", true)
		service.Db.Conn.Query(
			`
			INSERT INTO notification_send()
			`,
		)
	} else {
		logger.Error("notification", "service", (*notificationService).GetType(), "problemID", problemID, "prio", (*notificationService).GetPrio(), "ok", false, "error", err)
	}
}

func notificationsSent() (nss []NotificationSend, err error) {
	var rows *sqlx.Rows
	rows, err = service.Db.Conn.Queryx(
		`
		SELECT
			n.prio,
			n.service,
			
			t.name AS trigger_name,
			
			ns.id,
			ns.uuid,
			ns.send,
			ns.ok,
			ns.error::varchar,
			ns.acknowledged
			
		FROM
			public.notification_send ns
		INNER JOIN notification n ON ns.notification_id = n.id
		INNER JOIN problem p ON ns.problem_id = p.id
		INNER JOIN "trigger" t ON p.trigger_id = t.id
		
		ORDER BY
			send DESC
	`)
	if err != nil {
		err = werr.Wrap(err)
		return
	}
	defer rows.Close()

	for rows.Next() {
		ns := NotificationSend{}
		err = rows.StructScan(&ns)
		if err != nil {
			err = werr.Wrap(err)
			return
		}

		// Error contains json (can be NULL),
		// and can at least be presented indented.
		foo := make(map[string]any)
		json.Unmarshal([]byte(ns.Error.String), &foo)
		var j []byte
		j, err = json.MarshalIndent(foo, "", "    ")
		ns.ErrorIndented = string(j)

		nss = append(nss, ns)
	}
	return
}