webhook

type Envelope struct {
	ID        string    `json:"id"`
	Type      EventType `json:"type"`
	CreatedAt time.Time `json:"created_at"`
	Data      any       `json:"data"`
}

type EventType string

type FilteringPublisher struct {
	Inner   Publisher
	Enabled map[string]struct{}
}

type NoopPublisher struct{}

type OrganizationData struct {
	OrganizationID  uuid.UUID  `json:"organization_id"`
	Name            string     `json:"name"`
	Kind            string     `json:"kind"`
	CreatedByUserID *uuid.UUID `json:"created_by_user_id"`
}

type OrganizationInvitationAcceptedData struct {
	InvitationID     uuid.UUID `json:"invitation_id"`
	OrganizationID   uuid.UUID `json:"organization_id"`
	Email            string    `json:"email"`
	Role             string    `json:"role"`
	AcceptedByUserID uuid.UUID `json:"accepted_by_user_id"`
	AcceptedAt       time.Time `json:"accepted_at"`
}

type OrganizationInvitationCreatedData struct {
	InvitationID    uuid.UUID  `json:"invitation_id"`
	OrganizationID  uuid.UUID  `json:"organization_id"`
	Email           string     `json:"email"`
	Role            string     `json:"role"`
	InvitedByUserID *uuid.UUID `json:"invited_by_user_id"`
	ExpiresAt       time.Time  `json:"expires_at"`
}

type OrganizationInvitationRevokedData struct {
	InvitationID    uuid.UUID  `json:"invitation_id"`
	OrganizationID  uuid.UUID  `json:"organization_id"`
	Email           string     `json:"email"`
	Role            string     `json:"role"`
	RevokedByUserID *uuid.UUID `json:"revoked_by_user_id"`
	RevokedAt       time.Time  `json:"revoked_at"`
}

type OrganizationMembershipData struct {
	OrganizationID uuid.UUID `json:"organization_id"`
	UserID         uuid.UUID `json:"user_id"`
	Role           string    `json:"role"`
}

type Publisher interface {
	Publish(ctx context.Context, evt Envelope) error
}

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

type Sender struct {
	URL    string
	Secret string
	Client *http.Client
}

type UserData struct {
	UserID uuid.UUID `json:"user_id"`
}

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

type WorkerConfig struct {
	WorkerCount          int
	PollInterval         time.Duration
	MaxDeliveryAttempts  int
	ProcessingStaleAfter time.Duration
	StaleReaperInterval  time.Duration
	DeliveredRetention   time.Duration
	FailedRetention      time.Duration
	CleanupInterval      time.Duration
	MaintenanceBatchSize int
}