rule

type Action struct {
	NATS     *NATSAction `json:"nats,omitempty" yaml:"nats,omitempty"`
	HTTP     *HTTPAction `json:"http,omitempty" yaml:"http,omitempty"`
	RuleName string      `json:"-" yaml:"-"`
	TraceID  string      `json:"-" yaml:"-"`
}

type CompiledPattern struct {
	// contains filtered or unexported fields
}

type Condition struct {
	Field    string      `json:"field" yaml:"field"`                     // Template: "{temperature}" or "{@time.hour}"
	Operator string      `json:"operator" yaml:"operator"`               // eq, gt, contains, etc.
	Value    interface{} `json:"value,omitempty" yaml:"value,omitempty"` // Literal or template: 30 or "{@kv.config:max_temp}"

	// For array operators (any/all/none) - nested conditions to evaluate against array elements
	Conditions *Conditions `json:"conditions,omitempty" yaml:"conditions,omitempty"`
}

type Conditions struct {
	Operator string       `json:"operator" yaml:"operator"` // "and" or "or"
	Items    []Condition  `json:"items" yaml:"items"`
	Groups   []Conditions `json:"groups,omitempty" yaml:"groups,omitempty"` // For nested condition groups
}

type Debouncer struct {
	// contains filtered or unexported fields
}

type ElementError struct {
	Index     int
	ErrorType string
	Error     error
}

type EvaluationContext struct {
	// Message data
	Msg        map[string]interface{} // CURRENT context (root message OR array element during forEach)
	RawPayload []byte
	Headers    map[string]string

	// Original message reference for @msg prefix
	// ALWAYS points to root message, even when Msg points to array element
	OriginalMsg map[string]interface{}

	// Context (NATS or HTTP, one will be nil)
	Subject *SubjectContext
	HTTP    *HTTPRequestContext

	// Shared contexts
	Time *TimeContext
	KV   *KVContext
	// contains filtered or unexported fields
}

type Evaluator struct {
	// contains filtered or unexported fields
}

type ForEachResult struct {
	TotalElements     int
	ProcessedElements int
	FilteredElements  int
	FailedElements    int
	Errors            []ElementError
}

type HTTPAction struct {
	URL         string            `json:"url" yaml:"url"`
	Method      string            `json:"method" yaml:"method"`
	Payload     string            `json:"payload,omitempty" yaml:"payload,omitempty"`
	Passthrough bool              `json:"passthrough,omitempty" yaml:"passthrough,omitempty"`
	Headers     map[string]string `json:"headers,omitempty" yaml:"headers,omitempty"`
	RawPayload  []byte            `json:"-" yaml:"-"` // Populated during processing
	Retry       *RetryConfig      `json:"retry,omitempty" yaml:"retry,omitempty"`

	// Array iteration fields for forEach functionality
	// ForEach must use template syntax: "{arrayField}" or "{nested.array}" or "{@items}"
	ForEach string      `json:"forEach,omitempty" yaml:"forEach,omitempty"`
	Filter  *Conditions `json:"filter,omitempty" yaml:"filter,omitempty"`
}

type HTTPRequestContext struct {
	Path       string   // Full path: "/webhooks/github/pr"
	PathTokens []string // Tokens: ["webhooks", "github", "pr"]
	Method     string   // HTTP method: "POST", "GET", etc.
	Count      int      // Token count
}

type HTTPTrigger struct {
	Path   string `json:"path" yaml:"path"`
	Method string `json:"method,omitempty" yaml:"method,omitempty"` // Optional, defaults to all methods
}

type IndexStats struct {
	// contains filtered or unexported fields
}

type JSONPathTraverser struct {
}

type KVContext struct {
	// contains filtered or unexported fields
}

type LocalKVCache struct {
	// contains filtered or unexported fields
}

type MockTimeProvider struct {
	// contains filtered or unexported fields
}

type NATSAction struct {
	Subject     string            `json:"subject" yaml:"subject"`
	Mode        string            `json:"mode,omitempty" yaml:"mode,omitempty"`
	Payload     string            `json:"payload,omitempty" yaml:"payload,omitempty"`
	Passthrough bool              `json:"passthrough,omitempty" yaml:"passthrough,omitempty"`
	Headers     map[string]string `json:"headers,omitempty" yaml:"headers,omitempty"`
	RawPayload  []byte            `json:"-" yaml:"-"` // Populated during processing

	// Array iteration fields for forEach functionality
	// ForEach must use template syntax: "{arrayField}" or "{nested.array}" or "{@items}"
	ForEach string      `json:"forEach,omitempty" yaml:"forEach,omitempty"`
	Filter  *Conditions `json:"filter,omitempty" yaml:"filter,omitempty"`
}

type NATSTrigger struct {
	Subject string `json:"subject" yaml:"subject"`
}

type PatternCache struct {
	// contains filtered or unexported fields
}

type PatternMatcher struct {
	// contains filtered or unexported fields
}

type PatternRule struct {
	Rule    *Rule
	Matcher *PatternMatcher
}

type Processor struct {
	// contains filtered or unexported fields
}

type ProcessorStats struct {
	Processed uint64
	Matched   uint64
	Errors    uint64
}

type RetryConfig struct {
	MaxAttempts  int    `json:"maxAttempts" yaml:"maxAttempts"`
	InitialDelay string `json:"initialDelay" yaml:"initialDelay"` // e.g., "1s"
	MaxDelay     string `json:"maxDelay" yaml:"maxDelay"`         // e.g., "30s"
}

type Rule struct {
	Name             string        `json:"name,omitempty" yaml:"name,omitempty"`
	Trigger          Trigger       `json:"trigger" yaml:"trigger"`
	Conditions       *Conditions   `json:"conditions,omitempty" yaml:"conditions,omitempty"`
	Action           Action        `json:"action" yaml:"action"`
	Debounce         string        `json:"debounce,omitempty" yaml:"debounce,omitempty"`
	DebounceDuration time.Duration `json:"-" yaml:"-"`
}

type RuleIndex struct {
	// contains filtered or unexported fields
}

type RulesLoader struct {
	// contains filtered or unexported fields
}

type SignatureVerification struct {
	Enabled         bool
	PublicKeyHeader string
	SignatureHeader string
}

type SubjectContext struct {
	Full   string   `json:"full"`   // Full subject: "sensors.temperature.room1"
	Tokens []string `json:"tokens"` // Split tokens: ["sensors", "temperature", "room1"]
	Count  int      `json:"count"`  // Token count: 3
}

type SystemTimeProvider struct{}

type TemplateEngine struct {
	// contains filtered or unexported fields
}

type TimeContext struct {
	// contains filtered or unexported fields
}

type TimeProvider interface {
	GetCurrentContext() *TimeContext
	GetContextAt(time.Time) *TimeContext
}

type Trigger struct {
	NATS *NATSTrigger `json:"nats,omitempty" yaml:"nats,omitempty"`
	HTTP *HTTPTrigger `json:"http,omitempty" yaml:"http,omitempty"`
}

type WildcardType int