webhook

type Actor struct {
	PrincipalID string `json:"principal_id"`
	Name        string `json:"name"`
}

type Create struct {
	Name        string
	URL         string
	Description string
	Secret      string
	Events      []string
}

type Delivery struct {
	OrganizationID   string
	ProjectID        string
	ID               string
	WebhookID        string
	EventID          string
	Operation        string
	Status           string
	AttemptCount     int
	FirstAttemptedAt *time.Time
	LastAttemptedAt  *time.Time
	NextAttemptAt    *time.Time
	ResponseCode     *int
	Detail           *string
	CreatedAt        time.Time
}

type Dialer interface {
	DialContext(context.Context, string, string) (net.Conn, error)
}

type DispatchRepository interface {
	ListWebhookProjects(context.Context) ([]Project, error)
	GetNextWebhookOutboxEvent(context.Context, Project, time.Time) (*OutboxEvent, error)
	ListWebhookEventDeliveries(context.Context, Project, string) ([]Delivery, error)
	GetWebhook(context.Context, string, string, string) (*Record, error)
	RecordWebhookDeliveryAttempt(context.Context, Delivery) error
	ScheduleWebhookOutboxEvent(context.Context, Project, string, time.Time) error
	DeleteWebhookOutboxEvent(context.Context, Project, string) error
}

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

type Envelope struct {
	EventID        string          `json:"event_id"`
	OccurredAt     time.Time       `json:"occurred_at"`
	OrganizationID string          `json:"organization_id"`
	ProjectID      string          `json:"project_id,omitempty"`
	Operation      string          `json:"operation"`
	Target         Target          `json:"target"`
	Actor          Actor           `json:"actor"`
	Payload        json.RawMessage `json:"payload"`
}

type OutboxEvent struct {
	Envelope
	AvailableAt time.Time
}

type Project struct {
	OrganizationID string
	ProjectID      string
}

type Record struct {
	OrganizationID        string
	ProjectID             string
	ID                    string
	Name                  string
	URL                   string
	Description           string
	SealedSecret          []byte
	Events                []string
	State                 string
	LastVerificationAt    *time.Time
	LastVerificationError *string
	CreatedAt             time.Time
	UpdatedAt             time.Time
}

type Repository interface {
	CreateWebhook(context.Context, Record) (*Record, error)
	GetWebhook(context.Context, string, string, string) (*Record, error)
	ListWebhooks(context.Context, string, string) ([]Record, error)
	UpdateWebhook(context.Context, Record) (*Record, error)
	DeleteWebhook(context.Context, string, string, string) error
	RecordWebhookVerification(context.Context, Record, string, string, *int, *string, time.Time) (*Record, error)
	ListWebhookDeliveries(context.Context, string, string, string) ([]Delivery, error)
}

type Resolver interface {
	LookupNetIP(context.Context, string, string) ([]netip.Addr, error)
}

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

type Target struct {
	Type        string `json:"type"`
	Bucket      string `json:"bucket,omitempty"`
	Fingerprint string `json:"fingerprint,omitempty"`
	Name        string `json:"name,omitempty"`
}

type Update struct {
	Name        *string
	URL         *string
	Description *string
	Secret      *string
	Events      *[]string
}