notify

type Event struct {
	Type      EventType      `json:"type"`
	RunID     string         `json:"run_id"`
	FlowID    string         `json:"flow_id"`
	NodeID    string         `json:"node_id,omitempty"`
	Message   string         `json:"message"`
	Severity  string         `json:"severity"` // SeverityInfo, SeverityWarning, SeverityError
	Timestamp time.Time      `json:"timestamp"`
	Metadata  map[string]any `json:"metadata,omitempty"`
}

type EventType string

type LogNotifier struct {
	Logger *slog.Logger
}

type MultiNotifier struct {
	Notifiers []Notifier
	Logger    *slog.Logger
}

type NopNotifier struct{}

type Notifier interface {
	// Notify sends a notification. Implementations should be non-blocking
	// and handle errors gracefully (log, don't crash).
	Notify(ctx context.Context, event Event) error
}

type SlackNotifier struct {
	WebhookURL string
	Channel    string
	Username   string
	Client     *http.Client
}

type SlackOption func(*SlackNotifier)

type WebhookNotifier struct {
	URL     string
	Headers map[string]string
	Client  *http.Client
}