subscriber

type CertSource interface {
	GetCert(ctx context.Context, instance uint64) (*certs.FinalityCertificate, error)
	GetLatest(ctx context.Context) (*certs.FinalityCertificate, error)
}

type JSONRPCSource struct {
	URL    string
	Client *http.Client
}

type Options struct {
	// Anchor is the embedded F3 trust anchor (Instance, committee).
	Anchor *anchor.Anchor
	// Manifest is the F3 network manifest (NetworkName).
	Manifest *manifest.Manifest
	// Source is the cert source (Forest/Lotus RPC).
	Source CertSource
	// DB is an optional BadgerDB for persistence of (instance, powerTable).
	DB *badger.DB
}

type PeerProvider interface {
	// Peers returns the currently known-good Lantern beacon set. May
	// return an empty slice during cold start; callers handle that by
	// falling back to the JSON-RPC fallback.
	Peers() []peer.AddrInfo
}

type State struct {
	NetworkName gpbft.NetworkName
	Instance    uint64                     // next instance to verify
	PowerTable  gpbft.PowerEntries         // committee at Instance
	Latest      *certs.FinalityCertificate // most recently verified cert
	LatestChain *gpbft.ECChain             // its EC chain (head = finalized)
}

type StaticPeerProvider []peer.AddrInfo

type Stats struct {
	CertsVerified uint64
	LastInstance  uint64
	LatestFinalEp int64
	LastError     string
}

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

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

type SwarmConfig struct {
	// Host is the libp2p host used to dial Lantern beacons.
	Host host.Host
	// NetworkName is the F3 network name baked into the protocol id.
	// Defaults to "filecoin" (mainnet).
	NetworkName string
	// Provider returns the current pool of Lantern beacons.
	Provider PeerProvider
	// Fallback is the CertSource used when no swarm peer answers in time
	// or when all answers are stale. Typically a JSONRPCSource pointing
	// at Glif or a sibling Forest/Lotus.
	Fallback CertSource
	// PerPeerTimeout caps each libp2p call. Default 4s.
	PerPeerTimeout time.Duration
	// StaleAfter declares a swarm answer stale and triggers a fallback
	// when the cert's timestamp is older than this. Default 5 minutes.
	StaleAfter time.Duration
}

type SwarmStats struct {
	LastUpstream string // human-readable, e.g. "libp2p:12D3Koo..." or "fallback"
	TotalCalls   uint64
	SwarmHits    uint64
	SwarmMisses  uint64
	FallbackHits uint64
}