webhook

type AttemptLog struct {
	Attempt    int
	Timestamp  time.Time
	StatusCode int
	Error      string
	Duration   time.Duration
}

type BuiltInFormat string

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

type DeadLetter struct {
	Delivery   Delivery
	FailedAt   time.Time
	LastError  string
	AttemptLog []AttemptLog
}

type Delivery struct {
	ID        string
	Event     Event
	Webhook   *WebhookConfig
	Attempt   int
	NextRetry time.Time
	Error     error
}

type Event struct {
	ID        string            `json:"id"`
	Type      string            `json:"type"`
	Timestamp time.Time         `json:"timestamp"`
	Session   string            `json:"session,omitempty"`
	Pane      string            `json:"pane,omitempty"`
	Agent     string            `json:"agent,omitempty"`
	Message   string            `json:"message"`
	Details   map[string]string `json:"details,omitempty"`
}

type ManagerConfig struct {
	QueueSize       int           `toml:"queue_size" json:"queue_size"`
	WorkerCount     int           `toml:"worker_count" json:"worker_count"`
	DefaultTimeout  time.Duration `toml:"default_timeout" json:"default_timeout,omitempty"`
	DeadLetterLimit int           `toml:"dead_letter_limit" json:"dead_letter_limit"`
}

type RetryConfig struct {
	Enabled    bool          `toml:"enabled" json:"enabled"`
	MaxRetries int           `toml:"max_retries" json:"max_retries"`
	BaseDelay  time.Duration `toml:"base_delay" json:"base_delay,omitempty"`
	MaxDelay   time.Duration `toml:"max_delay" json:"max_delay,omitempty"`
}

type Stats struct {
	QueueLength     int   `json:"queue_length"`
	QueueCapacity   int   `json:"queue_capacity"`
	RetryQueueLen   int   `json:"retry_queue_length"`
	DeadLetterCount int   `json:"dead_letter_count"`
	Deliveries      int64 `json:"total_deliveries"`
	Failures        int64 `json:"total_failures"`
	DroppedEvents   int64 `json:"dropped_events"`
	WebhookCount    int   `json:"webhook_count"`
}

type WebhookConfig struct {
	ID       string `toml:"id" json:"id"`
	Name     string `toml:"name" json:"name"`
	URL      string `toml:"url" json:"url"`
	Method   string `toml:"method" json:"method"`     // HTTP method (default POST)
	Template string `toml:"template" json:"template"` // Go template for payload
	// Format selects a built-in JSON payload formatter when Template is empty.
	// Supported: json, slack, discord, teams.
	Format  string            `toml:"format" json:"format"`
	Headers map[string]string `toml:"headers" json:"headers"`
	Events  []string          `toml:"events" json:"events"` // Event types to receive (empty = all)
	Enabled bool              `toml:"enabled" json:"enabled"`

	// Per-webhook timeout (overrides default)
	Timeout time.Duration `toml:"timeout" json:"timeout,omitempty"`

	// Retry configuration
	Retry RetryConfig `toml:"retry" json:"retry"`

	// HMAC signing configuration
	Secret string `toml:"secret" json:"secret,omitempty"` // HMAC-SHA256 secret
}

type WebhookManager struct {

	// Logging callback (optional)
	Logger func(format string, args ...interface{})
	// contains filtered or unexported fields
}