federation

type Config struct {
	Store        *Store
	Relays       RelaySource
	Version      string
	SyncInterval time.Duration
	Log          *slog.Logger
	// InboundToken is the bearer token peers must present to this panel's
	// federation endpoints (RDPANEL_FEDERATION_TOKEN). Empty refuses all.
	InboundToken string
	// AllowPrivate reports whether peers may live on private, loopback or
	// link-local addresses (the relays "allow private hosts" option).
	// nil: never.
	AllowPrivate func(context.Context) bool
	// HTTPClient overrides the outgoing client (tests). The default refuses
	// private addresses at dial time (unless AllowPrivate), ignores proxy
	// variables and does not follow redirects.
	HTTPClient *http.Client
	// Lookup resolves peer host names for the registration check
	// (default net.DefaultResolver.LookupNetIP).
	Lookup func(ctx context.Context, network, host string) ([]netip.Addr, error)
}

type CreatePeerInput struct {
	Name       string
	APIURL     string
	AuthToken  string
	SyncRelays bool
}

type FederatedRelay struct {
	ID         int64     `json:"id"`
	PeerID     int64     `json:"peer_id"`
	PeerName   string    `json:"peer_name,omitempty"`
	RemoteName string    `json:"remote_name"`
	PublicHost string    `json:"public_host"`
	Region     string    `json:"region,omitempty"`
	Health     string    `json:"health"`
	LastSyncAt time.Time `json:"last_sync_at"`
}

type HealthDTO struct {
	Status        string `json:"status"`
	Version       string `json:"version"`
	ActiveRelays  int    `json:"active_relays"`
	TimestampNano int64  `json:"timestamp_nano"`
}

type Peer struct {
	ID         int64      `json:"id"`
	Name       string     `json:"name"`
	APIURL     string     `json:"api_url"`
	TokenHash  string     `json:"-"`
	SyncRelays bool       `json:"sync_relays"`
	Status     PeerStatus `json:"status"`
	LastSyncAt *time.Time `json:"last_sync_at,omitempty"`
	LastError  *string    `json:"last_error,omitempty"`
	CreatedAt  time.Time  `json:"created_at"`
	UpdatedAt  time.Time  `json:"updated_at"`
}

type PeerStatus string

type PublicRelayDTO struct {
	Name       string `json:"name"`
	PublicHost string `json:"public_host"`
	Region     string `json:"region,omitempty"`
	Health     string `json:"health"`
}

type RelaySource interface {
	List(ctx context.Context) ([]relays.View, relays.Rotation, error)
}

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

type Store struct {
	DB *db.DB
	// AEAD seals peer tokens (required by Create and Token).
	AEAD *crypto.AEAD
	Now  func() time.Time
}