apikit

type Admin struct {
	Keys          Store
	Hooks         WebhookStore
	Emitter       *Emitter
	AllowedScopes func() []string
	Events        []string
	TokenPrefix   string
	Owner         func(r *http.Request) int64
	Actor         func(r *http.Request) int64
	Audit         func(r *http.Request, action, detail string)
	Seal          func(string) (string, error)
	BaseURL       func(r *http.Request) string
	MaxKeys       int
	MaxHooks      int
}

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

type Config struct {
	Store            Store
	Enabled          func() bool
	ClientIP         func(*http.Request) string
	OnWrite          func(k *Key, r *http.Request, status int)
	DefaultRateLimit int
	RateWindow       time.Duration
	FailLimit        int
	FailWindow       time.Duration
}

type Delivery struct {
	ID         int64
	WebhookID  int64
	EventID    string
	EventType  string
	Attempt    int
	StatusCode int
	OK         bool
	Error      string
	DurationMS int
	CreatedAt  time.Time
}

type DeliveryView struct {
	ID         int64     `json:"id"`
	EventID    string    `json:"event_id"`
	EventType  string    `json:"event_type"`
	Attempt    int       `json:"attempt"`
	StatusCode int       `json:"status_code"`
	OK         bool      `json:"ok"`
	Error      string    `json:"error"`
	DurationMS int       `json:"duration_ms"`
	CreatedAt  time.Time `json:"created_at"`
}

type Emitter struct {
	Hooks        WebhookStore
	Open         func(sealed string) (string, error)
	Client       *http.Client
	Queue        string
	DisableAfter int
	RetryDelays  []time.Duration
}

type ErrorBody struct {
	Code    string `json:"code"`
	Message string `json:"message"`
}

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

type HandlerFunc func(w http.ResponseWriter, r *http.Request, k *Key)

type HookView struct {
	ID        int64     `json:"id"`
	URL       string    `json:"url"`
	Events    []string  `json:"events"`
	Enabled   bool      `json:"enabled"`
	FailCount int       `json:"fail_count"`
	CreatedAt time.Time `json:"created_at"`
}

type Key struct {
	ID         int64
	Label      string
	Prefix     string
	Scopes     []string
	RateLimit  int
	CreatedBy  int64
	CreatedAt  time.Time
	LastUsedAt *time.Time
	LastUsedIP string
	ExpiresAt  *time.Time
	RevokedAt  *time.Time
}

type KeyView struct {
	ID         int64      `json:"id"`
	Label      string     `json:"label"`
	Prefix     string     `json:"prefix"`
	Scopes     []string   `json:"scopes"`
	CreatedAt  time.Time  `json:"created_at"`
	LastUsedAt *time.Time `json:"last_used_at"`
	LastUsedIP string     `json:"last_used_ip"`
	ExpiresAt  *time.Time `json:"expires_at"`
	Revoked    bool       `json:"revoked"`
	Expired    bool       `json:"expired"`
}

type List struct {
	Data       any    `json:"data"`
	NextCursor string `json:"next_cursor,omitempty"`
}

type Op struct {
	Method     string
	Path       string
	Scope      string
	Summary    string
	Tag        string
	Params     []Param
	Request    any
	Response   any
	Status     int
	List       bool
	Idempotent bool
}

type OverviewView struct {
	Keys     []KeyView  `json:"keys"`
	Webhooks []HookView `json:"webhooks"`
	Scopes   []string   `json:"scopes"`
	Events   []string   `json:"events"`
	BaseURL  string     `json:"base_url"`
}

type Page struct {
	Limit  int
	Cursor int64
}

type Param struct {
	Name        string
	In          string
	Description string
	Required    bool
}

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

type SQLStore struct {
	DB *sql.DB
}

type SQLWebhookStore struct {
	DB *sql.DB
}

type SendResult struct {
	StatusCode int
	OK         bool
	Error      string
	Duration   time.Duration
}

type Store interface {
	Insert(ctx context.Context, k Key, hash string) (int64, error)
	Lookup(ctx context.Context, hash string) (*Key, error)
	Touch(ctx context.Context, id int64, ip string, now time.Time) error
	List(ctx context.Context, owner int64) ([]Key, error)
	Revoke(ctx context.Context, id int64, owner int64, now time.Time) (bool, error)
}

type Webhook struct {
	ID        int64
	OwnerID   int64
	URL       string
	SecretEnc string
	Events    []string
	Enabled   bool
	FailCount int
	CreatedAt time.Time
}

type WebhookStore interface {
	Create(ctx context.Context, w Webhook) (int64, error)
	Get(ctx context.Context, id int64) (*Webhook, error)
	List(ctx context.Context, owner int64) ([]Webhook, error)
	ListFor(ctx context.Context, owner int64, eventType string) ([]Webhook, error)
	Delete(ctx context.Context, id, owner int64) (bool, error)
	SetEnabled(ctx context.Context, id, owner int64, enabled bool) (bool, error)
	RecordResult(ctx context.Context, id int64, ok bool, disableAfter int) (bool, error)
	AddDelivery(ctx context.Context, d Delivery) error
	Deliveries(ctx context.Context, webhookID, owner int64, limit int) ([]Delivery, error)
	Prune(ctx context.Context, olderThan time.Time) error
}