events.go RawHistoryFolder

1package proxy
2
3import (
4	"context"
5
6	"github.com/bnema/zerowrap"
7
8	"gordon/internal/domain"
9)
10
11// TargetInvalidator defines the interface for invalidating proxy targets.
12type TargetInvalidator interface {
13	InvalidateTarget(ctx context.Context, domainName string)
14}
15
16// ContainerDeployedHandler handles container.deployed events to invalidate proxy cache.
17type ContainerDeployedHandler struct {
18	invalidator TargetInvalidator
19	ctx         context.Context
20}
21
22// NewContainerDeployedHandler creates a new ContainerDeployedHandler.
23func NewContainerDeployedHandler(ctx context.Context, invalidator TargetInvalidator) *ContainerDeployedHandler {
24	return &ContainerDeployedHandler{
25		invalidator: invalidator,
26		ctx:         ctx,
27	}
28}
29
30// Handle handles a container.deployed event by invalidating the proxy cache.
31func (h *ContainerDeployedHandler) Handle(event domain.Event) error {
32	ctx := zerowrap.CtxWithFields(h.ctx, map[string]any{
33		zerowrap.FieldLayer:   "usecase",
34		zerowrap.FieldHandler: "ContainerDeployedHandler",
35		zerowrap.FieldEvent:   string(event.Type),
36		"event_id":            event.ID,
37	})
38	log := zerowrap.FromCtx(ctx)
39
40	// Get domain from event
41	domainName := event.Route
42	if domainName == "" {
43		// Try to get from payload
44		if payload, ok := event.Data.(*domain.ContainerEventPayload); ok {
45			domainName = payload.Domain
46		}
47	}
48
49	if domainName == "" {
50		log.Debug().Msg("no domain in container deployed event, skipping cache invalidation")
51		return nil
52	}
53
54	log.Debug().Str("domain", domainName).Msg("invalidating proxy cache for deployed container")
55	h.invalidator.InvalidateTarget(ctx, domainName)
56
57	return nil
58}
59
60// CanHandle returns whether this handler can handle the given event type.
61func (h *ContainerDeployedHandler) CanHandle(eventType domain.EventType) bool {
62	return eventType == domain.EventContainerDeployed
63}