events.go RawHistoryFolder

1package proxy
2
3import (
4	"context"
5
6	"github.com/bnema/zerowrap"
7
8	"github.com/bnema/gordon/internal/domain"
9)
10
11// TargetRefresher defines the interface for refreshing all proxy targets.
12type TargetRefresher interface {
13	RefreshTargets(ctx context.Context) error
14}
15
16// ConfigReloadProxyHandler handles config.reload events to clear the proxy target cache.
17// When routes are removed during a config reload, cached targets for those routes
18// become stale. This handler clears all cached targets so they are re-resolved.
19type ConfigReloadProxyHandler struct {
20	refresher TargetRefresher
21	ctx       context.Context
22}
23
24// NewConfigReloadProxyHandler creates a new ConfigReloadProxyHandler.
25func NewConfigReloadProxyHandler(ctx context.Context, refresher TargetRefresher) *ConfigReloadProxyHandler {
26	return &ConfigReloadProxyHandler{
27		refresher: refresher,
28		ctx:       ctx,
29	}
30}
31
32// Handle clears all cached proxy targets so they are re-resolved from current state.
33func (h *ConfigReloadProxyHandler) Handle(ctx context.Context, event domain.Event) error {
34	ctx = zerowrap.CtxWithFields(ctx, map[string]any{
35		zerowrap.FieldLayer:   "usecase",
36		zerowrap.FieldHandler: "ConfigReloadProxyHandler",
37		zerowrap.FieldEvent:   string(event.Type),
38		"event_id":            event.ID,
39	})
40	log := zerowrap.FromCtx(ctx)
41
42	log.Debug().Msg("clearing proxy target cache after config reload")
43	return h.refresher.RefreshTargets(ctx)
44}
45
46// CanHandle returns whether this handler can handle the given event type.
47func (h *ConfigReloadProxyHandler) CanHandle(eventType domain.EventType) bool {
48	return eventType == domain.EventConfigReload
49}