servicedisc

type CoinInfo struct {
	// BlockchainPubKey is the block-publisher public key that signs this chain —
	// the AUTHORITATIVE, cryptographic chain identifier. A wallet must verify it
	// is on the intended chain by THIS key, not by the human name, so a node can
	// never spoof another chain by calling itself "skycoin".
	BlockchainPubKey string `json:"blockchain_pubkey,omitempty"`
	// GenesisAddress + GenesisSignature anchor the chain's genesis block — an
	// independent identity check beyond the block-publisher key.
	GenesisAddress   string `json:"genesis_address,omitempty"`
	GenesisSignature string `json:"genesis_signature,omitempty"`
	// Fiber is the human-readable coin name (e.g. "skycoin", "mdl") for display +
	// coarse filtering ONLY — never the trust anchor; BlockchainPubKey is.
	Fiber string `json:"fiber,omitempty"`
	// Network is the coin network — "main" or "test".
	Network string `json:"network,omitempty"`
	// Version + Commit identify the DAEMON's OWN build, as reported by its HTTP
	// API (skycoin /api/v1/health -> version{version, commit}). This is
	// deliberately NOT the visor's compiled-in skycoin import (`skywire -d`): the
	// daemon runs independently, so its build can differ from the visor's, and the
	// advertisement must reflect the ACTUAL running node. Commit pins the exact
	// build precisely.
	Version string `json:"version,omitempty"`
	Commit  string `json:"commit,omitempty"`
	// HeadSeq is the current block-head sequence, so a wallet can prefer a
	// well-synced node. Also a freshness signal alongside the SD re-registration.
	HeadSeq uint64 `json:"head_seq,omitempty"`
}

type Config struct {
	Type          string
	PK            cipher.PubKey
	SK            cipher.SecKey
	Port          uint16
	DiscAddr      string
	DisplayNodeIP bool
	// Geo, when non-nil, is attached to the entry on Register/Update.
	// The service-discovery server short-circuits its own IP→geo HTTP
	// lookup when the entry already carries Geo, so a visor that does
	// its own geoip lookup (via dmsg-server LookupIPGeo or the visor's
	// embedded MaxMind DB) eliminates the SD→geoip-service round-trip.
	Geo *geo.LocationData
	// GeoFunc, when non-nil, returns the visor's CURRENT geolocation and is
	// re-read on every RegisterEntry (heartbeat). This is what makes geo
	// RELIABLE: the visor's geoip lookup is async and usually finishes AFTER
	// the first registration, so a fixed Geo snapshot (captured at NewClient)
	// permanently registered with no country whenever it lost that race. With
	// GeoFunc, the next heartbeat after the lookup completes carries the country.
	GeoFunc func() *geo.LocationData
	// PublicIPFunc, when non-nil, returns the visor's current public IP. It is
	// re-read on every registration and request, so the entry and the
	// SW-PublicIP header follow the visor to a new network.
	PublicIPFunc func() string
	// Sink, when non-nil, is handed a copy of every entry this client
	// successfully registers, and of every entry it deregisters. It is how
	// the visor's SD-registration-over-CXO publisher learns its own live
	// service set VERBATIM — the exact Service the SD accepted and echoed
	// back, not a reconstruction. Purely additive: the HTTP register/delete
	// calls are unchanged and remain authoritative.
	Sink EntrySink
}

type EntrySink interface {
	// PutEntry records a service entry as live.
	PutEntry(entry Service)
	// DelEntry records a service entry as gone.
	DelEntry(entry Service)
}

type GeoQuery struct {
	Lat        float64
	Lon        float64
	Radius     float64 // Format: <value><unit>
	RadiusUnit string
	Count      int64
}

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

type HTTPError struct {
	HTTPStatus int    `json:"code,omitempty"` // HTTP Status.
	Err        string `json:"error,omitempty"`
}

type KeepaliveSink interface {
	EntrySink
	KeepaliveHealthy() (healthy bool, epoch uint64)
}

type SWAddr [len(cipher.PubKey{}) + 2]byte

type Service struct {
	ID            uint              `json:"-" gorm:"primarykey"`
	CreatedAt     time.Time         `json:"-"`
	Addr          SWAddr            `json:"address"`
	Type          string            `json:"type"`
	Geo           *geo.LocationData `json:"geo,omitempty" gorm:"embedded"`
	DisplayNodeIP bool              `json:"display_node_ip,omitempty"`
	Version       string            `json:"version,omitempty"`
	LocalIPs      []string          `json:"local_ips,omitempty"`
	Info          *VPNInfo          `json:"info,omitempty" gorm:"-"`
	// Coin, set for ServiceTypeCoin entries, carries the fibercoin identity +
	// capabilities so a thin-client wallet can filter discovery by coin/network
	// without launch flags. Transient (gorm:"-"), like Info.
	Coin *CoinInfo `json:"coin,omitempty" gorm:"-"`
}

type ServicesQuery struct {
	Count  int64  // <=0 : no limit
	Cursor uint64 // <=0 : 0 offset
}

type VPNInfo struct {
	Latency     float64 `json:"latency,omitempty"`
	Uptime      float64 `json:"uptime,omitempty"`
	Connections int     `json:"connections,omitempty"`
}