sourceadmin

type Cache struct {
	Used     int64 `json:"used"`
	Budget   int64 `json:"budget"`
	Hits     int64 `json:"hits"`
	HotBytes int64 `json:"hotBytes"`
}

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

type ClientOptions struct {
	Guard *nodewire.Guard
	Peer  nodewire.Identity
	// Endpoint is an explicit origin (https://host:port), never caller input.
	Endpoint string
	// Authorize checks current exact local server and target source roles and
	// current resource eligibility before each dial. Guard additionally checks
	// fresh remote incarnation/revocation before any HTTP headers are sent.
	Authorize func(context.Context, nodewire.Identity, Request) error
	Timeout   time.Duration
}

type Diagnostics struct {
	Providers []Provider      `json:"providers"`
	Indexers  []Indexer       `json:"indexers"`
	Cache     *Cache          `json:"cache,omitempty"`
	Stream    *Stream         `json:"stream,omitempty"`
	Sources   []SourceStartup `json:"sources,omitempty"`
}

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

type Indexer struct {
	Slot           int   `json:"slot"`
	HitsUsed       int   `json:"hitsUsed"`
	HitsRemaining  int   `json:"hitsRemaining"`
	GrabsUsed      int   `json:"grabsUsed"`
	GrabsRemaining int   `json:"grabsRemaining"`
	RetryAt        int64 `json:"retryAt"`
	Enabled        bool  `json:"enabled"`
	Torrent        bool  `json:"torrent"`
}

type Operation string

type Options struct {
	Guard *nodewire.Guard
	Local nodewire.Identity
	// Authorize MUST freshly check exact caller boot/node has server role,
	// local boot/node has source role, and the operation's source/resource
	// remains eligible in current shared config. Unavailable policy denies.
	Authorize func(context.Context, nodewire.Identity, nodewire.Identity, Request) error
	// VerifyOwner independently checks the ORIGINAL opaque credential with
	// real current owner authority. No delegated/viewer/setup bypass is valid.
	VerifyOwner func(context.Context, string) error
	Services    Services
	Timeout     time.Duration
}

type Protocol string

type Provider struct {
	// Slot indexes the CURRENT shared-config list, not an arbitrary label/host.
	Slot              int    `json:"slot"`
	State             Status `json:"state"`
	MaxConnections    int    `json:"maxConnections"`
	LiveConnections   int    `json:"liveConnections"`
	ActiveConnections int    `json:"activeConnections"`
	NodeShare         int    `json:"nodeShare"`
}

type Query struct {
	Limit   int   `json:"limit"`
	TitleID int64 `json:"titleID,omitempty"`
}

type Release struct {
	HistoryID   int64  `json:"historyID,omitempty"`
	TitleID     int64  `json:"titleID"`
	AtUnixMilli int64  `json:"atUnixMilli,omitempty"`
	Size        int64  `json:"size"`
	Height      int    `json:"height,omitempty"`
	State       Status `json:"state"`
	Pinned      bool   `json:"pinned"`
	Automatic   bool   `json:"automatic"`
}

type Request struct {
	Operation  Operation `json:"operation"`
	RequestID  string    `json:"requestID"`
	ResourceID string    `json:"resourceID,omitempty"`
	Payload    *Query    `json:"payload,omitempty"`
}

type Response struct {
	Diagnostics *Diagnostics `json:"diagnostics,omitempty"`
	Cache       *Cache       `json:"cache,omitempty"`
	Traces      []Trace      `json:"traces,omitempty"`
	Releases    []Release    `json:"releases,omitempty"`
	Tested      bool         `json:"tested,omitempty"`
}

type Services struct {
	Snapshot       func(context.Context, int) (Diagnostics, error)
	TestProvider   func(context.Context, string) error
	TestIndexer    func(context.Context, string) error
	TestDebrid     func(context.Context, string) error
	Traces         func(context.Context, Query) ([]Trace, error)
	CacheStatus    func(context.Context, string) (Cache, error)
	ReleaseHistory func(context.Context, Query) ([]Release, error)
	Variants       func(context.Context, Query) ([]Release, error)
}

type SourceStartup struct {
	Protocol      Protocol `json:"protocol"`
	AverageMillis int64    `json:"averageMillis"`
	LastMillis    int64    `json:"lastMillis"`
	Samples       int64    `json:"samples"`
}

type Status string

type Stream struct {
	Fetches       int64 `json:"fetches"`
	FetchedBytes  int64 `json:"fetchedBytes"`
	Missing       int64 `json:"missing"`
	ActiveSources int64 `json:"activeSources"`
	OpenReleases  int   `json:"openReleases"`
}

type Trace struct {
	TitleID           int64  `json:"titleID"`
	AtUnixMilli       int64  `json:"atUnixMilli"`
	State             Status `json:"state"`
	Candidates        int    `json:"candidates"`
	SearchMillis      int64  `json:"searchMillis"`
	PreparationMillis int64  `json:"preparationMillis"`
	TotalMillis       int64  `json:"totalMillis"`
	Failover          bool   `json:"failover"`
	Pinned            bool   `json:"pinned"`
}