nginx-ui/internal/notification/push.go

package notification

import (
	"github.com/0xJacky/Nginx-UI/internal/event"
	"github.com/0xJacky/Nginx-UI/model"
	"github.com/0xJacky/Nginx-UI/query"
	"github.com/uozi-tech/cosy/logger"
)

func push(nType model.NotificationType, title string, content string, details any) {
	n := query.Notification

	data := &model.Notification{
		Type:    nType,
		Title:   title,
		Content: content,
		Details: details,
	}

	err := n.Create(data)
	if err != nil {
		logger.Error(err)
		return
	}

	// Use event system instead of direct broadcast
	event.Publish(event.Event{
		Type: event.EventTypeNotification,
		Data: data,
	})

	// Keep the old broadcast for backward compatibility
	broadcast(data)

	extNotify := &ExternalMessage{data}
	extNotify.Send()
}