webhook

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

type DeliveryCache interface {
	// Has checks if a delivery ID exists in the cache
	Has(deliveryID string) bool

	// Add adds a delivery ID to the cache
	Add(deliveryID string, timestamp time.Time) error

	// GC performs garbage collection on the cache
	GC() error
}

type Event struct {
	Type               string         // GitHub event type
	DeliveryID         string         // GitHub delivery ID
	Payload            map[string]any // Raw event payload
	RawPayload         []byte         // Raw JSON payload
	Headers            http.Header    // HTTP headers
	Action             string         // Action (e.g. "opened", "closed", "edited")
	RepositoryID       int64          // Repository ID
	RepositoryName     string         // Repository name
	RepositoryOwner    string         // Repository owner
	RepositoryFullName string         // Repository full name (owner/name)
	RefName            string         // Reference name (for push events)
	SenderLogin        string         // Sender login
	ReceivedAt         string         // Time when the event was received
}

type Filter struct {
	EventTypes   []string         // Event types to handle
	Repositories []string         // Repositories to handle
	Branches     []string         // Branches to handle
	Actions      []string         // Actions to handle
	Custom       func(Event) bool // Custom filter function
}

type Handler struct {
	ID      string
	Handler HandlerFunc
	Filter  *Filter
}

type HandlerFunc func(ctx context.Context, event Event) error

type IPRange struct {
	CIDR  string
	IPNet *net.IPNet
}

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

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

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

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

type ProcessorConfig struct {
	QueueSize   int
	WorkerCount int
	Logger      observability.Logger
	Metrics     observability.MetricsClient
}

type RetryConfig struct {
	// MaxRetries is the maximum number of retries
	MaxRetries int

	// InitialBackoff is the initial backoff duration
	InitialBackoff time.Duration

	// MaxBackoff is the maximum backoff duration
	MaxBackoff time.Duration

	// BackoffFactor is the factor to multiply backoff on each retry
	BackoffFactor float64

	// Jitter is the jitter factor to randomize backoff
	Jitter float64
}

type RetryFilter struct {
	// DeliveryIDs are the delivery IDs to filter by
	DeliveryIDs []string

	// EventTypes are the event types to filter by
	EventTypes []string

	// Statuses are the statuses to filter by
	Statuses []RetryStatus

	// MinRetryCount is the minimum retry count to filter by
	MinRetryCount int

	// MaxRetryCount is the maximum retry count to filter by
	MaxRetryCount int

	// Since is the minimum creation time to filter by
	Since time.Time

	// Until is the maximum creation time to filter by
	Until time.Time
}

type RetryHandler func(ctx context.Context, event Event) error

type RetryInfo struct {
	// DeliveryID is the GitHub delivery ID
	DeliveryID string

	// EventType is the GitHub event type
	EventType string

	// Event is the parsed webhook event
	Event Event

	// Status is the retry status
	Status RetryStatus

	// RetryCount is the number of retries attempted
	RetryCount int

	// NextRetry is the time of the next retry
	NextRetry time.Time

	// LastError is the error from the last retry attempt
	LastError string

	// CreatedAt is the time when the retry info was created
	CreatedAt time.Time

	// UpdatedAt is the time when the retry info was last updated
	UpdatedAt time.Time
}

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

type RetryStatus string

type RetryStorage interface {
	// Store stores retry information for an event
	Store(ctx context.Context, event Event, status RetryStatus, retryCount int, nextRetry time.Time, err error) error

	// Get gets retry information for an event
	Get(ctx context.Context, deliveryID string) (*RetryInfo, error)

	// List lists all retry information matching a filter
	List(ctx context.Context, filter RetryFilter) ([]*RetryInfo, error)

	// Update updates retry information for an event
	Update(ctx context.Context, info *RetryInfo) error

	// Delete deletes retry information for an event
	Delete(ctx context.Context, deliveryID string) error
}

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

type WebhookEvent struct {
	ID        string
	Type      string
	Payload   []byte
	Timestamp time.Time
	Headers   map[string]string
}

type WebhookHandler interface {
	// HandleEvent handles a webhook event
	HandleEvent(ctx context.Context, event *WebhookEvent) error
}