delivery

type Attempt struct {
	EndpointID  string
	WorkspaceID string
	EventType   eventcontract.Type
	Attempt     int
	Status      Status
	StatusCode  int
	ErrorClass  ErrorClass
	Error       string
	Retry       bool
	NextRetryAt *time.Time
	Evidence    Evidence
	RecordedAt  time.Time
}

type Clock interface {
	Now() time.Time
}

type Endpoint struct {
	ID             string
	WorkspaceID    string
	URL            string
	Disabled       bool
	DisabledReason string
}

type ErrorClass string

type Evidence struct {
	EndpointID  string
	EndpointURL string
	WorkspaceID string
	EventType   eventcontract.Type
	Status      Status
	StatusCode  int
	ErrorClass  ErrorClass
	Attempt     int
	NextRetryAt *time.Time
}

type HTTPClient interface {
	PostWebhook(ctx context.Context, req HTTPRequest) (HTTPResponse, error)
}

type HTTPRequest struct {
	URL     string
	Body    string
	Headers map[string]string
}

type HTTPResponse struct {
	StatusCode int
}

type Request struct {
	WorkspaceID string
	Event       eventcontract.Event
	Attempt     int
}

type Result struct {
	EndpointID  string
	WorkspaceID string
	EventType   eventcontract.Type
	Attempt     int
	Status      Status
	StatusCode  int
	ErrorClass  ErrorClass
	Error       string
	Retry       bool
	NextRetryAt *time.Time
	Evidence    Evidence
}

type Status string

type Store interface {
	ListWebhookDeliveryEndpoints(ctx context.Context, workspaceID string) ([]Endpoint, error)
	RecordWebhookDelivery(ctx context.Context, attempt Attempt) error
	DisableWebhookDeliveryEndpoint(ctx context.Context, endpoint Endpoint, reason string, now time.Time) error
}

type Worker struct {
	Store       Store
	Client      HTTPClient
	Clock       Clock
	Secret      string
	MaxAttempts int
	Backoff     func(attempt int) time.Duration
}