TyleoDvDelaware3217/GoDoxy
1
0
Fork 0
mirror of https://github.com/yusing/godoxy.git synced 2025-07-22 20:24:03 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix: remove redundant event logging

Browse source
This commit is contained in:
yusing 2025-04-28 05:03:17 +08:00
parent 22a12d3116
commit 21c9e46274
1 changed files with 3 additions and 19 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

22
internal/route/provider/event_handler.go
View file

@ -12,19 +12,13 @@ import (
type EventHandler struct { type EventHandler struct {
provider *Provider provider *Provider
errs *gperr.Builder errs *gperr.Builder
added *gperr.Builder
removed *gperr.Builder
updated *gperr.Builder
} }
func (p *Provider) newEventHandler() *EventHandler { func (p *Provider) newEventHandler() *EventHandler {
return &EventHandler{ return &EventHandler{
provider: p, provider: p,
errs: gperr.NewBuilder("event errors"), errs: gperr.NewBuilder("event errors"),
added: gperr.NewBuilder("added"),
removed: gperr.NewBuilder("removed"),
updated: gperr.NewBuilder("updated"),
} }
} }
@ -88,15 +82,12 @@ func (handler *EventHandler) Add(parent task.Parent, route *route.Route) {
err := handler.provider.startRoute(parent, route) err := handler.provider.startRoute(parent, route)
if err != nil { if err != nil {
handler.errs.Add(err.Subject("add")) handler.errs.Add(err.Subject("add"))
} else {
handler.added.Adds(route.Alias)
} }
} }
func (handler *EventHandler) Remove(route *route.Route) { func (handler *EventHandler) Remove(route *route.Route) {
route.Finish("route removed") route.Finish("route removed")
delete(handler.provider.routes, route.Alias) delete(handler.provider.routes, route.Alias)
handler.removed.Adds(route.Alias)
} }
func (handler *EventHandler) Update(parent task.Parent, oldRoute *route.Route, newRoute *route.Route) { func (handler *EventHandler) Update(parent task.Parent, oldRoute *route.Route, newRoute *route.Route) {
@ -104,18 +95,11 @@ func (handler *EventHandler) Update(parent task.Parent, oldRoute *route.Route, n
err := handler.provider.startRoute(parent, newRoute) err := handler.provider.startRoute(parent, newRoute)
if err != nil { if err != nil {
handler.errs.Add(err.Subject("update")) handler.errs.Add(err.Subject("update"))
} else {
handler.updated.Adds(newRoute.Alias)
} }
} }
func (handler *EventHandler) Log() { func (handler *EventHandler) Log() {
results := gperr.NewBuilder("event occurred") if err := handler.errs.Error(); err != nil {
results.AddFrom(handler.added, false) handler.provider.Logger().Info().Msg(err.Error())
results.AddFrom(handler.removed, false)
results.AddFrom(handler.updated, false)
results.AddFrom(handler.errs, false)
if result := results.String(); result != "" {
handler.provider.Logger().Info().Msg(result)
} }
} }