mirror of
https://tangled.org/evan.jarrett.net/at-container-registry
synced 2026-04-22 17:30:33 +00:00
48 lines
1.9 KiB
Go
48 lines
1.9 KiB
Go
package storage
|
|
|
|
import (
|
|
"context"
|
|
|
|
"atcr.io/pkg/atproto"
|
|
"atcr.io/pkg/auth"
|
|
"atcr.io/pkg/auth/oauth"
|
|
"atcr.io/pkg/auth/proxy"
|
|
)
|
|
|
|
// DatabaseMetrics interface for tracking pull/push counts and querying hold DIDs
|
|
type DatabaseMetrics interface {
|
|
IncrementPullCount(did, repository string) error
|
|
IncrementPushCount(did, repository string) error
|
|
GetLatestHoldDIDForRepo(did, repository string) (string, error)
|
|
}
|
|
|
|
// ReadmeCache interface for README content caching
|
|
type ReadmeCache interface {
|
|
Get(ctx context.Context, url string) (string, error)
|
|
Invalidate(url string) error
|
|
}
|
|
|
|
// RegistryContext bundles all the context needed for registry operations
|
|
// This includes both per-request data (DID, hold) and shared services
|
|
type RegistryContext struct {
|
|
// Per-request identity and routing information
|
|
DID string // User's DID (e.g., "did:plc:abc123")
|
|
Handle string // User's handle (e.g., "alice.bsky.social")
|
|
HoldDID string // Hold service DID (e.g., "did:web:hold01.atcr.io")
|
|
PDSEndpoint string // User's PDS endpoint URL
|
|
Repository string // Image repository name (e.g., "debian")
|
|
ServiceToken string // Service token for hold authentication (cached by middleware)
|
|
ATProtoClient *atproto.Client // Authenticated ATProto client for this user
|
|
AuthMethod string // Auth method used ("oauth", "app_password", "service_token")
|
|
|
|
// Proxy assertion support (for CI and performance optimization)
|
|
ProxyAsserter *proxy.Asserter // Creates proxy assertions (nil if not configured)
|
|
HoldTrusted bool // Whether hold trusts AppView (has did:web:atcr.io in trustedProxies)
|
|
|
|
// Shared services (same for all requests)
|
|
Database DatabaseMetrics // Metrics tracking database
|
|
Authorizer auth.HoldAuthorizer // Hold access authorization
|
|
Refresher *oauth.Refresher // OAuth session manager
|
|
ReadmeCache ReadmeCache // README content cache
|
|
}
|