mirror/mantrae
1
0
Fork 0
mirror of https://github.com/MizuchiLabs/mantrae.git synced 2026-05-08 00:49:49 -05:00
Code Issues Packages Projects Releases Wiki Activity

fix: cleanup sse events

Browse Source
This commit is contained in:
d34dscene
2025-04-16 14:16:54 +02:00
parent 4501e301c1
commit a97f9c24c5
18 changed files with 184 additions and 115 deletions
Download Patch File Download Diff File Expand all files Collapse all files
internal/api/handler/agent.go
+8 -8
View File
@@ -101,8 +101,8 @@ func CreateAgent(a *config.App) http.HandlerFunc {
}
util.Broadcast <- util.EventMessage{
Type: util.EventTypeCreate,
Message: "agent",
Type: util.EventTypeCreate,
Category: util.EventCategoryAgent,
}
w.WriteHeader(http.StatusCreated)
}
@@ -122,8 +122,8 @@ func UpdateAgentIP(a *config.App) http.HandlerFunc {
}
util.Broadcast <- util.EventMessage{
Type: util.EventTypeUpdate,
Message: "agent",
Type: util.EventTypeUpdate,
Category: util.EventCategoryAgent,
}
w.WriteHeader(http.StatusNoContent)
}
@@ -147,8 +147,8 @@ func DeleteAgent(a *config.App) http.HandlerFunc {
}
util.Broadcast <- util.EventMessage{
Type: util.EventTypeDelete,
Message: "agent",
Type: util.EventTypeDelete,
Category: util.EventCategoryAgent,
}
w.WriteHeader(http.StatusNoContent)
}
@@ -190,8 +190,8 @@ func RotateAgentToken(a *config.App) http.HandlerFunc {
}
util.Broadcast <- util.EventMessage{
Type: util.EventTypeUpdate,
Message: "agent",
Type: util.EventTypeUpdate,
Category: util.EventCategoryAgent,
}
w.WriteHeader(http.StatusNoContent)
}
internal/api/handler/dns_providers.go
+6 -6
View File
@@ -63,8 +63,8 @@ func CreateDNSProvider(a *config.App) http.HandlerFunc {
}
util.Broadcast <- util.EventMessage{
Type: util.EventTypeCreate,
Message: "dns",
Type: util.EventTypeCreate,
Category: util.EventCategoryDNS,
}
w.WriteHeader(http.StatusCreated)
}
@@ -83,8 +83,8 @@ func UpdateDNSProvider(a *config.App) http.HandlerFunc {
return
}
util.Broadcast <- util.EventMessage{
Type: util.EventTypeUpdate,
Message: "dns",
Type: util.EventTypeUpdate,
Category: util.EventCategoryDNS,
}
w.WriteHeader(http.StatusNoContent)
}
@@ -104,8 +104,8 @@ func DeleteDNSProvider(a *config.App) http.HandlerFunc {
return
}
util.Broadcast <- util.EventMessage{
Type: util.EventTypeDelete,
Message: "dns",
Type: util.EventTypeDelete,
Category: util.EventCategoryDNS,
}
w.WriteHeader(http.StatusNoContent)
}
internal/api/handler/middlewares.go
+4 -4
View File
@@ -115,8 +115,8 @@ func UpsertMiddleware(a *config.App) http.HandlerFunc {
}
util.Broadcast <- util.EventMessage{
Type: util.EventTypeUpdate,
Message: "middleware",
Type: util.EventTypeUpdate,
Category: util.EventCategoryTraefik,
}
// Return the updated configuration
@@ -178,8 +178,8 @@ func DeleteMiddleware(a *config.App) http.HandlerFunc {
}
util.Broadcast <- util.EventMessage{
Type: util.EventTypeDelete,
Message: "middleware",
Type: util.EventTypeDelete,
Category: util.EventCategoryTraefik,
}
w.WriteHeader(http.StatusNoContent)
}
internal/api/handler/profiles.go
+6 -6
View File
@@ -84,8 +84,8 @@ func CreateProfile(a *config.App) http.HandlerFunc {
}
}()
util.Broadcast <- util.EventMessage{
Type: util.EventTypeCreate,
Message: "profile",
Type: util.EventTypeCreate,
Category: util.EventCategoryProfile,
}
w.WriteHeader(http.StatusNoContent)
}
@@ -115,8 +115,8 @@ func UpdateProfile(a *config.App) http.HandlerFunc {
}
}()
util.Broadcast <- util.EventMessage{
Type: util.EventTypeUpdate,
Message: "profile",
Type: util.EventTypeUpdate,
Category: util.EventCategoryProfile,
}
w.WriteHeader(http.StatusNoContent)
}
@@ -135,8 +135,8 @@ func DeleteProfile(a *config.App) http.HandlerFunc {
return
}
util.Broadcast <- util.EventMessage{
Type: util.EventTypeDelete,
Message: "profile",
Type: util.EventTypeDelete,
Category: util.EventCategoryProfile,
}
w.WriteHeader(http.StatusNoContent)
}
internal/api/handler/routers.go
+4 -4
View File
@@ -143,8 +143,8 @@ func UpsertRouter(a *config.App) http.HandlerFunc {
}
util.Broadcast <- util.EventMessage{
Type: util.EventTypeUpdate,
Message: "router",
Type: util.EventTypeUpdate,
Category: util.EventCategoryTraefik,
}
// Return the updated configuration
@@ -212,8 +212,8 @@ func DeleteRouter(a *config.App) http.HandlerFunc {
}
util.Broadcast <- util.EventMessage{
Type: util.EventTypeDelete,
Message: "router",
Type: util.EventTypeDelete,
Category: util.EventCategoryTraefik,
}
w.WriteHeader(http.StatusNoContent)
}
internal/api/handler/settings.go
+5
View File
@@ -6,6 +6,7 @@ import (
"github.com/MizuchiLabs/mantrae/internal/config"
"github.com/MizuchiLabs/mantrae/internal/db"
"github.com/MizuchiLabs/mantrae/internal/util"
)
func ListSettings(sm *config.SettingsManager) http.HandlerFunc {
@@ -49,6 +50,10 @@ func UpsertSetting(sm *config.SettingsManager) http.HandlerFunc {
http.Error(w, err.Error(), http.StatusInternalServerError)
return
}
util.Broadcast <- util.EventMessage{
Type: util.EventTypeUpdate,
Category: util.EventCategorySetting,
}
w.WriteHeader(http.StatusNoContent)
}
}
internal/api/handler/users.go
+6 -9
View File
@@ -66,8 +66,8 @@ func CreateUser(a *config.App) http.HandlerFunc {
return
}
util.Broadcast <- util.EventMessage{
Type: util.EventTypeCreate,
Message: "user",
Type: util.EventTypeCreate,
Category: util.EventCategoryUser,
}
w.WriteHeader(http.StatusCreated)
}
@@ -81,15 +81,13 @@ func UpdateUser(a *config.App) http.HandlerFunc {
http.Error(w, err.Error(), http.StatusInternalServerError)
return
}
if err := q.UpdateUser(r.Context(), user); err != nil {
http.Error(w, err.Error(), http.StatusInternalServerError)
return
}
util.Broadcast <- util.EventMessage{
Type: util.EventTypeUpdate,
Message: "user",
Type: util.EventTypeUpdate,
Category: util.EventCategoryUser,
}
w.WriteHeader(http.StatusNoContent)
}
@@ -107,10 +105,9 @@ func DeleteUser(a *config.App) http.HandlerFunc {
http.Error(w, err.Error(), http.StatusInternalServerError)
return
}
util.Broadcast <- util.EventMessage{
Type: util.EventTypeDelete,
Message: "user",
Type: util.EventTypeDelete,
Category: util.EventCategoryUser,
}
w.WriteHeader(http.StatusNoContent)
}